Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for connectionCount (0.11 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        setPolicy(pool, address, AddressPolicy(2))
        assertThat(pool.connectionCount()).isEqualTo(2)
    
        // Connections are replaced if they idle out or are evicted from the pool
        evictAllConnections(pool)
        assertThat(pool.connectionCount()).isEqualTo(2)
        forceConnectionsToExpire(pool, expireTime)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

        assert200Http2Response(execute(url), server.hostName)
        val sanUrl = url.newBuilder().host("san.com").build()
        assert200Http2Response(execute(sanUrl), "san.com")
        assertThat(client.connectionPool.connectionCount()).isEqualTo(1)
      }
    
      /**
       * Test connecting to an alternative host then common name, although only subject alternative
       * names are used if present no special consideration of common name.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jun 19 11:44:16 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

          connectionPool.evictAll()
          if (connectionPool.connectionCount() > 0) {
            // Minimise test flakiness due to possible race conditions with connections closing.
            // Some number of tests will report here, but not fail due to this delay.
            println("Delaying to avoid flakes")
            Thread.sleep(500L)
            println("After delay: " + connectionPool.connectionCount())
          }
    
          connectionPool.evictAll()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

          }
        }.also { expected ->
          assertEquals(cancelMode == INTERRUPT, Thread.interrupted())
        }
        responseBody.close()
        assertEquals(if (connectionType == H2) 1 else 0, client.connectionPool.connectionCount())
      }
    
      @ParameterizedTest
      @ArgumentsSource(CancelModelParamProvider::class)
      fun cancelAndFollowup(mode: Pair<CancelMode, ConnectionType>) {
        setUp(mode)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

        var connectionPool = ConnectionPool()
        connectionPool = ConnectionPool(0, 0L, TimeUnit.SECONDS)
        val idleConnectionCount: Int = connectionPool.idleConnectionCount()
        val connectionCount: Int = connectionPool.connectionCount()
        connectionPool.evictAll()
      }
    
      @Test
      fun connectionSpec() {
        var connectionSpec: ConnectionSpec = ConnectionSpec.RESTRICTED_TLS
        connectionSpec = ConnectionSpec.MODERN_TLS
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 46.5K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        require(keepAliveDuration > 0L) { "keepAliveDuration <= 0: $keepAliveDuration" }
      }
    
      fun idleConnectionCount(): Int =
        connections.count {
          it.withLock { it.calls.isEmpty() }
        }
    
      fun connectionCount(): Int = connections.size
    
      /**
       * Attempts to acquire a recycled connection to [address] for [connectionUser]. Returns the connection if it
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  7. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

        client.newCall(request).execute().use { response ->
          assertEquals(200, response.code)
        }
    
        client.connectionPool.evictAll()
        assertEquals(0, client.connectionPool.connectionCount())
    
        client.newCall(request).execute().use { response ->
          assertEquals(200, response.code)
        }
    
        assertEquals(2, sessionIds.size)
        assertEquals(sessionIds[0], sessionIds[1])
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 14:12:28 UTC 2025
    - 29K bytes
    - Viewed (0)
Back to top