- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 225 for decref (2.29 sec)
-
src/internal/poll/fd_fsync_posix.go
package poll import "syscall" // Fsync wraps syscall.Fsync. func (fd *FD) Fsync() error { if err := fd.incref(); err != nil { return err } defer fd.decref() return ignoringEINTR(func() error { return syscall.Fsync(fd.Sysfd) })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 07 23:34:17 UTC 2023 - 507 bytes - Viewed (0) -
src/internal/poll/fd_fsync_darwin.go
// on OS X, SYS_FSYNC doesn't fully flush contents to disk. // See Issue #26650 as well as the man page for fsync on OS X. func (fd *FD) Fsync() error { if err := fd.incref(); err != nil { return err } defer fd.decref() return ignoringEINTR(func() error { _, err := unix.Fcntl(fd.Sysfd, syscall.F_FULLFSYNC, 0) // There are scenarios such as SMB mounts where fcntl will fail
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 19:20:48 UTC 2024 - 850 bytes - Viewed (0) -
src/internal/poll/fd_wasip1.go
func (fd *FD) Fchdir() error { if err := fd.incref(); err != nil { return err } defer fd.decref() return syscall.Chdir(fd.Path) } // ReadDir wraps syscall.ReadDir. // We treat this like an ordinary system call rather than a call // that tries to fill the buffer. func (fd *FD) ReadDir(buf []byte, cookie syscall.Dircookie) (int, error) { if err := fd.incref(); err != nil { return 0, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 20:14:02 UTC 2024 - 6.7K bytes - Viewed (0) -
src/internal/poll/fd_poll_js.go
d := t.UnixNano() if t.IsZero() { d = 0 } if err := fd.incref(); err != nil { return err } switch mode { case 'r': syscall.SetReadDeadline(fd.Sysfd, d) case 'w': syscall.SetWriteDeadline(fd.Sysfd, d) case 'r' + 'w': syscall.SetReadDeadline(fd.Sysfd, d) syscall.SetWriteDeadline(fd.Sysfd, d) } fd.decref() return nil }
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/os/stat_plan9.go
for i := 0; i < 2; i++ { buf := make([]byte, bitSize16+size) var n int switch a := arg.(type) { case *File: name = a.name if err := a.incref("fstat"); err != nil { return nil, err } n, err = syscall.Fstat(a.fd, buf) a.decref() case string: name = a n, err = syscall.Stat(a, buf) default: panic("phase error in dirstat") } if n < bitSize16 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 08 03:57:40 UTC 2022 - 2.4K bytes - Viewed (0) -
src/internal/poll/fd_windows.go
// Fchdir wraps syscall.Fchdir. func (fd *FD) Fchdir() error { if err := fd.incref(); err != nil { return err } defer fd.decref() return syscall.Fchdir(fd.Sysfd) } // GetFileType wraps syscall.GetFileType. func (fd *FD) GetFileType() (uint32, error) { if err := fd.incref(); err != nil { return 0, err } defer fd.decref() return syscall.GetFileType(fd.Sysfd) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 16:50:42 UTC 2024 - 34.1K bytes - Viewed (0) -
src/internal/poll/fd_poll_runtime.go
var d int64 if !t.IsZero() { d = int64(time.Until(t)) if d == 0 { d = -1 // don't confuse deadline right now with no deadline } } if err := fd.incref(); err != nil { return err } defer fd.decref() if fd.pd.runtimeCtx == 0 { return ErrNoDeadline } runtime_pollSetDeadline(fd.pd.runtimeCtx, d, mode) return nil }
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/encoding/gob/decgen.go
slice[i] = uintptr(x)`, }, // uint8 Handled separately. } func main() { log.SetFlags(0) log.SetPrefix("decgen: ") flag.Parse() if flag.NArg() != 0 { log.Fatal("usage: decgen [--output filename]") } var b bytes.Buffer fmt.Fprintf(&b, "// Code generated by go run decgen.go -output %s; DO NOT EDIT.\n", *output) fmt.Fprint(&b, header) printMaps(&b, "Array") fmt.Fprint(&b, "\n")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 20 14:15:38 UTC 2024 - 5.3K bytes - Viewed (0) -
istioctl/pkg/util/configdump/secret.go
} // GetRootCAFromSecretConfigDump retrieves root CA from a secret config dump wrapper func (w *Wrapper) GetRootCAFromSecretConfigDump(anySec *anypb.Any) (string, error) { var secret extapi.Secret if err := anySec.UnmarshalTo(&secret); err != nil { return "", fmt.Errorf("failed to unmarshall ROOTCA secret: %v", err) } var returnStr string var returnErr error rCASecret := secret.GetValidationContext() if rCASecret != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 25 04:09:53 UTC 2023 - 2.2K bytes - Viewed (0) -
pkg/config/analysis/diag/message.go
docQueryString := "" if m.DocRef != "" { docQueryString = fmt.Sprintf("?ref=%s", m.DocRef) } result["documentationUrl"] = fmt.Sprintf("%s/%s/%s", url.ConfigAnalysis, strings.ToLower(m.Type.Code()), docQueryString) return result } func (m *Message) AnalysisMessageBase() *v1alpha1.AnalysisMessageBase { docQueryString := "" if m.DocRef != "" { docQueryString = fmt.Sprintf("?ref=%s", m.DocRef) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 10 02:05:07 UTC 2022 - 5.1K bytes - Viewed (0)