check for future times for leader commit msgs

Expensify · May 15, 2020 · 60113cc · 60113cc
1 parent c682e99
commit 60113cc
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/sqlitecluster/SQLiteNode.cpp b/sqlitecluster/SQLiteNode.cpp
@@ -2259,6 +2259,11 @@ void SQLiteNode::handleBeginTransaction(Peer* peer, const SData& message) {
         commandIt->second->transaction = message;
     }
 
+    // calculate and log replication timers
+    if (leaderSentTimestamp > followerDequeueTimestamp) {
+        SWARN("Leader replication timestamp is " << (leaderSentTimestamp - followerDequeueTimestamp) << " usecs newer than our timestamp. Possible clock synchronization issue.");
+        leaderSentTimestamp = followerDequeueTimestamp;
+    }
     uint64_t transitTimeUS = followerDequeueTimestamp - leaderSentTimestamp;
     uint64_t applyTimeUS = STimeNow() - followerDequeueTimestamp;
     float transitTimeMS = (float)transitTimeUS / 1000.0;