Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for listenUnix (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top