diff options
Diffstat (limited to 'src/mongo/db/repl/topology_coordinator.cpp')
-rw-r--r-- | src/mongo/db/repl/topology_coordinator.cpp | 15 |
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; + } } } |