- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 69 for currency (0.16 sec)
-
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) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
@Test fun nonStandardAuthenticationSchemeWithRealm() { val calls = authCallsForHeader("WWW-Authenticate: Foo realm=\"Bar\"") assertThat(calls.size).isEqualTo(0) } // Digest auth is currently unsupported. Test that digest requests should fail reasonably. // http://code.google.com/p/android/issues/detail?id=11140 @Test fun digestAuthentication() { val calls = authCallsForHeader(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
internal val taskRunner: TaskRunner, internal val name: String, ) { val lock: ReentrantLock = ReentrantLock() internal var shutdown = false /** This queue's currently-executing task, or null if none is currently executing. */ internal var activeTask: Task? = null /** Scheduled tasks ordered by [Task.nextExecuteNanoTime]. */ internal val futureTasks = mutableListOf<Task>()
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) -
okhttp/src/main/kotlin/okhttp3/internal/graal/OkHttpFeature.kt
import org.graalvm.nativeimage.hosted.Feature import org.graalvm.nativeimage.hosted.RuntimeResourceAccess /** * Automatic configuration of OkHttp for native images. * * Currently, includes all necessary resources. */ class OkHttpFeature : Feature { @IgnoreJRERequirement override fun beforeAnalysis(access: Feature.BeforeAnalysisAccess?) { RuntimeResourceAccess.addResource(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* ------------ * * Tasks may be canceled while they are waiting to be executed, or while they are executing. * * Canceling a task that is waiting to execute prevents that upcoming execution. Canceling a task * that is currently executing does not impact the ongoing run, but it does prevent a recurrence * from being scheduled. * * Tasks may opt-out of cancellation with `cancelable = false`. Such tasks will recur until they
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
private val taskRunner: TaskRunner, ) : ExchangeFinder { private val connectDelayNanos = TimeUnit.MILLISECONDS.toNanos(250L) private var nextTcpConnectAtNanos = Long.MIN_VALUE /** * Plans currently being connected, and that will later be added to [connectResults]. This is * mutated by the call thread only. If is accessed by background connect threads. */ private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt
val isOptional: Boolean = false, /** The value to return if this value is absent. Undefined unless this is optional. */ val defaultValue: T? = null, /** True to set the encoded or decoded value as the type hint for the current SEQUENCE. */ private val typeHint: Boolean = false, ) : DerAdapter<T> { init { require(tagClass >= 0) require(tag >= 0) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
val snapshot = (cached.body as CacheResponseBody).snapshot var editor: DiskLruCache.Editor? = null try { editor = snapshot.edit() ?: return // edit() returns null if snapshot is not current. entry.writeTo(editor) editor.commit() } catch (_: IOException) { abortQuietly(editor) } } private fun abortQuietly(editor: DiskLruCache.Editor?) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/CertificatePinner.kt
* certificate authorities. It also prevents connections through man-in-the-middle certificate * authorities either known or unknown to the application's user. * This class currently pins a certificate's Subject Public Key Info as described on * [Adam Langley's Weblog][langley]. Pins are either base64 SHA-256 hashes as in * [HTTP Public Key Pinning (HPKP)][rfc_7469] or SHA-1 base64 hashes as in Chromium's
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) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
} } finally { Security.removeProvider("BCJSSE") Security.removeProvider("BC") } } @Test @Disabled("TODO: currently logging okhttp3.internal.concurrent.TaskRunner, okhttp3.internal.http2.Http2") fun testLoggingLevels() { enableTls() val testHandler = object : Handler() {
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)