Loading core/src/db/DBImpl.cpp +9 −9 Original line number Diff line number Diff line Loading @@ -71,12 +71,12 @@ DBImpl::Start() { return Status::OK(); } ENGINE_LOG_TRACE << "DB service start"; // ENGINE_LOG_TRACE << "DB service start"; shutting_down_.store(false, std::memory_order_release); // for distribute version, some nodes are read only if (options_.mode_ != DBOptions::MODE::CLUSTER_READONLY) { ENGINE_LOG_TRACE << "StartTimerTasks"; // ENGINE_LOG_TRACE << "StartTimerTasks"; bg_timer_thread_ = std::thread(&DBImpl::BackgroundTimerTask, this); } Loading @@ -101,7 +101,7 @@ DBImpl::Stop() { meta_ptr_->CleanUp(); } ENGINE_LOG_TRACE << "DB service stop"; // ENGINE_LOG_TRACE << "DB service stop"; return Status::OK(); } Loading Loading @@ -506,7 +506,7 @@ DBImpl::StartMetricTask() { return; } ENGINE_LOG_TRACE << "Start metric task"; // ENGINE_LOG_TRACE << "Start metric task"; server::Metrics::GetInstance().KeepingAliveCounterIncrement(METRIC_ACTION_INTERVAL); int64_t cache_usage = cache::CpuCacheMgr::GetInstance()->CacheUsage(); Loading @@ -532,7 +532,7 @@ DBImpl::StartMetricTask() { server::Metrics::GetInstance().GPUTemperature(); server::Metrics::GetInstance().CPUTemperature(); ENGINE_LOG_TRACE << "Metric task finished"; // ENGINE_LOG_TRACE << "Metric task finished"; } Status Loading Loading @@ -692,7 +692,7 @@ DBImpl::BackgroundMergeFiles(const std::string& table_id) { void DBImpl::BackgroundCompaction(std::set<std::string> table_ids) { ENGINE_LOG_TRACE << " Background compaction thread start"; // ENGINE_LOG_TRACE << " Background compaction thread start"; Status status; for (auto& table_id : table_ids) { Loading @@ -715,7 +715,7 @@ DBImpl::BackgroundCompaction(std::set<std::string> table_ids) { } meta_ptr_->CleanUpFilesWithTTL(ttl); ENGINE_LOG_TRACE << " Background compaction thread exit"; // ENGINE_LOG_TRACE << " Background compaction thread exit"; } void Loading Loading @@ -748,7 +748,7 @@ DBImpl::StartBuildIndexTask(bool force) { void DBImpl::BackgroundBuildIndex() { ENGINE_LOG_TRACE << "Background build index thread start"; // ENGINE_LOG_TRACE << "Background build index thread start"; std::unique_lock<std::mutex> lock(build_index_mutex_); meta::TableFilesSchema to_index_files; Loading @@ -771,7 +771,7 @@ DBImpl::BackgroundBuildIndex() { } } ENGINE_LOG_TRACE << "Background build index thread exit"; // ENGINE_LOG_TRACE << "Background build index thread exit"; } } // namespace engine Loading Loading
core/src/db/DBImpl.cpp +9 −9 Original line number Diff line number Diff line Loading @@ -71,12 +71,12 @@ DBImpl::Start() { return Status::OK(); } ENGINE_LOG_TRACE << "DB service start"; // ENGINE_LOG_TRACE << "DB service start"; shutting_down_.store(false, std::memory_order_release); // for distribute version, some nodes are read only if (options_.mode_ != DBOptions::MODE::CLUSTER_READONLY) { ENGINE_LOG_TRACE << "StartTimerTasks"; // ENGINE_LOG_TRACE << "StartTimerTasks"; bg_timer_thread_ = std::thread(&DBImpl::BackgroundTimerTask, this); } Loading @@ -101,7 +101,7 @@ DBImpl::Stop() { meta_ptr_->CleanUp(); } ENGINE_LOG_TRACE << "DB service stop"; // ENGINE_LOG_TRACE << "DB service stop"; return Status::OK(); } Loading Loading @@ -506,7 +506,7 @@ DBImpl::StartMetricTask() { return; } ENGINE_LOG_TRACE << "Start metric task"; // ENGINE_LOG_TRACE << "Start metric task"; server::Metrics::GetInstance().KeepingAliveCounterIncrement(METRIC_ACTION_INTERVAL); int64_t cache_usage = cache::CpuCacheMgr::GetInstance()->CacheUsage(); Loading @@ -532,7 +532,7 @@ DBImpl::StartMetricTask() { server::Metrics::GetInstance().GPUTemperature(); server::Metrics::GetInstance().CPUTemperature(); ENGINE_LOG_TRACE << "Metric task finished"; // ENGINE_LOG_TRACE << "Metric task finished"; } Status Loading Loading @@ -692,7 +692,7 @@ DBImpl::BackgroundMergeFiles(const std::string& table_id) { void DBImpl::BackgroundCompaction(std::set<std::string> table_ids) { ENGINE_LOG_TRACE << " Background compaction thread start"; // ENGINE_LOG_TRACE << " Background compaction thread start"; Status status; for (auto& table_id : table_ids) { Loading @@ -715,7 +715,7 @@ DBImpl::BackgroundCompaction(std::set<std::string> table_ids) { } meta_ptr_->CleanUpFilesWithTTL(ttl); ENGINE_LOG_TRACE << " Background compaction thread exit"; // ENGINE_LOG_TRACE << " Background compaction thread exit"; } void Loading Loading @@ -748,7 +748,7 @@ DBImpl::StartBuildIndexTask(bool force) { void DBImpl::BackgroundBuildIndex() { ENGINE_LOG_TRACE << "Background build index thread start"; // ENGINE_LOG_TRACE << "Background build index thread start"; std::unique_lock<std::mutex> lock(build_index_mutex_); meta::TableFilesSchema to_index_files; Loading @@ -771,7 +771,7 @@ DBImpl::BackgroundBuildIndex() { } } ENGINE_LOG_TRACE << "Background build index thread exit"; // ENGINE_LOG_TRACE << "Background build index thread exit"; } } // namespace engine Loading