- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 96 for timediv (0.14 sec)
-
okhttp/src/test/java/okhttp3/TestLogHandler.kt
fun takeAll(): List<String> { val list = mutableListOf<String>() logs.drainTo(list) return list } fun take(): String { return logs.poll(10, TimeUnit.SECONDS) ?: throw AssertionError("Timed out waiting for log message.") }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/executor.go
g.e.totalRequests.Inc() g.e.activeRequests.Inc() defer g.e.activeRequests.Dec() // Acquire the group concurrency semaphore. if err := g.sem.Acquire(ctx, 1); err != nil { return fmt.Errorf("request set timed out: %v", err) } defer g.sem.Release(1) return work() }) } func (g *execGroup) Wait() *multierror.Error { return g.g.Wait() } func (e *executor) Close() { close(e.stopCh)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 10 18:09:08 UTC 2022 - 2K bytes - Viewed (0) -
pkg/config/mesh/networks_watcher_test.go
writeMessage(t, path, &n) select { case <-doneCh: g.Expect(newN).To(Equal(&n)) g.Expect(w.Networks()).To(Equal(newN)) break case <-time.After(time.Second * 5): t.Fatal("timed out waiting for update") } } func newNetworksWatcher(t *testing.T, filename string) mesh.NetworksWatcher { t.Helper() w, err := mesh.NewNetworksWatcher(filewatcher.NewWatcher(), filename) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/probe/exec/exec.go
} if errors.Is(err, remote.ErrCommandTimedOut) { if utilfeature.DefaultFeatureGate.Enabled(features.ExecProbeTimeout) { return probe.Failure, err.Error(), nil } klog.Warningf("Exec probe timed out but ExecProbeTimeout feature gate was disabled") } return probe.Unknown, "", err } return probe.Success, string(data), nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
throws TimeoutException, ExecutionException { SettableFuture<String> future = SettableFuture.create(); future.set(RESULT); /* * getUninterruptibly should call the timed get method once with a * wait of 0 seconds (and it should succeed, since the result is already * available). */ assertEquals(RESULT, getUninterruptibly(future, 0, SECONDS)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/xdsfake/updater.go
for { select { case e := <-fx.Events: if e.Type == et { return &e } log.Infof("skipping event %q want %q", e.Type, et) continue case <-delay.C: t.Fatalf("timed out waiting for %v", et) } } } // MatchOrFail expects the provided events to arrive, skipping unmatched events func (fx *Updater) MatchOrFail(t test.Failer, events ...Event) { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/proxy/config/api_test.go
svcHandler.lock.Lock() defer svcHandler.lock.Unlock() if reflect.DeepEqual(svcHandler.state, expectedSvcState) { return true, nil } return false, nil }) if err != nil { t.Fatal("Timed out waiting for the completion of handler `OnServiceAdd`") } err = wait.PollImmediate(time.Millisecond*10, wait.ForeverTestTimeout, func() (bool, error) { epsHandler.lock.Lock() defer epsHandler.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 8.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
throws TimeoutException, ExecutionException { SettableFuture<String> future = SettableFuture.create(); future.set(RESULT); /* * getUninterruptibly should call the timed get method once with a * wait of 0 seconds (and it should succeed, since the result is already * available). */ assertEquals(RESULT, getUninterruptibly(future, 0, SECONDS)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.1K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
defer klog.Infof("Shutting down system namespaces controller") klog.Infof("Starting system namespaces controller") if !cache.WaitForCacheSync(stopCh, c.namespaceSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } go wait.Until(c.sync, c.interval, stopCh) <-stopCh } func (c *Controller) sync() { // Loop the system namespace list, and create them if they do not exist
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/bootstrap/platform/discovery.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.6K bytes - Viewed (0)