Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for unixgram (0.26 sec)

  1. src/net/unixsock_test.go

    		t.Fatalf("got %v; want %v", b[:n], data[:])
    	}
    }
    
    func TestUnixgramZeroBytePayload(t *testing.T) {
    	if !testableNetwork("unixgram") {
    		t.Skip("unixgram test")
    	}
    
    	c1 := newLocalPacketListener(t, "unixgram")
    	defer os.Remove(c1.LocalAddr().String())
    	defer c1.Close()
    
    	c2, err := Dial("unixgram", c1.LocalAddr().String())
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.Remove(c2.LocalAddr().String())
    	defer c2.Close()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  2. src/net/unixsock.go

    // BUG(mikio): On Windows, methods and functions related to UnixConn
    // and UnixListener don't work for "unixgram" and "unixpacket".
    
    // UnixAddr represents the address of a Unix domain socket end point.
    type UnixAddr struct {
    	Name string
    	Net  string
    }
    
    // Network returns the address's network name, "unix", "unixgram" or
    // "unixpacket".
    func (a *UnixAddr) Network() string {
    	return a.Net
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. src/net/server_test.go

    		{saddr: "@nettest/go/unixgram/server", caddr: "@nettest/go/unixgram/client"},
    	}
    
    	for i, tt := range unixgramServerTests {
    		i, tt := i, tt
    		t.Run(fmt.Sprint(i), func(t *testing.T) {
    			if !testableListenArgs("unixgram", tt.saddr, "") {
    				t.Skipf("skipping unixgram %s<-%s test", tt.saddr, tt.caddr)
    			}
    			t.Logf("unixgram %s<-%s", tt.saddr, tt.caddr)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 11.7K bytes
    - Viewed (0)
  4. src/net/mockserver_test.go

    		ch <- err
    		return
    	}
    	if peer == nil { // for connected-mode sockets
    		switch c.LocalAddr().Network() {
    		case "udp":
    			peer, err = ResolveUDPAddr("udp", string(b[:n]))
    		case "unixgram":
    			peer, err = ResolveUnixAddr("unixgram", string(b[:n]))
    		}
    		if err != nil {
    			ch <- err
    			return
    		}
    	}
    	if _, err := c.WriteTo(b[:n], peer); err != nil {
    		if perr := parseWriteError(err); perr != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  5. src/net/splice_linux_test.go

    	}
    }
    
    func testSpliceNoUnixgram(t *testing.T) {
    	addr, err := ResolveUnixAddr("unixgram", testUnixAddr(t))
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.Remove(addr.Name)
    	up, err := ListenUnixgram("unixgram", addr)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer up.Close()
    	clientDown, serverDown := spawnTestSocketPair(t, "tcp")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  6. src/net/error_test.go

    		var err error
    		switch network {
    		case "tcp":
    			_, err = DialTCP(network, nil, &TCPAddr{Port: 1 << 16})
    		case "udp":
    			_, err = DialUDP(network, nil, &UDPAddr{Port: 1 << 16})
    		case "ip:4294967296":
    			_, err = DialIP(network, nil, nil)
    		case "unix", "unixpacket", "unixgram":
    			_, err = DialUnix(network, nil, &UnixAddr{Name: "//"})
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  7. src/net/net_test.go

    	t.Parallel()
    	for _, network := range []string{"udp", "unixgram"} {
    		network := network
    		t.Run(network, func(t *testing.T) {
    			if !testableNetwork(network) {
    				t.Skipf("network %s is not testable on the current platform", network)
    			}
    			t.Parallel()
    
    			c := newLocalPacketListener(t, network)
    			switch network {
    			case "unixgram":
    				defer os.Remove(c.LocalAddr().String())
    			}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jan 22 21:04:44 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. src/net/dial.go

    		switch network {
    		case "tcp", "tcp4", "tcp6":
    		case "udp", "udp4", "udp6":
    		case "ip", "ip4", "ip6":
    			if needsProto {
    				return "", 0, UnknownNetworkError(network)
    			}
    		case "unix", "unixgram", "unixpacket":
    		default:
    			return "", 0, UnknownNetworkError(network)
    		}
    		return network, 0, nil
    	}
    	afnet = network[:i]
    	switch afnet {
    	case "ip", "ip4", "ip6":
    		protostr := network[i+1:]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  9. src/net/net_fake.go

    			return err
    		}
    		if sa.Port <= 0 || sa.Port >= 1<<16 {
    			return &AddrError{
    				Err:  "port out of range",
    				Addr: sa.String(),
    			}
    		}
    		return nil
    
    	case "unix", "unixgram", "unixpacket":
    		sa, ok := sa.(*UnixAddr)
    		if !ok {
    			return &AddrError{
    				Err:  "non-Unix address for " + net + " network",
    				Addr: sa.String(),
    			}
    		}
    		if sa.Name != "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 19:24:21 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  10. src/net/dial_test.go

    			}
    			c.Close()
    		}
    	})
    	t.Run("PacketDial", func(t *testing.T) {
    		for _, network := range []string{"udp", "udp4", "udp6", "unixgram"} {
    			if !testableNetwork(network) {
    				continue
    			}
    			c1 := newLocalPacketListener(t, network)
    			if network == "unixgram" {
    				defer os.Remove(c1.LocalAddr().String())
    			}
    			defer c1.Close()
    			d := Dialer{Control: controlOnConnSetup}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 30.3K bytes
    - Viewed (0)
Back to top