blob: d50f2126115884cdc94c8fceee93c974c6511e20 (
plain)
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
|
// Test that setting maxSyncSourceLagSecs causes the set to change sync target
var replTest = new ReplSetTest({ nodes: 3, oplogSize: 5,
nodeOptions: {setParameter: "maxSyncSourceLagSecs=5"}});
replTest.startSet();
replTest.initiate();
var master = replTest.getMaster();
var docNum = 100;
for (i=0; i<docNum; i++) {
master.getDB("foo").bar.save({a: i});
}
replTest.awaitReplication();
var slaves = replTest.liveNodes.slaves;
jsTestLog("Setting sync target of slave 2 to slave 1");
assert.commandWorked(slaves[1].getDB("admin").runCommand({replSetSyncFrom: slaves[0].name}));
assert.soon(function() {
return (replTest.status().members[2].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}));
var docNum = 100;
for (var i=0; i<docNum; i++) {
master.getDB("foo").bar.save({a: i});
}
assert.soon(function() {
return (replTest.status().members[2].syncingTo == master.name);
}, "sync target not changed back to primary");
printjson(replTest.status);
assert.soon(function() {
return (slaves[1].getDB("foo").bar.count() == 200);
}, "slave should have caught up after syncing to primary.");
assert.commandWorked(slaves[0].getDB("admin").$cmd.sys.unlock.findOne());
replTest.stopSet();
|
