- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 63 for plfd (0.03 sec)
-
src/net/tcpsockopt_windows.go
secs := int(roundDurationUp(d, time.Second)) err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, windows.TCP_KEEPINTVL, secs) runtime.KeepAlive(fd) return os.NewSyscallError("setsockopt", err) } func setKeepAliveCount(fd *netFD, n int) error { if n == 0 { n = defaultTCPKeepAliveCount } else if n < 0 { return nil } err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, windows.TCP_KEEPCNT, n)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 11:49:35 UTC 2024 - 3.8K bytes - Viewed (0) -
src/internal/poll/splice_linux_test.go
for i := 0; i < N; i++ { p, err = poll.GetPipe() if err != nil { t.Skipf("failed to create pipe due to error(%v), skip this test", err) } _, pwfd := poll.GetPipeFds(p) allFDs = append(allFDs, pwfd) pendingFDs.Store(pwfd, struct{}{}) ps = append(ps, p) } for _, p = range ps { poll.PutPipe(p) } ps = nil p = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 2.8K bytes - Viewed (0) -
src/runtime/netpoll_aix.go
delta := int32(0) for i := 1; i < len(pfds) && n > 0; i++ { pfd := &pfds[i] var mode int32 if pfd.revents&(_POLLIN|_POLLHUP|_POLLERR) != 0 { mode += 'r' pfd.events &= ^_POLLIN } if pfd.revents&(_POLLOUT|_POLLHUP|_POLLERR) != 0 { mode += 'w' pfd.events &= ^_POLLOUT } if mode != 0 { pds[i].setEventErr(pfd.revents == _POLLERR, 0) delta += netpollready(&toRun, pds[i], mode)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0) -
src/net/fd_plan9.go
return syscall.EPLAN9 } func (fd *netFD) SetDeadline(t time.Time) error { return fd.pfd.SetDeadline(t) } func (fd *netFD) SetReadDeadline(t time.Time) error { return fd.pfd.SetReadDeadline(t) } func (fd *netFD) SetWriteDeadline(t time.Time) error { return fd.pfd.SetWriteDeadline(t)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 04 16:01:50 UTC 2018 - 3.6K bytes - Viewed (0) -
src/os/file_posix.go
func (f *File) read(b []byte) (n int, err error) { n, err = f.pfd.Read(b) runtime.KeepAlive(f) return n, err } // pread reads len(b) bytes from the File starting at byte offset off. // It returns the number of bytes read and the error, if any. // EOF is signaled by a zero count with err set to nil. func (f *File) pread(b []byte, off int64) (n int, err error) { n, err = f.pfd.Pread(b, off) runtime.KeepAlive(f) return n, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 7.1K bytes - Viewed (0) -
src/net/write_unix_test.go
// Loop writing to the server. The server is not reading // anything, so this will eventually block, and then time out. b := bytes.Repeat([]byte{'a'}, 8192) cagain := 0 for { n, err := ss.conn.fd.pfd.WriteOnce(b) if n > 0 { cagain = 0 } switch err { case nil: case syscall.EAGAIN: if cagain == 0 { // We've written enough data to // start blocking. Set a deadline
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 1.6K bytes - Viewed (0) -
src/net/tcpsockopt_unix.go
secs := int(roundDurationUp(d, time.Second)) err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, secs) runtime.KeepAlive(fd) return wrapSyscallError("setsockopt", err) } func setKeepAliveCount(fd *netFD, n int) error { if n == 0 { n = defaultTCPKeepAliveCount } else if n < 0 { return nil } err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, syscall.TCP_KEEPCNT, n)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:17:21 UTC 2024 - 1.3K bytes - Viewed (0) -
src/net/tcpsockopt_posix.go
// license that can be found in the LICENSE file. //go:build unix || windows package net import ( "runtime" "syscall" ) func setNoDelay(fd *netFD, noDelay bool) error { err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, syscall.TCP_NODELAY, boolint(noDelay)) runtime.KeepAlive(fd) return wrapSyscallError("setsockopt", err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 29 16:24:51 UTC 2022 - 442 bytes - Viewed (0) -
src/net/sockoptip_linux.go
var v int32 if ifi != nil { v = int32(ifi.Index) } mreq := &syscall.IPMreqn{Ifindex: v} err := fd.pfd.SetsockoptIPMreqn(syscall.IPPROTO_IP, syscall.IP_MULTICAST_IF, mreq) runtime.KeepAlive(fd) return wrapSyscallError("setsockopt", err) } func setIPv4MulticastLoopback(fd *netFD, v bool) error { err := fd.pfd.SetsockoptInt(syscall.IPPROTO_IP, syscall.IP_MULTICAST_LOOP, boolint(v)) runtime.KeepAlive(fd)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 13 18:36:28 UTC 2017 - 735 bytes - Viewed (0) -
src/net/sockoptip_bsdvar.go
return wrapSyscallError("setsockopt", err) } var a [4]byte copy(a[:], ip.To4()) err = fd.pfd.SetsockoptInet4Addr(syscall.IPPROTO_IP, syscall.IP_MULTICAST_IF, a) runtime.KeepAlive(fd) return wrapSyscallError("setsockopt", err) } func setIPv4MulticastLoopback(fd *netFD, v bool) error { err := fd.pfd.SetsockoptByte(syscall.IPPROTO_IP, syscall.IP_MULTICAST_LOOP, byte(boolint(v))) runtime.KeepAlive(fd)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 867 bytes - Viewed (0)