Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 248 for limiter (0.05 seconds)

  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");
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (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");
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (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()) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.1K bytes
    - Click Count (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
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  5. fastapi/concurrency.py

        # since we're creating a new limiter for each call, any non-zero limit
        # works (1 is arbitrary)
        exit_limiter = CapacityLimiter(1)
        try:
            yield await run_in_threadpool(cm.__enter__)
        except Exception as e:
            ok = bool(
                await anyio.to_thread.run_sync(
                    cm.__exit__, type(e), e, e.__traceback__, limiter=exit_limiter
                )
            )
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       * spread over each second. When the incoming request rate exceeds {@code permitsPerSecond} the
       * rate limiter will release one permit every {@code (1.0 / permitsPerSecond)} seconds. When the
       * rate limiter is unused, bursts of up to {@code permitsPerSecond} permits will be allowed, with
       * subsequent requests being smoothly limited at the stable rate of {@code permitsPerSecond}.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:05:27 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  7. android/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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  8. internal/bucket/bandwidth/monitor.go

    	m.tlock.RLock()
    	defer m.tlock.RUnlock()
    	return m.bucketsThrottle[opts]
    }
    
    // SetBandwidthLimit sets the bandwidth limit for a bucket
    func (m *Monitor) SetBandwidthLimit(bucket, arn string, limit int64) {
    	m.tlock.Lock()
    	defer m.tlock.Unlock()
    	limitBytes := limit / int64(m.NodeCount)
    	throttle, ok := m.bucketsThrottle[BucketOptions{Name: bucket, ReplicationARN: arn}]
    	if !ok {
    		throttle = &bucketThrottle{}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  9. docs/fr/docs/advanced/path-operation-advanced-configuration.md

    {* ../../docs_src/path_operation_advanced_configuration/tutorial003_py310.py hl[6] *}
    
    ## Description avancée depuis la docstring { #advanced-description-from-docstring }
    
    Vous pouvez limiter les lignes utilisées de la docstring d’une fonction de chemin d’accès pour OpenAPI.
    
    L’ajout d’un `\f` (un caractère « form feed » échappé) amène **FastAPI** à tronquer la sortie utilisée pour OpenAPI à cet endroit.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 8K bytes
    - Click Count (0)
  10. 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...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Tue Nov 11 22:42:32 GMT 2025
    - 7.9K bytes
    - Click Count (0)
Back to Top