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

peers try 2

Browse source
This commit is contained in:
0xdcarns 2022-01-30 20:52:56 -05:00
parent 8da7d96a82
commit d56bdc1ca1
1 changed files with 3 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
mq/mq.go
View file

@ -85,15 +85,12 @@ var UpdateNode mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message)
logger.Log(1, "error unmarshaling payload ", err.Error()) logger.Log(1, "error unmarshaling payload ", err.Error())
return return
} }
var shouldUpdatePeers = logic.IfaceDelta(&currentNode, &newNode)
if err := logic.UpdateNode(&currentNode, &newNode); err != nil { if err := logic.UpdateNode(&currentNode, &newNode); err != nil {
logger.Log(1, "error saving node", err.Error()) logger.Log(1, "error saving node", err.Error())
} }
if shouldUpdatePeers { if err := PublishPeerUpdate(&newNode); err != nil {
if err := PublishPeerUpdate(&newNode); err != nil { logger.Log(1, "error publishing peer update ", err.Error())
logger.Log(1, "error publishing peer update ", err.Error()) return
return
}
} }
logger.Log(1, "no need to update peers") logger.Log(1, "no need to update peers")
}() }()