- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for torrent (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
private var sourcePos = 0L /** * Selects where to find the bytes for a read and read them. This is one of three sources. * * ## Upstream * * In this case the current thread is assigned as the upstream reader. We read bytes from * upstream and copy them to both the file and to the buffer. Finally we release the upstream * reader lock and return the new bytes. *
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) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
* ``` */ BODY, } fun interface Logger { fun log(message: String) companion object { /** A [Logger] defaults output appropriate for the current platform. */ @JvmField val DEFAULT: Logger = DefaultLogger() private class DefaultLogger : Logger { override fun log(message: String) { Platform.get().log(message)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
*/ fun timeoutEarlyExit() { check(!timeoutEarlyExit) timeoutEarlyExit = true timeout.exit() } /** * @param closeExchange true if the current exchange should be closed because it will not be used. * This is usually due to either an exception or a retry. */ internal fun exitNetworkInterceptorExchange(closeExchange: Boolean) { this.withLock {
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
expected. * New: Constant string `okhttp3.VERSION`. This is a string like "4.5.0-RC1", "4.5.0", or "4.6.0-SNAPSHOT" indicating the version of OkHttp in the current runtime. Use this to include the OkHttp version in custom `User-Agent` headers. * Fix: Don't crash when running as a plugin in Android Studio Canary 4.1. To enable
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/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/ResponseBody.kt
* * This class may be used to stream very large responses. For example, it is possible to use this * class to read a response that is larger than the entire memory allocated to the current process. * It can even stream a response larger than the total storage on the current device, which is a * common requirement for video streaming applications. * * Because this class does not buffer the full response in memory, the application may not
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
tasksExecutor.execute { taskRunner.assertThreadDoesntHoldLock() require(currentTask == this) try { runnable.run() require(currentTask == this) { "unexpected current task: $currentTask" } } finally { taskRunner.lock.withLock { activeThreads-- startNextTask() } } } } } /**
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/Cookie.kt
* This is December 31, 9999 if the cookie is not [persistent], in which case it will expire at the * end of the current session. * * This may return a value less than the current time, in which case the cookie is already * expired. Webservers may return expired cookies as a mechanism to delete previously set cookies * that may or may not themselves be expired. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:12:05 GMT 2024 - 23.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
connectionUser = connectionUser, fastFallback = fastFallback, ) routeSelector = newRouteSelector } // List available IP addresses for the current proxy. This may block in Dns.lookup(). if (!newRouteSelector.hasNext()) throw IOException("exhausted all routes") val newRouteSelection = newRouteSelector.next() routeSelection = newRouteSelection
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)