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
|
t = db.jstests_killop
t.drop();
if ( typeof _threadInject == "undefined" ) { // don't run in v8 mode - SERVER-1900
function debug( x ) {
// printjson( x );
}
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; } );
debug( o );
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 );
}
|