Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for poll (0.17 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

       * like [poll]. It is only usable within task faker tasks.
       */
      private inner class TaskFakerBlockingQueue<T>(
        val delegate: BlockingQueue<T>,
      ) : AbstractQueue<T>(), BlockingQueue<T> {
        override val size: Int = delegate.size
    
        private var editCount = 0
    
        override fun poll(): T = delegate.poll()
    
        override fun poll(
          timeout: Long,
          unit: TimeUnit,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test causes two connections to become available simultaneously, one from a TCP connect and
       * one from the pool. We must take the pooled connection because by taking it from the pool, we've
       * fully acquired it.
       *
       * This test yields threads to force the decision of plan1 to be deliberate and not lucky. In
       * particular, we set up this sequence of events:
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        // Running at time 75, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(75L)).isEqualTo(75L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
        // Running at time 149, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(149L)).isEqualTo(1L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  4. docs/fr/docs/fastapi-people.md

    * [Aident les autres à résoudre des problèmes (questions) dans GitHub](help-fastapi.md#aider-les-autres-a-resoudre-les-problemes-dans-github){.internal-link target=_blank}.
    * [Créent des Pull Requests](help-fastapi.md#creer-une-pull-request){.internal-link target=_blank}.
    * Review les Pull Requests, [particulièrement important pour les traductions](contributing.md#traductions){.internal-link target=_blank}.
    
    Une salve d'applaudissements pour eux. 👏 🙇
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  5. docs/en/docs/help-fastapi.md

    ## Review Pull Requests
    
    You can help me review pull requests from others.
    
    Again, please try your best to be kind. 🤗
    
    ---
    
    Here's what to keep in mind and how to review a pull request:
    
    ### Understand the problem
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 13.7K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt

        val id: Int,
      ) : RoutePlanner.Plan {
        var planningThrowable: Throwable? = null
        var canceled = false
        var connectState = ConnectState.READY
        val connection =
          factory.newConnection(
            pool = pool,
            route = factory.newRoute(address),
            idleAtNanos = defaultConnectionIdleAtNanos,
          )
        var retry: FakePlan? = null
        var retryTaken = false
        var yieldBeforePlanReturns = false
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      @Throws(IOException::class)
      override fun plan(): Plan {
        val reuseCallConnection = planReuseCallConnection()
        if (reuseCallConnection != null) return reuseCallConnection
    
        // Attempt to get a connection from the pool.
        val pooled1 = planReusePooledConnection()
        if (pooled1 != null) return pooled1
    
        // Attempt a deferred plan before new routes.
        if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  8. .teamcity/src/test/kotlin/PerformanceTestBuildTypeTest.kt

        )
    
        @Test
        fun `create correct PerformanceTest build type for Linux`() {
            val performanceTest = PerformanceTest(
                buildModel,
                Stage(
                    StageName.PULL_REQUEST_FEEDBACK,
                    performanceTests = listOf(PerformanceTestCoverage(1, PerformanceTestType.per_commit, Os.LINUX))
                ),
                PerformanceTestCoverage(1, PerformanceTestType.per_commit, Os.LINUX),
    Plain Text
    - Registered: Wed May 08 11:36:15 GMT 2024
    - Last Modified: Wed Apr 24 08:17:56 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  9. .teamcity/src/main/kotlin/configurations/FlakyTestQuarantine.kt

        val testsWithOs = model.stages.filter {
            it.stageName in listOf(
                StageName.QUICK_FEEDBACK_LINUX_ONLY,
                StageName.QUICK_FEEDBACK,
                StageName.PULL_REQUEST_FEEDBACK,
                StageName.READY_FOR_NIGHTLY,
            )
        }.flatMap { it.functionalTests }.filter { it.os == os }
    
        if (os == Os.LINUX) {
            steps {
                script {
    Plain Text
    - Registered: Wed May 08 11:36:15 GMT 2024
    - Last Modified: Wed Apr 24 08:17:56 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  10. CHANGELOG.md

     *  New: `ConnectionPool.setPolicy()` configures a minimum connection pool size for a target
        address. Use this to proactively open HTTP connections.
    
        Connections opened to fulfill this policy are subject to the connection pool's
        `keepAliveDuration` but do not count against the pool-wide `maxIdleConnections` limit.
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:31:39 GMT 2024
    - 21.4K bytes
    - Viewed (0)
Back to top