diff options
author | Jack Mulrow <jack.mulrow@mongodb.com> | 2020-02-11 16:19:36 +0000 |
---|---|---|
committer | evergreen <evergreen@mongodb.com> | 2020-02-11 16:19:36 +0000 |
commit | dc1270c064fa71529d33395bd031c5965fba2a0b (patch) | |
tree | d5679d7b24609b46fd918459c6c9420452d9a8a9 /src/mongo/db/s/migration_util.cpp | |
parent | 0e593aa4ea3cc742fef12cf78b479898898756b7 (diff) | |
download | mongo-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.cpp | 8 |
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(); |