summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_coordinator_external_state_impl.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_external_state_impl.h')
-rw-r--r--src/mongo/db/repl/replication_coordinator_external_state_impl.h8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_external_state_impl.h b/src/mongo/db/repl/replication_coordinator_external_state_impl.h
index 577c0b2aa4f..78969cbb292 100644
--- a/src/mongo/db/repl/replication_coordinator_external_state_impl.h
+++ b/src/mongo/db/repl/replication_coordinator_external_state_impl.h
@@ -52,6 +52,9 @@ public:
ReplicationCoordinatorExternalStateImpl();
virtual ~ReplicationCoordinatorExternalStateImpl();
virtual void startThreads(const ReplSettings& settings) override;
+ virtual void startInitialSync(OnInitialSyncFinishedFn finished) override;
+ virtual void startSteadyStateReplication() override;
+
virtual void startMasterSlave(OperationContext* txn);
virtual void shutdown();
virtual Status initializeReplSetStorage(OperationContext* txn,
@@ -117,6 +120,11 @@ private:
long long _nextThreadId;
std::unique_ptr<SnapshotThread> _snapshotThread;
+
+ // Initial sync stuff
+ StartInitialSyncFn _startInitialSyncIfNeededFn;
+ StartSteadyReplicationFn _startSteadReplicationFn;
+ std::unique_ptr<stdx::thread> _initialSyncThread;
};
} // namespace repl