diff options
Diffstat (limited to 'src/mongo/db/s/cluster_pipeline_cmd_d.cpp')
-rw-r--r-- | src/mongo/db/s/cluster_pipeline_cmd_d.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/mongo/db/s/cluster_pipeline_cmd_d.cpp b/src/mongo/db/s/cluster_pipeline_cmd_d.cpp index cd78fa52e18..8526a411f67 100644 --- a/src/mongo/db/s/cluster_pipeline_cmd_d.cpp +++ b/src/mongo/db/s/cluster_pipeline_cmd_d.cpp @@ -62,13 +62,15 @@ struct ClusterPipelineCommandD { } static AggregateCommandRequest parseAggregationRequest( + OperationContext* opCtx, const OpMsgRequest& opMsgRequest, boost::optional<ExplainOptions::Verbosity> explainVerbosity, bool apiStrict) { // Replace clusterAggregate in the request body because the parser doesn't recognize it. auto modifiedRequestBody = opMsgRequest.body.replaceFieldNames(BSON(AggregateCommandRequest::kCommandName << 1)); - return aggregation_request_helper::parseFromBSON(opMsgRequest.getDatabase().toString(), + return aggregation_request_helper::parseFromBSON(opCtx, + opMsgRequest.getDatabase().toString(), modifiedRequestBody, explainVerbosity, apiStrict); |