Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 38 of 38 for recvmsg (0.11 sec)

  1. src/net/iprawsock_plan9.go

    package net
    
    import (
    	"context"
    	"syscall"
    )
    
    func (c *IPConn) readFrom(b []byte) (int, *IPAddr, error) {
    	return 0, nil, syscall.EPLAN9
    }
    
    func (c *IPConn) readMsg(b, oob []byte) (n, oobn, flags int, addr *IPAddr, err error) {
    	return 0, 0, 0, nil, syscall.EPLAN9
    }
    
    func (c *IPConn) writeTo(b []byte, addr *IPAddr) (int, error) {
    	return 0, syscall.EPLAN9
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 29 23:57:04 UTC 2018
    - 874 bytes
    - Viewed (0)
  2. cmd/bootstrap-peer-server.go

    	if newObjectLayerFn() != nil {
    		return nil
    	}
    
    	recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS())
    	if err != nil {
    		return err
    	}
    	// We do not need the response after returning.
    	defer serverVerifyHandler.PutResponse(recvCfg)
    
    	return srcCfg.Diff(recvCfg)
    }
    
    // Stringer provides a canonicalized representation of node.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. src/net/fd_posix.go

    	n, err = fd.pfd.ReadFromInet6(p, from)
    	runtime.KeepAlive(fd)
    	return n, wrapSyscallError(readFromSyscallName, err)
    }
    
    func (fd *netFD) readMsg(p []byte, oob []byte, flags int) (n, oobn, retflags int, sa syscall.Sockaddr, err error) {
    	n, oobn, retflags, sa, err = fd.pfd.ReadMsg(p, oob, flags)
    	runtime.KeepAlive(fd)
    	return n, oobn, retflags, sa, wrapSyscallError(readMsgSyscallName, 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)
  4. src/net/unixsock_posix.go

    		if sa.Name != "" {
    			addr = &UnixAddr{Name: sa.Name, Net: sotypeToNet(c.fd.sotype)}
    		}
    	}
    	return n, addr, err
    }
    
    func (c *UnixConn) readMsg(b, oob []byte) (n, oobn, flags int, addr *UnixAddr, err error) {
    	var sa syscall.Sockaddr
    	n, oobn, flags, sa, err = c.fd.readMsg(b, oob, readMsgFlags)
    	if readMsgFlags == 0 && err == nil && oobn > 0 {
    		setReadMsgCloseOnExec(oob[:oobn])
    	}
    
    	switch sa := sa.(type) {
    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/net/udpsock_plan9.go

    	}
    	buf = buf[:m]
    
    	h, buf := unmarshalUDPHeader(buf)
    	n := copy(b, buf)
    	ip, _ := netip.AddrFromSlice(h.raddr)
    	addr := netip.AddrPortFrom(ip, h.rport)
    	return n, addr, nil
    }
    
    func (c *UDPConn) readMsg(b, oob []byte) (n, oobn, flags int, addr netip.AddrPort, err error) {
    	return 0, 0, 0, netip.AddrPort{}, syscall.EPLAN9
    }
    
    func (c *UDPConn) writeTo(b []byte, addr *UDPAddr) (int, error) {
    	if addr == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 02 18:35:35 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  6. src/net/iprawsock.go

    func (c *IPConn) ReadMsgIP(b, oob []byte) (n, oobn, flags int, addr *IPAddr, err error) {
    	if !c.ok() {
    		return 0, 0, 0, nil, syscall.EINVAL
    	}
    	n, oobn, flags, addr, err = c.readMsg(b, oob)
    	if err != nil {
    		err = &OpError{Op: "read", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	return
    }
    
    // WriteToIP acts like [IPConn.WriteTo] but takes an [IPAddr].
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. src/net/udpsock_posix.go

    			port = from.Port
    		}
    	}
    	if err == nil {
    		addr = netip.AddrPortFrom(ip, uint16(port))
    	}
    	return n, addr, err
    }
    
    func (c *UDPConn) readMsg(b, oob []byte) (n, oobn, flags int, addr netip.AddrPort, err error) {
    	switch c.fd.family {
    	case syscall.AF_INET:
    		var sa syscall.SockaddrInet4
    		n, oobn, flags, err = c.fd.readMsgInet4(b, oob, 0, &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)
  8. test/ken/chan.go

    func main() {
    
    	tests(0)
    	tests(1)
    	tests(10)
    	tests(100)
    
    	t := 4 * // buffer sizes
    		(4*4 + // tests 1,2,3,4 channels
    			8 + // test 5 channels
    			12) * // test 6 channels
    		76 // sends/recvs on a channel
    
    	if tots != t || totr != t {
    		print("tots=", tots, " totr=", totr, " sb=", t, "\n")
    		os.Exit(1)
    	}
    	os.Exit(0)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 24 05:24:24 UTC 2012
    - 4.7K bytes
    - Viewed (0)
Back to top