Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for becomes (0.19 sec)

  1. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

        }
    
      /**
       * A callback to be invoked each time the dispatcher becomes idle (when the number of running
       * calls returns to zero).
       *
       * Note: The time at which a [call][Call] is considered idle is different depending on whether it
       * was run [asynchronously][Call.enqueue] or [synchronously][Call.execute]. Asynchronous calls
       * become idle after the [onResponse][Callback.onResponse] or [onFailure][Callback.onFailure]
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 9K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/Cookie.kt

                year = matcher.group(1).toInt()
              }
            }
    
            pos = dateCharacterOffset(s, end + 1, limit, false)
          }
    
          // Convert two-digit years into four-digit years. 99 becomes 1999, 15 becomes 2015.
          if (year in 70..99) year += 1900
          if (year in 0..69) year += 2000
    
          // If any partial is omitted or out of range, return -1. The date is impossible. Note that leap
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:12:05 GMT 2024
    - 23.1K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallTest.kt

       */
      @Test
      fun anonCipherSuiteUnsupported() {
        platform.assumeNotConscrypt()
        platform.assumeNotBouncyCastle()
    
        // The _anon_ suites became unsupported in "1.8.0_201" and "11.0.2".
        assumeFalse(
          System.getProperty("java.version", "unknown").matches(Regex("1\\.8\\.0_1\\d\\d")),
        )
        server.enqueue(MockResponse())
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

              if (minDelayNanos < coordinatorWakeUpAt - now) {
                backend.coordinatorNotify(this@TaskRunner)
              }
              return null
            }
    
            // No other thread is coordinating. Become the coordinator!
            else -> {
              coordinatorWaiting = true
              coordinatorWakeUpAt = now + minDelayNanos
              try {
                backend.coordinatorWait(this@TaskRunner, minDelayNanos)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        connections.add(connection)
    //    connection.queueEvent { connectionListener.connectEnd(connection) }
        scheduleCloser()
      }
    
      /**
       * Notify this pool that [connection] has become idle. Returns true if the connection has been
       * removed from the pool and should be closed.
       */
      fun connectionBecameIdle(connection: RealConnection): Boolean {
        connection.lock.assertHeld()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        Thread.sleep(TimeUnit.NANOSECONDS.toMillis(Http2Connection.DEGRADED_PONG_TIMEOUT_NS.toLong()))
        assertThat(connection.isHealthy(System.nanoTime())).isFalse()
    
        // When a pong does arrive, the connection becomes healthy again.
        connection.writePingAndAwaitPong()
        assertThat(connection.isHealthy(System.nanoTime())).isTrue()
    
        // Verify the peer received what was expected.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 75.4K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.advanceUntil(800.ms)
        assertEvents(
          "plan 3 TCP connect canceled",
        )
    
        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.
       *
    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)
Back to top