- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 500 for fd (0.02 sec)
-
src/internal/poll/fd.go
// exported APIs (now we've got some in net.rawConn) which are only used // internally and are not intended to be used outside the standard libraries, // Therefore, we make those APIs use internal types like poll.FD or poll.String // in their function signatures to disable the usability of these APIs from // external codebase.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 17 23:16:28 UTC 2023 - 3.3K bytes - Viewed (0) -
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/fd_fake.go
} return netfd, nil } func (fd *netFD) setAddr(laddr, raddr Addr) { fd.laddr = laddr fd.raddr = raddr runtime.SetFinalizer(fd, (*netFD).Close) } func (fd *netFD) Close() error { if fd.fakeNetFD != nil { return fd.fakeNetFD.Close() } runtime.SetFinalizer(fd, nil) return fd.pfd.Close() } func (fd *netFD) shutdown(how int) error { if fd.fakeNetFD != nil { return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 20 15:56:08 UTC 2023 - 3.8K bytes - Viewed (0) -
src/net/sock_posix.go
} return fd, nil } func (fd *netFD) ctrlNetwork() string { switch fd.net { case "unix", "unixgram", "unixpacket": return fd.net } switch fd.net[len(fd.net)-1] { case '4', '6': return fd.net } if fd.family == syscall.AF_INET { return fd.net + "4" } return fd.net + "6" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 6.3K bytes - Viewed (0) -
src/net/fd_posix.go
return fd.pfd.Close() } func (fd *netFD) shutdown(how int) error { err := fd.pfd.Shutdown(how) runtime.KeepAlive(fd) return wrapSyscallError("shutdown", err) } func (fd *netFD) closeRead() error { return fd.shutdown(syscall.SHUT_RD) } func (fd *netFD) closeWrite() error { return fd.shutdown(syscall.SHUT_WR) } func (fd *netFD) Read(p []byte) (n int, err error) { n, err = fd.pfd.Read(p)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 29 16:24:51 UTC 2022 - 4.3K bytes - Viewed (0) -
src/syscall/net_wasip1.go
return ENOSYS } func Accept(fd int) (int, Sockaddr, error) { var newfd int32 errno := sock_accept(int32(fd), 0, unsafe.Pointer(&newfd)) return int(newfd), nil, errnoErr(errno) } func Connect(fd int, sa Sockaddr) error { return ENOSYS } func Recvfrom(fd int, p []byte, flags int) (n int, from Sockaddr, err error) { return 0, nil, ENOSYS }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:41 UTC 2023 - 1.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/fdset.go
package unix // Set adds fd to the set fds. func (fds *FdSet) Set(fd int) { fds.Bits[fd/NFDBITS] |= (1 << (uintptr(fd) % NFDBITS)) } // Clear removes fd from the set fds. func (fds *FdSet) Clear(fd int) { fds.Bits[fd/NFDBITS] &^= (1 << (uintptr(fd) % NFDBITS)) } // IsSet returns whether fd is in the set fds. func (fds *FdSet) IsSet(fd int) bool { return fds.Bits[fd/NFDBITS]&(1<<(uintptr(fd)%NFDBITS)) != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 781 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_unixjs.go
if err = fd.pd.waitRead(fd.isFile); err == nil { continue } } } // Do not call eofError; caller does not expect to see io.EOF. return n, err } } // Seek wraps syscall.Seek. func (fd *FD) Seek(offset int64, whence int) (int64, error) { if err := fd.incref(); err != nil { return 0, err } defer fd.decref() return syscall.Seek(fd.Sysfd, offset, whence)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:41 UTC 2023 - 2K bytes - Viewed (0) -
src/net/sockoptip_posix.go
var v int if ifi != nil { v = ifi.Index } err := fd.pfd.SetsockoptInt(syscall.IPPROTO_IPV6, syscall.IPV6_MULTICAST_IF, v) runtime.KeepAlive(fd) return wrapSyscallError("setsockopt", err) } func setIPv6MulticastLoopback(fd *netFD, v bool) error { err := fd.pfd.SetsockoptInt(syscall.IPPROTO_IPV6, syscall.IPV6_MULTICAST_LOOP, boolint(v)) runtime.KeepAlive(fd)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 29 16:24:51 UTC 2022 - 1.4K bytes - Viewed (0)