diff options
author | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:17:50 -0500 |
---|---|---|
committer | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:18:14 -0500 |
commit | 4ae691e8edc87d0e3cfb633bb91c328426be007b (patch) | |
tree | 52079a593f54382ca13a2e741633eab1b6271893 /jstests/repl/repl6.js | |
parent | a025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff) | |
download | mongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz |
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/repl/repl6.js')
-rw-r--r-- | jstests/repl/repl6.js | 114 |
1 files changed, 57 insertions, 57 deletions
diff --git a/jstests/repl/repl6.js b/jstests/repl/repl6.js index a26a7be94e5..c9ccdbdd559 100644 --- a/jstests/repl/repl6.js +++ b/jstests/repl/repl6.js @@ -8,75 +8,75 @@ var baseName = "jstests_repl6test"; -soonCount = function( m, count ) { - assert.soon( function() { - return m.getDB( baseName ).a.find().count() == count; - }, "expected count: " + count + " from : " + m ); +soonCount = function(m, count) { + assert.soon(function() { + return m.getDB(baseName).a.find().count() == count; + }, "expected count: " + count + " from : " + m); }; -doTest = function( signal ) { - - ports = allocatePorts( 3 ); - - ms1 = new ReplTest( "repl6tests-1", [ ports[ 0 ], ports[ 1 ] ] ); - ms2 = new ReplTest( "repl6tests-2", [ ports[ 0 ], ports[ 2 ] ] ); - - m = ms1.start( true ); - s1 = ms1.start( false ); - s2 = ms2.start( false ); - - am = m.getDB( baseName ).a; - - for( i = 0; i < 1000; ++i ) - am.save( { _id: new ObjectId(), i: i } ); - - soonCount( s1, 1000 ); - soonCount( s2, 1000 ); - - check = function( as ) { - assert.eq( 1, as.find( { i: 0 } ).count() ); - assert.eq( 1, as.find( { i: 999 } ).count() ); +doTest = function(signal) { + + ports = allocatePorts(3); + + ms1 = new ReplTest("repl6tests-1", [ports[0], ports[1]]); + ms2 = new ReplTest("repl6tests-2", [ports[0], ports[2]]); + + m = ms1.start(true); + s1 = ms1.start(false); + s2 = ms2.start(false); + + am = m.getDB(baseName).a; + + for (i = 0; i < 1000; ++i) + am.save({_id: new ObjectId(), i: i}); + + soonCount(s1, 1000); + soonCount(s2, 1000); + + check = function(as) { + assert.eq(1, as.find({i: 0}).count()); + assert.eq(1, as.find({i: 999}).count()); }; - - as = s1.getDB( baseName ).a; - check( as ); - as = s2.getDB( baseName ).a; - check( as ); - ms1.stop( false, signal ); - ms2.stop( false, signal ); - - for( i = 1000; i < 1010; ++i ) - am.save( { _id: new ObjectId(), i: i } ); + as = s1.getDB(baseName).a; + check(as); + as = s2.getDB(baseName).a; + check(as); + + ms1.stop(false, signal); + ms2.stop(false, signal); + + for (i = 1000; i < 1010; ++i) + am.save({_id: new ObjectId(), i: i}); - s1 = ms1.start( false, null, true ); - soonCount( s1, 1010 ); - as = s1.getDB( baseName ).a; - assert.eq( 1, as.find( { i: 1009 } ).count() ); + s1 = ms1.start(false, null, true); + soonCount(s1, 1010); + as = s1.getDB(baseName).a; + assert.eq(1, as.find({i: 1009}).count()); - ms1.stop( true, signal ); + ms1.stop(true, signal); // Need to pause here on Windows, since killing processes does not synchronously close their // open file handles. sleep(5000); - m = ms1.start( true, null, true ); - am = m.getDB( baseName ).a; - - for( i = 1010; i < 1020; ++i ) - am.save( { _id: new ObjectId(), i: i } ); - - soonCount( s1, 1020 ); - assert.eq( 1, as.find( { i: 1019 } ).count() ); - - s2 = ms2.start( false, null, true ); - soonCount( s2, 1020 ); - as = s2.getDB( baseName ).a; - assert.eq( 1, as.find( { i: 1009 } ).count() ); - assert.eq( 1, as.find( { i: 1019 } ).count() ); + m = ms1.start(true, null, true); + am = m.getDB(baseName).a; + + for (i = 1010; i < 1020; ++i) + am.save({_id: new ObjectId(), i: i}); + + soonCount(s1, 1020); + assert.eq(1, as.find({i: 1019}).count()); + + s2 = ms2.start(false, null, true); + soonCount(s2, 1020); + as = s2.getDB(baseName).a; + assert.eq(1, as.find({i: 1009}).count()); + assert.eq(1, as.find({i: 1019}).count()); ms1.stop(); - ms2.stop( false ); + ms2.stop(false); }; -doTest( 15 ); // SIGTERM +doTest(15); // SIGTERM |