- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for AcceptTCP (0.22 sec)
-
internal/http/listener.go
return false } } // Closure to handle TCPListener until done channel is closed. handleListener := func(idx int, tcpListener *net.TCPListener) { for { tcpConn, err := tcpListener.AcceptTCP() if tcpConn != nil { tcpConn.SetKeepAlive(true) } send(acceptResult{tcpConn, err, idx}) } } // Start separate goroutine for each TCP listener to handle connection.
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
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 } deadlineconn := New(tcpConn) deadlineconn.WithReadDeadline(time.Second) deadlineconn.WithWriteDeadline(time.Second)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0) -
api/go1.txt
pkg net, method (*TCPConn) SetWriteDeadline(time.Time) error pkg net, method (*TCPConn) Write([]uint8) (int, error) pkg net, method (*TCPListener) Accept() (Conn, error) pkg net, method (*TCPListener) AcceptTCP() (*TCPConn, error) pkg net, method (*TCPListener) Addr() Addr pkg net, method (*TCPListener) Close() error pkg net, method (*TCPListener) File() (*os.File, error)
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Wed Aug 14 18:58:28 GMT 2013 - 1.7M bytes - Viewed (1)