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

Updated cgr-engine to start RPC before precaching is done

Browse Source
This commit is contained in:
Trial97
2019-08-06 14:18:08 +03:00
committed by Dan Christian Bogos
parent 8b0cef1b93
commit f75d4ebda3
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1335,7 +1335,7 @@ func startRpc(server *utils.Server, internalRaterChan,
internalCdrSChan, internalRsChan, internalStatSChan,
internalAttrSChan, internalChargerSChan, internalThdSChan, internalSuplSChan,
internalSMGChan, internalAnalyzerSChan, internalDispatcherSChan,
internalLoaderSChan, internalRALsv1Chan chan rpcclient.RpcClientConnection,
internalLoaderSChan, internalRALsv1Chan, internalCacheSChan chan rpcclient.RpcClientConnection,
exitChan chan bool) {
if !cfg.DispatcherSCfg().Enabled {
select { // Any of the rpc methods will unlock listening to rpc requests
@@ -1363,6 +1363,8 @@ func startRpc(server *utils.Server, internalRaterChan,
internalLoaderSChan <- loaderS
case ralS := <-internalRALsv1Chan:
internalRALsv1Chan <- ralS
case chS := <-internalCacheSChan: // added in order to start the RPC before precaching is done
internalCacheSChan <- chS
}
} else {
select {
@@ -1846,7 +1848,7 @@ func main() {
internalRsChan, internalStatSChan,
internalAttributeSChan, internalChargerSChan, internalThresholdSChan,
internalSupplierSChan, internalSMGChan, internalAnalyzerSChan,
internalDispatcherSChan, internalLoaderSChan, internalRALsv1Chan, exitChan)
internalDispatcherSChan, internalLoaderSChan, internalRALsv1Chan, internalCacheSChan, exitChan)
<-exitChan
if *cpuProfDir != "" { // wait to end cpuProfiling