- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 76 for timeEnd (0.32 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
case <-time.After(wait.ForeverTestTimeout): t.Errorf("Expected the server handler to panic for request: %q", firstRequestPathPanic) } if isClientTimeout(err) { t.Fatalf("the client has unexpectedly timed out - request: %q error: %s", firstRequestPathPanic, err.Error()) } expectResetStreamError(t, err) // the second request should be served successfully. response, err := requestGetter(secondRequestPathShouldWork)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
// Gets and Timed Gets // // * Be responsive to interruption // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on the // waiters field. // * Future completion is defined by when #value becomes non-null/non SetFuture // * Future completion can be observed if the waiters field contains a TOMBSTONE // Timed Get
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// Gets and Timed Gets // // * Be responsive to interruption // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on the // waiters field. // * Future completion is defined by when #value becomes non-null/non SetFuture // * Future completion can be observed if the waiters field contains a TOMBSTONE // Timed Get
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
deviceState operationexecutor.DeviceMountState unmountDeviceCallCount int volumeName string supportRemount bool }{ { name: "timed out operations should result in device marked as uncertain", deviceState: operationexecutor.DeviceMountUncertain, unmountDeviceCallCount: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/volume/testing/testing.go
if fv.VolName == TimeoutAndFailOnMountDeviceVolumeName { _, ok := fv.DeviceMountState[fv.VolName] if !ok { fv.DeviceMountState[fv.VolName] = deviceMountUncertain return "", volumetypes.NewUncertainProgressError("timed out mounting error") } fv.DeviceMountState[fv.VolName] = deviceNotMounted return "", fmt.Errorf("error mapping disk: %s", fv.VolName) } if fv.VolName == SuccessAndTimeoutDeviceName {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zerrors_aix_ppc64.go
{75, "EISCONN", "socket is already connected"}, {76, "ENOTCONN", "socket is not connected"}, {77, "ESHUTDOWN", "can't send after socket shutdown"}, {78, "ETIMEDOUT", "connection timed out"}, {79, "ECONNREFUSED", "connection refused"}, {80, "EHOSTDOWN", "host is down"}, {81, "EHOSTUNREACH", "no route to host"}, {82, "ERESTART", "restart the system call"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 52.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zerrors_aix_ppc.go
{75, "EISCONN", "socket is already connected"}, {76, "ENOTCONN", "socket is not connected"}, {77, "ESHUTDOWN", "can't send after socket shutdown"}, {78, "ETIMEDOUT", "connection timed out"}, {79, "ECONNREFUSED", "connection refused"}, {80, "EHOSTDOWN", "host is down"}, {81, "EHOSTUNREACH", "no route to host"}, {82, "ERESTART", "restart the system call"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 52.4K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
t.Fatal("Write which previously failed should still time out") } // Verify the error if ne := err.(net.Error); ne.Temporary() != false { t.Error("Write timed out but incorrectly classified the error as Temporary") } if !isTimeoutError(err) { t.Error("Write timed out but did not classify the error as a Timeout") } } type readerFunc func([]byte) (int, error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
private Futures() {} /** * Creates a {@code ListenableFuture} which has its value set immediately upon construction. The * getters just return the value. This {@code Future} can't be canceled or timed out and its * {@code isDone()} method always returns {@code true}. */ public static <V extends @Nullable Object> ListenableFuture<V> immediateFuture( @ParametricNullness V value) { if (value == null) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
t.Logf("Warning: MultiAttach error not yet set on Node. Will retry.") return false, nil } err := retryWithExponentialBackOff(100*time.Millisecond, multAttachCheckFunc) if err != nil { t.Fatalf("Timed out waiting for MultiAttach Error to be set on non-attached node") } } func waitForNewAttacherCallCount( t *testing.T, expectedCallCount int, fakePlugin *volumetesting.FakeVolumePlugin) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0)