summaryrefslogtreecommitdiff
path: root/jstests/sharding/shard_aware_primary_failover.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/shard_aware_primary_failover.js')
-rw-r--r--jstests/sharding/shard_aware_primary_failover.js106
1 files changed, 53 insertions, 53 deletions
diff --git a/jstests/sharding/shard_aware_primary_failover.js b/jstests/sharding/shard_aware_primary_failover.js
index abbfb47c1cf..9e7f572c3e9 100644
--- a/jstests/sharding/shard_aware_primary_failover.js
+++ b/jstests/sharding/shard_aware_primary_failover.js
@@ -2,57 +2,57 @@
* Test that a new primary that gets elected will properly perform shard initialization.
*/
(function() {
- "use strict";
-
- var st = new ShardingTest({shards: 1});
-
- var replTest = new ReplSetTest({nodes: 3});
- replTest.startSet({shardsvr: ''});
-
- var nodes = replTest.nodeList();
- replTest.initiate({
- _id: replTest.name,
- members: [
- {_id: 0, host: nodes[0]},
- {_id: 1, host: nodes[1]},
- {_id: 2, host: nodes[2], arbiterOnly: true}
- ]
- });
-
- var primaryConn = replTest.getPrimary();
-
- var shardIdentityDoc = {
- _id: 'shardIdentity',
- configsvrConnectionString: st.configRS.getURL(),
- shardName: 'newShard',
- clusterId: ObjectId()
- };
-
- // Simulate the upsert that is performed by a config server on addShard.
- var shardIdentityQuery = {
- _id: shardIdentityDoc._id,
- shardName: shardIdentityDoc.shardName,
- clusterId: shardIdentityDoc.clusterId
- };
- var shardIdentityUpdate = {
- $set: {configsvrConnectionString: shardIdentityDoc.configsvrConnectionString}
- };
- assert.writeOK(primaryConn.getDB('admin').system.version.update(
- shardIdentityQuery, shardIdentityUpdate, {upsert: true, writeConcern: {w: 'majority'}}));
-
- replTest.stopMaster();
- replTest.waitForMaster(30000);
-
- primaryConn = replTest.getPrimary();
-
- var res = primaryConn.getDB('admin').runCommand({shardingState: 1});
-
- assert(res.enabled);
- assert.eq(shardIdentityDoc.configsvrConnectionString, res.configServer);
- assert.eq(shardIdentityDoc.shardName, res.shardName);
- assert.eq(shardIdentityDoc.clusterId, res.clusterId);
-
- replTest.stopSet();
-
- st.stop();
+"use strict";
+
+var st = new ShardingTest({shards: 1});
+
+var replTest = new ReplSetTest({nodes: 3});
+replTest.startSet({shardsvr: ''});
+
+var nodes = replTest.nodeList();
+replTest.initiate({
+ _id: replTest.name,
+ members: [
+ {_id: 0, host: nodes[0]},
+ {_id: 1, host: nodes[1]},
+ {_id: 2, host: nodes[2], arbiterOnly: true}
+ ]
+});
+
+var primaryConn = replTest.getPrimary();
+
+var shardIdentityDoc = {
+ _id: 'shardIdentity',
+ configsvrConnectionString: st.configRS.getURL(),
+ shardName: 'newShard',
+ clusterId: ObjectId()
+};
+
+// Simulate the upsert that is performed by a config server on addShard.
+var shardIdentityQuery = {
+ _id: shardIdentityDoc._id,
+ shardName: shardIdentityDoc.shardName,
+ clusterId: shardIdentityDoc.clusterId
+};
+var shardIdentityUpdate = {
+ $set: {configsvrConnectionString: shardIdentityDoc.configsvrConnectionString}
+};
+assert.writeOK(primaryConn.getDB('admin').system.version.update(
+ shardIdentityQuery, shardIdentityUpdate, {upsert: true, writeConcern: {w: 'majority'}}));
+
+replTest.stopMaster();
+replTest.waitForMaster(30000);
+
+primaryConn = replTest.getPrimary();
+
+var res = primaryConn.getDB('admin').runCommand({shardingState: 1});
+
+assert(res.enabled);
+assert.eq(shardIdentityDoc.configsvrConnectionString, res.configServer);
+assert.eq(shardIdentityDoc.shardName, res.shardName);
+assert.eq(shardIdentityDoc.clusterId, res.clusterId);
+
+replTest.stopSet();
+
+st.stop();
})();