- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 350 for waitms (0.15 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/wait.go
// NeverStop may be passed to Until to make it never stop. var NeverStop <-chan struct{} = make(chan struct{}) // Group allows to start a group of goroutines and wait for their completion. type Group struct { wg sync.WaitGroup } func (g *Group) Wait() { g.wg.Wait() } // StartWithChannel starts f in a new goroutine in the group. // stopCh is passed to f as an argument. f should stop when stopCh is available.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_termination_order_test.go
time.Sleep(1 * time.Second) to.containerTerminated("main") wg.Done() }() wg.Wait() if sidecarWaitDelay != 1 { t.Errorf("expected sidecar to wait for main container to exit, got delay of %d", sidecarWaitDelay) } if mainWaitDelay != 0 { t.Errorf("expected main container to not wait to exit, got delay of %d", mainWaitDelay) } } func TestTerminationOrderingSidecarsInReverseOrder(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 6.7K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/join/kubelet.go
// Wait for the kubelet to create the /etc/kubernetes/kubelet.conf kubeconfig file. If this process // times out, display a somewhat user-friendly message. waiter := apiclient.NewKubeWaiter(nil, 0, os.Stdout) waiter.SetTimeout(cfg.Timeouts.KubeletHealthCheck.Duration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 10.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
final NoOpService service = new NoOpService(); Thread waiter = new Thread() { @Override public void run() { service.awaitTerminated(); } }; waiter.start(); service.startAsync().awaitRunning(); assertEquals(State.RUNNING, service.state()); service.stopAsync();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 29.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
final NoOpService service = new NoOpService(); Thread waiter = new Thread() { @Override public void run() { service.awaitTerminated(); } }; waiter.start(); service.startAsync().awaitRunning(); assertEquals(State.RUNNING, service.state()); service.stopAsync();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 29.3K bytes - Viewed (0) -
src/database/sql/fakedb_test.go
parts = parts[2:] case "WAIT": wait, err := time.ParseDuration(parts[1]) if err != nil { return nil, errf("expected section after WAIT to be a duration, got %q %v", parts[1], err) } parts = parts[2:] stmt.wait = wait } } cmd := parts[0] stmt.cmd = cmd parts = parts[1:] if c.waiter != nil { c.waiter(ctx) if err := ctx.Err(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 01 12:38:07 UTC 2024 - 30.3K 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) -
src/cmd/vendor/golang.org/x/sys/plan9/syscall_plan9.go
fd, err := Create(path, O_RDONLY, DMDIR|mode) if fd != -1 { Close(fd) } return } type Waitmsg struct { Pid int Time [3]uint32 Msg string } func (w Waitmsg) Exited() bool { return true } func (w Waitmsg) Signaled() bool { return false } func (w Waitmsg) ExitStatus() int { if len(w.Msg) == 0 { // a normal exit returns no message return 0 } return 1 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 16 22:24:28 UTC 2022 - 7K 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) -
pkg/test/util/assert/tracker.go
func (t *Tracker[T]) Empty() { t.t.Helper() t.mu.Lock() defer t.mu.Unlock() if len(t.events) != 0 { t.t.Fatalf("unexpected events: %v", t.events) } } // WaitOrdered waits for an event to happen, in order func (t *Tracker[T]) WaitOrdered(events ...T) { t.t.Helper() for i, event := range events { var err error retry.UntilSuccessOrFail(t.t, func() error { t.mu.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 3.6K bytes - Viewed (0)