- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for waitc (0.85 sec)
-
android/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: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
/** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
/** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/test/xds/fake.go
if err := adscConn.Run(); err != nil { f.t.Fatalf("ADSC: failed running: %v", err) } if len(wait) > 0 { _, err := adscConn.Wait(10*time.Second, wait...) if err != nil { f.t.Fatalf("Error getting initial for %v config: %v", wait, err) } } return adscConn } func (f *FakeDiscoveryServer) Endpoints(p *model.Proxy) []*endpoint.ClusterLoadAssignment { loadAssignments := make([]*endpoint.ClusterLoadAssignment, 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go
ctx := context.Background() terminate := func() { cacher.Stop() server.Terminate(t) } // Since some tests depend on the fact that GetList shouldn't fail, // we wait until the error from the underlying storage is consumed. if err := wait.PollInfinite(100*time.Millisecond, wrappedStorage.ErrorsConsumed); err != nil { t.Fatalf("Failed to inject list errors: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 17K bytes - Viewed (0) -
cmd/erasure-multipart.go
} } // Fallback for older uploads without time in the ID. if modTime.IsZero() { wait := deleteMultipartCleanupSleeper.Timer(ctx) fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{}) if err != nil { return nil } modTime = fi.ModTime wait() } if time.Since(modTime) < expiry { return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
} // List returns list of pointers to <storeElement> objects. func (w *watchCache) List() []interface{} { return w.store.List() } // waitUntilFreshAndBlock waits until cache is at least as fresh as given <resourceVersion>. // NOTE: This function acquired lock and doesn't release it. // You HAVE TO explicitly call w.RUnlock() after this function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K 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) -
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
(build.standardOutput =~ "Pinged owner at port ${socket.localPort}").count } def waitCloseAndFinish(GradleHandle build) { Thread.sleep(10 * 1000) //wait 10 seconds, in which the build should only wait for the lock to become available receivingLock.close() build.waitForFinish() } def replaceSocketReceiver(Runnable reactOnRequest) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
addTestClientEndpoints(s.MemRegistry) s.MemRegistry.AddHTTPService(edsIncSvc, edsIncVip, 8080) s.MemRegistry.SetEndpoints(edsIncSvc, "", newEndpointWithAccount("127.0.0.1", "hello-sa", "v1")) // Wait until the above debounce, to ensure we can precisely check XDS responses without spurious pushes s.EnsureSynced(t) ads := s.ConnectDeltaADS().WithID("sidecar~127.0.0.1~test.default~default.svc.cluster.local")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0)