diff options
Diffstat (limited to 'src/mongo/s/query/cluster_cursor_manager.cpp')
| -rw-r--r-- | src/mongo/s/query/cluster_cursor_manager.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/s/query/cluster_cursor_manager.cpp b/src/mongo/s/query/cluster_cursor_manager.cpp index 2b4e68ac2cf..85d396490c6 100644 --- a/src/mongo/s/query/cluster_cursor_manager.cpp +++ b/src/mongo/s/query/cluster_cursor_manager.cpp @@ -110,9 +110,9 @@ ClusterCursorManager::PinnedCursor& ClusterCursorManager::PinnedCursor::operator return *this; } -StatusWith<ClusterQueryResult> ClusterCursorManager::PinnedCursor::next(OperationContext* txn) { +StatusWith<ClusterQueryResult> ClusterCursorManager::PinnedCursor::next(OperationContext* opCtx) { invariant(_cursor); - return _cursor->next(txn); + return _cursor->next(opCtx); } bool ClusterCursorManager::PinnedCursor::isTailable() const { @@ -187,7 +187,7 @@ void ClusterCursorManager::shutdown() { } StatusWith<CursorId> ClusterCursorManager::registerCursor( - OperationContext* txn, + OperationContext* opCtx, std::unique_ptr<ClusterClientCursor> cursor, const NamespaceString& nss, CursorType cursorType, @@ -199,7 +199,7 @@ StatusWith<CursorId> ClusterCursorManager::registerCursor( if (_inShutdown) { lk.unlock(); - cursor->kill(txn); + cursor->kill(opCtx); return Status(ErrorCodes::ShutdownInProgress, "Cannot register new cursors as we are in the process of shutting down"); } @@ -246,7 +246,7 @@ StatusWith<CursorId> ClusterCursorManager::registerCursor( } StatusWith<ClusterCursorManager::PinnedCursor> ClusterCursorManager::checkOutCursor( - const NamespaceString& nss, CursorId cursorId, OperationContext* txn) { + const NamespaceString& nss, CursorId cursorId, OperationContext* opCtx) { // Read the clock out of the lock. const auto now = _clockSource->now(); |