- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 95 for waits (0.04 sec)
-
pkg/controller/daemon/daemon_controller.go
return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, dsc.runWorker, time.Second) } go wait.Until(dsc.failedPodsBackoff.GC, BackoffGCInterval, ctx.Done()) <-ctx.Done() } func (dsc *DaemonSetsController) runWorker(ctx context.Context) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
default: cacher.Lock() cacher.bookmarkWatchers.popExpiredWatchersThreadUnsafe() cacher.Unlock() } } }() // wait for adding/removing watchers to end wg.Wait() if watchErr != nil { t.Fatal(watchErr) } // wait out the expiration period and pop expired watchers time.Sleep(2 * time.Second) cacher.Lock() defer cacher.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
src/runtime/pprof/pprof_test.go
defer wg.Done() mu.Lock() mu.Unlock() }() } wg.Wait() } func blockCond(t *testing.T) { var mu sync.Mutex c := sync.NewCond(&mu) mu.Lock() go func() { awaitBlockedGoroutine(t, "sync.Cond.Wait", "blockCond", 1) mu.Lock() c.Signal() mu.Unlock() }() c.Wait() mu.Unlock() } // See http://golang.org/cl/299991.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 68.8K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
} // Start only the ReplicaSet watcher and the workqueue, send a watch event, // and make sure it hits the sync method. go wait.UntilWithContext(tCtx, manager.worker, 10*time.Millisecond) testRSSpec.Name = "foo" fakeWatch.Add(&testRSSpec) select { case <-received: case <-time.After(wait.ForeverTestTimeout): t.Errorf("unexpected timeout from result channel") } } func TestWatchPods(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
g.Go(func() error { // Get the set where it would be placed. storageInfos[index] = getDiskInfos(ctx, pool.getHashedSet(object).getDisks()...) return nil }, index) } // Wait for the go routines. g.Wait() for i, zinfo := range storageInfos { if zinfo == nil { serverPools[i] = poolAvailableSpace{Index: i} continue } var available uint64 if !isMinioMetaBucketName(bucket) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
cmd/erasure-object.go
if err != nil { return err } diskVersions[index] = resp.Sign dataDirs[index] = resp.OldDataDir return nil }, index) } // Wait for all renames to finish. errs := g.Wait() err := reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum) if err != nil { dg := errgroup.WithNErrs(len(disks)) for index, nerr := range errs {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
}) if err != nil { t.Fatal(err) } select { case _, ok := <-w.ResultChan(): if ok { t.Error("ResultChan() should be closed") } case <-time.After(wait.ForeverTestTimeout): t.Errorf("timeout after %v", wait.ForeverTestTimeout) } } func RunTestWatcherTimeout(ctx context.Context, t *testing.T, store storage.Interface) { // initialRV is used to initate the watcher at the beginning of the world.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
hack/local-up-cluster.sh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 25 02:33:52 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
// plugins returns a status other than "Success" or "Wait", it does not continue // running the remaining plugins and returns an error. Otherwise, if any of the // plugins returns "Wait", then this function will create and add waiting pod // to a map of currently waiting pods and return status with "Wait" code. // Pod will remain waiting pod for the minimum duration returned by the permit plugins.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
fakePlugin.GetNewDetacherCallCount()) } } func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { backoff := wait.Backoff{ Duration: initialDuration, Factor: 3, Jitter: 0, Steps: 6, } return wait.ExponentialBackoff(backoff, fn) } // verifies the force detach metric with reason
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0)