From aa4502c556a004f6700ef721f1d3456829352ecc Mon Sep 17 00:00:00 2001
From: Mark Holt <mark@distributed.vision>
Date: Sun, 21 Jul 2024 14:17:54 +0100
Subject: [PATCH] ds printer

---
 mmap_span/mmap_span.go | 9 +++++----
 storage/mmap.go        | 2 +-
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/mmap_span/mmap_span.go b/mmap_span/mmap_span.go
index 1fe63a023c..be07440bf5 100644
--- a/mmap_span/mmap_span.go
+++ b/mmap_span/mmap_span.go
@@ -85,10 +85,11 @@ func (ms *MMapSpan) flushMaps(onFlush func(size int64), lock bool) (errs []error
 
 	if flushedCallback != nil {
 		flushedCallback(ms.InfoHash, dirtyPieces)
-		fmt.Println("FDS", onFlush, dirtySize)
-		if onFlush != nil {
-			onFlush(dirtySize)
-		}
+	}
+
+	fmt.Println("FDS", onFlush, dirtySize)
+	if onFlush != nil {
+		onFlush(dirtySize)
 	}
 
 	return
diff --git a/storage/mmap.go b/storage/mmap.go
index 4d4eda1b43..875a34da89 100644
--- a/storage/mmap.go
+++ b/storage/mmap.go
@@ -91,7 +91,7 @@ func (ts *mmapTorrentStorage) Close() error {
 }
 
 func (ts *mmapTorrentStorage) Flush(onFlush func(size int64)) error {
-	errs := ts.span.Flush(nil)
+	errs := ts.span.Flush(onFlush)
 	if len(errs) > 0 {
 		return errs[0]
 	}