summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/skip.cpp
diff options
context:
space:
mode:
authorLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-18 17:02:53 -0300
committerLucas de Castro Borges <lucas@gnuabordo.com.br>2025-02-18 17:02:53 -0300
commit959575a5ca598bf5f37fb5cebe7ed1d80d3d71f7 (patch)
treeacc8d60aedb12b70048e676e8a7349deb0010db8 /src/mongo/db/exec/skip.cpp
parent76588293975fc059cf076779e4283e6ffaf8afff (diff)
New upstream version 6.0.20upstream
Diffstat (limited to 'src/mongo/db/exec/skip.cpp')
-rw-r--r--src/mongo/db/exec/skip.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/exec/skip.cpp b/src/mongo/db/exec/skip.cpp
index d3d0fc48afd..755e9278fe0 100644
--- a/src/mongo/db/exec/skip.cpp
+++ b/src/mongo/db/exec/skip.cpp
@@ -47,7 +47,7 @@ SkipStage::SkipStage(ExpressionContext* expCtx,
long long toSkip,
WorkingSet* ws,
std::unique_ptr<PlanStage> child)
- : PlanStage(kStageType, expCtx), _ws(ws), _toSkip(toSkip) {
+ : PlanStage(kStageType, expCtx), _ws(ws), _leftToSkip(toSkip), _skipAmount(toSkip) {
_children.emplace_back(std::move(child));
}
@@ -63,9 +63,9 @@ PlanStage::StageState SkipStage::doWork(WorkingSetID* out) {
if (PlanStage::ADVANCED == status) {
// If we're still skipping results...
- if (_toSkip > 0) {
+ if (_leftToSkip > 0) {
// ...drop the result.
- --_toSkip;
+ --_leftToSkip;
_ws->free(id);
return PlanStage::NEED_TIME;
}
@@ -82,7 +82,7 @@ PlanStage::StageState SkipStage::doWork(WorkingSetID* out) {
unique_ptr<PlanStageStats> SkipStage::getStats() {
_commonStats.isEOF = isEOF();
- _specificStats.skip = _toSkip;
+ _specificStats.skip = _skipAmount;
unique_ptr<PlanStageStats> ret = std::make_unique<PlanStageStats>(_commonStats, STAGE_SKIP);
ret->specific = std::make_unique<SkipStats>(_specificStats);
ret->children.emplace_back(child()->getStats());