Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 10 for ConnectionAcquired (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt

        assertThat(clientTestRule.recordedConnectionEventTypes()).containsExactly(
          "ConnectStart",
          "ConnectEnd",
          "ConnectionAcquired",
          "NoNewExchanges",
          "ConnectionReleased",
          "ConnectionClosed",
          "ConnectStart",
          "ConnectEnd",
          "ConnectionAcquired",
          "ConnectionReleased",
        )
      }
    
      @RepeatedTest(100)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jan 10 15:25:06 GMT 2026
    - 11.8K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * to the [Call.request] is a redirect to a different address.
       */
      open fun connectionAcquired(
        call: Call,
        connection: Connection,
      ) {
      }
    
      /**
       * Invoked after a connection has been released for the `call`.
       *
       * This method is always invoked after [connectionAcquired].
       *
       * This can be invoked more than 1 time for a single [Call]. For example, if the response to the
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  3. android-test/src/androidDeviceTest/java/okhttp/android/test/OkHttpTest.kt

    import okhttp3.Cache
    import okhttp3.Call
    import okhttp3.CallEvent.CallEnd
    import okhttp3.CallEvent.CallStart
    import okhttp3.CallEvent.ConnectEnd
    import okhttp3.CallEvent.ConnectStart
    import okhttp3.CallEvent.ConnectionAcquired
    import okhttp3.CallEvent.ConnectionReleased
    import okhttp3.CallEvent.DnsEnd
    import okhttp3.CallEvent.DnsStart
    import okhttp3.CallEvent.FollowUpDecision
    import okhttp3.CallEvent.ProxySelectEnd
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 29.9K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt

    import mockwebserver3.junit5.StartStop
    import okhttp3.CallEvent.CallEnd
    import okhttp3.CallEvent.CallStart
    import okhttp3.CallEvent.ConnectEnd
    import okhttp3.CallEvent.ConnectStart
    import okhttp3.CallEvent.ConnectionAcquired
    import okhttp3.CallEvent.ConnectionReleased
    import okhttp3.CallEvent.DnsEnd
    import okhttp3.CallEvent.DnsStart
    import okhttp3.CallEvent.FollowUpDecision
    import okhttp3.CallEvent.ProxySelectEnd
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 11:54:15 GMT 2026
    - 10.7K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

                latch1.await()
              } catch (e: InterruptedException) {
                throw AssertionError(e)
              }
            }
    
            override fun connectionAcquired(
              call: Call,
              connection: Connection,
            ) {
              // We have the connection and it's in the pool. Let request2 proceed to make a connection.
              latch2.countDown()
            }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jun 19 11:44:16 GMT 2025
    - 19.1K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        if (planToReplace != null) {
          nextRouteToTry = planToReplace.route
          planToReplace.closeQuietly()
        }
    
        call.eventListener.connectionAcquired(call, result)
        result.connectionListener.connectionAcquired(result, call)
        return ReusePlan(result)
      }
    
      /** Returns a plan for the first attempt at [route]. This throws if no plan is possible. */
      @Throws(IOException::class)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  7. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

          logger.removeHandler(loggerHandler)
        }
    
        override fun callEnd(call: Call) {
          // Cleanup log handler if failed.
          logger.removeHandler(loggerHandler)
        }
    
        override fun connectionAcquired(
          call: Call,
          connection: Connection,
        ) {
          if (random != null) {
            val sslSocket = connection.socket() as SSLSocket
            val session = sslSocket.session
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.9K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

    import mockwebserver3.junit5.StartStop
    import okhttp3.CallEvent.CallEnd
    import okhttp3.CallEvent.CallStart
    import okhttp3.CallEvent.ConnectEnd
    import okhttp3.CallEvent.ConnectStart
    import okhttp3.CallEvent.ConnectionAcquired
    import okhttp3.CallEvent.ConnectionReleased
    import okhttp3.CallEvent.DnsEnd
    import okhttp3.CallEvent.DnsStart
    import okhttp3.CallEvent.FollowUpDecision
    import okhttp3.CallEvent.ProxySelectEnd
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt

        }
    
        // Observed Events are variable
        // JDK 14
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
        // SecureConnectEnd, ConnectEnd, ConnectionAcquired, RequestHeadersStart, RequestHeadersEnd,
        // ResponseFailed, ConnectionReleased, CallFailed
        // JDK 8
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 13K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

        connection.withLock {
          connectionPool.put(connection)
          call.acquireConnectionNoEvents(connection)
        }
    
        call.eventListener.connectionAcquired(call, connection)
        connection.connectionListener.connectionAcquired(connection, call)
        return connection
      }
    
      override fun trackFailure(
        call: RealCall,
        e: IOException?,
      ) {
        // Do nothing.
      }
    
    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