SERVER-28792 make dropIndexes unversioned again

1 files changed, 4 insertions, 15 deletions

diff --git a/src/mongo/s/commands/cluster_db_stats_cmd.cpp b/src/mongo/s/commands/cluster_db_stats_cmd.cpp
index 1dc1e87392e..8bddb22148b 100644
--- a/src/mongo/s/commands/cluster_db_stats_cmd.cpp
+++ b/src/mongo/s/commands/cluster_db_stats_cmd.cpp
@@ -68,22 +68,11 @@ public:
              BSONObj& cmdObj,
              std::string& errmsg,
              BSONObjBuilder& output) override {
-        auto requests = buildRequestsForAllShards(opCtx, cmdObj);
-        auto swResponses =
-            gatherResponsesFromShards(opCtx, dbName, cmdObj, requests, &output, nullptr);
-        if (!swResponses.isOK()) {
-            // We failed to obtain a response or error from all shards.
-            return appendCommandStatus(output, swResponses.getStatus());
-        }
-
-        // Only aggregate results if we got a success response from every shard.
-        auto responses = std::move(swResponses.getValue());
-        if (std::all_of(
-                responses.begin(), responses.end(), [](AsyncRequestsSender::Response response) {
-                    return response.swResponse.getStatus().isOK();
-                })) {
-            aggregateResults(std::move(responses), output);
+        auto shardResponses = uassertStatusOK(scatterGather(opCtx, dbName, cmdObj));
+        if (!appendRawResponses(opCtx, &errmsg, &output, shardResponses)) {
+            return false;
         }
+        aggregateResults(shardResponses, output);
         return true;
     }