mongo::ReplSource Class Reference

#include <repl.h>

List of all members.

Public Types

typedef vector< shared_ptr
< ReplSource > > 
SourceVector

Public Member Functions

void forceResync (const char *requester)
bool haveMoreDbsToSync () const
BSONObj jsobj ()
bool operator== (const ReplSource &r) const
 ReplSource (BSONObj)
void save ()
int sleepAdvice () const
string sourceName () const
int sync (int &nApplied)
string toString () const

Static Public Member Functions

static void applyOperation (const BSONObj &op)
static void forceResyncDead (const char *requester)
static void loadAll (SourceVector &)
static bool throttledForceResyncDead (const char *requester)

Public Attributes

OpTime _lastSavedLocalTs
string _sourceName
string hostName
int nClonedThisPass
string only
OplogReader oplogReader
bool paired
bool replacing
OpTime syncedTo

Private Member Functions

OpTime nextLastSavedLocalTs () const
string ns () const
 ReplSource ()
void resetSlave ()
bool resync (string db)
string resyncDrop (const char *db, const char *requester)
void setLastSavedLocalTs (const OpTime &nextLocalTs)
int sync_pullOpLog (int &nApplied)
void sync_pullOpLog_applyOperation (BSONObj &op, OpTime *localLogTail, bool alreadyLocked)
void syncToTailOfRemoteLog ()
bool updateSetsWithLocalOps (OpTime &localLogTail, bool mayUnlock)

Static Private Member Functions

static BSONObj idForOp (const BSONObj &op, bool &mod)
static void updateSetsWithOp (const BSONObj &op, bool mayUpdateStorage)

Private Attributes

unsigned _sleepAdviceTime
set< string > addDbNextPass
set< string > incompleteCloneDbs
auto_ptr< ThreadPool > tp

Detailed Description

Definition at line 91 of file repl.h.


Member Typedef Documentation

typedef vector< shared_ptr< ReplSource > > mongo::ReplSource::SourceVector

Definition at line 157 of file repl.h.


Constructor & Destructor Documentation

mongo::ReplSource::ReplSource (  )  [private]
mongo::ReplSource::ReplSource ( BSONObj   )  [explicit]

Member Function Documentation

static void mongo::ReplSource::applyOperation ( const BSONObj op  )  [static]
void mongo::ReplSource::forceResync ( const char *  requester  ) 
static void mongo::ReplSource::forceResyncDead ( const char *  requester  )  [static]
bool mongo::ReplSource::haveMoreDbsToSync (  )  const [inline]

Definition at line 175 of file repl.h.

static BSONObj mongo::ReplSource::idForOp ( const BSONObj op,
bool &  mod 
) [static, private]
BSONObj mongo::ReplSource::jsobj (  ) 
static void mongo::ReplSource::loadAll ( SourceVector  )  [static]
OpTime mongo::ReplSource::nextLastSavedLocalTs (  )  const [private]
string mongo::ReplSource::ns (  )  const [inline, private]

Definition at line 130 of file repl.h.

bool mongo::ReplSource::operator== ( const ReplSource r  )  const [inline]

Definition at line 170 of file repl.h.

void mongo::ReplSource::resetSlave (  )  [private]
bool mongo::ReplSource::resync ( string  db  )  [private]
string mongo::ReplSource::resyncDrop ( const char *  db,
const char *  requester 
) [private]
void mongo::ReplSource::save (  ) 
void mongo::ReplSource::setLastSavedLocalTs ( const OpTime nextLocalTs  )  [private]
int mongo::ReplSource::sleepAdvice (  )  const [inline]

Definition at line 176 of file repl.h.

string mongo::ReplSource::sourceName (  )  const [inline]

Definition at line 141 of file repl.h.

int mongo::ReplSource::sync ( int &  nApplied  ) 
int mongo::ReplSource::sync_pullOpLog ( int &  nApplied  )  [private]
void mongo::ReplSource::sync_pullOpLog_applyOperation ( BSONObj op,
OpTime localLogTail,
bool  alreadyLocked 
) [private]
Parameters:
alreadyLocked caller already put us in write lock if true
void mongo::ReplSource::syncToTailOfRemoteLog (  )  [private]
static bool mongo::ReplSource::throttledForceResyncDead ( const char *  requester  )  [static]
string mongo::ReplSource::toString (  )  const [inline]

Definition at line 173 of file repl.h.

bool mongo::ReplSource::updateSetsWithLocalOps ( OpTime localLogTail,
bool  mayUnlock 
) [private]
static void mongo::ReplSource::updateSetsWithOp ( const BSONObj op,
bool  mayUpdateStorage 
) [static, private]

Member Data Documentation

Definition at line 153 of file repl.h.

Definition at line 131 of file repl.h.

Definition at line 140 of file repl.h.

set<string> mongo::ReplSource::addDbNextPass [private]

Definition at line 109 of file repl.h.

Definition at line 139 of file repl.h.

Definition at line 111 of file repl.h.

Definition at line 155 of file repl.h.

Definition at line 142 of file repl.h.

Definition at line 134 of file repl.h.

Definition at line 138 of file repl.h.

Definition at line 137 of file repl.h.

Definition at line 145 of file repl.h.

auto_ptr<ThreadPool> mongo::ReplSource::tp [private]

Definition at line 92 of file repl.h.


The documentation for this class was generated from the following file:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines


mongodb
Author(s): Nate Koenig
autogenerated on Fri Jan 11 12:15:57 2013