LBRYCommunity/lbcd
1
0
Fork 0
Code Issues17 Pull requests4 Projects Releases28 Packages Wiki Activity

[lbry] cli: minor refactoring stats report

Browse source
This commit is contained in:
Roy Lee 2021-08-03 11:53:07 -07:00
parent 2ead2539c0
commit 26a4ffe2e3
1 changed files with 13 additions and 7 deletions

20
claimtrie/cmd/cmd/chain.go
View file

@ -234,6 +234,7 @@ func NewChainConvertCommand() *cobra.Command {
blockChan: make(chan *btcutil.Block, 1000), blockChan: make(chan *btcutil.Block, 1000),
changesChan: make(chan []change.Change, 1000), changesChan: make(chan []change.Change, 1000),
wg: &sync.WaitGroup{}, wg: &sync.WaitGroup{},
stat: &stat{},
} }
startTime := time.Now() startTime := time.Now()
@ -254,6 +255,12 @@ func NewChainConvertCommand() *cobra.Command {
return cmd return cmd
} }
type stat struct {
blocksFetched int
blocksProcessed int
changesSaved int
}
type chainConverter struct { type chainConverter struct {
db database.DB db database.DB
chain *blockchain.BlockChain chain *blockchain.BlockChain
@ -263,9 +270,7 @@ type chainConverter struct {
wg *sync.WaitGroup wg *sync.WaitGroup
statBlocksFetched int stat *stat
statBlocksProcessed int
statChangesSaved int
} }
func (cc *chainConverter) wait() { func (cc *chainConverter) wait() {
@ -302,7 +307,7 @@ func (cb *chainConverter) getBlock() {
log.Errorf("load changes from repo: %w", err) log.Errorf("load changes from repo: %w", err)
return return
} }
cb.statBlocksFetched++ cb.stat.blocksFetched++
cb.blockChan <- block cb.blockChan <- block
} }
} }
@ -385,7 +390,7 @@ func (cb *chainConverter) processBlock() {
changes = append(changes, chg) changes = append(changes, chg)
} }
} }
cb.statBlocksProcessed++ cb.stat.blocksProcessed++
if len(changes) != 0 { if len(changes) != 0 {
cb.changesChan <- changes cb.changesChan <- changes
@ -410,15 +415,16 @@ func (cb *chainConverter) saveChanges() {
log.Errorf("save to chain repo: %s", err) log.Errorf("save to chain repo: %s", err)
return return
} }
cb.statChangesSaved++ cb.stat.changesSaved++
} }
} }
func (cb *chainConverter) reportStats() { func (cb *chainConverter) reportStats() {
stat := cb.stat
tick := time.NewTicker(5 * time.Second) tick := time.NewTicker(5 * time.Second)
for range tick.C { for range tick.C {
log.Infof("block : %7d / %7d, changes saved: %d", log.Infof("block : %7d / %7d, changes saved: %d",
cb.statBlocksFetched, cb.statBlocksProcessed, cb.statChangesSaved) stat.blocksFetched, stat.blocksProcessed, stat.changesSaved)
} }
} }