diff options
Diffstat (limited to 'jstests/replsets/maxSyncSourceLagSecs.js')
-rw-r--r-- | jstests/replsets/maxSyncSourceLagSecs.js | 42 |
1 files changed, 23 insertions, 19 deletions
diff --git a/jstests/replsets/maxSyncSourceLagSecs.js b/jstests/replsets/maxSyncSourceLagSecs.js index 8d44dd5ddb2..0e7fe04355b 100644 --- a/jstests/replsets/maxSyncSourceLagSecs.js +++ b/jstests/replsets/maxSyncSourceLagSecs.js @@ -5,18 +5,22 @@ (function() { "use strict"; var name = "maxSyncSourceLagSecs"; - var replTest = new ReplSetTest({name: name, - nodes: 3, - oplogSize: 5, - nodeOptions: {setParameter: "maxSyncSourceLagSecs=3"}}); + var replTest = new ReplSetTest({ + name: name, + nodes: 3, + oplogSize: 5, + nodeOptions: {setParameter: "maxSyncSourceLagSecs=3"} + }); var nodes = replTest.nodeList(); replTest.startSet(); - replTest.initiate({"_id": name, - "members": [ - { "_id": 0, "host": nodes[0], priority: 3 }, - { "_id": 1, "host": nodes[1], priority: 0 }, - { "_id": 2, "host": nodes[2], priority: 0 }], - }); + replTest.initiate({ + "_id": name, + "members": [ + {"_id": 0, "host": nodes[0], priority: 3}, + {"_id": 1, "host": nodes[1], priority: 0}, + {"_id": 2, "host": nodes[2], priority: 0} + ], + }); var master = replTest.getPrimary(); master.getDB("foo").bar.save({a: 1}); @@ -30,24 +34,24 @@ jsTestLog("Setting sync target of slave 2 to slave 1"); assert.commandWorked(slaves[1].getDB("admin").runCommand({replSetSyncFrom: slaves[0].name})); assert.soon(function() { - var res = slaves[1].getDB("admin").runCommand({"replSetGetStatus": 1}); - return res.syncingTo === slaves[0].name; - }, "sync target not changed to other slave"); + var res = slaves[1].getDB("admin").runCommand({"replSetGetStatus": 1}); + return res.syncingTo === slaves[0].name; + }, "sync target not changed to other slave"); printjson(replTest.status()); jsTestLog("Lock slave 1 and add some docs. Force sync target for slave 2 to change to primary"); - assert.commandWorked(slaves[0].getDB("admin").runCommand({fsync:1, lock: 1})); + assert.commandWorked(slaves[0].getDB("admin").runCommand({fsync: 1, lock: 1})); master.getDB("foo").bar.save({a: 2}); assert.soon(function() { - var res = slaves[1].getDB("admin").runCommand({"replSetGetStatus": 1}); - return res.syncingTo === master.name; - }, "sync target not changed back to primary"); + var res = slaves[1].getDB("admin").runCommand({"replSetGetStatus": 1}); + return res.syncingTo === master.name; + }, "sync target not changed back to primary"); printjson(replTest.status()); assert.soon(function() { - return (slaves[1].getDB("foo").bar.count() === 2); - }, "slave should have caught up after syncing to primary."); + return (slaves[1].getDB("foo").bar.count() === 2); + }, "slave should have caught up after syncing to primary."); assert.commandWorked(slaves[0].getDB("admin").fsyncUnlock()); replTest.stopSet(); |