diff options
Diffstat (limited to 'jstests/parallel/update_serializability2.js')
-rw-r--r-- | jstests/parallel/update_serializability2.js | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/jstests/parallel/update_serializability2.js b/jstests/parallel/update_serializability2.js index c99eafea9ef..c2672491177 100644 --- a/jstests/parallel/update_serializability2.js +++ b/jstests/parallel/update_serializability2.js @@ -6,27 +6,28 @@ function test() { var N = 100000; var bulk = t.initializeUnorderedBulkOp(); - for ( var i = 0; i < N; i++ ) { - bulk.insert( { _id : i, a : i, b: N-i, x : 1, y : 1 } ); + for (var i = 0; i < N; i++) { + bulk.insert({_id: i, a: i, b: N - i, x: 1, y: 1}); } bulk.execute(); - t.ensureIndex( { a : 1 } ); - t.ensureIndex( { b : 1 } ); + t.ensureIndex({a: 1}); + t.ensureIndex({b: 1}); - var s1 = startParallelShell( "db.update_serializability1.update( { a : { $gte : 0 } }, { $set : { x : 2 } }, false, true );" ); - var s2 = startParallelShell( "db.update_serializability1.update( { b : { $lte : " + N + " } }, { $set : { y : 2 } }, false, true );" ); + var s1 = startParallelShell( + "db.update_serializability1.update( { a : { $gte : 0 } }, { $set : { x : 2 } }, false, true );"); + var s2 = startParallelShell("db.update_serializability1.update( { b : { $lte : " + N + + " } }, { $set : { y : 2 } }, false, true );"); s1(); s2(); // both operations should happen on every document - assert.eq( N, t.find( { x : 2, y : 2 } ).count() ); + assert.eq(N, t.find({x: 2, y: 2}).count()); } if (db.serverStatus().storageEngine.name == 'mmapv1') { - jsTest.log('skipping test on mmapv1'); // This is only guaranteed on other engines. -} -else { + jsTest.log('skipping test on mmapv1'); // This is only guaranteed on other engines. +} else { test(); } |