summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/topology_coordinator.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/topology_coordinator.cpp')
-rw-r--r--src/mongo/db/repl/topology_coordinator.cpp15
1 files changed, 7 insertions, 8 deletions
diff --git a/src/mongo/db/repl/topology_coordinator.cpp b/src/mongo/db/repl/topology_coordinator.cpp
index 4b6538d9cc3..6a158175c16 100644
--- a/src/mongo/db/repl/topology_coordinator.cpp
+++ b/src/mongo/db/repl/topology_coordinator.cpp
@@ -1288,11 +1288,6 @@ std::pair<MemberId, Date_t> TopologyCoordinator::getStalestLiveMember() const {
return std::make_pair(earliestMemberId, earliestDate);
}
-void TopologyCoordinator::resetAllMemberTimeouts(Date_t now) {
- for (auto&& memberData : _memberData)
- memberData.updateLiveness(now);
-}
-
void TopologyCoordinator::resetMemberTimeouts(Date_t now,
const stdx::unordered_set<HostAndPort>& member_set) {
for (auto&& memberData : _memberData) {
@@ -3303,9 +3298,13 @@ void TopologyCoordinator::setStorageEngineSupportsReadCommitted(bool supported)
supported ? ReadCommittedSupport::kYes : ReadCommittedSupport::kNo;
}
-void TopologyCoordinator::restartHeartbeats() {
- for (auto& hb : _memberData) {
- hb.restart();
+void TopologyCoordinator::restartHeartbeat(const Date_t now, const HostAndPort& target) {
+ for (auto&& member : _memberData) {
+ if (member.getHostAndPort() == target) {
+ member.restart();
+ member.updateLiveness(now);
+ return;
+ }
}
}