- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 282 for 1000ms (0.87 sec)
-
pkg/util/async/bounded_frequency_runner_test.go
// Advance and do the deferred run timer.advance(1 * time.Millisecond) // abs=2000ms, rel=1000ms waitForRun("fourth run", t, timer, obj) // Run again, once burst has fully replenished. timer.advance(2 * time.Second) // abs=4000ms, rel=2000ms runner.Run() waitForRun("fifth run", t, timer, obj) runner.Run() waitForRun("sixth run", t, timer, obj) runner.Run()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 12.5K bytes - Viewed (0) -
platforms/software/maven/src/integTest/groovy/org/gradle/api/publish/maven/MavenPublishJavaRetriesIntegTest.groovy
expectPublication() ExecutionResult result = run "publish", '--info' then: verifyPublications() outputContains("Waiting 1000ms before next retry, 2 retries left") outputContains("Waiting 2000ms before next retry, 1 retries left") outputContains("after 2 retries") } def expectPublication() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 14:02:46 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/software/ivy/src/integTest/groovy/org/gradle/api/publish/ivy/IvyPublishJavaRetriesIntegTest.groovy
expectPublication() ExecutionResult result = run "publish", '--info' then: verifyPublications() outputContains("Waiting 1000ms before next retry, 2 retries left") outputContains("Waiting 2000ms before next retry, 1 retries left") outputContains("after 2 retries") } def expectPublication() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 14:02:46 UTC 2023 - 3.8K bytes - Viewed (0) -
src/runtime/testdata/testprog/gc.go
// them rapidly. // // OpenBSD's scheduler makes every usleep() take at least // 20ms, so we need a long time to ensure all goroutines have // run. If they haven't run after 30ms, give it another 1000ms // and check again. time.Sleep(30 * time.Millisecond) var fail bool for i := range count { if atomic.LoadInt64(&count[i]) == 0 { fail = true } } if fail {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 12.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer_test.go
atomic.StoreInt32(&shouldWrite, 0) if testWriteContention { b.Logf("graph modifications during contention test: %d", writes) b.Logf("<1ms=%d, <10ms=%d, <25ms=%d, <50ms=%d, <100ms=%d, <250ms=%d, <500ms=%d, <1000ms=%d, >1000ms=%d", _1ms, _10ms, _25ms, _50ms, _100ms, _250ms, _500ms, _1000ms, _1s) } else { b.Logf("graph modifications during non-contention test: %d", writes) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 40.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
server.webSocket!!.close(1000, "Hello!") client.processNextFrame() client.listener.assertClosing(1000, "Hello!") assertThat(client.webSocket!!.close(1000, "Bye!")).isTrue() client.webSocket!!.finishReader() taskFaker.runTasks() client.listener.assertClosed(1000, "Hello!") server.processNextFrame() server.listener.assertClosing(1000, "Bye!") server.webSocket!!.finishReader()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
// The etcd server waits until it cannot find a leader for 3 election // timeouts to cancel existing streams. 3 is currently a hard coded // constant. The election timeout defaults to 1000ms. If the cluster is // healthy, when the leader is stopped, the leadership transfer should be // smooth. (leader transfers its leadership before stopping). If leader is
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
platforms/core-runtime/wrapper-main/src/integTest/groovy/org/gradle/integtests/WrapperHttpIntegrationTest.groovy
def failure = wrapperExecuter.runWithFailure() then: failure.assertHasErrorOutput("Downloading from ${getDefaultBaseUrl()}/$TEST_DISTRIBUTION_URL failed: timeout (10000ms)") failure.assertHasErrorOutput('Read timed out') } @Issue('https://github.com/gradle/gradle-private/issues/3032') def "does not leak credentials when download times out"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:54:32 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/helpers_linux_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_none_test.go
policy := &nonePolicy{} st := &mockState{ assignments: state.ContainerCPUAssignments{}, defaultCPUSet: cpuset.New(1, 2, 3, 4, 5, 6, 7), } testPod := makePod("fakePod", "fakeContainer", "1000m", "1000m") container := &testPod.Spec.Containers[0] err := policy.Allocate(st, testPod, container) if err != nil { t.Errorf("NonePolicy Allocate() error. expected no error but got: %v", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.7K bytes - Viewed (0)