- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 440 for waits (0.04 sec)
-
pkg/envoy/agent.go
type exitStatus struct { err error } // Run starts the envoy and waits until it terminates. // There are a few exit paths: // 1. Envoy exits. In this case, we simply log and exit. // 2. /quitquitquit (on agent, not Envoy) is called. We will set skipDrain and cancel the context, which triggers us to exit immediately.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/continuous/ContinuousBuildGateIntegrationTest.groovy
and: // command the gate keeper to open the gate and shutdown command.releaseAll() server.expect(server.get("command").send("stop")) then: // waits for build to start and finish buildTriggeredAndSucceeded() // Change has been incorporated outputFile.text == "changed" }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.1K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/deployment/internal/DefaultDeploymentRegistryTest.groovy
when: registry.stop() then: 1 * pendingChangesManager.removeListener(_) } def "can start a deployment with a given type and parameters and continuous build waits"() { def testHandle = new ParametersDeploymentHandle("parameter") objectFactory.newInstance(ParametersDeploymentHandle, "parameter") >> testHandle when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 4.6K bytes - Viewed (0) -
src/runtime/cgo/libcgo.h
*/ extern uintptr_t *_cgo_pthread_key_created; /* * Creates the new operating system thread (OS, arch dependent). */ void _cgo_sys_thread_start(ThreadStart *ts); /* * Waits for the Go runtime to be initialized (OS dependent). * If runtime.SetCgoTraceback is used to set a context function, * calls the context function and returns the context value. */ uintptr_t _cgo_wait_runtime_init_done(void);
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 13 20:50:04 UTC 2024 - 3.5K bytes - Viewed (0) -
src/runtime/rwmutex_test.go
var cunlock atomic.Bool cdone := make(chan bool) for i := 0; i < numReaders; i++ { go parallelReader(&m, clocked, &cunlock, cdone) } // Wait for all parallel RLock()s to succeed. for i := 0; i < numReaders; i++ { <-clocked } cunlock.Store(true) // Wait for the goroutines to finish. for i := 0; i < numReaders; i++ { <-cdone } } func TestParallelRWMutexReaders(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 22:00:45 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/kube/multicluster/cluster.go
Update ) func (a ACTION) String() string { switch a { case Add: return "Add" case Update: return "Update" } return "Unknown" } // Run starts the cluster's informers and waits for caches to sync. Once caches are synced, we mark the cluster synced. // This should be called after each of the handlers have registered informers, and should be run in a goroutine.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.8K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
defaultExpirationSeconds = 60 * 60 ) // Audience to create tokens for var tokenAudiences = []string{"istio-ca"} // GetXdsResponse opens a gRPC connection to opts.xds and waits for a single response func GetXdsResponse(dr *discovery.DiscoveryRequest, ns string, serviceAccount string, opts clioptions.CentralControlPlaneOptions, grpcOpts []grpc.DialOption, ) (*discovery.DiscoveryResponse, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
"istio.io/istio/pkg/log" ) type Watcher struct { watcher *fsnotify.Watcher Events chan struct{} Errors chan error } // Waits until a file is modified (returns nil), the context is cancelled (returns context error), or returns error func (w *Watcher) Wait(ctx context.Context) error { select { case <-w.Events: return nil case err := <-w.Errors: return err case <-ctx.Done(): return ctx.Err()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 3.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
slowChannel.exitClose.countDown(); // release the interrupter // We need to wait for the runner to exit. To make sure that the interrupting thread wakes it // back up. runner.join(TimeUnit.SECONDS.toMillis(10)); } // waits for the given thread to be blocked on the given object private static void awaitBlockedOnInstanceOf(Thread t, Class<?> blocker)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
slowChannel.exitClose.countDown(); // release the interrupter // We need to wait for the runner to exit. To make sure that the interrupting thread wakes it // back up. runner.join(TimeUnit.SECONDS.toMillis(10)); } // waits for the given thread to be blocked on the given object private static void awaitBlockedOnInstanceOf(Thread t, Class<?> blocker)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0)