diff options
Diffstat (limited to 'jstests/replsets/initial_sync_fail_insert_once.js')
-rw-r--r-- | jstests/replsets/initial_sync_fail_insert_once.js | 46 |
1 files changed, 23 insertions, 23 deletions
diff --git a/jstests/replsets/initial_sync_fail_insert_once.js b/jstests/replsets/initial_sync_fail_insert_once.js index d85f97f5a63..0a1f0a11a8a 100644 --- a/jstests/replsets/initial_sync_fail_insert_once.js +++ b/jstests/replsets/initial_sync_fail_insert_once.js @@ -5,33 +5,33 @@ */ (function() { - var name = 'initial_sync_fail_insert_once'; - var replSet = new ReplSetTest( - {name: name, nodes: 2, nodeOptions: {setParameter: "numInitialSyncAttempts=3"}}); +var name = 'initial_sync_fail_insert_once'; +var replSet = new ReplSetTest( + {name: name, nodes: 2, nodeOptions: {setParameter: "numInitialSyncAttempts=3"}}); - replSet.startSet(); - replSet.initiate(); - var primary = replSet.getPrimary(); - var secondary = replSet.getSecondary(); +replSet.startSet(); +replSet.initiate(); +var primary = replSet.getPrimary(); +var secondary = replSet.getSecondary(); - var coll = primary.getDB('test').getCollection(name); - assert.writeOK(coll.insert({_id: 0, x: 1}, {writeConcern: {w: 2}})); +var coll = primary.getDB('test').getCollection(name); +assert.writeOK(coll.insert({_id: 0, x: 1}, {writeConcern: {w: 2}})); - jsTest.log("Enabling Failpoint failCollectionInserts on " + tojson(secondary)); - assert.commandWorked(secondary.getDB("admin").adminCommand({ - configureFailPoint: "failCollectionInserts", - mode: {times: 2}, - data: {collectionNS: coll.getFullName()} - })); +jsTest.log("Enabling Failpoint failCollectionInserts on " + tojson(secondary)); +assert.commandWorked(secondary.getDB("admin").adminCommand({ + configureFailPoint: "failCollectionInserts", + mode: {times: 2}, + data: {collectionNS: coll.getFullName()} +})); - jsTest.log("Re-syncing " + tojson(secondary)); - secondary = replSet.restart(secondary, {startClean: true}); - replSet.awaitReplication(); - replSet.awaitSecondaryNodes(); +jsTest.log("Re-syncing " + tojson(secondary)); +secondary = replSet.restart(secondary, {startClean: true}); +replSet.awaitReplication(); +replSet.awaitSecondaryNodes(); - assert.eq(1, secondary.getDB("test")[name].count()); - assert.docEq({_id: 0, x: 1}, secondary.getDB("test")[name].findOne()); +assert.eq(1, secondary.getDB("test")[name].count()); +assert.docEq({_id: 0, x: 1}, secondary.getDB("test")[name].findOne()); - jsTest.log("Stopping repl set test; finished."); - replSet.stopSet(); +jsTest.log("Stopping repl set test; finished."); +replSet.stopSet(); })(); |