- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for tcpListeners (0.17 sec)
-
internal/http/listener.go
} if len(tcpListeners) == 0 { // No listeners initialized, no need to continue return } listener = &httpListener{ tcpListeners: tcpListeners, acceptCh: make(chan acceptResult, len(tcpListeners)), opts: opts, } listener.ctx, listener.ctxCanceler = context.WithCancel(ctx) if opts.Trace != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
t.Fatalf("unable to create listener. %v", err) } defer l.Close() serverAddr := l.Addr().String() tcpListener, ok := l.(*net.TCPListener) if !ok { t.Fatalf("failed to assert to net.TCPListener") } var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() tcpConn, terr := tcpListener.AcceptTCP() if terr != nil { t.Errorf("failed to accept new connection. %v", terr) return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0)