|
@@ -156,6 +156,7 @@ func GetPeerUpdateForHost(network string, host *models.Host) (models.HostPeerUpd
|
|
|
nodePeerMap = make(map[string]models.PeerRouteInfo)
|
|
|
}
|
|
|
for _, peer := range currentPeers {
|
|
|
+ peer := peer
|
|
|
if peer.ID == node.ID {
|
|
|
logger.Log(2, "peer update, skipping self")
|
|
|
//skip yourself
|
|
@@ -289,6 +290,7 @@ func GetPeerUpdateForHost(network string, host *models.Host) (models.HostPeerUpd
|
|
|
extPeers, extPeerIDAndAddrs, err = getExtPeers(&node)
|
|
|
if err == nil {
|
|
|
for _, extPeerIdAndAddr := range extPeerIDAndAddrs {
|
|
|
+ extPeerIdAndAddr := extPeerIdAndAddr
|
|
|
nodePeerMap[extPeerIdAndAddr.ID] = models.PeerRouteInfo{
|
|
|
PeerAddr: net.IPNet{
|
|
|
IP: net.ParseIP(extPeerIdAndAddr.Address),
|
|
@@ -300,6 +302,7 @@ func GetPeerUpdateForHost(network string, host *models.Host) (models.HostPeerUpd
|
|
|
}
|
|
|
hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, extPeers...)
|
|
|
for _, extPeerIdAndAddr := range extPeerIDAndAddrs {
|
|
|
+ extPeerIdAndAddr := extPeerIdAndAddr
|
|
|
hostPeerUpdate.HostPeerIDs[extPeerIdAndAddr.ID] = make(map[string]models.IDandAddr)
|
|
|
hostPeerUpdate.HostPeerIDs[extPeerIdAndAddr.ID][extPeerIdAndAddr.ID] = models.IDandAddr{
|
|
|
ID: extPeerIdAndAddr.ID,
|