summaryrefslogtreecommitdiff
path: root/jstests/replsets/index_restart_secondary.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/index_restart_secondary.js')
-rw-r--r--jstests/replsets/index_restart_secondary.js49
1 files changed, 26 insertions, 23 deletions
diff --git a/jstests/replsets/index_restart_secondary.js b/jstests/replsets/index_restart_secondary.js
index 7308de83271..be328ede8bc 100644
--- a/jstests/replsets/index_restart_secondary.js
+++ b/jstests/replsets/index_restart_secondary.js
@@ -1,13 +1,13 @@
/**
- * Starts a replica set with arbiter, build an index
- * restart secondary once it starts building index,
+ * Starts a replica set with arbiter, build an index
+ * restart secondary once it starts building index,
* index build restarts after secondary restarts
*/
var replTest = new ReplSetTest({
name: 'fgIndex',
nodes: 3,
- oplogSize: 100, // This test inserts enough data to wrap the default 40MB oplog.
+ oplogSize: 100, // This test inserts enough data to wrap the default 40MB oplog.
});
var nodes = replTest.nodeList();
@@ -18,11 +18,14 @@ var conns = replTest.startSet();
// don't run on 32-bit builders since they are slow and single core, which leads to heartbeats
// failing and loss of primary during the bulk write
if (conns[0].getDB('test').serverBuildInfo().bits !== 32) {
- replTest.initiate({"_id" : "fgIndex",
- "members" : [
- {"_id" : 0, "host" : nodes[0]},
- {"_id" : 1, "host" : nodes[1]},
- {"_id" : 2, "host" : nodes[2], "arbiterOnly" : true}]});
+ replTest.initiate({
+ "_id": "fgIndex",
+ "members": [
+ {"_id": 0, "host": nodes[0]},
+ {"_id": 1, "host": nodes[1]},
+ {"_id": 2, "host": nodes[2], "arbiterOnly": true}
+ ]
+ });
var master = replTest.getPrimary();
var second = replTest.getSecondary();
@@ -36,39 +39,39 @@ if (conns[0].getDB('test').serverBuildInfo().bits !== 32) {
jsTest.log("creating test data " + size + " documents");
var bulk = masterDB.jstests_fgsec.initializeUnorderedBulkOp();
- for(var i = 0; i < size; ++i) {
- bulk.insert({ i: i });
+ for (var i = 0; i < size; ++i) {
+ bulk.insert({i: i});
}
- assert.writeOK(bulk.execute( { w: "majority" } ));
+ assert.writeOK(bulk.execute({w: "majority"}));
jsTest.log("Creating index");
- masterDB.jstests_fgsec.ensureIndex( {i:1} );
+ masterDB.jstests_fgsec.ensureIndex({i: 1});
assert.eq(2, masterDB.jstests_fgsec.getIndexes().length);
// Wait for the secondary to get the index entry
- assert.soon( function() {
- return 2 == secondDB.jstests_fgsec.getIndexes().length; },
- "index not created on secondary (prior to restart)", 800000, 50 );
+ assert.soon(function() {
+ return 2 == secondDB.jstests_fgsec.getIndexes().length;
+ }, "index not created on secondary (prior to restart)", 800000, 50);
jsTest.log("Index created on secondary");
// restart secondary and reconnect
jsTest.log("Restarting secondary");
- replTest.restart(secondId, {}, /*wait=*/true);
+ replTest.restart(secondId, {}, /*wait=*/true);
// Make sure secondary comes back
- assert.soon( function() {
+ assert.soon(function() {
try {
- secondDB.isMaster(); // trigger a reconnect if needed
+ secondDB.isMaster(); // trigger a reconnect if needed
return true;
} catch (e) {
- return false;
+ return false;
}
- } , "secondary didn't restart", 30000, 1000);
+ }, "secondary didn't restart", 30000, 1000);
- assert.soon( function() {
- return 2 == secondDB.jstests_fgsec.getIndexes().length; },
- "Index build not resumed after restart", 30000, 50 );
+ assert.soon(function() {
+ return 2 == secondDB.jstests_fgsec.getIndexes().length;
+ }, "Index build not resumed after restart", 30000, 50);
jsTest.log("index-restart-secondary.js complete");
}