- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for Done (0.12 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
lock.assertHeld() // If this connection is not accepting new exchanges, we're done. if (calls.size >= allocationLimit || noNewExchanges) return false // If the non-host fields of the address don't overlap, we're done. if (!this.route.address.equalsNonHost(address)) return false // If the host exactly matches, we're done: this connection can carry the address.
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/internal/http2/MockHttp2Peer.kt
port = serverSocket!!.localPort executor.execute { try { readAndWriteFrames() } catch (e: IOException) { ******@****.***uietly() logger.info("${this@MockHttp2Peer} done: ${e.message}") } } } private fun readAndWriteFrames() { check(socket == null) val socket = serverSocket!!.accept()!! this.socket = socket
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
* Fix: Change HTTP/2 to use a daemon thread for its socket reader. If you've ever seen a command line application hang after all of the work is done, it may be due to a non-daemon thread like this one. * New: Include suppressed exceptions when all routes to a target service fail. ## Version 4.4.1 _2020-03-08_
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
private val body: Sink var done = false init { this.body = object : ForwardingSink(cacheOut) { @Throws(IOException::class) override fun close() { synchronized(this@Cache) { if (done) return done = true writeSuccessCount++ } super.close()
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/ConnectionPool.kt
maxIdleConnections: Int = 5, keepAliveDuration: Long = 5, timeUnit: TimeUnit = TimeUnit.MINUTES, taskRunner: TaskRunner = TaskRunner.INSTANCE, connectionListener: ConnectionListener = ConnectionListener.NONE, readTimeoutMillis: Int = 10_000, writeTimeoutMillis: Int = 10_000, socketConnectTimeoutMillis: Int = 10_000, socketReadTimeoutMillis: Int = 10_000, pingIntervalMillis: Int = 10_000,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
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/idn/Punycode.kt
// order, not in increasing index order. val codePoints = mutableListOf<Int>() // consume all code points before the last delimiter (if there is one) // and copy them to output, fail on any non-basic code point val lastDelimiter = string.lastIndexOf('-', limit) if (lastDelimiter >= pos) { while (pos < lastDelimiter) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 03:04:50 GMT 2024 - 8.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
val networkRequest = strategy.networkRequest val cacheResponse = strategy.cacheResponse cache?.trackResponse(strategy) val listener = (call as? RealCall)?.eventListener ?: EventListener.NONE if (cacheCandidate != null && cacheResponse == null) { // The cache candidate wasn't applicable. Close it. cacheCandidate.body.closeQuietly() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
while (true) { val socket = serverSocket!!.accept() connectionCount.incrementAndGet() service(socket) } } catch (e: SocketException) { logger.info("$threadName done accepting connections: ${e.message}") } catch (e: IOException) { logger.log(Level.WARNING, "$threadName failed unexpectedly", e) } finally { for (socket in openSockets) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
val toEvictIdleAtNs: Long when { // We had at least one OLD connection. Close the oldest one. earliestOldConnection != null -> { toEvict = earliestOldConnection toEvictIdleAtNs = earliestOldIdleAtNs } // We have too many EVICTABLE connections. Close the oldest one. evictableConnectionCount > maxIdleConnections -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0)