From 31e5c31a79b2043d0fa4288c0435fdfce4348343 Mon Sep 17 00:00:00 2001 From: Esha Maharishi Date: Thu, 9 Feb 2017 15:08:31 -0500 Subject: SERVER-27965 thread OperationContext* down through ClusterClientCursor's next() and kill() methods --- src/mongo/s/query/store_possible_cursor.cpp | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) (limited to 'src/mongo/s/query/store_possible_cursor.cpp') diff --git a/src/mongo/s/query/store_possible_cursor.cpp b/src/mongo/s/query/store_possible_cursor.cpp index 13477f1e14e..1e3b7d03306 100644 --- a/src/mongo/s/query/store_possible_cursor.cpp +++ b/src/mongo/s/query/store_possible_cursor.cpp @@ -39,7 +39,8 @@ namespace mongo { -StatusWith storePossibleCursor(const HostAndPort& server, +StatusWith storePossibleCursor(OperationContext* txn, + const HostAndPort& server, const BSONObj& cmdResult, const NamespaceString& requestedNss, executor::TaskExecutor* executor, @@ -61,10 +62,11 @@ StatusWith storePossibleCursor(const HostAndPort& server, params.remotes.emplace_back(server, incomingCursorResponse.getValue().getCursorId()); - auto ccc = ClusterClientCursorImpl::make(executor, std::move(params)); + auto ccc = ClusterClientCursorImpl::make(txn, executor, std::move(params)); auto clusterCursorId = - cursorManager->registerCursor(ccc.releaseCursor(), + cursorManager->registerCursor(txn, + ccc.releaseCursor(), requestedNss, ClusterCursorManager::CursorType::NamespaceNotSharded, ClusterCursorManager::CursorLifetime::Mortal); -- cgit v1.2.1