- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for retryOnEAGAIN (0.22 sec)
-
src/runtime/retry.go
//go:build unix package runtime // retryOnEAGAIN retries a function until it does not return EAGAIN. // It will use an increasing delay between calls, and retry up to 20 times. // The function argument is expected to return an errno value, // and retryOnEAGAIN will return any errno value other than EAGAIN. // If all retries return EAGAIN, then retryOnEAGAIN will return EAGAIN. func retryOnEAGAIN(fn func() int32) int32 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 10 20:44:45 UTC 2022 - 760 bytes - Viewed (0) -
src/runtime/os_openbsd_libc.go
exit(1) } // Finally, create the thread. It starts at mstart_stub, which does some low-level // setup and then calls mstart. var oset sigset sigprocmask(_SIG_SETMASK, &sigset_all, &oset) err := retryOnEAGAIN(func() int32 { return pthread_create(&attr, abi.FuncPCABI0(mstart_stub), unsafe.Pointer(mp)) }) sigprocmask(_SIG_SETMASK, &oset, nil) if err != 0 { writeErrStr(failthreadcreate) exit(1) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 10 20:44:45 UTC 2022 - 1.5K bytes - Viewed (0) -
src/runtime/os_openbsd_syscall.go
tf_tcb: unsafe.Pointer(&mp.tls[0]), tf_tid: nil, // minit will record tid tf_stack: uintptr(stk) - goarch.PtrSize, } var oset sigset sigprocmask(_SIG_SETMASK, &sigset_all, &oset) ret := retryOnEAGAIN(func() int32 { errno := tfork(¶m, unsafe.Sizeof(param), mp, mp.g0, abi.FuncPCABI0(mstart)) // tfork returns negative errno return -errno }) sigprocmask(_SIG_SETMASK, &oset, nil) if ret != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 10 20:44:45 UTC 2022 - 1.4K bytes - Viewed (0) -
src/runtime/os_dragonfly.go
start_func: abi.FuncPCABI0(lwp_start), arg: unsafe.Pointer(mp), stack: uintptr(stk), tid1: nil, // minit will record tid tid2: nil, } // TODO: Check for error. retryOnEAGAIN(func() int32 { lwp_create(¶ms) return 0 }) sigprocmask(_SIG_SETMASK, &oset, nil) } func osinit() { ncpu = getncpu() if physPageSize == 0 { physPageSize = getPageSize() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 7.1K bytes - Viewed (0) -
src/runtime/os_aix.go
} // Disable signals during create, so that the new thread starts // with signals disabled. It will enable them in minit. sigprocmask(_SIG_SETMASK, &sigset_all, &oset) ret := retryOnEAGAIN(func() int32 { return pthread_create(&tid, &attr, &tstart, unsafe.Pointer(mp)) }) sigprocmask(_SIG_SETMASK, &oset, nil) if ret != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.9K bytes - Viewed (0)