mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
@@ -4486,6 +4486,9 @@ func (js *jetStream) clusterInfo(rg *raftGroup) *ClusterInfo {
|
||||
for _, rp := range peers {
|
||||
if rp.ID != id && rg.isMember(rp.ID) {
|
||||
lastSeen := now.Sub(rp.Last)
|
||||
if lastSeen < 0 {
|
||||
lastSeen = 1
|
||||
}
|
||||
current := rp.Current
|
||||
if current && lastSeen > lostQuorumInterval {
|
||||
current = false
|
||||
|
||||
Reference in New Issue
Block a user