Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 213 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. docs/fr/README.md

    bs.org/15.3/admin/fileconfig-guide.html), ou un [Data Store](https://fess.codelibs.org/15.3/admin/dataconfig-guide.html) (comme un fichier CSV ou une base de données). De nombreux formats de fichiers sont pris en charge, y compris (mais sans s'y limiter) : Microsoft Office, PDF, et zip.
    
    *[Fess Site Search](https://github.com/codelibs/fess-site-search)* est une alternative gratuite à [Google Site Search](https://enterprise.google.com/search/products/gss.html). Pour plus de détails, consultez...
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Tue Nov 11 22:42:32 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  6. 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)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/Punycode.kt

       * integer overflow. This will not return null for labels that fit within the DNS size
       * limits.
       */
      fun encode(string: String): String? {
        var pos = 0
        val limit = string.length
        val result = Buffer()
    
        while (pos < limit) {
          var dot = string.indexOf('.', startIndex = pos)
          if (dot == -1) dot = limit
    
          if (!encodeLabel(string, pos, dot, result)) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. src/test/java/jcifs/SmbConnectionTest.java

            // When both are enabled, batch limits should be available
            int limit = config.getBatchLimit("TreeConnectAndX.QueryInformation");
            assertTrue(limit >= 0, "Batch limit should be non-negative when Unicode and batching enabled");
        }
    
        /**
         * Test configuration when batching is disabled
         */
        @Test
        @DisplayName("Batch limit configuration with batching disabled")
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top