From 7d3c60e9562369c60f583051f3b7eb65a7d10337 Mon Sep 17 00:00:00 2001
From: starlord <chxiehust@gmail.com>
Date: Mon, 15 Jul 2019 19:24:20 +0800
Subject: [PATCH] avoid background merge thread stop

Former-commit-id: 9dca4b821b870fa6167ca4e0bab3febe5eb98169
---
 cpp/src/db/DBImpl.cpp | 5 ++---
 cpp/src/db/DBImpl.h   | 2 --
 2 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/cpp/src/db/DBImpl.cpp b/cpp/src/db/DBImpl.cpp
index 55fc9cea5a..6e4c49fc35 100644
--- a/cpp/src/db/DBImpl.cpp
+++ b/cpp/src/db/DBImpl.cpp
@@ -235,7 +235,6 @@ void DBImpl::BackgroundTimerTask() {
     Status status;
     server::SystemInfo::GetInstance().Init();
     while (true) {
-        if (!bg_error_.ok()) break;
         if (shutting_down_.load(std::memory_order_acquire)){
             for(auto& iter : compact_thread_results_) {
                 iter.wait();
@@ -398,7 +397,7 @@ void DBImpl::BackgroundCompaction(std::set<std::string> table_ids) {
     for (auto& table_id : table_ids) {
         status = BackgroundMergeFiles(table_id);
         if (!status.ok()) {
-            bg_error_ = status;
+            ENGINE_LOG_ERROR << "Merge files for table " << table_id << " failed: " << status.ToString();
             return;
         }
     }
@@ -544,7 +543,7 @@ void DBImpl::BackgroundBuildIndex() {
         /* ENGINE_LOG_DEBUG << "Buiding index for " << file.location; */
         status = BuildIndex(file);
         if (!status.ok()) {
-            bg_error_ = status;
+            ENGINE_LOG_ERROR << "Building index for " << file.id_ << " failed: " << status.ToString();
             return;
         }
 
diff --git a/cpp/src/db/DBImpl.h b/cpp/src/db/DBImpl.h
index 1309154a3c..73d28779b7 100644
--- a/cpp/src/db/DBImpl.h
+++ b/cpp/src/db/DBImpl.h
@@ -118,10 +118,8 @@ class DBImpl : public DB {
     BuildIndex(const meta::TableFileSchema &);
 
  private:
-
     const Options options_;
 
-    Status bg_error_;
     std::atomic<bool> shutting_down_;
 
     std::thread bg_timer_thread_;