- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 665 for waits (0.12 sec)
-
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 - 33K bytes - Viewed (0) -
pkg/proxy/config/config.go
func (c *EndpointSliceConfig) RegisterEventHandler(handler EndpointSliceHandler) { c.eventHandlers = append(c.eventHandlers, handler) } // Run waits for cache synced and invokes handlers after syncing. func (c *EndpointSliceConfig) Run(stopCh <-chan struct{}) { c.logger.Info("Starting endpoint slice config controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
*/ void releaseAll(); /** * Waits for the expected number of concurrent requests to be received. */ void waitForAllPendingCalls(); /** * Waits for the expected number of concurrent requests to be received or until the given {@link FailureTracker} provides a
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
src/runtime/os_darwin.go
// handler: the sigsend function. The signal handler code does not require // all the features of notes: it does not need to do a timed wait. // This is a separate implementation of notes, based on a pipe, that does // not support timed waits but is async-signal-safe. func sigNoteSetup(*note) { if sigNoteRead != 0 || sigNoteWrite != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 11.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
) const ( // reconcilerLoopSleepPeriod is the amount of time the reconciler loop waits // between successive executions reconcilerLoopSleepPeriod = 100 * time.Millisecond // desiredStateOfWorldPopulatorLoopSleepPeriod is the amount of time the // DesiredStateOfWorldPopulator loop waits between successive executions desiredStateOfWorldPopulatorLoopSleepPeriod = 100 * time.Millisecond
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
const pollInterval = time.Second // Cmd represents the wait command func Cmd(cliCtx cli.Context) *cobra.Command { namespace := cliCtx.Namespace() var opts clioptions.ControlPlaneOptions cmd := &cobra.Command{ Use: "wait [flags] <type> <name>[.<namespace>]", Short: "Wait for an Istio resource", Long: `Waits for the specified condition to be true of an Istio resource.`,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (1) -
pkg/kube/client.go
ObjectFilter() kubetypes.DynamicObjectFilter // RunAndWait starts all informers and waits for their caches to sync. // Warning: this must be called AFTER .Informer() is called, which will register the informer. // "false" is returned if this prematurely exited without syncing. RunAndWait(stop <-chan struct{}) bool // WaitForCacheSync waits for all cache functions to sync, as well as all informers started by the *fake* client.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
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) -
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)