diff options
author | Hari Khalsa <hkhalsa@10gen.com> | 2013-09-18 11:57:21 -0400 |
---|---|---|
committer | Hari Khalsa <hkhalsa@10gen.com> | 2013-09-18 16:42:20 -0400 |
commit | 311ebc33f399b555309ee6eba04af8c605108529 (patch) | |
tree | be50e3cfea0c124759ded943a5d1c7cc5a79910b /src/mongo/db/exec/and_sorted.cpp | |
parent | de25d5b966fae434669df47b41c076445d2303f6 (diff) | |
download | mongo-311ebc33f399b555309ee6eba04af8c605108529.tar.gz |
SERVER-10026 enumeration as strategies, bug fixes galore, build plans
Diffstat (limited to 'src/mongo/db/exec/and_sorted.cpp')
-rw-r--r-- | src/mongo/db/exec/and_sorted.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/exec/and_sorted.cpp b/src/mongo/db/exec/and_sorted.cpp index 0ffdb43b326..c3241eb8e4b 100644 --- a/src/mongo/db/exec/and_sorted.cpp +++ b/src/mongo/db/exec/and_sorted.cpp @@ -60,7 +60,7 @@ namespace mongo { // If we don't have any nodes that we're work()-ing until they hit a certain DiskLoc... if (0 == _workingTowardRep.size()) { // Get a target DiskLoc. - return getTargetLoc(); + return getTargetLoc(out); } // Move nodes toward the target DiskLoc. @@ -69,7 +69,7 @@ namespace mongo { return moveTowardTargetLoc(out); } - PlanStage::StageState AndSortedStage::getTargetLoc() { + PlanStage::StageState AndSortedStage::getTargetLoc(WorkingSetID* out) { verify(numeric_limits<size_t>::max() == _targetNode); verify(WorkingSet::INVALID_ID == _targetId); verify(DiskLoc() == _targetLoc); @@ -104,6 +104,7 @@ namespace mongo { } else { if (PlanStage::NEED_FETCH == state) { + *out = id; ++_commonStats.needFetch; } else if (PlanStage::NEED_TIME == state) { @@ -200,6 +201,7 @@ namespace mongo { } else { if (PlanStage::NEED_FETCH == state) { + *out = id; ++_commonStats.needFetch; } else if (PlanStage::NEED_TIME == state) { |