forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-18 01:43:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm: rename method for periodically updating gauges

Browse source
This commit is contained in:
Anton Evangelatov 2018-01-26 11:38:21 +02:00
parent 76dd62cb7f
commit e05e4cab48
1 changed files with 12 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
swarm/swarm.go
View file

@ -48,13 +48,13 @@ import (
) )
var ( var (
startTime time.Time startTime time.Time
metricsTimeout = 5 * time.Second updateGaugesPeriod = 5 * time.Second
startCounter = metrics.NewCounter("stack,start") startCounter = metrics.NewCounter("stack,start")
stopCounter = metrics.NewCounter("stack,stop") stopCounter = metrics.NewCounter("stack,stop")
uptimeGauge = metrics.NewGauge("stack.uptime") uptimeGauge = metrics.NewGauge("stack.uptime")
dbSizeGauge = metrics.NewGauge("storage.db.chunks.size") dbSizeGauge = metrics.NewGauge("storage.db.chunks.size")
cacheSizeGauge = metrics.NewGauge("storage.db.cache.size") cacheSizeGauge = metrics.NewGauge("storage.db.cache.size")
) )
// the swarm stack // the swarm stack
@ -319,24 +319,23 @@ func (self *Swarm) Start(srv *p2p.Server) error {
} }
} }
go self.metricsLoop() self.periodicallyUpdateGauges()
startCounter.Inc(1) startCounter.Inc(1)
return nil return nil
} }
// metricsLoop periodically sends metrics about storage func (self *Swarm) periodicallyUpdateGauges() {
func (self *Swarm) metricsLoop() { ticker := time.NewTicker(updateGaugesPeriod)
ticker := time.NewTicker(metricsTimeout)
go func() { go func() {
for _ = range ticker.C { for _ = range ticker.C {
self.sendMetrics() self.updateGauges()
} }
}() }()
} }
func (self *Swarm) sendMetrics() { func (self *Swarm) updateGauges() {
dbSizeGauge.Update(int64(self.lstore.DbCounter())) dbSizeGauge.Update(int64(self.lstore.DbCounter()))
cacheSizeGauge.Update(int64(self.lstore.CacheCounter())) cacheSizeGauge.Update(int64(self.lstore.CacheCounter()))
uptimeGauge.Update(time.Since(startTime).Nanoseconds()) uptimeGauge.Update(time.Since(startTime).Nanoseconds())