Resolve merge problems

This commit is contained in:
TeoV
2020-12-08 14:47:38 +02:00
committed by Dan Christian Bogos
parent 28c59978b9
commit 6f4161dbca
2 changed files with 5 additions and 1 deletions

View File

@@ -559,6 +559,7 @@ func main() {
utils.StatS: new(sync.WaitGroup),
utils.StorDB: new(sync.WaitGroup),
utils.ThresholdS: new(sync.WaitGroup),
utils.ActionS: new(sync.WaitGroup),
}
gvService := services.NewGlobalVarS(cfg, srvDep)
shdWg.Add(1)
@@ -672,6 +673,7 @@ func main() {
services.NewRateService(cfg, cacheS, filterSChan, dmService,
server, internalRateSChan, anz, srvDep),
services.NewSIPAgent(cfg, filterSChan, shdChan, connManager, srvDep),
services.NewActionService(cfg, dmService, cacheS, filterSChan, server, internalActionSChan, anz, srvDep),
)
srvManager.StartServices()
// Start FilterS

View File

@@ -37,7 +37,7 @@ import (
func NewActionService(cfg *config.CGRConfig, dm *DataDBService,
cacheS *engine.CacheS, filterSChan chan *engine.FilterS,
server *cores.Server, internalChan chan rpcclient.ClientConnector,
anz *AnalyzerService) servmanager.Service {
anz *AnalyzerService, srvDep map[string]*sync.WaitGroup) servmanager.Service {
return &ActionService{
connChan: internalChan,
cfg: cfg,
@@ -46,6 +46,7 @@ func NewActionService(cfg *config.CGRConfig, dm *DataDBService,
filterSChan: filterSChan,
server: server,
anz: anz,
srvDep: srvDep,
}
}
@@ -62,6 +63,7 @@ type ActionService struct {
rpc *v1.ActionSv1 // useful on restart
connChan chan rpcclient.ClientConnector // publish the internal Subsystem when available
anz *AnalyzerService
srvDep map[string]*sync.WaitGroup
}
// Start should handle the sercive start