Cluster: update node replication offset from bus packets headers.

40cd38f0 · antirez · 9d4ded7e · 40cd38f0
隐藏空白更改
内联并排

Showing with 3 addition and 0 deletion

src/cluster.c src/cluster.c +3 -0

未找到文件。
--- a/src/cluster.c
+++ b/src/cluster.c
@@ -1181,6 +1181,9 @@ int clusterProcessPacket(clusterLink *link) {
            sender->configEpoch = senderConfigEpoch;
            clusterDoBeforeSleep(CLUSTER_TODO_SAVE_CONFIG|CLUSTER_TODO_FSYNC_CONFIG);
        }
+        /* Update the replication offset info for this node. */
+        sender->repl_offset = ntohu64(hdr->offset);
+        sender->repl_offset_time = mstime();
    }

    /* Process packets by type. */