From 3540b638f6719ec72ac856efbb5d6b0b0178fff8 Mon Sep 17 00:00:00 2001 From: Martin Geno Date: Thu, 6 Jul 2017 09:17:19 +0200 Subject: [PATCH] fix ssh update --- runtime/nodes.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/runtime/nodes.go b/runtime/nodes.go index b8d67a3..f706657 100644 --- a/runtime/nodes.go +++ b/runtime/nodes.go @@ -89,6 +89,7 @@ func (nodes *Nodes) UpdateNode(node *Node) { nodes.Lock() defer nodes.Unlock() if n, ok := nodes.List[node.NodeID]; ok { + node.Address = n.Address go node.SSHUpdate(nodes.ssh, nodes.iface, n) } nodes.List[node.NodeID] = node @@ -100,7 +101,7 @@ func (nodes *Nodes) Updater() { defer nodes.Unlock() for nodeid, node := range nodes.List { if n, ok := nodes.Current[nodeid]; ok { - go n.SSHUpdate(nodes.ssh, nodes.iface, node) + go node.SSHUpdate(nodes.ssh, nodes.iface, n) } } log.Log.Debug("updater per ssh runs")