- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 67 for timeEnd (0.39 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
updateCRD() drained := make(chan struct{}) go func() { defer close(drained) wg.Wait() }() select { case <-drained: case <-time.After(wait.ForeverTestTimeout): t.Fatal("timed out waiting for watchers to be terminated") } stopChan := make(chan struct{}) // Set up loop to modify CRD in the background wg.Add(1) go func() { defer wg.Done() for { select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
src/internal/testenv/exec.go
// after (or too close before) the test has already timed out. // Add a shorter timeout so that the test will produce useful output. ctx, cancelCtx = context.WithTimeout(ctx, cmdTimeout) } } } cmd := exec.CommandContext(ctx, name, args...) cmd.Cancel = func() error { if cancelCtx != nil && ctx.Err() == context.DeadlineExceeded { // The command timed out due to running too close to the test's deadline.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 27 17:53:23 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/config/mesh/watcher_test_utils.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Nov 03 00:26:45 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/software/resources-http/src/test/groovy/org/gradle/internal/resource/transport/http/HttpClientHelperTimeoutTest.groovy
client.performRequest(new HttpGet("${httpServer.uri}/"), false) then: def e = thrown(HttpRequestException) e.cause instanceof SocketTimeoutException e.cause.message == 'Read timed out' } private HttpSettings getHttpSettings() { Stub(HttpSettings) { getProxySettings() >> Mock(HttpProxySettings) getSecureProxySettings() >> Mock(HttpProxySettings)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/server/scaninfo/DaemonScanInfoIntegrationSpec.groovy
""" openJpmsModulesForConfigurationCache() def waitForExpirationResult = executer.withArgument('waitForExpiration').runWithFailure() then: waitForExpirationResult.assertHasCause("Timed out waiting for expiration event") and: !file(EXPIRATION_EVENT).exists() } def "a daemon expiration listener receives expiration reasons when daemons run in the foreground"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 9.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
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/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) -
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)