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

replication debug output

Browse Source 

This commit is contained in:
Dwight 2008-12-01 13:23:20 -05:00
parent d68ca4cc23
commit d4504325ee
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
db/repl.cpp
View File

@ -44,6 +44,9 @@ void ensureHaveIdIndex(const char *ns);
#include "replset.h" #include "replset.h"
#define debugrepl(z) cout << "debugrepl " << z << '\n'
//define debugrepl
/* --- ReplPair -------------------------------- */ /* --- ReplPair -------------------------------- */
ReplPair *replPair = 0; ReplPair *replPair = 0;
@ -507,6 +510,7 @@ void ReplSource::sync_pullOpLog_applyOperation(BSONObj& op) {
/* note: not yet in mutex at this point. */ /* note: not yet in mutex at this point. */
void ReplSource::sync_pullOpLog() { void ReplSource::sync_pullOpLog() {
string ns = string("local.oplog.$") + sourceName(); string ns = string("local.oplog.$") + sourceName();
debugrepl( "sync_pullOpLog " << ns );
bool tailing = true; bool tailing = true;
DBClientCursor *c = cursor.get(); DBClientCursor *c = cursor.get();
@ -516,16 +520,21 @@ void ReplSource::sync_pullOpLog() {
} }
if( c == 0 ) { if( c == 0 ) {
// queryObj = { ts: { $gte: syncedTo } }
BSONObjBuilder q; BSONObjBuilder q;
q.appendDate("$gte", syncedTo.asDate()); q.appendDate("$gte", syncedTo.asDate());
BSONObjBuilder query; BSONObjBuilder query;
query.append("ts", q.done()); query.append("ts", q.done());
// query = { ts: { $gte: syncedTo } } BSONObj queryObj = query.done();
cursor = conn->query( ns.c_str(), query.done(), 0, 0, 0, Option_CursorTailable ); debugrepl( ns << ".find(" << queryObj.toString() << ')' );
cursor = conn->query( ns.c_str(), queryObj, 0, 0, 0, Option_CursorTailable );
c = cursor.get(); c = cursor.get();
tailing = false; tailing = false;
} }
else {
debugrepl( "tailing=true" );
}
if( c == 0 ) { if( c == 0 ) {
problem() << "pull: dbclient::query returns null (conn closed?)" << endl; problem() << "pull: dbclient::query returns null (conn closed?)" << endl;
@ -547,9 +556,9 @@ void ReplSource::sync_pullOpLog() {
} }
if( !c->more() ) { if( !c->more() ) {
if( tailing ) if( tailing ) {
; //log() << "pull: " <<OpT ns << " no new activity\n"; debugrepl( "tailing & no new activity" );
else } else
log() << "pull: " << ns << " oplog is empty\n"; log() << "pull: " << ns << " oplog is empty\n";
sleepsecs(3); sleepsecs(3);
return; return;
@ -563,6 +572,7 @@ void ReplSource::sync_pullOpLog() {
assert(false); assert(false);
} }
OpTime nextOpTime( ts.date() ); OpTime nextOpTime( ts.date() );
debugrepl( "first op time received: " << nextOpTime.toString() );
bool initial = syncedTo.isNull(); bool initial = syncedTo.isNull();
if( initial || tailing ) { if( initial || tailing ) {
if( tailing ) { if( tailing ) {
@ -601,6 +611,7 @@ void ReplSource::sync_pullOpLog() {
if( !c->more() ) { if( !c->more() ) {
log() << "pull: applied " << n << " operations" << endl; log() << "pull: applied " << n << " operations" << endl;
syncedTo = nextOpTime; syncedTo = nextOpTime;
debugrepl( "end sync_pullOpLog syncedTo: " << syncedTo.toString() );
dblock lk; dblock lk;
save(); // note how far we are synced up to now save(); // note how far we are synced up to now
break; break;