- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Falls (2.56 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
val connection = this.connection!! connection.lock.assertHeld() val calls = connection.calls val index = calls.indexOfFirst { it.get() == this@RealCall } check(index != -1) calls.removeAt(index) this.connection = null if (calls.isEmpty()) { connection.idleAtNs = System.nanoTime() if (connectionPool.connectionBecameIdle(connection)) {
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
* `allocations.size() < allocationLimit` then new streams can be created on this connection. */ internal var allocationLimit = 1 private set /** Current calls carried by this connection. */ val calls = mutableListOf<Reference<RealCall>>() /** Timestamp when `allocations.size()` reached zero. Also assigned upon initial connection. */ var idleAtNs = Long.MAX_VALUE /**
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
certain bad routes indefinitely; now we only track the ones that could be necessary. * Fix: Defer proxy selection until a proxy is required. This saves calls to `ProxySelector` on calls that use a pooled connection. ## Version 4.3.1 _2020-01-07_ * Fix: Don't crash with a `NullPointerException` when a web socket is closed before it connects.
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/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
val buffer = Buffer() /** * Reference count of the number of active sources reading this stream. When decremented to 0 * resources are released and all following calls to [.newSource] return null. Guarded by this. */ var sourceCount = 0 val isClosed: Boolean get() = file == null @Throws(IOException::class) private fun writeHeader( prefix: ByteString,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
fun testLoggingLevels() { enableTls() val testHandler = object : Handler() { val calls = mutableMapOf<String, AtomicInteger>() override fun publish(record: LogRecord) { calls.getOrPut(record.loggerName) { AtomicInteger(0) } .incrementAndGet() } override fun flush() { }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 27K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/CertificatePinner.kt
) { /** * Confirms that at least one of the certificates pinned for `hostname` is in `peerCertificates`. * Does nothing if there are no certificates pinned for `hostname`. OkHttp calls this after a * successful TLS handshake, but before the connection is used. * * @throws SSLPeerUnverifiedException if `peerCertificates` don't match the certificates pinned * for `hostname`. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/CipherSuite.kt
if (lengthA != lengthB) return if (lengthA < lengthB) -1 else 1 return 0 } } /** * Holds interned instances. This needs to be above the init() calls below so that it's * initialized by the time those parts of `<clinit>()` run. Guarded by CipherSuite.class. */ private val INSTANCES = mutableMapOf<String, CipherSuite>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 39.9K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
// Cancel some calls. That doesn't impact running or queued. a2.cancel() a3.cancel() assertThat(dispatcher.runningCalls()) .containsExactlyInAnyOrder(a1, a2) assertThat(dispatcher.queuedCalls()).isEmpty() // Let the calls finish. waiting.countDown() t1.join() t2.join() // Now we should have 0 running calls and 0 queued calls.
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) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* * `Response.body().string()` * * There is no benefit to invoking multiple `close()` methods for the same response body. * * For synchronous calls, the easiest way to make sure a response body is closed is with a `try` * block. With this structure the compiler inserts an implicit `finally` clause that calls * [close()][Response.close] for you. * * ```java * Call call = client.newCall(request); * try (Response response = call.execute()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
/** * True if this task faker has ever had multiple tasks scheduled to run concurrently. Guarded by * [TaskRunner.lock]. */ var isParallel = false /** Number of calls to [TaskRunner.Backend.execute]. Guarded by [TaskRunner.lock]. */ var executeCallCount = 0 /** Guarded by [taskRunner]. */ var nanoTime = 0L private set
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0)