upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-06-08 16:34:29 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

Fix context startup

Browse source
This commit is contained in:
Jean Flach 2019-03-20 11:31:34 +01:00
parent 73dbb86426
commit 76ae76c367
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
main.go
View file

@ -51,9 +51,9 @@ func main() {
go icingadb_json_decoder.DecodePool(super.ChDecode, super.ChErr, 16)
chHA := ha.RegisterNotificationListener()
chHAHost := ha.RegisterNotificationListener()
go func() {
super.ChErr <- sync.Operator(&super, chHA, &sync.Context{
super.ChErr <- sync.Operator(&super, chHAHost, &sync.Context{
ObjectType: "host",
Factory: host.NewHost,
InsertStmt: host.BulkInsertStmt,
@ -62,10 +62,10 @@ func main() {
})
}()
chHAService := ha.RegisterNotificationListener()
go func() {
chHA := ha.RegisterNotificationListener()
super.ChErr <- sync.Operator(&super, chHA, &sync.Context{
super.ChErr <- sync.Operator(&super, chHAService, &sync.Context{
ObjectType: "service",
Factory: service.NewService,
InsertStmt: service.BulkInsertStmt,