From 23454c3402629b8bf7becd378e42d9c250153a2b Mon Sep 17 00:00:00 2001
From: Hans Moog <hm@mkjc.net>
Date: Tue, 30 Jul 2019 17:14:34 +0200
Subject: [PATCH] Refactor: removed some old code
---
.../protocol/incoming_response_processor.go | 16 +---------------
1 file changed, 1 insertion(+), 15 deletions(-)
diff --git a/plugins/autopeering/protocol/incoming_response_processor.go b/plugins/autopeering/protocol/incoming_response_processor.go
index 1bec1044..ea33fa60 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()
- }
- */
}
}
--
GitLab