From d392a07b9930d3679e5e799621b7334a1c1905b4 Mon Sep 17 00:00:00 2001 From: William Banfield Date: Wed, 3 Aug 2022 18:02:11 -0400 Subject: [PATCH] no peer status --- internal/p2p/peermanager.go | 34 ++++++++++++++++++---------------- 1 file changed, 18 insertions(+), 16 deletions(-) diff --git a/internal/p2p/peermanager.go b/internal/p2p/peermanager.go index 2e15fc8d2..bf225b059 100644 --- a/internal/p2p/peermanager.go +++ b/internal/p2p/peermanager.go @@ -1126,25 +1126,27 @@ func (m *PeerManager) Register(peerUpdates *PeerUpdates) { } func (m *PeerManager) processPeerEvent(pu PeerUpdate) { - m.mtx.Lock() - defer m.mtx.Unlock() + /* + m.mtx.Lock() + defer m.mtx.Unlock() - if _, ok := m.store.peers[pu.NodeID]; !ok { - m.store.peers[pu.NodeID] = &peerInfo{} - } + if _, ok := m.store.peers[pu.NodeID]; !ok { + m.store.peers[pu.NodeID] = &peerInfo{} + } - switch pu.Status { - case PeerStatusBad: - if m.store.peers[pu.NodeID].MutableScore == math.MinInt16 { - return + switch pu.Status { + case PeerStatusBad: + if m.store.peers[pu.NodeID].MutableScore == math.MinInt16 { + return + } + m.store.peers[pu.NodeID].MutableScore-- + case PeerStatusGood: + if m.store.peers[pu.NodeID].MutableScore == math.MaxInt16 { + return + } + m.store.peers[pu.NodeID].MutableScore++ } - m.store.peers[pu.NodeID].MutableScore-- - case PeerStatusGood: - if m.store.peers[pu.NodeID].MutableScore == math.MaxInt16 { - return - } - m.store.peers[pu.NodeID].MutableScore++ - } + */ } // broadcast broadcasts a peer update to all subscriptions. The caller must