diff options
Diffstat (limited to 'src/mongo/dbtests/query_stage_keep.cpp')
-rw-r--r-- | src/mongo/dbtests/query_stage_keep.cpp | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/mongo/dbtests/query_stage_keep.cpp b/src/mongo/dbtests/query_stage_keep.cpp index f78a2977300..743d1f7bdd2 100644 --- a/src/mongo/dbtests/query_stage_keep.cpp +++ b/src/mongo/dbtests/query_stage_keep.cpp @@ -66,12 +66,10 @@ namespace QueryStageKeep { } void getLocs(set<RecordId>* out, Collection* coll) { - RecordIterator* it = coll->getIterator(&_txn); - while (!it->isEOF()) { - RecordId nextLoc = it->getNext(); - out->insert(nextLoc); + auto cursor = coll->getCursor(&_txn); + while (auto record = cursor->next()) { + out->insert(record->id); } - delete it; } void insert(const BSONObj& obj) { @@ -154,7 +152,10 @@ namespace QueryStageKeep { ASSERT_EQUALS(member->obj.value()["x"].numberInt(), 1); } - ASSERT(cs->isEOF()); + { + WorkingSetID out; + ASSERT_EQ(cs->work(&out), PlanStage::IS_EOF); + } // Flagged results *must* be at the end. for (size_t i = 0; i < 10; ++i) { |