From 4bb8a451df5a84091bfb69e76a1b82932fdaf4a1 Mon Sep 17 00:00:00 2001 From: dylanhuang Date: Mon, 11 Nov 2024 05:01:02 +0000 Subject: [PATCH] fix: reduce fcu sending in parlia task --- crates/bsc/engine/src/task.rs | 25 ++++++++++++------------- 1 file changed, 12 insertions(+), 13 deletions(-) diff --git a/crates/bsc/engine/src/task.rs b/crates/bsc/engine/src/task.rs index da4a0e0a6..babb46bcf 100644 --- a/crates/bsc/engine/src/task.rs +++ b/crates/bsc/engine/src/task.rs @@ -421,21 +421,20 @@ impl< } for header in disconnected_headers { storage.insert_new_header(header.clone()); - let result = - fork_choice_tx.send(ForkChoiceMessage::NewHeader(NewHeaderEvent { - header: header.clone(), - // if the pipeline sync is true, the fork choice will not use the safe - // and finalized hash. - // this can make Block Sync Engine to use pipeline sync mode. - pipeline_sync, - local_header: latest_unsafe_header.clone(), - })); - if result.is_err() { - error!(target: "consensus::parlia", "Failed to send new block event to - fork choice"); - } } drop(storage); + let result = fork_choice_tx.send(ForkChoiceMessage::NewHeader(NewHeaderEvent { + header: sealed_header.clone(), + // if the pipeline sync is true, the fork choice will not use the safe + // and finalized hash. + // this can make Block Sync Engine to use pipeline sync mode. + pipeline_sync, + local_header: latest_unsafe_header.clone(), + })); + if result.is_err() { + error!(target: "consensus::parlia", "Failed to send new block event to + fork choice"); + } let result = chain_tracker_tx.send(ForkChoiceMessage::NewHeader(NewHeaderEvent { header: sealed_header.clone(),