andreacavalli/rocksdb
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixed ~ThreadStatusImpl().

Browse Source
This commit is contained in:
Yueh-Hsuan Chiang 2014-11-20 15:45:56 -08:00
parent fbc42a0933
commit beabc6879c
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
util/thread_status_impl.cc
View File

@ -21,13 +21,7 @@ std::unordered_map<const void*, std::unordered_set<const void*>>
ThreadStatusImpl::db_key_map_; ThreadStatusImpl::db_key_map_;
ThreadStatusImpl::~ThreadStatusImpl() { ThreadStatusImpl::~ThreadStatusImpl() {
std::lock_guard<std::mutex> lck(thread_list_mutex_);
for (auto* thread_data : thread_data_set_) {
assert(thread_data->thread_type == ThreadStatus::ThreadType::USER_THREAD);
delete thread_data;
}
assert(thread_data_set_.size() == 0); assert(thread_data_set_.size() == 0);
thread_data_set_.clear();
} }
void ThreadStatusImpl::UnregisterThread() { void ThreadStatusImpl::UnregisterThread() {
@ -35,6 +29,7 @@ void ThreadStatusImpl::UnregisterThread() {
std::lock_guard<std::mutex> lck(thread_list_mutex_); std::lock_guard<std::mutex> lck(thread_list_mutex_);
thread_data_set_.erase(thread_status_data_); thread_data_set_.erase(thread_status_data_);
delete thread_status_data_; delete thread_status_data_;
thread_status_data_ = nullptr;
} }
} }