Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for timeoutNanos (0.07 sec)

  1. guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

          throws TimeoutException, InterruptedException, ExecutionException {
    
        long timeoutNanos = unit.toNanos(timeout);
        if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) {
          return super.get(timeout, unit);
        }
        // Waiting 68 years should be enough for any program.
        return super.get(
            min(timeoutNanos, OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD), NANOSECONDS);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

      }
    
      @Test
      fun defaultConfigIsNoTimeout() {
        val request =
          Request.Builder()
            .url(server.url("/"))
            .build()
        val call = client.newCall(request)
        assertThat(call.timeout().timeoutNanos()).isEqualTo(0)
      }
    
      @Test
      fun configureClientDefault() {
        val request =
          Request.Builder()
            .url(server.url("/"))
            .build()
        val timeoutClient =
          client.newBuilder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/MoreExecutors.java

              } else if (active == 0) {
                break;
              } else if (timed) {
                f = futureQueue.poll(timeoutNanos, TimeUnit.NANOSECONDS);
                if (f == null) {
                  throw new TimeoutException();
                }
                long now = System.nanoTime();
                timeoutNanos -= now - lastTime;
                lastTime = now;
              } else {
                f = futureQueue.take();
              }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

      private fun readHeader() {
        if (closed) throw IOException("closed")
    
        // Disable the timeout to read the first byte of a new frame.
        val b0: Int
        val timeoutBefore = source.timeout().timeoutNanos()
        source.timeout().clearTimeout()
        try {
          b0 = source.readByte() and 0xff
        } finally {
          source.timeout().timeout(timeoutBefore, TimeUnit.NANOSECONDS)
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
Back to top