diff options
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)}; } } |