- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for retryOnEAGAIN (0.26 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) -
src/runtime/os_netbsd.go
uc.uc_link = nil uc.uc_sigmask = sigset_all var oset sigset sigprocmask(_SIG_SETMASK, &sigset_all, &oset) lwp_mcontext_init(&uc.uc_mcontext, stk, mp, mp.g0, abi.FuncPCABI0(netbsdMstart)) ret := retryOnEAGAIN(func() int32 { errno := lwp_create(unsafe.Pointer(&uc), _LWP_DETACHED, unsafe.Pointer(&mp.procid)) // lwp_create returns negative errno return -errno }) sigprocmask(_SIG_SETMASK, &oset, nil)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 10.1K bytes - Viewed (0) -
src/runtime/os_darwin.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: Tue Dec 05 20:34:30 UTC 2023 - 11.9K bytes - Viewed (0) -
src/runtime/os_freebsd.go
parent_tid: nil, tls_base: unsafe.Pointer(&mp.tls[0]), tls_size: unsafe.Sizeof(mp.tls), } var oset sigset sigprocmask(_SIG_SETMASK, &sigset_all, &oset) ret := retryOnEAGAIN(func() int32 { errno := thr_new(¶m, int32(unsafe.Sizeof(param))) // thr_new returns negative errno return -errno }) sigprocmask(_SIG_SETMASK, &oset, nil) if ret != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 11.6K bytes - Viewed (0) -
src/runtime/os3_solaris.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, abi.FuncPCABI0(tstart_sysvicall), 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 - 17.6K bytes - Viewed (0) -
src/runtime/os_linux.go
} // Disable signals during clone, so that the new thread starts // with signals disabled. It will enable them in minit. var oset sigset sigprocmask(_SIG_SETMASK, &sigset_all, &oset) ret := retryOnEAGAIN(func() int32 { r := clone(cloneFlags, stk, unsafe.Pointer(mp), unsafe.Pointer(mp.g0), unsafe.Pointer(abi.FuncPCABI0(mstart))) // clone returns positive TID, negative errno. // We don't care about the TID.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 25.9K bytes - Viewed (0)