blob: dd7e5d9aee72881902f1f6598b5fac2542a33506 (
plain)
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
|
t = db.query_yield2;
t.drop()
N = 200;
i = 0;
q = function(){ var x=this.n; for ( var i=0; i<25000; i++ ){ x = x * 2; } return false; }
while ( true ){
function fill(){
for ( ; i<N; i++ ){
t.insert( { _id : i , n : 1 } )
}
}
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_yield2.find( function(){ var x=this.n; for ( var i=0; i<50000; 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();
while ( ( (new Date()).getTime() - start ) < ( time * 2 ) ){
var me = Date.timeFunc( function(){ t.insert( { x : 1 } ); db.getLastError(); } )
var x = db.currentOp()
if ( num++ == 0 ){
assert.eq( 1 , x.inprog.length , "nothing in prog" );
}
assert.gt( 100 , me );
if ( x.inprog.length == 0 )
break;
}
join();
var x = db.currentOp()
assert.eq( 0 , x.inprog.length , "weird 2" );
|
