summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/rollback_impl.h
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2017-04-25 10:15:22 -0400
committerBenety Goh <benety@mongodb.com>2017-05-04 14:11:21 -0400
commitf1730beea3b55c31e33ece40e8bc1f9b4ed78b9a (patch)
tree1a742e5123c182bc0ad4002bded05c25c496b9ae /src/mongo/db/repl/rollback_impl.h
parentc65825adeeae0ff217f3780afbe9f0a03e7a9f5d (diff)
downloadmongo-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.h8
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)