From 40cd38f0c4988838a2b0e31799ddfc5a96537b95 Mon Sep 17 00:00:00 2001
From: antirez <antirez@gmail.com>
Date: Wed, 29 Jan 2014 16:01:00 +0100
Subject: [PATCH] Cluster: update node replication offset from bus packets
 headers.

---
 src/cluster.c | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/cluster.c b/src/cluster.c
index 6da1d1f6..7dbfbf93 100644
--- 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. */