Searched refs:rate_limiter_ (Results 1 – 5 of 5) sorted by relevance
59 RateLimiter* rate_limiter_; variable75 rate_limiter_(rate_limiter), in file_()100 rate_limiter_ = std::move(o.rate_limiter_);
49 if (for_compaction && rate_limiter_ != nullptr) { in Read()50 allowed = rate_limiter_->RequestToken( in Read()98 if (for_compaction && rate_limiter_ != nullptr) { in Read()99 if (rate_limiter_->IsRateLimited(RateLimiter::OpType::kRead)) { in Read()102 allowed = rate_limiter_->RequestToken(n - pos, 0 /* alignment */, in Read()105 if (rate_limiter_->IsRateLimited(RateLimiter::OpType::kRead)) { in Read()
300 if (rate_limiter_ != nullptr) { in WriteBuffered()301 allowed = rate_limiter_->RequestToken( in WriteBuffered()387 if (rate_limiter_ != nullptr) { in WriteDirect()388 size = rate_limiter_->RequestToken(left, buf_.Alignment(), in WriteDirect()
72 RateLimiter* rate_limiter_; variable97 rate_limiter_(options.rate_limiter), in writable_file_()
256 : file_(file), rate_limiter_(rate_limiter) { in MockWritableFile()288 if (rate_limiter_ && io_priority_ < Env::IO_TOTAL) { in RequestToken()290 bytes, static_cast<size_t>(rate_limiter_->GetSingleBurstBytes())); in RequestToken()291 rate_limiter_->Request(bytes, io_priority_); in RequestToken()297 RateLimiter* rate_limiter_; member in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockWritableFile