- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Reed (8.55 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
allocationLimit = settings.getMaxConcurrentStreams() if (allocationLimit < oldLimit) { // We might need new connections to keep policies satisfied connectionPool.scheduleOpener(route.address) } else if (allocationLimit > oldLimit) { // We might no longer need some connections connectionPool.scheduleCloser() } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
_2020-09-11_ **With this release, `okhttp-tls` no longer depends on Bouncy Castle and doesn't install the Bouncy Castle security provider.** If you still need it, you can do it yourself: ``` Security.addProvider(BouncyCastleProvider()) ``` You will also need to configure this dependency: ``` dependencies { implementation "org.bouncycastle:bcprov-jdk15on:1.65" } ```
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-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
* [application interceptor][OkHttpClient.interceptors] or as a [OkHttpClient.networkInterceptors]. * * The format of the logs created by this class should not be considered stable and may * change slightly between releases. If you need a stable logging format, use your own interceptor. */ class HttpLoggingInterceptor @JvmOverloads constructor( private val logger: Logger = Logger.DEFAULT, ) : Interceptor {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
val tlsEquipPlan = planWithCurrentOrInitialConnectionSpec(connectionSpecs, sslSocket) val connectionSpec = connectionSpecs[tlsEquipPlan.connectionSpecIndex] // Figure out the next connection spec in case we need a retry. retryTlsConnection = tlsEquipPlan.nextConnectionSpec(connectionSpecs, sslSocket) connectionSpec.apply(sslSocket, isFallback = tlsEquipPlan.isTlsFallback) connectTls(sslSocket, connectionSpec)
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) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
/** Returns true if a Vary header contains an asterisk. Such responses cannot be cached. */ fun Response.hasVaryAll(): Boolean = "*" in headers.varyFields() /** * Returns the names of the request headers that need to be checked for equality when caching. */ private fun Headers.varyFields(): Set<String> { var result: MutableSet<String>? = null for (i in 0 until size) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
private var coordinatorWakeUpAt = 0L /** * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until * the already-requested ones are in service, otherwise we might create more threads than we need. *
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/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
.sentRequestAtMillis(-1L) .receivedResponseAtMillis(System.currentTimeMillis()) .build().also { listener.satisfactionFailure(call, it) } } // If we don't need the network, we're done. if (networkRequest == null) { return cacheResponse!!.newBuilder() .cacheResponse(cacheResponse.stripBody()) .build().also { listener.cacheHit(call, it) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
maxIdleConnections = 2, ) val c1 = factory.newConnection(pool, routeA1, 50L) val c2 = factory.newConnection(pool, routeB1, 75L) // With 2 connections, there's no need to evict until the connections time out. assertThat(pool.closeConnections(100L)).isEqualTo(50L) assertThat(pool.connectionCount()).isEqualTo(2) assertThat(c1.socket().isClosed).isFalse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
// performed while holding this lock! // // Socket writes are guarded by frameWriter. // // Socket reads are unguarded but are only made by the reader thread. // // Certain operations (like SYN_STREAM) need to synchronize on both the frameWriter (to do // blocking I/O) and this (to create streams). Such operations must synchronize on 'this' last. // This ensures that we never wait for a blocking operation while holding 'this'.
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/connection/RealConnectionPool.kt
// Find the longest-idle connections in 2 categories: // // 1. OLD: Connections that have been idle for at least keepAliveDurationNs. We close these if // we find them, regardless of what the address policies need. // // 2. EVICTABLE: Connections not required by any address policy. This matches connections that // don't participate in any policy, plus connections whose policies won't be violated if the
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)