- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for listenTCP (0.14 sec)
-
src/net/mptcpsock_stub.go
return sd.dialTCP(ctx, laddr, raddr) } func (sl *sysListener) listenMPTCP(ctx context.Context, laddr *TCPAddr) (*TCPListener, error) { return sl.listenTCP(ctx, laddr) } func isUsingMultipathTCP(fd *netFD) bool { return false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 18 13:48:22 UTC 2023 - 542 bytes - Viewed (0) -
src/net/mptcpsock_linux.go
return dial, nil } } // Fallback to listenTCP if Multipath TCP isn't supported on this operating // system. But also fallback in case of any error with MPTCP. // // Possible MPTCP specific error: ENOPROTOOPT (sysctl net.mptcp.enabled=0) // But just in case MPTCP is blocked differently (SELinux, etc.), just // retry with "plain" TCP. return sl.listenTCP(ctx, laddr) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 18:48:34 UTC 2023 - 4K bytes - Viewed (0) -
src/net/tcpsock.go
return nil, &OpError{Op: "file", Net: l.fd.net, Source: nil, Addr: l.fd.laddr, Err: err} } return } // ListenTCP acts like [Listen] for TCP networks. // // The network must be a TCP network name; see func Dial for details. // // If the IP field of laddr is nil or an unspecified IP address, // ListenTCP listens on all available unicast and anycast IP addresses // of the local system.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 13.7K bytes - Viewed (0) -
src/net/rpc/server_test.go
newServer.RegisterName("net.rpc.Arith", new(Arith)) newServer.RegisterName("newServer.Arith", new(Arith)) var l net.Listener l, _ = listenTCP() l.Close() newServer.Accept(l) } func TestShutdown(t *testing.T) { var l net.Listener l, _ = listenTCP() ch := make(chan net.Conn, 1) go func() { defer l.Close() c, err := l.Accept() if err != nil { t.Error(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 05:23:29 UTC 2023 - 19K bytes - Viewed (0) -
src/net/tcpsock_plan9.go
return err } return nil } func (ln *TCPListener) file() (*os.File, error) { f, err := ln.dup() if err != nil { return nil, err } return f, nil } func (sl *sysListener) listenTCP(ctx context.Context, laddr *TCPAddr) (*TCPListener, error) { fd, err := listenPlan9(ctx, sl.network, laddr) if err != nil { return nil, err } return &TCPListener{fd: fd, lc: sl.ListenConfig}, nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.3K bytes - Viewed (0) -
src/net/protoconn_test.go
switch runtime.GOOS { case "plan9": t.Skipf("not supported on %s", runtime.GOOS) } la, err := ResolveTCPAddr("tcp4", "127.0.0.1:0") if err != nil { t.Fatal(err) } ln, err := ListenTCP("tcp4", la) if err != nil { t.Fatal(err) } defer ln.Close() ln.Addr() mustSetDeadline(t, ln.SetDeadline, 30*time.Nanosecond) if c, err := ln.Accept(); err != nil { if !err.(Error).Timeout() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 7.4K bytes - Viewed (0) -
src/net/tcpsock_posix.go
return ln.fd.Close() } func (ln *TCPListener) file() (*os.File, error) { f, err := ln.fd.dup() if err != nil { return nil, err } return f, nil } func (sl *sysListener) listenTCP(ctx context.Context, laddr *TCPAddr) (*TCPListener, error) { return sl.listenTCPProto(ctx, laddr, 0) } func (sl *sysListener) listenTCPProto(ctx context.Context, laddr *TCPAddr, proto int) (*TCPListener, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.3K bytes - Viewed (0) -
src/net/listen_test.go
t.Fatalf("panicked: %v", p) } }() if ln, err := Listen("tcp", ""); err == nil { ln.Close() } if ln, err := ListenPacket("udp", ""); err == nil { ln.Close() } if ln, err := ListenTCP("tcp", nil); err == nil { ln.Close() } if ln, err := ListenUDP("udp", nil); err == nil { ln.Close() } if ln, err := ListenIP("ip:icmp", nil); err == nil { ln.Close() } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.5K bytes - Viewed (0) -
src/net/mockserver_test.go
{"tcp6", TCPAddr{IP: IPv6loopback}}, } for i := 0; i < 64; i++ { var port int var lns []*TCPListener for _, arg := range args { arg.TCPAddr.Port = port ln, err := ListenTCP(arg.network, &arg.TCPAddr) if err != nil { continue } port = ln.Addr().(*TCPAddr).Port lns = append(lns, ln) } if len(lns) != len(args) { for _, ln := range lns { ln.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 13.3K bytes - Viewed (0) -
src/net/tcpsock_test.go
{"tcp4", &TCPAddr{}}, {"tcp4", nil}, } func TestTCPListenerName(t *testing.T) { testenv.MustHaveExternalNetwork(t) for _, tt := range tcpListenerNameTests { ln, err := ListenTCP(tt.net, tt.laddr) if err != nil { t.Fatal(err) } defer ln.Close() la := ln.Addr() if a, ok := la.(*TCPAddr); !ok || a.Port == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0)