Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for burst (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

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

          int oneSecWorthOfWork = rate;
          stopwatch.sleepMillis(rate * 1000);
          limiter.setRate(rate);
          long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
          // we allow one second worth of work to go in a burst (i.e. take less than a second)
          assertThat(burst).isAtMost(1000);
          long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 21.9K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          int oneSecWorthOfWork = rate;
          stopwatch.sleepMillis(rate * 1000);
          limiter.setRate(rate);
          long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
          // we allow one second worth of work to go in a burst (i.e. take less than a second)
          assertThat(burst).isAtMost(1000);
          long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 21.9K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3
    
    import app.cash.burst.Burst
    import assertk.assertThat
    import assertk.assertions.containsExactly
    import assertk.assertions.isEmpty
    import assertk.assertions.isEqualTo
    import java.io.IOException
    import java.net.InetAddress
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/CookieTest.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3
    
    import app.cash.burst.Burst
    import app.cash.burst.burstValues
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import assertk.assertions.isFalse
    import assertk.assertions.isNotEqualTo
    import assertk.assertions.isNotNull
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 24.4K bytes
    - Click Count (0)
  5. build.gradle.kts

        classpath(libs.gradlePlugin.kotlinSerialization)
        classpath(libs.gradlePlugin.androidJunit5)
        classpath(libs.gradlePlugin.android)
        classpath(libs.gradlePlugin.bnd)
        classpath(libs.gradlePlugin.burst)
        classpath(libs.gradlePlugin.shadow)
        classpath(libs.gradlePlugin.animalsniffer)
        classpath(libs.gradlePlugin.errorprone)
        classpath(libs.gradlePlugin.spotless)
        classpath(libs.gradlePlugin.mavenPublish)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 11.5K bytes
    - Click Count (1)
  6. cmd/local-locker.go

    )
    
    // Reject new lock requests immediately when this many are queued
    // for the local lock mutex.
    // We do not block unlocking or maintenance, but they add to the count.
    // The limit is set to allow for bursty behavior,
    // but prevent requests to overload the server completely.
    // Rejected clients are expected to retry.
    const lockMutexWaitLimit = 1000
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

        }
    
        @Override
        double coolDownIntervalMicros() {
          return warmupPeriodMicros / maxPermits;
        }
      }
    
      /**
       * This implements a "bursty" RateLimiter, where storedPermits are translated to zero throttling.
       * The maximum number of permits that can be saved (when the RateLimiter is unused) is defined in
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
Back to Top