- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 131 for timeEnd (0.24 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* the request completes normally or when it fails due to an exception, in which case [e] should * be non-null. * * If the exchange was canceled or timed out, this will wrap [e] in an exception that provides * that additional context. Otherwise [e] is returned as-is. */ internal fun <E : IOException?> messageDone( exchange: Exchange, requestDone: Boolean,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
src/os/pipe_test.go
wg.Add(1) go func() { defer wg.Done() var buf [count]byte r.SetReadDeadline(time.Now().Add(time.Minute)) c <- true if _, err := r.Read(buf[:]); os.IsTimeout(err) { t.Error("read timed out") } }() wg.Add(1) go func() { defer wg.Done() <-c // Give the other goroutine a chance to enter the Read. // It doesn't matter if this occasionally fails, the test
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
@GwtIncompatible @ParametricNullness static <T extends @Nullable Object> T invokeAnyImpl( ListeningExecutorService executorService, Collection<? extends Callable<T>> tasks, boolean timed, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { checkNotNull(executorService); checkNotNull(unit); int ntasks = tasks.size();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 39K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
} utilruntime.HandleError(callErr) select { case <-ctx.Done(): // parent context is canceled or timed out, no point in continuing return apierrors.NewTimeoutError("request did not complete within requested timeout", 0) default: // individual webhook timed out, but parent context did not, continue continue } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
fakeInformerFactory.Start(res.Done()) go policyInformer.Run(res.Done()) go bindingInformer.Run(res.Done()) if !cache.WaitForCacheSync(res.Done(), res.Source.HasSynced) { return fmt.Errorf("timed out waiting for initial cache sync") } return nil } return res, testCancel, nil } // UpdateAndWait updates the given object in the test, or creates it if it doesn't exist
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout_test.go
// this error must be ignored by the WithPanicRecovery handler // it is thrown by WithTimeoutForNonLongRunningRequests handler when a response has been already sent to the client and the handler timed out // panicking with http.ErrAbortHandler also suppresses logging of a stack trace to the server's error log and closes the underlying connection w.Write([]byte("hello from the handler")) panic(http.ErrAbortHandler) })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 18.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
getChecked( FAILED_FUTURE_CHECKED_EXCEPTION, ExceptionWithGoodAndBadConstructor.class)); assertThat(expected).hasCauseThat().isSameInstanceAs(CHECKED_EXCEPTION); } // Boring timed-get tests: public void testGetCheckedTimed_success() throws TwoArgConstructorException { assertEquals( "foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class, 0, SECONDS)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 16.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertThrows( TimeoutException.class, () -> service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS)); assertThat(e) .hasMessageThat() .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state."); } private class FakeService extends AbstractExecutionThreadService implements TearDown {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
getChecked( FAILED_FUTURE_CHECKED_EXCEPTION, ExceptionWithGoodAndBadConstructor.class)); assertThat(expected).hasCauseThat().isSameInstanceAs(CHECKED_EXCEPTION); } // Boring timed-get tests: public void testGetCheckedTimed_success() throws TwoArgConstructorException { assertEquals( "foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class, 0, SECONDS)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 16.4K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
logger.Info("Starting storage version garbage collector") if !cache.WaitForCacheSync(ctx.Done(), c.leasesSynced, c.storageVersionSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // Identity lease deletion and storageversion update don't happen too often. Start one // worker for each of them.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0)