fix waitgroup

This commit is contained in:
Matthew R. Kasun
2022-07-12 05:37:51 -04:00
parent 1fa4becb48
commit 23c3b0c276

View File

@@ -30,6 +30,7 @@ import (
) )
var messageCache = new(sync.Map) var messageCache = new(sync.Map)
var serverSet map[string]bool var serverSet map[string]bool
const lastNodeUpdate = "lnu" const lastNodeUpdate = "lnu"
@@ -103,6 +104,7 @@ func startGoRoutines(wg *sync.WaitGroup) context.CancelFunc {
// == subscribe to all nodes for each on machine == // == subscribe to all nodes for each on machine ==
serverSet[server] = true serverSet[server] = true
logger.Log(1, "started daemon for server ", server) logger.Log(1, "started daemon for server ", server)
wg.Add(1)
go messageQueue(ctx, wg, &cfg) go messageQueue(ctx, wg, &cfg)
} }
} }