extern/zrepl
1
0
Fork 0
mirror of https://github.com/zrepl/zrepl.git synced 2025-06-20 17:58:04 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

pruner: fixup 69bfcb7bed71c2a26ac342bef5a94b746f61ac3f: add missing progress updates for watchdog

Browse Source
This commit is contained in:
Christian Schwarz 2018-10-20 10:58:22 +02:00
parent 6e21a67473
commit 50c1549865
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
daemon/pruner/pruner.go
View File

@ -470,6 +470,7 @@ fsloop:
} }
return u(func(pruner *Pruner) { return u(func(pruner *Pruner) {
pruner.Progress.MadeProgress()
for _, pfs := range pfss { for _, pfs := range pfss {
if pfs.err != nil { if pfs.err != nil {
pruner.pruneCompleted = append(pruner.pruneCompleted, pfs) pruner.pruneCompleted = append(pruner.pruneCompleted, pfs)
@ -522,6 +523,7 @@ func stateExec(a *args, u updater) state {
// if it's not retryable, treat is like as being done // if it's not retryable, treat is like as being done
return u(func(pruner *Pruner) { return u(func(pruner *Pruner) {
pruner.Progress.MadeProgress()
pruner.pruneCompleted = append(pruner.pruneCompleted, pfs) pruner.pruneCompleted = append(pruner.pruneCompleted, pfs)
pruner.prunePending = pruner.prunePending[1:] pruner.prunePending = pruner.prunePending[1:]
}).statefunc() }).statefunc()