File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -627,19 +627,22 @@ func (e *Executor) ProduceBlock(ctx context.Context) error {
627627 signature : signature ,
628628 })
629629
630- // Broadcast header and data to P2P network sequentially.
631- // IMPORTANT: Header MUST be broadcast before data — the P2P layer validates
632- // incoming data against the current and previous header, so out-of-order
633- // delivery would cause validation failures on peers.
634- if err := e .headerBroadcaster .WriteToStoreAndBroadcast (ctx , & types.P2PSignedHeader {
635- SignedHeader : header ,
636- }); err != nil {
637- e .logger .Error ().Err (err ).Msg ("failed to broadcast header" )
638- }
639- if err := e .dataBroadcaster .WriteToStoreAndBroadcast (ctx , & types.P2PData {
640- Data : data ,
641- }); err != nil {
642- e .logger .Error ().Err (err ).Msg ("failed to broadcast data" )
630+ // No broadcast to P2P when fiber is enabled.
631+ if ! e .config .DA .IsFiberEnabled () {
632+ // Broadcast header and data to P2P network sequentially.
633+ // IMPORTANT: Header MUST be broadcast before data — the P2P layer validates
634+ // incoming data against the current and previous header, so out-of-order
635+ // delivery would cause validation failures on peers.
636+ if err := e .headerBroadcaster .WriteToStoreAndBroadcast (ctx , & types.P2PSignedHeader {
637+ SignedHeader : header ,
638+ }); err != nil {
639+ e .logger .Error ().Err (err ).Msg ("failed to broadcast header" )
640+ }
641+ if err := e .dataBroadcaster .WriteToStoreAndBroadcast (ctx , & types.P2PData {
642+ Data : data ,
643+ }); err != nil {
644+ e .logger .Error ().Err (err ).Msg ("failed to broadcast data" )
645+ }
643646 }
644647
645648 e .recordBlockMetrics (newState , data )
You can’t perform that action at this time.
0 commit comments