- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for dispatch (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
callStart() try { client.dispatcher.executed(this) return getResponseWithInterceptorChain() } finally { client.dispatcher.finished(this) } } override fun enqueue(responseCallback: Callback) { check(executed.compareAndSet(false, true)) { "Already Executed" } callStart() client.dispatcher.enqueue(AsyncCall(responseCallback)) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
lock.assertHeld() val routeUrl = route.address.url if (url.port != routeUrl.port) { return false // Port mismatch. } if (url.host == routeUrl.host) { return true // Host match. The URL is supported. } // We have a host mismatch. But if the certificate matches, we're still good. return !noCoalescedConnections && handshake != null && certificateSupportHost(url, handshake!!)
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/Dispatcher.kt
import okhttp3.internal.threadFactory /** * Policy on when async requests are executed. * * Each dispatcher uses an [ExecutorService] to run calls internally. If you supply your own * executor, it should be able to run [the configured maximum][maxRequests] number of calls * concurrently. */ class Dispatcher() { internal val lock: ReentrantLock = ReentrantLock() /**
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) -
CHANGELOG.md
* Fix: Don't log response bodies for server-sent events. * Fix: Skip early hints (status code 103) responses. * Fix: Don't log sensitive headers in `Request.toString()`. * Fix: Don't crash when the dispatcher's `ExecutorService` is shutdown with many calls still enqueued. * Upgrade: [GraalVM 22][graalvm_22]. * Upgrade: [Kotlin 1.7.10][kotlin_1_7_10]. ## Version 5.0.0-alpha.10 _2022-06-26_
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/internal/http2/Http2Connection.kt
if (windowSize != DEFAULT_INITIAL_WINDOW_SIZE) { writer.windowUpdate(0, (windowSize - DEFAULT_INITIAL_WINDOW_SIZE).toLong()) } } // Thread doesn't use client Dispatcher, since it is scoped potentially across clients via // ConnectionPool. taskRunner.newQueue().execute(name = connectionName, block = readerRunnable) }
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/Locks.kt
import kotlin.contracts.InvocationKind import kotlin.contracts.contract import okhttp3.Dispatcher import okhttp3.internal.http2.Http2Connection import okhttp3.internal.http2.Http2Stream import okhttp3.internal.http2.Http2Writer /** * Centralisation of central locks according to docs/contribute/concurrency.md */ internal object Locks { inline fun <T> Dispatcher.withLock(action: () -> T): T {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 2.1K bytes - Viewed (0)