Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for listenUnix (0.32 sec)

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