Lines Matching refs:thread_updater_local_cache_

14 __thread ThreadStatusUpdater* ThreadStatusUtil::thread_updater_local_cache_ =  member in ROCKSDB_NAMESPACE::ThreadStatusUtil
23 assert(thread_updater_local_cache_); in RegisterThread()
24 thread_updater_local_cache_->RegisterThread(thread_type, env->GetThreadID()); in RegisterThread()
29 if (thread_updater_local_cache_ != nullptr) { in UnregisterThread()
30 thread_updater_local_cache_->UnregisterThread(); in UnregisterThread()
31 thread_updater_local_cache_ = nullptr; in UnregisterThread()
41 assert(thread_updater_local_cache_); in SetColumnFamily()
43 thread_updater_local_cache_->SetColumnFamilyInfoKey(cfd); in SetColumnFamily()
48 thread_updater_local_cache_->SetColumnFamilyInfoKey(nullptr); in SetColumnFamily()
53 if (thread_updater_local_cache_ == nullptr) { in SetThreadOperation()
61 thread_updater_local_cache_->SetOperationStartTime(current_time); in SetThreadOperation()
65 thread_updater_local_cache_->SetOperationStartTime(0); in SetThreadOperation()
67 thread_updater_local_cache_->SetThreadOperation(op); in SetThreadOperation()
72 if (thread_updater_local_cache_ == nullptr) { in SetThreadOperationStage()
78 return thread_updater_local_cache_->SetThreadOperationStage(stage); in SetThreadOperationStage()
82 if (thread_updater_local_cache_ == nullptr) { in SetThreadOperationProperty()
88 thread_updater_local_cache_->SetThreadOperationProperty(code, value); in SetThreadOperationProperty()
93 if (thread_updater_local_cache_ == nullptr) { in IncreaseThreadOperationProperty()
99 thread_updater_local_cache_->IncreaseThreadOperationProperty(code, delta); in IncreaseThreadOperationProperty()
103 if (thread_updater_local_cache_ == nullptr) { in SetThreadState()
109 thread_updater_local_cache_->SetThreadState(state); in SetThreadState()
113 if (thread_updater_local_cache_ == nullptr) { in ResetThreadStatus()
116 thread_updater_local_cache_->ResetThreadStatus(); in ResetThreadStatus()
126 assert(thread_updater_local_cache_); in NewColumnFamilyInfo()
127 if (thread_updater_local_cache_) { in NewColumnFamilyInfo()
128 thread_updater_local_cache_->NewColumnFamilyInfo(db, db->GetName(), cfd, in NewColumnFamilyInfo()
134 if (thread_updater_local_cache_ == nullptr) { in EraseColumnFamilyInfo()
137 thread_updater_local_cache_->EraseColumnFamilyInfo(cfd); in EraseColumnFamilyInfo()
151 thread_updater_local_cache_ = env->GetThreadStatusUpdater(); in MaybeInitThreadLocalUpdater()
153 return (thread_updater_local_cache_ != nullptr); in MaybeInitThreadLocalUpdater()
167 ThreadStatusUpdater* ThreadStatusUtil::thread_updater_local_cache_ = nullptr;