continue
}
log.Info("discover new node: ", node)
-
- for m.isConnected() {
- time.Sleep(1 * time.Second)
- }
+ // m.Lock()
if err := m.upSertNode(&config.Node{
PublicKey: node.ID.String(),
Host: node.IP.String(),
}
nodeMap[node.ID.String()] = node
+ // m.Unlock()
}
}