Home
last modified time | relevance | path

Searched refs:HIGH (Results 1 – 25 of 36) sorted by relevance

12

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DDefaultEnvTest.java39 defaultEnv.setBackgroundThreads(5, Priority.HIGH); in backgroundThreads()
40 assertThat(defaultEnv.getBackgroundThreads(Priority.HIGH)).isEqualTo(5); in backgroundThreads()
49 assertThat(defaultEnv.getThreadPoolQueueLen(Priority.HIGH)).isEqualTo(0); in threadPoolQueueLen()
62 defaultEnv.incBackgroundThreadsIfNeeded(20, Priority.HIGH); in incBackgroundThreadsIfNeeded()
63 assertThat(defaultEnv.getBackgroundThreads(Priority.HIGH)).isGreaterThanOrEqualTo(20); in incBackgroundThreadsIfNeeded()
74 defaultEnv.lowerThreadPoolIOPriority(Priority.HIGH); in lowerThreadPoolIOPriority()
85 defaultEnv.lowerThreadPoolCPUPriority(Priority.HIGH); in lowerThreadPoolCPUPriority()
/rocksdb-6.9/env/
Denv_test.cc573 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
578 Env::Priority::HIGH); in TEST_P()
587 env_->SetBackgroundThreads(2, Env::Priority::HIGH); in TEST_P()
595 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
611 env_->SetBackgroundThreads(5, Env::Priority::HIGH); in TEST_P()
620 env_->SetBackgroundThreads(7, Env::Priority::HIGH); in TEST_P()
624 env_->SetBackgroundThreads(3, Env::Priority::HIGH); in TEST_P()
627 env_->SetBackgroundThreads(4, Env::Priority::HIGH); in TEST_P()
643 Env::Priority::HIGH); in TEST_P()
692 Env::Priority::HIGH); in TEST_P()
[all …]
Denv_posix.cc326 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in SetBackgroundThreads()
331 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in GetBackgroundThreads()
342 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in IncBackgroundThreadsIfNeeded()
347 assert(pool >= Priority::BOTTOM && pool <= Priority::HIGH); in LowerThreadPoolIOPriority()
356 assert(pool >= Priority::BOTTOM && pool <= Priority::HIGH); in LowerThreadPoolCPUPriority()
434 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in Schedule()
443 assert(pri >= Priority::BOTTOM && pri <= Priority::HIGH); in GetThreadPoolQueueLen()
Denv.cc91 case Env::Priority::HIGH: in PriorityToString()
/rocksdb-6.9/cache/
Dlru_cache_test.cc127 Insert("x", Cache::Priority::HIGH); in TEST_F()
128 Insert("y", Cache::Priority::HIGH); in TEST_F()
139 Insert("z", Cache::Priority::HIGH); in TEST_F()
157 Insert("X", Cache::Priority::HIGH); in TEST_F()
158 Insert("Y", Cache::Priority::HIGH); in TEST_F()
162 Insert("Z", Cache::Priority::HIGH); in TEST_F()
Dlru_cache.h110 if (priority == Cache::Priority::HIGH) { in SetPriority()
/rocksdb-6.9/db/
Ddeletefile_test.cc245 &sleeping_task_before, Env::Priority::HIGH); in TEST_F()
249 &sleeping_task_after, Env::Priority::HIGH); in TEST_F()
292 &sleeping_task_after, Env::Priority::HIGH); in TEST_F()
358 &sleeping_task_after, Env::Priority::HIGH); in TEST_F()
400 env_->Schedule(&DeleteFileTest::DoSleep, this, Env::Priority::HIGH); in TEST_F()
402 env_->Schedule(&DeleteFileTest::GuardFinish, nullptr, Env::Priority::HIGH); in TEST_F()
Dfault_injection_test.cc393 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_P()
396 Env::Priority::HIGH); in TEST_P()
479 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_P()
482 Env::Priority::HIGH); in TEST_P()
Ddb_dynamic_level_test.cc119 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
402 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
Ddb_block_cache_test.cc463 for (auto priority : {Cache::Priority::LOW, Cache::Priority::HIGH}) { in TEST_F()
472 priority == Cache::Priority::HIGH ? true : false; in TEST_F()
Dcolumn_family_test.cc2432 Env::Priority::HIGH); in TEST_P()
2446 Env::Priority::HIGH); in TEST_P()
2995 Env::Priority::HIGH); in TEST_P()
3040 Env::Priority::HIGH); in TEST_P()
3066 env.SetBackgroundThreads(2, Env::HIGH); in TEST_P()
3123 env.SetBackgroundThreads(2, Env::HIGH); in TEST_P()
Ddb_test.cc3819 (i < 4) ? Env::Priority::LOW : Env::Priority::HIGH); in TEST_F()
3825 options.env->GetThreadPoolQueueLen(Env::Priority::HIGH) <= 2) { in TEST_F()
4000 env_->SetBackgroundThreads(0, Env::HIGH); in TEST_F()
4105 env_->SetBackgroundThreads(kHighPriCounts[test], Env::HIGH); in TEST_F()
4347 env_->SetBackgroundThreads(kHighPriCount, Env::HIGH); in TEST_P()
4436 env_->SetBackgroundThreads(kHighPriCount, Env::HIGH); in TEST_P()
4756 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
5313 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
5319 &sleeping_task_high, Env::Priority::HIGH); in TEST_F()
5332 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
[all …]
Ddb_properties_test.cc732 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
739 &sleeping_task_high, Env::Priority::HIGH); in TEST_F()
986 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
Ddb_flush_test.cc150 env_->SetBackgroundThreads(0, Env::HIGH); in TEST_F()
Ddb_options_test.cc435 env_->GetBackgroundThreads(Env::Priority::HIGH)); in TEST_F()
/rocksdb-6.9/util/
Dthread_list_test.cc127 env->SetBackgroundThreads(kHighPriorityThreads, Env::HIGH); in TEST_F()
136 &running_task, Env::Priority::HIGH); in TEST_F()
250 correct_operation_counts[ThreadStatus::OP_FLUSH], Env::HIGH); in TEST_F()
257 &flush_write_task, Env::Priority::HIGH); in TEST_F()
Dthreadpool_imp.cc287 case Env::Priority::HIGH: in BGThreadWrapper()
/rocksdb-6.9/utilities/simulator_cache/
Dcache_simulator.cc82 return Cache::Priority::HIGH; in ComputeBlockPriority()
148 AccessKVPair(row_key, access.referenced_data_size, Cache::Priority::HIGH, in Access()
181 /*handle=*/nullptr, Cache::Priority::HIGH); in Access()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DPriority.java14 HIGH((byte)0x2), enumConstant
/rocksdb-6.9/port/win/
Denv_win.cc1217 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in Schedule()
1265 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in GetThreadPoolQueueLen()
1281 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in SetBackgroundThreads()
1286 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in GetBackgroundThreads()
1291 assert(pri >= Env::Priority::BOTTOM && pri <= Env::Priority::HIGH); in IncBackgroundThreadsIfNeeded()
/rocksdb-6.9/include/rocksdb/
Dcache.h144 enum class Priority { HIGH, LOW }; enumerator
/rocksdb-6.9/options/
Doptions.cc577 env->SetBackgroundThreads(1, Env::HIGH); in IncreaseParallelism()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc1970 env_->GetBackgroundThreads(Env::Priority::HIGH) == 0; in MaybeScheduleFlushOrCompaction()
1976 fta->thread_pri_ = Env::Priority::HIGH; in MaybeScheduleFlushOrCompaction()
1977 env_->Schedule(&DBImpl::BGWorkFlush, fta, Env::Priority::HIGH, this, in MaybeScheduleFlushOrCompaction()
2176 IOSTATS_SET_THREAD_POOL_ID(Env::Priority::HIGH); in BGWorkPurge()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc54 env_->SetBackgroundThreads(1, Env::HIGH); in CheckpointTest()
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc96 env_->SetBackgroundThreads(1, Env::HIGH); in CompactionJobStatsTest()

12