SERVER-41513 Track the time the new term oplog entry was written by primary and applied in secondary

1 files changed, 20 insertions, 7 deletions

diff --git a/src/mongo/db/repl/replication_metrics.cpp b/src/mongo/db/repl/replication_metrics.cpp
index 2eef9206b55..addb4f7027d 100644
--- a/src/mongo/db/repl/replication_metrics.cpp
+++ b/src/mongo/db/repl/replication_metrics.cpp
@@ -300,7 +300,7 @@ void ReplicationMetrics::setNumCatchUpOps(long numCatchUpOps) {
     _updateAverageCatchUpOps(lk);
 }
 
-void ReplicationMetrics::setNewTermStartDate(Date_t newTermStartDate) {
+void ReplicationMetrics::setCandidateNewTermStartDate(Date_t newTermStartDate) {
     stdx::lock_guard<Latch> lk(_mutex);
     _electionCandidateMetrics.setNewTermStartDate(newTermStartDate);
 }
@@ -328,6 +328,15 @@ BSONObj ReplicationMetrics::getElectionCandidateMetricsBSON() {
     return BSONObj();
 }
 
+void ReplicationMetrics::clearElectionCandidateMetrics() {
+    stdx::lock_guard<Latch> lk(_mutex);
+    _electionCandidateMetrics.setTargetCatchupOpTime(boost::none);
+    _electionCandidateMetrics.setNumCatchUpOps(boost::none);
+    _electionCandidateMetrics.setNewTermStartDate(boost::none);
+    _electionCandidateMetrics.setWMajorityWriteAvailabilityDate(boost::none);
+    _nodeIsCandidateOrPrimary = false;
+}
+
 void ReplicationMetrics::setElectionParticipantMetrics(const bool votedForCandidate,
                                                        const long long electionTerm,
                                                        const Date_t lastVoteDate,
@@ -357,13 +366,17 @@ BSONObj ReplicationMetrics::getElectionParticipantMetricsBSON() {
     return BSONObj();
 }
 
-void ReplicationMetrics::clearElectionCandidateMetrics() {
+void ReplicationMetrics::setParticipantNewTermDates(Date_t newTermStartDate,
+                                                    Date_t newTermAppliedDate) {
     stdx::lock_guard<Latch> lk(_mutex);
-    _electionCandidateMetrics.setTargetCatchupOpTime(boost::none);
-    _electionCandidateMetrics.setNumCatchUpOps(boost::none);
-    _electionCandidateMetrics.setNewTermStartDate(boost::none);
-    _electionCandidateMetrics.setWMajorityWriteAvailabilityDate(boost::none);
-    _nodeIsCandidateOrPrimary = false;
+    _electionParticipantMetrics.setNewTermStartDate(newTermStartDate);
+    _electionParticipantMetrics.setNewTermAppliedDate(newTermAppliedDate);
+}
+
+void ReplicationMetrics::clearParticipantNewTermDates() {
+    stdx::lock_guard<Latch> lk(_mutex);
+    _electionParticipantMetrics.setNewTermStartDate(boost::none);
+    _electionParticipantMetrics.setNewTermAppliedDate(boost::none);
 }
 
 void ReplicationMetrics::_updateAverageCatchUpOps(WithLock lk) {