diff options
Diffstat (limited to 'src/mongo/db/repl/initial_sync.cpp')
-rw-r--r-- | src/mongo/db/repl/initial_sync.cpp | 37 |
1 files changed, 18 insertions, 19 deletions
diff --git a/src/mongo/db/repl/initial_sync.cpp b/src/mongo/db/repl/initial_sync.cpp index 494094862ba..0c6695c15a3 100644 --- a/src/mongo/db/repl/initial_sync.cpp +++ b/src/mongo/db/repl/initial_sync.cpp @@ -39,24 +39,23 @@ namespace mongo { namespace repl { - unsigned replSetForceInitialSyncFailure = 0; - - InitialSync::InitialSync(BackgroundSyncInterface *q) : - SyncTail(q, multiInitialSyncApply) {} - - InitialSync::~InitialSync() {} - - /* initial oplog application, during initial sync, after cloning. - */ - void InitialSync::oplogApplication(OperationContext* txn, const OpTime& endOpTime) { - if (replSetForceInitialSyncFailure > 0) { - log() << "test code invoked, forced InitialSync failure: " - << replSetForceInitialSyncFailure; - replSetForceInitialSyncFailure--; - throw DBException("forced error",0); - } - _applyOplogUntil(txn, endOpTime); +unsigned replSetForceInitialSyncFailure = 0; + +InitialSync::InitialSync(BackgroundSyncInterface* q) : SyncTail(q, multiInitialSyncApply) {} + +InitialSync::~InitialSync() {} + +/* initial oplog application, during initial sync, after cloning. +*/ +void InitialSync::oplogApplication(OperationContext* txn, const OpTime& endOpTime) { + if (replSetForceInitialSyncFailure > 0) { + log() << "test code invoked, forced InitialSync failure: " + << replSetForceInitialSyncFailure; + replSetForceInitialSyncFailure--; + throw DBException("forced error", 0); } + _applyOplogUntil(txn, endOpTime); +} -} // namespace repl -} // namespace mongo +} // namespace repl +} // namespace mongo |