mirror of
https://github.com/gravitl/netmaker.git
synced 2025-09-11 07:34:31 +08:00
moved log to reflect when message is actually consumed
This commit is contained in:
parent
8da999f21d
commit
52b876b333
1 changed files with 1 additions and 1 deletions
|
@ -44,13 +44,13 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
logger.Log(0, "received message to update node "+newNode.Name)
|
|
||||||
// see if cache hit, if so skip
|
// see if cache hit, if so skip
|
||||||
var currentMessage = read(newNode.Network, lastNodeUpdate)
|
var currentMessage = read(newNode.Network, lastNodeUpdate)
|
||||||
if currentMessage == string(data) {
|
if currentMessage == string(data) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
insert(newNode.Network, lastNodeUpdate, string(data)) // store new message in cache
|
insert(newNode.Network, lastNodeUpdate, string(data)) // store new message in cache
|
||||||
|
logger.Log(0, "received message to update node "+newNode.Name)
|
||||||
|
|
||||||
// ensure that OS never changes
|
// ensure that OS never changes
|
||||||
newNode.OS = runtime.GOOS
|
newNode.OS = runtime.GOOS
|
||||||
|
|
Loading…
Add table
Reference in a new issue