SERVER-43279 Make OplogFetcher called from initial sync use the initial sync restart strategy.

1 files changed, 34 insertions, 0 deletions

diff --git a/src/mongo/db/repl/oplog_fetcher.cpp b/src/mongo/db/repl/oplog_fetcher.cpp
index 514de02e8c8..47b7a8a84d7 100644
--- a/src/mongo/db/repl/oplog_fetcher.cpp
+++ b/src/mongo/db/repl/oplog_fetcher.cpp
@@ -326,6 +326,40 @@ OplogFetcher::OplogFetcher(executor::TaskExecutor* executor,
     invariant(enqueueDocumentsFn);
 }
 
+OplogFetcher::OplogFetcher(executor::TaskExecutor* executor,
+                           OpTime lastFetched,
+                           HostAndPort source,
+                           NamespaceString nss,
+                           ReplSetConfig config,
+                           std::unique_ptr<OplogFetcherRestartDecision> oplogFetcherRestartDecision,
+                           int requiredRBID,
+                           bool requireFresherSyncSource,
+                           DataReplicatorExternalState* dataReplicatorExternalState,
+                           EnqueueDocumentsFn enqueueDocumentsFn,
+                           OnShutdownCallbackFn onShutdownCallbackFn,
+                           const int batchSize,
+                           StartingPoint startingPoint)
+    : AbstractOplogFetcher(executor,
+                           lastFetched,
+                           source,
+                           nss,
+                           std::move(oplogFetcherRestartDecision),
+                           onShutdownCallbackFn,
+                           "oplog fetcher"),
+      _metadataObject(makeMetadataObject()),
+      _requiredRBID(requiredRBID),
+      _requireFresherSyncSource(requireFresherSyncSource),
+      _dataReplicatorExternalState(dataReplicatorExternalState),
+      _enqueueDocumentsFn(enqueueDocumentsFn),
+      _awaitDataTimeout(calculateAwaitDataTimeout(config)),
+      _batchSize(batchSize),
+      _startingPoint(startingPoint) {
+
+    invariant(config.isInitialized());
+    invariant(enqueueDocumentsFn);
+}
+
+
 OplogFetcher::~OplogFetcher() {
     shutdown();
     join();