summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/sbe/parser/parser.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/exec/sbe/parser/parser.cpp')
-rw-r--r--src/mongo/db/exec/sbe/parser/parser.cpp12
1 files changed, 8 insertions, 4 deletions
diff --git a/src/mongo/db/exec/sbe/parser/parser.cpp b/src/mongo/db/exec/sbe/parser/parser.cpp
index 49bd40b3cbc..0c17e710f3d 100644
--- a/src/mongo/db/exec/sbe/parser/parser.cpp
+++ b/src/mongo/db/exec/sbe/parser/parser.cpp
@@ -574,7 +574,8 @@ void Parser::walkScan(AstQuery& ast) {
boost::none,
forward,
nullptr,
- getCurrentPlanNodeId());
+ getCurrentPlanNodeId(),
+ LockAcquisitionCallback{});
}
void Parser::walkParallelScan(AstQuery& ast) {
@@ -642,7 +643,8 @@ void Parser::walkSeek(AstQuery& ast) {
lookupSlot(ast.nodes[0]->identifier),
true /* forward */,
nullptr,
- getCurrentPlanNodeId());
+ getCurrentPlanNodeId(),
+ LockAcquisitionCallback{});
}
void Parser::walkIndexScan(AstQuery& ast) {
@@ -692,7 +694,8 @@ void Parser::walkIndexScan(AstQuery& ast) {
boost::none,
boost::none,
nullptr,
- getCurrentPlanNodeId());
+ getCurrentPlanNodeId(),
+ LockAcquisitionCallback{});
}
void Parser::walkIndexSeek(AstQuery& ast) {
@@ -742,7 +745,8 @@ void Parser::walkIndexSeek(AstQuery& ast) {
lookupSlot(ast.nodes[0]->identifier),
lookupSlot(ast.nodes[1]->identifier),
nullptr,
- getCurrentPlanNodeId());
+ getCurrentPlanNodeId(),
+ LockAcquisitionCallback{});
}
void Parser::walkProject(AstQuery& ast) {