- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for NoNewExchanges (0.11 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
val call: Call, ) : ConnectionEvent() { override fun closes(event: ConnectionEvent): Boolean = event is ConnectionAcquired && connection == event.connection && call == event.call } data class NoNewExchanges( override val timestampNs: Long, override val connection: Connection, ) : ConnectionEvent()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
*/ interface Carrier { val route: Route fun trackFailure( call: RealCall, e: IOException?, ) fun noNewExchanges() fun cancel() } companion object { /** * The timeout to use while discarding a stream of input data. Since this is used for connection
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
} fun webSocketUpgradeFailed() { bodyComplete(-1L, responseDone = true, requestDone = true, e = null) } fun noNewExchangesOnConnection() { codec.carrier.noNewExchanges() } fun cancel() { codec.cancel() } /** * Revoke this exchange's access to streams. This is necessary when a follow-up request is
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
} assertThat(listener.recordedEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "NoNewExchanges", "ConnectionReleased", "ConnectionClosed", ) } @Throws(IOException::class) private fun assertSuccessfulEventOrder() { val call = client.newCall(
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.6K bytes - Viewed (0) -
docs/contribute/concurrency.md
#### Per-Connection Locks Each connection has its own lock. The connections in the pool are all in a `ConcurrentLinkedQueue`. Due to data races, iterators of this queue may return removed connections. Callers must check the connection's `noNewExchanges` property before using connections from the pool. The connection lock is never held while doing I/O (even closing a socket) to prevent contention.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
awaitGarbageCollection() assertThat(pool.closeConnections(100L)).isEqualTo(0L) assertThat(c1.calls).isEmpty() // Can't allocate once a leak has been detected. assertThat(c1.noNewExchanges).isTrue() } @Test fun interruptStopsThread() { val realTaskRunner = TaskRunner.INSTANCE val pool = factory.newConnectionPool( taskRunner = TaskRunner.INSTANCE,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jun 22 16:06:35 UTC 2024 - 12.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
return connection } override fun trackFailure( call: RealCall, e: IOException?, ) { // Do nothing. } override fun noNewExchanges() { // Do nothing. } override fun cancel() { canceled = true // Close the raw socket so we don't end up doing synchronous I/O. rawSocket?.closeQuietly() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0) -
okhttp/api/okhttp.api
public fun connectionAcquired (Lokhttp3/Connection;Lokhttp3/Call;)V public fun connectionClosed (Lokhttp3/Connection;)V public fun connectionReleased (Lokhttp3/Connection;Lokhttp3/Call;)V public fun noNewExchanges (Lokhttp3/Connection;)V } public final class okhttp3/ConnectionListener$Companion { public final fun getNONE ()Lokhttp3/ConnectionListener; } public final class okhttp3/ConnectionPool {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 70.2K bytes - Viewed (0)