- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 1,377 for waitc (0.04 sec)
-
platforms/software/version-control/src/integTest/groovy/org/gradle/vcs/internal/ParallelSourceDependencyIntegrationTest.groovy
""" when: // Wait for each project to list versions concurrently httpServer.expectConcurrent("A", "B", "C", "D") // Only one project should clone repo.expectListVersions() repo.expectCloneSomething() then: succeeds('resolve', '--parallel', '--max-workers=4') when: // Wait for each project to list versions concurrently
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_test.go
reactor.DeleteClaimEvent(claim) // wait until claim is cleared from cache, i.e., deleteClaim is called err := wait.Poll(10*time.Millisecond, wait.ForeverTestTimeout, func() (bool, error) { return len(ctrl.claims.ListKeys()) == 0, nil }) if err != nil { return err } // wait for volume delete operation to appear once volumeWorker() runs
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.4K bytes - Viewed (0) -
src/runtime/race/testdata/cgo_test_main.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 08 04:08:51 UTC 2014 - 415 bytes - Viewed (0) -
pkg/test/framework/config.go
for ns, y := range c.yamlText { ns, y := ns, y g.Go(func() error { return c.applyYAML(options.Cleanup, ns, y...) }) } // Wait for all each apply to complete. if err := g.Wait(); err != nil { return err } if options.Wait { // TODO: wait for each namespace concurrently once WaitForConfig supports concurrency. for ns, y := range c.yamlText {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/waitcontrolplane.go
`))) ) // NewWaitControlPlanePhase is a hidden phase that runs after the control-plane and etcd phases func NewWaitControlPlanePhase() workflow.Phase { phase := workflow.Phase{ Name: "wait-control-plane", Short: "Wait for the control plane to start", // TODO: unhide this phase once WaitForAllControlPlaneComponents goes GA: // https://github.com/kubernetes/kubeadm/issues/2907 Hidden: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 5K bytes - Viewed (0) -
pkg/kubelet/winstats/perfcounters_test.go
} // There are some counters that we can't expect to see any non-zero values, like the // networking-related counters. if tc.skipCheck { return } // Wait until we get a non-zero perf counter data. if pollErr := wait.Poll(100*time.Millisecond, 5*perfCounterUpdatePeriod, func() (bool, error) { data, err := counter.getData() if err != nil { return false, err } if data != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 3.5K bytes - Viewed (0) -
cmd/mrf.go
} } now := time.Now() if now.Sub(u.queued) < time.Second { // let recently failed networks to reconnect // making MRF wait for 1s before retrying, // i.e 4 reconnect attempts. time.Sleep(time.Second) } // wait on timer per heal wait := healSleeper.Timer(context.Background()) scan := madmin.HealNormalScan if u.scanMode != 0 { scan = u.scanMode }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.2K bytes - Viewed (0) -
src/sync/oncefunc_test.go
// is not kept alive after the first call to f. t.Fatal("wrapped function should be garbage collected, but still live") } f() }) } } // gcwaitfin performs garbage collection and waits for all finalizers to run. func gcwaitfin() { runtime.GC() runtime_blockUntilEmptyFinalizerQueue(math.MaxInt64) } //go:linkname runtime_blockUntilEmptyFinalizerQueue runtime.blockUntilEmptyFinalizerQueue
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 17:31:33 UTC 2023 - 6.9K bytes - Viewed (0) -
src/internal/singleflight/singleflight_test.go
return } if s, _ := v.(string); s != "bar" { t.Errorf("Do = %T %v; want %q", v, v, "bar") } }() } wg1.Wait() // At least one goroutine is in fn now and all of them have at // least reached the line before the Do. c <- "bar" wg2.Wait() if got := calls.Load(); got <= 0 || got >= n { t.Errorf("number of calls = %d; want over 0 and less than %d", got, n) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 29 22:21:50 UTC 2023 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
// Update CRD and ensure that all watches are gracefully terminated. updateCRD() drained := make(chan struct{}) go func() { defer close(drained) wg.Wait() }() select { case <-drained: case <-time.After(wait.ForeverTestTimeout): t.Fatal("timed out waiting for watchers to be terminated") } stopChan := make(chan struct{}) // Set up loop to modify CRD in the background
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0)