- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for existent (0.15 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) // Note that although we have two routes available, we only use one. The retry is permitted // because there are routes available, but it chooses the existing connection since it isn't // yet considered unhealthy. assertThat(server.takeRequest().sequenceNumber).isEqualTo(1) } @ParameterizedTest @ArgumentsSource(ProtocolParamProvider::class)
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/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* failed connect attempts (such as trying the next [ConnectionSpec]), or as attempts that lost * a race in fast follow-up. * * 4. If there's no existing connection, make a list of routes (which may require blocking DNS * lookups) and attempt a new connection them. When failures occur, retries iterate the list of * available routes. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
} internal fun enqueue(call: AsyncCall) { this.withLock { readyAsyncCalls.add(call) // Mutate the AsyncCall so that it shares the AtomicInteger of an existing running call to // the same host. if (!call.call.forWebSocket) { val existingCall = findExistingCallWithHost(call.host) if (existingCall != null) call.reuseCallsPerHostFrom(existingCall)
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
val localNextRouteToTry = nextRouteToTry if (localNextRouteToTry != null) { nextRouteToTry = null return planConnectToRoute(localNextRouteToTry) } // Use a route from an existing route selection. val existingRouteSelection = routeSelection if (existingRouteSelection != null && existingRouteSelection.hasNext()) { return planConnectToRoute(existingRouteSelection.next()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
@Throws(IOException::class) fun flush() { writer.flush() } /** * Degrades this connection such that new streams can neither be created locally, nor accepted * from the remote peer. Existing streams are not impacted. This is intended to permit an endpoint * to gracefully stop accepting new requests without harming previously established streams. */ @Throws(IOException::class)
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) -
CHANGELOG.md
* New: `Cache` now has a public constructor that takes an [okio.FileSystem]. This should make it possible to implement decorators for cache encryption or compression. * New: `Cookie.newBuilder()` to build upon an existing cookie. * New: Use TLSv1.3 when running on JDK 8u261 or newer. * New: `QueueDispatcher.clear()` may be used to reset a MockWebServer instance.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
* * This can be invoked more than 1 time for a single [Call]. For example, if the response to the * [Call.request] is a redirect to a different host. * * If the [Call] is able to reuse an existing pooled connection, this method will not be invoked. * See [ConnectionPool]. */ open fun dnsStart( call: Call, domainName: String, ) { } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SessionReuseTest.kt
assertEquals(0, client.connectionPool.connectionCount()) // Force reuse. This appears flaky (30% of the time) even though sessions are reused. // javax.net.ssl.SSLHandshakeException: No new session is allowed and no existing // session can be resumed // // Report https://bugs.java.com/bugdatabase/view_bug.do?bug_id=JDK-8264944 // Sessions improvement https://bugs.java.com/bugdatabase/view_bug.do?bug_id=JDK-8245576
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 6K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
* * Copy WireSharkKeyLoggerListener to your test code to use in development. * * This logs TLSv1.2 on a JVM (OpenJDK 11+) without any additional code. For TLSv1.3 * an existing external tool is required. * * See https://stackoverflow.com/questions/61929216/how-to-log-tlsv1-3-keys-in-jsse-for-wireshark-to-decode-traffic * * Steps to run in your own code *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
if (state.address != connection.route.address) continue connection.withLock { concurrentCallCapacity += connection.allocationLimit } // The policy was satisfied by existing connections, don't run again if (concurrentCallCapacity >= state.policy.minimumConcurrentCalls) return -1L } // If we got here then the policy was not satisfied -- open a connection! try {
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)