- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for tcpListeners (0.29 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) -
istioctl/pkg/writer/envoy/configdump/listener.go
const ( // HTTPListener identifies a listener as being of HTTP type by the presence of an HTTP connection manager filter HTTPListener = wellknown.HTTPConnectionManager // TCPListener identifies a listener as being of TCP type by the presence of TCP proxy filter TCPListener = wellknown.TCPProxy IPMatcher = "type.googleapis.com/xds.type.matcher.v3.IPMatcher" )
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0)