- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for testTimeouts (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go
data := []byte("test data") _, err = service.Encrypt(data) if err != nil { t.Fatalf("failed when execute encrypt, error: %v", err) } } // TestTimeout tests behaviour of the kube-apiserver based on the supplied timeout and delayed start of kms-plugin. func TestTimeouts(t *testing.T) { t.Parallel() var testCases = []struct { desc string callTimeout time.Duration pluginDelay time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service_unix_test.go
data := []byte("test data") uid := string(uuid.NewUUID()) _, err = service.Encrypt(ctx, uid, data) if err != nil { t.Fatalf("failed when execute encrypt, error: %v", err) } } func TestTimeouts(t *testing.T) { t.Parallel() var testCases = []struct { desc string callTimeout time.Duration pluginDelay time.Duration kubeAPIServerDelay time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 12.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
String toString = manager.toString(); assertThat(toString).contains("NoOpService"); assertThat(toString).contains("FailStartService"); } public void testTimeouts() throws Exception { Service a = new NoOpDelayedService(50); ServiceManager manager = new ServiceManager(asList(a)); manager.startAsync();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 02 17:20:27 UTC 2023 - 23.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
String toString = manager.toString(); assertThat(toString).contains("NoOpService"); assertThat(toString).contains("FailStartService"); } public void testTimeouts() throws Exception { Service a = new NoOpDelayedService(50); ServiceManager manager = new ServiceManager(asList(a)); manager.startAsync();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 02 17:20:27 UTC 2023 - 23.2K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/testng/TestNGTestFrameworkIntegrationTest.groovy
testResult.testClass('TestNG18566') .assertTestCount(1, 1, 0) .testFailed("testTimeout", containsNormalizedString("Method TestNG18566.testTimeout() didn't finish within the time-out 10")) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/audit_test.go
t.Errorf("[%s] expected ResponseStatus.Code=%d, got %d", test.desc, test.code, status.Code) } } }) } } // testTimeout returns the minimimum of the "ForeverTestTimeout" and the testing deadline (with // cleanup time). func testTimeout(t *testing.T) time.Duration { defaultTimeout := wait.ForeverTestTimeout const cleanupTime = 5 * time.Second if deadline, ok := t.Deadline(); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 14 23:04:34 UTC 2022 - 12.1K bytes - Viewed (0) -
src/cmd/go/internal/test/testflag.go
// If the timeout wasn't set (and forwarded) explicitly, add the default // timeout to the command line. if testTimeout > 0 && !timeoutSet { injectedFlags = append(injectedFlags, fmt.Sprintf("-test.timeout=%v", testTimeout)) } // Similarly, the test binary defaults -test.outputdir to its own working // directory, but 'go test' defaults it to the working directory of the 'go'
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 21 19:25:24 UTC 2024 - 12.2K bytes - Viewed (0) -
src/internal/testenv/exec.go
} gracePeriod *= time.Duration(scale) } // If time allows, increase the termination grace period to 5% of the // test's remaining time. testTimeout := time.Until(td) if gp := testTimeout / 20; gp > gracePeriod { gracePeriod = gp } // When we run commands that execute subprocesses, we want to reserve two
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 27 17:53:23 UTC 2023 - 7.5K bytes - Viewed (0) -
src/context/x_test.go
} } } if !testTimeout { select { case <-ctx.Done(): errorf("ctx should not be canceled yet") default: } } if s, prefix := fmt.Sprint(ctx), "context.Background."; !strings.HasPrefix(s, prefix) { t.Errorf("ctx.String() = %q want prefix %q", s, prefix) } t.Log(ctx) checkValues("before cancel") if testTimeout { d := quiescent(t) timer := time.NewTimer(d)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
assertEquals("TestService [RUNNING]", service.toString()); service.stopAsync().awaitTerminated(); assertEquals("TestService [TERMINATED]", service.toString()); } public void testTimeout() throws Exception { // Create a service whose executor will never run its commands Service service = new TestService() { @Override protected Executor executor() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0)