fix: peer gc (#918)

* fix: peer gc Signed-off-by: Gaius <[email protected]> * Check whether the peer is in zombie state Signed-off-by: sunwp <[email protected]> Co-authored-by: sunwp <[email protected]>
dragonflyoss · Dec 13, 2021 · 869f3d1 · 869f3d1
1 parent 344ed8a
commit 869f3d1
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/scheduler/supervisor/peer.go b/scheduler/supervisor/peer.go
@@ -138,10 +138,13 @@ func (m *peerManager) RunGC() error {
 
 		if elapsed > m.peerTTI && !peer.IsDone() && !peer.Host.IsCDN {
 			if !peer.IsConnected() {
+				peer.Log().Infof("peer is not connected")
 				peer.Leave()
 			}
-			peer.Log().Infof("peer has been more than %s since last access, it's status changes from %s to zombie", m.peerTTI, peer.GetStatus().String())
-			peer.SetStatus(PeerStatusZombie)
+			if peer.GetStatus() != PeerStatusZombie {
+				peer.Log().Infof("peer has been more than %s since last access, it's status changes from %s to zombie", m.peerTTI, peer.GetStatus().String())
+				peer.SetStatus(PeerStatusZombie)
+			}
 		}
 
 		if peer.IsLeave() || peer.IsFail() || elapsed > m.peerTTL {