Home
last modified time | relevance | path

Searched refs:SetBackgroundThreads (Results 1 – 25 of 35) sorted by relevance

12

/rocksdb-6.9/env/
Denv_test.cc290 env_->SetBackgroundThreads(1, Env::LOW); in TEST_P()
471 env_->SetBackgroundThreads(kLowPoolSize); in TEST_P()
573 env_->SetBackgroundThreads(1, 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()
630 env_->SetBackgroundThreads(5, Env::Priority::HIGH); in TEST_P()
[all …]
Denv_posix.cc325 void SetBackgroundThreads(int num, Priority pri) override { in SetBackgroundThreads() function in ROCKSDB_NAMESPACE::__anon43aff5a30111::PosixEnv
327 thread_pools_[pri].SetBackgroundThreads(num); in SetBackgroundThreads()
/rocksdb-6.9/util/
Dthread_list_test.cc127 env->SetBackgroundThreads(kHighPriorityThreads, Env::HIGH); in TEST_F()
128 env->SetBackgroundThreads(kLowPriorityThreads, Env::LOW); in TEST_F()
249 env->SetBackgroundThreads( in TEST_F()
251 env->SetBackgroundThreads( in TEST_F()
Dthreadpool_imp.h37 void SetBackgroundThreads(int num) override;
Dthreadpool_imp.cc435 void ThreadPoolImpl::SetBackgroundThreads(int num) { in SetBackgroundThreads() function in ROCKSDB_NAMESPACE::ThreadPoolImpl
504 thread_pool->SetBackgroundThreads(num_threads); in NewThreadPool()
/rocksdb-6.9/db/
Ddb_dynamic_level_test.cc118 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
119 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
401 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
402 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
Dfault_injection_test.cc393 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_P()
479 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_P()
Ddb_test.cc3992 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
4000 env_->SetBackgroundThreads(0, Env::HIGH); in TEST_F()
4755 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
4756 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
5312 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
5313 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
5331 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
5332 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
5922 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
5987 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
[all …]
Ddb_compaction_test.cc640 env_->SetBackgroundThreads(1, Env::Priority::BOTTOM); in TEST_F()
653 env_->SetBackgroundThreads(0, Env::Priority::BOTTOM); in TEST_F()
780 env_->SetBackgroundThreads(4, Env::LOW); in TEST_F()
2741 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_P()
2742 env_->SetBackgroundThreads(1, Env::LOW); in TEST_P()
3294 Env::Default()->SetBackgroundThreads(1, Env::Priority::BOTTOM); in TEST_P()
3331 Env::Default()->SetBackgroundThreads(0, Env::Priority::BOTTOM); in TEST_P()
4607 env_->SetBackgroundThreads((int)kTotalFlushTasks, Env::HIGH); in TEST_F()
4608 env_->SetBackgroundThreads((int)kTotalCompactTasks, Env::LOW); in TEST_F()
5182 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_P()
Ddb_properties_test.cc732 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
733 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
986 env_->SetBackgroundThreads(1, Env::HIGH); in TEST_F()
987 env_->SetBackgroundThreads(1, Env::LOW); in TEST_F()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_tool.cc79 db_stress_env->SetBackgroundThreads(FLAGS_max_background_compactions, in db_stress_tool()
81 db_stress_env->SetBackgroundThreads(FLAGS_num_bottom_pri_threads, in db_stress_tool()
Ddb_stress_common.cc107 db_stress_env->SetBackgroundThreads(new_thread_pool_size, in PoolSizeChangeThread()
/rocksdb-6.9/hdfs/
Denv_hdfs.h147 void SetBackgroundThreads(int number, Priority pri = LOW) override {
148 posixEnv->SetBackgroundThreads(number, pri);
369 virtual void SetBackgroundThreads(int /*number*/,
/rocksdb-6.9/include/rocksdb/
Dthreadpool.h33 virtual void SetBackgroundThreads(int num) = 0;
Denv.h460 virtual void SetBackgroundThreads(int number, Priority pri = LOW) = 0;
1328 void SetBackgroundThreads(int num, Priority pri) override { in SetBackgroundThreads() function
1329 return target_->SetBackgroundThreads(num, pri); in SetBackgroundThreads()
/rocksdb-6.9/port/win/
Denv_win.h67 void SetBackgroundThreads(int num, Env::Priority pri);
325 void SetBackgroundThreads(int num, Env::Priority pri) override;
Denv_win.cc1280 void WinEnvThreads::SetBackgroundThreads(int num, Env::Priority pri) { in SetBackgroundThreads() function in ROCKSDB_NAMESPACE::port::WinEnvThreads
1282 thread_pools_[pri].SetBackgroundThreads(num); in SetBackgroundThreads()
1492 void WinEnv::SetBackgroundThreads(int num, Env::Priority pri) { in SetBackgroundThreads() function in ROCKSDB_NAMESPACE::port::WinEnv
1493 return winenv_threads_.SetBackgroundThreads(num, pri); in SetBackgroundThreads()
/rocksdb-6.9/options/
Doptions.cc576 env->SetBackgroundThreads(total_threads, Env::LOW); in IncreaseParallelism()
577 env->SetBackgroundThreads(1, Env::HIGH); in IncreaseParallelism()
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc307 thread_pool.SetBackgroundThreads(static_cast<int>(threads_num)); in MultiThreadReplay()
309 thread_pool.SetBackgroundThreads(1); in MultiThreadReplay()
/rocksdb-6.9/docs/_posts/
D2017-09-28-rocksdb-5-8-released.markdown16 …multi-instance use cases. Users can enable this feature via `Env::SetBackgroundThreads(N, Env::Pri…
/rocksdb-6.9/java/rocksjni/
Denv.cc50 rocks_env->SetBackgroundThreads( in Java_org_rocksdb_Env_setBackgroundThreads()
/rocksdb-6.9/memtable/
Dinlineskiplist_test.cc599 Env::Default()->SetBackgroundThreads(1); in RunConcurrentRead()
612 Env::Default()->SetBackgroundThreads(1 + write_parallelism, in RunConcurrentInsert()
Dskiplist_test.cc366 Env::Default()->SetBackgroundThreads(1); in RunConcurrent()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc53 env_->SetBackgroundThreads(1, Env::LOW); in CheckpointTest()
54 env_->SetBackgroundThreads(1, Env::HIGH); in CheckpointTest()
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc95 env_->SetBackgroundThreads(1, Env::LOW); in CompactionJobStatsTest()
96 env_->SetBackgroundThreads(1, Env::HIGH); in CompactionJobStatsTest()

12