diff options
author | Medha Potluri <medha.potluri@mongodb.com> | 2019-08-06 11:04:20 -0400 |
---|---|---|
committer | Medha Potluri <medha.potluri@mongodb.com> | 2019-08-16 14:30:34 -0400 |
commit | 8494ca7d8a88aa3d5df96e89beafacd4caca3801 (patch) | |
tree | 819fc2ee7c4b6d0c2e3a7cc6a0d93d34ae9dd70c /src/mongo/db/repl/replication_metrics.cpp | |
parent | d362c1c39ca79dd20e0aa6e9f93171fc5bd2cdec (diff) | |
download | mongo-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.cpp | 6 |
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; } |