diff options
Diffstat (limited to 'src/mongo/db/query/plan_executor_sbe.cpp')
| -rw-r--r-- | src/mongo/db/query/plan_executor_sbe.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/mongo/db/query/plan_executor_sbe.cpp b/src/mongo/db/query/plan_executor_sbe.cpp index 5f9c347f463..9d3f4595b48 100644 --- a/src/mongo/db/query/plan_executor_sbe.cpp +++ b/src/mongo/db/query/plan_executor_sbe.cpp @@ -81,13 +81,16 @@ PlanExecutorSBE::PlanExecutorSBE(OperationContext* opCtx, uassert(4822866, "Query does not have recordId slot.", _resultRecordId); } + sbe::RuntimeEnvironment* env = _rootData.env; if (_rootData.shouldTrackLatestOplogTimestamp) { - _oplogTs = _rootData.env->getAccessor(_rootData.env->getSlot("oplogTs"_sd)); + _oplogTs = env->getAccessor(env->getSlot("oplogTs"_sd)); } if (_rootData.shouldUseTailableScan) { - _resumeRecordIdSlot = _rootData.env->getSlot("resumeRecordId"_sd); + _resumeRecordIdSlot = env->getSlot("resumeRecordId"_sd); } + _minRecordIdSlot = env->getSlotIfExists("minRecordId"_sd); + _maxRecordIdSlot = env->getSlotIfExists("maxRecordId"_sd); if (!_stash.empty()) { // The PlanExecutor keeps an extra reference to the last object pulled out of the PlanStage |