summaryrefslogtreecommitdiff
path: root/src/mongo/executor
diff options
context:
space:
mode:
authorMatt Broadstone <mbroadst@mongodb.com>2023-04-26 10:27:50 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2023-04-26 12:51:44 +0000
commit7c1ed6898f9004cf7aa9b2e16371fa83c72b3ba3 (patch)
tree5d1af598ff00c60fa59c8f5dd43c4c208b759b57 /src/mongo/executor
parent4052ce367a9a01bb92872e15ca69ffdf4465174c (diff)
downloadmongo-7c1ed6898f9004cf7aa9b2e16371fa83c72b3ba3.tar.gz
SERVER-75529 Reduce the width of NamespaceString
Diffstat (limited to 'src/mongo/executor')
-rw-r--r--src/mongo/executor/async_rpc.cpp4
-rw-r--r--src/mongo/executor/mock_async_rpc.h3
2 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/executor/async_rpc.cpp b/src/mongo/executor/async_rpc.cpp
index a9bb1f0e6b7..9a0986c87e5 100644
--- a/src/mongo/executor/async_rpc.cpp
+++ b/src/mongo/executor/async_rpc.cpp
@@ -59,7 +59,7 @@ public:
auto targetsUsed = std::make_shared<std::vector<HostAndPort>>();
return targeter->resolve(token)
.thenRunOn(proxyExec)
- .then([dbName,
+ .then([dbName = dbName.toString(),
cmdBSON,
opCtx,
exec = std::move(exec),
@@ -70,7 +70,7 @@ public:
"Successful targeting implies there are hosts to target.");
*targetsUsed = targets;
executor::RemoteCommandRequestOnAny executorRequest(
- targets, dbName.toString(), cmdBSON, rpc::makeEmptyMetadata(), opCtx);
+ targets, dbName, cmdBSON, rpc::makeEmptyMetadata(), opCtx);
return exec->scheduleRemoteCommandOnAny(executorRequest, token, std::move(baton));
})
.onError([targetsUsed](Status s) -> StatusWith<TaskExecutor::ResponseOnAnyStatus> {
diff --git a/src/mongo/executor/mock_async_rpc.h b/src/mongo/executor/mock_async_rpc.h
index 1f6b34e3078..5af1ae70d07 100644
--- a/src/mongo/executor/mock_async_rpc.h
+++ b/src/mongo/executor/mock_async_rpc.h
@@ -109,7 +109,8 @@ public:
.onError([](Status s) -> StatusWith<std::vector<HostAndPort>> {
return Status{AsyncRPCErrorInfo(s), "Remote command execution failed"};
})
- .then([=, f = std::move(f), p = std::move(p)](auto&& targets) mutable {
+ .then([=, f = std::move(f), p = std::move(p), dbName = dbName.toString()](
+ auto&& targets) mutable {
stdx::lock_guard lg{_m};
*targetsAttempted = targets;
_requests.emplace_back(cmdBSON, dbName, targets[0], std::move(p));