Skip to content

Commit

Permalink
Throw in a way that will get handled and retried
Browse files Browse the repository at this point in the history
  • Loading branch information
tylerkaraszewski committed Oct 5, 2023
1 parent ac0a516 commit cf9e098
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion sqlitecluster/SQLiteNode.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1657,7 +1657,7 @@ void SQLiteNode::_onMESSAGE(SQLitePeer* peer, const SData& message) {
thread(&SQLiteNode::_replicate, this, peer, message, _dbPool->getIndex(false), threadAttemptStartTimestamp).detach();
} catch (const system_error& e) {
SWARN("Caught system_error starting _replicate thread with " << _replicationThreadCount.load() << " threads. e.what()=" << e.what());
throw;
STHROW("Error starting replicate thread so giving up and reconnecting.");
}
SDEBUG("Done spawning concurrent replicate thread: " << threadID);
}
Expand Down

0 comments on commit cf9e098

Please sign in to comment.