- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 218 for ShutDown (0.09 sec)
-
cmd/erasure-server-pool.go
} func (z *erasureServerPools) Shutdown(ctx context.Context) error { g := errgroup.WithNErrs(len(z.serverPools)) for index := range z.serverPools { index := index g.Go(func() error { return z.serverPools[index].Shutdown(ctx) }, index) } for _, err := range g.Wait() { if err != nil { storageLogIf(ctx, err) } // let's the rest shutdown } return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
assertFailsWith<IOException> { getResponse(request) } } @Test fun connectRetriesUntilConnectedOrFailed() { val request = newRequest("/foo") server.shutdown() assertFailsWith<IOException> { getResponse(request) } } @Test fun requestBodySurvivesRetriesWithFixedLength() { testRequestBodySurvivesRetries(TransferKind.FIXED_LENGTH)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 131.7K bytes - Viewed (0) -
docs/en/docs/alternatives.md
It is very simple and intuitive. It's designed to be easily extensible, and have modular components. It has: * Seriously impressive performance. * WebSocket support. * In-process background tasks. * Startup and shutdown events. * Test client built on HTTPX. * CORS, GZip, Static Files, Streaming responses. * Session and Cookie support. * 100% test coverage. * 100% type annotated codebase. * Few hard dependencies.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 23.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
else break; } } /** Waits out termination of a thread pool or fails doing so. */ void joinPool(ExecutorService exec) throws InterruptedException { try { exec.shutdown(); assertTrue( "ExecutorService did not terminate in a timely manner", exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS)); } catch (SecurityException ok) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 37.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
* server will return "Access denied" even if a logoff is * sent. Unfortunately calling disconnect() doesn't always * actually shutdown the connection before other threads * have committed themselves (e.g. InterruptTest example). */ try {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Nov 14 17:41:04 UTC 2021 - 49K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
val cached = cacheGet(cache, request) if (shouldWriteToCache) { assertThat(cached).isNotNull() cached!!.body.close() } else { assertThat(cached).isNull() } server.shutdown() // tearDown() isn't sufficient; this test starts multiple servers } private fun assertSubsequentResponseCached( initialResponseCode: Int, finalResponseCode: Int, ) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 108.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
else break; } } /** Waits out termination of a thread pool or fails doing so. */ void joinPool(ExecutorService exec) throws InterruptedException { try { exec.shutdown(); assertTrue( "ExecutorService did not terminate in a timely manner", exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS)); } catch (SecurityException ok) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 37.9K bytes - Viewed (0) -
docs/en/docs/deployment/docker.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Sep 18 16:09:57 UTC 2024 - 28.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
listener.forbidLock(get(client.connectionPool)) listener.forbidLock(client.dispatcher) } @AfterEach fun tearDown() { if (socksProxy != null) { socksProxy!!.shutdown() } if (cache != null) { cache!!.delete() } } @Test fun successfulCallEventSequence() { server.enqueue( MockResponse.Builder() .body("abc")
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.16.md
* The kube-apiserver has improved behavior for both startup and shutdown sequences and also now exposes `/readyz` for readiness checking. Readyz includes all existing healthz checks but also adds a shutdown check. When a cluster admin initiates a shutdown, the kube-apiserver will try to process existing requests (for the duration of request timeout) before killing the apiserver process. ([#78458](https://...
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Thu Feb 11 10:00:57 UTC 2021 - 345.2K bytes - Viewed (0)