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
|
// Test SERVER-623 - starting slave from a new snapshot
//
// This test requires persistence because it assumes copying the dbpath with copy the data between
// nodes. There should not be any data in the dbpath for ephemeral storage engines, so this will not
// work. It also requires the fsync command to enduce replication lag.
// @tags: [requires_persistence, requires_fsync]
ports = allocatePorts(3);
var baseName = "repl_snapshot1";
rt1 = new ReplTest("repl_snapshot1-1", [ports[0], ports[1]]);
rt2 = new ReplTest("repl_snapshot1-2", [ports[0], ports[2]]);
m = rt1.start(true);
big = new Array(2000).toString();
for (i = 0; i < 1000; ++i)
m.getDB(baseName)[baseName].save({_id: new ObjectId(), i: i, b: big});
m.getDB("admin").runCommand({fsync: 1, lock: 1});
copyDbpath(rt1.getPath(true), rt1.getPath(false));
m.getDB("admin").fsyncUnlock();
s1 = rt1.start(false, null, true);
assert.eq(1000, s1.getDB(baseName)[baseName].count());
m.getDB(baseName)[baseName].save({i: 1000});
assert.soon(function() {
return 1001 == s1.getDB(baseName)[baseName].count();
});
s1.getDB("admin").runCommand({fsync: 1, lock: 1});
copyDbpath(rt1.getPath(false), rt2.getPath(false));
s1.getDB("admin").fsyncUnlock();
s2 = rt2.start(false, null, true);
assert.eq(1001, s2.getDB(baseName)[baseName].count());
m.getDB(baseName)[baseName].save({i: 1001});
assert.soon(function() {
return 1002 == s2.getDB(baseName)[baseName].count();
});
assert.soon(function() {
return 1002 == s1.getDB(baseName)[baseName].count();
});
assert(!rawMongoProgramOutput().match(/resync/));
|
