Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for healthy (0.15 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

        }
    
        val http2Connection = this.http2Connection
        if (http2Connection != null) {
          return http2Connection.isHealthy(nowNs)
        }
    
        val idleDurationNs = lock.withLock { nowNs - idleAtNs }
        if (idleDurationNs >= IDLE_CONNECTION_HEALTHY_NS && doExtensiveChecks) {
          return socket.isHealthy(source)
        }
    
        return true
      }
    
      /** Refuse incoming streams. */
      @Throws(IOException::class)
    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)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        // Make sure this connection is healthy & eligible for new exchanges. If it's no longer needed
        // then we're on the hook to close it.
        val healthy = candidate.isHealthy(connectionUser.doExtensiveHealthChecks())
        var noNewExchangesEvent = false
        val toClose: Socket? =
          candidate.withLock {
            when {
              !healthy -> {
                noNewExchangesEvent = !candidate.noNewExchanges
    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)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

                  true
                }
              }
            }
          if (!acquired) continue
    
          // Confirm the connection is healthy and return it.
          if (connection.isHealthy(doExtensiveHealthChecks)) return connection
    
          // In the second synchronized block, release the unhealthy acquired connection. We're also on
          // the hook to close this connection if it's no longer in use.
          val noNewExchangesEvent: Boolean
    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)
  4. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

        }.also { expected ->
          assertThat(expected).hasMessage("timeout")
        }
      }
    
      /**
       * This test reproduces a crash where OkHttp attempted to use a deferred connection when the call
       * already had a healthy connection. It sets up a deferred connection by stalling the IPv6
       * connect, and it sets up a same-connection retry with [ErrorCode.REFUSED_STREAM].
       *
       * https://github.com/square/okhttp/pull/7190
       */
      @Test
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  5. docs/changelogs/changelog_4x.md

        `okhttp-tls` module.
    
     *  Upgrade: [Kotlin 1.3.71][kotlin_1_3_71].
    
    
    ## Version 4.5.0
    
    _2020-04-06_
    
    **This release fixes a severe bug where OkHttp incorrectly detected and recovered from unhealthy
    connections.** Stale or canceled connections were incorrectly attempted when they shouldn't have
    been, leading to rare cases of infinite retries. Please upgrade to this release!
    
    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)
  6. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

     *
     * Unfortunately Java's networking APIs don't offer a good health check, so we go on our own by
     * attempting to read with a short timeout. If the fails immediately we know the socket is
     * unhealthy.
     *
     * @param source the source used to read bytes from the socket.
     */
    internal fun Socket.isHealthy(source: BufferedSource): Boolean {
      return try {
        val readTimeout = soTimeout
        try {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

        assert200Http2Response(execute(url), server.hostName)
        assertThat(client.connectionPool.connectionCount()).isEqualTo(1)
      }
    
      /** Test a previously coalesced connection that's no longer healthy.  */
      @Test
      fun staleCoalescedConnection() {
        server.enqueue(MockResponse())
        server.enqueue(MockResponse())
        val connection = AtomicReference<Connection?>()
        client =
          client.newBuilder()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      private var degradedPingsSent = 0L
      private var degradedPongsReceived = 0L
      private var awaitPingsSent = 0L
      private var awaitPongsReceived = 0L
    
      /** Consider this connection to be unhealthy if a degraded pong isn't received by this time. */
      private var degradedPongDeadlineNs = 0L
    
      internal val flowControlListener: FlowControlListener = builder.flowControlListener
    
    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)
  9. docs/changelogs/changelog_2x.md

        need them to handle redirects.
    
    
    ## Version 2.7.1
    
    _2016-01-01_
    
     *  Fix: Don't do a health check on newly-created connections. This is
        unnecessary work that could put the client in an inconsistent state if the
        health check fails.
    
    
    ## Version 2.7.0
    
    _2015-12-13_
    
     *  **Rewritten connection management.** Previously OkHttp's connection pool
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 26.6K bytes
    - Viewed (0)
  10. okhttp/src/main/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.gz

    hasvik.no hatogaya.saitama.jp hatoyama.saitama.jp hatsukaichi.hiroshima.jp hattfjelldal.no haugesund.no haus hawaii.museum hayakawa.yamanashi.jp hayashima.okayama.jp hazu.aichi.jp hb.cldmail.ru hb.cn hbo hdfc hdfcbank he.cn health health-carereform.com health.museum health.nz health.vn healthcare heavy.jp heguri.nara.jp heimatunduhren.museum hekinan.aichi.jp hellas.museum help helsinki helsinki.museum hembygdsforbund.museum hemne.no hemnes.no hemsedal.no hepforge.org her.jp herad.no here here-for-more.info...
    Others
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 40.4K bytes
    - Viewed (0)
Back to top