Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for AcceptTCP (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top