summaryrefslogtreecommitdiff
path: root/src/mongo/s/async_requests_sender.cpp
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2019-06-27 15:41:10 -0400
committerRandolph Tan <randolph@10gen.com>2019-07-09 15:24:50 -0400
commitd15b1f2e036e262f8ea976e04780aa366fa20ad4 (patch)
treea999cbb7f411c32855e6ce93f4588a7fd309ace7 /src/mongo/s/async_requests_sender.cpp
parent209bbe879e84b4419295c8195bdbc2929c89e602 (diff)
downloadmongo-d15b1f2e036e262f8ea976e04780aa366fa20ad4.tar.gz
SERVER-40785 Change sharding fixed and arbitrary executors from unique_ptr to shared_ptr
Diffstat (limited to 'src/mongo/s/async_requests_sender.cpp')
-rw-r--r--src/mongo/s/async_requests_sender.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/s/async_requests_sender.cpp b/src/mongo/s/async_requests_sender.cpp
index 494dd4edb8f..0d14cf81015 100644
--- a/src/mongo/s/async_requests_sender.cpp
+++ b/src/mongo/s/async_requests_sender.cpp
@@ -59,7 +59,7 @@ const int kMaxNumFailedHostRetryAttempts = 3;
} // namespace
AsyncRequestsSender::AsyncRequestsSender(OperationContext* opCtx,
- executor::TaskExecutor* executor,
+ std::shared_ptr<executor::TaskExecutor> executor,
StringData dbName,
const std::vector<AsyncRequestsSender::Request>& requests,
const ReadPreferenceSetting& readPreference,
@@ -68,7 +68,7 @@ AsyncRequestsSender::AsyncRequestsSender(OperationContext* opCtx,
_db(dbName.toString()),
_readPreference(readPreference),
_retryPolicy(retryPolicy),
- _subExecutor(executor),
+ _subExecutor(std::move(executor)),
_subBaton(opCtx->getBaton()->makeSubBaton()) {
_remotesLeft = requests.size();