From 75e1bb616b2853d65397fd3bbfde2f0d147de326 Mon Sep 17 00:00:00 2001 From: Agnish Ghosh Date: Sun, 18 Aug 2024 13:35:16 +0530 Subject: [PATCH] handling reconstruction condition internally --- beacon_chain/networking/eth2_network.nim | 2 ++ beacon_chain/nimbus_beacon_node.nim | 4 +--- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/beacon_chain/networking/eth2_network.nim b/beacon_chain/networking/eth2_network.nim index 4ad1667b7..d9ba035d7 100644 --- a/beacon_chain/networking/eth2_network.nim +++ b/beacon_chain/networking/eth2_network.nim @@ -1675,6 +1675,8 @@ proc handlePeer*(peer: Peer) {.async: (raises: [CancelledError]).} = debug "Peer has low score or there no space in PeerPool", peer = peer, reason = res await peer.disconnect(FaultOrError) + of PeerStatus.LowCscError: + discard of PeerStatus.DeadPeerError: # Peer's lifetime future is finished, so its already dead, # we do not need to perform gracefull disconect. diff --git a/beacon_chain/nimbus_beacon_node.nim b/beacon_chain/nimbus_beacon_node.nim index 597002820..391248cfa 100644 --- a/beacon_chain/nimbus_beacon_node.nim +++ b/beacon_chain/nimbus_beacon_node.nim @@ -1581,9 +1581,7 @@ proc reconstructAndSendDataColumns*(node: BeaconNode) {.async.} = proc onSlotEnd(node: BeaconNode, slot: Slot) {.async.} = # Things we do when slot processing has ended and we're about to wait for the # next slot - - if node.config.subscribeAllSubnets: - await node.reconstructAndSendDataColumns() + await node.reconstructAndSendDataColumns() # By waiting until close before slot end, ensure that preparation for next # slot does not interfere with propagation of messages and with VC duties.