SERVER-29932 add asserts to mapReduce_inSharded_outSharded.js to facilitate debugging

(cherry picked from commit 330c6b140d578cf311c982237690798ed33fa41c)

1 files changed, 69 insertions, 59 deletions

diff --git a/jstests/sharding/mapReduce_inSharded_outSharded.js b/jstests/sharding/mapReduce_inSharded_outSharded.js
index d1aba2599f0..d73eb517e98 100644
--- a/jstests/sharding/mapReduce_inSharded_outSharded.js
+++ b/jstests/sharding/mapReduce_inSharded_outSharded.js
@@ -1,60 +1,70 @@
-var verifyOutput = function(out) {
-    printjson(out);
-    assert.eq(out.counts.input, 51200, "input count is wrong");
-    assert.eq(out.counts.emit, 51200, "emit count is wrong");
-    assert.gt(out.counts.reduce, 99, "reduce count is wrong");
-    assert.eq(out.counts.output, 512, "output count is wrong");
-};
-
-var st = new ShardingTest(
-    {shards: 2, verbose: 1, mongos: 1, other: {chunkSize: 1, enableBalancer: true}});
-
-st.adminCommand({enablesharding: "mrShard"});
-st.ensurePrimaryShard('mrShard', 'shard0001');
-st.adminCommand({shardcollection: "mrShard.srcSharded", key: {"_id": 1}});
-
-var db = st.getDB("mrShard");
-
-var bulk = db.srcSharded.initializeUnorderedBulkOp();
-for (j = 0; j < 100; j++) {
-    for (i = 0; i < 512; i++) {
-        bulk.insert({j: j, i: i});
+(function() {
+    "use strict";
+
+    var verifyOutput = function(out) {
+        printjson(out);
+        assert.eq(out.counts.input, 51200, "input count is wrong");
+        assert.eq(out.counts.emit, 51200, "emit count is wrong");
+        assert.gt(out.counts.reduce, 99, "reduce count is wrong");
+        assert.eq(out.counts.output, 512, "output count is wrong");
+    };
+
+    var st = new ShardingTest(
+        {shards: 2, verbose: 1, mongos: 1, other: {chunkSize: 1, enableBalancer: true}});
+
+    var admin = st.s0.getDB('admin');
+
+    assert.commandWorked(admin.runCommand({enablesharding: "mrShard"}));
+    st.ensurePrimaryShard('mrShard', 'shard0001');
+    assert.commandWorked(
+        admin.runCommand({shardcollection: "mrShard.srcSharded", key: {"_id": 1}}));
+
+    var db = st.s0.getDB("mrShard");
+
+    var bulk = db.srcSharded.initializeUnorderedBulkOp();
+    for (var j = 0; j < 100; j++) {
+        for (var i = 0; i < 512; i++) {
+            bulk.insert({j: j, i: i});
+        }
+    }
+    assert.writeOK(bulk.execute());
+
+    function map() {
+        emit(this.i, 1);
+    }
+    function reduce(key, values) {
+        return Array.sum(values);
     }
-}
-assert.writeOK(bulk.execute());
-
-function map() {
-    emit(this.i, 1);
-}
-function reduce(key, values) {
-    return Array.sum(values);
-}
-
-// sharded src sharded dst
-var suffix = "InShardedOutSharded";
-
-var out =
-    db.srcSharded.mapReduce(map, reduce, {out: {replace: "mrReplace" + suffix, sharded: true}});
-verifyOutput(out);
-
-out = db.srcSharded.mapReduce(map, reduce, {out: {merge: "mrMerge" + suffix, sharded: true}});
-verifyOutput(out);
-
-out = db.srcSharded.mapReduce(map, reduce, {out: {reduce: "mrReduce" + suffix, sharded: true}});
-verifyOutput(out);
-
-out = db.srcSharded.mapReduce(map, reduce, {out: {inline: 1}});
-verifyOutput(out);
-assert(out.results != 'undefined', "no results for inline");
-
-out = db.srcSharded.mapReduce(
-    map, reduce, {out: {replace: "mrReplace" + suffix, db: "mrShardOtherDB", sharded: true}});
-verifyOutput(out);
-
-out = db.runCommand({
-    mapReduce: "srcSharded",  // use new name mapReduce rather than mapreduce
-    map: map,
-    reduce: reduce,
-    out: "mrBasic" + "srcSharded",
-});
-verifyOutput(out);
+
+    // sharded src sharded dst
+    var suffix = "InShardedOutSharded";
+
+    var out =
+        db.srcSharded.mapReduce(map, reduce, {out: {replace: "mrReplace" + suffix, sharded: true}});
+    verifyOutput(out);
+
+    out = db.srcSharded.mapReduce(map, reduce, {out: {merge: "mrMerge" + suffix, sharded: true}});
+    verifyOutput(out);
+
+    out = db.srcSharded.mapReduce(map, reduce, {out: {reduce: "mrReduce" + suffix, sharded: true}});
+    verifyOutput(out);
+
+    out = db.srcSharded.mapReduce(map, reduce, {out: {inline: 1}});
+    verifyOutput(out);
+    assert(out.results != 'undefined', "no results for inline");
+
+    out = db.srcSharded.mapReduce(
+        map, reduce, {out: {replace: "mrReplace" + suffix, db: "mrShardOtherDB", sharded: true}});
+    verifyOutput(out);
+
+    out = db.runCommand({
+        mapReduce: "srcSharded",  // use new name mapReduce rather than mapreduce
+        map: map,
+        reduce: reduce,
+        out: "mrBasic" + "srcSharded",
+    });
+    verifyOutput(out);
+
+    st.stop();
+
+})();