summaryrefslogtreecommitdiff
path: root/src/mongo/db/commands/pipeline_command.cpp
diff options
context:
space:
mode:
authorBenjamin Murphy <benjamin_murphy@me.com>2016-01-27 16:42:04 -0500
committerBenjamin Murphy <benjamin_murphy@me.com>2016-02-08 12:53:48 -0500
commitc3a232ef38480f317cd42cc00755fd9032c107d2 (patch)
treebb664b92f2ffcf1b6c9c1dab0ad483404ac7d813 /src/mongo/db/commands/pipeline_command.cpp
parenta1a4f91a9c70b3f9f58f2922c260f1df97418e2c (diff)
downloadmongo-c3a232ef38480f317cd42cc00755fd9032c107d2.tar.gz
SERVER-19643 Aggregation directly from a shard does not use sharding filter.
Diffstat (limited to 'src/mongo/db/commands/pipeline_command.cpp')
-rw-r--r--src/mongo/db/commands/pipeline_command.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/mongo/db/commands/pipeline_command.cpp b/src/mongo/db/commands/pipeline_command.cpp
index fc3537d1a49..31b80d4fda6 100644
--- a/src/mongo/db/commands/pipeline_command.cpp
+++ b/src/mongo/db/commands/pipeline_command.cpp
@@ -224,7 +224,7 @@ public:
// This does mongod-specific stuff like creating the input PlanExecutor and adding
// it to the front of the pipeline if needed.
std::shared_ptr<PlanExecutor> input =
- PipelineD::prepareCursorSource(txn, collection, pPipeline, pCtx);
+ PipelineD::prepareCursorSource(txn, collection, nss, pPipeline, pCtx);
pPipeline->stitch();
if (collection && input) {