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
|
baseName = "jstests_shellkillop";
// 'retry' should be set to true in contexts where an exception should cause the test to be retried
// rather than to fail.
retry = false;
function testShellAutokillop() {
if (true) { // toggle to disable test
db[baseName].drop();
print("shellkillop.js insert data");
for (i = 0; i < 100000; ++i) {
db[baseName].insert({i: 1});
}
assert.eq(100000, db[baseName].count());
// mongo --autokillop suppressed the ctrl-c "do you want to kill current operation" message
// it's just for testing purposes and thus not in the shell help
var evalStr = "print('SKO subtask started'); db." + baseName +
".update( {}, {$set:{i:'abcdefghijkl'}}, false, true ); db." + baseName + ".count();";
print("shellkillop.js evalStr:" + evalStr);
spawn = startMongoProgramNoConnect(
"mongo", "--autokillop", "--port", myPort(), "--eval", evalStr);
sleep(100);
retry = true;
assert(db[baseName].find({i: 'abcdefghijkl'}).count() < 100000,
"update ran too fast, test won't be valid");
retry = false;
stopMongoProgramByPid(spawn);
sleep(100);
print("count abcdefghijkl:" + db[baseName].find({i: 'abcdefghijkl'}).count());
var inprog = db.currentOp().inprog;
for (i in inprog) {
if (inprog[i].ns == "test." + baseName)
throw Error("shellkillop.js op is still running: " + tojson(inprog[i]));
}
retry = true;
assert(db[baseName].find({i: 'abcdefghijkl'}).count() < 100000,
"update ran too fast, test was not valid");
retry = false;
}
}
for (var nTries = 0; nTries < 10 && retry; ++nTries) {
try {
testShellAutokillop();
} catch (e) {
if (!retry) {
throw e;
}
printjson(e);
print("retrying...");
}
}
assert(!retry, "retried too many times");
print("shellkillop.js SUCCESS");
|
