synchronous again

Author: julienrbrt

block/internal/syncing/syncer.go

@@ -240,37 +240,16 @@ func (s *Syncer) syncLoop() {
 	// Backoff control when DA replies with errors
 	nextDARequestAt := &time.Time{}
 
-	blockTicker := time.NewTicker(s.config.Node.BlockTime.Duration)
-	defer blockTicker.Stop()
-
 	for {
-		wg := sync.WaitGroup{}
-
 		select {
 		case <-s.ctx.Done():
 			return
 		default:
 		}
-		wg.Add(1)
-		go func() {
-			defer wg.Done()
-			s.processPendingEvents()
-		}()
-
-		wg.Add(1)
-		go func() {
-			defer wg.Done()
-			s.tryFetchFromP2P()
-		}()
-
-		wg.Add(1)
-		go func() {
-			defer wg.Done()
-			s.tryFetchFromDA(nextDARequestAt)
-		}()
-
-		// wait for pending events processing, p2p and da fetching
-		wg.Wait()
+
+		s.processPendingEvents()
+		s.tryFetchFromP2P()
+		s.tryFetchFromDA(nextDARequestAt)
 
 		// Prevent busy-waiting when no events are processed
 		select {