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

Fix env

Browse source
This commit is contained in:
Noah Hilverling 2019-03-22 15:27:03 +01:00
parent cf6da447d9
commit f8bfc79f13
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
configobject/configsync/configsync.go
View file

@ -35,8 +35,8 @@ type Checksums struct {
// connection information and other control mechanisms, a channel chHA, which informs the Operator of the current HA
// state, and a Context reference ctx defining the type and providing the necessary factories.
func Operator(super *supervisor.Supervisor, chHA chan int, ctx *Context) error {
insert, update, delete := GetDelta(super, ctx)
log.Infof("%s - Delta: (Insert: %d, Maybe Update: %d, Delete: %d)", ctx.ObjectType, len(insert), len(update), len(delete))
//insert, update, delete := GetDelta(super, ctx)
//log.Infof("%s - Delta: (Insert: %d, Maybe Update: %d, Delete: %d)", ctx.ObjectType, len(insert), len(update), len(delete))
var (
// If this IcingaDB-Instance looses responsibility, this channel will be
@ -78,7 +78,7 @@ func Operator(super *supervisor.Supervisor, chHA chan int, ctx *Context) error {
log.Infof("%s: Got responsibility", ctx.ObjectType)
//TODO: This should only be done, if HA was taken over from another instance
insert, update, delete = GetDelta(super, ctx)
insert, update, delete := GetDelta(super, ctx)
log.Infof("%s - Delta: (Insert: %d, Maybe Update: %d, Delete: %d)", ctx.ObjectType, len(insert), len(update), len(delete))
// Clean up all channels and wait groups for a fresh config dump