(kvrocks) branch unstable updated: chore: move the migration initialized before calling LoadClusterNodes (#2820)

[hu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hulk pushed a commit to branch unstable
in repository https://gitbox.apache.org/repos/asf/kvrocks.git


The following commit(s) were added to refs/heads/unstable by this push:
     new a85eadd2 chore: move the migration initialized before calling LoadClusterNodes (#2820)
a85eadd2 is described below

commit a85eadd24c17acdca6553bb0544bba5afd9c3955
Author: Rivers <ri...@gmail.com>
AuthorDate: Fri Mar 7 19:23:02 2025 +0800

    chore: move the migration initialized before calling LoadClusterNodes (#2820)
---
 src/server/server.cc | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/server/server.cc b/src/server/server.cc
index 395f972c..253a4802 100644
--- a/src/server/server.cc
+++ b/src/server/server.cc
@@ -176,14 +176,16 @@ Status Server::Start() {
   }
 
   if (config_->cluster_enabled) {
+    // Create objects used for slot migration
+    slot_migrator = std::make_unique<SlotMigrator>(this);
+
     if (config_->persist_cluster_nodes_enabled) {
       auto s = cluster->LoadClusterNodes(config_->NodesFilePath());
       if (!s.IsOK()) {
         return s.Prefixed("failed to load cluster nodes info");
       }
     }
-    // Create objects used for slot migration
-    slot_migrator = std::make_unique<SlotMigrator>(this);
+
     auto s = slot_migrator->CreateMigrationThread();
     if (!s.IsOK()) {
       return s.Prefixed("failed to create migration thread");