Home
last modified time | relevance | path

Searched refs:pri (Results 1 – 17 of 17) sorted by relevance

/rocksdb-6.9/env/
Denv_posix.cc219 int UnSchedule(void* arg, Priority pri) override;
326 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in SetBackgroundThreads()
327 thread_pools_[pri].SetBackgroundThreads(num); in SetBackgroundThreads()
330 int GetBackgroundThreads(Priority pri) override { in GetBackgroundThreads() argument
331 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in GetBackgroundThreads()
342 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in IncBackgroundThreadsIfNeeded()
434 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in Schedule()
438 int PosixEnv::UnSchedule(void* arg, Priority pri) { in UnSchedule() argument
439 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()
443 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in GetThreadPoolQueueLen()
[all …]
Dcomposite_env_wrapper.h503 void Schedule(void (*f)(void* arg), void* a, Priority pri,
505 return env_target_->Schedule(f, a, pri, tag, u);
508 int UnSchedule(void* tag, Priority pri) override { in UnSchedule() argument
509 return env_target_->UnSchedule(tag, pri); in UnSchedule()
517 return env_target_->GetThreadPoolQueueLen(pri);
535 void SetBackgroundThreads(int num, Priority pri) override { in SetBackgroundThreads() argument
536 return env_target_->SetBackgroundThreads(num, pri); in SetBackgroundThreads()
538 int GetBackgroundThreads(Priority pri) override { in GetBackgroundThreads() argument
539 return env_target_->GetBackgroundThreads(pri); in GetBackgroundThreads()
546 void IncBackgroundThreadsIfNeeded(int num, Priority pri) override { in IncBackgroundThreadsIfNeeded() argument
[all …]
Denv_test.cc121 for (int pri = Env::BOTTOM; pri < Env::TOTAL; ++pri) { in TEST_F() local
123 env_->SetBackgroundThreads(1, static_cast<Env::Priority>(pri)); in TEST_F()
124 env_->Schedule(&SetBool, &called, static_cast<Env::Priority>(pri)); in TEST_F()
/rocksdb-6.9/port/win/
Denv_win.cc1217 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in Schedule()
1222 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()
1265 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in GetThreadPoolQueueLen()
1266 return thread_pools_[pri].GetQueueLen(); in GetThreadPoolQueueLen()
1281 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in SetBackgroundThreads()
1282 thread_pools_[pri].SetBackgroundThreads(num); in SetBackgroundThreads()
1286 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in GetBackgroundThreads()
1287 return thread_pools_[pri].GetBackgroundThreads(); in GetBackgroundThreads()
1291 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in IncBackgroundThreadsIfNeeded()
1464 return winenv_threads_.UnSchedule(arg, pri); in UnSchedule()
[all …]
Denv_win.h49 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
52 int UnSchedule(void* arg, Env::Priority pri);
58 unsigned int GetThreadPoolQueueLen(Env::Priority pri) const;
67 void SetBackgroundThreads(int num, Env::Priority pri);
68 int GetBackgroundThreads(Env::Priority pri);
70 void IncBackgroundThreadsIfNeeded(int num, Env::Priority pri);
303 void Schedule(void(*function)(void*), void* arg, Env::Priority pri,
306 int UnSchedule(void* arg, Env::Priority pri) override;
312 unsigned int GetThreadPoolQueueLen(Env::Priority pri) const override;
325 void SetBackgroundThreads(int num, Env::Priority pri) override;
[all …]
/rocksdb-6.9/util/
Drate_limiter.h39 virtual void Request(const int64_t bytes, const Env::IOPriority pri,
47 const Env::IOPriority pri = Env::IO_TOTAL) const override {
49 if (pri == Env::IO_TOTAL) {
53 return total_bytes_through_[pri];
57 const Env::IOPriority pri = Env::IO_TOTAL) const override {
59 if (pri == Env::IO_TOTAL) {
62 return total_requests_[pri];
Drate_limiter.cc101 void GenericRateLimiter::Request(int64_t bytes, const Env::IOPriority pri, in Request() argument
122 ++total_requests_[pri]; in Request()
129 total_bytes_through_[pri] += bytes; in Request()
135 queue_[pri].push_back(&r); in Request()
Drate_limiter_test.cc135 : request_size(_request_size), pri(_pri), limiter(_limiter) {} in TEST_F()
137 Env::IOPriority pri; in TEST_F() member
143 arg->limiter->Request(arg->request_size, arg->pri, nullptr /* stats */, in TEST_F()
/rocksdb-6.9/hdfs/
Denv_hdfs.h107 posixEnv->Schedule(function, arg, pri, tag, unschedFunction);
110 int UnSchedule(void* tag, Priority pri) override { in UnSchedule() argument
111 return posixEnv->UnSchedule(tag, pri); in UnSchedule()
120 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override {
121 return posixEnv->GetThreadPoolQueueLen(pri);
147 void SetBackgroundThreads(int number, Priority pri = LOW) override {
148 posixEnv->SetBackgroundThreads(number, pri);
151 int GetBackgroundThreads(Priority pri = LOW) override {
152 return posixEnv->GetBackgroundThreads(pri);
155 void IncBackgroundThreadsIfNeeded(int number, Priority pri) override { in IncBackgroundThreadsIfNeeded() argument
[all …]
/rocksdb-6.9/include/rocksdb/
Drate_limiter.h55 virtual void Request(const int64_t bytes, const Env::IOPriority pri, in Request() argument
59 Request(bytes, pri); in Request()
66 virtual void Request(const int64_t bytes, const Env::IOPriority pri, in Request() argument
69 Request(bytes, pri, stats); in Request()
86 const Env::IOPriority pri = Env::IO_TOTAL) const = 0;
90 const Env::IOPriority pri = Env::IO_TOTAL) const = 0;
Denv.h461 virtual int GetBackgroundThreads(Priority pri = LOW) = 0;
805 virtual void SetIOPriority(Env::IOPriority pri) { io_priority_ = pri; } in SetIOPriority() argument
1290 return target_->Schedule(f, a, pri, tag, u);
1293 int UnSchedule(void* tag, Priority pri) override { in UnSchedule() argument
1294 return target_->UnSchedule(tag, pri); in UnSchedule()
1302 return target_->GetThreadPoolQueueLen(pri);
1329 return target_->SetBackgroundThreads(num, pri); in SetBackgroundThreads()
1331 int GetBackgroundThreads(Priority pri) override { in GetBackgroundThreads() argument
1332 return target_->GetBackgroundThreads(pri); in GetBackgroundThreads()
1481 void SetIOPriority(Env::IOPriority pri) override { in SetIOPriority() argument
[all …]
Dfile_system.h788 virtual void SetIOPriority(Env::IOPriority pri) { io_priority_ = pri; } in SetIOPriority() argument
/rocksdb-6.9/utilities/
Denv_mirror.cc151 void SetIOPriority(Env::IOPriority pri) override { in SetIOPriority() argument
152 a_->SetIOPriority(pri); in SetIOPriority()
153 b_->SetIOPriority(pri); in SetIOPriority()
/rocksdb-6.9/docs/_posts/
D2017-07-25-rocksdb-5-6-1-released.markdown9 …ound_flushes=0`. Instead, users can achieve this by configuring their high-pri thread pool to have…
/rocksdb-6.9/db/
Ddb_test_util.h285 void SetIOPriority(Env::IOPriority pri) override { in NewWritableFile()
286 base_->SetIOPriority(pri); in NewWritableFile()
Ddb_compaction_test.cc628 Env::Priority* pri = reinterpret_cast<Env::Priority*>(arg); in TEST_F() local
631 ASSERT_EQ(Env::Priority::LOW, *pri); in TEST_F()
633 if (*pri == Env::Priority::LOW) { in TEST_F()
/rocksdb-6.9/
DHISTORY.md427 …> 0, midpoint insertion strategy will be enabled to put low-pri items to the tail of low-pri list …
467 * In level-based compaction, if bottom-pri thread pool was setup via `Env::SetBackgroundThreads()`,…
534 * Fix a mislabel bug for bottom-pri compaction threads.
616 …ound_flushes=0`. Instead, users can achieve this by configuring their high-pri thread pool to have…
998 …e existing low pri pool of options.env, it will enlarge it. Similarly, options.max_background_flus…