uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 10:06:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Added filtered replication for dataDB items

Browse Source
This commit is contained in:
Trial97
2021-03-04 13:45:15 +02:00
committed by Dan Christian Bogos
parent 5cc52cb490
commit 7e90a42c1f
44 changed files with 683 additions and 522 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
servmanager/servmanager.go
View File

@@ -32,12 +32,13 @@ import (
)
// NewServiceManager returns a service manager
func NewServiceManager(cfg *config.CGRConfig, shdChan *utils.SyncedChan, shdWg *sync.WaitGroup) *ServiceManager {
func NewServiceManager(cfg *config.CGRConfig, shdChan *utils.SyncedChan, shdWg *sync.WaitGroup, connMgr *engine.ConnManager) *ServiceManager {
sm := &ServiceManager{
cfg: cfg,
subsystems: make(map[string]Service),
shdChan: shdChan,
shdWg: shdWg,
connMgr: connMgr,
}
return sm
}
@@ -50,6 +51,7 @@ type ServiceManager struct {
shdChan *utils.SyncedChan
shdWg *sync.WaitGroup
connMgr *engine.ConnManager
}
// Call .
@@ -240,7 +242,7 @@ func (srvMngr *ServiceManager) handleReload() {
case <-srvMngr.GetConfig().GetReloadChan(config.RateSJson):
go srvMngr.reloadService(utils.RateS)
case <-srvMngr.GetConfig().GetReloadChan(config.RPCConnsJsonName):
engine.Cache.Clear([]string{utils.CacheRPCConnections})
go srvMngr.connMgr.Reload()
case <-srvMngr.GetConfig().GetReloadChan(config.SIPAgentJson):
go srvMngr.reloadService(utils.SIPAgent)
case <-srvMngr.GetConfig().GetReloadChan(config.RegistrarCJson):