- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 320 for timeEnd (0.59 sec)
-
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/metrics_test.go
expectedRegisteredStatusCode: "200", expectEvalutionResult: "success", expectDurationResult: "success", expectFailOpenResult: "", }, { name: "timed out request", clientCert: clientCert, clientKey: clientKey, clientCA: caCert, serverCert: serverCert, serverKey: serverKey, serverCA: caCert, authzFakeServiceStatusCode: http.StatusGatewayTimeout,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 6.6K bytes - Viewed (0) -
src/internal/trace/batchcursor.go
// into e. It does not try to interpret the arguments // but it does validate that the event is a regular // event with a timestamp (vs. a structural event). // // It requires that the event its reading be timed, which must // be the case for every event in a plain EventBatch. func readTimedBaseEvent(b []byte, e *baseEvent) (int, timestamp, error) { // Get the event type. typ := event.Type(b[0]) specs := go122.Specs()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/queue/delay_test.go
dq := dq.(*delayQueue) dq.mu.Lock() if dq.queue.Len() < queuedItems { t.Fatalf("expected 50 items in the queue, got %d", dq.queue.Len()) } dq.mu.Unlock() return case <-timeout: t.Fatal("timed out waiting for enqueues") } } func TestPriorityQueueShrinking(t *testing.T) { c := 48 pq := make(pq, 0, c) pqp := &pq t0 := time.Now() for i := 0; i < c; i++ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/errors.go
func IsConflict(err error) bool { return isErrCode(err, ErrCodeResourceVersionConflicts) } // IsRequestTimeout returns true if and only if err indicates that the request has timed out. func IsRequestTimeout(err error) bool { return isErrCode(err, ErrCodeTimeout) } // IsInvalidObj returns true if and only if err is invalid error func IsInvalidObj(err error) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:39:10 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/proxy/config/config_test.go
return } // Unittests will hard timeout in 5m with a stack trace, prevent that // and surface a clearer reason for failure. case <-time.After(wait.ForeverTestTimeout): t.Errorf("Timed out. Expected %#v, Got %#v", expectedServices, services) return } } } type sortedEndpointSlices []*discoveryv1.EndpointSlice func (s sortedEndpointSlices) Len() int { return len(s) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/sources/KotlinSourceQueries.kt
if (ktTypeAsText.contains(" -> ")) { // This is a function of some sort return name.startsWith("kotlin.jvm.functions.Function") } val ktTypeRawName = ktTypeAsText .trimEnd('?') // nullability is not part of JVM types .substringBefore('<') // generics are not part of parameter types in JVM method signatures val thisTypeAsKt = primitiveTypeStrings[name] ?: name
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Dec 20 20:38:19 UTC 2023 - 11.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
// The task thread waits for the latch, so we expect a timeout here. try { future.get(20, MILLISECONDS); fail("Should have timed out trying to get the value."); } catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.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 static class TestService extends AbstractIdleService { int startUpCalled = 0; int shutDownCalled = 0;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
// The task thread waits for the latch, so we expect a timeout here. try { future.get(20, MILLISECONDS); fail("Should have timed out trying to get the value."); } catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.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 static class TestService extends AbstractIdleService { int startUpCalled = 0; int shutDownCalled = 0;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0)