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
89
90
91
|
if (0) { // Test disabled until SERVER-8579 is finished. Reminder ticket: SERVER-8342
load("jstests/libs/slow_weekly_util.js");
testServer = new SlowWeeklyMongod("query_yield1");
db = testServer.getDB("test");
t = db.query_yield1;
t.drop();
N = 20000;
i = 0;
q = function() {
var x = this.n;
for (var i = 0; i < 250; i++) {
x = x * 2;
}
return false;
};
while (true) {
function fill() {
var bulk = t.initializeUnorderedBulkOp();
for (; i < N; i++) {
bulk.insert({_id: i, n: 1});
}
assert.writeOK(bulk.execute());
}
function timeQuery() {
return Date.timeFunc(function() {
assert.eq(0, t.find(q).itcount());
});
}
fill();
timeQuery();
timeQuery();
time = timeQuery();
print(N + "\t" + time);
if (time > 2000)
break;
N *= 2;
}
// --- test 1
assert.eq(0, db.currentOp().inprog.length, "setup broken");
join = startParallelShell(
"print( 0 == db.query_yield1.find( function(){ var x=this.n; for ( var i=0; i<500; i++ ){ x = x * 2; } return false; } ).itcount() ); ");
assert.soon(function() {
var x = db.currentOp().inprog;
return x.length > 0;
}, "never doing query", 2000, 1);
print("start query");
num = 0;
start = new Date();
biggestMe = 0;
while (((new Date()).getTime() - start) < (time * 2)) {
var me = Date.timeFunc(function() {
t.insert({x: 1});
});
var x = db.currentOp();
if (num++ == 0) {
assert.eq(1, x.inprog.length, "nothing in prog");
}
if (me > biggestMe) {
biggestMe = me;
print("biggestMe: " + biggestMe);
}
assert.gt(200, me, "took too long for me to run");
if (x.inprog.length == 0)
break;
}
join();
var x = db.currentOp();
assert.eq(0, x.inprog.length, "weird 2");
testServer.stop();
}
|
