mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

indent

Browse Source
This commit is contained in:
Eliot Horowitz 2010-12-17 01:01:50 -05:00
parent 4efaae0566
commit 55cd8ae9d4
1 changed files with 85 additions and 85 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

170
jstests/mr_killop.js
View File

@ -3,33 +3,33 @@ t.drop();
if ( typeof _threadInject == "undefined" ) { // don't run in v8 mode - SERVER-1900
t.save( {a:1} );
db.getLastError();
t.save( {a:1} );
db.getLastError();
function debug( x ) {
// printjson( x );
}
function debug( x ) {
// printjson( x );
}
/** @return op code for map reduce op created by spawned shell, or that op's child */
function op( where ) {
p = db.currentOp().inprog;
debug( p );
for ( var i in p ) {
var o = p[ i ];
if ( where ) {
if ( o.active && o.ns == "test.jstests_mr_killop" && o.query && o.query.query && o.query.query.$where ) {
return o.opid;
}
} else {
if ( o.active && o.query && o.query.mapreduce && o.query.mapreduce == "jstests_mr_killop" ) {
return o.opid;
/** @return op code for map reduce op created by spawned shell, or that op's child */
function op( where ) {
p = db.currentOp().inprog;
debug( p );
for ( var i in p ) {
var o = p[ i ];
if ( where ) {
if ( o.active && o.ns == "test.jstests_mr_killop" && o.query && o.query.query && o.query.query.$where ) {
return o.opid;
}
} else {
if ( o.active && o.query && o.query.mapreduce && o.query.mapreduce == "jstests_mr_killop" ) {
return o.opid;
}
}
}
return -1;
}
return -1;
}
/**
/**
* Run one map reduce with the specified parameters in a parallel shell, kill the
* map reduce op or its child op with killOp, and wait for the map reduce op to
* terminate.
@ -37,76 +37,76 @@ function op( where ) {
* This is necessay for a child count $where of a map reduce op because child
* ops currently mask parent ops in currentOp.
*/
function testOne( map, reduce, finalize, scope, where, wait ) {
spec =
{
mapreduce:"jstests_mr_killop",
map: map,
reduce: reduce
};
if ( finalize ) {
spec[ "finalize" ] = finalize;
}
if ( scope ) {
spec[ "scope" ] = scope;
function testOne( map, reduce, finalize, scope, where, wait ) {
spec =
{
mapreduce:"jstests_mr_killop",
map: map,
reduce: reduce
};
if ( finalize ) {
spec[ "finalize" ] = finalize;
}
if ( scope ) {
spec[ "scope" ] = scope;
}
s = startParallelShell( "db.runCommand( " + tojson( spec ) + " );" );
if ( wait ) {
sleep( 2000 );
}
o = null;
assert.soon( function() { o = op( where ); return o != -1 } );
db.killOp( o );
// When the map reduce op is killed, the spawned shell will exit
s();
assert.eq( -1, op( where ) );
}
s = startParallelShell( "db.runCommand( " + tojson( spec ) + " );" );
if ( wait ) {
sleep( 2000 );
/** Test using wait and non wait modes */
function test( map, reduce, finalize, scope, where ) {
testOne( map, reduce, finalize, scope, where, false );
testOne( map, reduce, finalize, scope, where, true );
}
o = null;
assert.soon( function() { o = op( where ); return o != -1 } );
db.killOp( o );
// When the map reduce op is killed, the spawned shell will exit
s();
assert.eq( -1, op( where ) );
}
/** Test using wait and non wait modes */
function test( map, reduce, finalize, scope, where ) {
testOne( map, reduce, finalize, scope, where, false );
testOne( map, reduce, finalize, scope, where, true );
}
/** Test looping in map and reduce functions */
function runMRTests( loop, where ) {
test( loop, function( k, v ) { return v[ 0 ]; }, null, null, where );
test( function() { emit( this.id, 1 ); }, loop, null, null, where );
test( function() { loop(); }, function( k, v ) { return v[ 0 ] }, null, { loop: loop }, where );
}
/** Test looping in finalize function */
function runFinalizeTests( loop, where ) {
test( function() { emit( this.id, 1 ); }, function( k, v ) { return v[ 0 ] }, loop, null, where );
test( function() { emit( this.id, 1 ); }, function( k, v ) { return v[ 0 ] }, function( a, b ) { loop() }, { loop: loop }, where );
}
var loop = function() {
while( 1 ) {
;
/** Test looping in map and reduce functions */
function runMRTests( loop, where ) {
test( loop, function( k, v ) { return v[ 0 ]; }, null, null, where );
test( function() { emit( this.id, 1 ); }, loop, null, null, where );
test( function() { loop(); }, function( k, v ) { return v[ 0 ] }, null, { loop: loop }, where );
}
}
runMRTests( loop, false );
runFinalizeTests( loop, false );
var loop = function() {
while( 1 ) {
db.jstests_mr_killop.count( { a:1 } );
/** Test looping in finalize function */
function runFinalizeTests( loop, where ) {
test( function() { emit( this.id, 1 ); }, function( k, v ) { return v[ 0 ] }, loop, null, where );
test( function() { emit( this.id, 1 ); }, function( k, v ) { return v[ 0 ] }, function( a, b ) { loop() }, { loop: loop }, where );
}
}
runMRTests( loop, false );
// db can't be accessed from finalize() so not running that test
/** Test that we can kill the child op of a map reduce op */
var loop = function() {
db.jstests_mr_killop.count( {$where:function() { while( 1 ) { ; } }} );
}
runMRTests( loop, true );
var loop = function() {
while( 1 ) {
;
}
}
runMRTests( loop, false );
runFinalizeTests( loop, false );
}
var loop = function() {
while( 1 ) {
db.jstests_mr_killop.count( { a:1 } );
}
}
runMRTests( loop, false );
// db can't be accessed from finalize() so not running that test
/** Test that we can kill the child op of a map reduce op */
var loop = function() {
db.jstests_mr_killop.count( {$where:function() { while( 1 ) { ; } }} );
}
runMRTests( loop, true );
}