- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 536 for waitc (0.15 sec)
-
src/os/wait6_dragonfly.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package os import ( "syscall" "unsafe" ) const _P_PID = 0 func wait6(idtype, id, options int) (status int, errno syscall.Errno) { var status32 int32 // C.int _, _, errno = syscall.Syscall6(syscall.SYS_WAIT6, uintptr(idtype), uintptr(id), uintptr(unsafe.Pointer(&status32)), uintptr(options), 0, 0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 13 21:25:45 UTC 2022 - 496 bytes - Viewed (0) -
src/cmd/go/internal/script/state.go
return s, nil } // CloseAndWait cancels the State's Context and waits for any background commands to // finish. If any remaining background command ended in an unexpected state, // Close returns a non-nil error. func (s *State) CloseAndWait(log io.Writer) error { s.cancel() wait, err := Wait().Run(s) if wait != nil { panic("script: internal error: Wait unexpectedly returns its own WaitFunc") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 31 20:33:02 UTC 2023 - 6.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
protected CountDownLatch latch; protected ListenableFuture<Boolean> future; @Override protected void setUp() throws Exception { // Create a latch and a future that waits on the latch. latch = new CountDownLatch(1); future = createListenableFuture(Boolean.TRUE, null, latch); } @Override protected void tearDown() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
test/fixedbugs/issue44370.dir/a.go
// Copyright 2021 The Go Authors. All rights reserved. Use of this // source code is governed by a BSD-style license that can be found in // the LICENSE file. package a // A StoppableWaitGroup waits for a collection of goroutines to finish. type StoppableWaitGroup struct { // i is the internal counter which can store tolerate negative values // as opposed the golang's library WaitGroup. i *int64 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 26 02:11:50 UTC 2021 - 682 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/finisher/finisher.go
// kick off a goroutine (receiver) here to wait for the sender (goroutine executing ResultFunc) // to send the result and then log details of the result. defer func() { go func() { timedOutAt := time.Now() var result *result select { case result = <-resultCh: case <-time.After(postTimeoutWait): // we will not wait forever, if we are here then we know that some sender
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 07 14:20:33 UTC 2021 - 6K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
Context string // DryRun performs all steps except actually applying the manifests or creating output dirs/files. DryRun bool // Maximum amount of time to wait for resources to be ready after install when Wait=true. WaitTimeout time.Duration } func applyManifest(kubeClient kube.Client, client client.Client, manifestStr string,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 5.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
protected CountDownLatch latch; protected ListenableFuture<Boolean> future; @Override protected void setUp() throws Exception { // Create a latch and a future that waits on the latch. latch = new CountDownLatch(1); future = createListenableFuture(Boolean.TRUE, null, latch); } @Override protected void tearDown() throws Exception {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
src/net/textproto/pipeline.go
mu sync.Mutex id uint wait map[uint]chan struct{} } // Start waits until it is time for the event numbered id to begin. // That is, except for the first event, it waits until End(id-1) has // been called. func (s *sequencer) Start(id uint) { s.mu.Lock() if s.id == id { s.mu.Unlock() return } c := make(chan struct{}) if s.wait == nil { s.wait = make(map[uint]chan struct{}) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 08 16:19:51 UTC 2020 - 3K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
"istio.io/istio/pkg/log" ) type Watcher struct { watcher *fsnotify.Watcher Events chan struct{} Errors chan error } // Waits until a file is modified (returns nil), the context is cancelled (returns context error), or returns error func (w *Watcher) Wait(ctx context.Context) error { select { case <-w.Events: return nil case err := <-w.Errors: return err case <-ctx.Done(): return ctx.Err()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 3.6K bytes - Viewed (0) -
src/syscall/exec_unix.go
if n == int(unsafe.Sizeof(err1)) { err = Errno(err1) } if err == nil { err = EPIPE } // Child failed; wait for it to exit, to make sure // the zombies don't accumulate. _, err1 := Wait4(pid, &wstatus, 0, nil) for err1 == EINTR { _, err1 = Wait4(pid, &wstatus, 0, nil) } return 0, err } // Read got EOF, so pipe closed on exec, so exec succeeded. return pid, nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 8.7K bytes - Viewed (0)