- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,948 for waits (0.09 sec)
-
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) -
src/runtime/semasleep_test.go
if waiting { <-doneCh } else { cmd.Wait() } }) // Wait for After1 to close its stdout so that we know the runtime's SIGIO // handler is registered. b, err := io.ReadAll(stdout) if len(b) > 0 { t.Logf("read from testprog stdout: %s", b) } if err != nil { t.Fatalf("error reading from testprog: %v", err) } // Wait for child exit. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 17:48:24 UTC 2023 - 3.5K 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) -
staging/src/k8s.io/apimachinery/pkg/watch/filter.go
func (fw *filteredWatch) ResultChan() <-chan Event { return fw.result } // Stop stops the upstream watch, which will eventually stop this watch. func (fw *filteredWatch) Stop() { fw.incoming.Stop() } // loop waits for new values, filters them, and resends them. func (fw *filteredWatch) loop() { defer close(fw.result) for event := range fw.incoming.ResultChan() { filtered, keep := fw.f(event) if keep { fw.result <- filtered
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.8K 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) -
android/guava/src/com/google/common/cache/LoadingCache.java
* necessary. No observable state associated with this cache is modified until loading completes. * * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for * {@code key}, simply waits for that thread to finish and returns its loaded value. Note that * multiple threads can concurrently load values for distinct keys. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat Aug 06 17:12:03 UTC 2022 - 8.3K 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) -
src/internal/singleflight/singleflight.go
Err error Shared bool } // Do executes and returns the results of the given function, making // sure that only one execution is in-flight for a given key at a // time. If a duplicate comes in, the duplicate caller waits for the // original to complete and receives the same results. // The return value shared indicates whether v was given to multiple callers. func (g *Group) Do(key string, fn func() (any, error)) (v any, err error, shared bool) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 30 20:49:56 UTC 2022 - 3.1K 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) -
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)