Skip to content
Snippets Groups Projects
Commit 23454c34 authored by Hans Moog's avatar Hans Moog
Browse files

Refactor: removed some old code

parent 5f7494fb
Branches
Tags
No related merge requests found
......@@ -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()
}
*/
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment