cerc-io/go-ethereum
13
0
Fork 0
Code Issues 9 Pull Requests Packages Projects Releases 66 Wiki Activity

fix update prometheus statediff block height #48

Closed
ramilexe wants to merge 1 commits from prom_statediff_block_height_fix into v1.9.24-statediff
pull from: prom_statediff_block_height_fix
merge into: cerc-io:v1.9.24-statediff
Conversation 0 Commits 1 Files Changed 1 +4 -2
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
statediff/service.go
View File

@ -273,8 +273,10 @@ func (sds *Service) writeLoopWorker(params workerParams) {
log.Error("statediff.Service.WriteLoop: processing error", "block height", currentBlock.Number().Uint64(), "error", err.Error(), "worker", params.id)
continue
}
// TODO: how to handle with concurrent workers
statediffMetrics.lastStatediffHeight.Update(int64(currentBlock.Number().Uint64()))
lastStatediffHeight := statediffMetrics.lastStatediffHeight.Value()
if currentBlock.Number().Uint64() > uint64(lastStatediffHeight) {
statediffMetrics.lastStatediffHeight.Update(int64(currentBlock.Number().Uint64()))
}
case err := <-params.errCh:
log.Warn("Error from chain event subscription", "error", err, "worker", params.id)
sds.close()