1 files changed, 82 insertions, 86 deletions
diff --git a/jstests/sharding/recovering_slaveok.js b/jstests/sharding/recovering_slaveok.js
index 936f8856903..cd66a1b81f5 100644
--- a/jstests/sharding/recovering_slaveok.js
+++ b/jstests/sharding/recovering_slaveok.js
@@ -2,127 +2,123 @@
 // RECOVERING state, and don't break
 
 (function() {
-'use strict';
+    'use strict';
 
-var shardTest = new ShardingTest({ name: "recovering_slaveok",
-                                   shards: 2,
-                                   mongos: 2,
-                                   other: { rs: true } });
+    var shardTest =
+        new ShardingTest({name: "recovering_slaveok", shards: 2, mongos: 2, other: {rs: true}});
 
-var mongos = shardTest.s0;
-var mongosSOK = shardTest.s1;
-mongosSOK.setSlaveOk();
+    var mongos = shardTest.s0;
+    var mongosSOK = shardTest.s1;
+    mongosSOK.setSlaveOk();
 
-var admin = mongos.getDB("admin");
-var config = mongos.getDB("config");
+    var admin = mongos.getDB("admin");
+    var config = mongos.getDB("config");
 
-var dbase = mongos.getDB("test");
-var coll = dbase.getCollection("foo");
-var dbaseSOk = mongosSOK.getDB( "" + dbase );
-var collSOk = mongosSOK.getCollection( "" + coll );
+    var dbase = mongos.getDB("test");
+    var coll = dbase.getCollection("foo");
+    var dbaseSOk = mongosSOK.getDB("" + dbase);
+    var collSOk = mongosSOK.getCollection("" + coll);
 
-var rsA = shardTest._rs[0].test;
-var rsB = shardTest._rs[1].test;
+    var rsA = shardTest._rs[0].test;
+    var rsB = shardTest._rs[1].test;
 
-assert.writeOK(rsA.getPrimary().getDB( "test_a" ).dummy.insert({ x : 1 }));
-assert.writeOK(rsB.getPrimary().getDB( "test_b" ).dummy.insert({ x : 1 }));
+    assert.writeOK(rsA.getPrimary().getDB("test_a").dummy.insert({x: 1}));
+    assert.writeOK(rsB.getPrimary().getDB("test_b").dummy.insert({x: 1}));
 
-rsA.awaitReplication();
-rsB.awaitReplication();
+    rsA.awaitReplication();
+    rsB.awaitReplication();
 
-print("1: initial insert");
+    print("1: initial insert");
 
-coll.save({ _id : -1, a : "a", date : new Date() });
-coll.save({ _id : 1, b : "b", date : new Date() });
+    coll.save({_id: -1, a: "a", date: new Date()});
+    coll.save({_id: 1, b: "b", date: new Date()});
 
-print("2: shard collection");
+    print("2: shard collection");
 
-shardTest.shardColl(coll, /* shardBy */ { _id : 1 }, /* splitAt */ { _id : 0 });
+    shardTest.shardColl(coll, /* shardBy */ {_id: 1}, /* splitAt */ {_id: 0});
 
-print("3: test normal and slaveOk queries");
+    print("3: test normal and slaveOk queries");
 
-// Make shardA and rsA the same
-var shardA = shardTest.getShard(coll, { _id : -1 });
-var shardAColl = shardA.getCollection( "" + coll );
-var shardB = shardTest.getShard(coll, { _id : 1 });
+    // Make shardA and rsA the same
+    var shardA = shardTest.getShard(coll, {_id: -1});
+    var shardAColl = shardA.getCollection("" + coll);
+    var shardB = shardTest.getShard(coll, {_id: 1});
 
-if (shardA.name == rsB.getURL()) {
-    var swap = rsB;
-    rsB = rsA;
-    rsA = swap;
-}
+    if (shardA.name == rsB.getURL()) {
+        var swap = rsB;
+        rsB = rsA;
+        rsA = swap;
+    }
 
-rsA.awaitReplication();
-rsB.awaitReplication();
+    rsA.awaitReplication();
+    rsB.awaitReplication();
 
-// Because of async migration cleanup, we need to wait for this condition to be true
-assert.soon(function() { return coll.find().itcount() == collSOk.find().itcount(); });
+    // Because of async migration cleanup, we need to wait for this condition to be true
+    assert.soon(function() {
+        return coll.find().itcount() == collSOk.find().itcount();
+    });
 
-assert.eq(shardAColl.find().itcount(), 1);
-assert.eq(shardAColl.findOne()._id, -1);
+    assert.eq(shardAColl.find().itcount(), 1);
+    assert.eq(shardAColl.findOne()._id, -1);
 
-print("5: make one of the secondaries RECOVERING");
+    print("5: make one of the secondaries RECOVERING");
 
-var secs = rsA.getSecondaries();
-var goodSec = secs[0];
-var badSec = secs[1];
+    var secs = rsA.getSecondaries();
+    var goodSec = secs[0];
+    var badSec = secs[1];
 
-assert.commandWorked(badSec.adminCommand("replSetMaintenance"));
-rsA.waitForState(badSec, ReplSetTest.State.RECOVERING);
+    assert.commandWorked(badSec.adminCommand("replSetMaintenance"));
+    rsA.waitForState(badSec, ReplSetTest.State.RECOVERING);
 
-print("6: stop non-RECOVERING secondary");
+    print("6: stop non-RECOVERING secondary");
 
-rsA.stop(goodSec);
+    rsA.stop(goodSec);
 
-print("7: check our regular and slaveOk query");
+    print("7: check our regular and slaveOk query");
 
-assert.eq(2, coll.find().itcount());
-assert.eq(2, collSOk.find().itcount());
+    assert.eq(2, coll.find().itcount());
+    assert.eq(2, collSOk.find().itcount());
 
-print("8: restart both our secondaries clean");
+    print("8: restart both our secondaries clean");
 
-rsA.restart(rsA.getSecondaries(),
-            { remember : true, startClean : true },
-            undefined,
-            5 * 60 * 1000);
+    rsA.restart(rsA.getSecondaries(), {remember: true, startClean: true}, undefined, 5 * 60 * 1000);
 
-print("9: wait for recovery");
+    print("9: wait for recovery");
 
-rsA.waitForState(rsA.getSecondaries(), ReplSetTest.State.SECONDARY, 5 * 60 * 1000 );
+    rsA.waitForState(rsA.getSecondaries(), ReplSetTest.State.SECONDARY, 5 * 60 * 1000);
 
-print("10: check our regular and slaveOk query");
+    print("10: check our regular and slaveOk query");
 
-// We need to make sure our nodes are considered accessible from mongos - otherwise we fail
-// See SERVER-7274
-ReplSetTest.awaitRSClientHosts(coll.getMongo(), rsA.nodes, { ok : true });
-ReplSetTest.awaitRSClientHosts(coll.getMongo(), rsB.nodes, { ok : true });
+    // We need to make sure our nodes are considered accessible from mongos - otherwise we fail
+    // See SERVER-7274
+    ReplSetTest.awaitRSClientHosts(coll.getMongo(), rsA.nodes, {ok: true});
+    ReplSetTest.awaitRSClientHosts(coll.getMongo(), rsB.nodes, {ok: true});
 
-// We need to make sure at least one secondary is accessible from mongos - otherwise we fail
-// See SERVER-7699
-ReplSetTest.awaitRSClientHosts(collSOk.getMongo(), [rsA.getSecondaries()[0]], 
-                               { secondary : true, ok : true });
-ReplSetTest.awaitRSClientHosts(collSOk.getMongo(), [rsB.getSecondaries()[0]], 
-                               { secondary : true, ok : true });
+    // We need to make sure at least one secondary is accessible from mongos - otherwise we fail
+    // See SERVER-7699
+    ReplSetTest.awaitRSClientHosts(
+        collSOk.getMongo(), [rsA.getSecondaries()[0]], {secondary: true, ok: true});
+    ReplSetTest.awaitRSClientHosts(
+        collSOk.getMongo(), [rsB.getSecondaries()[0]], {secondary: true, ok: true});
 
-print("SlaveOK Query...");
-var sOKCount = collSOk.find().itcount();
+    print("SlaveOK Query...");
+    var sOKCount = collSOk.find().itcount();
 
-var collCount = null;
-try{
-    print("Normal query...");
-    collCount = coll.find().itcount();
-}
-catch(e){
-    printjson(e);
+    var collCount = null;
+    try {
+        print("Normal query...");
+        collCount = coll.find().itcount();
+    } catch (e) {
+        printjson(e);
 
-    // There may have been a stepdown caused by step 8, so we run this twice in a row. The first
-    // time can error out.
-    print("Error may have been caused by stepdown, try again.");
-    collCount = coll.find().itcount();
-}
+        // There may have been a stepdown caused by step 8, so we run this twice in a row. The first
+        // time can error out.
+        print("Error may have been caused by stepdown, try again.");
+        collCount = coll.find().itcount();
+    }
 
-assert.eq(collCount, sOKCount);
+    assert.eq(collCount, sOKCount);
 
-shardTest.stop();
+    shardTest.stop();
 
 })();