2010-10-05 05:53:48 +02:00
|
|
|
t = db.jstests_killop
|
|
|
|
t.drop();
|
|
|
|
|
2010-10-06 06:49:21 +02:00
|
|
|
if ( typeof _threadInject == "undefined" ) { // don't run in v8 mode - SERVER-1900
|
|
|
|
|
2010-10-05 05:53:48 +02:00
|
|
|
function debug( x ) {
|
2010-10-05 06:31:50 +02:00
|
|
|
// printjson( x );
|
2010-10-05 05:53:48 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
t.save( {} );
|
|
|
|
db.getLastError();
|
|
|
|
|
|
|
|
function ops() {
|
|
|
|
p = db.currentOp().inprog;
|
|
|
|
debug( p );
|
|
|
|
ids = [];
|
|
|
|
for ( var i in p ) {
|
|
|
|
var o = p[ i ];
|
|
|
|
if ( o.active && o.query && o.query.query && o.query.query.$where && o.ns == "test.jstests_killop" ) {
|
|
|
|
ids.push( o.opid );
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return ids;
|
|
|
|
}
|
|
|
|
|
|
|
|
s1 = startParallelShell( "db.jstests_killop.count( { $where: function() { while( 1 ) { ; } } } )" );
|
|
|
|
s2 = startParallelShell( "db.jstests_killop.count( { $where: function() { while( 1 ) { ; } } } )" );
|
|
|
|
|
|
|
|
o = [];
|
|
|
|
assert.soon( function() { o = ops(); return o.length == 2; } );
|
2010-10-06 06:49:21 +02:00
|
|
|
debug( o );
|
2010-10-05 05:53:48 +02:00
|
|
|
db.killOp( o[ 0 ] );
|
|
|
|
db.killOp( o[ 1 ] );
|
|
|
|
|
|
|
|
start = new Date();
|
|
|
|
|
|
|
|
s1();
|
|
|
|
s2();
|
|
|
|
|
|
|
|
// don't want to pass if timeout killed the js function
|
|
|
|
assert( ( new Date() ) - start < 30000 );
|
2010-10-06 06:49:21 +02:00
|
|
|
|
|
|
|
}
|