fix: remove hack

ethersphere · Feb 26, 2024 · 5cb6e9c · 5cb6e9c
1 parent ad22034
commit 5cb6e9c
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/pkg/storer/fix_refcnt.go b/pkg/storer/fix_refcnt.go
@@ -19,6 +19,15 @@ import (
 	"github.com/ethersphere/bee/pkg/swarm"
 )
 
+type ItemInfo struct {
+	item       *chunkstore.RetrievalIndexItem
+	pinCnt     uint32
+	reserveCnt uint32
+	cacheCnt   uint32
+	uploadCnt  uint32
+	batches    [][]byte
+}
+
 // FixRefCnt attempts to correct the RefCnt in all RetrievalIndexItems by scanning the actual chunk referers.
 func FixRefCnt(ctx context.Context, basePath string, opts *Options, repair bool) error {
 	logger := opts.Logger
@@ -71,15 +80,6 @@ func FixRefCnt(ctx context.Context, basePath string, opts *Options, repair bool)
 		logger.Info("pin count finished", "total", pinTotal, "elapsed", time.Since(startPinCount).Round(time.Second))
 	}
 
-	type ItemInfo struct {
-		item       *chunkstore.RetrievalIndexItem
-		pinCnt     uint32
-		reserveCnt uint32
-		cacheCnt   uint32
-		uploadCnt  uint32
-		batches    [][]byte
-	}
-
 	start := time.Now()
 	repaired := 0
 	processed := 0
@@ -226,7 +226,7 @@ func FixRefCnt(ctx context.Context, basePath string, opts *Options, repair bool)
 		refs := make(map[uint32]uint32)
 		for _, item := range items {
 			refs[item.item.RefCnt]++
-			newRefCnt := item.pinCnt*100 + item.reserveCnt + item.cacheCnt + item.uploadCnt
+			newRefCnt := item.pinCnt + item.reserveCnt + item.cacheCnt + item.uploadCnt
 			if newRefCnt != item.item.RefCnt {
 				discovered++
 				if item.item.RefCnt == 1 && newRefCnt == 0 {