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

Fix cdrsConn for SMG in engine

Browse Source
This commit is contained in:
DanB
2016-01-06 19:48:55 +01:00
parent 04fb413cd4
commit c122d4e74a
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -138,8 +138,8 @@ func startCdrc(internalCdrSChan chan *engine.CdrServer, internalRaterChan chan *
func startSmGeneric(internalSMGChan chan rpcclient.RpcClientConnection, internalRaterChan chan *engine.Responder, internalCDRSChan chan *engine.CdrServer, server *utils.Server, exitChan chan bool) {
utils.Logger.Info("Starting CGRateS SM-Generic service.")
raterConn := rpcclient.NewRpcClientPool(rpcclient.POOL_BROADCAST)
cdrsConn := rpcclient.NewRpcClientPool(rpcclient.POOL_BROADCAST)
raterConn := rpcclient.NewRpcClientPool(rpcclient.POOL_FIRST)
cdrsConn := rpcclient.NewRpcClientPool(rpcclient.POOL_FIRST)
var client *rpcclient.RpcClient
var err error
// Connect to rater
@@ -253,9 +253,7 @@ func startSmFreeSWITCH(internalRaterChan chan *engine.Responder, internalCDRSCha
}
}
// Connect to CDRS
if reflect.DeepEqual(cfg.SmFsConfig.CdrsConns, cfg.SmFsConfig.RaterConns) {
cdrsConn = raterConn
} else if len(cfg.SmFsConfig.CdrsConns) != 0 {
if len(cfg.SmFsConfig.CdrsConns) != 0 {
for _, cdrsCfg := range cfg.SmFsConfig.CdrsConns {
if cdrsCfg.Server == utils.INTERNAL {
resp := <-internalCDRSChan