diff options
author | Antonin Kral <a.kral@bobek.cz> | 2011-03-17 00:05:43 +0100 |
---|---|---|
committer | Antonin Kral <a.kral@bobek.cz> | 2011-03-17 00:05:43 +0100 |
commit | 582fc32574a3b158c81e49cb00e6ae59205e66ba (patch) | |
tree | ac64a3243e0d2121709f685695247052858115c8 /jstests/slowWeekly/update_yield1.js | |
parent | 2761bffa96595ac1698d86bbc2e95ebb0d4d6e93 (diff) | |
download | mongodb-582fc32574a3b158c81e49cb00e6ae59205e66ba.tar.gz |
Imported Upstream version 1.8.0
Diffstat (limited to 'jstests/slowWeekly/update_yield1.js')
-rw-r--r-- | jstests/slowWeekly/update_yield1.js | 21 |
1 files changed, 12 insertions, 9 deletions
diff --git a/jstests/slowWeekly/update_yield1.js b/jstests/slowWeekly/update_yield1.js index 2e63690..7e95855 100644 --- a/jstests/slowWeekly/update_yield1.js +++ b/jstests/slowWeekly/update_yield1.js @@ -27,7 +27,7 @@ while ( true ){ timeUpdate(); time = timeUpdate(); print( N + "\t" + time ); - if ( time > 2000 ) + if ( time > 8000 ) break; N *= 2; @@ -47,13 +47,14 @@ num = 0; start = new Date(); while ( ( (new Date()).getTime() - start ) < ( time * 2 ) ){ var me = Date.timeFunc( function(){ t.findOne(); } ); + if (me > 50) print("time: " + me); if ( num++ == 0 ){ var x = db.currentOp() assert.eq( 1 , x.inprog.length , "nothing in prog" ); } - assert.gt( 50 , me ); + assert.gt( 2000 , me ); } join(); @@ -65,14 +66,16 @@ assert.eq( 0 , x.inprog.length , "weird 2" ); join = startParallelShell( "db.update_yield1.update( { $atomic : true } , { $inc : { n : 1 } } , false , true ); db.getLastError()" ); -assert.soon( - function(){ - return db.currentOp().inprog.length > 0; - } , "never doing update 2" -); +sleep(1000); // wait for shell startup ops to finish + +var x = db.currentOp(); +printjson(x); +assert.eq(1, x.inprog.length, "never doing update 2"); +assert.eq("update", x.inprog[0].op); + +t.findOne(); // should wait for update to finish -t.findOne(); var x = db.currentOp() -assert.eq( 0 , x.inprog.length , "should have been atomic" ); +assert.eq( [] , x.inprog , "should have been atomic" ); join(); |