Searched refs:Request (Results 1 – 11 of 11) sorted by relevance
44 limiter.Request(1000 /* bytes */, Env::IO_HIGH, nullptr /* stats */, in TEST_F()52 limiter.Request(1000 /* bytes */, Env::IO_HIGH, nullptr /* stats */, in TEST_F()84 arg->limiter->Request(r.Uniform(arg->request_size - 1) + 1, in TEST_F()88 arg->limiter->Request(r.Uniform(arg->request_size - 1) + 1, Env::IO_LOW, in TEST_F()143 arg->limiter->Request(arg->request_size, arg->pri, nullptr /* stats */, in TEST_F()207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
38 using RateLimiter::Request;39 virtual void Request(const int64_t bytes, const Env::IOPriority pri,
31 Request(bytes, io_priority, stats, op_type); in RequestToken()101 void GenericRateLimiter::Request(int64_t bytes, const Env::IOPriority pri, in Request() function in ROCKSDB_NAMESPACE::GenericRateLimiter
48 virtual void Request(const int64_t /*bytes*/, const Env::IOPriority /*pri*/) { in Request() function55 virtual void Request(const int64_t bytes, const Env::IOPriority pri, in Request() function59 Request(bytes, pri); in Request()66 virtual void Request(const int64_t bytes, const Env::IOPriority pri, in Request() function69 Request(bytes, pri, stats); in Request()
434 using Request = _t<std::conditional< variable582 typename Request,584 typename Func = typename Request::F>585 CoalescedTask<Func, Waiter> coalesce(Request& request, Waiter& waiter) {586 static_assert(!std::is_same<Request, std::nullptr_t>{}, "");628 template <typename Request, typename Waiter>629 void throwIfExceptionOccurred(Request&, Waiter& waiter, bool exception) {631 using F = typename Request::F;1061 auto&& task = Request<Func>{func};1134 typename Request>[all …]
84 ->Request(jbytes, ROCKSDB_NAMESPACE::Env::IO_TOTAL); in Java_org_rocksdb_RateLimiter_request()
4482 thread->shared->write_rate_limiter->Request( in DoWrite()4910 thread->shared->read_rate_limiter->Request( in ReadToRowCache()4993 thread->shared->read_rate_limiter->Request( in ReadRandomFast()5087 thread->shared->read_rate_limiter->Request( in ReadRandom()5178 thread->shared->read_rate_limiter->Request( in MultiReadRandom()5535 thread->shared->read_rate_limiter->Request( in MixGraph()5721 thread->shared->read_rate_limiter->Request( in SeekRandom()5870 write_rate_limiter->Request( in BGWriter()6156 thread->shared->write_rate_limiter->Request( in UpdateRandom()6745 thread->shared->read_rate_limiter->Request( in TimeSeriesReadOrDelete()[all …]
15 …hat is just text links to the companies/apps and can be updated via Pull Request by the community.…
291 rate_limiter_->Request(bytes, io_priority_); in RequestToken()
1497 write_controller_.low_pri_rate_limiter()->Request( in ThrottleLowPriWritesIfNeeded()
1367 rate_limiter->Request(data.size(), Env::IO_LOW, nullptr /* stats */, in CopyOrCreateFile()