mirror of
https://github.com/gravitl/netmaker.git
synced 2025-10-06 01:07:41 +08:00
adding checks for DNS to ensure connectivity
This commit is contained in:
@@ -298,18 +298,6 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
func setDNS(iface, network, address string) {
|
|
||||||
var reachable bool
|
|
||||||
for counter := 0; !reachable && counter < 5; counter++ {
|
|
||||||
reachable = local.IsDNSReachable(address)
|
|
||||||
time.Sleep(time.Second << 1)
|
|
||||||
}
|
|
||||||
if !reachable {
|
|
||||||
ncutils.Log("not setting dns, server unreachable: " + address)
|
|
||||||
} else if err := local.UpdateDNS(iface, network, address); err != nil {
|
|
||||||
ncutils.Log("error applying dns" + err.Error())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// UpdatePeers -- mqtt message handler for peers/<Network>/<NodeID> topic
|
// UpdatePeers -- mqtt message handler for peers/<Network>/<NodeID> topic
|
||||||
func UpdatePeers(client mqtt.Client, msg mqtt.Message) {
|
func UpdatePeers(client mqtt.Client, msg mqtt.Message) {
|
||||||
@@ -581,3 +569,16 @@ func shouldResub(currentServers, newServers []models.ServerAddr) bool {
|
|||||||
}
|
}
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func setDNS(iface, network, address string) {
|
||||||
|
var reachable bool
|
||||||
|
for counter := 0; !reachable && counter < 5; counter++ {
|
||||||
|
reachable = local.IsDNSReachable(address)
|
||||||
|
time.Sleep(time.Second << 1)
|
||||||
|
}
|
||||||
|
if !reachable {
|
||||||
|
ncutils.Log("not setting dns, server unreachable: " + address)
|
||||||
|
} else if err := local.UpdateDNS(iface, network, address); err != nil {
|
||||||
|
ncutils.Log("error applying dns" + err.Error())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Reference in New Issue
Block a user