From ded348a320fa3027fbd27ce434eb83773c8312b0 Mon Sep 17 00:00:00 2001 From: abhishek9686 Date: Mon, 31 Mar 2025 19:05:47 +0400 Subject: [PATCH] remove pending delete nodes --- logic/zombie.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/logic/zombie.go b/logic/zombie.go index ad06b377..cedf5e1f 100644 --- a/logic/zombie.go +++ b/logic/zombie.go @@ -77,7 +77,7 @@ func checkForZombieHosts(h *models.Host) { func ManageZombies(ctx context.Context, peerUpdate chan *models.Node) { logger.Log(2, "Zombie management started") go InitializeZombies() - + go checkPendingRemovalNodes() // Zombie Nodes Cleanup Four Times a Day ticker := time.NewTicker(time.Hour * ZOMBIE_TIMEOUT) @@ -138,6 +138,15 @@ func ManageZombies(ctx context.Context, peerUpdate chan *models.Node) { } } } +func checkPendingRemovalNodes() { + nodes, _ := GetAllNodes() + for _, node := range nodes { + pendingDelete := node.PendingDelete || node.Action == models.NODE_DELETE + if pendingDelete { + DeleteNode(&node, true) + } + } +} // InitializeZombies - populates the zombie quarantine list (should be called from initialization) func InitializeZombies() {