- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Ridley (0.44 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
import okhttp3.internal.platform.Platform import okio.IOException class RealConnectionPool( private val taskRunner: TaskRunner, /** * The maximum number of idle connections across all addresses. * Connections needed to satisfy a [ConnectionPool.AddressPolicy] are not considered idle. */ private val maxIdleConnections: Int, keepAliveDuration: Long, timeUnit: TimeUnit, internal val connectionListener: ConnectionListener,
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/test/java/okhttp3/UrlComponentEncodingTester.kt
encodings[ 0x13] = encoding // Device Control 3 (oft. XOFF) encodings[ 0x14] = encoding // Device Control 4 encodings[ 0x15] = encoding // Negative Acknowledgment encodings[ 0x16] = encoding // Synchronous idle encodings[ 0x17] = encoding // End of Transmission Block encodings[ 0x18] = encoding // Cancel encodings[ 0x19] = encoding // End of Medium encodings[ 0x1a] = encoding // Substitute
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 12.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
/** Returns the number of idle connections in the pool. */ fun idleConnectionCount(): Int = delegate.idleConnectionCount() /** Returns total number of connections in the pool. */ fun connectionCount(): Int = delegate.connectionCount() internal val connectionListener: ConnectionListener get() = delegate.connectionListener /** Close and remove all idle connections in the pool. */ fun evictAll() {
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
if (http2Connection != null) { return http2Connection.isHealthy(nowNs) } val idleDurationNs = lock.withLock { nowNs - idleAtNs } if (idleDurationNs >= IDLE_CONNECTION_HEALTHY_NS && doExtensiveChecks) { return socket.isHealthy(source) } return true } /** Refuse incoming 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 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Connection.kt
* used. HTTP/1.x connections can carry either zero or one streams. HTTP/2 connections can carry any * number of streams, dynamically configured with `SETTINGS_MAX_CONCURRENT_STREAMS`. A connection * currently carrying zero streams is an idle stream. We keep it alive because reusing an existing * connection is typically faster than establishing a new one. * * When a single logical call requires multiple streams due to redirects or authorization
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
if (!inputExhausted) { responseBodyComplete() } closed = true } } companion object { private const val NO_CHUNK_YET = -1L private const val STATE_IDLE = 0 // Idle connections are ready to write request headers. private const val STATE_OPEN_REQUEST_BODY = 1 private const val STATE_WRITING_REQUEST_BODY = 2 private const val STATE_READ_RESPONSE_HEADERS = 3
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
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) -
docs/contribute/concurrency.md
Blocking APIs may be inefficient because you hold a thread idle while waiting on the network. Threads are expensive because they have both a memory overhead and a context-switching overhead. #### Framed protocols
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0) -
.github/CONTRIBUTING.md
- OkHttp is a small and light dependency. Don't introduce new dependencies or major new functionality. - OkHttp targets the intersection of RFC correct *and* widely implemented. Incorrect implementations that are very widely implemented e.g. a bug in Apache, Nginx, Google, Firefox should also be handled. Before your code can be accepted into the project you must also sign the
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 17 04:16:26 GMT 2019 - 1.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
} @Test fun idleCallbackInvokedWhenIdle() { val idle = AtomicBoolean() dispatcher.idleCallback = Runnable { idle.set(true) } client.newCall(newRequest("http://a/1")).enqueue(callback) client.newCall(newRequest("http://a/2")).enqueue(callback) executor.finishJob("http://a/1") assertThat(idle.get()).isFalse() val ready = CountDownLatch(1) val proceed = CountDownLatch(1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0)