From 088b4ef82b454dfe54a1f02db1db4bb1956518ec Mon Sep 17 00:00:00 2001 From: abhishek9686 Date: Mon, 6 Jan 2025 17:54:04 +0400 Subject: [PATCH] check peer status --- pro/logic/status.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/pro/logic/status.go b/pro/logic/status.go index 39dccd269..35ab0b60f 100644 --- a/pro/logic/status.go +++ b/pro/logic/status.go @@ -168,9 +168,12 @@ func checkPeerConnectivity(node *models.Node, metrics *models.Metrics, defaultAc if err != nil { continue } - allowed, _ := logic.IsNodeAllowedToCommunicate(*node, peer, false) - if !defaultAclPolicy && !allowed { - continue + + if !defaultAclPolicy { + allowed, _ := logic.IsNodeAllowedToCommunicate(*node, peer, false) + if !allowed { + continue + } } if time.Since(peer.LastCheckIn) > models.LastCheckInThreshold { @@ -181,7 +184,7 @@ func checkPeerConnectivity(node *models.Node, metrics *models.Metrics, defaultAc } // check if peer is in error state checkPeerStatus(&peer, defaultAclPolicy) - if peer.Status == models.ErrorSt { + if peer.Status == models.ErrorSt || peer.Status == models.WarningSt { continue } peerNotConnectedCnt++