diff options
author | Louis Williams <louis.williams@mongodb.com> | 2021-02-23 16:03:49 -0500 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-02-24 00:42:55 +0000 |
commit | dd395723139d3d04cb05c66136a670102be210f1 (patch) | |
tree | fc64859029e3884270f522e2ae29f24be5b512c3 /src/mongo/db/pipeline/document_source_check_resume_token_test.cpp | |
parent | 24a71228f4bf3ca9051b72f0777bae2286e7182a (diff) | |
download | mongo-dd395723139d3d04cb05c66136a670102be210f1.tar.gz |
SERVER-54008 Generalize CollectionScan to perform queries over RecordId
ranges
Diffstat (limited to 'src/mongo/db/pipeline/document_source_check_resume_token_test.cpp')
-rw-r--r-- | src/mongo/db/pipeline/document_source_check_resume_token_test.cpp | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/mongo/db/pipeline/document_source_check_resume_token_test.cpp b/src/mongo/db/pipeline/document_source_check_resume_token_test.cpp index fbea1ea1076..668596500a0 100644 --- a/src/mongo/db/pipeline/document_source_check_resume_token_test.cpp +++ b/src/mongo/db/pipeline/document_source_check_resume_token_test.cpp @@ -77,6 +77,9 @@ public: boost::optional<Record> seekExact(const RecordId& id) override { return Record{}; } + boost::optional<Record> seekNear(const RecordId& id) override { + return boost::none; + } void save() override {} bool restore() override { return true; @@ -115,7 +118,7 @@ public: _data.push_back(mutableDoc.freeze().toBson()); Record record; record.data = {_data.back().objdata(), _data.back().objsize()}; - record.id = RecordId{static_cast<int64_t>(_data.size())}; + record.id = RecordId{doc["ts"].getTimestamp().asLL()}; _records.push_back(std::move(record)); } @@ -162,9 +165,9 @@ public: : DocumentSourceMock({}, expCtx), _collectionPtr(&_collection) { _filterExpr = BSON("ns" << kTestNs); _filter = MatchExpressionParser::parseAndNormalize(_filterExpr, pExpCtx); - _params.assertMinTsHasNotFallenOffOplog = true; + _params.assertTsHasNotFallenOffOplog = Timestamp(0); _params.shouldTrackLatestOplogTimestamp = true; - _params.minTs = Timestamp(0, 0); + _params.minRecord = RecordId(0); _params.tailable = true; } @@ -172,7 +175,8 @@ public: invariant(!_collScan); _filterExpr = BSON("ns" << kTestNs << "ts" << BSON("$gte" << resumeToken.clusterTime)); _filter = MatchExpressionParser::parseAndNormalize(_filterExpr, pExpCtx); - _params.minTs = resumeToken.clusterTime; + _params.minRecord = RecordId(resumeToken.clusterTime.asLL()); + _params.assertTsHasNotFallenOffOplog = resumeToken.clusterTime; } void push_back(GetNextResult&& result) { |