- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 747 for fd (0.02 sec)
-
pkg/proto/merge/merge.go
} src.Range(func(fd protoreflect.FieldDescriptor, v protoreflect.Value) bool { switch { case fd.IsList(): o.mergeList(dst.Mutable(fd).List(), v.List(), fd) case fd.IsMap(): o.mergeMap(dst.Mutable(fd).Map(), v.Map(), fd.MapValue()) case fd.Message() != nil: mergeFn, exists := o.customMergeFn[fd.Message().FullName()] if exists { mergeFn(dst.Mutable(fd).Message(), v.Message()) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 21 17:31:22 UTC 2022 - 4.8K bytes - Viewed (0) -
src/internal/poll/fd_poll_js.go
// SetDeadline sets the read and write deadlines associated with fd. 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 25 00:12:40 UTC 2023 - 2.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/syscall/zsysnum_freebsd_386.go
SYS_FACCESSAT = 489 // { int faccessat(int fd, char *path, int amode, \ SYS_FCHMODAT = 490 // { int fchmodat(int fd, char *path, mode_t mode, \ SYS_FCHOWNAT = 491 // { int fchownat(int fd, char *path, uid_t uid, \ SYS_FEXECVE = 492 // { int fexecve(int fd, char **argv, \ SYS_FUTIMESAT = 494 // { int futimesat(int fd, char *path, \
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 16 01:17:28 UTC 2022 - 25.5K bytes - Viewed (0) -
src/internal/poll/fd_posix.go
// Fchown wraps syscall.Fchown. func (fd *FD) Fchown(uid, gid int) error { if err := fd.incref(); err != nil { return err } defer fd.decref() return ignoringEINTR(func() error { return syscall.Fchown(fd.Sysfd, uid, gid) }) } // Ftruncate wraps syscall.Ftruncate. func (fd *FD) Ftruncate(size int64) error { if err := fd.incref(); err != nil { return err } defer fd.decref() return ignoringEINTR(func() error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 07 23:34:17 UTC 2023 - 1.9K 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/sockopt_posix.go
} return nil } func setReadBuffer(fd *netFD, bytes int) error { err := fd.pfd.SetsockoptInt(syscall.SOL_SOCKET, syscall.SO_RCVBUF, bytes) runtime.KeepAlive(fd) return wrapSyscallError("setsockopt", err) } func setWriteBuffer(fd *netFD, bytes int) error { err := fd.pfd.SetsockoptInt(syscall.SOL_SOCKET, syscall.SO_SNDBUF, bytes) runtime.KeepAlive(fd) return wrapSyscallError("setsockopt", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 25 15:06:47 UTC 2023 - 2.1K 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/net/fd_unix.go
ls = fd.laddr.String() } if fd.raddr != nil { rs = fd.raddr.String() } return fd.net + ":" + ls + "->" + rs } func (fd *netFD) connect(ctx context.Context, la, ra syscall.Sockaddr) (rsa syscall.Sockaddr, ret error) { // Do not need to call fd.writeLock here, // because fd is not yet accessible to user, // so no concurrent operations are possible. switch err := connectFunc(fd.pfd.Sysfd, ra); err {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 20:19:46 UTC 2023 - 5.4K bytes - Viewed (0)