diff --git a/plugins/autopeering/protocol/incoming_response_processor.go b/plugins/autopeering/protocol/incoming_response_processor.go index 1bec1044722132eda13f3f8d1f7edd37d3637824..ea33fa60d5c7f00411f8315065692014d022a1e6 100644 --- a/plugins/autopeering/protocol/incoming_response_processor.go +++ b/plugins/autopeering/protocol/incoming_response_processor.go @@ -17,7 +17,7 @@ func createIncomingResponseProcessor(plugin *node.Plugin) *events.Closure { func processIncomingResponse(plugin *node.Plugin, peeringResponse *response.Response) { plugin.LogDebug("received peering response from " + peeringResponse.Issuer.String()) - peeringResponse.Issuer.Conn.Close() + _ = peeringResponse.Issuer.Conn.Close() knownpeers.INSTANCE.AddOrUpdate(peeringResponse.Issuer) for _, peer := range peeringResponse.Peers { @@ -28,19 +28,5 @@ func processIncomingResponse(plugin *node.Plugin, peeringResponse *response.Resp defer chosenneighbors.INSTANCE.Lock()() chosenneighbors.INSTANCE.AddOrUpdate(peeringResponse.Issuer, false) - - /* - if len(chosenneighbors.INSTANCE.Peers) > constants.NEIGHBOR_COUNT / 2 { - dropMessage := &drop.Drop{Issuer:ownpeer.INSTANCE} - dropMessage.Sign() - - chosenneighbors.FurthestNeighborLock.RLock() - if _, err := chosenneighbors.FURTHEST_NEIGHBOR.Send(dropMessage.Marshal(), types.PROTOCOL_TYPE_UDP, false); err != nil { - plugin.LogDebug("error when sending drop message to" + chosenneighbors.FURTHEST_NEIGHBOR.String()) - } - chosenneighbors.INSTANCE.Remove(chosenneighbors.FURTHEST_NEIGHBOR.Identity.StringIdentifier, false) - chosenneighbors.FurthestNeighborLock.RUnlock() - } - */ } }