upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

StateSync: Add missing mutex for sync counter map

Browse source
This commit is contained in:
Noah Hilverling 2019-10-08 12:30:55 +02:00
parent 7e48515382
commit 68ba73d761
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
configobject/statesync/statesync.go
View file

@ -7,11 +7,13 @@ import (
"github.com/go-redis/redis"
"github.com/prometheus/client_golang/prometheus"
log "github.com/sirupsen/logrus"
"sync"
"time"
)
//Counter on how many host/service states have synced since the last logSyncCounters()
var syncCounter = make(map[string]int)
var syncCounterLock = sync.Mutex{}
var mysqlObservers = func() (mysqlObservers map[string]prometheus.Observer) {
mysqlObservers = map[string]prometheus.Observer{}
@ -48,7 +50,9 @@ func logSyncCounters() {
for {
<-every20s.C
log.Infof("Synced %d host and %d service states in the last 20 seconds", syncCounter["host"], syncCounter["service"])
syncCounterLock.Lock()
syncCounter = make(map[string]int)
syncCounterLock.Unlock()
}
}
@ -159,7 +163,9 @@ func syncStates(super *supervisor.Supervisor, objectType string) {
log.Debugf("%d %s state synced", len(storedStateIds) - brokenStates, objectType)
log.Debugf("%d %s state broken", brokenStates, objectType)
syncCounterLock.Lock()
syncCounter[objectType] += len(storedStateIds)
syncCounterLock.Unlock()
StateSyncsTotal.WithLabelValues(objectType).Add(float64(len(storedStateIds)))
}