fix: chunk retry not working

dashpay · Feb 3, 2025 · 3d39ee0 · 3d39ee0
1 parent 44f8f19
commit 3d39ee0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/statesync/chunks.go b/internal/statesync/chunks.go
@@ -104,8 +104,10 @@ func (q *chunkQueue) Enqueue(chunkIDs ...[]byte) {
 
 func (q *chunkQueue) enqueue(chunkID bytes.HexBytes) {
 	q.requestQueue = append(q.requestQueue, chunkID)
-	_, ok := q.items[chunkID.String()]
+	chunk, ok := q.items[chunkID.String()]
 	if ok {
+		// If the chunk is already in the queue, reset its status to initStatus to retry fetching it.
+		chunk.status = initStatus
 		return
 	}
 	q.items[chunkID.String()] = &chunkItem{