diff options
author | Jason Rassi <rassi@10gen.com> | 2016-01-14 12:58:13 -0500 |
---|---|---|
committer | Jason Rassi <rassi@10gen.com> | 2016-01-14 15:12:38 -0500 |
commit | 09b89f0986550443a13af16b76ef04d91120bb2f (patch) | |
tree | 977b1fa1965ac1cba4e6b39b430e309636832305 /src/mongo/db/exec/skip.cpp | |
parent | 225ac6a226bc34bdae716c17f3b49f5a1a279e4e (diff) | |
download | mongo-09b89f0986550443a13af16b76ef04d91120bb2f.tar.gz |
SERVER-19377 PlanStage: make work() non-virt, add virt method doWork()
Changes PlanStage::work() to be non-virtual. PlanStage::work() now
updates _commonStats and calls new pure virtual method doWork().
Diffstat (limited to 'src/mongo/db/exec/skip.cpp')
-rw-r--r-- | src/mongo/db/exec/skip.cpp | 12 |
1 files changed, 1 insertions, 11 deletions
diff --git a/src/mongo/db/exec/skip.cpp b/src/mongo/db/exec/skip.cpp index 5c5a27a685f..7a353e5219f 100644 --- a/src/mongo/db/exec/skip.cpp +++ b/src/mongo/db/exec/skip.cpp @@ -52,12 +52,7 @@ bool SkipStage::isEOF() { return child()->isEOF(); } -PlanStage::StageState SkipStage::work(WorkingSetID* out) { - ++_commonStats.works; - - // Adds the amount of time taken by work() to executionTimeMillis. - ScopedTimer timer(&_commonStats.executionTimeMillis); - +PlanStage::StageState SkipStage::doWork(WorkingSetID* out) { WorkingSetID id = WorkingSet::INVALID_ID; StageState status = child()->work(&id); @@ -67,12 +62,10 @@ PlanStage::StageState SkipStage::work(WorkingSetID* out) { // ...drop the result. --_toSkip; _ws->free(id); - ++_commonStats.needTime; return PlanStage::NEED_TIME; } *out = id; - ++_commonStats.advanced; return PlanStage::ADVANCED; } else if (PlanStage::FAILURE == status || PlanStage::DEAD == status) { *out = id; @@ -86,10 +79,7 @@ PlanStage::StageState SkipStage::work(WorkingSetID* out) { *out = WorkingSetCommon::allocateStatusMember(_ws, status); } return status; - } else if (PlanStage::NEED_TIME == status) { - ++_commonStats.needTime; } else if (PlanStage::NEED_YIELD == status) { - ++_commonStats.needYield; *out = id; } |