- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 872 for writeMsg (0.14 sec)
-
src/net/iprawsock_posix.go
} return c.fd.writeTo(b, sa) } func (c *IPConn) writeMsg(b, oob []byte, addr *IPAddr) (n, oobn int, err error) { if c.fd.isConnected { return 0, 0, ErrWriteToConnected } if addr == nil { return 0, 0, errMissingAddress } sa, err := addr.sockaddr(c.fd.family) if err != nil { return 0, 0, err } return c.fd.writeMsg(b, oob, sa) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/dns/client/dns_test.go
answer.Rcode = dns.RcodeSuccess if err := resp.WriteMsg(&answer); err != nil { t.Fatalf("err: %s", err) } }) } mux.HandleFunc("giant.", func(resp dns.ResponseWriter, msg *dns.Msg) { answer := &dns.Msg{ Answer: giantResponse, } answer.SetReply(msg) answer.Rcode = dns.RcodeSuccess if err := resp.WriteMsg(answer); err != nil { t.Fatalf("err: %s", err) } })
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/unixsock_posix.go
} if addr.Net != sotypeToNet(c.fd.sotype) { return 0, syscall.EAFNOSUPPORT } sa := &syscall.SockaddrUnix{Name: addr.Name} return c.fd.writeTo(b, sa) } func (c *UnixConn) writeMsg(b, oob []byte, addr *UnixAddr) (n, oobn int, err error) { if c.fd.sotype == syscall.SOCK_DGRAM && c.fd.isConnected { return 0, 0, ErrWriteToConnected } var sa syscall.Sockaddr if addr != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.6K bytes - Viewed (0) -
src/internal/poll/fd_unix.go
if err = fd.pd.waitWrite(fd.isFile); err == nil { continue } } if err != nil { return 0, err } return len(p), nil } } // WriteMsg wraps the sendmsg network call. func (fd *FD) WriteMsg(p []byte, oob []byte, sa syscall.Sockaddr) (int, int, error) { if err := fd.writeLock(); err != nil { return 0, 0, err } defer fd.writeUnlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 04:09:44 UTC 2024 - 17.9K bytes - Viewed (0) -
src/net/udpsock_posix.go
} } func (c *UDPConn) writeMsg(b, oob []byte, addr *UDPAddr) (n, oobn int, err error) { if c.fd.isConnected && addr != nil { return 0, 0, ErrWriteToConnected } if !c.fd.isConnected && addr == nil { return 0, 0, errMissingAddress } sa, err := addr.sockaddr(c.fd.family) if err != nil { return 0, 0, err } return c.fd.writeMsg(b, oob, sa) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 7.5K bytes - Viewed (0) -
src/net/platform_test.go
return false } } return true } func condFatalf(t *testing.T, network string, format string, args ...any) { t.Helper() // A few APIs like File and Read/WriteMsg{UDP,IP} are not // fully implemented yet on Plan 9 and Windows. switch runtime.GOOS { case "windows", "js", "wasip1": if network == "file+net" { t.Logf(format, args...) return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 4.3K bytes - Viewed (0) -
src/net/net_fake.go
} n, err = ffd.readFromInet6(p, sa) return n, 0, 0, err } func (ffd *fakeNetFD) writeMsg(p []byte, oob []byte, sa syscall.Sockaddr) (n int, oobn int, err error) { if len(oob) > 0 { return 0, 0, os.NewSyscallError("writeMsg", syscall.ENOTSUP) } n, err = ffd.writeTo(p, sa) return n, 0, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 19:24:21 UTC 2024 - 26.4K bytes - Viewed (0) -
pkg/dns/client/dns.go
response.SetReply(req) response.Rcode = dns.RcodeServerFailure _ = w.WriteMsg(response) return } lp := h.lookupTable.Load() hostname := strings.ToLower(req.Question[0].Name) if lp == nil { if h.respondBeforeSync { response = h.upstream(proxy, req, hostname) response.Truncate(size(proxy.protocol, req)) _ = w.WriteMsg(response) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 16:17:34 UTC 2024 - 23.9K bytes - Viewed (0) -
pilot/pkg/model/network_test.go
case dns.TypeANY: msg.Rcode = dns.RcodeRefused default: msg.Rcode = dns.RcodeNotImplemented } } else { msg.Rcode = dns.RcodeNameError } } if err := w.WriteMsg(msg); err != nil { scopes.Framework.Errorf("failed writing fake DNS response: %v", err) } } func (s *fakeDNSServer) setHosts(hosts sets.String) { s.mu.Lock() defer s.mu.Unlock()
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
// used to manipulate IP-level socket options in oob. func (c *IPConn) WriteMsgIP(b, oob []byte, addr *IPAddr) (n, oobn int, err error) { if !c.ok() { return 0, 0, syscall.EINVAL } n, oobn, err = c.writeMsg(b, oob, addr) if err != nil { err = &OpError{Op: "write", Net: c.fd.net, Source: c.fd.laddr, Addr: addr.opAddr(), Err: err} } return } func newIPConn(fd *netFD) *IPConn { return &IPConn{conn{fd}} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7.1K bytes - Viewed (0)