From 629613de1be64224bafb26a28e432bb242441729 Mon Sep 17 00:00:00 2001
From: sneak <sneak@sneak.berlin>
Date: Mon, 2 Feb 2026 13:50:42 -0800
Subject: [PATCH] Track actual bytes read instead of stale file size

fileMultihash now returns the number of bytes actually read during
hashing. This ensures BytesProcessed reflects the true amount of
data processed, not a potentially stale size from the initial walk.
---
 attrsum.go | 21 +++++++++++----------
 1 file changed, 11 insertions(+), 10 deletions(-)

diff --git a/attrsum.go b/attrsum.go
index 52c2e36..30ba5f1 100644
--- a/attrsum.go
+++ b/attrsum.go
@@ -241,7 +241,7 @@ func writeChecksumAndTime(path string, info os.FileInfo, stats *Stats) error {
 	// Record mtime before hashing to detect modifications during hash
 	mtimeBefore := info.ModTime()
 
-	hash, err := fileMultihash(path)
+	hash, bytesRead, err := fileMultihash(path)
 	if err != nil {
 		return err
 	}
@@ -273,7 +273,7 @@ func writeChecksumAndTime(path string, info os.FileInfo, stats *Stats) error {
 	}
 
 	atomic.AddInt64(&stats.FilesProcessed, 1)
-	atomic.AddInt64(&stats.BytesProcessed, infoAfter.Size())
+	atomic.AddInt64(&stats.BytesProcessed, bytesRead)
 	return nil
 }
 
@@ -426,7 +426,7 @@ func ProcessCheck(dir string, cont bool, stats *Stats, bar *progressbar.Progress
 			return err
 		}
 
-		act, err := fileMultihash(p)
+		act, bytesRead, err := fileMultihash(p)
 		if err != nil {
 			atomic.AddInt64(&s.FilesFailed, 1)
 			return err
@@ -436,7 +436,7 @@ func ProcessCheck(dir string, cont bool, stats *Stats, bar *progressbar.Progress
 			atomic.AddInt64(&s.FilesFailed, 1)
 		} else {
 			atomic.AddInt64(&s.FilesProcessed, 1)
-			atomic.AddInt64(&s.BytesProcessed, info.Size())
+			atomic.AddInt64(&s.BytesProcessed, bytesRead)
 		}
 		if verbose && !quiet {
 			status := "OK"
@@ -604,20 +604,21 @@ func hasXattr(path, key string) bool {
 	return err == nil
 }
 
-func fileMultihash(path string) ([]byte, error) {
+func fileMultihash(path string) (hash []byte, bytesRead int64, err error) {
 	f, err := os.Open(path)
 	if err != nil {
-		return nil, err
+		return nil, 0, err
 	}
 	defer f.Close()
 
 	h := sha256.New()
-	if _, err := io.Copy(h, f); err != nil {
-		return nil, err
+	bytesRead, err = io.Copy(h, f)
+	if err != nil {
+		return nil, bytesRead, err
 	}
 	mh, err := multihash.Encode(h.Sum(nil), multihash.SHA2_256)
 	if err != nil {
-		return nil, err
+		return nil, bytesRead, err
 	}
-	return []byte(base58.Encode(mh)), nil
+	return []byte(base58.Encode(mh)), bytesRead, nil
 }