moved locking post data fetching

dymensionxyz · Apr 17, 2024 · 6433abc · 6433abc
1 parent 69521b3
commit 6433abc
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/block/retriever.go b/block/retriever.go
@@ -42,8 +42,6 @@ func (m *Manager) RetriveLoop(ctx context.Context) {
 // It fetches the batches from the settlement, gets the DA height and gets
 // the actual blocks from the DA.
 func (m *Manager) syncUntilTarget(ctx context.Context, syncTarget uint64) error {
-	m.executeBlockMutex.Lock()
-	defer m.executeBlockMutex.Unlock()
 
 	currentHeight := m.store.Height()
 	for currentHeight < syncTarget {
@@ -95,6 +93,9 @@ func (m *Manager) processNextDABatch(ctx context.Context, daMetaData *da.DASubmi
 
 	m.logger.Debug("retrieved batches", "n", len(batchResp.Batches), "daHeight", daMetaData.Height)
 
+	m.executeBlockMutex.Lock()
+	defer m.executeBlockMutex.Unlock()
+
 	for _, batch := range batchResp.Batches {
 		for i, block := range batch.Blocks {
 			if block.Header.Height != m.store.NextHeight() {