func()

in src/tcp/tcpserver.go [73:92]

• 19 lines of code
• 4 McCabe index (conditional complexity)

func (s *SocketsServer) acceptConnections() {
	_, port, _ := net.SplitHostPort(s.listener.Addr().String())
	log.Println("TCP server listening on:", port)
	defer close(s.StreamDataChan)

	for {
		conn, err := s.listener.Accept()
		if err != nil {
			select {
			case <-s.ctx.Done():
				return
			default:
				log.Println("accept error, retrying...", err.Error())
			}
		} else {
			s.handleConnection(conn)
			return
		}
	}
}