From 943e0fbfd8bf7223f03189bd8af1d5e423aa387f Mon Sep 17 00:00:00 2001 From: Maria van Keulen Date: Mon, 15 Apr 2019 11:52:11 -0400 Subject: SERVER-40659 Add regression tests for wall clock time transmission --- src/mongo/db/repl/replication_coordinator_test_fixture.h | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'src/mongo/db/repl/replication_coordinator_test_fixture.h') diff --git a/src/mongo/db/repl/replication_coordinator_test_fixture.h b/src/mongo/db/repl/replication_coordinator_test_fixture.h index ab831e8820a..c7dcbcb8985 100644 --- a/src/mongo/db/repl/replication_coordinator_test_fixture.h +++ b/src/mongo/db/repl/replication_coordinator_test_fixture.h @@ -119,7 +119,7 @@ protected: void replCoordSetMyLastAppliedOpTime(const OpTime& opTime, Date_t wallTime = Date_t::min()) { if (wallTime == Date_t::min()) { - wallTime = wallTime + Seconds(opTime.getSecs()); + wallTime = Date_t() + Seconds(opTime.getSecs()); } getReplCoord()->setMyLastAppliedOpTimeAndWallTime({opTime, wallTime}); } @@ -128,14 +128,14 @@ protected: ReplicationCoordinator::DataConsistency consistency, Date_t wallTime = Date_t::min()) { if (wallTime == Date_t::min()) { - wallTime = wallTime + Seconds(opTime.getSecs()); + wallTime = Date_t() + Seconds(opTime.getSecs()); } getReplCoord()->setMyLastAppliedOpTimeAndWallTimeForward({opTime, wallTime}, consistency); } void replCoordSetMyLastDurableOpTime(const OpTime& opTime, Date_t wallTime = Date_t::min()) { if (wallTime == Date_t::min()) { - wallTime = wallTime + Seconds(opTime.getSecs()); + wallTime = Date_t() + Seconds(opTime.getSecs()); } getReplCoord()->setMyLastDurableOpTimeAndWallTime({opTime, wallTime}); } @@ -143,7 +143,7 @@ protected: void replCoordSetMyLastDurableOpTimeForward(const OpTime& opTime, Date_t wallTime = Date_t::min()) { if (wallTime == Date_t::min()) { - wallTime = wallTime + Seconds(opTime.getSecs()); + wallTime = Date_t() + Seconds(opTime.getSecs()); } getReplCoord()->setMyLastDurableOpTimeAndWallTimeForward({opTime, wallTime}); } @@ -152,7 +152,7 @@ protected: Date_t wallTime = Date_t::min(), bool fromSyncSource = false) { if (wallTime == Date_t::min()) { - wallTime = wallTime + Seconds(opTime.getSecs()); + wallTime = Date_t() + Seconds(opTime.getSecs()); } getReplCoord()->advanceCommitPoint({opTime, wallTime}, fromSyncSource); } -- cgit v1.2.1