- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 122 for AF_INET (0.14 sec)
-
src/net/file_unix.go
poll.CloseFunc(s) return nil, os.NewSyscallError("getsockopt", err) } lsa, _ := syscall.Getsockname(s) rsa, _ := syscall.Getpeername(s) switch lsa.(type) { case *syscall.SockaddrInet4: family = syscall.AF_INET case *syscall.SockaddrInet6: family = syscall.AF_INET6 case *syscall.SockaddrUnix: family = syscall.AF_UNIX default: poll.CloseFunc(s) return nil, syscall.EPROTONOSUPPORT }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.5K bytes - Viewed (0) -
src/internal/syscall/windows/version_windows.go
} var ( supportTCPKeepAliveIdle bool supportTCPKeepAliveInterval bool supportTCPKeepAliveCount bool ) var initTCPKeepAlive = sync.OnceFunc(func() { s, err := WSASocket(syscall.AF_INET, syscall.SOCK_STREAM, syscall.IPPROTO_TCP, nil, 0, WSA_FLAG_NO_HANDLE_INHERIT) if err != nil { // Fallback to checking the Windows version. major, _, build := version()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 11:49:46 UTC 2024 - 3.6K bytes - Viewed (0) -
src/net/tcpsock_posix.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.3K bytes - Viewed (0) -
tools/istio-iptables/pkg/capture/run_linux.go
} // Route all packets marked in chain ISTIODIVERT using routing table ${INBOUND_TPROXY_ROUTE_TABLE}. // Equivalent to `ip rule add fwmark <tproxyMark> lookup <tproxyTable>` families := []int{unix.AF_INET} if cfg.EnableIPv6 { families = append(families, unix.AF_INET6) } for _, family := range families { r := netlink.NewRule() r.Family = family r.Table = tproxyTable r.Mark = tproxyMark
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 3.1K bytes - Viewed (0) -
src/net/listen_test.go
fd := ln.(*TCPListener).fd if err := checkDualStackAddrFamily(fd); err != nil { return err } case "tcp4": fd := ln.(*TCPListener).fd if fd.family != syscall.AF_INET { return fmt.Errorf("%v got %v; want %v", fd.laddr, fd.family, syscall.AF_INET) } case "tcp6": fd := ln.(*TCPListener).fd if fd.family != syscall.AF_INET6 { return fmt.Errorf("%v got %v; want %v", fd.laddr, fd.family, syscall.AF_INET6) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.5K bytes - Viewed (0) -
src/internal/syscall/unix/kernel_version_solaris.go
// for socket() system call, returns true if affirmative. var SupportSockNonblockCloexec = sync.OnceValue(func() bool { // First test if socket() supports SOCK_NONBLOCK and SOCK_CLOEXEC directly. s, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM|syscall.SOCK_NONBLOCK|syscall.SOCK_CLOEXEC, 0) if err == nil { syscall.Close(s) return true } if err != syscall.EPROTONOSUPPORT && err != syscall.EINVAL {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 3.1K bytes - Viewed (0) -
cni/pkg/iptables/iptables_linux.go
return forEachInpodMarkIPRule(cfg, netlink.RuleDel) } func forEachInpodMarkIPRule(cfg *Config, f func(*netlink.Rule) error) error { var rules []*netlink.Rule families := []int{unix.AF_INET} if cfg.EnableIPv6 { families = append(families, unix.AF_INET6) } for _, family := range families { // Equiv: // ip rule add fwmark 0x111/0xfff pref 32764 lookup 100 //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/proxy/ipvs/util/ipvs_linux.go
} // Sub Flags to 0x2 // 011 -> 001, 010 -> 000 vs.Flags = ServiceFlags(svc.Flags &^ uint32(FlagHashed)) if vs.Address == nil { if svc.AddressFamily == unix.AF_INET { vs.Address = net.IPv4zero } else { vs.Address = net.IPv6zero } } return vs, nil } // toRealServer converts an IPVS Destination to the equivalent RealServer structure.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 9K bytes - Viewed (0) -
src/net/mptcpsock_linux_test.go
} } func canCreateMPTCPSocket() bool { // We want to know if we can create an MPTCP socket, not just if it is // available (mptcpAvailable()): it could be blocked by the admin fd, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, _IPPROTO_MPTCP) if err != nil { return false } syscall.Close(fd) return true } func testMultiPathTCP(t *testing.T, envVar bool) { if envVar {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 00:36:57 UTC 2023 - 4.1K bytes - Viewed (0) -
src/internal/poll/fd_windows_test.go
err = checkFileIsNotPartOfNetpoll(f) if err != nil { t.Fatal(err) } }) } } func TestWSASocketConflict(t *testing.T) { s, err := windows.WSASocket(syscall.AF_INET, syscall.SOCK_STREAM, syscall.IPPROTO_TCP, nil, 0, windows.WSA_FLAG_OVERLAPPED) if err != nil { t.Fatal(err) } fd := poll.FD{Sysfd: s, IsStream: true, ZeroReadIsEOF: true} _, err = fd.Init("tcp", true)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 14 08:33:36 UTC 2024 - 4.3K bytes - Viewed (0)