SERVER-41772 Apply clang-format 7.0.1 to the codebase

1 files changed, 372 insertions, 374 deletions

diff --git a/jstests/sharding/mongos_rs_shard_failure_tolerance.js b/jstests/sharding/mongos_rs_shard_failure_tolerance.js
index 7b43adcdd49..d41759de5db 100644
--- a/jstests/sharding/mongos_rs_shard_failure_tolerance.js
+++ b/jstests/sharding/mongos_rs_shard_failure_tolerance.js
@@ -16,417 +16,415 @@
 TestData.skipCheckingUUIDsConsistentAcrossCluster = true;
 
 (function() {
-    'use strict';
+'use strict';
 
-    var st = new ShardingTest({shards: 3, mongos: 1, other: {rs: true, rsOptions: {nodes: 2}}});
+var st = new ShardingTest({shards: 3, mongos: 1, other: {rs: true, rsOptions: {nodes: 2}}});
 
-    var mongos = st.s0;
-    var admin = mongos.getDB("admin");
+var mongos = st.s0;
+var admin = mongos.getDB("admin");
 
-    assert.commandWorked(admin.runCommand({setParameter: 1, traceExceptions: true}));
+assert.commandWorked(admin.runCommand({setParameter: 1, traceExceptions: true}));
 
-    var collSharded = mongos.getCollection("fooSharded.barSharded");
-    var collUnsharded = mongos.getCollection("fooUnsharded.barUnsharded");
+var collSharded = mongos.getCollection("fooSharded.barSharded");
+var collUnsharded = mongos.getCollection("fooUnsharded.barUnsharded");
 
-    // Create the unsharded database
-    assert.writeOK(collUnsharded.insert({some: "doc"}));
-    assert.writeOK(collUnsharded.remove({}));
-    assert.commandWorked(
-        admin.runCommand({movePrimary: collUnsharded.getDB().toString(), to: st.shard0.shardName}));
+// Create the unsharded database
+assert.writeOK(collUnsharded.insert({some: "doc"}));
+assert.writeOK(collUnsharded.remove({}));
+assert.commandWorked(
+    admin.runCommand({movePrimary: collUnsharded.getDB().toString(), to: st.shard0.shardName}));
 
-    // Create the sharded database
-    assert.commandWorked(admin.runCommand({enableSharding: collSharded.getDB().toString()}));
-    assert.commandWorked(
-        admin.runCommand({movePrimary: collSharded.getDB().toString(), to: st.shard0.shardName}));
-    assert.commandWorked(
-        admin.runCommand({shardCollection: collSharded.toString(), key: {_id: 1}}));
-    assert.commandWorked(admin.runCommand({split: collSharded.toString(), middle: {_id: 0}}));
-    assert.commandWorked(admin.runCommand(
-        {moveChunk: collSharded.toString(), find: {_id: 0}, to: st.shard1.shardName}));
+// Create the sharded database
+assert.commandWorked(admin.runCommand({enableSharding: collSharded.getDB().toString()}));
+assert.commandWorked(
+    admin.runCommand({movePrimary: collSharded.getDB().toString(), to: st.shard0.shardName}));
+assert.commandWorked(admin.runCommand({shardCollection: collSharded.toString(), key: {_id: 1}}));
+assert.commandWorked(admin.runCommand({split: collSharded.toString(), middle: {_id: 0}}));
+assert.commandWorked(
+    admin.runCommand({moveChunk: collSharded.toString(), find: {_id: 0}, to: st.shard1.shardName}));
 
-    // Secondaries do not refresh their in-memory routing table until a request with a higher
-    // version is received, and refreshing requires communication with the primary to obtain the
-    // newest version. Read from the secondaries once before taking down primaries to ensure they
-    // have loaded the routing table into memory.
-    // TODO SERVER-30148: replace this with calls to awaitReplication() on each shard owning data
-    // for the sharded collection once secondaries refresh proactively.
-    var mongosSetupConn = new Mongo(mongos.host);
-    mongosSetupConn.setReadPref("secondary");
-    assert(!mongosSetupConn.getCollection(collSharded.toString()).find({}).hasNext());
+// Secondaries do not refresh their in-memory routing table until a request with a higher
+// version is received, and refreshing requires communication with the primary to obtain the
+// newest version. Read from the secondaries once before taking down primaries to ensure they
+// have loaded the routing table into memory.
+// TODO SERVER-30148: replace this with calls to awaitReplication() on each shard owning data
+// for the sharded collection once secondaries refresh proactively.
+var mongosSetupConn = new Mongo(mongos.host);
+mongosSetupConn.setReadPref("secondary");
+assert(!mongosSetupConn.getCollection(collSharded.toString()).find({}).hasNext());
 
-    gc();  // Clean up connections
+gc();  // Clean up connections
 
-    st.printShardingStatus();
+st.printShardingStatus();
 
-    //
-    // Setup is complete
-    //
+//
+// Setup is complete
+//
 
-    jsTest.log("Inserting initial data...");
+jsTest.log("Inserting initial data...");
 
-    var mongosConnActive = new Mongo(mongos.host);
-    var mongosConnIdle = null;
-    var mongosConnNew = null;
+var mongosConnActive = new Mongo(mongos.host);
+var mongosConnIdle = null;
+var mongosConnNew = null;
 
-    var wc = {writeConcern: {w: 2, wtimeout: 60000}};
+var wc = {writeConcern: {w: 2, wtimeout: 60000}};
 
-    assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -1}, wc));
-    assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 1}, wc));
-    assert.writeOK(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 1}, wc));
+assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -1}, wc));
+assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 1}, wc));
+assert.writeOK(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 1}, wc));
 
