mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 01:21:03 +01:00
Code Issues Releases Activity

more robust maintenance of mod ids set in repl code

Browse Source
This commit is contained in:
Aaron 2009-05-19 17:30:11 -04:00
parent f9c896224b
commit b8c6d85506
2 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
db/repl.cpp
View File

@ -953,13 +953,11 @@ namespace mongo {
BSONObj id = idForOp( op, mod );
if ( !id.isEmpty() ) {
const char *ns = op.getStringField( "ns" );
if ( mod ) {
if ( !idTracker.haveId( ns, id ) ) {
idTracker.haveModId( ns, id, true );
}
} else {
idTracker.haveModId( ns, id, false );
}
// Since our range of local ops may not be the same as our peer's
// range of unapplied ops, it is always necessary to rewrite objects
// to the oplog after a mod update.
if ( mod )
idTracker.haveModId( ns, id, true );
idTracker.haveId( ns, id, true );
}
}

4
jstests/repl/pair4.js
View File

@ -71,8 +71,8 @@ doTest = function( recover, newMaster, newSlave ) {
// start normally
connect();
a = new MongodRunner( aPort, "/data/db/" + baseName + "-arbiter" );
l = new MongodRunner( lPort, "/data/db/" + baseName + "-left", "127.0.0.1:" + rpPort, "127.0.0.1:" + aPort, "-vvvvvv" );
r = new MongodRunner( rPort, "/data/db/" + baseName + "-right", "127.0.0.1:" + lpPort, "127.0.0.1:" + aPort, "-vvvvvv" );
l = new MongodRunner( lPort, "/data/db/" + baseName + "-left", "127.0.0.1:" + rpPort, "127.0.0.1:" + aPort );
r = new MongodRunner( rPort, "/data/db/" + baseName + "-right", "127.0.0.1:" + lpPort, "127.0.0.1:" + aPort );
pair = new ReplPair( l, r, a );
pair.start();
pair.waitForSteadyState();