Searched refs:RateLimiter (Results 1 – 15 of 15) 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/perfetto/src/perfetto_cmd/ |
| D | rate_limiter.cc | 60 RateLimiter::RateLimiter() = default;
61 RateLimiter::~RateLimiter() = default;
63 bool RateLimiter::ShouldTrace(const Args& args) { in ShouldTrace()
138 bool RateLimiter::OnTraceDone(const Args& args, bool success, uint64_t bytes) { in OnTraceDone()
166 std::string RateLimiter::GetStateFilePath() const { in GetStateFilePath()
170 bool RateLimiter::StateFileExists() { in StateFileExists()
175 bool RateLimiter::ClearState() { in ClearState()
186 bool RateLimiter::LoadState(PerfettoCmdState* state) { in LoadState()
198 bool RateLimiter::SaveState(const PerfettoCmdState& state) { in SaveState()
|
| D | rate_limiter_unittest.cc | 39 class MockRateLimiter : public RateLimiter {
58 return RateLimiter::LoadState(state); in LoadStateConcrete()
62 return RateLimiter::SaveState(state); in SaveStateConcrete()
139 RateLimiter::Args args; in TEST()
162 RateLimiter::Args args; in TEST()
184 RateLimiter::Args args; in TEST()
212 RateLimiter::Args args; in TEST()
232 RateLimiter::Args args; in TEST()
256 RateLimiter::Args args; in TEST()
273 RateLimiter::Args args; in TEST()
[all …]
|
| D | rate_limiter.h | 25 class RateLimiter {
35 RateLimiter();
36 virtual ~RateLimiter();
|
| D | perfetto_cmd.cc | 250 RateLimiter limiter; in Main()
566 RateLimiter::Args args{}; in Main()
|
| /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
|