Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for listenTCP (0.11 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_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)
  4. 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)
  5. 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)
Back to top