Searched refs:RateLimiter (Results 1 – 11 of 11) sorted by relevance
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | RateLimiterTest.java | 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 …]
|
| D | PackageSanityTests.java | 20 import com.google.common.util.concurrent.RateLimiter.SleepingStopwatch;
41 setDefault(RateLimiter.class, RateLimiter.create(1.0)); in PackageSanityTests()
|
| D | MoreExecutorsTest.java | 606 .setDefault(RateLimiter.class, RateLimiter.create(1.0)) in testExecutors_nullCheck()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | RateLimiter.java | 96 public abstract class RateLimiter { class
115 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
|
| D | SmoothRateLimiter.java | 24 abstract class SmoothRateLimiter extends RateLimiter {
|
| /external/webrtc/webrtc/base/ |
| D | ratelimiter.h | 25 class RateLimiter {
28 RateLimiter(size_t max, double period) in RateLimiter() function
35 virtual ~RateLimiter() {} in ~RateLimiter()
|
| D | ratelimiter.cc | 15 bool RateLimiter::CanUse(size_t desired, double time) { in CanUse()
20 void RateLimiter::Use(size_t used, double time) { in Use()
|
| D | ratelimiter_unittest.cc | 18 RateLimiter limiter = RateLimiter(2000, 1.0); in TEST()
|
| /external/webrtc/talk/media/base/ |
| D | rtpdataengine.cc | 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()
|
| D | rtpdataengine.h | 136 rtc::scoped_ptr<rtc::RateLimiter> send_limiter_;
|
| D | mediachannel.h | 50 class RateLimiter; variable
|