jstests/replsets/replset3.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56


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});

    // Step down master
    master.getDB("admin").runCommand({replSetStepDown: true});

    try {
      var new_master = replTest.getMaster();
    }
    catch( err ) {
      throw( "Could not elect new master before timeout." );
    }

    assert( master != new_master, "Old master shouldn't be equal to new master." );

    // 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 );

    slaves = replTest.liveNodes.slaves;
    assert.soon(function() {
        res = slaves[0].getDB("admin").runCommand({replSetGetStatus: 1})
        return res.myState == 2;
    }, "Slave 0 state not ready.");

    assert.soon(function() {
        res = slaves[1].getDB("admin").runCommand({replSetGetStatus: 1})
        return res.myState == 2;
    }, "Slave 1 state not ready.");

    replTest.stopSet( 15 );
}

doTest( 15 );