ds printer

erigontech · Jul 21, 2024 · aa4502c · aa4502c
1 parent 77cfed7
commit aa4502c
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git 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
@@ -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]
 	}