Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for TCPListener (0.27 sec)

  1. 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
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Nov 05 18:09:21 UTC 2022
    - 3K bytes
    - Viewed (0)
  2. 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"
    )
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  3. internal/http/listener.go

    		}
    	}
    
    	// Closure to handle TCPListener until done channel is closed.
    	handleListener := func(idx int, listener net.Listener) {
    		for {
    			conn, err := listener.Accept()
    			send(acceptResult{conn, err, idx})
    		}
    	}
    
    	// Start separate goroutine for each TCP listener to handle connection.
    	for idx, tcpListener := range listener.listeners {
    		go handleListener(idx, tcpListener)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. api/go1.10.txt

    pkg math/big, method (*Float) Sqrt(*Float) *Float
    pkg math/big, method (*Int) CmpAbs(*Int) int
    pkg math/rand, func Shuffle(int, func(int, int))
    pkg math/rand, method (*Rand) Shuffle(int, func(int, int))
    pkg net, method (*TCPListener) SyscallConn() (syscall.RawConn, error)
    pkg net, method (*UnixListener) SyscallConn() (syscall.RawConn, error)
    pkg net/smtp, method (*Client) Noop() error
    pkg os, func IsTimeout(error) bool
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Feb 06 05:00:01 UTC 2018
    - 30.1K bytes
    - Viewed (0)
  5. api/go1.txt

    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)
    pkg net, method (*TCPListener) SetDeadline(time.Time) error
    pkg net, method (*UDPAddr) Network() string
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top