fix retrieve loop

dymensionxyz · May 13, 2024 · 88abca6 · 88abca6
1 parent e1de9b2
commit 88abca6
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/block/retriever.go b/block/retriever.go
@@ -15,16 +15,18 @@ import (
 // fetching batches from the settlement layer and then fetching the actual blocks
 // from the DA.
 func (m *Manager) RetrieveLoop(ctx context.Context) {
-	m.logger.Info("started retrieve loop")
-	targetSyncHeightPoller := diodes.NewPoller(m.targetSyncHeight, diodes.WithPollingContext(ctx))
+	m.logger.Info("Started retrieve loop.")
+	p := diodes.NewPoller(m.targetSyncHeight, diodes.WithPollingContext(ctx))
 
 	for {
 		select {
 		case <-ctx.Done():
 			return
 		default:
-			// Get only the latest sync target
-			targetHeight := targetSyncHeightPoller.Next()
+			/*
+				We only care about the latest one
+			*/
+			targetHeight := p.Next()
 			err := m.syncToTargetHeight(*(*uint64)(targetHeight))
 			if err != nil {
 				panic(fmt.Errorf("sync until target: %w", err))