doTest = function (signal) { // Test replica set step down // Replica set testing API // Create a new replica set test. Specify set name and the number of nodes you want. var replTest = new ReplSetTest({ name: 'testSet', nodes: 3 }); // call startSet() to start each mongod in the replica set // this returns a list of nodes var nodes = replTest.startSet(); // Call initiate() to send the replSetInitiate command // This will wait for initiation replTest.initiate(); // Get master node var master = replTest.getMaster(); // Write some data to master // NOTE: this test fails unless we write some data. master.getDB("foo").foo.save({ a: 1 }); master.getDB("foo").runCommand({ getlasterror: 1, w: 3, wtimeout: 20000 }); var phase = 1; print(phase++); // Step down master. Note: this may close our connection! try { master.getDB("admin").runCommand({ replSetStepDown: true }); } catch (err) { print("caught: " + err + " on stepdown"); } print(phase++); try { var new_master = replTest.getMaster(); } catch (err) { throw ("Could not elect new master before timeout."); } print(phase++); assert(master != new_master, "Old master shouldn't be equal to new master."); print(phase++); // Make sure that slaves are still up var result = new_master.getDB("admin").runCommand({ replSetGetStatus: 1 }); assert(result['ok'] == 1, "Could not verify that slaves were still up:" + result); print(phase++); slaves = replTest.liveNodes.slaves; assert.soon(function () { try { res = slaves[0].getDB("admin").runCommand({ replSetGetStatus: 1 }) } catch (err) { } return res.myState == 2; }, "Slave 0 state not ready."); print(phase++); assert.soon(function () { try { res = slaves[1].getDB("admin").runCommand({ replSetGetStatus: 1 }) } catch (err) { } return res.myState == 2; }, "Slave 1 state not ready."); print("replset3.js SUCCESS"); replTest.stopSet(15); } doTest( 15 );