Searched refs:RateLimiter (Results 1 – 13 of 13) sorted by relevance
30 import com.google.common.util.concurrent.RateLimiter.SleepingStopwatch;54 RateLimiter limiter = RateLimiter.create(stopwatch, 5.0); in testSimple()62 RateLimiter r = RateLimiter.create(1); in testImmediateTryAcquire()68 RateLimiter limiter = RateLimiter.create(5.0, 5, SECONDS); in testSimpleRateUpdate()84 RateLimiter limiter = RateLimiter.create(999); in testAcquireParameterValidation()118 RateLimiter limiter = RateLimiter.create(stopwatch, 5.0); in testSimpleWithWait()127 RateLimiter limiter = RateLimiter.create(stopwatch, 5.0); in testSimpleAcquireReturnValues()136 RateLimiter limiter = RateLimiter.create(stopwatch, 5.0); in testSimpleAcquireEarliestAvailableIsInPast()145 RateLimiter limiter = RateLimiter.create(stopwatch, 5.0); in testOneSecondBurst()161 RateLimiter.create(1.0, 1, NANOSECONDS); in testCreateWarmupParameterValidation()[all …]
20 import com.google.common.util.concurrent.RateLimiter.SleepingStopwatch;41 setDefault(RateLimiter.class, RateLimiter.create(1.0)); in PackageSanityTests()
606 .setDefault(RateLimiter.class, RateLimiter.create(1.0)) in testExecutors_nullCheck()
96 public abstract class RateLimiter { class115 public static RateLimiter create(double permitsPerSecond) { in create()137 static RateLimiter create(SleepingStopwatch stopwatch, double permitsPerSecond) { in create()138 RateLimiter rateLimiter = new SmoothBursty(stopwatch, 1.0 /* maxBurstSeconds */); in create()167 public static RateLimiter create(double permitsPerSecond, long warmupPeriod, TimeUnit unit) { in create()173 static RateLimiter create( in create()175 RateLimiter rateLimiter = new SmoothWarmingUp(stopwatch, warmupPeriod, unit); in create()202 RateLimiter(SleepingStopwatch stopwatch) { in RateLimiter() method in RateLimiter
24 abstract class SmoothRateLimiter extends RateLimiter {
25 class RateLimiter {28 RateLimiter(size_t max, double period) in RateLimiter() function35 virtual ~RateLimiter() {} in ~RateLimiter()
15 bool RateLimiter::CanUse(size_t desired, double time) { in CanUse()20 void RateLimiter::Use(size_t used, double time) { in Use()
18 RateLimiter limiter = RateLimiter(2000, 1.0); in TEST()
93 send_limiter_.reset(new rtc::RateLimiter(kDataMaxBandwidth / 8, 1.0)); in Construct()289 send_limiter_.reset(new rtc::RateLimiter(bps / 8, 1.0)); in SetMaxSendBandwidth()
136 rtc::scoped_ptr<rtc::RateLimiter> send_limiter_;
50 class RateLimiter; variable
META-INF/MANIFEST.MF META-INF/ META-INF/maven/ META- ...
META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...