diff options
| author | Abdul Qadeer <abdul.qadeer@mongodb.com> | 2022-11-16 17:02:21 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-11-16 22:35:52 +0000 |
| commit | 24ea1d6cd7e1f34c77c81856bb5b27124247a57f (patch) | |
| tree | d14665933fb387d247ae93fcb2fcc44381e8025b | |
| parent | 29296c1ed9d000f761d908e1c32363acb0802568 (diff) | |
| download | mongo-24ea1d6cd7e1f34c77c81856bb5b27124247a57f.tar.gz | |
SERVER-71383 Add cleanup executor for scoped executor shutdown
(cherry picked from commit 92b2f2d4bf503dfe9a9bf2cc02770f7a66b8c2a1)
| -rw-r--r-- | src/mongo/db/s/resharding/resharding_coordinator_service.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/mongo/db/s/resharding/resharding_coordinator_service.cpp b/src/mongo/db/s/resharding/resharding_coordinator_service.cpp index dc1ea0d4cef..817f7f58875 100644 --- a/src/mongo/db/s/resharding/resharding_coordinator_service.cpp +++ b/src/mongo/db/s/resharding/resharding_coordinator_service.cpp @@ -1387,6 +1387,7 @@ SemiFuture<void> ReshardingCoordinator::run(std::shared_ptr<executor::ScopedTask _cancelableOpCtxFactory.emplace(_ctHolder->getAbortToken(), _markKilledExecutor); return _isReshardingOpRedundant(executor) + .thenRunOn(_coordinatorService->getInstanceCleanupExecutor()) .onCompletion([this, self = shared_from_this(), executor]( StatusWith<bool> shardKeyMatchesSW) -> ExecutorFuture<void> { if (shardKeyMatchesSW.isOK() && shardKeyMatchesSW.getValue()) { |