@@ -381,7 +381,6 @@ func (e *Executor) executionLoop() {
381381 } else {
382382 delay = time .Until (currentState .LastBlockTime .Add (e .config .Node .BlockTime .Duration ))
383383 }
384-
385384 if delay > 0 {
386385 e .logger .Info ().Dur ("delay" , delay ).Msg ("waiting to start block production" )
387386 select {
@@ -591,7 +590,7 @@ func (e *Executor) ProduceBlock(ctx context.Context) error {
591590 LastSubmittedDaHeaderHeight : e .cache .GetLastSubmittedHeaderHeight (),
592591 LastSubmittedDaDataHeight : e .cache .GetLastSubmittedDataHeight (),
593592 }
594- if err := e .raftNode .Broadcast (e . ctx , raftState ); err != nil {
593+ if err := e .raftNode .Broadcast (ctx , raftState ); err != nil {
595594 return fmt .Errorf ("failed to propose block to raft: %w" , err )
596595 }
597596 e .logger .Debug ().Uint64 ("height" , newHeight ).Msg ("proposed block to raft" )
@@ -617,12 +616,12 @@ func (e *Executor) ProduceBlock(ctx context.Context) error {
617616 // IMPORTANT: Header MUST be broadcast before data — the P2P layer validates
618617 // incoming data against the current and previous header, so out-of-order
619618 // delivery would cause validation failures on peers.
620- if err := e .headerBroadcaster .WriteToStoreAndBroadcast (e . ctx , & types.P2PSignedHeader {
619+ if err := e .headerBroadcaster .WriteToStoreAndBroadcast (ctx , & types.P2PSignedHeader {
621620 SignedHeader : header ,
622621 }); err != nil {
623622 e .logger .Error ().Err (err ).Msg ("failed to broadcast header" )
624623 }
625- if err := e .dataBroadcaster .WriteToStoreAndBroadcast (e . ctx , & types.P2PData {
624+ if err := e .dataBroadcaster .WriteToStoreAndBroadcast (ctx , & types.P2PData {
626625 Data : data ,
627626 }); err != nil {
628627 e .logger .Error ().Err (err ).Msg ("failed to broadcast data" )
@@ -637,7 +636,7 @@ func (e *Executor) ProduceBlock(ctx context.Context) error {
637636
638637 // For based sequencer, advance safe/finalized since it comes from DA.
639638 if e .config .Node .BasedSequencer {
640- if err := e .exec .SetFinal (e . ctx , newHeight ); err != nil {
639+ if err := e .exec .SetFinal (ctx , newHeight ); err != nil {
641640 e .sendCriticalError (fmt .Errorf ("failed to set final height in based sequencer mode: %w" , err ))
642641 return fmt .Errorf ("failed to set final height in based sequencer mode: %w" , err )
643642 }
0 commit comments