- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 704 for wait4 (0.06 sec)
-
src/syscall/zsyscall_openbsd_riscv64.go
err = errnoErr(e1) } return } func libc_setgroups_trampoline() //go:cgo_import_dynamic libc_setgroups setgroups "libc.so" // THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT func wait4(pid int, wstatus *_C_int, options int, rusage *Rusage) (wpid int, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 04 07:51:20 UTC 2024 - 47.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
// WaitForAPI waits for the API Server's /healthz endpoint to become "ok" // TODO: remove WaitForAPI once WaitForAllControlPlaneComponents goes GA: // https://github.com/kubernetes/kubeadm/issues/2907 WaitForAPI() error // WaitForPodsWithLabel waits for Pods in the kube-system namespace to become Ready WaitForPodsWithLabel(kvLabel string) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/syscall_zos_s390x.go
if int64(r0) == -1 { err = errnoErr2(e1, e2) } return } //go:nosplit func get_Wait4Addr() *(func(pid int, wstatus *WaitStatus, options int, rusage *Rusage) (wpid int, err error)) var Wait4 = enter_Wait4 func enter_Wait4(pid int, wstatus *WaitStatus, options int, rusage *Rusage) (wpid int, err error) { funcref := get_Wait4Addr() if funcptrtest(GetZosLibVec()+SYS_WAIT4<<4, "") == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 16:12:58 UTC 2024 - 84.4K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/wait-on-pipe.go
time.Sleep(100 * time.Millisecond) // Write to the pipe to unblock it. if _, err := syscall.Write(wfd, []byte{10}); err != nil { log.Fatalf("failed to write to pipe: %v", err) } // Wait for the goroutine to unblock and start running. // This is helpful to catch incorrect information written // down for the syscall-blocked goroutine, since it'll start // executing, and that execution information will be
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.6K bytes - Viewed (0) -
src/sync/waitgroup.go
package sync import ( "internal/race" "sync/atomic" "unsafe" ) // A WaitGroup waits for a collection of goroutines to finish. // The main goroutine calls [WaitGroup.Add] to set the number of // goroutines to wait for. Then each of the goroutines // runs and calls [WaitGroup.Done] when finished. At the same time, // [WaitGroup.Wait] can be used to block until all goroutines have finished. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
src/runtime/lock_sema.go
// to the caller. // This reduces the nosplit footprint of notetsleep_internal. gp = getg() // Register for wakeup on n->waitm. if !atomic.Casuintptr(&n.key, 0, uintptr(unsafe.Pointer(gp.m))) { // Must be locked (got wakeup). if n.key != locked { throw("notetsleep - waitm out of sync") } return true } if ns < 0 { // Queued. Sleep. gp.m.blocked = true if *cgo_yield == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
src/os/exec/exec.go
// // If any of c.Stdin, c.Stdout or c.Stderr are not an [*os.File], Wait also waits // for the respective I/O loop copying to or from the process to complete. // // Wait releases any resources associated with the [Cmd]. func (c *Cmd) Wait() error { if c.Process == nil { return errors.New("exec: not started") } if c.ProcessState != nil { return errors.New("exec: Wait was already called") } state, err := c.Process.Wait()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
) const ( // reconcilerLoopSleepPeriod is the amount of time the reconciler loop waits // between successive executions reconcilerLoopSleepPeriod = 100 * time.Millisecond // desiredStateOfWorldPopulatorLoopSleepPeriod is the amount of time the // DesiredStateOfWorldPopulator loop waits between successive executions desiredStateOfWorldPopulatorLoopSleepPeriod = 100 * time.Millisecond
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
<-c.syncedInitialSet } func (c *crdRegistrationController) runWorker() { // hot loop until we're told to stop. processNextWorkItem will automatically wait until there's work // available, so we don't worry about secondary waits for c.processNextWorkItem() { } } // processNextWorkItem deals with one key off the queue. It returns false when it's time to quit. func (c *crdRegistrationController) processNextWorkItem() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
src/os/exec.go
return p.kill() } // Wait waits for the [Process] to exit, and then returns a // ProcessState describing its status and an error, if any. // Wait releases any resources associated with the Process. // On most operating systems, the Process must be a child // of the current process or an error will be returned. func (p *Process) Wait() (*ProcessState, error) { return p.wait() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0)