- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 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) -
pkg/util/goroutinemap/goroutinemap_test.go
import ( "fmt" "testing" "time" "k8s.io/apimachinery/pkg/util/wait" ) const ( // testTimeout is a timeout of goroutines to finish. This _should_ be just a // "context switch" and it should take several ms, however, Clayton says "We // have had flakes due to tests that assumed that 15s is long enough to sleep") testTimeout time.Duration = 1 * time.Minute // initialOperationWaitTimeShort is the initial amount of time the test will
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 11 14:09:48 UTC 2017 - 14.9K 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) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
volumetypes "k8s.io/kubernetes/pkg/volume/util/types" ) const ( // testTimeout is a timeout of goroutines to finish. This _should_ be just a // "context switch" and it should take several ms, however, Clayton says "We // have had flakes due to tests that assumed that 15s is long enough to sleep") testTimeout time.Duration = 1 * time.Minute // initialOperationWaitTimeShort is the initial amount of time the test will
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K 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-gwt/pom.xml
<sourceLevel>1.8</sourceLevel> <!-- Keep these timeouts very large because, if we hit the timeout, the tests silently pass :( --> <testTimeOut>86400 <!-- seconds --></testTimeOut> <testMethodTimeout>1440 <!-- minutes --></testMethodTimeout> <!-- Presumably we want watchFileChanges=false here, since we want it for compile: -->
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 11 15:00:55 UTC 2024 - 19.8K bytes - Viewed (0)