summaryrefslogtreecommitdiff
path: root/src/mongo/db/query/find.cpp
diff options
context:
space:
mode:
authorMartin Neupauer <martin.neupauer@mongodb.com>2020-06-11 08:07:39 +0100
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-06-11 11:17:49 +0000
commite3948d4d8817579b6b03618e64e1b9e8cc2ef086 (patch)
tree649bef264a16807b269f7b645a8d2312c4442455 /src/mongo/db/query/find.cpp
parent0af9c85d7e2ba60f592f2d7a9a35217e254e59fb (diff)
downloadmongo-e3948d4d8817579b6b03618e64e1b9e8cc2ef086.tar.gz
SERVER-48228 Move slot-based execution engine and supporting changes into the master branch
This is an initial commit for the slot-based execution engine (SBE) which contains: * Implementation of the core slot-based engine. * The SBE stage builder, which is responsible for translating a QuerySolution tree into an SBE plan. * Other changes necessary for integration with the find command. Co-authored-by: Anton Korshunov <anton.korshunov@mongodb.com> Co-authored-by: Justin Seyster <justin.seyster@mongodb.com> Co-authored-by: David Storch <david.storch@mongodb.com>
Diffstat (limited to 'src/mongo/db/query/find.cpp')
-rw-r--r--src/mongo/db/query/find.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/mongo/db/query/find.cpp b/src/mongo/db/query/find.cpp
index 602e525cb9c..49169ef4ddc 100644
--- a/src/mongo/db/query/find.cpp
+++ b/src/mongo/db/query/find.cpp
@@ -270,7 +270,7 @@ Message getMore(OperationContext* opCtx,
opCtx->setExhaust(cursorPin->queryOptions() & QueryOption_Exhaust);
- if (cursorPin->lockPolicy() == ClientCursorParams::LockPolicy::kLocksInternally) {
+ if (cursorPin->getExecutor()->lockPolicy() == PlanExecutor::LockPolicy::kLocksInternally) {
if (!nss.isCollectionlessCursorNamespace()) {
AutoGetDb autoDb(opCtx, nss.db(), MODE_IS);
statsTracker.emplace(opCtx,
@@ -497,7 +497,7 @@ Message getMore(OperationContext* opCtx,
// info for an aggregation, but the source PlanExecutor could be destroyed before we know if we
// need 'execStats' and we do not want to generate the stats eagerly for all operations due to
// cost.
- if (cursorPin->lockPolicy() != ClientCursorParams::LockPolicy::kLocksInternally &&
+ if (cursorPin->getExecutor()->lockPolicy() != PlanExecutor::LockPolicy::kLocksInternally &&
curOp.shouldDBProfile()) {
BSONObjBuilder execStatsBob;
Explain::getWinningPlanStats(exec, &execStatsBob);
@@ -756,7 +756,6 @@ bool runQuery(OperationContext* opCtx,
opCtx->getWriteConcern(),
readConcernArgs,
upconvertedQuery,
- ClientCursorParams::LockPolicy::kLockExternally,
{Privilege(ResourcePattern::forExactNamespace(nss), ActionType::find)},
false // needsMerge always 'false' for find().
});