File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -135,7 +135,6 @@ func (s *Syncer) Start(ctx context.Context) error {
135135 }
136136
137137 // Start main processing loop
138- s .wg .Add (1 )
139138 go s .processLoop ()
140139
141140 // Start dedicated workers for DA, and pending processing
@@ -227,6 +226,7 @@ func (s *Syncer) initializeState() error {
227226
228227// processLoop is the main coordination loop for processing events
229228func (s * Syncer ) processLoop () {
229+ s .wg .Add (1 )
230230 defer s .wg .Done ()
231231
232232 s .logger .Info ().Msg ("starting process loop" )
@@ -530,7 +530,7 @@ func (s *Syncer) trySyncNextBlock(event *common.DAHeightEvent) error {
530530 }
531531
532532 // Update DA height if needed
533- // This height is only updated when an height is process from DA as P2P
533+ // This height is only updated when a height is processed from DA as P2P
534534 // events do not contain DA height information
535535 if event .DaHeight > newState .DAHeight {
536536 newState .DAHeight = event .DaHeight
You can’t perform that action at this time.
0 commit comments