- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for PacketConn (0.33 sec)
-
src/net/mockserver_test.go
pcmu sync.RWMutex PacketConn done chan bool // signal that indicates server stopped } func (ls *localPacketServer) buildup(handler func(*localPacketServer, PacketConn)) error { go func() { handler(ls, ls.PacketConn) close(ls.done) }() return nil } func (ls *localPacketServer) teardown() error { ls.pcmu.Lock() if ls.PacketConn != 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) -
src/net/packetconn_test.go
return nil, func() { t.Logf("skipping %s test", network) } } return []byte("PACKETCONN TEST"), nil } func TestPacketConn(t *testing.T) { var packetConnTests = []struct { net string addr1 string addr2 string }{ {"udp", "127.0.0.1:0", "127.0.0.1:0"}, {"unixgram", testUnixAddr(t), testUnixAddr(t)}, } closer := func(c PacketConn, net, addr1, addr2 string) { c.Close() switch net { case "unixgram":
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 3K bytes - Viewed (0) -
src/net/server_test.go
t.Fatal(err) } ls := (&packetListener{PacketConn: c1}).newLocalServer() defer ls.teardown() tpch := make(chan error, 1) handler := func(ls *localPacketServer, c PacketConn) { packetTransponder(c, tpch) } if err := ls.buildup(handler); err != nil { t.Fatal(err) } trch := make(chan error, 1) _, port, err := SplitHostPort(ls.PacketConn.LocalAddr().String()) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 11.7K bytes - Viewed (0) -
src/net/file_stub.go
"syscall" ) func fileConn(f *os.File) (Conn, error) { return nil, syscall.ENOPROTOOPT } func fileListener(f *os.File) (Listener, error) { return nil, syscall.ENOPROTOOPT }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 481 bytes - Viewed (0) -
pilot/pkg/model/network_test.go
failingDNSServer.setFailure(true) model.NetworkGatewayTestDNSServers = []string{ // try resolving with the failing server first to make sure the next upstream is retried failingDNSServer.Server.PacketConn.LocalAddr().String(), workingDNSServer.Server.PacketConn.LocalAddr().String(), } t.Cleanup(func() { errW := workingDNSServer.Shutdown() errF := failingDNSServer.Shutdown() if errW != nil || errF != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 6.9K bytes - Viewed (0) -
src/net/iprawsock.go
if err != nil { return nil, err } return addrs.forResolve(network, address).(*IPAddr), nil } // IPConn is the implementation of the [Conn] and [PacketConn] interfaces // for IP network connections. type IPConn struct { conn } // SyscallConn returns a raw network connection. // This implements the [syscall.Conn] interface.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7.1K bytes - Viewed (0) -
src/net/file_unix.go
return &TCPListener{fd: fd}, nil case *UnixAddr: return &UnixListener{fd: fd, path: laddr.Name, unlink: false}, nil } fd.Close() return nil, syscall.EINVAL } func filePacketConn(f *os.File) (PacketConn, error) { fd, err := newFileFD(f) if err != nil { return nil, err } switch fd.laddr.(type) { case *UDPAddr: return newUDPConn(fd), nil case *IPAddr: return newIPConn(fd), nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.5K bytes - Viewed (0) -
src/net/udpsock_test.go
// suitable address" error on some platforms. t.Log(err) continue } ls := (&packetListener{PacketConn: c1}).newLocalServer() defer ls.teardown() ch := make(chan error, 1) handler := func(ls *localPacketServer, c PacketConn) { packetTransponder(c, ch) } 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 - 17.2K bytes - Viewed (0) -
src/net/file_plan9.go
if err != nil { return nil, err } if s != "Listen" { return nil, errors.New("file does not represent a listener") } return &TCPListener{fd: fd}, nil } func filePacketConn(f *os.File) (PacketConn, error) { return nil, syscall.EPLAN9
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.8K bytes - Viewed (0) -
src/net/unixsock.go
} n, addr, err := c.readFrom(b) if err != nil { err = &OpError{Op: "read", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } return n, addr, err } // ReadFrom implements the [PacketConn] ReadFrom method. func (c *UnixConn) ReadFrom(b []byte) (int, Addr, error) { if !c.ok() { return 0, nil, syscall.EINVAL } n, addr, err := c.readFrom(b) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.1K bytes - Viewed (0)