-    jsTest.log("Stopping primary of third shard...");
+jsTest.log("Stopping primary of third shard...");
 
-    mongosConnIdle = new Mongo(mongos.host);
+mongosConnIdle = new Mongo(mongos.host);
 
-    st.rs2.stop(st.rs2.getPrimary());
+st.rs2.stop(st.rs2.getPrimary());
 
-    jsTest.log("Testing active connection with third primary down...");
+jsTest.log("Testing active connection with third primary down...");
 
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
 
-    assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -2}, wc));
-    assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 2}, wc));
-    assert.writeOK(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 2}, wc));
+assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -2}, wc));
+assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 2}, wc));
+assert.writeOK(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 2}, wc));
 
-    jsTest.log("Testing idle connection with third primary down...");
+jsTest.log("Testing idle connection with third primary down...");
 
-    assert.writeOK(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: -3}, wc));
-    assert.writeOK(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: 3}, wc));
-    assert.writeOK(mongosConnIdle.getCollection(collUnsharded.toString()).insert({_id: 3}, wc));
-
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    jsTest.log("Testing new connections with third primary down...");
-
-    mongosConnNew = new Mongo(mongos.host);
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeOK(mongosConnNew.getCollection(collSharded.toString()).insert({_id: -4}, wc));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeOK(mongosConnNew.getCollection(collSharded.toString()).insert({_id: 4}, wc));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeOK(mongosConnNew.getCollection(collUnsharded.toString()).insert({_id: 4}, wc));
-
-    gc();  // Clean up new connections
-
-    jsTest.log("Stopping primary of second shard...");
-
-    mongosConnIdle = new Mongo(mongos.host);
-
-    // Need to save this node for later
-    var rs1Secondary = st.rs1.getSecondary();
-
-    st.rs1.stop(st.rs1.getPrimary());
-
-    jsTest.log("Testing active connection with second primary down...");
-
-    // Reads with read prefs
-    mongosConnActive.setSlaveOk();
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-    mongosConnActive.setSlaveOk(false);
-
-    mongosConnActive.setReadPref("primary");
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.throws(function() {
-        mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1});
-    });
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    // Ensure read prefs override slaveOK
-    mongosConnActive.setSlaveOk();
-    mongosConnActive.setReadPref("primary");
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.throws(function() {
-        mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1});
-    });
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-    mongosConnActive.setSlaveOk(false);
-
-    mongosConnActive.setReadPref("secondary");
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    mongosConnActive.setReadPref("primaryPreferred");
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    mongosConnActive.setReadPref("secondaryPreferred");
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    mongosConnActive.setReadPref("nearest");
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    // Writes
-    assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -5}, wc));
-    assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 5}, wc));
-    assert.writeOK(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 5}, wc));
-
-    jsTest.log("Testing idle connection with second primary down...");
-
-    // Writes
-    assert.writeOK(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: -6}, wc));
-    assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: 6}, wc));
-    assert.writeOK(mongosConnIdle.getCollection(collUnsharded.toString()).insert({_id: 6}, wc));
-
-    // Reads with read prefs
-    mongosConnIdle.setSlaveOk();
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-    mongosConnIdle.setSlaveOk(false);
-
-    mongosConnIdle.setReadPref("primary");
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.throws(function() {
-        mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1});
-    });
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    // Ensure read prefs override slaveOK
-    mongosConnIdle.setSlaveOk();
-    mongosConnIdle.setReadPref("primary");
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.throws(function() {
-        mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1});
-    });
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-    mongosConnIdle.setSlaveOk(false);
-
-    mongosConnIdle.setReadPref("secondary");
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    mongosConnIdle.setReadPref("primaryPreferred");
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    mongosConnIdle.setReadPref("secondaryPreferred");
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    mongosConnIdle.setReadPref("nearest");
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    jsTest.log("Testing new connections with second primary down...");
-
-    // Reads with read prefs
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
-
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("primary");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("primary");
-    assert.throws(function() {
-        mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1});
-    });
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("primary");
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
-
-    // Ensure read prefs override slaveok
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    mongosConnNew.setReadPref("primary");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    mongosConnNew.setReadPref("primary");
-    assert.throws(function() {
-        mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1});
-    });
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    mongosConnNew.setReadPref("primary");
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
-
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("secondary");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("secondary");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("secondary");
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
-
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("primaryPreferred");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("primaryPreferred");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("primaryPreferred");
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
-
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("secondaryPreferred");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("secondaryPreferred");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("secondaryPreferred");
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
-
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("nearest");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("nearest");
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setReadPref("nearest");
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
-
-    // Writes
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeOK(mongosConnNew.getCollection(collSharded.toString()).insert({_id: -7}, wc));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: 7}, wc));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeOK(mongosConnNew.getCollection(collUnsharded.toString()).insert({_id: 7}, wc));
-
-    gc();  // Clean up new connections
-
-    jsTest.log("Stopping primary of first shard...");
-
-    mongosConnIdle = new Mongo(mongos.host);
-
-    st.rs0.stop(st.rs0.getPrimary());
-
-    jsTest.log("Testing active connection with first primary down...");
-
-    mongosConnActive.setSlaveOk();
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -8}));
-    assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 8}));
-    assert.writeError(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 8}));
-
-    jsTest.log("Testing idle connection with first primary down...");
-
-    assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: -9}));
-    assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: 9}));
-    assert.writeError(mongosConnIdle.getCollection(collUnsharded.toString()).insert({_id: 9}));
-
-    mongosConnIdle.setSlaveOk();
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
-
-    jsTest.log("Testing new connections with first primary down...");
-
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+assert.writeOK(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: -3}, wc));
+assert.writeOK(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: 3}, wc));
+assert.writeOK(mongosConnIdle.getCollection(collUnsharded.toString()).insert({_id: 3}, wc));
 
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: -10}));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: 10}));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeError(mongosConnNew.getCollection(collUnsharded.toString()).insert({_id: 10}));
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
 
