summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/initial_sync.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/initial_sync.cpp')
-rw-r--r--src/mongo/db/repl/initial_sync.cpp37
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