37 void ThreadPoolImpl::PthreadCall(const char* label, int result) {  in PthreadCall()
44 struct ThreadPoolImpl::Impl {
131 ThreadPoolImpl::Impl::Impl()  in Impl()
148 ThreadPoolImpl::Impl::~Impl() { assert(bgthreads_.size() == 0U); }  in ~Impl()
150 void ThreadPoolImpl::Impl::JoinThreads(bool wait_for_jobs_to_complete) {  in JoinThreads()
176 void ThreadPoolImpl::Impl::LowerIOPriority() {  in LowerIOPriority()
182 void ThreadPoolImpl::Impl::LowerCPUPriority() {  in LowerCPUPriority()
187 void ThreadPoolImpl::Impl::BGThread(size_t thread_id) {  in BGThread()
272   ThreadPoolImpl::Impl* thread_pool_;
274   BGThreadMetadata(ThreadPoolImpl::Impl* thread_pool, size_t thread_id)  in BGThreadMetadata()
278 void ThreadPoolImpl::Impl::BGThreadWrapper(void* arg) {  in BGThreadWrapper()
281   ThreadPoolImpl::Impl* tp = meta->thread_pool_;  in BGThreadWrapper()
314 void ThreadPoolImpl::Impl::SetBackgroundThreadsInternal(int num,  in SetBackgroundThreadsInternal()
328 int ThreadPoolImpl::Impl::GetBackgroundThreads() {  in GetBackgroundThreads()
333 void ThreadPoolImpl::Impl::StartBGThreads() {  in StartBGThreads()
358 void ThreadPoolImpl::Impl::Submit(std::function<void()>&& schedule,  in Submit()
390 int ThreadPoolImpl::Impl::UnSchedule(void* arg) {  in UnSchedule()
423 ThreadPoolImpl::ThreadPoolImpl() :  in ThreadPoolImpl()  function in ROCKSDB_NAMESPACE::ThreadPoolImpl
428 ThreadPoolImpl::~ThreadPoolImpl() {  in ~ThreadPoolImpl()
431 void ThreadPoolImpl::JoinAllThreads() {  in JoinAllThreads()
435 void ThreadPoolImpl::SetBackgroundThreads(int num) {  in SetBackgroundThreads()
439 int ThreadPoolImpl::GetBackgroundThreads() {  in GetBackgroundThreads()
443 unsigned int ThreadPoolImpl::GetQueueLen() const {  in GetQueueLen()
447 void ThreadPoolImpl::WaitForJobsAndJoinAllThreads() {  in WaitForJobsAndJoinAllThreads()
451 void ThreadPoolImpl::LowerIOPriority() {  in LowerIOPriority()
455 void ThreadPoolImpl::LowerCPUPriority() {  in LowerCPUPriority()
459 void ThreadPoolImpl::IncBackgroundThreadsIfNeeded(int num) {  in IncBackgroundThreadsIfNeeded()
463 void ThreadPoolImpl::SubmitJob(const std::function<void()>& job) {  in SubmitJob()
469 void ThreadPoolImpl::SubmitJob(std::function<void()>&& job) {  in SubmitJob()
473 void ThreadPoolImpl::Schedule(void(*function)(void* arg1), void* arg,  in Schedule()
483 int ThreadPoolImpl::UnSchedule(void* arg) {  in UnSchedule()
487 void ThreadPoolImpl::SetHostEnv(Env* env) { impl_->SetHostEnv(env); }  in SetHostEnv()
489 Env* ThreadPoolImpl::GetHostEnv() const { return impl_->GetHostEnv(); }  in GetHostEnv()
493 Env::Priority ThreadPoolImpl::GetThreadPriority() const {  in GetThreadPriority()
498 void ThreadPoolImpl::SetThreadPriority(Env::Priority priority) {  in SetThreadPriority()
503   ThreadPoolImpl* thread_pool = new ThreadPoolImpl();  in NewThreadPool()