- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,164 for Decref (0.13 sec)
-
src/internal/poll/sockopt.go
if err := fd.incref(); err != nil { return err } defer fd.decref() return syscall.SetsockoptInt(fd.Sysfd, level, name, arg) } // SetsockoptInet4Addr wraps the setsockopt network call with an IPv4 address. func (fd *FD) SetsockoptInet4Addr(level, name int, arg [4]byte) error { if err := fd.incref(); err != nil { return err } defer fd.decref()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 18 13:44:49 UTC 2023 - 1.3K bytes - Viewed (0) -
src/internal/poll/export_test.go
package poll var Consume = consume type XFDMutex struct { fdMutex } func (mu *XFDMutex) Incref() bool { return mu.incref() } func (mu *XFDMutex) IncrefAndClose() bool { return mu.increfAndClose() } func (mu *XFDMutex) Decref() bool { return mu.decref() } func (mu *XFDMutex) RWLock(read bool) bool { return mu.rwlock(read) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 08 03:57:40 UTC 2022 - 714 bytes - Viewed (0) -
src/internal/poll/fd_posix.go
// Shutdown wraps syscall.Shutdown. func (fd *FD) Shutdown(how int) error { if err := fd.incref(); err != nil { return err } defer fd.decref() return syscall.Shutdown(fd.Sysfd, how) } // 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) })
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/os/file_mutex_plan9.go
} } return err } // decref removes a reference to the file. If this is the last // remaining reference, and the file has been marked to be closed, // then actually close it. func (file *file) decref() error { if file.fdmu.Decref() { return file.destroy() } return nil } // readLock adds a reference to the file and locks it for reading. // It returns an error if the file is already closed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 08 03:57:40 UTC 2022 - 1.8K bytes - Viewed (0) -
src/internal/poll/fd_mutex_test.go
ensurePanics(func() { mu.RWUnlock(false) }) ensurePanics(func() { mu.Incref(); mu.Decref(); mu.Decref() }) ensurePanics(func() { mu.RWLock(true); mu.RWUnlock(true); mu.RWUnlock(true) }) ensurePanics(func() { mu.RWLock(false); mu.RWUnlock(false); mu.RWUnlock(false) }) // ensure that it's still not broken mu.Incref() mu.Decref() mu.RWLock(true) mu.RWUnlock(true) mu.RWLock(false) mu.RWUnlock(false) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 08 03:57:40 UTC 2022 - 4K bytes - Viewed (0) -
src/internal/poll/fd_mutex.go
// // Misc operations must do incref/decref. // Misc operations include functions like setsockopt and setDeadline. // They need to use incref/decref to ensure that they operate on the // correct fd in presence of a concurrent close call (otherwise fd can // be closed under their feet). // // Close operations must do increfAndClose/decref. // incref adds a reference to mu.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0) -
src/internal/poll/fd_fsync_windows.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 07 20:27:01 UTC 2018 - 358 bytes - Viewed (0) -
src/internal/poll/fd_unixjs.go
func (fd *FD) Fchdir() error { if err := fd.incref(); err != nil { return err } defer fd.decref() return syscall.Fchdir(fd.Sysfd) } // ReadDirent wraps syscall.ReadDirent. // We treat this like an ordinary system call rather than a call // that tries to fill the buffer. func (fd *FD) ReadDirent(buf []byte) (int, error) { if err := fd.incref(); err != nil { return 0, err } defer fd.decref()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:41 UTC 2023 - 2K bytes - Viewed (0) -
src/internal/poll/sockoptip.go
if err := fd.incref(); err != nil { return err } defer fd.decref() return syscall.SetsockoptIPMreq(fd.Sysfd, level, name, mreq) } // SetsockoptIPv6Mreq wraps the setsockopt network call with an IPv6Mreq argument. func (fd *FD) SetsockoptIPv6Mreq(level, name int, mreq *syscall.IPv6Mreq) error { if err := fd.incref(); err != nil { return err } defer fd.decref()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 29 16:24:51 UTC 2022 - 817 bytes - Viewed (0) -
src/internal/poll/file_plan9.go
// FDMutex is an exported fdMutex, only for Plan 9. type FDMutex struct { fdmu fdMutex } func (fdmu *FDMutex) Incref() bool { return fdmu.fdmu.incref() } func (fdmu *FDMutex) Decref() bool { return fdmu.fdmu.decref() } func (fdmu *FDMutex) IncrefAndClose() bool { return fdmu.fdmu.increfAndClose() } func (fdmu *FDMutex) ReadLock() bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 08 03:57:40 UTC 2022 - 972 bytes - Viewed (0)