- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for PacketConn (0.22 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/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/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/dial.go
addrs, err := DefaultResolver.resolveAddrList(ctx, "listen", network, address, nil) if err != nil { return nil, &OpError{Op: "listen", Net: network, Source: nil, Addr: nil, Err: err} } sl := &sysListener{ ListenConfig: *lc, network: network, address: address, } var c PacketConn la := addrs.first(isIPv4) switch la := la.(type) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/dns/client/dns_test.go
case <-up: } t.Cleanup(func() { _ = server.Shutdown() }) server.Addr = server.PacketConn.LocalAddr().String() select { case <-time.After(time.Second * 10): t.Fatalf("setup timeout") case <-up: } t.Cleanup(func() { _ = tcp.Shutdown() }) t.Cleanup(func() { _ = server.Shutdown() }) tcp.Addr = server.PacketConn.LocalAddr().String() return server.Addr }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 16:17:34 UTC 2024 - 20.4K bytes - Viewed (0) -
src/net/net.go
if err != nil { err = &OpError{Op: "file", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } return } // PacketConn is a generic packet-oriented network connection. // // Multiple goroutines may invoke methods on a PacketConn simultaneously. type PacketConn interface { // ReadFrom reads a packet from the connection, // copying the payload into p. It returns the number of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/nettest.go
// loopback IP address or local file system path. // // The provided network must be "udp", "udp4", "udp6" or "unixgram". func NewLocalPacketListener(network string) (net.PacketConn, error) { stackOnce.Do(probeStack) switch network { case "udp": if canListenTCP4OnLoopback { if c, err := net.ListenPacket("udp4", "127.0.0.1:0"); err == nil { return c, nil } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 8.5K bytes - Viewed (0) -
src/net/dnsclient_unix.go
return dnsmessage.Parser{}, dnsmessage.Header{}, err } if d, ok := ctx.Deadline(); ok && !d.IsZero() { c.SetDeadline(d) } var p dnsmessage.Parser var h dnsmessage.Header if _, ok := c.(PacketConn); ok { p, h, err = dnsPacketRoundTrip(c, id, q, udpReq) } else { p, h, err = dnsStreamRoundTrip(c, id, q, tcpReq) } c.Close() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 24.5K bytes - Viewed (0) -
src/net/lookup.go
// always be a literal IP address and not a host name, and the // port in the address parameter will be a literal port number // and not a service name. // If the Conn returned is also a PacketConn, sent and received DNS // messages must adhere to RFC 1035 section 4.2.1, "UDP usage". // Otherwise, DNS messages transmitted over Conn must adhere // to RFC 7766 section 5, "Transport Protocol Selection".
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 28.6K bytes - Viewed (0) -
src/net/dnsclient_unix_test.go
} return len(b), nil } func (f *fakeDNSConn) SetDeadline(t time.Time) error { f.t = t return nil } type fakeDNSPacketConn struct { PacketConn fakeDNSConn } func (f *fakeDNSPacketConn) SetDeadline(t time.Time) error { return f.fakeDNSConn.SetDeadline(t) } func (f *fakeDNSPacketConn) Close() error { return f.fakeDNSConn.Close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 72.4K bytes - Viewed (0)