- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 871 for waits (0.07 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
// Depending upon object type, waits afterward until the object is synced // by the policy source func (p *PolicyTestContext[P, B, E]) update(wait bool, objects ...runtime.Object) error { for _, object := range objects { if err := p.updateOne(object); err != nil { return err } } if wait { timeoutCtx, timeoutCancel := context.WithTimeout(p, 3*time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
* * <p>Provides some fixtures for testing:</p> * * <ul> * <li>An action starts another action asynchronously without waiting for the result.</li> * <li>An action starts another action asynchronously and waits for the result.</li> * </ul> */ class ConcurrentTestUtil extends ExternalResource { private static final Logger LOG = LoggerFactory.getLogger(ConcurrentTestUtil.class) private Lock lock = new ReentrantLock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
threadUnexpectedException(t); } } // /** // * Spin-waits up to LONG_DELAY_MS until flag becomes true. // */ // public void await(AtomicBoolean flag) { // await(flag, LONG_DELAY_MS); // } // /** // * Spin-waits up to the specified timeout until flag becomes true. // */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
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 (0) -
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)