gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-10-26 05:56:36 +08:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #1597 from gravitl/bugfix_v0.16.1_disconnect_cleanup

Browse source 
additional checks for disconnected nodes
This commit is contained in:
Alex Feiszli 2022-09-23 15:29:22 -04:00 • committed by GitHub
commit 318914c48b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 45 additions and 37 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
logic/peers.go
View file

@ -61,6 +61,10 @@ func GetPeerUpdate(node *models.Node) (models.PeerUpdate, error) {
if node.NetworkSettings.IsPointToSite == "yes" && node.IsHub == "no" && peer.IsHub == "no" {
continue
}
if node.Connected != "yes" {
//skip unconnected nodes
continue
}
// if the node is not a server, set the endpoint
var setEndpoint = !(node.IsServer == "yes")

2
netclient/functions/daemon.go
View file

@ -94,12 +94,14 @@ func startGoRoutines(wg *sync.WaitGroup) context.CancelFunc {
cfg := config.ClientConfig{}
cfg.Network = network
cfg.ReadConfig()
if cfg.Node.Connected == "yes" {
if err := wireguard.ApplyConf(&cfg.Node, cfg.Node.Interface, ncutils.GetNetclientPathSpecific()+cfg.Node.Interface+".conf"); err != nil {
logger.Log(0, "failed to start ", cfg.Node.Interface, "wg interface", err.Error())
}
if cfg.PublicIPService != "" {
global_settings.PublicIPServices[network] = cfg.PublicIPService
}
}
server := cfg.Server.Server
if !serverSet[server] {

2
netclient/functions/mqpublish.go
View file

@ -69,6 +69,7 @@ func checkin(currentRun int) {
// defaults to iptables for now, may need another default for non-Linux OSes
nodeCfg.Node.FirewallInUse = models.FIREWALL_IPTABLES
}
if nodeCfg.Node.Connected == "yes" {
if nodeCfg.Node.IsStatic != "yes" {
extIP, err := ncutils.GetPublicIP(nodeCfg.Server.API)
if err != nil {
@ -107,6 +108,7 @@ func checkin(currentRun int) {
}
}
}
}
//check version
if nodeCfg.Node.Version != ncutils.Version {
nodeCfg.Node.Version = ncutils.Version