diff options
Diffstat (limited to 'jstests/parallel/repl.js')
-rw-r--r-- | jstests/parallel/repl.js | 68 |
1 files changed, 34 insertions, 34 deletions
diff --git a/jstests/parallel/repl.js b/jstests/parallel/repl.js index 714d0f7742e..314cd4df335 100644 --- a/jstests/parallel/repl.js +++ b/jstests/parallel/repl.js @@ -3,59 +3,59 @@ load('jstests/libs/parallelTester.js'); baseName = "parallel_repl"; -rt = new ReplTest( baseName ); +rt = new ReplTest(baseName); -m = rt.start( true ); -s = rt.start( false ); +m = rt.start(true); +s = rt.start(false); // tests need to run against master server -db = m.getDB( "test" ); +db = m.getDB("test"); host = db.getMongo().host; Random.setRandomSeed(); t = new ParallelTester(); -for( id = 0; id < 10; ++id ) { - var g = new EventGenerator( id, baseName, Random.randInt( 20 ), host ); - for( var j = 0; j < 1000; ++j ) { - var op = Random.randInt( 3 ); - switch( op ) { - case 0: // insert - g.addInsert( { _id:Random.randInt( 1000 ) } ); +for (id = 0; id < 10; ++id) { + var g = new EventGenerator(id, baseName, Random.randInt(20), host); + for (var j = 0; j < 1000; ++j) { + var op = Random.randInt(3); + switch (op) { + case 0: // insert + g.addInsert({_id: Random.randInt(1000)}); break; - case 1: // remove - g.addRemove( { _id:Random.randInt( 1000 ) } ); + case 1: // remove + g.addRemove({_id: Random.randInt(1000)}); break; - case 2: // update - g.addUpdate( {_id:{$lt:1000}}, {$inc:{a:5}} ); + case 2: // update + g.addUpdate({_id: {$lt: 1000}}, {$inc: {a: 5}}); break; default: - assert( false, "Invalid op code" ); + assert(false, "Invalid op code"); } } - t.add( EventGenerator.dispatch, g.getEvents() ); + t.add(EventGenerator.dispatch, g.getEvents()); } -var g = new EventGenerator( id, baseName, Random.randInt( 5 ), host ); -for( var j = 1000; j < 3000; ++j ) { - g.addCheckCount( j - 1000, { _id: {$gte:1000} }, j % 100 == 0, j % 500 == 0 ); - g.addInsert( {_id:j} ); +var g = new EventGenerator(id, baseName, Random.randInt(5), host); +for (var j = 1000; j < 3000; ++j) { + g.addCheckCount(j - 1000, {_id: {$gte: 1000}}, j % 100 == 0, j % 500 == 0); + g.addInsert({_id: j}); } -t.add( EventGenerator.dispatch, g.getEvents() ); +t.add(EventGenerator.dispatch, g.getEvents()); -t.run( "one or more tests failed" ); +t.run("one or more tests failed"); -masterValidation = m.getDB( "test" )[ baseName ].validate(); -assert( masterValidation.valid, tojson( masterValidation ) ); +masterValidation = m.getDB("test")[baseName].validate(); +assert(masterValidation.valid, tojson(masterValidation)); -slaveValidation = s.getDB( "test" )[ baseName ].validate(); -assert( slaveValidation.valid, tojson( slaveValidation ) ); +slaveValidation = s.getDB("test")[baseName].validate(); +assert(slaveValidation.valid, tojson(slaveValidation)); -assert.soon( function() { - mh = m.getDB( "test" ).runCommand( "dbhash" ); -// printjson( mh ); - sh = s.getDB( "test" ).runCommand( "dbhash" ); -// printjson( sh ); - return mh.md5 == sh.md5; - } ); +assert.soon(function() { + mh = m.getDB("test").runCommand("dbhash"); + // printjson( mh ); + sh = s.getDB("test").runCommand("dbhash"); + // printjson( sh ); + return mh.md5 == sh.md5; +}); |