Searched refs:GenericRateLimiter (Results 1 – 3 of 3) sorted by relevance
| /rocksdb-6.9/util/ |
| D | rate_limiter.cc | 37 struct GenericRateLimiter::Req {
46 GenericRateLimiter::GenericRateLimiter(int64_t rate_bytes_per_sec, in GenericRateLimiter() function in ROCKSDB_NAMESPACE::GenericRateLimiter
76 GenericRateLimiter::~GenericRateLimiter() { in ~GenericRateLimiter()
93 void GenericRateLimiter::SetBytesPerSecond(int64_t bytes_per_second) { in SetBytesPerSecond()
101 void GenericRateLimiter::Request(int64_t bytes, const Env::IOPriority pri, in Request()
229 void GenericRateLimiter::Refill() { in Refill()
265 int64_t GenericRateLimiter::CalculateRefillBytesPerPeriod( in CalculateRefillBytesPerPeriod()
277 Status GenericRateLimiter::Tune() { in Tune()
335 return new GenericRateLimiter(rate_bytes_per_sec, refill_period_us, fairness, in NewGenericRateLimiter()
|
| D | rate_limiter.h | 24 class GenericRateLimiter : public RateLimiter {
26 GenericRateLimiter(int64_t refill_bytes, int64_t refill_period_us,
30 virtual ~GenericRateLimiter();
|
| D | rate_limiter_test.cc | 28 GenericRateLimiter limiter(port::kMaxInt64, 1000, 10, in TEST_F()
41 GenericRateLimiter limiter( in TEST_F()
152 std::make_shared<GenericRateLimiter>( in TEST_F()
188 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F()
|