diff --git a/util/env_posix.cc b/util/env_posix.cc index a850ed130..039e79c4a 100644 --- a/util/env_posix.cc +++ b/util/env_posix.cc @@ -1667,14 +1667,18 @@ class PosixEnv : public Env { BGThreadMetadata* meta = reinterpret_cast(arg); size_t thread_id = meta->thread_id_; ThreadPool* tp = meta->thread_pool_; +#if ROCKSDB_USING_THREAD_STATUS // for thread-status thread_local_status.SetThreadType( (tp->GetThreadPriority() == Env::Priority::HIGH ? ThreadStatus::ThreadType::ROCKSDB_HIGH_PRIORITY : ThreadStatus::ThreadType::ROCKSDB_LOW_PRIORITY)); +#endif delete meta; tp->BGThread(thread_id); +#if ROCKSDB_USING_THREAD_STATUS thread_local_status.UnregisterThread(); +#endif return nullptr; }