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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
/* test durability
runs mongod, kill -9's, recovers
*/
var debugging = false;
var testname = "dur2";
var step = 1;
var conn = null;
var start = new Date();
function howLongSecs() {
return (new Date() - start) / 1000;
}
function log(str) {
if(str)
print("\n" + testname+" step " + step++ + " " + str);
else
print(testname+" step " + step++);
}
function verify() {
log("verify");
var d = conn.getDB("test");
var mycount = d.foo.count();
//print("count:" + mycount);
assert(mycount>2, "count wrong");
}
function work() {
log("work");
x = 'x'; while(x.length < 1024) x+=x;
var d = conn.getDB("test");
d.foo.drop();
d.foo.insert({});
// go long enough we will have time to kill it later during recovery
var j = 2;
var MaxTime = 90;
while (1) {
d.foo.insert({ _id: j, z: x });
d.foo.update({ _id: j }, { $inc: { a: 1} });
if (j % 25 == 0)
d.foo.remove({ _id: j });
j++;
if( j % 3 == 0 )
d.foo.update({ _id: j }, { $inc: { a: 1} }, true);
if (j % 10000 == 0)
print(j);
if (howLongSecs() > MaxTime)
break;
}
verify();
d.runCommand({ getLastError: 1, fsync: 1 });
}
if( debugging ) {
// mongod already running in debugger
print("DOING DEBUG MODE BEHAVIOR AS 'db' IS DEFINED -- RUN mongo --nodb FOR REGULAR TEST BEHAVIOR");
conn = db.getMongo();
work();
sleep(30000);
quit();
}
// directories
var path = "/data/db/" + testname+"dur";
log("run mongod with --dur");
conn = startMongodEmpty("--port", 30001, "--dbpath", path, "--dur", "--smallfiles", "--durOptions", /*DurParanoid*/8, "--master", "--oplogSize", 64);
work();
log("kill -9");
stopMongod(30001, /*signal*/9);
// journal file should be present, and non-empty as we killed hard
assert(listFiles(path + "/journal/").length > 0, "journal directory is unexpectantly empty after kill");
// restart and recover
log("restart mongod and recover");
conn = startMongodNoReset("--port", 30002, "--dbpath", path, "--dur", "--smallfiles", "--durOptions", 8, "--master", "--oplogSize", 64);
verify();
log("stopping mongod 30002");
stopMongod(30002);
print(testname + " SUCCESS");
|
