summaryrefslogtreecommitdiff
path: root/src/mongo/dbtests/query_stage_keep.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/dbtests/query_stage_keep.cpp')
-rw-r--r--src/mongo/dbtests/query_stage_keep.cpp13
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) {