- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for listenUnix (0.18 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_plan9.go
} func (ln *UnixListener) close() error { return syscall.EPLAN9 } func (ln *UnixListener) file() (*os.File, error) { return nil, syscall.EPLAN9 } func (sl *sysListener) listenUnix(ctx context.Context, laddr *UnixAddr) (*UnixListener, error) { return nil, syscall.EPLAN9 } func (sl *sysListener) listenUnixgram(ctx context.Context, laddr *UnixAddr) (*UnixConn, error) { return nil, syscall.EPLAN9
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 29 23:57:04 UTC 2018 - 1.2K bytes - Viewed (0) -
src/net/unixsock_linux_test.go
t.Fatalf("expected autobind address %v, got %v", c1.LocalAddr(), c2.RemoteAddr()) } } func TestUnixAutobindClose(t *testing.T) { laddr := &UnixAddr{Name: "", Net: "unix"} ln, err := ListenUnix("unix", laddr) if err != nil { t.Fatal(err) } ln.Close() } func TestUnixgramLinuxAbstractLongName(t *testing.T) { if !testableNetwork("unixgram") { t.Skip("abstract unix socket long name test")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 28 03:00:34 UTC 2017 - 2.3K 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) -
pkg/util/iptables/iptables_linux.go
} // Roughly duplicate iptables 1.4.x xtables_lock() function. if err := wait.PollImmediate(200*time.Millisecond, 2*time.Second, func() (bool, error) { l.lock14, err = net.ListenUnix("unix", &net.UnixAddr{Name: lockfilePath14x, Net: "unix"}) if err != nil { return false, nil } return true, nil }); err != nil { return nil, fmt.Errorf("failed to acquire old iptables lock: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 2.6K 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)