- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for listenUnix (0.32 sec)
-
src/net/unixsock.go
} f, err = l.file() if err != nil { err = &OpError{Op: "file", Net: l.fd.net, Source: nil, Addr: l.fd.laddr, Err: err} } return } // ListenUnix acts like [Listen] for Unix networks. // // The network must be "unix" or "unixpacket". func ListenUnix(network string, laddr *UnixAddr) (*UnixListener, error) { switch network { case "unix", "unixpacket": default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.1K bytes - Viewed (0) -
src/net/unixsock_test.go
for _, laddr := range []string{"", testUnixAddr(t)} { laddr := laddr taddr := testUnixAddr(t) ta, err := ResolveUnixAddr("unix", taddr) if err != nil { t.Fatal(err) } ln, err := ListenUnix("unix", ta) if err != nil { t.Fatal(err) } ls := (&streamListener{Listener: ln}).newLocalServer() defer ls.teardown() if err := ls.buildup(handler); err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 10.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
if err := os.Remove(addr); err != nil && !os.IsNotExist(err) { // Anything other than "file not found" is an error. return nil, fmt.Errorf("failed to remove unix://%s: %w", addr, err) } l, err := net.ListenUnix("unixpacket", resolvedAddr) if err != nil { return nil, fmt.Errorf("failed to listen unix: %w", err) } return &ztunnelServer{ listener: l, conns: &connMgr{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 12.3K bytes - Viewed (0) -
src/net/error_test.go
case "udp": _, err = ListenUDP(network, &UDPAddr{Port: 1 << 16}) case "ip:4294967296": _, err = ListenIP(network, nil) case "unix", "unixpacket": _, err = ListenUnix(network, &UnixAddr{Name: "//"}) case "unixgram": _, err = ListenUnixgram(network, &UnixAddr{Name: "//"}) } if err == nil { t.Errorf("%s: should fail", network) continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.3K bytes - Viewed (0) -
src/net/dial.go
switch la := la.(type) { case *TCPAddr: if sl.MultipathTCP() { l, err = sl.listenMPTCP(ctx, la) } else { l, err = sl.listenTCP(ctx, la) } case *UnixAddr: l, err = sl.listenUnix(ctx, la) default: return nil, &OpError{Op: "listen", Net: sl.network, Source: nil, Addr: la, Err: &AddrError{Err: "unexpected address type", Addr: address}} } if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/util/iptables/iptables_test.go
var runLock *net.UnixListener // Grab the abstract @xtables socket, will retry if the socket exists err := wait.PollImmediate(time.Second, wait.ForeverTestTimeout, func() (done bool, err error) { runLock, err = net.ListenUnix("unix", &net.UnixAddr{Name: lockPath14x, Net: "unix"}) if err != nil { t.Logf("Failed to lock %s: %v, will retry.", lockPath14x, err) return false, nil } return true, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:21:59 UTC 2023 - 46.3K bytes - Viewed (0)