[feat][br] Add br backup get job list check. default true.

Author: yuhaijun999

dingo-store-proto

@@ -109,6 +109,21 @@ butil::Status Backup::Init() {
   std::cout << "safe point ts check ok" << std::endl;
   DINGO_LOG(INFO) << "safe point ts check ok";
 
+  // Get the job list to see whether there is a merge split being executed, etc.
+  if (FLAGS_br_backup_enable_get_job_list_check) {
+    status = GetJobListCheck();
+    if (!status.ok()) {
+      DINGO_LOG(ERROR) << Utils::FormatStatusError(status);
+      return status;
+    }
+    std::cout << "br_backup_enable_get_job_list_check is true, get job list check ok" << std::endl;
+    DINGO_LOG(INFO) << "br_backup_enable_get_job_list_check is true, get job list check ok";
+
+  } else {
+    std::cout << "br_backup_enable_get_job_list_check is false, skip get job list check" << std::endl;
+    DINGO_LOG(INFO) << "br_backup_enable_get_job_list_check is false, skip get job list check";
+  }
+
   backup_task_id_ = dingodb::UUIDGenerator::GenerateUUID();
 
   auto lambda_exit_function = [this, &status]() {
@@ -1270,4 +1285,53 @@ butil::Status Backup::DoFinish() {
   return butil::Status::OK();
 }
 
+butil::Status Backup::GetJobListCheck() {
+  dingodb::pb::coordinator::GetJobListRequest request;
+  dingodb::pb::coordinator::GetJobListResponse response;
+
+  request.mutable_request_info()->set_request_id(br::Helper::GetRandInt());
+
+  DINGO_LOG_IF(INFO, FLAGS_br_log_switch_backup_detail_detail) << request.DebugString();
+
+  butil::Status status = br::InteractionManager::GetInstance().GetCoordinatorInteraction()->SendRequest(
+      "CoordinatorService", "GetJobList", request, response);
+  if (!status.ok()) {
+    std::string s = fmt::format("Fail to get job list, status={}", Utils::FormatStatusError(status));
+    DINGO_LOG(ERROR) << s;
+    return status;
+  }
+
+  if (response.error().errcode() != dingodb::pb::error::OK) {
+    std::string s = fmt::format("Fail to get job list, error={}", Utils::FormatResponseError(response));
+    DINGO_LOG(ERROR) << s;
+    return butil::Status(dingodb::pb::error::EINTERNAL, s);
+  }
+
+  DINGO_LOG_IF(INFO, FLAGS_br_log_switch_backup_detail_detail) << response.DebugString();
+
+  for (const auto& job : response.job_list()) {
+    for (const auto& task : job.tasks()) {
+      for (const auto& store_operation : task.store_operations()) {
+        for (const auto& region_cmd : store_operation.region_cmds()) {
+          if (region_cmd.region_cmd_type() == dingodb::pb::coordinator::RegionCmdType::CMD_SPLIT ||
+              region_cmd.region_cmd_type() == dingodb::pb::coordinator::RegionCmdType::CMD_MERGE ||
+              region_cmd.region_cmd_type() == dingodb::pb::coordinator::RegionCmdType::CMD_CHANGE_PEER ||
+              region_cmd.region_cmd_type() == dingodb::pb::coordinator::RegionCmdType::CMD_TRANSFER_LEADER) {
+            std::string s = fmt::format("exist job list, region_cmd_type={}({})",
+                                        dingodb::pb::coordinator::RegionCmdType_Name(region_cmd.region_cmd_type()),
+                                        static_cast<int>(region_cmd.region_cmd_type()));
+            DINGO_LOG(ERROR) << s;
+            status = butil::Status(dingodb::pb::error::EBACKUP_DINGO_STORE_JOB_LIST_EXIST, s);
+            goto _err;
+          }
+        }
+      }
+    }
+  }
+
+_err:
+
+  return status;
+}
+
 }  // namespace br

src/br/backup.cc

@@ -75,6 +75,7 @@ class Backup : public std::enable_shared_from_this<Backup> {
                                       const dingodb::pb::common::VersionInfo& version_info_remote);
 
   butil::Status DoFinish();
+  static butil::Status GetJobListCheck();
 
   std::string coor_url_;
   std::string br_type_;

src/br/backup.h

@@ -117,4 +117,6 @@ DEFINE_string(br_client_method_param1, "", "br client method param1. default emp
 
 DEFINE_bool(just_store, false, "just store server");
 
+DEFINE_bool(br_backup_enable_get_job_list_check, true, "br backup enable get job list check. default true");
+
 }  // namespace br

src/br/parameter.cc

@@ -165,6 +165,8 @@ DECLARE_string(br_client_method_param1);
 
 DECLARE_bool(just_store);
 
+DECLARE_bool(br_backup_enable_get_job_list_check);
+
 }  // namespace br
 
 #endif  // DINGODB_BR_PARAMETER_H_