Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newUDPConn (0.09 sec)

  1. src/net/udpsock_plan9.go

    }
    
    func (sd *sysDialer) dialUDP(ctx context.Context, laddr, raddr *UDPAddr) (*UDPConn, error) {
    	fd, err := dialPlan9(ctx, sd.network, laddr, raddr)
    	if err != nil {
    		return nil, err
    	}
    	return newUDPConn(fd), nil
    }
    
    const udpHeaderSize = 16*3 + 2*2
    
    type udpHeader struct {
    	raddr, laddr, ifcaddr IP
    	rport, lport          uint16
    }
    
    func (h *udpHeader) Bytes() []byte {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 02 18:35:35 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  2. src/net/file_unix.go

    		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:
    		return newUnixConn(fd), nil
    	}
    	fd.Close()
    	return nil, syscall.EINVAL
    }
    
    func fileListener(f *os.File) (Listener, error) {
    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/udpsock_posix.go

    			return sd.Dialer.Control(network, address, c)
    		}
    	}
    	fd, err := internetSocket(ctx, sd.network, laddr, raddr, syscall.SOCK_DGRAM, 0, "dial", ctrlCtxFn)
    	if err != nil {
    		return nil, err
    	}
    	return newUDPConn(fd), nil
    }
    
    func (sl *sysListener) listenUDP(ctx context.Context, laddr *UDPAddr) (*UDPConn, error) {
    	var ctrlCtxFn func(ctx context.Context, network, address string, c syscall.RawConn) error
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. src/net/file_plan9.go

    		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
    }
    
    func fileListener(f *os.File) (Listener, error) {
    	fd, err := newFileFD(f)
    	if err != nil {
    		return nil, err
    	}
    	switch fd.laddr.(type) {
    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/udpsock.go

    	}
    	n, oobn, err = c.writeMsgAddrPort(b, oob, addr)
    	if err != nil {
    		err = &OpError{Op: "write", Net: c.fd.net, Source: c.fd.laddr, Addr: addrPortUDPAddr{addr}, Err: err}
    	}
    	return
    }
    
    func newUDPConn(fd *netFD) *UDPConn { return &UDPConn{conn{fd}} }
    
    // DialUDP acts like Dial for UDP networks.
    //
    // The network must be a UDP network name; see func Dial for details.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 20 16:58:25 UTC 2023
    - 11.8K bytes
    - Viewed (0)
Back to top