Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for timeoutNanos (0.3 seconds)

  1. android/guava/src/com/google/common/util/concurrent/Monitor.java

        long timeoutNanos = unit.toNanos(time);
        return Longs.constrainToRange(timeoutNanos, 0L, (Long.MAX_VALUE / 4) * 3);
      }
    
      /**
       * Returns System.nanoTime() unless the timeout has already elapsed. Returns 0L if and only if the
       * timeout has already elapsed.
       */
      private static long initNanoTime(long timeoutNanos) {
        if (timeoutNanos <= 0L) {
          return 0L;
        } else {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 43.5K bytes
    - Click Count (0)
  2. android/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);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 4.2K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

      private fun readHeader() {
        if (receivedCloseFrame) 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)
        }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

        // NOTE: if timeout < 0, remainingNanos will be < 0 and we will fall into the while(true) loop
        // at the bottom and throw a timeoutexception.
        long timeoutNanos = unit.toNanos(timeout); // we rely on the implicit null check on unit.
        long remainingNanos = timeoutNanos;
        if (Thread.interrupted()) {
          throw new InterruptedException();
        }
        @RetainedLocalRef Object localValue = valueField;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

              } else if (active == 0) {
                break;
              } else if (timed) {
                f = futureQueue.poll(timeoutNanos, NANOSECONDS);
                if (f == null) {
                  throw new TimeoutException();
                }
                long now = System.nanoTime();
                timeoutNanos -= now - lastTime;
                lastTime = now;
              } else {
                f = futureQueue.take();
              }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 45.6K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorOverridesTest.kt

                override fun contentType(): MediaType? = null
    
                override fun writeTo(sink: BufferedSink) {
                  if (sink
                      .timeout()
                      .timeoutNanos()
                      .nanoseconds.inWholeMilliseconds == 10L
                  ) {
                    throw IOException()
                  }
                }
              }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 11 02:37:00 GMT 2026
    - 28.8K bytes
    - Click Count (0)
Back to Top