- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for timeoutNanos (0.05 sec)
-
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 {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K bytes - Viewed (0) -
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); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.2K bytes - Viewed (0) -
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 Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.2K bytes - Viewed (0) -
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
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 10.6K bytes - Viewed (0) -
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;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
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;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/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 Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.9K bytes - Viewed (0)