Commit 4a57fffd authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 719d8005
...@@ -181,7 +181,7 @@ func verifyIdxMain(argv []string) { ...@@ -181,7 +181,7 @@ func verifyIdxMain(argv []string) {
storPath := argv[0] storPath := argv[0]
// progress display // progress display
progress := func(p *fs1.IndexVerifyProgress) { display := func(p *fs1.IndexVerifyProgress) {
if p.TxnTotal == -1 { if p.TxnTotal == -1 {
bytesChecked := p.Index.TopPos - p.Iter.Txnh.Pos bytesChecked := p.Index.TopPos - p.Iter.Txnh.Pos
bytesAll := p.Index.TopPos bytesAll := p.Index.TopPos
...@@ -196,14 +196,34 @@ func verifyIdxMain(argv []string) { ...@@ -196,14 +196,34 @@ func verifyIdxMain(argv []string) {
} }
} }
// display updates once per tick
tick := time.NewTicker(time.Second / 4)
defer tick.Stop()
var lastp *fs1.IndexVerifyProgress
progress := func(p *fs1.IndexVerifyProgress) {
lastp = p
select {
case <- tick.C:
default:
return
}
display(p)
}
if quiet { if quiet {
progress = nil progress = nil
} }
err := VerifyIndexFor(context.Background(), storPath, ntxn, progress) err := VerifyIndexFor(context.Background(), storPath, ntxn, progress)
if !quiet { if !quiet {
// (re-)display last update in case no progress was displayed so far
display(lastp)
fmt.Println() fmt.Println()
} }
if err != nil { if err != nil {
zt.Fatal(err) zt.Fatal(err)
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment