diff options
| author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2023-01-12 14:58:50 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-01-12 16:02:09 +0000 |
| commit | dc3f7b70dc813440ca2bf3e260f30d0e4d445bef (patch) | |
| tree | 0668c7cace02d85416bca3c423566bd012735a10 /src/mongo/db/repl/rollback_impl.cpp | |
| parent | bcb06e83ad5a2f678c1b9d76bcaa96ce34e8b7bc (diff) | |
| download | mongo-dc3f7b70dc813440ca2bf3e260f30d0e4d445bef.tar.gz | |
SERVER-72736 Pull `Collection::makePlanExecutor` up into the query layer
Diffstat (limited to 'src/mongo/db/repl/rollback_impl.cpp')
| -rw-r--r-- | src/mongo/db/repl/rollback_impl.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/mongo/db/repl/rollback_impl.cpp b/src/mongo/db/repl/rollback_impl.cpp index a1cec2f9309..c4a9c84a19e 100644 --- a/src/mongo/db/repl/rollback_impl.cpp +++ b/src/mongo/db/repl/rollback_impl.cpp @@ -48,6 +48,7 @@ #include "mongo/db/index_builds_coordinator.h" #include "mongo/db/logical_time_validator.h" #include "mongo/db/operation_context.h" +#include "mongo/db/query/get_executor.h" #include "mongo/db/repl/apply_ops.h" #include "mongo/db/repl/drop_pending_collection_reaper.h" #include "mongo/db/repl/replication_coordinator.h" @@ -715,10 +716,10 @@ void RollbackImpl::_correctRecordStoreCounts(OperationContext* opCtx) { invariant(coll == collToScan.getCollection(), str::stream() << "Catalog returned invalid collection: " << nss.ns() << " (" << uuid.toString() << ")"); - auto exec = collToScan->makePlanExecutor(opCtx, - collToScan.getCollection(), - PlanYieldPolicy::YieldPolicy::INTERRUPT_ONLY, - Collection::ScanDirection::kForward); + auto exec = getCollectionScanExecutor(opCtx, + collToScan.getCollection(), + PlanYieldPolicy::YieldPolicy::INTERRUPT_ONLY, + CollectionScanDirection::kForward); long long countFromScan = 0; PlanExecutor::ExecState state; while (PlanExecutor::ADVANCED == |