@@ -109,7 +109,9 @@ func (h *peerHub) add(id int64, rawurl string) (*peer, error) {
if h.stopped {
return nil, fmt.Errorf("peerHub stopped")
}
- h.peers[id] = newPeer(u.String(), h.c)
+ if _, ok := h.peers[id]; !ok {
+ h.peers[id] = newPeer(u.String(), h.c)
+ }
return h.peers[id], nil