diff options
Diffstat (limited to 'src/mongo/db/commands/map_reduce_agg.cpp')
| -rw-r--r-- | src/mongo/db/commands/map_reduce_agg.cpp | 6 |
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 { |
