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

periodic host updates

Browse source
This commit is contained in:
Abhishek Kondur 2023-01-06 17:52:17 +05:30
parent ca3d9dc40b
commit 68ed1b8b33
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
mq/publishers.go
View file

@ -139,7 +139,7 @@ func ProxyUpdate(proxyPayload *proxy_models.ProxyManagerPayload, node *models.No
// sendPeers - retrieve networks, send peer ports to all peers // sendPeers - retrieve networks, send peer ports to all peers
func sendPeers() { func sendPeers() {
networks, err := logic.GetNetworks() hosts, err := logic.GetAllHosts()
if err != nil { if err != nil {
logger.Log(1, "error retrieving networks for keepalive", err.Error()) logger.Log(1, "error retrieving networks for keepalive", err.Error())
} }
@ -164,13 +164,12 @@ func sendPeers() {
//collectServerMetrics(networks[:]) //collectServerMetrics(networks[:])
} }
for _, network := range networks { for _, host := range hosts {
if force { if force {
logger.Log(2, "sending scheduled peer update (5 min)") logger.Log(2, "sending scheduled peer update (5 min)")
err = PublishPeerUpdate(network.NetID, false) err = PublishSingleHostUpdate(&host)
if err != nil { if err != nil {
logger.Log(1, "error publishing udp port updates for network", network.NetID) logger.Log(1, "error publishing peer updates for host: ", host.ID.String(), " Err: ", err.Error())
logger.Log(1, err.Error())
} }
} }
} }