Home
last modified time | relevance | path

Searched refs:IO_HIGH (Results 1 – 13 of 13) sorted by relevance

/rocksdb-6.9/util/
Drate_limiter.cc81 for (auto& r : queue_[Env::IO_HIGH]) { in ~GenericRateLimiter()
146 ((!queue_[Env::IO_HIGH].empty() && in Request()
147 &r == queue_[Env::IO_HIGH].front()) || in Request()
175 (!queue_[Env::IO_HIGH].empty() && in Request()
176 &r == queue_[Env::IO_HIGH].front()) || in Request()
180 (!queue_[Env::IO_HIGH].empty() && in Request()
181 leader_ == queue_[Env::IO_HIGH].front()) || in Request()
199 assert((queue_[Env::IO_HIGH].empty() || in Request()
200 &r != queue_[Env::IO_HIGH].front()) && in Request()
203 if (!queue_[Env::IO_HIGH].empty()) { in Request()
[all …]
Drate_limiter_test.cc44 limiter.Request(1000 /* bytes */, Env::IO_HIGH, nullptr /* stats */, in TEST_F()
47 ASSERT_EQ(0, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
49 ASSERT_EQ(1000, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
52 limiter.Request(1000 /* bytes */, Env::IO_HIGH, nullptr /* stats */, in TEST_F()
55 ASSERT_EQ(2000, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
57 ASSERT_EQ(1000, limiter.GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
85 Env::IO_HIGH, nullptr /* stats */, in TEST_F()
160 Arg arg(target, Env::IO_HIGH, limiter); 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()
[all …]
Drate_limiter.h51 total_bytes_through_[Env::IO_HIGH];
60 return total_requests_[Env::IO_LOW] + total_requests_[Env::IO_HIGH];
/rocksdb-6.9/db/
Dbuilder.h82 const Env::IOPriority io_priority = Env::IO_HIGH,
Dbuilder.cc168 if (io_priority == Env::IO_HIGH && in BuildTable()
Dflush_job.cc390 job_context_->job_id, Env::IO_HIGH, &table_properties_, 0 /* level */, in WriteLevel0Table()
Drepair.cc437 0 /* job_id */, Env::IO_HIGH, nullptr /* table_properties */, in ConvertLogToTable()
Ddb_test2.cc2893 ASSERT_EQ(0, options.rate_limiter->GetTotalBytesThrough(Env::IO_HIGH)); in TEST_F()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc4483 batch_bytes, Env::IO_HIGH, in DoWrite()
4857 thread->shared->read_rate_limiter->Request(1024, Env::IO_HIGH, in ReadSequential()
4911 256, Env::IO_HIGH, nullptr /* stats */, RateLimiter::OpType::kRead); in ReadToRowCache()
4950 thread->shared->read_rate_limiter->Request(1024, Env::IO_HIGH, in ReadReverse()
5179 256 * entries_per_batch_, Env::IO_HIGH, nullptr /* stats */, in MultiReadRandom()
5536 256, Env::IO_HIGH, nullptr /* stats */, in MixGraph()
5560 key.size() + val_size, Env::IO_HIGH, nullptr /*stats*/, in MixGraph()
5871 key.size() + val.size(), Env::IO_HIGH, in BGWriter()
6157 key.size() + value.size(), Env::IO_HIGH, nullptr /*stats*/, in UpdateRandom()
6746 1, Env::IO_HIGH, nullptr /* stats */, RateLimiter::OpType::kRead); in TimeSeriesReadOrDelete()
[all …]
/rocksdb-6.9/include/rocksdb/
Denv.h384 enum IOPriority { IO_LOW = 0, IO_HIGH = 1, IO_TOTAL = 2 }; enumerator
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1253 &event_logger_, job_id, Env::IO_HIGH, nullptr /* table_properties */, in WriteLevel0TableForRecovery()
Ddb_impl_write.cc1498 my_batch->GetDataSize(), Env::IO_HIGH, nullptr /* stats */, in ThrottleLowPriWritesIfNeeded()
/rocksdb-6.9/env/
Denv_test.cc1708 w.SetIOPriority(Env::IOPriority::IO_HIGH); in TEST_P()