From edb08bd209424db8d6ada7da58bb090d8a31149f Mon Sep 17 00:00:00 2001 From: Shay Zluf Date: Wed, 24 Jun 2020 13:40:33 +0300 Subject: [PATCH] QPS-20 implement removeDisconnectedPeerStatus (#6370) * QPS-20 implement removeDisconnectedPeerStatus * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * remove function * Merge branch 'remove_disconnected_peer_status' of github.com:prysmaticlabs/prysm into remove_disconnected_peer_status * Merge refs/heads/master into remove_disconnected_peer_status * Merge branch 'remove_disconnected_peer_status' of github.com:prysmaticlabs/prysm into remove_disconnected_peer_status --- beacon-chain/sync/rpc_status.go | 4 ---- beacon-chain/sync/service.go | 1 - 2 files changed, 5 deletions(-) diff --git a/beacon-chain/sync/rpc_status.go b/beacon-chain/sync/rpc_status.go index 5fcfb821f3..be9a2fa1a3 100644 --- a/beacon-chain/sync/rpc_status.go +++ b/beacon-chain/sync/rpc_status.go @@ -158,10 +158,6 @@ func (s *Service) reValidatePeer(ctx context.Context, id peer.ID) error { return nil } -func (s *Service) removeDisconnectedPeerStatus(ctx context.Context, pid peer.ID) error { - return nil -} - // statusRPCHandler reads the incoming Status RPC from the peer and responds with our version of a status message. // This handler will disconnect any peer that does not match our fork version. func (s *Service) statusRPCHandler(ctx context.Context, msg interface{}, stream libp2pcore.Stream) error { diff --git a/beacon-chain/sync/service.go b/beacon-chain/sync/service.go index f0eba30059..a2527eed7b 100644 --- a/beacon-chain/sync/service.go +++ b/beacon-chain/sync/service.go @@ -146,7 +146,6 @@ func (s *Service) Start() { } s.p2p.AddConnectionHandler(s.reValidatePeer, s.sendGenericGoodbyeMessage) - s.p2p.AddDisconnectionHandler(s.removeDisconnectedPeerStatus) s.p2p.AddPingMethod(s.sendPingRequest) s.processPendingBlocksQueue() s.processPendingAttsQueue()