summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_util.cpp
diff options
context:
space:
mode:
authorJack Mulrow <jack.mulrow@mongodb.com>2020-02-11 16:19:36 +0000
committerevergreen <evergreen@mongodb.com>2020-02-11 16:19:36 +0000
commitdc1270c064fa71529d33395bd031c5965fba2a0b (patch)
treed5679d7b24609b46fd918459c6c9420452d9a8a9 /src/mongo/db/s/migration_util.cpp
parent0e593aa4ea3cc742fef12cf78b479898898756b7 (diff)
downloadmongo-dc1270c064fa71529d33395bd031c5965fba2a0b.tar.gz
SERVER-45577 Submit range deletion tasks on fixed executor
Diffstat (limited to 'src/mongo/db/s/migration_util.cpp')
-rw-r--r--src/mongo/db/s/migration_util.cpp8
1 files changed, 2 insertions, 6 deletions
diff --git a/src/mongo/db/s/migration_util.cpp b/src/mongo/db/s/migration_util.cpp
index 18c06472062..ff3d10e6537 100644
--- a/src/mongo/db/s/migration_util.cpp
+++ b/src/mongo/db/s/migration_util.cpp
@@ -130,11 +130,7 @@ bool checkForConflictingDeletions(OperationContext* opCtx,
ExecutorFuture<bool> submitRangeDeletionTask(OperationContext* opCtx,
const RangeDeletionTask& deletionTask) {
const auto serviceContext = opCtx->getServiceContext();
- // TODO (SERVER-45577): Use the Grid's fixed executor once the refresh is done asynchronously.
- // An arbitrary executor is being used temporarily because unit tests have only one thread in
- // the fixed executor, and that thread is needed to respond to the refresh.
- return ExecutorFuture<void>(
- Grid::get(serviceContext)->getExecutorPool()->getArbitraryExecutor())
+ return ExecutorFuture<void>(Grid::get(serviceContext)->getExecutorPool()->getFixedExecutor())
.then([=] {
ThreadClient tc(kRangeDeletionThreadName, serviceContext);
{
@@ -160,7 +156,7 @@ ExecutorFuture<bool> submitRangeDeletionTask(OperationContext* opCtx,
: " is not known")
<< ", forcing a refresh of " << deletionTask.getNss();
- // TODO (SERVER-45577): Add an asynchronous version of
+ // TODO (SERVER-46075): Add an asynchronous version of
// forceShardFilteringMetadataRefresh to avoid blocking on the network in the
// thread pool.
autoColl.reset();