Lines Matching refs:thread_pools_
143 thread_pools_[pool_id].JoinAllThreads(); in ~PosixEnv()
327 thread_pools_[pri].SetBackgroundThreads(num); in SetBackgroundThreads()
332 return thread_pools_[pri].GetBackgroundThreads(); in GetBackgroundThreads()
343 thread_pools_[pri].IncBackgroundThreadsIfNeeded(num); in IncBackgroundThreadsIfNeeded()
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::PosixEnv
409 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()
435 thread_pools_[pri].Schedule(function, arg, tag, unschedFunction); in Schedule()
439 return thread_pools_[pri].UnSchedule(arg); in UnSchedule()
444 return thread_pools_[pri].GetQueueLen(); in GetThreadPoolQueueLen()