- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 349 for reached (0.05 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertThat(limiter.acquire()).isWithin(EPSILON).of(0.2); } public void testOneSecondBurst() { RateLimiter limiter = RateLimiter.create(5.0, stopwatch); stopwatch.sleepMillis(1000); // max capacity reached stopwatch.sleepMillis(1000); // this makes no difference limiter.acquire(1); // R0.00, since it's the first request limiter.acquire(1); // R0.00, from capacity limiter.acquire(3); // R0.00, from capacity
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertThat(limiter.acquire()).isWithin(EPSILON).of(0.2); } public void testOneSecondBurst() { RateLimiter limiter = RateLimiter.create(5.0, stopwatch); stopwatch.sleepMillis(1000); // max capacity reached stopwatch.sleepMillis(1000); // this makes no difference limiter.acquire(1); // R0.00, since it's the first request limiter.acquire(1); // R0.00, from capacity limiter.acquire(3); // R0.00, from capacity
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 21.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
Thread.currentThread().interrupt() // Retain interrupted status. throw InterruptedIOException() } } /** * The Okio timeout watchdog will call [timedOut] if the timeout is reached. In that case we close * the stream (asynchronously) which will notify the waiting thread. */ internal inner class StreamTimeout : AsyncTimeout() { override fun timedOut() { closeLater(ErrorCode.CANCEL)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 22.4K bytes - Viewed (0) -
cmd/erasure-metadata.go
return 0, 0, nil } partOffset = offset // Seek until object offset maps to a particular part offset. for i, part := range fi.Parts { partIndex = i // Offset is smaller than size we have reached the proper part offset. if partOffset < part.Size { return partIndex, partOffset, nil } // Continue to towards the next part. partOffset -= part.Size } internalLogIf(ctx, InvalidRange{})Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 21.3K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Ascii.java
/** * Shift Out: A control character indicating that the code combinations which follow shall be * interpreted as outside of the character set of the standard code table until a Shift In * character is reached. * * @since 8.0 */ public static final byte SO = 14; /** * Shift In: A control character indicating that the code combinations which follow shall be
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 21.7K bytes - Viewed (0) -
docs/smb3-features/02-persistent-handles-design.md
```java public enum HandleBreakReason { NETWORK_FAILURE, // Network connection lost SESSION_EXPIRED, // Session timeout SERVER_REBOOT, // Server restart HANDLE_EXPIRED, // Handle timeout reached LEASE_BREAK, // Associated lease broken EXPLICIT_CLOSE // User closed handle } public class HandleBreakHandler { public void handleBreak(HandleInfo handle, HandleBreakReason reason) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 31.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
// healing traversal may be mutating on-disk data when an external // quit signal is received, this routine cannot quit immediately and // has to wait until a safe point is reached, such as between scanning // two objects. func (h *healSequence) traverseAndHeal(objAPI ObjectLayer) { h.traverseAndHealDoneCh <- h.healItems(objAPI) xioutil.SafeClose(h.traverseAndHealDoneCh) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/props/MavenProperties.java
* name and value in internal fields. These fields can be obtained using * the provided getter methods. The return value indicates whether EOF * was reached (<b>false</b>) or whether further properties are * available (<b>true</b>). * * @return a flag if further properties are available * @throws IOException if an error occurs */Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Oct 16 09:03:48 UTC 2025 - 38.5K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java
* name and value in internal fields. These fields can be obtained using * the provided getter methods. The return value indicates whether EOF * was reached (<b>false</b>) or whether further properties are * available (<b>true</b>). * * @return a flag if further properties are available * @throws IOException if an error occurs */Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jul 23 17:27:08 UTC 2025 - 38.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
final String eolLink = fessConfig.getOnlineHelpEol(); runtime.registerData("eolLink", getHelpUrl(eolLink)); } } /** * Checks if the application has reached its end-of-life. * * @return true if the application is EOL, false otherwise. */ protected boolean isEoled() { return getCurrentTimeAsLong() > eolTime; } /**
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 08:30:43 UTC 2025 - 36.6K bytes - Viewed (0)