-    gc();  // Clean up new connections
+jsTest.log("Testing new connections with third primary down...");
 
-    jsTest.log("Stopping second shard...");
+mongosConnNew = new Mongo(mongos.host);
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
+mongosConnNew = new Mongo(mongos.host);
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+mongosConnNew = new Mongo(mongos.host);
+assert.writeOK(mongosConnNew.getCollection(collSharded.toString()).insert({_id: -4}, wc));
+mongosConnNew = new Mongo(mongos.host);
+assert.writeOK(mongosConnNew.getCollection(collSharded.toString()).insert({_id: 4}, wc));
+mongosConnNew = new Mongo(mongos.host);
+assert.writeOK(mongosConnNew.getCollection(collUnsharded.toString()).insert({_id: 4}, wc));
+
+gc();  // Clean up new connections
+
+jsTest.log("Stopping primary of second shard...");
+
+mongosConnIdle = new Mongo(mongos.host);
+
+// Need to save this node for later
+var rs1Secondary = st.rs1.getSecondary();
+
+st.rs1.stop(st.rs1.getPrimary());
+
+jsTest.log("Testing active connection with second primary down...");
+
+// Reads with read prefs
+mongosConnActive.setSlaveOk();
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+mongosConnActive.setSlaveOk(false);
+
+mongosConnActive.setReadPref("primary");
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.throws(function() {
+    mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1});
+});
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+// Ensure read prefs override slaveOK
+mongosConnActive.setSlaveOk();
+mongosConnActive.setReadPref("primary");
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.throws(function() {
+    mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1});
+});
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+mongosConnActive.setSlaveOk(false);
+
+mongosConnActive.setReadPref("secondary");
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+mongosConnActive.setReadPref("primaryPreferred");
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+mongosConnActive.setReadPref("secondaryPreferred");
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+mongosConnActive.setReadPref("nearest");
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+// Writes
+assert.writeOK(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -5}, wc));
+assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 5}, wc));
+assert.writeOK(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 5}, wc));
+
+jsTest.log("Testing idle connection with second primary down...");
+
+// Writes
+assert.writeOK(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: -6}, wc));
+assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: 6}, wc));
+assert.writeOK(mongosConnIdle.getCollection(collUnsharded.toString()).insert({_id: 6}, wc));
+
+// Reads with read prefs
+mongosConnIdle.setSlaveOk();
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+mongosConnIdle.setSlaveOk(false);
+
+mongosConnIdle.setReadPref("primary");
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.throws(function() {
+    mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1});
+});
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+// Ensure read prefs override slaveOK
+mongosConnIdle.setSlaveOk();
+mongosConnIdle.setReadPref("primary");
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.throws(function() {
+    mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1});
+});
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+mongosConnIdle.setSlaveOk(false);
+
+mongosConnIdle.setReadPref("secondary");
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+mongosConnIdle.setReadPref("primaryPreferred");
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+mongosConnIdle.setReadPref("secondaryPreferred");
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+mongosConnIdle.setReadPref("nearest");
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+jsTest.log("Testing new connections with second primary down...");
+
+// Reads with read prefs
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
+
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("primary");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("primary");
+assert.throws(function() {
+    mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1});
+});
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("primary");
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
+
+// Ensure read prefs override slaveok
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+mongosConnNew.setReadPref("primary");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+mongosConnNew.setReadPref("primary");
+assert.throws(function() {
+    mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1});
+});
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+mongosConnNew.setReadPref("primary");
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
+
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("secondary");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("secondary");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("secondary");
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
+
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("primaryPreferred");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("primaryPreferred");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("primaryPreferred");
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
+
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("secondaryPreferred");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("secondaryPreferred");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("secondaryPreferred");
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
+
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("nearest");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("nearest");
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setReadPref("nearest");
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+gc();  // Clean up new connections incrementally to compensate for slow win32 machine.
+
+// Writes
+mongosConnNew = new Mongo(mongos.host);
+assert.writeOK(mongosConnNew.getCollection(collSharded.toString()).insert({_id: -7}, wc));
+mongosConnNew = new Mongo(mongos.host);
+assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: 7}, wc));
+mongosConnNew = new Mongo(mongos.host);
+assert.writeOK(mongosConnNew.getCollection(collUnsharded.toString()).insert({_id: 7}, wc));
+
+gc();  // Clean up new connections
+
+jsTest.log("Stopping primary of first shard...");
+
+mongosConnIdle = new Mongo(mongos.host);
+
+st.rs0.stop(st.rs0.getPrimary());
+
+jsTest.log("Testing active connection with first primary down...");
+
+mongosConnActive.setSlaveOk();
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -8}));
+assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 8}));
+assert.writeError(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 8}));
+
+jsTest.log("Testing idle connection with first primary down...");
+
+assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: -9}));
+assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: 9}));
+assert.writeError(mongosConnIdle.getCollection(collUnsharded.toString()).insert({_id: 9}));
+
+mongosConnIdle.setSlaveOk();
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: 1}));
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+
+jsTest.log("Testing new connections with first primary down...");
+
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: 1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
 
