SERVER-44442 Allow queryableBackupMode to perform replication recovery

1 files changed, 16 insertions, 1 deletions

diff --git a/src/mongo/db/repl/replication_recovery.h b/src/mongo/db/repl/replication_recovery.h
index 72acfbb8d3b..0a891420b54 100644
--- a/src/mongo/db/repl/replication_recovery.h
+++ b/src/mongo/db/repl/replication_recovery.h
@@ -62,6 +62,11 @@ public:
      *  ensures that recovery can be skipped safely.
      */
     virtual void recoverFromOplogAsStandalone(OperationContext* opCtx) = 0;
+
+    /**
+     * Recovers the data on disk from the oplog up to and including the given timestamp.
+     */
+    virtual void recoverFromOplogUpTo(OperationContext* opCtx, Timestamp endPoint) = 0;
 };
 
 class ReplicationRecoveryImpl : public ReplicationRecovery {
@@ -77,6 +82,8 @@ public:
 
     void recoverFromOplogAsStandalone(OperationContext* opCtx) override;
 
+    void recoverFromOplogUpTo(OperationContext* opCtx, Timestamp endPoint) override;
+
 private:
     /**
      * Confirms that the data and oplog all indicate that the nodes has an unstable checkpoint
@@ -102,7 +109,7 @@ private:
                                         OpTime topOfOplog);
 
     /**
-     * Applies all oplog entries from oplogApplicationStartPoint (exclusive) to topOfOplog
+     * Applies all oplog entries from oplogApplicationStartPoint (inclusive) to topOfOplog
      * (inclusive). This fasserts if oplogApplicationStartPoint is not in the oplog.
      */
     void _applyToEndOfOplog(OperationContext* opCtx,
@@ -110,6 +117,14 @@ private:
                             const Timestamp& topOfOplog);
 
     /**
+     * Applies all oplog entries from startPoint (inclusive) to endPoint (inclusive). Returns the
+     * Timestamp of the last applied operation.
+     */
+    Timestamp _applyOplogOperations(OperationContext* opCtx,
+                                    const Timestamp& startPoint,
+                                    const Timestamp& endPoint);
+
+    /**
      * Gets the last applied OpTime from the end of the oplog. Returns CollectionIsEmpty if there is
      * no oplog.
      */