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()