summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/initial_syncer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/initial_syncer.cpp')
-rw-r--r--src/mongo/db/repl/initial_syncer.cpp15
1 files changed, 10 insertions, 5 deletions
diff --git a/src/mongo/db/repl/initial_syncer.cpp b/src/mongo/db/repl/initial_syncer.cpp
index 3aaa4ea6dcc..e1f7171634e 100644
--- a/src/mongo/db/repl/initial_syncer.cpp
+++ b/src/mongo/db/repl/initial_syncer.cpp
@@ -445,11 +445,16 @@ void InitialSyncer::_startInitialSyncAttemptCallback(
const executor::TaskExecutor::CallbackArgs& callbackArgs,
std::uint32_t initialSyncAttempt,
std::uint32_t initialSyncMaxAttempts) noexcept {
- auto status = _checkForShutdownAndConvertStatus_inlock(
- callbackArgs,
- str::stream() << "error while starting initial sync attempt " << (initialSyncAttempt + 1)
- << " of "
- << initialSyncMaxAttempts);
+ auto status = [&] {
+ stdx::lock_guard<stdx::mutex> lock(_mutex);
+ return _checkForShutdownAndConvertStatus_inlock(
+ callbackArgs,
+ str::stream() << "error while starting initial sync attempt "
+ << (initialSyncAttempt + 1)
+ << " of "
+ << initialSyncMaxAttempts);
+ }();
+
if (!status.isOK()) {
_finishInitialSyncAttempt(status);
return;