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
57
58
59
60
61
62
63
|
// test basic operations in parallel, with replication
// @tags: [requires_replication]
load('jstests/libs/parallelTester.js');
baseName = "parallel_repl";
rt = new ReplTest(baseName);
m = rt.start(true);
s = rt.start(false);
// tests need to run against master server
db = m.getDB("test");
host = db.getMongo().host;
Random.setRandomSeed();
t = new ParallelTester();
for (id = 0; id < 10; ++id) {
var g = new EventGenerator(id, baseName, Random.randInt(20), host);
for (var j = 0; j < 1000; ++j) {
var op = Random.randInt(3);
switch (op) {
case 0: // insert
g.addInsert({_id: Random.randInt(1000)});
break;
case 1: // remove
g.addRemove({_id: Random.randInt(1000)});
break;
case 2: // update
g.addUpdate({_id: {$lt: 1000}}, {$inc: {a: 5}});
break;
default:
assert(false, "Invalid op code");
}
}
t.add(EventGenerator.dispatch, g.getEvents());
}
var g = new EventGenerator(id, baseName, Random.randInt(5), host);
for (var j = 1000; j < 3000; ++j) {
g.addCheckCount(j - 1000, {_id: {$gte: 1000}}, j % 100 == 0, j % 500 == 0);
g.addInsert({_id: j});
}
t.add(EventGenerator.dispatch, g.getEvents());
t.run("one or more tests failed");
masterValidation = m.getDB("test")[baseName].validate();
assert(masterValidation.valid, tojson(masterValidation));
slaveValidation = s.getDB("test")[baseName].validate();
assert(slaveValidation.valid, tojson(slaveValidation));
assert.soon(function() {
mh = m.getDB("test").runCommand("dbhash");
// printjson( mh );
sh = s.getDB("test").runCommand("dbhash");
// printjson( sh );
return mh.md5 == sh.md5;
});
rt.stop();
|
