- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 130 for timediv (0.25 sec)
-
guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
getChecked( FAILED_FUTURE_CHECKED_EXCEPTION, ExceptionWithGoodAndBadConstructor.class)); assertThat(expected).hasCauseThat().isSameInstanceAs(CHECKED_EXCEPTION); } // Boring timed-get tests: public void testGetCheckedTimed_success() throws TwoArgConstructorException { assertEquals( "foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class, 0, SECONDS)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 16.4K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
logger.Info("Starting storage version garbage collector") if !cache.WaitForCacheSync(ctx.Done(), c.leasesSynced, c.storageVersionSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // Identity lease deletion and storageversion update don't happen too often. Start one // worker for each of them.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.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 class FakeService extends AbstractExecutionThreadService implements TearDown {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
val readTimeout = soTimeout try { soTimeout = 1 !source.exhausted() } finally { soTimeout = readTimeout } } catch (_: SocketTimeoutException) { true // Read timed out; socket is good. } catch (_: IOException) { false // Couldn't read; socket is closed. } } internal inline fun threadName( name: String, block: () -> Unit, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon May 13 13:42:37 UTC 2024 - 10.7K bytes - Viewed (0) -
src/net/net.go
Err string // description of the error Name string // name looked for Server string // server used IsTimeout bool // if true, timed out; not all timeouts set this IsTemporary bool // if true, error is temporary; not all errors set this // IsNotFound is set to true when the requested name does not
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
pkg/registry/flowcontrol/rest/storage_flowcontrol.go
ctx, cancel := contextFromChannelAndMaxWaitDuration(hookContext.StopCh, 5*time.Minute) defer cancel() if !cache.WaitForCacheSync(ctx.Done(), bce.informersSynced...) { return fmt.Errorf("APF bootstrap ensurer timed out waiting for cache sync") } err = wait.PollImmediateUntilWithContext( ctx, time.Second, func(context.Context) (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 12.3K bytes - Viewed (0) -
internal/dsync/drwmutex.go
} }(index, c) } // Wait until we have either // // a) received all refresh responses // b) received too many refreshed for quorum to be still possible // c) timed out // lockNotFound, lockRefreshed := 0, 0 done := false for i := 0; i < len(restClnts); i++ { select { case refreshResult := <-ch: if refreshResult.offline { continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
.socketPolicy(NoResponse) .build(), ) val webSocket: WebSocket = newWebSocket() clientListener.assertFailure( SocketTimeoutException::class.java, "timeout", "Read timed out", ) assertThat(webSocket.close(1000, null)).isFalse() } /** * There's no read timeout when reading the first byte of a new frame. But as soon as we start
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/stub.go
} klog.ErrorS(restartErr, "Retrying after error") lastErr = restartErr return false, nil }) if err != nil { klog.ErrorS(err, "Unable to restart server: wait timed out", "lastErr", lastErr.Error()) panic(err) } if ok := m.registerControlFunc(); ok { if err := m.Register(kubeletEndpoint, resourceName, pluginSockDir); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 11:19:10 UTC 2023 - 11.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0)