SERVER-26572 Reset stopTimestamp in DataReplicator when initial sync apply phase tries to fetch a remote document

1 files changed, 12 insertions, 3 deletions

diff --git a/src/mongo/db/repl/replication_coordinator_external_state.h b/src/mongo/db/repl/replication_coordinator_external_state.h
index 73e99635c36..9a48c5e6866 100644
--- a/src/mongo/db/repl/replication_coordinator_external_state.h
+++ b/src/mongo/db/repl/replication_coordinator_external_state.h
@@ -312,10 +312,19 @@ public:
 
     /**
      * Used by multiApply() to writes operations to database during initial sync.
-     * Fetches missing documents from "source".
      */
-    virtual Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
-                                         const HostAndPort& source) = 0;
+    virtual Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops) = 0;
+
+    /**
+     * Resets the sync source used to fetch missing documents from the source and resets the
+     * count of the number of fetched documents to 0.
+     */
+    virtual void resetSyncSourceHostAndFetchCount(const HostAndPort& source) = 0;
+
+    /**
+     * Returns the number of missing documents fetched from the sync source by the applier.
+     */
+    virtual unsigned getApplierFetchCount() const = 0;
 
     /**
      * This function creates an oplog buffer of the type specified at server startup.