gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-10-06 20:05:46 +08:00
Code Issues Projects Releases Packages Wiki Activity

code review changes

Browse source
This commit is contained in:
Matthew R. Kasun 2022-06-14 08:27:30 -04:00 • committed by Matthew R Kasun
parent 236ada91bc
commit 77a629dff1
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
logic/zombie.go
View file

@ -9,8 +9,10 @@ import (
) )
const ( const (
ZOMBIE_TIMEOUT = 60 // timeout in seconds // ZOMBIE_TIMEOUT - timeout in seconds for checking zombie status
ZOMBIE_DELETE_TIME = 10 // minutes ZOMBIE_TIMEOUT = 60
// ZOMBIE_DELETE_TIME - timeout in minutes for zombie node deletion
ZOMBIE_DELETE_TIME = 10
) )
var ( var (
@ -44,13 +46,17 @@ func ManageZombies(ctx context.Context) {
logger.Log(1, "adding", id, "to zombie quaratine list") logger.Log(1, "adding", id, "to zombie quaratine list")
zombies = append(zombies, id) zombies = append(zombies, id)
case id := <-removeZombie: case id := <-removeZombie:
found := false
for i, zombie := range zombies { for i, zombie := range zombies {
if zombie == id { if zombie == id {
logger.Log(1, "removing zombie from quaratine list", zombie) logger.Log(1, "removing zombie from quaratine list", zombie)
zombies = append(zombies[:i], zombies[i+1:]...) zombies = append(zombies[:i], zombies[i+1:]...)
found = true
} }
} }
logger.Log(3, "no zombies found") if !found {
logger.Log(3, "no zombies found")
}
case <-time.After(time.Second * ZOMBIE_TIMEOUT): case <-time.After(time.Second * ZOMBIE_TIMEOUT):
for i, zombie := range zombies { for i, zombie := range zombies {
node, err := GetNodeByID(zombie) node, err := GetNodeByID(zombie)
@ -61,6 +67,7 @@ func ManageZombies(ctx context.Context) {
if time.Since(time.Unix(node.LastCheckIn, 0)) > time.Minute*ZOMBIE_DELETE_TIME { if time.Since(time.Unix(node.LastCheckIn, 0)) > time.Minute*ZOMBIE_DELETE_TIME {
if err := DeleteNodeByID(&node, true); err != nil { if err := DeleteNodeByID(&node, true); err != nil {
logger.Log(1, "error deleting zombie node", zombie, err.Error()) logger.Log(1, "error deleting zombie node", zombie, err.Error())
continue
} }
logger.Log(1, "deleting zombie node", node.Name) logger.Log(1, "deleting zombie node", node.Name)
zombies = append(zombies[:i], zombies[i+1:]...) zombies = append(zombies[:i], zombies[i+1:]...)