Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 153 for limiter (0.03 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(Integer.MAX_VALUE / 4);
        limiter.acquire(Integer.MAX_VALUE / 2);
        limiter.acquire(Integer.MAX_VALUE);
        assertEvents("R0.00", "R0.00", "R0.00");
    
        limiter.setRate(1.0);
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        assertEvents("R0.00", "R1.00", "R1.00");
    
    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

        limiter.acquire(Integer.MAX_VALUE / 4);
        limiter.acquire(Integer.MAX_VALUE / 2);
        limiter.acquire(Integer.MAX_VALUE);
        assertEvents("R0.00", "R0.00", "R0.00");
    
        limiter.setRate(1.0);
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        assertEvents("R0.00", "R1.00", "R1.00");
    
    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. src/main/java/jcifs/util/AuthenticationRateLimiter.java

         * @return true if attempt is allowed, false if rate limited
         * @throws SmbException if account is locked out
         */
        public boolean checkAttempt(String username, String sourceIp) throws SmbException {
            if (closed.get()) {
                throw new IllegalStateException("Rate limiter is closed");
            }
    
            // Check global rate limit
            if (!checkGlobalRateLimit()) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  4. src/test/java/jcifs/util/AuthenticationRateLimiterTest.java

                // The rate limiter should still be functional after concurrent access
                assertTrue(concurrentLimiter.checkAttempt("finaluser", "192.168.3.1"),
                        "Rate limiter should still be functional after concurrent operations");
    
                // Verify that the rate limiter tracked some activity
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * acquire(10) request arriving. We serve the request partly from storedPermits, using all the
       * remaining 7.0 permits, and the remaining 3.0, we serve them by fresh permits produced by the
       * rate limiter.
       *
       * We already know how much time it takes to serve 3 fresh permits: if the rate is
       * "1 token per second", then this will take 3 seconds. But what does it mean to serve 7 stored
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.2.md

    issues with Docker 1.9.1 can be found below.
      * CPU hardcapping will be enabled by default for containers with CPU limit set,
    if supported by the kernel. You should either adjust your CPU limit, or set CPU
    request only, if you want to avoid hardcapping. If the kernel does not support
    CPU Quota, NodeStatus will contain a warning indicating that CPU Limits cannot
    be enforced.
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Fri Dec 04 06:36:19 UTC 2020
    - 41.4K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HostnamesCommon.kt

      input: String,
      pos: Int,
      limit: Int,
    ): ByteArray? {
      val address = ByteArray(16)
      var b = 0
      var compress = -1
      var groupOffset = -1
    
      var i = pos
      while (i < limit) {
        if (b == address.size) return null // Too many groups.
    
        // Read a delimiter.
        if (i + 2 <= limit && input.startsWith("::", startIndex = i)) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 11.2K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CsvExtractor.java

         */
        public void setMaxRows(final int maxRows) {
            this.maxRows = maxRows;
        }
    
        /**
         * Sets the delimiter character.
         *
         * @param delimiter the delimiter
         */
        public void setDelimiter(final Character delimiter) {
            this.delimiter = delimiter;
        }
    
        /**
         * Sets whether the first row contains headers.
         *
         * @param hasHeader true if has header
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMultipartRequestHandler.java

            br.addElement("Against for CVE-2014-0050 (JVN14876762).");
            br.addElement("Boundary size is limited by Framework.");
            br.addElement("Too long boundary is treated as 404 because it's thought of as attack.");
            br.addElement("");
            br.addElement("While, you can override the boundary limit size");
            br.addElement(" in " + getClass().getSimpleName() + ".");
            br.addItem("Content Type");
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 18.6K bytes
    - Viewed (1)
  10. src/main/java/jcifs/internal/smb2/Smb2EncryptionContext.java

        }
    
        /**
         * Set the key rotation bytes limit
         *
         * @param limit number of bytes to encrypt before rotating keys
         */
        public void setKeyRotationBytesLimit(long limit) {
            this.keyRotationBytesLimit = limit;
        }
    
        /**
         * Set the key rotation time limit
         *
         * @param limit time in milliseconds before rotating keys
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 35.5K bytes
    - Viewed (0)
Back to top