summaryrefslogtreecommitdiff
path: root/src/mongo/transport
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/transport')
-rw-r--r--src/mongo/transport/asio/asio_transport_layer.cpp7
-rw-r--r--src/mongo/transport/session_workflow_test.cpp4
2 files changed, 5 insertions, 6 deletions
diff --git a/src/mongo/transport/asio/asio_transport_layer.cpp b/src/mongo/transport/asio/asio_transport_layer.cpp
index a31bec2aa06..0c1997d05aa 100644
--- a/src/mongo/transport/asio/asio_transport_layer.cpp
+++ b/src/mongo/transport/asio/asio_transport_layer.cpp
@@ -483,7 +483,7 @@ public:
// Then, if the numeric (IP address) lookup failed, we fall back to DNS or return the error
// from the resolver.
return _resolve(peer, flags | Resolver::numeric_host, enableIPv6)
- .onError([=](Status) { return _resolve(peer, flags, enableIPv6); })
+ .onError([=, this](Status) { return _resolve(peer, flags, enableIPv6); })
.getNoThrow();
}
@@ -495,9 +495,8 @@ public:
// We follow the same numeric -> hostname fallback procedure as the synchronous resolver
// function for setting resolver flags (see above).
const auto flags = Resolver::numeric_service;
- return _asyncResolve(peer, flags | Resolver::numeric_host, enableIPv6).onError([=](Status) {
- return _asyncResolve(peer, flags, enableIPv6);
- });
+ return _asyncResolve(peer, flags | Resolver::numeric_host, enableIPv6)
+ .onError([=, this](Status) { return _asyncResolve(peer, flags, enableIPv6); });
}
void cancel() {
diff --git a/src/mongo/transport/session_workflow_test.cpp b/src/mongo/transport/session_workflow_test.cpp
index ad87fad7a29..7406f369ffa 100644
--- a/src/mongo/transport/session_workflow_test.cpp
+++ b/src/mongo/transport/session_workflow_test.cpp
@@ -336,7 +336,7 @@ private:
std::unique_ptr<MockServiceEntryPoint> _makeServiceEntryPoint(ServiceContext* sc) {
auto sep = std::make_unique<MockServiceEntryPoint>(sc);
- sep->handleRequestCb = [=](OperationContext* opCtx, const Message& msg) {
+ sep->handleRequestCb = [=, this](OperationContext* opCtx, const Message& msg) {
if (!gInitialUseDedicatedThread) {
// Simulates an async command implemented under the borrowed
// thread model. The returned future will be fulfilled while
@@ -359,7 +359,7 @@ private:
}
return _onMockEvent<Event::sepHandleRequest>(std::tie(opCtx, msg));
};
- sep->onEndSessionCb = [=](const std::shared_ptr<Session>& session) {
+ sep->onEndSessionCb = [=, this](const std::shared_ptr<Session>& session) {
_onMockEvent<Event::sepEndSession>(std::tie(session));
};
sep->derivedOnClientDisconnectCb = [&](Client*) {