- Sort Score
- Num 10 results
- Language All
Results 1 - 9 of 9 for _shutdown (0.23 seconds)
-
src/main/java/jcifs/smb/SmbSessionImpl.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 68.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* ``` * * ## Shutdown Isn't Necessary * * The threads and connections that are held will be released automatically if they remain idle. But * if you are writing a application that needs to aggressively release unused resources you may do * so. * * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 51.5K bytes - Click Count (0) -
docs/changelogs/changelog_3x.md
## Version 3.4.2 _2016-11-03_ * Fix: Recover gracefully when an HTTP/2 connection is shutdown. We had a bug where shutdown HTTP/2 connections were considered usable. This caused infinite loops when calls attempted to recover. ## Version 3.4.1 _2016-07-10_ * **Fix a major bug in encoding HTTP headers.** In 3.4.0 and 3.4.0-RC1 OkHttpCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
object : okhttp3.mockwebserver.Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse = TODO() override fun peek(): MockResponse = TODO() override fun shutdown() = TODO() } } @Test fun dns() { var dns: Dns = Dns { TODO() } val system: Dns = Dns.SYSTEM } @Test fun eventListener() { val eventListener =
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 49.7K bytes - Click Count (0) -
cmd/test-utils_test.go
} // Deleting the temporary backend and stopping the server. func (testServer TestServer) Stop() { testServer.cancel() testServer.Server.Close() testServer.Obj.Shutdown(context.Background()) os.RemoveAll(testServer.Root) for _, ep := range testServer.Disks { for _, disk := range ep.Endpoints { os.RemoveAll(disk.Path) } } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 77K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
assertThat(server.takeRequest().exchangeIndex).isEqualTo(1) // New connection. } /** * We had a bug where we'd perform infinite retries of route that fail with connection shutdown * errors. The problem was that the logic that decided whether to reuse a route didn't track * certain HTTP/2 errors. https://github.com/square/okhttp/issues/5547 */ @Test
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 67.5K bytes - Click Count (0) -
cmd/erasure-server-pool.go
} func (z *erasureServerPools) Shutdown(ctx context.Context) error { g := errgroup.WithNErrs(len(z.serverPools)) for index := range z.serverPools { 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 }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
eventRecorder.forbidLock(get(client.connectionPool)) eventRecorder.forbidLock(client.dispatcher) } @AfterEach fun tearDown() { if (socksProxy != null) { socksProxy!!.shutdown() } if (cache != null) { cache!!.delete() } } @Test fun successfulCallEventSequence() { server.enqueue( MockResponse .Builder()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 70.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
connection.withLock { if (!connection.isHealthy(System.nanoTime())) { throw ConnectionShutdownException() } } connection.writePing() connection.shutdown(ErrorCode.PROTOCOL_ERROR) assertThat(connection.openStreamCount()).isEqualTo(1) connection.awaitPong() // Prevent the peer from exiting prematurely. // Verify the peer received what was expected.Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 75.5K bytes - Click Count (0)