summaryrefslogtreecommitdiff
path: root/jstests/slowWeekly/update_yield1.js
diff options
context:
space:
mode:
authorAntonin Kral <a.kral@bobek.cz>2011-03-17 00:05:43 +0100
committerAntonin Kral <a.kral@bobek.cz>2011-03-17 00:05:43 +0100
commit582fc32574a3b158c81e49cb00e6ae59205e66ba (patch)
treeac64a3243e0d2121709f685695247052858115c8 /jstests/slowWeekly/update_yield1.js
parent2761bffa96595ac1698d86bbc2e95ebb0d4d6e93 (diff)
downloadmongodb-582fc32574a3b158c81e49cb00e6ae59205e66ba.tar.gz
Imported Upstream version 1.8.0
Diffstat (limited to 'jstests/slowWeekly/update_yield1.js')
-rw-r--r--jstests/slowWeekly/update_yield1.js21
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();