Update SQLiteNode.cpp

Expensify · Dec 23, 2024 · bd8d470 · bd8d470
1 parent 2d02306
commit bd8d470
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sqlitecluster/SQLiteNode.cpp b/sqlitecluster/SQLiteNode.cpp
@@ -1287,9 +1287,11 @@ void SQLiteNode::_onMESSAGE(SQLitePeer* peer, const SData& message) {
         if (peer == _leadPeer && currentCommitDifference >= 12'500 && !_blockedCommandPort) {
             SINFO("Node is lagging behind, closing command port so it can catch up.");
             _server.blockCommandPort(blockReason);
+            _blockedCommandPort = true;
         } else if (currentCommitDifference < 1'000 && _blockedCommandPort) {
             SINFO("Node is caught up enough, unblocking command port.");
             _server.unblockCommandPort(blockReason);
+            _blockedCommandPort = false;
         }
         // Classify and process the message
         if (SIEquals(message.methodLine, "LOGIN")) {