diff options
| author | Nikita Lapkov <nikita.lapkov@mongodb.com> | 2020-11-04 16:49:42 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-11-09 12:38:01 +0000 |
| commit | a4c597067a26e71859ca07de33dacde98c1747f1 (patch) | |
| tree | 744177b24f3693facdc5165e1c84a500b5420e67 /src/mongo/db/query/plan_executor_sbe.cpp | |
| parent | b806ef292dad8608db70cefe97cc90a1603182ca (diff) | |
| download | mongo-a4c597067a26e71859ca07de33dacde98c1747f1.tar.gz | |
SERVER-50905: Add RecordId type in SBE
Diffstat (limited to 'src/mongo/db/query/plan_executor_sbe.cpp')
| -rw-r--r-- | src/mongo/db/query/plan_executor_sbe.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/query/plan_executor_sbe.cpp b/src/mongo/db/query/plan_executor_sbe.cpp index 875956d117e..30d2e2dc602 100644 --- a/src/mongo/db/query/plan_executor_sbe.cpp +++ b/src/mongo/db/query/plan_executor_sbe.cpp @@ -217,7 +217,7 @@ PlanExecutor::ExecState PlanExecutorSBE::getNext(BSONObj* out, RecordId* dlOut) uassert(4946306, "Collection scan was asked to track resume token, but found a result " "without a valid RecordId", - tag == sbe::value::TypeTags::NumberInt64 || + tag == sbe::value::TypeTags::RecordId || tag == sbe::value::TypeTags::Nothing); _env->resetSlot(*_resumeRecordIdSlot, tag, val, false); } @@ -276,7 +276,7 @@ BSONObj PlanExecutorSBE::getPostBatchResumeToken() const { str::stream() << "Collection scan was asked to track resume token, " "but found a result without a valid RecordId: " << msgTag, - tag == sbe::value::TypeTags::NumberInt64); + tag == sbe::value::TypeTags::RecordId); return BSON("$recordId" << sbe::value::bitcastTo<int64_t>(val)); } } @@ -313,7 +313,7 @@ sbe::PlanState fetchNext(sbe::PlanStage* root, if (dlOut) { invariant(recordIdSlot); auto [tag, val] = recordIdSlot->getViewOfValue(); - if (tag == sbe::value::TypeTags::NumberInt64) { + if (tag == sbe::value::TypeTags::RecordId) { *dlOut = RecordId{sbe::value::bitcastTo<int64_t>(val)}; } } |