summaryrefslogtreecommitdiff
path: root/src/mongo/s/query/router_stage_limit.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/s/query/router_stage_limit.cpp')
-rw-r--r--src/mongo/s/query/router_stage_limit.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/s/query/router_stage_limit.cpp b/src/mongo/s/query/router_stage_limit.cpp
index 4a1a428a533..ea90251eef6 100644
--- a/src/mongo/s/query/router_stage_limit.cpp
+++ b/src/mongo/s/query/router_stage_limit.cpp
@@ -39,12 +39,12 @@ RouterStageLimit::RouterStageLimit(std::unique_ptr<RouterExecStage> child, long
invariant(limit > 0);
}
-StatusWith<ClusterQueryResult> RouterStageLimit::next(OperationContext* txn) {
+StatusWith<ClusterQueryResult> RouterStageLimit::next(OperationContext* opCtx) {
if (_returnedSoFar >= _limit) {
return {ClusterQueryResult()};
}
- auto childResult = getChildStage()->next(txn);
+ auto childResult = getChildStage()->next(opCtx);
if (!childResult.isOK()) {
return childResult;
}
@@ -55,8 +55,8 @@ StatusWith<ClusterQueryResult> RouterStageLimit::next(OperationContext* txn) {
return childResult;
}
-void RouterStageLimit::kill(OperationContext* txn) {
- getChildStage()->kill(txn);
+void RouterStageLimit::kill(OperationContext* opCtx) {
+ getChildStage()->kill(opCtx);
}
bool RouterStageLimit::remotesExhausted() {