summaryrefslogtreecommitdiff
path: root/jstests/repl/repl6.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/repl/repl6.js')
-rw-r--r--jstests/repl/repl6.js114
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