| /rocksdb-6.9/cache/ |
| D | lru_cache_test.cc | 124 Insert("a", Cache::Priority::LOW); in TEST_F()
125 Insert("b", Cache::Priority::LOW); in TEST_F()
126 Insert("c", Cache::Priority::LOW); in TEST_F()
133 Insert("d", Cache::Priority::LOW); in TEST_F()
147 Insert("a", Cache::Priority::LOW); in TEST_F()
148 Insert("b", Cache::Priority::LOW); in TEST_F()
149 Insert("c", Cache::Priority::LOW); in TEST_F()
153 Insert("u", Cache::Priority::LOW); in TEST_F()
154 Insert("v", Cache::Priority::LOW); in TEST_F()
166 Insert("a", Cache::Priority::LOW); in TEST_F()
[all …]
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | DefaultEnvTest.java | 34 assertThat(defaultEnv.getBackgroundThreads(Priority.LOW)).isEqualTo(5); in backgroundThreads()
36 defaultEnv.setBackgroundThreads(5, Priority.LOW); in backgroundThreads()
37 assertThat(defaultEnv.getBackgroundThreads(Priority.LOW)).isEqualTo(5); in backgroundThreads()
48 assertThat(defaultEnv.getThreadPoolQueueLen(Priority.LOW)).isEqualTo(0); in threadPoolQueueLen()
59 defaultEnv.incBackgroundThreadsIfNeeded(20, Priority.LOW); in incBackgroundThreadsIfNeeded()
60 assertThat(defaultEnv.getBackgroundThreads(Priority.LOW)).isGreaterThanOrEqualTo(20); in incBackgroundThreadsIfNeeded()
72 defaultEnv.lowerThreadPoolIOPriority(Priority.LOW); in lowerThreadPoolIOPriority()
83 defaultEnv.lowerThreadPoolCPUPriority(Priority.LOW); in lowerThreadPoolCPUPriority()
|
| /rocksdb-6.9/hdfs/ |
| D | env_hdfs.h | 104 void Schedule(void (*function)(void* arg), void* arg, Priority pri = LOW,
120 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override {
147 void SetBackgroundThreads(int number, Priority pri = LOW) override {
151 int GetBackgroundThreads(Priority pri = LOW) override {
333 Priority /*pri*/ = LOW, void* /*tag*/ = nullptr,
344 Priority /*pri*/ = LOW) const override {
370 Priority /*pri*/ = LOW) override {}
371 virtual int GetBackgroundThreads(Priority /*pri*/ = LOW) override {
|
| /rocksdb-6.9/util/ |
| D | thread_list_test.cc | 128 env->SetBackgroundThreads(kLowPriorityThreads, Env::LOW); in TEST_F()
140 &running_task, Env::Priority::LOW); in TEST_F()
252 correct_operation_counts[ThreadStatus::OP_COMPACTION], Env::LOW); in TEST_F()
263 &compaction_write_task, Env::Priority::LOW); in TEST_F()
269 &compaction_read_task, Env::Priority::LOW); in TEST_F()
275 &compaction_wait_task, Env::Priority::LOW); in TEST_F()
|
| D | threadpool_imp.cc | 135 priority_(Env::LOW), in Impl()
290 case Env::Priority::LOW: in BGThreadWrapper()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | env.h | 379 enum Priority { BOTTOM, LOW, HIGH, USER, TOTAL }; enumerator
397 Priority pri = LOW, void* tag = nullptr,
412 virtual unsigned int GetThreadPoolQueueLen(Priority /*pri*/ = LOW) const {
460 virtual void SetBackgroundThreads(int number, Priority pri = LOW) = 0;
461 virtual int GetBackgroundThreads(Priority pri = LOW) = 0;
473 virtual void LowerThreadPoolIOPriority(Priority /*pool*/ = LOW) {}
476 virtual void LowerThreadPoolCPUPriority(Priority /*pool*/ = LOW) {}
1301 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override {
1343 void LowerThreadPoolIOPriority(Priority pool = LOW) override {
1347 void LowerThreadPoolCPUPriority(Priority pool = LOW) override {
|
| D | cache.h | 144 enum class Priority { HIGH, LOW }; enumerator
182 Priority priority = Priority::LOW) = 0;
|
| /rocksdb-6.9/env/ |
| D | env_test.cc | 105 while (env_->GetThreadPoolQueueLen(Env::Priority::LOW) != 0) { in WaitThreadPoolsEmpty()
290 env_->SetBackgroundThreads(1, Env::LOW); in TEST_P()
295 Env::Priority::LOW); in TEST_P()
299 Env::Priority::LOW, &sleeping_task1); in TEST_P()
302 ASSERT_EQ(0, env_->UnSchedule(&called, Env::Priority::LOW)); in TEST_P()
485 env_->GetThreadPoolQueueLen(Env::Priority::LOW) || in TEST_P()
497 env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
546 env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
2085 Env::Default()->SetBackgroundThreads(16, Env::LOW); in TEST_P()
2087 ASSERT_EQ(env1->GetBackgroundThreads(Env::LOW), 16); in TEST_P()
[all …]
|
| D | env_posix.cc | 215 void Schedule(void (*function)(void* arg1), void* arg, Priority pri = LOW,
225 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override;
346 void LowerThreadPoolIOPriority(Priority pool = LOW) override { in LowerThreadPoolIOPriority()
355 void LowerThreadPoolCPUPriority(Priority pool = LOW) override { in LowerThreadPoolCPUPriority()
|
| D | composite_env_wrapper.h | 516 unsigned int GetThreadPoolQueueLen(Priority pri = LOW) const override {
550 void LowerThreadPoolIOPriority(Priority pool = LOW) override {
554 void LowerThreadPoolCPUPriority(Priority pool = LOW) override {
|
| D | env.cc | 89 case Env::Priority::LOW: in PriorityToString()
|
| /rocksdb-6.9/db/ |
| D | db_block_cache_test.cc | 448 if (priority == Priority::LOW) { in Insert()
463 for (auto priority : {Cache::Priority::LOW, Cache::Priority::HIGH}) { in TEST_F()
491 if (priority == Cache::Priority::LOW) { in TEST_F()
509 if (priority == Cache::Priority::LOW) { in TEST_F()
|
| D | db_test.cc | 3992 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
3995 Env::Priority::LOW); in TEST_F()
4030 Env::Priority::LOW); in TEST_F()
4053 Env::Priority::LOW); in TEST_F()
4850 Env::Priority::LOW); in TEST_F()
4881 Env::Priority::LOW); in TEST_F()
5316 Env::Priority::LOW); in TEST_F()
5940 Env::Priority::LOW); in TEST_F()
6003 Env::Priority::LOW); in TEST_F()
6131 Env::Priority::LOW); in TEST_F()
[all …]
|
| D | db_dynamic_level_test.cc | 118 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
401 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
|
| D | db_compaction_test.cc | 631 ASSERT_EQ(Env::Priority::LOW, *pri); in TEST_F()
633 if (*pri == Env::Priority::LOW) { in TEST_F()
780 env_->SetBackgroundThreads(4, Env::LOW); in TEST_F()
784 &sleeping_tasks[i], Env::Priority::LOW); in TEST_F()
805 ASSERT_EQ(1u, env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_F()
833 &sleeping_tasks[i], Env::Priority::LOW); in TEST_F()
2742 env_->SetBackgroundThreads(1, Env::LOW); in TEST_P()
2746 Env::Priority::LOW); in TEST_P()
2839 Env::Priority::LOW); in TEST_P()
4615 &sleeping_compact_tasks[i], Env::LOW); in TEST_F()
[all …]
|
| D | db_properties_test.cc | 733 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
736 Env::Priority::LOW); in TEST_F()
987 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
990 Env::Priority::LOW); in TEST_F()
|
| D | db_basic_test.cc | 359 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
362 Env::Priority::LOW); in TEST_F()
2057 Priority priority = Priority::LOW) override { in Insert()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | Priority.java | 13 LOW((byte) 0x1), enumConstant
|
| D | Env.java | 55 return setBackgroundThreads(number, Priority.LOW); in setBackgroundThreads()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 1546 Env::Priority thread_pool_pri = Env::Priority::LOW; in RunManualCompaction()
1994 fta->thread_pri_ = Env::Priority::LOW; in MaybeScheduleFlushOrCompaction()
1995 env_->Schedule(&DBImpl::BGWorkFlush, fta, Env::Priority::LOW, this, in MaybeScheduleFlushOrCompaction()
2026 env_->Schedule(&DBImpl::BGWorkCompaction, ca, Env::Priority::LOW, this, in MaybeScheduleFlushOrCompaction()
2154 IOSTATS_SET_THREAD_POOL_ID(Env::Priority::LOW); in BGWorkCompaction()
2159 prepicked_compaction, Env::Priority::LOW); in BGWorkCompaction()
2381 (bg_thread_pri == Env::Priority::LOW && bg_compaction_scheduled_)); in BackgroundCallCompaction()
2445 if (bg_thread_pri == Env::Priority::LOW) { in BackgroundCallCompaction()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_tool.cc | 80 ROCKSDB_NAMESPACE::Env::Priority::LOW); in db_stress_tool()
|
| D | db_stress_common.cc | 108 ROCKSDB_NAMESPACE::Env::Priority::LOW); in PoolSizeChangeThread()
|
| /rocksdb-6.9/utilities/simulator_cache/ |
| D | cache_simulator.cc | 84 return Cache::Priority::LOW; in ComputeBlockPriority()
|
| /rocksdb-6.9/options/ |
| D | options.cc | 576 env->SetBackgroundThreads(total_threads, Env::LOW); in IncreaseParallelism()
|
| /rocksdb-6.9/memtable/ |
| D | inlineskiplist_test.cc | 613 Env::Priority::LOW); in RunConcurrentInsert()
|