Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for listenUnix (0.3 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.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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top