summaryrefslogtreecommitdiff
path: root/src/mongo/s/commands/cluster_pipeline_cmd.cpp
diff options
context:
space:
mode:
authorJames Wahlin <james.wahlin@10gen.com>2016-08-25 08:36:22 -0400
committerJames Wahlin <james.wahlin@10gen.com>2016-08-26 16:45:30 -0400
commita4a9a9ad29415239091db171e01f45677464f668 (patch)
tree461bbdd6275712543b617ce6e8b8bbc313ffb9e0 /src/mongo/s/commands/cluster_pipeline_cmd.cpp
parent752dcf912d5e45c8614ed749e20982e69cc89813 (diff)
downloadmongo-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.cpp10
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;