summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/pipeline_command.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/commands/pipeline_command.cpp')
-rw-r--r--src/mongo/db/commands/pipeline_command.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/mongo/db/commands/pipeline_command.cpp b/src/mongo/db/commands/pipeline_command.cpp
index 2042914e16b..eb5f74d4387 100644
--- a/src/mongo/db/commands/pipeline_command.cpp
+++ b/src/mongo/db/commands/pipeline_command.cpp
@@ -89,7 +89,7 @@ public:
this, opMsgRequest, std::move(aggregationRequest), std::move(privileges));
}
- bool shouldAffectReadOptionCounters() const override {
+ bool shouldAffectReadConcernCounter() const override {
return true;
}
@@ -142,6 +142,7 @@ public:
opCtx, !Pipeline::aggHasWriteStage(_request.body));
uassertStatusOK(runAggregate(opCtx,
+ _aggregationRequest.getNamespace(),
_aggregationRequest,
_liteParsedPipeline,
_request.body,
@@ -164,6 +165,7 @@ public:
rpc::ReplyBuilderInterface* result) override {
uassertStatusOK(runAggregate(opCtx,
+ _aggregationRequest.getNamespace(),
_aggregationRequest,
_liteParsedPipeline,
_request.body,