Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for sendmsgN (0.2 sec)

  1. src/syscall/syscall_aix.go

    //sys	Shutdown(s int, how int) (err error)
    
    // In order to use msghdr structure with Control, Controllen in golang.org/x/net,
    // nrecvmsg and nsendmsg must be used.
    //sys	recvmsg(s int, msg *Msghdr, flags int) (n int, err error) = nrecvmsg
    //sys	sendmsg(s int, msg *Msghdr, flags int) (n int, err error) = nsendmsg
    
    func (sa *SockaddrInet4) sockaddr() (unsafe.Pointer, _Socklen, error) {
    	if sa.Port < 0 || sa.Port > 0xFFFF {
    		return nil, 0, EINVAL
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:50:55 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  2. src/internal/poll/fd_unix.go

    		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()
    	if err := fd.pd.prepareWrite(fd.isFile); err != nil {
    		return 0, 0, err
    	}
    	for {
    		n, err := syscall.SendmsgN(fd.Sysfd, p, oob, sa, 0)
    		if err == syscall.EINTR {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/sys/unix/syscall_zos_s390x.go

    		// TODO(neeilan): Remove 0 arg added to get this compiling on z/OS
    		from, err = anyToSockaddr(0, &rsa)
    	}
    	return
    }
    
    func Sendmsg(fd int, p, oob []byte, to Sockaddr, flags int) (err error) {
    	_, err = SendmsgN(fd, p, oob, to, flags)
    	return
    }
    
    func SendmsgN(fd int, p, oob []byte, to Sockaddr, flags int) (n int, err error) {
    	var ptr unsafe.Pointer
    	var salen _Socklen
    	if to != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 16:12:58 UTC 2024
    - 84.4K bytes
    - Viewed (0)
  4. src/syscall/syscall_linux.go

    	}
    	msg.Iov = &iov
    	msg.Iovlen = 1
    	if n, err = recvmsg(fd, &msg, flags); err != nil {
    		return
    	}
    	oobn = int(msg.Controllen)
    	recvflags = int(msg.Flags)
    	return
    }
    
    func sendmsgN(fd int, p, oob []byte, ptr unsafe.Pointer, salen _Socklen, flags int) (n int, err error) {
    	var msg Msghdr
    	msg.Name = (*byte)(ptr)
    	msg.Namelen = uint32(salen)
    	var iov Iovec
    	if len(p) > 0 {
    		iov.Base = &p[0]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 20:12:46 UTC 2024
    - 35.7K bytes
    - Viewed (0)
  5. internal/grid/connection.go

    		return err
    	}
    	if msg.Flags&FlagCRCxxh3 != 0 {
    		h := xxh3.Hash(dst)
    		dst = binary.LittleEndian.AppendUint32(dst, uint32(h))
    	}
    	return c.send(c.ctx, dst)
    }
    
    // sendMsg will send
    func (c *Connection) sendMsg(conn net.Conn, msg message, payload msgp.MarshalSizer) error {
    	if payload != nil {
    		if sz := payload.Msgsize(); cap(msg.Payload) < sz {
    			PutByteBuffer(msg.Payload)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  6. src/syscall/zsyscall_aix_ppc64.go

    	n = int(r0)
    	if e1 != 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    // THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT
    
    func sendmsg(s int, msg *Msghdr, flags int) (n int, err error) {
    	r0, _, e1 := syscall6(uintptr(unsafe.Pointer(&libc_nsendmsg)), 3, uintptr(s), uintptr(unsafe.Pointer(msg)), uintptr(flags), 0, 0, 0)
    	n = int(r0)
    	if e1 != 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:50:55 UTC 2024
    - 41.7K bytes
    - Viewed (0)
  7. src/syscall/zsyscall_openbsd_arm.go

    func sendmsg(s int, msg *Msghdr, flags int) (n int, err error) {
    	r0, _, e1 := syscall(abi.FuncPCABI0(libc_sendmsg_trampoline), uintptr(s), uintptr(unsafe.Pointer(msg)), uintptr(flags))
    	n = int(r0)
    	if e1 != 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func libc_sendmsg_trampoline()
    
    //go:cgo_import_dynamic libc_sendmsg sendmsg "libc.so"
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 04 07:51:20 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  8. src/syscall/zsyscall_openbsd_riscv64.go

    func sendmsg(s int, msg *Msghdr, flags int) (n int, err error) {
    	r0, _, e1 := syscall(abi.FuncPCABI0(libc_sendmsg_trampoline), uintptr(s), uintptr(unsafe.Pointer(msg)), uintptr(flags))
    	n = int(r0)
    	if e1 != 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func libc_sendmsg_trampoline()
    
    //go:cgo_import_dynamic libc_sendmsg sendmsg "libc.so"
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 04 07:51:20 UTC 2024
    - 47.5K bytes
    - Viewed (0)
  9. src/syscall/zsyscall_openbsd_386.go

    func sendmsg(s int, msg *Msghdr, flags int) (n int, err error) {
    	r0, _, e1 := syscall(abi.FuncPCABI0(libc_sendmsg_trampoline), uintptr(s), uintptr(unsafe.Pointer(msg)), uintptr(flags))
    	n = int(r0)
    	if e1 != 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func libc_sendmsg_trampoline()
    
    //go:cgo_import_dynamic libc_sendmsg sendmsg "libc.so"
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 04 07:51:20 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  10. src/syscall/zsyscall_openbsd_amd64.go

    func sendmsg(s int, msg *Msghdr, flags int) (n int, err error) {
    	r0, _, e1 := syscall(abi.FuncPCABI0(libc_sendmsg_trampoline), uintptr(s), uintptr(unsafe.Pointer(msg)), uintptr(flags))
    	n = int(r0)
    	if e1 != 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func libc_sendmsg_trampoline()
    
    //go:cgo_import_dynamic libc_sendmsg sendmsg "libc.so"
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 04 07:51:20 UTC 2024
    - 47.4K bytes
    - Viewed (0)
Back to top