Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for acquireConnectionNoEvents (0.15 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        withLock {
          this.requestBodyOpen = true
          this.responseBodyOpen = true
        }
    
        if (canceled) throw IOException("Canceled")
        return result
      }
    
      fun acquireConnectionNoEvents(connection: RealConnection) {
        connection.assertLockHeld()
    
        check(this.connection == null)
        this.connection = connection
        connection.calls.add(CallReference(this, callStackTrace))
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

            .build()
        val call = client.newCall(Request(addressA.url)) as RealCall
        call.enterNetworkInterceptorExchange(call.request(), true, factory.newChain(call))
        c1.withLock { call.acquireConnectionNoEvents(c1) }
    
        // Running at time 50, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(50L)).isEqualTo(100L)
        assertThat(pool.connectionCount()).isEqualTo(1)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

                  false
                }
    
                !connection.isEligible(address, routes) -> {
                  false
                }
    
                else -> {
                  call.acquireConnectionNoEvents(connection)
                  true
                }
              }
            }
          if (!acquired) continue
    
          // Confirm the connection is healthy and return it.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 11.1K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

        val pooled3 = routePlanner.planReusePooledConnection(this, routes)
        if (pooled3 != null) return pooled3.connection
    
        connection.withLock {
          connectionPool.put(connection)
          call.acquireConnectionNoEvents(connection)
        }
    
        call.eventListener.connectionAcquired(call, connection)
        connection.connectionListener.connectionAcquired(connection, call)
        return connection
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
Back to Top