fix: peer gc

Signed-off-by: Gaius <[email protected]>
dragonflyoss · Dec 10, 2021 · 258bf04 · 258bf04
1 parent 1e62cc4
commit 258bf04
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/deploy/helm-charts b/deploy/helm-charts
diff --git a/manager/console b/manager/console
diff --git a/scheduler/supervisor/peer.go b/scheduler/supervisor/peer.go
@@ -136,8 +136,9 @@ func (m *peerManager) RunGC() error {
 		peer := value.(*Peer)
 		elapsed := time.Since(peer.lastAccessAt.Load())
 
-		if elapsed > m.peerTTI && !peer.IsDone() && !peer.Host.IsCDN {
+		if elapsed > m.peerTTI && !peer.IsDone() && !peer.Host.IsCDN && peer.GetStatus() != PeerStatusZombie {
 			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())
+8 −7		charts/dragonfly/Chart.yaml
+12 −6		charts/dragonfly/README.md
+1 −0		charts/dragonfly/templates/cdn/cdn-configmap.yaml
+3 −1		charts/dragonfly/templates/dfdaemon/dfdaemon-configmap.yaml
+2 −0		charts/dragonfly/templates/scheduler/scheduler-configmap.yaml
+19 −6		charts/dragonfly/values.yaml