SERVER-46257: OplogFetcher should run LogicalTimeMetadataHook on DBClientConnection

1 files changed, 17 insertions, 0 deletions

diff --git a/src/mongo/db/repl/replication_coordinator_test_fixture.cpp b/src/mongo/db/repl/replication_coordinator_test_fixture.cpp
index 4d2c4c82dd4..5aa9fd122d5 100644
--- a/src/mongo/db/repl/replication_coordinator_test_fixture.cpp
+++ b/src/mongo/db/repl/replication_coordinator_test_fixture.cpp
@@ -506,5 +506,22 @@ void ReplCoordTest::simulateCatchUpAbort() {
     net->exitNetwork();
 }
 
+void ReplCoordTest::replCoordAdvanceCommitPoint(const OpTime& opTime,
+                                                Date_t wallTime,
+                                                bool fromSyncSource) {
+    if (wallTime == Date_t()) {
+        wallTime = Date_t() + Seconds(opTime.getSecs());
+    }
+    getExternalState()->setGlobalTimestamp(getGlobalServiceContext(), opTime.getTimestamp());
+    getReplCoord()->advanceCommitPoint({opTime, wallTime}, fromSyncSource);
+}
+
+void ReplCoordTest::replCoordAdvanceCommitPoint(const OpTimeAndWallTime& opTimeAndWallTime,
+                                                bool fromSyncSource) {
+    getExternalState()->setGlobalTimestamp(getGlobalServiceContext(),
+                                           opTimeAndWallTime.opTime.getTimestamp());
+    getReplCoord()->advanceCommitPoint(opTimeAndWallTime, fromSyncSource);
+}
+
 }  // namespace repl
 }  // namespace mongo