Browse Source

Merge pull request #1296 from gravitl/feature_v0.14.5_longer_client_peer_cache

changed client message cache to a day
dcarns 3 years ago
parent
commit
ef82ac4af5
2 changed files with 2 additions and 2 deletions
  1. 1 1
      netclient/functions/daemon.go
  2. 1 1
      netclient/functions/mqhandlers.go

+ 1 - 1
netclient/functions/daemon.go

@@ -328,7 +328,7 @@ func read(network, which string) string {
 		if readMessage.LastSeen.IsZero() {
 		if readMessage.LastSeen.IsZero() {
 			return ""
 			return ""
 		}
 		}
-		if time.Now().After(readMessage.LastSeen.Add(time.Minute * 10)) { // check if message has been there over a minute
+		if time.Now().After(readMessage.LastSeen.Add(time.Hour * 24)) { // check if message has been there over a minute
 			messageCache.Delete(fmt.Sprintf("%s%s", network, which)) // remove old message if expired
 			messageCache.Delete(fmt.Sprintf("%s%s", network, which)) // remove old message if expired
 			return ""
 			return ""
 		}
 		}

+ 1 - 1
netclient/functions/mqhandlers.go

@@ -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