summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_process.cpp
diff options
context:
space:
mode:
authorJudah Schvimer <judah@mongodb.com>2017-08-10 10:36:27 -0400
committerJudah Schvimer <judah@mongodb.com>2017-08-10 10:44:22 -0400
commitd8eda8b631928bd78e71d06f20f39b6611b908a4 (patch)
treeb637cc2fedc89e38cb2067799b34688c19738661 /src/mongo/db/repl/replication_process.cpp
parent9c246267785dba72660fc03f5767b9d663e8b94a (diff)
downloadmongo-d8eda8b631928bd78e71d06f20f39b6611b908a4.tar.gz
SERVER-29893 Rename recovery code and make it accessible to both startup and rollback
Diffstat (limited to 'src/mongo/db/repl/replication_process.cpp')
-rw-r--r--src/mongo/db/repl/replication_process.cpp8
1 files changed, 7 insertions, 1 deletions
diff --git a/src/mongo/db/repl/replication_process.cpp b/src/mongo/db/repl/replication_process.cpp
index 7e7dc077b11..cde7fcdbae9 100644
--- a/src/mongo/db/repl/replication_process.cpp
+++ b/src/mongo/db/repl/replication_process.cpp
@@ -82,9 +82,11 @@ void ReplicationProcess::set(ServiceContext* service, std::unique_ptr<Replicatio
ReplicationProcess::ReplicationProcess(
StorageInterface* storageInterface,
- std::unique_ptr<ReplicationConsistencyMarkers> consistencyMarkers)
+ std::unique_ptr<ReplicationConsistencyMarkers> consistencyMarkers,
+ std::unique_ptr<ReplicationRecovery> recovery)
: _storageInterface(storageInterface),
_consistencyMarkers(std::move(consistencyMarkers)),
+ _recovery(std::move(recovery)),
_rbid(kUninitializedRollbackId) {}
StatusWith<int> ReplicationProcess::getRollbackID(OperationContext* opCtx) {
@@ -182,5 +184,9 @@ ReplicationConsistencyMarkers* ReplicationProcess::getConsistencyMarkers() {
return _consistencyMarkers.get();
}
+ReplicationRecovery* ReplicationProcess::getReplicationRecovery() {
+ return _recovery.get();
+}
+
} // namespace repl
} // namespace mongo