- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for shutdown (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
ignoreIoExceptions { socket.close() } // Release the threads. writerQueue.shutdown() pushQueue.shutdown() settingsListenerQueue.shutdown() } private fun failConnection(e: IOException?) { close(ErrorCode.PROTOCOL_ERROR, ErrorCode.PROTOCOL_ERROR, e) } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
redQueue.shutdown() redQueue.execute("task", 100.µs) { // Do nothing. } taskFaker.assertNoMoreTasks() assertThat(testLogHandler.takeAll()).containsExactly( "FINE: Q10000 schedule canceled (queue is shutdown): task", ) } @Test fun scheduleThrowsWhenShutdown() { redQueue.shutdown()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0) -
docs/en/docs/features.md
* **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. ## Pydantic features
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu May 02 22:37:31 GMT 2024 - 9.3K bytes - Viewed (0) -
okhttp/src/test/java/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.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
docs/en/docs/release-notes.md
## 0.93.0 ### Features * ✨ Add support for `lifespan` async context managers (superseding `startup` and `shutdown` events). Initial PR [#2944](https://github.com/tiangolo/fastapi/pull/2944) by [@uSpike](https://github.com/uSpike). Now, instead of using independent `startup` and `shutdown` events, you can define that logic in a single function with `yield` decorated with `@asynccontextmanager` (an async context manager).
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Fri May 03 23:25:42 GMT 2024 - 388.1K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
} // Avoid resubmitting if we can't logically progress // particularly because RealCall handles a RejectedExecutionException // by executing on the same thread. if (executorService.isShutdown) { for (i in 0 until executableCalls.size) { val asyncCall = executableCalls[i] asyncCall.callsPerHost.decrementAndGet() this.withLock { runningAsyncCalls.remove(asyncCall)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
RELEASE.md
* New API for initialization of CPU/GPU/TPU in dtensor. `dtensor.initialize_accelerator_system` and `dtensor.shutdown_accelerator_system`. * The following existing API will be removed: `dtensor.initialize_multi_client`, `dtensor.initialize_tpu_system`, and `dtensor.shutdown_tpu_system`. ## Deprecations * The C++ `tensorflow::Code` and `tensorflow::Status` will become aliases of
Plain Text - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Mon Apr 29 19:17:57 GMT 2024 - 727.7K bytes - Viewed (8)