Update src/cluster_legacy.c

Co-authored-by: Ping Xie <pingxie@outlook.com> Signed-off-by: Binbin <binloveplay1314@qq.com>
valkey-io · Aug 29, 2024 · 7788208 · 7788208
1 parent 87dcb22
commit 7788208
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/cluster_legacy.c b/src/cluster_legacy.c
@@ -3343,8 +3343,7 @@ int clusterProcessPacket(clusterLink *link) {
                          * so we can try a psync. */
                         serverLog(LL_NOTICE, "I'm a sub-replica! Reconfiguring myself as a replica of %.40s from %.40s",
                                   myself->replicaof->replicaof->name, myself->replicaof->name);
-                        int are_in_same_shard = areInSameShard(myself->replicaof->replicaof, myself);
-                        clusterSetPrimary(myself->replicaof->replicaof, 1, !are_in_same_shard);
+                        clusterSetPrimary(myself->replicaof->replicaof, 1, !areInSameShard(myself->replicaof->replicaof, myself));
                         clusterDoBeforeSleep(CLUSTER_TODO_SAVE_CONFIG| CLUSTER_TODO_UPDATE_STATE | CLUSTER_TODO_FSYNC_CONFIG);
                     }