fixes

Author: julienrbrt

block/internal/cache/generic_cache.go

@@ -97,9 +97,14 @@ func (c *Cache[T]) setDAIncluded(hash string, daHeight uint64, blockHeight uint6
 	c.hashByHeight.Store(blockHeight, hash)
 
 	// Update max DA height if necessary
-	current := c.maxDAHeight.Load()
-	if daHeight > current {
-		c.maxDAHeight.Store(daHeight)
+	for {
+		current := c.maxDAHeight.Load()
+		if daHeight <= current {
+			return
+		}
+		if c.maxDAHeight.CompareAndSwap(current, daHeight) {
+			return
+		}
 	}
 }
 

block/internal/syncing/p2p_handler.go

@@ -50,8 +50,14 @@ func NewP2PHandler(
 
 // SetProcessedHeight updates the highest processed block height.
 func (h *P2PHandler) SetProcessedHeight(height uint64) {
-	if height > h.processedHeight.Load() {
-		h.processedHeight.Store(height)
+	for {
+		current := h.processedHeight.Load()
+		if height <= current {
+			return
+		}
+		if h.processedHeight.CompareAndSwap(current, height) {
+			return
+		}
 	}
 }