Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for raddr (0.91 sec)

  1. src/net/tcpsock_unix.go

    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	if err := setKeepAliveIdle(c.fd, config.Idle); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	if err := setKeepAliveInterval(c.fd, config.Interval); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  2. src/net/tcpsock_posix.go

    }
    
    func (sd *sysDialer) dialTCP(ctx context.Context, laddr, raddr *TCPAddr) (*TCPConn, error) {
    	if h := sd.testHookDialTCP; h != nil {
    		return h(ctx, sd.network, laddr, raddr)
    	}
    	if h := testHookDialTCP; h != nil {
    		return h(ctx, sd.network, laddr, raddr)
    	}
    	return sd.doDialTCP(ctx, laddr, raddr)
    }
    
    func (sd *sysDialer) doDialTCP(ctx context.Context, laddr, raddr *TCPAddr) (*TCPConn, 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)
  3. src/net/unixsock_posix.go

    		sotype = syscall.SOCK_SEQPACKET
    	default:
    		return nil, UnknownNetworkError(net)
    	}
    
    	switch mode {
    	case "dial":
    		if laddr != nil && laddr.isWildcard() {
    			laddr = nil
    		}
    		if raddr != nil && raddr.isWildcard() {
    			raddr = nil
    		}
    		if raddr == nil && (sotype != syscall.SOCK_DGRAM || laddr == nil) {
    			return nil, errMissingAddress
    		}
    	case "listen":
    	default:
    		return nil, errors.New("unknown mode: " + mode)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. src/net/tcpsock_solaris.go

    		}
    		if err := setKeepAliveCount(c.fd, config.Count); err != nil {
    			return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    		}
    	} else if err := setKeepAliveIdleAndIntervalAndCount(c.fd, config.Idle, config.Interval, config.Count); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    
    	return nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  5. src/net/ipsock_posix.go

    		if laddr == nil {
    			return syscall.AF_INET, false
    		}
    		return laddr.family(), false
    	}
    
    	if (laddr == nil || laddr.family() == syscall.AF_INET) &&
    		(raddr == nil || raddr.family() == syscall.AF_INET) {
    		return syscall.AF_INET, false
    	}
    	return syscall.AF_INET6, false
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  6. src/net/tcpsock.go

    	}
    	if raddr == nil {
    		return nil, &OpError{Op: "dial", Net: network, Source: laddr.opAddr(), Addr: nil, Err: errMissingAddress}
    	}
    	sd := &sysDialer{network: network, address: raddr.String()}
    	c, err := sd.dialTCP(context.Background(), laddr, raddr)
    	if err != nil {
    		return nil, &OpError{Op: "dial", Net: network, Source: laddr.opAddr(), Addr: raddr.opAddr(), Err: err}
    	}
    	return c, nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  7. src/net/iprawsock_posix.go

    	// type to avoid the header trim/copy
    	var addr *IPAddr
    	n, sa, err := c.fd.readFrom(b)
    	switch sa := sa.(type) {
    	case *syscall.SockaddrInet4:
    		addr = &IPAddr{IP: sa.Addr[0:]}
    		n = stripIPv4Header(n, b)
    	case *syscall.SockaddrInet6:
    		addr = &IPAddr{IP: sa.Addr[0:], Zone: zoneCache.name(int(sa.ZoneId))}
    	}
    	return n, addr, err
    }
    
    func stripIPv4Header(n int, b []byte) int {
    	if len(b) < 20 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. src/net/udpsock_posix.go

    		if err == nil {
    			ip := from.Addr // copy from.Addr; ip escapes, so this line allocates 16 bytes
    			*addr = UDPAddr{IP: ip[:], Port: from.Port, Zone: zoneCache.name(int(from.ZoneId))}
    		}
    	}
    	if err != nil {
    		// No sockaddr, so don't return UDPAddr.
    		addr = nil
    	}
    	return n, addr, err
    }
    
    func (c *UDPConn) readFromAddrPort(b []byte) (n int, addr netip.AddrPort, err error) {
    	var ip netip.Addr
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. src/net/net.go

    		err = &OpError{Op: "read", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	return n, err
    }
    
    // Write implements the Conn Write method.
    func (c *conn) Write(b []byte) (int, error) {
    	if !c.ok() {
    		return 0, syscall.EINVAL
    	}
    	n, err := c.fd.Write(b)
    	if err != nil {
    		err = &OpError{Op: "write", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	return n, err
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  10. pkg/proxy/nftables/proxier_test.go

    		add rule ip kube-proxy services ip daddr . meta l4proto . th dport vmap @service-ips
    		add rule ip kube-proxy services ip daddr @nodeport-ips meta l4proto . th dport vmap @service-nodeports
    		add element ip kube-proxy nodeport-ips { 192.168.0.2 }
    
    		# svc1
    		add chain ip kube-proxy service-ULMVA6XW-ns1/svc1/tcp/p80
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
Back to top