summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_coordinator.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/migration_coordinator.cpp')
-rw-r--r--src/mongo/db/s/migration_coordinator.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/s/migration_coordinator.cpp b/src/mongo/db/s/migration_coordinator.cpp
index febea6e0fc8..a5c18af46ab 100644
--- a/src/mongo/db/s/migration_coordinator.cpp
+++ b/src/mongo/db/s/migration_coordinator.cpp
@@ -267,7 +267,8 @@ SharedSemiFuture<void> MigrationCoordinator::_commitMigrationOnDonorAndRecipient
auto waitForActiveQueriesToComplete = [&]() {
AutoGetCollection autoColl(opCtx, deletionTask.getNss(), MODE_IS);
- return CollectionShardingRuntime::get(opCtx, deletionTask.getNss())
+ return CollectionShardingRuntime::assertCollectionLockedAndAcquire(
+ opCtx, deletionTask.getNss(), CSRAcquisitionMode::kShared)
->getOngoingQueriesCompletionFuture(deletionTask.getCollectionUuid(),
deletionTask.getRange())
.semi();