diff options
author | James Wahlin <james.wahlin@10gen.com> | 2016-08-25 08:36:22 -0400 |
---|---|---|
committer | James Wahlin <james.wahlin@10gen.com> | 2016-08-26 16:45:30 -0400 |
commit | a4a9a9ad29415239091db171e01f45677464f668 (patch) | |
tree | 461bbdd6275712543b617ce6e8b8bbc313ffb9e0 /src/mongo/s/commands/cluster_pipeline_cmd.cpp | |
parent | 752dcf912d5e45c8614ed749e20982e69cc89813 (diff) | |
download | mongo-a4a9a9ad29415239091db171e01f45677464f668.tar.gz |
SERVER-24771 Support killCursors & mongos getMore on view namespace
Diffstat (limited to 'src/mongo/s/commands/cluster_pipeline_cmd.cpp')
-rw-r--r-- | src/mongo/s/commands/cluster_pipeline_cmd.cpp | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/mongo/s/commands/cluster_pipeline_cmd.cpp b/src/mongo/s/commands/cluster_pipeline_cmd.cpp index bbb98110d67..11564077cb0 100644 --- a/src/mongo/s/commands/cluster_pipeline_cmd.cpp +++ b/src/mongo/s/commands/cluster_pipeline_cmd.cpp @@ -79,8 +79,14 @@ public: std::string& errmsg, BSONObjBuilder& result) { const std::string fullns = parseNs(dbname, cmdObj); - return ClusterAggregate::runAggregate( - txn, dbname, fullns, cmdObj, options, errmsg, &result); + const NamespaceString nss(fullns); + + ClusterAggregate::Namespaces nsStruct; + nsStruct.requestedNss = nss; + nsStruct.executionNss = std::move(nss); + auto status = ClusterAggregate::runAggregate(txn, nsStruct, cmdObj, options, &result); + appendCommandStatus(result, status); + return status.isOK(); } } clusterPipelineCmd; |