Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for listenTCP (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top