RanchiMall/blockbook
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Randomize period of ComputeInternalStateColumnStats to avoid CPU peaks

Browse Source
This commit is contained in:
Martin Boehm 2018-06-12 21:23:34 +02:00
parent c723ba92e5
commit a4e5418f50
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
blockbook.go
View File

@ -4,6 +4,7 @@ import (
"context" "context"
"flag" "flag"
"log" "log"
"math/rand"
"os" "os"
"os/signal" "os/signal"
"strings" "strings"
@ -123,6 +124,8 @@ func main() {
defer glog.Flush() defer glog.Flush()
rand.Seed(time.Now().UTC().UnixNano())
chanOsSignal = make(chan os.Signal, 1) chanOsSignal = make(chan os.Signal, 1)
signal.Notify(chanOsSignal, syscall.SIGHUP, syscall.SIGINT, syscall.SIGQUIT, syscall.SIGTERM) signal.Notify(chanOsSignal, syscall.SIGHUP, syscall.SIGINT, syscall.SIGQUIT, syscall.SIGTERM)
@ -417,11 +420,13 @@ func storeInternalStateLoop() {
close(stopCompute) close(stopCompute)
close(chanStoreInternalStateDone) close(chanStoreInternalStateDone)
}() }()
glog.Info("storeInternalStateLoop starting")
lastCompute := time.Now()
var computeRunning bool var computeRunning bool
lastCompute := time.Now()
// randomize the duration between ComputeInternalStateColumnStats to avoid peeks after reboot of machine with multiple blockbooks
computePeriod := 9*time.Hour + time.Duration(rand.Float64()*float64((2*time.Hour).Nanoseconds()))
glog.Info("storeInternalStateLoop starting with internal state compute period ", computePeriod)
tickAndDebounce(storeInternalStatePeriodMs*time.Millisecond, (storeInternalStatePeriodMs-1)*time.Millisecond, chanStoreInternalState, func() { tickAndDebounce(storeInternalStatePeriodMs*time.Millisecond, (storeInternalStatePeriodMs-1)*time.Millisecond, chanStoreInternalState, func() {
if !computeRunning && lastCompute.Add(10*time.Hour).Before(time.Now()) { if !computeRunning && lastCompute.Add(computePeriod).Before(time.Now()) {
computeRunning = true computeRunning = true
go func() { go func() {
err := index.ComputeInternalStateColumnStats(stopCompute) err := index.ComputeInternalStateColumnStats(stopCompute)