Only stop replicate thread if it was started

Expensify · Jan 14, 2025 · 635ba5c · 635ba5c
1 parent 89e2a3b
commit 635ba5c
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/sqlitecluster/SQLiteNode.cpp b/sqlitecluster/SQLiteNode.cpp
@@ -1817,12 +1817,14 @@ void SQLiteNode::_changeState(SQLiteNodeState newState, uint64_t commitIDToCance
 
         // If we were following, and now we're not, we give up an any replications.
         if (_state == SQLiteNodeState::FOLLOWING) {
-            _replicateThreadShouldExit = true;
-            _replicateCV.notify_one();
-            _replicateThread->join();
-            delete _replicateThread;
-            _replicateThread = nullptr;
-            _replicateThreadShouldExit = false;
+            if (_replicateThread) {
+                _replicateThreadShouldExit = true;
+                _replicateCV.notify_one();
+                _replicateThread->join();
+                delete _replicateThread;
+                _replicateThread = nullptr;
+                _replicateThreadShouldExit = false;
+            }
 
             // We have no leader anymore.
             _leadPeer = nullptr;