summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_metrics.cpp
diff options
context:
space:
mode:
authorMedha Potluri <medha.potluri@mongodb.com>2019-08-06 11:04:20 -0400
committerMedha Potluri <medha.potluri@mongodb.com>2019-08-16 14:30:34 -0400
commit8494ca7d8a88aa3d5df96e89beafacd4caca3801 (patch)
tree819fc2ee7c4b6d0c2e3a7cc6a0d93d34ae9dd70c /src/mongo/db/repl/replication_metrics.cpp
parentd362c1c39ca79dd20e0aa6e9f93171fc5bd2cdec (diff)
downloadmongo-8494ca7d8a88aa3d5df96e89beafacd4caca3801.tar.gz
SERVER-41504 Track the number of ops during catchup in replSetStatus on primaries
Diffstat (limited to 'src/mongo/db/repl/replication_metrics.cpp')
-rw-r--r--src/mongo/db/repl/replication_metrics.cpp6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/mongo/db/repl/replication_metrics.cpp b/src/mongo/db/repl/replication_metrics.cpp
index 6603158c483..b6fb3289f35 100644
--- a/src/mongo/db/repl/replication_metrics.cpp
+++ b/src/mongo/db/repl/replication_metrics.cpp
@@ -273,6 +273,11 @@ void ReplicationMetrics::setTargetCatchupOpTime(OpTime opTime) {
_electionCandidateMetrics.setTargetCatchupOpTime(opTime);
}
+void ReplicationMetrics::setNumCatchUpOps(int numCatchUpOps) {
+ stdx::lock_guard<stdx::mutex> lk(_mutex);
+ _electionCandidateMetrics.setNumCatchUpOps(numCatchUpOps);
+}
+
void ReplicationMetrics::setNewTermStartDate(Date_t newTermStartDate) {
stdx::lock_guard<stdx::mutex> lk(_mutex);
_electionCandidateMetrics.setNewTermStartDate(newTermStartDate);
@@ -299,6 +304,7 @@ BSONObj ReplicationMetrics::getElectionCandidateMetricsBSON() {
void ReplicationMetrics::clearElectionCandidateMetrics() {
stdx::lock_guard<stdx::mutex> lk(_mutex);
_electionCandidateMetrics.setTargetCatchupOpTime(boost::none);
+ _electionCandidateMetrics.setNumCatchUpOps(boost::none);
_electionCandidateMetrics.setNewTermStartDate(boost::none);
_nodeIsCandidateOrPrimary = false;
}