- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for pool (0.21 sec)
-
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
* of which connections to keep open for future use. * * @constructor Create a new connection pool with tuning parameters appropriate for a single-user * application. The tuning parameters in this pool are subject to change in future OkHttp releases. * Currently this pool holds up to 5 idle connections which will be evicted after 5 minutes of * inactivity. */ class ConnectionPool internal constructor(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
expectedEvents += "ResponseBodyEnd" expectedEvents += "ConnectionReleased" expectedEvents += "CallEnd" assertThat(listener.recordedEventTypes()).isEqualTo(expectedEvents) // Confirm that the connection pool was not corrupted by making another call. makeSimpleCall() } /** * If the server returns a full response, it doesn't really matter if the HTTP/2 stream is reset.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
/** * If true, no new exchanges can be created on this connection. It is necessary to set this to * true when removing a connection from the pool; otherwise a racing caller might get it from the * pool when it shouldn't. Symmetrically, this must always be checked before returning a * connection from the pool. * * Once true this is always true. Guarded by this. */ var noNewExchanges = false /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
of unacknowledged data per stream and no per-connection limit. * Fix: Don't operate on a connection after it's been returned to the pool. This race occurred on failed web socket connection attempts. * Upgrade: [Okio 3.6.0][okio_3_6_0]. * Upgrade: [Kotlin 1.8.21][kotlin_1_8_21]. ## Version 4.11.0 _2023-04-22_
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
// Running at time 75, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(75L)).isEqualTo(75L) assertThat(pool.connectionCount()).isEqualTo(2) // Running at time 149, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(149L)).isEqualTo(1L) assertThat(pool.connectionCount()).isEqualTo(2)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
val id: Int, ) : RoutePlanner.Plan { var planningThrowable: Throwable? = null var canceled = false var connectState = ConnectState.READY val connection = factory.newConnection( pool = pool, route = factory.newRoute(address), idleAtNanos = defaultConnectionIdleAtNanos, ) var retry: FakePlan? = null var retryTaken = false var yieldBeforePlanReturns = false
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
docs/features/connections.md
1. It uses the URL and configured OkHttpClient to create an **address**. This address specifies how we'll connect to the webserver. 2. It attempts to retrieve a connection with that address from the **connection pool**. 3. If it doesn't find a connection in the pool, it selects a **route** to attempt. This usually means making a DNS request to get the server's IP addresses. It then selects a TLS version and proxy server if necessary.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Feb 21 03:33:59 GMT 2022 - 5.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* 1. If the current call already has a connection that can satisfy the request it is used. Using * the same connection for an initial exchange and its follow-ups may improve locality. * * 2. If there is a connection in the pool that can satisfy the request it is used. Note that it is * possible for shared exchanges to make requests to different host names! See * [RealConnection.isEligible] for details. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
.build(), ) } } private fun testServerClosesOutput(socketPolicy: SocketPolicy) { server.enqueue( MockResponse( body = "This connection won't pool properly", socketPolicy = socketPolicy, ), ) val responseAfter = MockResponse(body = "This comes after a busted connection") server.enqueue(responseAfter)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
@Throws(IOException::class) override fun plan(): Plan { val reuseCallConnection = planReuseCallConnection() if (reuseCallConnection != null) return reuseCallConnection // Attempt to get a connection from the pool. val pooled1 = planReusePooledConnection() if (pooled1 != null) return pooled1 // Attempt a deferred plan before new routes. if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0)