From f75d4ebda3ad55481f3f8847749f42114b2ab3e8 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Tue, 6 Aug 2019 14:18:08 +0300 Subject: [PATCH] Updated cgr-engine to start RPC before precaching is done --- cmd/cgr-engine/cgr-engine.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/cmd/cgr-engine/cgr-engine.go b/cmd/cgr-engine/cgr-engine.go index 543a6dbbd..e59c69570 100644 --- a/cmd/cgr-engine/cgr-engine.go +++ b/cmd/cgr-engine/cgr-engine.go @@ -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