Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 68 for plans (0.01 sec)

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

        if (nextPlanIndex >= plans.size && autoGeneratePlans) addPlan()
    
        require(nextPlanIndex < plans.size) {
          "not enough plans! call addPlan() or set autoGeneratePlans=true in the test to set this up"
        }
        val result = plans[nextPlanIndex++]
        events += "take plan ${result.id}"
    
        if (result.yieldBeforePlanReturns) {
          taskFaker.yield()
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     */
    interface RoutePlanner {
      val address: Address
    
      /** Follow-ups for failed plans and plans that lost a race. */
      val deferredPlans: ArrayDeque<Plan>
    
      fun isCanceled(): Boolean
    
      /** Returns a plan to attempt. */
      @Throws(IOException::class)
      fun plan(): Plan
    
      /**
       * Returns true if there's more route plans to try.
       *
    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/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

        if (plan is FailedPlan) return plan.result
    
        // Connect TCP asynchronously.
        tcpConnectsInFlight += plan
        val taskName = "$okHttpName connect ${routePlanner.address.url.redact()}"
        taskRunner.newQueue().schedule(
          object : Task(taskName) {
            override fun runOnce(): Long {
              val connectResult =
                try {
                  plan.connectTcp()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. README.md

        period. The last release to remove non-`@Beta` APIs was Guava 21.0.) Even
        `@Deprecated` APIs will remain (again, unless they are `@Beta`). We have no
        plans to start removing things again, but officially, we're leaving our
        options open in case of surprises (like, say, a serious security problem).
    
    3.  Guava has one dependency that is needed for linkage at runtime:
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Aug 05 15:30:14 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        plan0.tcpConnectDelayNanos = 280.ms
    
        val plan1 = routePlanner.addPlan()
        plan1.tcpConnectDelayNanos = 10.ms // Connect at time = 260 ms.
        plan1.tlsConnectDelayNanos = 10.ms // Connect at time = 270 ms.
        plan1.tlsConnectThrowable = IOException("boom!")
    
        val plan2 = plan1.createConnectTlsNextPlan()
        plan2.tcpConnectDelayNanos = 270.ms // Connect at time = 540 ms.
    
        val plan3 = plan0.createRetry()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      private var routeSelector: RouteSelector? = null
      private var nextRouteToTry: Route? = null
    
      override val deferredPlans = ArrayDeque<Plan>()
    
      override fun isCanceled(): Boolean = connectionUser.isCanceled()
    
      @Throws(IOException::class)
      override fun plan(): Plan {
        val reuseCallConnection = planReuseCallConnection()
        if (reuseCallConnection != null) return reuseCallConnection
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 12K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        routePlanner.defaultConnectionIdleAtNanos = expireSooner
    
        // Turn it into an http/2 connection that supports 5 concurrent streams
        // which can satisfy a larger policy
        val connection = routePlanner.plans.first().connection
        val http2Connection = connectHttp2(peer, connection, 5)
        setPolicy(pool, address, AddressPolicy(5))
        assertThat(pool.connectionCount()).isEqualTo(1)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  8. docs/es/docs/tutorial/background-tasks.md

    {* ../../docs_src/background_tasks/tutorial002_an_py310.py hl[13,15,22,25] *}
    
    En este ejemplo, los mensajes se escribirán en el archivo `log.txt` *después* de que se envíe el response.
    
    Si hay un query en el request, se escribirá en el log en una tarea en segundo plano.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  9. docs/pt/docs/tutorial/background-tasks.md

    {* ../../docs_src/background_tasks/tutorial002.py hl[13,15,22,25] *}
    
    Neste exemplo, as mensagens serão gravadas no arquivo `log.txt` _após_ o envio da resposta.
    
    Se houver uma consulta na solicitação, ela será gravada no log em uma tarefa em segundo plano.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Nov 10 17:23:38 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  10. docs/fr/docs/tutorial/background-tasks.md

    {* ../../docs_src/background_tasks/tutorial002.py hl[13,15,22,25] *}
    
    Dans cet exemple, les messages seront écrits dans le fichier `log.txt` après que la réponse soit envoyée.
    
    S'il y avait une `query` (paramètre nommé `q`) dans la requête, alors elle sera écrite dans `log.txt` via une tâche d'arrière-plan.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Nov 10 17:23:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
Back to top