- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 444 for wait4 (0.04 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
defer c.watchCache.RUnlock() return err } return nil } // Wait blocks until the cacher is Ready or Stopped, it returns an error if Stopped. func (c *Cacher) Wait(ctx context.Context) error { return c.ready.wait(ctx) } // errWatcher implements watch.Interface to return a single error type errWatcher struct { result chan watch.Event }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K 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) -
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) -
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) -
src/runtime/metrics_test.go
// See issue #60276. func TestCPUMetricsSleep(t *testing.T) { if runtime.GOOS == "wasip1" { // Since wasip1 busy-waits in the scheduler, there's no meaningful idle // time. This is accurately reflected in the metrics, but it means this // test is basically meaningless on this platform. t.Skip("wasip1 currently busy-waits in idle time; test not applicable") } names := []string{ "/cpu/classes/idle:cpu-seconds",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 45K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/bundling/ConcurrentArchiveIntegrationTest.groovy
} } } """ when: def waiting = server.expectConcurrentAndBlock(3, "wait", "wait", "wait") def handle = executer.withTasks("extract").start() // Wait for all extracters to be ready waiting.waitForAllPendingCalls() def firstExtracter = server.expectAndBlock("extract")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 17:32:21 UTC 2024 - 28.6K bytes - Viewed (0) -
src/os/pidfd_linux_test.go
} if err := proc.Signal(os.Kill); err != os.ErrProcessDone { t.Errorf("Signal: got %v, want %v", err, os.ErrProcessDone) } if _, err := proc.Wait(); !errors.Is(err, syscall.ECHILD) { t.Errorf("Wait: got %v, want %v", err, os.ErrProcessDone) } // Release never returns errors on Unix. if err := proc.Release(); err != nil { t.Fatalf("Release: got %v, want <nil>", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 1.6K bytes - Viewed (0) -
src/os/pidfd_linux.go
handle, status := p.handleTransientAcquire() switch status { case statusDone: // Process already completed Wait, or was not found by // pidfdFind. Return ECHILD for consistency with what the wait // syscall would return. return nil, NewSyscallError("wait", syscall.ECHILD) case statusReleased: return nil, syscall.EINVAL } defer p.handleTransientRelease() var (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 4.2K bytes - Viewed (0) -
operator/pkg/util/progress/progress.go
comps := make([]string, 0, len(p.components)) wait := make([]string, 0, len(p.components)) for c, l := range p.components { comps = append(comps, name.UserFacingComponentName(name.ComponentName(c))) wait = append(wait, l.waitingResources()...) } sort.Strings(comps) sort.Strings(wait) msg := fmt.Sprintf(`Processing resources for %s.`, strings.Join(comps, ", ")) if len(wait) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 6.2K bytes - Viewed (0)