Skip to content

Commit 1b813ea

Browse files
committed
move all the state globals up top
1 parent a842d1d commit 1b813ea

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

main.go

+5-5
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,11 @@ var queueCond = sync.Cond{L: &queueLock}
6767
var queue []string // FIXME: should be a resizable ring buffer
6868
var currentlyWorkingWorkers uint
6969

70+
var lazyHasherBackoff chan struct{}
71+
72+
var totalDedupped atomic.Uint64
73+
var totalDeddupingErrors atomic.Uint64
74+
7075
// decrementCurrentlyWorkingWorkers must be called while holding [queueLock].
7176
func decrementCurrentlyWorkingWorkers() {
7277
currentlyWorkingWorkers--
@@ -235,8 +240,6 @@ func scan(f *os.File, p string, length, blocksize uint64) error {
235240
return hashFile(f, length, p, false)
236241
}
237242

238-
var lazyHasherBackoff chan struct{}
239-
240243
func doLazyHash(other string, length uint64) {
241244
defer wg.Done()
242245
defer func() { <-lazyHasherBackoff }()
@@ -285,9 +288,6 @@ func hashFile(f *os.File, length uint64, p string, statsWereAlreadyRecorded bool
285288
return nil
286289
}
287290

288-
var totalDedupped atomic.Uint64
289-
var totalDeddupingErrors atomic.Uint64
290-
291291
func dedup(backoff chan struct{}, length uint64, paths ...string) {
292292
defer func() { <-backoff }()
293293

0 commit comments

Comments
 (0)