Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 349 for reached (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top