// Test that setting maxSyncSourceLagSecs causes the set to change sync target
//
// This test requires the fsync command to ensure members experience a delay.
// @tags: [requires_fsync]
(function() {
    "use strict";
    var name = "maxSyncSourceLagSecs";
    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 }],
                      });

    var master = replTest.getPrimary();
    master.getDB("foo").bar.save({a: 1});
    replTest.awaitReplication();
    var slaves = replTest.liveNodes.slaves;

    // need to put at least maxSyncSourceLagSecs b/w first op and subsequent ops
    // so that the shouldChangeSyncSource logic goes into effect
    sleep(4000);

    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");
    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}));
    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");
    printjson(replTest.status());

    assert.soon(function() {
            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();
}());