-    mongosConnIdle = new Mongo(mongos.host);
+mongosConnNew = new Mongo(mongos.host);
+assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: -10}));
+mongosConnNew = new Mongo(mongos.host);
+assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: 10}));
+mongosConnNew = new Mongo(mongos.host);
+assert.writeError(mongosConnNew.getCollection(collUnsharded.toString()).insert({_id: 10}));
+
+gc();  // Clean up new connections
 
-    st.rs1.stop(rs1Secondary);
+jsTest.log("Stopping second shard...");
 
-    jsTest.log("Testing active connection with second shard down...");
+mongosConnIdle = new Mongo(mongos.host);
 
-    mongosConnActive.setSlaveOk();
-    assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+st.rs1.stop(rs1Secondary);
+
+jsTest.log("Testing active connection with second shard down...");
 
-    assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -11}));
-    assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 11}));
-    assert.writeError(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 11}));
+mongosConnActive.setSlaveOk();
+assert.neq(null, mongosConnActive.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnActive.getCollection(collUnsharded.toString()).findOne({_id: 1}));
 
-    jsTest.log("Testing idle connection with second shard down...");
+assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: -11}));
+assert.writeError(mongosConnActive.getCollection(collSharded.toString()).insert({_id: 11}));
+assert.writeError(mongosConnActive.getCollection(collUnsharded.toString()).insert({_id: 11}));
 
