- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 31 for PacketConn (0.18 sec)
-
pkg/test/echo/server/endpoint/util.go
_ = os.Remove(uds) ln, err := net.Listen("unix", uds) if err != nil { return nil, err } return ln, nil } func listenUDPAddress(ip string, port int) (net.PacketConn, int, error) { parsedIP := net.ParseIP(ip) ipBind := "udp" if parsedIP != nil { if parsedIP.To4() == nil && parsedIP.To16() != nil { ipBind = "udp6" } else if parsedIP.To4() != nil { ipBind = "udp4"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.6K bytes - Viewed (0) -
src/net/file_wasip1.go
} pfd := f.PollFD().Copy() fd := newPollFD(net, pfd) if err := fd.init(); err != nil { pfd.Close() return nil, err } return newFileConn(fd), nil } func filePacketConn(f *os.File) (PacketConn, error) { return nil, syscall.ENOPROTOOPT } func fileListenNet(filetype syscall.Filetype) (string, error) { switch filetype { case syscall.FILETYPE_SOCKET_STREAM: return "tcp", nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 12 23:11:39 UTC 2023 - 2.2K bytes - Viewed (0) -
src/net/file.go
// corresponding to the open file f. // It is the caller's responsibility to close f when finished. // Closing c does not affect f, and closing f does not affect c. func FilePacketConn(f *os.File) (c PacketConn, err error) { c, err = filePacketConn(f) if err != nil { err = &OpError{Op: "file", Net: "file+net", Source: nil, Addr: fileAddr(f.Name()), Err: err} } return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 09 06:14:44 UTC 2019 - 1.7K 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/udpsock.go
type addrPortUDPAddr struct { netip.AddrPort } func (addrPortUDPAddr) Network() string { return "udp" } // UDPConn is the implementation of the Conn and PacketConn interfaces // for UDP network connections. type UDPConn 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: Thu Jul 20 16:58:25 UTC 2023 - 11.8K 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) -
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) -
src/net/timeout_test.go
defer close(ch) handler := func(ls *localPacketServer, c PacketConn) { if dst, ok := <-ch; ok { c.WriteTo([]byte("READFROM TIMEOUT TEST"), dst) } } ls := newLocalPacketServer(t, "udp") defer ls.teardown() if err := ls.buildup(handler); err != nil { t.Fatal(err) } host, _, err := SplitHostPort(ls.PacketConn.LocalAddr().String()) if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 18:06:55 UTC 2024 - 30K bytes - Viewed (0)