- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for listenUnix (0.3 sec)
-
pkg/util/filesystem/util_test.go
os.Remove(addr) ta, err := net.ResolveUnixAddr("unix", addr) require.NoErrorf(t, err, "Failed to ResolveUnixAddr: %v while setting up: %s", err, test.label) ln, err = net.ListenUnix("unix", ta) require.NoErrorf(t, err, "Failed to ListenUnix: %v while setting up: %s", err, test.label) } fileToTest := addr if test.invalidFile { fileToTest = fileToTest + ".invalid" } result, err := IsUnixDomainSocket(fileToTest)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/util/filesystem/util_windows_test.go
os.Remove(testFile) ta, err := net.ResolveUnixAddr("unix", testFile) require.NoError(t, err, "Failed to ResolveUnixAddr.") unixln, err := net.ListenUnix("unix", ta) require.NoError(t, err, "Failed to ListenUnix.") // Wait for the goroutine to finish, then close the socket wg.Wait() unixln.Close() } func TestAbsWithSlash(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 09:10:26 UTC 2024 - 3.2K bytes - Viewed (0) -
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_posix.go
// Listen or ListenUnix, then by default closing the listener will remove the socket file. // but if the listener was created by a call to FileListener to use an already existing // socket file, then by default closing the listener will not remove the socket file. func (l *UnixListener) SetUnlinkOnClose(unlink bool) { l.unlink = unlink }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.6K bytes - Viewed (0) -
src/net/unixsock_windows_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: Tue Mar 12 17:24:57 UTC 2024 - 1.8K bytes - Viewed (0) -
src/net/protoconn_test.go
if !testableNetwork("unix") { t.Skip("unix test") } addr := testUnixAddr(t) la, err := ResolveUnixAddr("unix", addr) if err != nil { t.Fatal(err) } ln, err := ListenUnix("unix", la) if err != nil { t.Fatal(err) } defer ln.Close() defer os.Remove(addr) ln.Addr() mustSetDeadline(t, ln.SetDeadline, 30*time.Nanosecond) if c, err := ln.Accept(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 7.4K 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)