Fix don't log the error if the importer isn't in started state

apache · Apr 28, 2024 · ed9fabc · ed9fabc
1 parent 1f03a55
commit ed9fabc
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/src/cluster/cluster.cc b/src/cluster/cluster.cc
@@ -333,24 +333,24 @@ Status Cluster::ImportSlot(redis::Connection *conn, int slot, int state) {
       conn->SetImporting();
       myself_->importing_slot = slot;
       // Set link error callback
-      conn->close_cb = [object_ptr = srv_->slot_import.get()](int fd) {
+      conn->close_cb = [object_ptr = srv_->slot_import.get()](int fd, int slot) {
         auto s = object_ptr->StopForLinkError();
         if (!s.IsOK()) {
-          LOG(ERROR) << "[import] Failed to stop importing slot: " << s.Msg();
+          LOG(ERROR) << fmt::format("[import] Failed to stop importing slot {}: {}", slot, s.Msg());
         }
       };  // Stop forbidding writing slot to accept write commands
       if (slot == srv_->slot_migrator->GetForbiddenSlot()) srv_->slot_migrator->ReleaseForbiddenSlot();
-      LOG(INFO) << "[import] Start importing slot " << slot;
+      LOG(INFO) << fmt::format("[import] Start importing slot {}", slot);
       break;
     case kImportSuccess:
       s = srv_->slot_import->Success(slot);
       if (!s.IsOK()) return s;
-      LOG(INFO) << "[import] Mark the importing slot as succeed" << slot;
+      LOG(INFO) << fmt::format("[import] Mark the importing slot {} as succeed", slot);
       break;
     case kImportFailed:
       s = srv_->slot_import->Fail(slot);
       if (!s.IsOK()) return s;
-      LOG(INFO) << "[import] Mark the importing slot as failed" << slot;
+      LOG(INFO) << fmt::format("[import] Mark the importing slot {} as failed", slot);
       break;
     default:
       return {Status::NotOK, errInvalidImportState};

diff --git a/src/cluster/slot_import.cc b/src/cluster/slot_import.cc
@@ -82,7 +82,8 @@ Status SlotImport::Fail(int slot) {
 
 Status SlotImport::StopForLinkError() {
   std::lock_guard<std::mutex> guard(mutex_);
-  if (import_status_ != kImportStart) return {Status::NotOK, "no slot is importing"};
+  // We don't need to do anything if the importer is not started yet.
+  if (import_status_ != kImportStart) return Status::OK();
 
   // Maybe server has failovered
   // Situation: