summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKristina Chodorow <kristina@10gen.com>2010-11-15 12:14:54 -0500
committerKristina Chodorow <kristina@10gen.com>2010-11-15 12:14:54 -0500
commit6d97633a36e2fb589ab68cdefe6ea727d4f3f2aa (patch)
tree10a8f65676ce37bab15aa6b610e7bd238ea92c05
parentd7b885a44f4816874cdb69e6962f483147f9ed43 (diff)
downloadmongo-6d97633a36e2fb589ab68cdefe6ea727d4f3f2aa.tar.gz
add debugging to tests that failed in 1.6
Conflicts: jstests/repl/mastermaster1.js
-rw-r--r--jstests/repl/mastermaster1.js8
-rw-r--r--jstests/repl/pair3.js32
2 files changed, 26 insertions, 14 deletions
diff --git a/jstests/repl/mastermaster1.js b/jstests/repl/mastermaster1.js
index d0fcec3814f..9f9334b17ae 100644
--- a/jstests/repl/mastermaster1.js
+++ b/jstests/repl/mastermaster1.js
@@ -16,9 +16,13 @@ ldb = left.getDB( "test" )
rdb = right.getDB( "test" )
ldb.foo.insert( { _id : 1 , x : "eliot" } )
-ldb.runCommand( { getlasterror : 1 , w : 2 } )
+var result = ldb.runCommand( { getlasterror : 1 , w : 2 , wtimeout : 20000 } );
+printjson(result);
rdb.foo.insert( { _id : 2 , x : "sara" } )
-rdb.runCommand( { getlasterror : 1 , w : 2 } )
+result = rdb.runCommand( { getlasterror : 1 , w : 2 , wtimeout : 20000 } )
+printjson(result);
+
+print( "check 3" )
assert.eq( 2 , ldb.foo.count() , "B1" )
assert.eq( 2 , rdb.foo.count() , "B2" )
diff --git a/jstests/repl/pair3.js b/jstests/repl/pair3.js
index d1cf99ab72a..d5fdf7eee5c 100644
--- a/jstests/repl/pair3.js
+++ b/jstests/repl/pair3.js
@@ -12,32 +12,40 @@ ismaster = function( n ) {
// bring up node connections before arbiter connections so that arb can forward to node when expected
connect = function() {
if ( lp == null ) {
+ print("connecting lp");
lp = startMongoProgram( "mongobridge", "--port", lpPort, "--dest", "localhost:" + lPort );
}
if ( rp == null ) {
+ print("connecting rp");
rp = startMongoProgram( "mongobridge", "--port", rpPort, "--dest", "localhost:" + rPort );
}
if ( al == null ) {
+ print("connecting al");
al = startMongoProgram( "mongobridge", "--port", alPort, "--dest", "localhost:" + aPort );
}
if ( ar == null ) {
+ print("connecting ar");
ar = startMongoProgram( "mongobridge", "--port", arPort, "--dest", "localhost:" + aPort );
}
}
-disconnectNode = function( mongo ) {
+disconnectNode = function( mongo ) {
if ( lp ) {
+ print("disconnecting lp: "+lpPort);
stopMongoProgram( lpPort );
lp = null;
}
if ( rp ) {
+ print("disconnecting rp: "+rpPort);
stopMongoProgram( rpPort );
rp = null;
}
if ( mongo.host.match( new RegExp( "^127.0.0.1:" + lPort + "$" ) ) ) {
+ print("disconnecting al: "+alPort);
stopMongoProgram( alPort );
al = null;
} else if ( mongo.host.match( new RegExp( "^127.0.0.1:" + rPort + "$" ) ) ) {
+ print("disconnecting ar: "+arPort);
stopMongoProgram( arPort );
ar = null;
} else {
@@ -64,47 +72,47 @@ doTest1 = function() {
pair = new ReplPair( l, r, a );
- // normal startup
+ print("normal startup");
pair.start();
pair.waitForSteadyState();
- // disconnect slave
+ print("disconnect slave");
disconnectNode( pair.slave() );
pair.waitForSteadyState( [ 1, -3 ], pair.master().host );
- // disconnect master
+ print("disconnect master");
disconnectNode( pair.master() );
pair.waitForSteadyState( [ -3, -3 ] );
- // reconnect
+ print("reconnect");
connect();
pair.waitForSteadyState();
- // disconnect master
+ print("disconnect master");
disconnectNode( pair.master() );
pair.waitForSteadyState( [ 1, -3 ], pair.slave().host, true );
- // disconnect new master
+ print("disconnect new master");
disconnectNode( pair.master() );
pair.waitForSteadyState( [ -3, -3 ] );
- // reconnect
+ print("reconnect");
connect();
pair.waitForSteadyState();
- // disconnect slave
+ print("disconnect slave");
disconnectNode( pair.slave() );
pair.waitForSteadyState( [ 1, -3 ], pair.master().host );
- // reconnect slave
+ print("reconnect slave");
connect();
pair.waitForSteadyState( [ 1, 0 ], pair.master().host );
- // disconnect master
+ print("disconnect master");
disconnectNode( pair.master() );
pair.waitForSteadyState( [ 1, -3 ], pair.slave().host, true );
- // reconnect old master
+ print("reconnect old master");
connect();
pair.waitForSteadyState( [ 1, 0 ], pair.master().host );