Skip to content

Commit

Permalink
change state to searching
Browse files Browse the repository at this point in the history
  • Loading branch information
danieldoglas committed Jun 4, 2024
1 parent d2053e5 commit a8ef77d
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion sqlitecluster/SQLiteNode.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1723,7 +1723,8 @@ void SQLiteNode::_onMESSAGE(SQLitePeer* peer, const SData& message) {
uint64_t cancelAfter = message.calcU64("NewCount") - 1;
_localCommitNotifier.cancel(cancelAfter);
_leaderCommitNotifier.cancel(cancelAfter);
SWARN("Caught system_error starting _replicate thread with" << _replicationThreadCount.load() << " threads. cancelAfter=" << cancelAfter << " e.what()=" << e.what());
_changeState(SQLiteNodeState::SEARCHING);
SWARN("Caught system_error starting _replicate thread with" << _replicationThreadCount.load() << " threads. cancelAfter="<< cancelAfter << " e.what()=" << e.what());
STHROW("Error starting replicate thread so giving up and reconnecting.");
}
SDEBUG("Done spawning concurrent replicate thread: " << threadID);
Expand Down

0 comments on commit a8ef77d

Please sign in to comment.