diff options
author | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:17:50 -0500 |
---|---|---|
committer | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:18:14 -0500 |
commit | 4ae691e8edc87d0e3cfb633bb91c328426be007b (patch) | |
tree | 52079a593f54382ca13a2e741633eab1b6271893 /jstests/replsets/stepdown3.js | |
parent | a025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff) | |
download | mongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz |
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/replsets/stepdown3.js')
-rw-r--r-- | jstests/replsets/stepdown3.js | 101 |
1 files changed, 51 insertions, 50 deletions
diff --git a/jstests/replsets/stepdown3.js b/jstests/replsets/stepdown3.js index 9bfda0ae82b..d0da019f7a1 100644 --- a/jstests/replsets/stepdown3.js +++ b/jstests/replsets/stepdown3.js @@ -3,58 +3,59 @@ // This test requires the fsync command to force a secondary to be stale. // @tags: [requires_fsync] (function() { -'use strict'; - -var replTest = new ReplSetTest({ name: 'testSet', nodes: 2 }); -var nodes = replTest.startSet(); -replTest.initiate(); -var master = replTest.getPrimary(); - -// do a write to allow stepping down of the primary; -// otherwise, the primary will refuse to step down -print("\ndo a write"); -master.getDB("test").foo.insert({x:1}); -replTest.awaitReplication(); - -// do another write, because the first one might be longer than 10 seconds ago -// on the secondary (due to starting up), and we need to be within 10 seconds -// to step down. -var options = { writeConcern: { w: 2, wtimeout: 30000 }}; -assert.writeOK(master.getDB("test").foo.insert({ x: 2 }, options)); -// lock secondary, to pause replication -print("\nlock secondary"); -var locked = replTest.liveNodes.slaves[0]; -printjson( locked.getDB("admin").runCommand({fsync : 1, lock : 1}) ); - -// do a write -print("\ndo a write"); -master.getDB("test").foo.insert({x:3}); - -// step down the primary asyncronously -print("stepdown"); -var command = "sleep(4000); tojson(db.adminCommand( { replSetStepDown : 60, force : 1 } ));"; -var awaitShell = startParallelShell(command, master.port); - -print("getlasterror; should assert or return an error, depending on timing"); -var gleFunction = function() { - var result = master.getDB("test").runCommand({getLastError : 1, w: 2 , wtimeout :30000 }); - if (result.errmsg === "not master" || - result.code == ErrorCodes.NotMaster || - result.code == ErrorCodes.InterruptedDueToReplStateChange) { - throw new Error("satisfy assert.throws()"); - } - print("failed to throw exception; GLE returned: "); + 'use strict'; + + var replTest = new ReplSetTest({name: 'testSet', nodes: 2}); + var nodes = replTest.startSet(); + replTest.initiate(); + var master = replTest.getPrimary(); + + // do a write to allow stepping down of the primary; + // otherwise, the primary will refuse to step down + print("\ndo a write"); + master.getDB("test").foo.insert({x: 1}); + replTest.awaitReplication(); + + // do another write, because the first one might be longer than 10 seconds ago + // on the secondary (due to starting up), and we need to be within 10 seconds + // to step down. + var options = { + writeConcern: {w: 2, wtimeout: 30000} + }; + assert.writeOK(master.getDB("test").foo.insert({x: 2}, options)); + // lock secondary, to pause replication + print("\nlock secondary"); + var locked = replTest.liveNodes.slaves[0]; + printjson(locked.getDB("admin").runCommand({fsync: 1, lock: 1})); + + // do a write + print("\ndo a write"); + master.getDB("test").foo.insert({x: 3}); + + // step down the primary asyncronously + print("stepdown"); + var command = "sleep(4000); tojson(db.adminCommand( { replSetStepDown : 60, force : 1 } ));"; + var awaitShell = startParallelShell(command, master.port); + + print("getlasterror; should assert or return an error, depending on timing"); + var gleFunction = function() { + var result = master.getDB("test").runCommand({getLastError: 1, w: 2, wtimeout: 30000}); + if (result.errmsg === "not master" || result.code == ErrorCodes.NotMaster || + result.code == ErrorCodes.InterruptedDueToReplStateChange) { + throw new Error("satisfy assert.throws()"); + } + print("failed to throw exception; GLE returned: "); + printjson(result); + }; + var result = assert.throws(gleFunction); + print("result of gle:"); printjson(result); -}; -var result = assert.throws(gleFunction); -print("result of gle:"); -printjson(result); -var exitCode = awaitShell({checkExitSuccess: false}); -assert.neq(0, exitCode, "expected replSetStepDown to close the shell's connection"); + var exitCode = awaitShell({checkExitSuccess: false}); + assert.neq(0, exitCode, "expected replSetStepDown to close the shell's connection"); -// unlock and shut down -printjson(locked.getDB("admin").fsyncUnlock()); -replTest.stopSet(); + // unlock and shut down + printjson(locked.getDB("admin").fsyncUnlock()); + replTest.stopSet(); })(); |