diff options
Diffstat (limited to 'src/mongo/s/query/router_stage_skip.cpp')
-rw-r--r-- | src/mongo/s/query/router_stage_skip.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/s/query/router_stage_skip.cpp b/src/mongo/s/query/router_stage_skip.cpp index a6bec5c8733..6763ca5808b 100644 --- a/src/mongo/s/query/router_stage_skip.cpp +++ b/src/mongo/s/query/router_stage_skip.cpp @@ -39,9 +39,9 @@ RouterStageSkip::RouterStageSkip(std::unique_ptr<RouterExecStage> child, long lo invariant(skip > 0); } -StatusWith<ClusterQueryResult> RouterStageSkip::next(OperationContext* txn) { +StatusWith<ClusterQueryResult> RouterStageSkip::next(OperationContext* opCtx) { while (_skippedSoFar < _skip) { - auto next = getChildStage()->next(txn); + auto next = getChildStage()->next(opCtx); if (!next.isOK()) { return next; } @@ -53,11 +53,11 @@ StatusWith<ClusterQueryResult> RouterStageSkip::next(OperationContext* txn) { ++_skippedSoFar; } - return getChildStage()->next(txn); + return getChildStage()->next(opCtx); } -void RouterStageSkip::kill(OperationContext* txn) { - getChildStage()->kill(txn); +void RouterStageSkip::kill(OperationContext* opCtx) { + getChildStage()->kill(opCtx); } bool RouterStageSkip::remotesExhausted() { |