- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Schack (0.6 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
newRoutePlanner: Boolean, chain: RealInterceptorChain, ) { check(interceptorScopedExchange == null) this.withLock { check(!responseBodyOpen) { "cannot make a new request because the previous response is still open: " + "please call response.close()" } check(!requestBodyOpen) } if (newRoutePlanner) { val routePlanner =
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/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
private val outputFile = resources / PUBLIC_SUFFIX_RESOURCE val request = Request("https://publicsuffix.org/list/public_suffix_list.dat".toHttpUrl()) suspend fun import() { check(fileSystem.metadata(resources).isDirectory) check(fileSystem.metadata(testResources).isDirectory) updateLocalFile() val importResults = readImportResults() writeOutputFile(importResults) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
if (address.hostnameVerifier !== OkHostnameVerifier) return false if (!supportsUrl(address.url)) return false // 4. Certificate pinning must match the host. try { address.certificatePinner!!.check(address.url.host, handshake()!!.peerCertificates) } catch (_: SSLPeerUnverifiedException) { return false } return true // The caller's address can be carried by this connection. }
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/internal/connection/ConnectPlan.kt
user.removePlanToCancel(this) if (!success) { rawSocket?.closeQuietly() } } } override fun connectTlsEtc(): ConnectResult { check(rawSocket != null) { "TCP not connected" } check(!isReady) { "already connected" } val connectionSpecs = route.address.connectionSpecs var retryTlsConnection: ConnectPlan? = null var success = false
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
} override fun nanoTime() = nanoTime override fun coordinatorNotify(taskRunner: TaskRunner) { taskRunner.assertThreadHoldsLock() check(waitingCoordinatorTask != null) // Queue a task to resume the waiting coordinator. serialTaskQueue += object : SerialTask { override fun start() {
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) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} currentThread.name = oldName } } private fun afterRun( task: Task, delayNanos: Long, ) { lock.assertHeld() val queue = task.queue!! check(queue.activeTask === task) val cancelActiveTask = queue.cancelActiveTask queue.cancelActiveTask = false queue.activeTask = null busyQueues.remove(queue)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
var connectTlsNextPlan: FakePlan? = null fun createRetry(): FakePlan { check(retry == null) return FakePlan(nextPlanId++) .also { retry = it } } fun createConnectTcpNextPlan(): FakePlan { check(connectTcpNextPlan == null) return FakePlan(nextPlanId++) .also { connectTcpNextPlan = it }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
} // If the call's connection wasn't released, reuse it. We don't call connectionAcquired() here // because we already acquired it. if (connectionUser.candidateConnection() != null) { check(toClose == null) return ReusePlan(candidate) } // The call's connection was released. toClose?.closeQuietly() connectionUser.connectionReleased(candidate)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* Corresponds to `FLAG_FIN`. */ @Throws(IOException::class) fun pushStream( associatedStreamId: Int, requestHeaders: List<Header>, out: Boolean, ): Http2Stream { check(!client) { "Client cannot push requests." } return newStream(associatedStreamId, requestHeaders, out) } /** * Returns a new locally-initiated stream. *
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/http2/Http2Stream.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1)