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

Updated RALs config

Browse Source
This commit is contained in:
Trial97
2019-09-23 17:41:15 +03:00
committed by Dan Christian Bogos
parent e4abc4ea07
commit c821828d93
5 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/cgr-engine/cgr-engine.go
View File

@@ -1144,7 +1144,7 @@ func main() {
}
}
}
if cfg.RalsCfg().Enabled || cfg.CdrsCfg().CDRSEnabled {
if cfg.RalsCfg().Enabled || cfg.CdrsCfg().Enabled {
storDb, err := engine.ConfigureStorStorage(cfg.StorDbCfg().StorDBType,
cfg.StorDbCfg().StorDBHost, cfg.StorDbCfg().StorDBPort,
cfg.StorDbCfg().StorDBName, cfg.StorDbCfg().StorDBUser,

2
config/config_it_test.go
View File

@@ -281,7 +281,7 @@ func TestCGRConfigReloadCDRs(t *testing.T) {
if err != nil {
t.Fatal(err)
}
cfg.RalsCfg().RALsEnabled = true
cfg.RalsCfg().Enabled = true
var reply string
if err = cfg.V1ReloadConfig(&ConfigReloadWithArgDispatcher{
Path: path.Join("/usr", "share", "cgrates", "conf", "samples", "tutmongo2"),

2
services/cdrs_it_test.go
View File

@@ -58,7 +58,7 @@ func TestCdrsReload(t *testing.T) {
close(chS.GetPrecacheChannel(utils.CacheTimings))
cfg.ChargerSCfg().Enabled = true
cfg.RalsCfg().RALsEnabled = true
cfg.RalsCfg().Enabled = true
cacheSChan := make(chan rpcclient.RpcClientConnection, 1)
cacheSChan <- chS
server := utils.NewServer()

6
services/responders.go
View File

@@ -50,12 +50,12 @@ func (resp *ResponderService) Start(sp servmanager.ServiceProvider, waitCache bo
}
var thdS, stats rpcclient.RpcClientConnection
if thdS, err = sp.GetConnection(utils.ThresholdS, sp.GetConfig().RalsCfg().RALsThresholdSConns); err != nil {
if thdS, err = sp.GetConnection(utils.ThresholdS, sp.GetConfig().RalsCfg().ThresholdSConns); err != nil {
utils.Logger.Crit(fmt.Sprintf("<%s> Could not connect to %s, error: %s",
utils.RALService, utils.ThresholdS, err.Error()))
return
}
if stats, err = sp.GetConnection(utils.StatS, sp.GetConfig().RalsCfg().RALsStatSConns); err != nil {
if stats, err = sp.GetConnection(utils.StatS, sp.GetConfig().RalsCfg().StatSConns); err != nil {
utils.Logger.Crit(fmt.Sprintf("<%s> Could not connect to %s, error: %s",
utils.RALService, utils.StatS, err.Error()))
return
@@ -70,7 +70,7 @@ func (resp *ResponderService) Start(sp servmanager.ServiceProvider, waitCache bo
defer resp.Unlock()
resp.resp = &engine.Responder{
ExitChan: sp.GetExitChan(),
MaxComputedUsage: sp.GetConfig().RalsCfg().RALsMaxComputedUsage,
MaxComputedUsage: sp.GetConfig().RalsCfg().MaxComputedUsage,
}
if !sp.GetConfig().DispatcherSCfg().Enabled {

4
servmanager/servmanager.go
View File

@@ -271,7 +271,7 @@ func (srvMngr *ServiceManager) StartServices() (err error) {
if srvMngr.GetConfig().CdrsCfg().Enabled {
go srvMngr.startService(utils.CDRServer)
}
if srvMngr.GetConfig().RalsCfg().RALsEnabled {
if srvMngr.GetConfig().RalsCfg().Enabled {
go srvMngr.startService(utils.RALService)
}
// startServer()
@@ -330,7 +330,7 @@ func (srvMngr *ServiceManager) handleReload() {
return
}
case <-srvMngr.GetConfig().GetReloadChan(config.RALS_JSN):
if err = srvMngr.reloadService(utils.RALService, srvMngr.GetConfig().RalsCfg().RALsEnabled); err != nil {
if err = srvMngr.reloadService(utils.RALService, srvMngr.GetConfig().RalsCfg().Enabled); err != nil {
return
}
}