X-Git-Url: http://git.osdn.net/view?a=blobdiff_plain;f=toolbar%2Fprecog%2Fmonitor%2Fdiscover.go;h=0e9ef4735c80c2cedc973a7208031498be94bb0e;hb=568892ca3bfaa3a8ed32b7fc39c16ed2548595cc;hp=9a1560cacc92c7a22c3476ec0a8de8eb751a204f;hpb=53a70cd88c6d76a4a41f4ccab50b6d9b351d72ed;p=bytom%2Fvapor.git diff --git a/toolbar/precog/monitor/discover.go b/toolbar/precog/monitor/discover.go index 9a1560ca..0e9ef473 100644 --- a/toolbar/precog/monitor/discover.go +++ b/toolbar/precog/monitor/discover.go @@ -33,10 +33,7 @@ func (m *monitor) collectDiscoveredNodes() { 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(), @@ -46,5 +43,6 @@ func (m *monitor) collectDiscoveredNodes() { } nodeMap[node.ID.String()] = node + // m.Unlock() } }