Searched refs:thread_pools_ (Results 1 – 3 of 3) sorted by relevance
143 thread_pools_[pool_id].JoinAllThreads(); in ~PosixEnv()327 thread_pools_[pri].SetBackgroundThreads(num); in SetBackgroundThreads()349 thread_pools_[pool].LowerIOPriority(); in LowerThreadPoolIOPriority()358 thread_pools_[pool].LowerCPUPriority(); in LowerThreadPoolCPUPriority()397 std::vector<ThreadPoolImpl>& thread_pools_; member in ROCKSDB_NAMESPACE::__anon43aff5a30111::PosixEnv409 thread_pools_(thread_pools_storage_), in PosixEnv()415 thread_pools_[pool_id].SetThreadPriority( in PosixEnv()418 thread_pools_[pool_id].SetHostEnv(this); in PosixEnv()425 thread_pools_(default_env->thread_pools_), in PosixEnv()439 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()[all …]
1195 : hosted_env_(hosted_env), thread_pools_(Env::Priority::TOTAL) { in WinEnvThreads()1198 thread_pools_[pool_id].SetThreadPriority( in WinEnvThreads()1201 thread_pools_[pool_id].SetHostEnv(hosted_env); in WinEnvThreads()1209 for (auto& thpool : thread_pools_) { in ~WinEnvThreads()1218 thread_pools_[pri].Schedule(function, arg, tag, unschedFunction); in Schedule()1222 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()1266 return thread_pools_[pri].GetQueueLen(); in GetThreadPoolQueueLen()1282 thread_pools_[pri].SetBackgroundThreads(num); in SetBackgroundThreads()1287 return thread_pools_[pri].GetBackgroundThreads(); in GetBackgroundThreads()1292 thread_pools_[pri].IncBackgroundThreadsIfNeeded(num); in IncBackgroundThreadsIfNeeded()
76 std::vector<ThreadPoolImpl> thread_pools_; variable