diff --git a/orchestrator.go b/orchestrator.go index b332530..c0b87eb 100644 --- a/orchestrator.go +++ b/orchestrator.go @@ -116,11 +116,20 @@ func (b *AbstractBridge) WaitAndClean(entity AbstractMulticast) { log.Println("Inizializing Escalator") + entity.AddUniqueAndSort(b.hIerarchyNumber) + + brIp, _, err := net.ParseCIDR(b.BridgeIpCIDR) + if err != nil { + log.Println(err.Error()) + } + for { - entity.AddUniqueAndSort(b.hIerarchyNumber) + pollTime := len(entity.HierarchyArray) + 1 time.Sleep(time.Duration(pollTime) * time.Second) - // svuotare l'array - entity.HierarchyArray = entity.HierarchyArray[:0] + // svuotare l'array e rifare le elezioni + if !isActive(string(brIp)) { + entity.HierarchyArray = entity.HierarchyArray[:0] + } } }