- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 159 for fd (0.02 sec)
-
src/internal/poll/fd_plan9.go
} func setDeadlineImpl(fd *FD, t time.Time, mode int) error { d := t.Sub(time.Now()) if mode == 'r' || mode == 'r'+'w' { fd.rmu.Lock() defer fd.rmu.Unlock() if fd.rtimer != nil { fd.rtimer.Stop() fd.rtimer = nil } fd.rtimedout = false } if mode == 'w' || mode == 'r'+'w' { fd.wmu.Lock() defer fd.wmu.Unlock() if fd.wtimer != nil { fd.wtimer.Stop()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 06 14:00:54 UTC 2024 - 5.4K bytes - Viewed (0) -
src/net/tcpsock_windows.go
return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } } else if err := setKeepAliveIdleAndInterval(c.fd, config.Idle, config.Interval); err != nil { return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } if err := setKeepAliveCount(c.fd, config.Count); err != nil { return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 11:49:35 UTC 2024 - 1.3K bytes - Viewed (0) -
src/internal/poll/fd_poll_runtime.go
func (fd *FD) SetDeadline(t time.Time) error { return setDeadlineImpl(fd, t, 'r'+'w') } // SetReadDeadline sets the read deadline associated with fd. func (fd *FD) SetReadDeadline(t time.Time) error { return setDeadlineImpl(fd, t, 'r') } // SetWriteDeadline sets the write deadline associated with fd. func (fd *FD) SetWriteDeadline(t time.Time) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:59 UTC 2024 - 4.2K bytes - Viewed (0) -
src/net/file_plan9.go
if err != nil { return nil, err } switch fd.laddr.(type) { case *TCPAddr: return newTCPConn(fd, defaultTCPKeepAliveIdle, KeepAliveConfig{}, testPreHookSetKeepAlive, testHookSetKeepAlive), nil case *UDPAddr: return newUDPConn(fd), nil } return nil, syscall.EPLAN9 } func fileListener(f *os.File) (Listener, error) { fd, err := newFileFD(f)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.8K bytes - Viewed (0) -
src/net/rawconn.go
if !c.ok() { return syscall.EINVAL } err := c.fd.pfd.RawRead(f) runtime.KeepAlive(c.fd) if err != nil { err = &OpError{Op: "raw-read", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } return err } func (c *rawConn) Write(f func(uintptr) bool) error { if !c.ok() { return syscall.EINVAL } err := c.fd.pfd.RawWrite(f) runtime.KeepAlive(c.fd) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 2.7K bytes - Viewed (0) -
src/net/tcpsock_unix.go
return syscall.EINVAL } if err := setKeepAlive(c.fd, config.Enable); err != nil { return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } if err := setKeepAliveIdle(c.fd, config.Idle); err != nil { return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } if err := setKeepAliveInterval(c.fd, config.Interval); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 1.1K bytes - Viewed (0) -
src/internal/poll/writev.go
"runtime" "syscall" ) // Writev wraps the writev system call. func (fd *FD) Writev(v *[][]byte) (int64, error) { if err := fd.writeLock(); err != nil { return 0, err } defer fd.writeUnlock() if err := fd.pd.prepareWrite(fd.isFile); err != nil { return 0, err } var iovecs []syscall.Iovec if fd.iovecs != nil { iovecs = *fd.iovecs } // TODO: read from sysconf(_SC_IOV_MAX)? The Linux default is
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 1.8K bytes - Viewed (0) -
src/net/tcpsock_solaris.go
} if err := setKeepAliveCount(c.fd, config.Count); err != nil { return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } } else if err := setKeepAliveIdleAndIntervalAndCount(c.fd, config.Idle, config.Interval, config.Count); err != nil { return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 1.3K bytes - Viewed (0) -
src/net/tcpconn_keepalive_illumos_test.go
"time" ) func getCurrentKeepAliveSettings(fd fdType) (cfg KeepAliveConfig, err error) { tcpKeepAlive, err := syscall.GetsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_KEEPALIVE) if err != nil { return } tcpKeepAliveIdle, err := syscall.GetsockoptInt(fd, syscall.IPPROTO_TCP, syscall_TCP_KEEPIDLE) if err != nil { return } tcpKeepAliveInterval, err := syscall.GetsockoptInt(fd, syscall.IPPROTO_TCP, syscall_TCP_KEEPINTVL)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:17:21 UTC 2024 - 4K bytes - Viewed (0) -
src/internal/poll/fd_wasip1.go
return CloseFunc(fd) } // Copy creates a copy of the FD. // // The FD instance points to the same underlying file descriptor. The file // descriptor isn't closed until all FD instances that refer to it have been // closed/destroyed. func (fd *FD) Copy() FD { return FD{ Sysfd: fd.Sysfd, SysFile: fd.SysFile.ref(), IsStream: fd.IsStream, ZeroReadIsEOF: fd.ZeroReadIsEOF,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 20:14:02 UTC 2024 - 6.7K bytes - Viewed (0)