- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for closeConnections (0.06 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
private val cleanupQueue: TaskQueue = taskRunner.newQueue() private val cleanupTask = object : Task("$okHttpName ConnectionPool connection closer") { override fun runOnce(): Long = closeConnections(System.nanoTime()) } /** * Holding the lock of the connection being added or removed when mutating this, and check its
Created: 2026-04-03 11:42 - Last Modified: 2026-01-27 09:00 - 11.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(pool.closeConnections(50L)).isEqualTo(100L) assertThat(pool.connectionCount()).isEqualTo(1) assertThat(c1.socket().isClosed).isFalse() // Running at time 60, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(60L)).isEqualTo(90L) assertThat(pool.connectionCount()).isEqualTo(1)
Created: 2026-04-03 11:42 - Last Modified: 2025-10-07 21:55 - 8.2K bytes - Click Count (0) -
compat/maven-compat/src/test/java/org/apache/maven/repository/legacy/StringWagon.java
this.expectedContent.put(resourceName, expectedContent); } public String[] getSupportedProtocols() { return new String[] {"string"}; } @Override public void closeConnection() throws ConnectionException {} @Override public void fillInputData(InputData inputData) throws TransferFailedException, ResourceDoesNotExistException, AuthorizationException {
Created: 2026-04-05 03:35 - Last Modified: 2024-10-25 12:31 - 3K bytes - Click Count (0)