squash

hemilabs · Feb 29, 2024 · cfe17d3 · cfe17d3
1 parent bdadebb
commit cfe17d3
Showing 1 changed file with 12 additions and 10 deletions.
diff --git a/service/popm/popm.go b/service/popm/popm.go
@@ -89,18 +89,20 @@ func (r *CircularFifo) MineEach(cb func(ks hemi.L2Keystone) error) {
 	})
 
 	for _, e := range copies {
-		if e.requiresMine {
-			if err := cb(e.l2Keystone); err == nil {
-				r.mtx.Lock()
-				for i := 0; i < cap(r.buf); i++ {
-					queued := hemi.L2KeystoneAbbreviate(r.buf[i].l2Keystone).Serialize()
-					mined := hemi.L2KeystoneAbbreviate(e.l2Keystone).Serialize()
-					if slices.Equal(queued[:], mined[:]) {
-						r.buf[i].requiresMine = false
-					}
+		if !e.requiresMine {
+			continue
+		}
+
+		if err := cb(e.l2Keystone); err == nil {
+			r.mtx.Lock()
+			for i := 0; i < cap(r.buf); i++ {
+				queued := hemi.L2KeystoneAbbreviate(r.buf[i].l2Keystone).Serialize()
+				mined := hemi.L2KeystoneAbbreviate(e.l2Keystone).Serialize()
+				if slices.Equal(queued[:], mined[:]) {
+					r.buf[i].requiresMine = false
 				}
-				r.mtx.Unlock()
 			}
+			r.mtx.Unlock()
 		}
 	}
 }