Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for connectTcp (0.99 sec)

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

     */
    internal class FailedPlan(
      e: Throwable,
    ) : RoutePlanner.Plan {
      val result = RoutePlanner.ConnectResult(plan = this, throwable = e)
    
      override val isReady = false
    
      override fun connectTcp() = result
    
      override fun connectTlsEtc() = result
    
      override fun handleSuccess() = error("unexpected call")
    
      override fun cancel() = error("unexpected cancel")
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

      /**
       * A plan holds either an immediately-usable connection, or one that must be connected first.
       * These steps are split so callers can call [connectTcp] on a background thread if attempting
       * multiple plans concurrently.
       */
      interface Plan {
        val isReady: Boolean
    
        fun connectTcp(): ConnectResult
    
        fun connectTlsEtc(): ConnectResult
    
        fun handleSuccess(): RealConnection
    
        fun cancel()
    
        /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt

          check(connectTlsNextPlan == null)
          return FakePlan(nextPlanId++)
            .also {
              connectTlsNextPlan = it
            }
        }
    
        override fun connectTcp(): ConnectResult {
          check(connectState == ConnectState.READY)
          events += "plan $id TCP connecting..."
    
          taskFaker.sleep(tcpConnectDelayNanos)
    
          if (yieldBeforeTcpConnectReturns) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

          routes = routes,
          attempt = attempt,
          tunnelRequest = tunnelRequest,
          connectionSpecIndex = connectionSpecIndex,
          isTlsFallback = isTlsFallback,
        )
    
      override fun connectTcp(): ConnectResult {
        check(rawSocket == null) { "TCP already connected" }
    
        var success = false
    
        // Tell the call about the connecting call so async cancels work.
        user.addPlanToCancel(this)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
Back to top