zishuo/netmaker
1
0
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-10-06 09:22:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'develop' into feature-messageQueue

Browse Source
This commit is contained in:
Matthew R Kasun
2022-01-24 06:21:21 -05:00
parent 4b826e6de2 a1f07ef78c
commit c239ee3787
42 changed files with 953 additions and 189 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
controllers/server_util.go
View File

@@ -1,20 +1,33 @@
package controller
//func runServerPeerUpdate(network string, shouldPeerUpdate bool) error {
// if servercfg.IsClientMode() != "on" {
// return nil
// }
// var currentServerNodeID, err = logic.GetNetworkServerNodeID(network)
// if err != nil {
// return err
// }
// var currentServerNode, currErr = logic.GetNodeByID(currentServerNodeID)
// if currErr != nil {
// return currErr
// }
// if err = logic.ServerUpdate(&currentServerNode, shouldPeerUpdate); err != nil {
// logger.Log(1, "server node:", currentServerNode.ID, "failed update")
// return err
// }
// return nil
//}
import (
"github.com/gravitl/netmaker/logger"
"github.com/gravitl/netmaker/logic"
"github.com/gravitl/netmaker/servercfg"
"github.com/gravitl/netmaker/serverctl"
)
func runServerPeerUpdate(network string, shouldPeerUpdate bool) error {
if servercfg.Telemetry() == "on" {
err := serverctl.TelemetryCheckpoint()
if err != nil {
logger.Log(1, "failed to send telemetry:", err.Error())
}
}
if servercfg.IsClientMode() != "on" {
return nil
}
var currentServerNodeID, err = logic.GetNetworkServerNodeID(network)
if err != nil {
return err
}
var currentServerNode, currErr = logic.GetNodeByID(currentServerNodeID)
if currErr != nil {
return currErr
}
if err = logic.ServerUpdate(&currentServerNode, shouldPeerUpdate); err != nil {
logger.Log(1, "server node:", currentServerNode.ID, "failed update")
return err
}
return nil
}