summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/map_reduce_agg.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/commands/map_reduce_agg.cpp')
-rw-r--r--src/mongo/db/commands/map_reduce_agg.cpp6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/mongo/db/commands/map_reduce_agg.cpp b/src/mongo/db/commands/map_reduce_agg.cpp
index 91a27c93bf4..eb1d432f5b5 100644
--- a/src/mongo/db/commands/map_reduce_agg.cpp
+++ b/src/mongo/db/commands/map_reduce_agg.cpp
@@ -138,8 +138,6 @@ bool runAggregationMapReduce(OperationContext* opCtx,
Timer cmdTimer;
auto parsedMr = MapReduceCommandRequest::parse(IDLParserErrorContext("mapReduce"), cmd);
- auto curop = CurOp::get(opCtx);
- curop->beginQueryPlanningTimer();
auto expCtx = makeExpressionContext(opCtx, parsedMr, verbosity);
auto runnablePipeline = [&]() {
auto pipeline = map_reduce_common::translateFromMR(parsedMr, expCtx);
@@ -148,10 +146,10 @@ bool runAggregationMapReduce(OperationContext* opCtx,
}();
auto exec = plan_executor_factory::make(expCtx, std::move(runnablePipeline));
auto&& explainer = exec->getPlanExplainer();
- // Store the plan summary string in CurOp.
+
{
stdx::lock_guard<Client> lk(*opCtx->getClient());
- curop->setPlanSummary_inlock(explainer.getPlanSummary());
+ CurOp::get(opCtx)->setPlanSummary_inlock(explainer.getPlanSummary());
}
try {