diff options
author | Benety Goh <benety@mongodb.com> | 2017-04-25 10:15:22 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2017-05-04 14:11:21 -0400 |
commit | f1730beea3b55c31e33ece40e8bc1f9b4ed78b9a (patch) | |
tree | 1a742e5123c182bc0ad4002bded05c25c496b9ae /src/mongo/db/repl/rollback_impl.h | |
parent | c65825adeeae0ff217f3780afbe9f0a03e7a9f5d (diff) | |
download | mongo-f1730beea3b55c31e33ece40e8bc1f9b4ed78b9a.tar.gz |
SERVER-28214 add remoteOplogNss and maxFetcherRestarts arguments to RollbackImpl constructor
Diffstat (limited to 'src/mongo/db/repl/rollback_impl.h')
-rw-r--r-- | src/mongo/db/repl/rollback_impl.h | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/mongo/db/repl/rollback_impl.h b/src/mongo/db/repl/rollback_impl.h index b7f73465dbf..5bbe64d0a80 100644 --- a/src/mongo/db/repl/rollback_impl.h +++ b/src/mongo/db/repl/rollback_impl.h @@ -91,6 +91,8 @@ public: RollbackImpl(executor::TaskExecutor* executor, OplogInterface* localOplog, const HostAndPort& syncSource, + const NamespaceString& remoteOplogNss, + std::size_t maxFetcherRestarts, int requiredRollbackId, ReplicationCoordinator* replicationCoordinator, StorageInterface* storageInterface, @@ -224,6 +226,12 @@ private: // Host and port of the sync source we are rolling back against. const HostAndPort _syncSource; // (R) + // Fully qualified namespace of the remote oplog. + const NamespaceString _remoteOplogNss; // (R) + + // Number of times to restart the query in the RollbackCommonPointResolver and OplogFetcher. + std::size_t _maxFetcherRestarts; // (R) + // This is the current rollback ID on the sync source that we are rolling back against. // It is an error if the rollback ID on the sync source changes before rollback is complete. const int _requiredRollbackId; // (R) |