- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Magnin (0.18 sec)
-
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
MockResponse(body = "This is the 2nd server, again!"), ) server.enqueue( MockResponse( code = HttpURLConnection.HTTP_MOVED_TEMP, headers = headersOf("Location", server2.url("/").toString()), body = "This page has moved!", ), ) server.enqueue( MockResponse(body = "This is the first server again!"), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
* New: `OkHttpClient.x509TrustManager` accessor. * New: Permit [new WebSocket response codes][iana_websocket]: 1012 (Service Restart), 1013 (Try Again Later), and 1014 (invalid response from the upstream). * New: Build with Kotlin 1.3.41, BouncyCastle 1.62, and Conscrypt 2.2.1. * Fix: Recover gracefully when a coalesced connection immediately goes unhealthy.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
* If there are already enough connections, we're done. * If not, we create one and then schedule the task to run again immediately. */ private fun openConnections(state: AddressState): Long { // This policy does not require minimum connections, don't run again if (state.policy.minimumConcurrentCalls == 0) return -1L var concurrentCallCapacity = 0 for (connection in connections) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
readBytes.update(acknowledged = unacknowledgedBytesRead) } } else if (!finished && errorExceptionToDeliver == null) { // Nothing to do. Wait until that changes then try again. waitForIo() tryAgain = true } } finally { if (doReadTimeout) { readTimeout.exitAndThrowIfTimedOut() } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 scheduled after 100 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 run again after 50 µs: task", "FINE: Q10000 finished run in 0 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 run again after 150 µs: task", "FINE: Q10000 finished run in 0 µs: task", "FINE: Q10000 starting : task",
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) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
Thread.sleep(TimeUnit.NANOSECONDS.toMillis(Http2Connection.DEGRADED_PONG_TIMEOUT_NS.toLong())) assertThat(connection.isHealthy(System.nanoTime())).isFalse() // When a pong does arrive, the connection becomes healthy again. connection.writePingAndAwaitPong() assertThat(connection.isHealthy(System.nanoTime())).isTrue() // 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) -
okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt
2F1B ; mapped ; 53B6 # 3.0 KANGXI RADICAL PRIVATE 2F1C ; mapped ; 53C8 # 3.0 KANGXI RADICAL AGAIN 2F1D ; mapped ; 53E3 # 3.0 KANGXI RADICAL MOUTH 2F1E ; mapped ; 56D7 # 3.0 KANGXI RADICAL ENCLOSURE
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Feb 10 11:25:47 GMT 2024 - 854.1K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* A unit of work that can be executed one or more times. * * Recurrence * ---------- * * Tasks control their recurrence schedule. The [runOnce] function returns -1L to signify that the * task should not be executed again. Otherwise it returns a delay until the next execution. * * A task has at most one next execution. If the same task instance is scheduled multiple times, the
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
futureTasks.removeAt(existingIndex) // Already scheduled later: reschedule below! } task.nextExecuteNanoTime = executeNanoTime taskRunner.logger.taskLog(task, this) { if (recurrence) { "run again after ${formatDuration(executeNanoTime - now)}" } else { "scheduled after ${formatDuration(executeNanoTime - now)}" } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
user.addPlanToCancel(this) try { if (tunnelRequest != null) { val tunnelResult = connectTunnel() // Tunnel didn't work. Start it all again. if (tunnelResult.nextPlan != null || tunnelResult.throwable != null) { return tunnelResult } } if (route.address.sslSocketFactory != null) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0)