scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-10 07:01:01 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

timed progress

Browse source
This commit is contained in:
Jason E. Aten 2020-10-29 01:12:19 +00:00
parent 509348260f
commit 85fc785296
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
txfactory.go
View file

@ -25,6 +25,7 @@ import (
"sync"
"syscall"
"text/tabwriter"
"time"
"github.com/pilosa/pilosa/v2/hash"
"github.com/pilosa/pilosa/v2/rbf"
@ -1345,6 +1346,7 @@ func (f *TxFactory) green2blue(holder *Holder) (err error) {
}
}
lastProgress := time.Now()
progressCount := 0
for shard := range greenShards {
@ -1365,9 +1367,11 @@ func (f *TxFactory) green2blue(holder *Holder) (err error) {
} else {
// the main copy work
progressCount++
holder.Logger.Printf("migration progress on index '%v' (%v of %v): on shard %v of %v",
k+1, len(idxs), idx.name, progressCount, len(greenShards))
if progressCount == 1 || time.Since(lastProgress) > time.Second {
holder.Logger.Printf("migration progress on index '%v' (%v of %v): on shard %v of %v",
idx.name, k+1, len(idxs), progressCount, len(greenShards))
lastProgress = time.Now()
}
err = dbs.populateBlueFromGreen()
if err != nil {
return errors.Wrap(err,