- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for 1000 (2.33 sec)
-
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()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
webSocket.close(1000, reason) }.also { expected -> assertThat(expected.message).isEqualTo("reason.size() > 123: $reason") } webSocket.close(1000, null) serverListener.assertClosing(1000, "") server.close(1000, null) clientListener.assertClosing(1000, "") clientListener.assertClosed(1000, "") serverListener.assertClosed(1000, "") } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
connectionListener: ConnectionListener = ConnectionListener.NONE, readTimeoutMillis: Int = 10_000, writeTimeoutMillis: Int = 10_000, socketConnectTimeoutMillis: Int = 10_000, socketReadTimeoutMillis: Int = 10_000, pingIntervalMillis: Int = 10_000, retryOnConnectionFailure: Boolean = true, fastFallback: Boolean = true, routeDatabase: RouteDatabase = RouteDatabase(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
cni/README.md
under the `kubelet` process. On systems with `journalctl` the following is an example command line to view the last 1000 `kubelet` logs via the `less` utility to allow for `vi`-style searching: ```console $ journalctl -t kubelet -n 1000 | less ``` #### GKE via Stackdriver Log Viewer Each GKE cluster's will have many categories of logs collected by Stackdriver. Logs can be monitored via
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 12.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cookie.kt
if (deltaSeconds == Long.MIN_VALUE) { expiresAt = Long.MIN_VALUE } else if (deltaSeconds != -1L) { val deltaMilliseconds = if (deltaSeconds <= Long.MAX_VALUE / 1000) { deltaSeconds * 1000 } else { Long.MAX_VALUE } expiresAt = currentTimeMillis + deltaMilliseconds if (expiresAt < currentTimeMillis || expiresAt > MAX_DATE) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:12:05 GMT 2024 - 23.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* * ```java * public final OkHttpClient client = new OkHttpClient.Builder() * .readTimeout(1000, TimeUnit.MILLISECONDS) * .writeTimeout(1000, TimeUnit.MILLISECONDS) * .build(); * ``` * * This example shows a call with a short 500 millisecond read timeout and a 1000 millisecond * write timeout. Original configuration is kept, but can be overriden. * * ```java
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
* the server doesn't respond the web socket will be canceled. */ const val CANCEL_AFTER_CLOSE_MILLIS = 60L * 1000 /** * The smallest message that will be compressed. We use 1024 because smaller messages already * fit comfortably within a single ethernet packet (1500 bytes) even with framing overhead. * * For tests this must be big enough to realize real compression on test messages like
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
setUp(protocol, mockWebServer) client = client.newBuilder() .readTimeout(Duration.ofMillis(500)) .build() server.enqueue( MockResponse.Builder() .bodyDelay(1000, TimeUnit.MILLISECONDS) .body("a") .build(), ) server.enqueue(MockResponse(body = "b")) server.enqueue(MockResponse(body = "c")) // The first call times out.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
class TaskRunner( val backend: Backend, internal val logger: Logger = TaskRunner.logger, ) { val lock: ReentrantLock = ReentrantLock() val condition: Condition = lock.newCondition() private var nextQueueName = 10000 private var coordinatorWaiting = false private var coordinatorWakeUpAt = 0L /** * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we
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)