-    assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: -12}));
-    assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: 12}));
-    assert.writeError(mongosConnIdle.getCollection(collUnsharded.toString()).insert({_id: 12}));
+jsTest.log("Testing idle connection with second shard down...");
 
-    mongosConnIdle.setSlaveOk();
-    assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
-    assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: -12}));
+assert.writeError(mongosConnIdle.getCollection(collSharded.toString()).insert({_id: 12}));
+assert.writeError(mongosConnIdle.getCollection(collUnsharded.toString()).insert({_id: 12}));
 
-    jsTest.log("Testing new connections with second shard down...");
+mongosConnIdle.setSlaveOk();
+assert.neq(null, mongosConnIdle.getCollection(collSharded.toString()).findOne({_id: -1}));
+assert.neq(null, mongosConnIdle.getCollection(collUnsharded.toString()).findOne({_id: 1}));
 
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
-    mongosConnNew = new Mongo(mongos.host);
-    mongosConnNew.setSlaveOk();
-    assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
+jsTest.log("Testing new connections with second shard down...");
 
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: -13}));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: 13}));
-    mongosConnNew = new Mongo(mongos.host);
-    assert.writeError(mongosConnNew.getCollection(collUnsharded.toString()).insert({_id: 13}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+assert.neq(null, mongosConnNew.getCollection(collSharded.toString()).findOne({_id: -1}));
+mongosConnNew = new Mongo(mongos.host);
+mongosConnNew.setSlaveOk();
+assert.neq(null, mongosConnNew.getCollection(collUnsharded.toString()).findOne({_id: 1}));
 
-    gc();  // Clean up new connections
+mongosConnNew = new Mongo(mongos.host);
+assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: -13}));
+mongosConnNew = new Mongo(mongos.host);
+assert.writeError(mongosConnNew.getCollection(collSharded.toString()).insert({_id: 13}));
+mongosConnNew = new Mongo(mongos.host);
+assert.writeError(mongosConnNew.getCollection(collUnsharded.toString()).insert({_id: 13}));
 
-    st.stop();
+gc();  // Clean up new connections
 
+st.stop();
 })();