Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for nrecvmsg (0.3 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) {
    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/syscall/zsyscall_aix_ppc64.go

    //go:cgo_import_dynamic libc_recvfrom recvfrom "libc.a/shr_64.o"
    //go:cgo_import_dynamic libc_sendto sendto "libc.a/shr_64.o"
    //go:cgo_import_dynamic libc_Shutdown shutdown "libc.a/shr_64.o"
    //go:cgo_import_dynamic libc_nrecvmsg nrecvmsg "libc.a/shr_64.o"
    //go:cgo_import_dynamic libc_nsendmsg nsendmsg "libc.a/shr_64.o"
    //go:cgo_import_dynamic libc_accept accept "libc.a/shr_64.o"
    //go:cgo_import_dynamic libc_Openat openat "libc.a/shr_64.o"
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:50:55 UTC 2024
    - 41.7K bytes
    - Viewed (0)
  3. src/net/tcpsock_test.go

    		if conns > b.N {
    			conns = b.N
    		}
    	}
    	sendMsg := func(c Conn, buf []byte) bool {
    		n, err := c.Write(buf)
    		if n != len(buf) || err != nil {
    			b.Log(err)
    			return false
    		}
    		return true
    	}
    	recvMsg := func(c Conn, buf []byte) bool {
    		for read := 0; read != len(buf); {
    			n, err := c.Read(buf)
    			read += n
    			if err != nil {
    				b.Log(err)
    				return false
    			}
    		}
    		return true
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  4. src/runtime/select.go

    	if nsends+nrecvs == 0 {
    		return dflt, false
    	}
    
    	// Compact sel and orig if necessary.
    	if nsends+nrecvs < len(cases) {
    		copy(sel[nsends:], sel[len(cases)-nrecvs:])
    		copy(orig[nsends:], orig[len(cases)-nrecvs:])
    	}
    
    	order := make([]uint16, 2*(nsends+nrecvs))
    	var pc0 *uintptr
    	if raceenabled {
    		pcs := make([]uintptr, nsends+nrecvs)
    		for i := range pcs {
    			selectsetpc(&pcs[i])
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 13 21:36:04 UTC 2024
    - 15K bytes
    - Viewed (0)
  5. src/syscall/syscall_solaris.go

    		if len(p) == 0 {
    			iov.Base = &dummy
    			iov.SetLen(1)
    		}
    		msg.Accrights = (*int8)(unsafe.Pointer(&oob[0]))
    		msg.Accrightslen = int32(len(oob))
    	}
    	msg.Iov = &iov
    	msg.Iovlen = 1
    	if n, err = recvmsg(fd, &msg, flags); err != nil {
    		return
    	}
    	oobn = int(msg.Accrightslen)
    	return
    }
    
    //sys	sendmsg(s int, msg *Msghdr, flags int) (n int, err error) = libsocket.__xnet_sendmsg
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 21:03:59 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  6. src/internal/poll/fd_unix.go

    	}
    }
    
    // ReadMsg wraps the recvmsg network call.
    func (fd *FD) ReadMsg(p []byte, oob []byte, flags int) (int, int, int, syscall.Sockaddr, error) {
    	if err := fd.readLock(); err != nil {
    		return 0, 0, 0, nil, err
    	}
    	defer fd.readUnlock()
    	if err := fd.pd.prepareRead(fd.isFile); err != nil {
    		return 0, 0, 0, nil, err
    	}
    	for {
    		n, oobn, sysflags, sa, err := syscall.Recvmsg(fd.Sysfd, p, oob, flags)
    		if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  7. src/syscall/syscall_unix.go

    	pp := (*RawSockaddrInet6)(unsafe.Pointer(&rsa))
    	port := (*[2]byte)(unsafe.Pointer(&pp.Port))
    	from.Port = int(port[0])<<8 + int(port[1])
    	from.ZoneId = pp.Scope_id
    	from.Addr = pp.Addr
    	return
    }
    
    func Recvmsg(fd int, p, oob []byte, flags int) (n, oobn int, recvflags int, from Sockaddr, err error) {
    	var rsa RawSockaddrAny
    	n, oobn, recvflags, err = recvmsgRaw(fd, p, oob, flags, &rsa)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 19 16:19:26 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/typecheck/_builtin/runtime.go

    func selectnbsend(hchan chan<- any, elem *any) bool
    func selectnbrecv(elem *any, hchan <-chan any) (bool, bool)
    
    func selectsetpc(pc *uintptr)
    func selectgo(cas0 *byte, order0 *byte, pc0 *uintptr, nsends int, nrecvs int, block bool) (int, bool)
    func block()
    
    func makeslice(typ *byte, len int, cap int) unsafe.Pointer
    func makeslice64(typ *byte, len int64, cap int64) unsafe.Pointer
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 21:08:03 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. src/syscall/zsyscall_openbsd_arm.go

    func recvmsg(s int, msg *Msghdr, flags int) (n int, err error) {
    	r0, _, e1 := syscall(abi.FuncPCABI0(libc_recvmsg_trampoline), uintptr(s), uintptr(unsafe.Pointer(msg)), uintptr(flags))
    	n = int(r0)
    	if e1 != 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func libc_recvmsg_trampoline()
    
    //go:cgo_import_dynamic libc_recvmsg recvmsg "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_riscv64.go

    func recvmsg(s int, msg *Msghdr, flags int) (n int, err error) {
    	r0, _, e1 := syscall(abi.FuncPCABI0(libc_recvmsg_trampoline), uintptr(s), uintptr(unsafe.Pointer(msg)), uintptr(flags))
    	n = int(r0)
    	if e1 != 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func libc_recvmsg_trampoline()
    
    //go:cgo_import_dynamic libc_recvmsg recvmsg "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)
Back to top