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

rs initial sync fixes

Browse Source
This commit is contained in:
dwight 2010-08-02 12:16:01 -04:00
parent a56117f97d
commit 6a355fc327
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
db/repl/rs_initialsync.cpp
View File

@ -22,6 +22,7 @@
#include "../../util/mongoutils/str.h"
#include "../dbhelpers.h"
#include "rs_optime.h"
#include "../oplog.h"
namespace mongo {
@ -75,9 +76,20 @@ namespace mongo {
string errmsg;
bob res;
Client::Context ctx(rsoplog);
NamespaceDetails *d = nsdetails(rsoplog);
// temp
if( d && d->nrecords == 0 )
return; // already empty, ok.
dropCollection(rsoplog, errmsg, res);
log() << "replSet FATAL error during initial sync. mongod restart required." << rsLog;
dbexit( EXIT_CLEAN );
log() << "replSet recreated oplog so it is empty. todo optimize this..." << rsLog;
createOplog();
// TEMP: restart to recreate empty oplog
//log() << "replSet FATAL error during initial sync. mongod restart required." << rsLog;
//dbexit( EXIT_CLEAN );
/*
writelock lk(rsoplog);
@ -166,6 +178,8 @@ namespace mongo {
if( ! initialSyncOplogApplication(masterHostname, cp, startingTS, mvoptime) ) {
log() << "replSet initial sync failed during applyoplog [1]" << rsLog;
emptyOplog(); // otherwise we'll be up!
lastOpTimeWritten = OpTime();
lastH = 0;
log() << "replSet initial sync failed during applyoplog [2]" << rsLog;
{
writelock lk("local.");