Author SHA1 Message Date
sneak ac2f4416fa Stop the disk size tests failing at random on ZFS (closes #150)
check / check (push) Canceled after 0s
One ZFS commit can take a file through several sizes, and unix.Sync can
return before the blocks are counted. A test that expected the size on
disk to be settled therefore failed at random. The test that needs the
size to change now calls unix.Sync in a loop until it does, for at most
30 seconds. All three tests read the size before and after the scan and
fail only on a disk_size outside those two reads. The two that do not
wait call unix.Sync once first, so a wrong 512 usually fails them.

Model: opus-5-5
2026-11-03 00:07:03 +00:00
2 changed files with 16 additions and 38 deletions
+2 -3
View File
@@ -33,9 +33,8 @@ are known.
`unix.Sync` can return before ZFS has counted a file's blocks, and one ZFS `unix.Sync` can return before ZFS has counted a file's blocks, and one ZFS
commit can take a file through several sizes. The test that needs the size to commit can take a file through several sizes. The test that needs the size to
change waits for it, for at most 30 seconds. Each test reads the size before change waits for it, for at most 30 seconds. Each test reads the size before
and after its scan. The rewrite test rescans until the two reads match, then and after its scan. It fails only on a `disk_size` outside those two reads
compares exactly. The other two fail only on a `disk_size` outside the two (2026-11-02, https://git.eeqj.de/sneak/sfdupes/issues/150)
reads (2026-11-02, https://git.eeqj.de/sneak/sfdupes/issues/150)
- `TODO.md` rewritten from scratch by the same rules as `README.md`, sentence by - `TODO.md` rewritten from scratch by the same rules as `README.md`, sentence by
sentence. Every completed step is kept, with its date and its issue or branch. sentence. Every completed step is kept, with its date and its issue or branch.
+14 -35
View File
@@ -50,9 +50,8 @@ func writeFile(t *testing.T, dir, name string, data []byte) string {
// but a unix.Sync call often takes long enough that the blocks are // but a unix.Sync call often takes long enough that the blocks are
// counted when it returns. A test that needs the value to change waits // counted when it returns. A test that needs the value to change waits
// for the change. A test that compares it with a scan's disk_size reads // for the change. A test that compares it with a scan's disk_size reads
// it before and after the scan. The rewrite test rescans until the two // it before and after the scan, and fails only on a disk_size outside
// reads match, then compares exactly. The other two tests fail only on // those two reads.
// a disk_size outside the two reads.
func diskSizeOf(t *testing.T, path string) int64 { func diskSizeOf(t *testing.T, path string) int64 {
t.Helper() t.Helper()
@@ -1515,42 +1514,22 @@ func TestSyncScanRewriteUpdatesDiskSize(t *testing.T) {
unix.Sync() unix.Sync()
} }
// ZFS may still be counting, so the size may change during a rescan. // ZFS may still be counting, so the size may change during the rescan.
// Only a rescan with the same size on both sides of it can be compared // A rescan that keeps the old size still fails, because the wait made
// exactly. A rescan that keeps the old size still fails, because the // before differ from it.
// wait made before differ from it. before := diskSizeOf(t, p)
for {
before := diskSizeOf(t, p)
st := syncTree(t, db, dir) st := syncTree(t, db, dir)
after := diskSizeOf(t, p) after := diskSizeOf(t, p)
if st != (scanStats{walked: 1, updated: 1}) { if st != (scanStats{walked: 1, updated: 1}) {
t.Fatalf("rescan stats = %+v, want 1 updated", st) t.Fatalf("rescan stats = %+v, want 1 updated", st)
} }
if before == after { got := recordByPath(t, dbRecords(t, db), p).diskSize
got := recordByPath(t, dbRecords(t, db), p).diskSize if got < before || got > after {
if got != after { t.Errorf("disk_size = %d, want %d to %d", got, before, after)
t.Errorf("disk_size = %d, want %d", got, after)
}
return
}
if time.Now().After(deadline) {
t.Fatalf("the size on disk was still changing 30 seconds after "+
"the write into its hole: %d, then %d", before, after)
}
// A later mtime makes the next rescan read the file again.
later = later.Add(time.Second)
err = os.Chtimes(p, later, later)
if err != nil {
t.Fatal(err)
}
} }
} }