Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 926 for writeMsg (0.21 sec)

  1. 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)
  2. src/net/fd_posix.go

    	n, err = fd.pfd.WriteToInet6(p, sa)
    	runtime.KeepAlive(fd)
    	return n, wrapSyscallError(writeToSyscallName, err)
    }
    
    func (fd *netFD) writeMsg(p []byte, oob []byte, sa syscall.Sockaddr) (n int, oobn int, err error) {
    	n, oobn, err = fd.pfd.WriteMsg(p, oob, sa)
    	runtime.KeepAlive(fd)
    	return n, oobn, wrapSyscallError(writeMsgSyscallName, err)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 29 16:24:51 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. src/net/udpsock_plan9.go

    	return len(b), nil
    }
    
    func (c *UDPConn) writeToAddrPort(b []byte, addr netip.AddrPort) (int, error) {
    	return c.writeTo(b, UDPAddrFromAddrPort(addr)) // TODO: optimize instead of allocating
    }
    
    func (c *UDPConn) writeMsg(b, oob []byte, addr *UDPAddr) (n, oobn int, err error) {
    	return 0, 0, syscall.EPLAN9
    }
    
    func (c *UDPConn) writeMsgAddrPort(b, oob []byte, addr netip.AddrPort) (n, oobn int, err error) {
    	return 0, 0, syscall.EPLAN9
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 02 18:35:35 UTC 2021
    - 4.6K bytes
    - Viewed (0)
Back to top