diff options
| author | Esha Maharishi <esha.maharishi@mongodb.com> | 2017-02-09 15:08:31 -0500 |
|---|---|---|
| committer | Esha Maharishi <esha.maharishi@mongodb.com> | 2017-02-09 18:19:26 -0500 |
| commit | 31e5c31a79b2043d0fa4288c0435fdfce4348343 (patch) | |
| tree | 8c02d5cc58ea067dbc5af6722eccdf16707a9b9c /src/mongo/s/query/store_possible_cursor.cpp | |
| parent | 0e3e4b1dbb3fa475abc29033171e26d194028391 (diff) | |
| download | mongo-31e5c31a79b2043d0fa4288c0435fdfce4348343.tar.gz | |
SERVER-27965 thread OperationContext* down through ClusterClientCursor's next() and kill() methods
Diffstat (limited to 'src/mongo/s/query/store_possible_cursor.cpp')
| -rw-r--r-- | src/mongo/s/query/store_possible_cursor.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
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<BSONObj> storePossibleCursor(const HostAndPort& server, +StatusWith<BSONObj> storePossibleCursor(OperationContext* txn, + const HostAndPort& server, const BSONObj& cmdResult, const NamespaceString& requestedNss, executor::TaskExecutor* executor, @@ -61,10 +62,11 @@ StatusWith<BSONObj> 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); |