uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-15 13:19:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

Updated cgr-loader. Fixes #1817

Browse Source
This commit is contained in:
Trial97
2019-12-13 11:56:13 +02:00
parent ae5f0319a1
commit 03f0d4bec1
1 changed files with 27 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
cmd/cgr-loader/cgr-loader.go
View File

@@ -101,6 +101,7 @@ var (
cacheSAddress = cgrLoaderFlags.String("caches_address", dfltCfg.LoaderCgrCfg().CachesConns[0],
"CacheS component to contact for cache reloads, empty to disable automatic cache reloads")
schedulerAddress = cgrLoaderFlags.String("scheduler_address", dfltCfg.LoaderCgrCfg().SchedulerConns[0], "")
rpcEncoding = cgrLoaderFlags.String("rpc_encoding", rpcclient.JSONrpc, "RPC encoding used <*gob|*json>")
)
func main() {
@@ -196,18 +197,36 @@ func main() {
}
if *cacheSAddress != dfltCfg.LoaderCgrCfg().CachesConns[0] {
ldrCfg.LoaderCgrCfg().CachesConns = make([]string, 0)
if *cacheSAddress != "" {
ldrCfg.LoaderCgrCfg().CachesConns = append(ldrCfg.LoaderCgrCfg().CachesConns,
*cacheSAddress)
if *cacheSAddress == utils.EmptyString {
ldrCfg.LoaderCgrCfg().CachesConns = []string{}
} else {
ldrCfg.LoaderCgrCfg().CachesConns = []string{*cacheSAddress}
if _, has := ldrCfg.RPCConns()[*cacheSAddress]; !has {
ldrCfg.RPCConns()[*cacheSAddress] = &config.RPCConn{
Strategy: rpcclient.PoolFirst,
Conns: []*config.RemoteHost{{
Address: *cacheSAddress,
Transport: *rpcEncoding,
}},
}
}
}
}
if *schedulerAddress != dfltCfg.LoaderCgrCfg().SchedulerConns[0] {
ldrCfg.LoaderCgrCfg().SchedulerConns = make([]string, 0)
if *schedulerAddress != "" {
ldrCfg.LoaderCgrCfg().SchedulerConns = append(ldrCfg.LoaderCgrCfg().SchedulerConns,
*schedulerAddress)
if *schedulerAddress == utils.EmptyString {
ldrCfg.LoaderCgrCfg().SchedulerConns = []string{}
} else {
ldrCfg.LoaderCgrCfg().SchedulerConns = []string{*schedulerAddress}
if _, has := ldrCfg.RPCConns()[*schedulerAddress]; !has {
ldrCfg.RPCConns()[*schedulerAddress] = &config.RPCConn{
Strategy: rpcclient.PoolFirst,
Conns: []*config.RemoteHost{{
Address: *schedulerAddress,
Transport: *rpcEncoding,
}},
}
}
}
}