- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 871 for waits (0.09 sec)
-
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
} return this; } /** * Waits for the all the services to reach a terminal state. After this method returns all * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain * Service.State#FAILED failed}. */ public void awaitStopped() { state.awaitStopped(); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
// b) was force-deleted. // // It's now just waiting for garbage collection. We could wait // for it to actually get removed, but that may be blocked by // finalizers for the pod and thus get delayed. // // Worse, it is possible that there is a cyclic dependency // (pod finalizer waits for PVC to get removed, PVC protection // controller waits for pod to get removed). By considering
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
internal/s3select/message.go
// closes `doneCh` to indicate to caller to also exit. // // 2. If caller (Evaluate()) has an error, it sends an error // message and waits for this go-routine to quit in // FinishWithError() // // 3. If caller is done, it waits for this go-routine to exit // in Finish() quitFlag := false for !quitFlag { select { case data := <-writer.errCh: quitFlag = true
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 15.2K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
throw new RuntimeException(String.format("Cannot wait for %s, as clock is currently at %s.", clockTick, currentTick)); } if (!active.contains(Thread.currentThread())) { throw new RuntimeException("Cannot wait for clock tick from a thread which is not a test thread."); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
src/os/exec/exec.go
// // If any of c.Stdin, c.Stdout or c.Stderr are not an [*os.File], Wait also waits // for the respective I/O loop copying to or from the process to complete. // // Wait releases any resources associated with the [Cmd]. func (c *Cmd) Wait() error { if c.Process == nil { return errors.New("exec: not started") } if c.ProcessState != nil { return errors.New("exec: Wait was already called") } state, err := c.Process.Wait()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go
err := wait.PollImmediate(500*time.Millisecond, 30*time.Second, func() (bool, error) { exists, err := existsInDiscoveryV1(crd, apiExtensionsClient, version) return !exists, err }) if err != nil { return err } } return nil } // DeleteV1CustomResourceDefinitions deletes all CRD matching the provided deleteListOpts and waits until all the CRDs disappear from discovery.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 02:01:40 UTC 2021 - 21.4K bytes - Viewed (0) -
cmd/batch-expire.go
if len(toDel) > 0 { select { case <-ctx.Done(): case expireCh <- toDel: } } xioutil.SafeClose(expireCh) <-expireDoneCh // waits for the expire goroutine to complete wk.Wait() // waits for all expire workers to retire ri.Complete = !failed && ri.ObjectsFailed == 0 ri.Failed = failed || ri.ObjectsFailed > 0 globalBatchJobsMetrics.save(job.ID, ri)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 13:50:53 UTC 2024 - 21.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
// DesiredStateOfWorldPopulatorLoopSleepPeriod is the amount of time the // DesiredStateOfWorldPopulator loop waits between successive executions DesiredStateOfWorldPopulatorLoopSleepPeriod time.Duration // DesiredStateOfWorldPopulatorListPodsRetryDuration is the amount of // time the DesiredStateOfWorldPopulator loop waits between list pods // calls. DesiredStateOfWorldPopulatorListPodsRetryDuration time.Duration }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
} synced := []cache.InformerSynced{kvh.csiDriversSynced} if !cache.WaitForCacheSync(wait.NeverStop, synced...) { klog.InfoS("Failed to wait for cache sync for CSIDriverLister") return fmt.Errorf("failed to wait for cache sync for CSIDriverLister") } return nil } func (kvh *kubeletVolumeHost) NewWrapperMounter( volName string, spec volume.Spec, pod *v1.Pod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
src/cmd/go/internal/script/cmds.go
}) } // Wait waits for the completion of background commands. // // When Wait returns, the stdout and stderr buffers contain the concatenation of // the background commands' respective outputs in the order in which those // commands were started. func Wait() Cmd { return Command( CmdUsage{ Summary: "wait for completion of background commands", Args: "",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 28.5K bytes - Viewed (0)