Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for newTCPConn (0.17 sec)

  1. src/net/tcpsock_plan9.go

    		return nil, err
    	}
    	return newTCPConn(fd, sd.Dialer.KeepAlive, sd.Dialer.KeepAliveConfig, testPreHookSetKeepAlive, testHookSetKeepAlive), nil
    }
    
    func (ln *TCPListener) ok() bool { return ln != nil && ln.fd != nil && ln.fd.ctl != nil }
    
    func (ln *TCPListener) accept() (*TCPConn, error) {
    	fd, err := ln.fd.acceptPlan9()
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. src/net/file_unix.go

    	fd.setAddr(laddr, raddr)
    	return fd, nil
    }
    
    func fileConn(f *os.File) (Conn, error) {
    	fd, err := newFileFD(f)
    	if err != nil {
    		return nil, err
    	}
    	switch fd.laddr.(type) {
    	case *TCPAddr:
    		return newTCPConn(fd, defaultTCPKeepAliveIdle, KeepAliveConfig{}, testPreHookSetKeepAlive, testHookSetKeepAlive), nil
    	case *UDPAddr:
    		return newUDPConn(fd), nil
    	case *IPAddr:
    		return newIPConn(fd), nil
    	case *UnixAddr:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. src/net/tcpsock_posix.go

    		if err == nil {
    			fd.Close()
    		}
    		fd, err = internetSocket(ctx, sd.network, laddr, raddr, syscall.SOCK_STREAM, proto, "dial", ctrlCtxFn)
    	}
    
    	if err != nil {
    		return nil, err
    	}
    	return newTCPConn(fd, sd.Dialer.KeepAlive, sd.Dialer.KeepAliveConfig, testPreHookSetKeepAlive, testHookSetKeepAlive), nil
    }
    
    func selfConnect(fd *netFD, err error) bool {
    	// If the connect failed, we clearly didn't connect to ourselves.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. src/net/file_plan9.go

    	if !fd.ok() {
    		return nil, syscall.EINVAL
    	}
    
    	fd.data, err = os.OpenFile(fd.dir+"/data", os.O_RDWR, 0)
    	if err != nil {
    		return nil, err
    	}
    
    	switch fd.laddr.(type) {
    	case *TCPAddr:
    		return newTCPConn(fd, defaultTCPKeepAliveIdle, KeepAliveConfig{}, testPreHookSetKeepAlive, testHookSetKeepAlive), nil
    	case *UDPAddr:
    		return newUDPConn(fd), nil
    	}
    	return nil, syscall.EPLAN9
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. src/net/tcpsock.go

    // the results.
    func (c *TCPConn) MultipathTCP() (bool, error) {
    	if !c.ok() {
    		return false, syscall.EINVAL
    	}
    	return isUsingMultipathTCP(c.fd), nil
    }
    
    func newTCPConn(fd *netFD, keepAliveIdle time.Duration, keepAliveCfg KeepAliveConfig, preKeepAliveHook func(*netFD), keepAliveHook func(KeepAliveConfig)) *TCPConn {
    	setNoDelay(fd, true)
    	if !keepAliveCfg.Enable && keepAliveIdle >= 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  6. src/cmd/trace/testdata/go122.test

    String id=133
    	data="net.setKeepAlivePeriod"
    String id=134
    	data="/usr/local/google/home/mknyszek/work/go-1/src/net/tcpsockopt_unix.go"
    String id=135
    	data="net.newTCPConn"
    String id=136
    	data="syscall.Close"
    String id=137
    	data="internal/poll.(*SysFile).destroy"
    String id=138
    	data="/usr/local/google/home/mknyszek/work/go-1/src/internal/poll/fd_unixjs.go"
    String id=139
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 17:15:58 UTC 2024
    - 166K bytes
    - Viewed (0)
Back to top