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

Make engine wait for precache

Browse Source
This commit is contained in:
TeoV
2019-04-02 15:26:01 +03:00
committed by Dan Christian Bogos
parent cebb43a6c0
commit a6cda0bd60
2 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -617,6 +617,7 @@ func startAttributeService(internalAttributeSChan chan rpcclient.RpcClientConnec
filterS := <-filterSChan
filterSChan <- filterS
<-cacheS.GetPrecacheChannel(utils.CacheAttributeProfiles)
<-cacheS.GetPrecacheChannel(utils.CacheAttributeFilterIndexes)
aS, err := engine.NewAttributeService(dm, filterS,
cfg.AttributeSCfg().StringIndexedFields,
@@ -652,6 +653,7 @@ func startChargerService(internalChargerSChan chan rpcclient.RpcClientConnection
filterS := <-filterSChan
filterSChan <- filterS
<-cacheS.GetPrecacheChannel(utils.CacheChargerProfiles)
<-cacheS.GetPrecacheChannel(utils.CacheChargerFilterIndexes)
var attrSConn *rpcclient.RpcClientPool
var err error
if len(cfg.ChargerSCfg().AttributeSConns) != 0 { // AttributeS connection init
@@ -715,6 +717,7 @@ func startResourceService(internalRsChan chan rpcclient.RpcClientConnection, cac
}
<-cacheS.GetPrecacheChannel(utils.CacheResourceProfiles)
<-cacheS.GetPrecacheChannel(utils.CacheResources)
<-cacheS.GetPrecacheChannel(utils.CacheResourceFilterIndexes)
rS, err := engine.NewResourceService(dm, cfg.ResourceSCfg().StoreInterval,
thdSConn, filterS, cfg.ResourceSCfg().StringIndexedFields, cfg.ResourceSCfg().PrefixIndexedFields)
@@ -762,6 +765,7 @@ func startStatService(internalStatSChan chan rpcclient.RpcClientConnection, cach
}
<-cacheS.GetPrecacheChannel(utils.CacheStatQueueProfiles)
<-cacheS.GetPrecacheChannel(utils.CacheStatQueues)
<-cacheS.GetPrecacheChannel(utils.CacheStatFilterIndexes)
sS, err := engine.NewStatService(dm, cfg.StatSCfg().StoreInterval,
thdSConn, filterS, cfg.StatSCfg().StringIndexedFields, cfg.StatSCfg().PrefixIndexedFields)
@@ -792,6 +796,7 @@ func startThresholdService(internalThresholdSChan chan rpcclient.RpcClientConnec
filterSChan <- filterS
<-cacheS.GetPrecacheChannel(utils.CacheThresholdProfiles)
<-cacheS.GetPrecacheChannel(utils.CacheThresholds)
<-cacheS.GetPrecacheChannel(utils.CacheThresholdFilterIndexes)
tS, err := engine.NewThresholdService(dm, cfg.ThresholdSCfg().StringIndexedFields,
cfg.ThresholdSCfg().PrefixIndexedFields, cfg.ThresholdSCfg().StoreInterval, filterS)
@@ -870,6 +875,7 @@ func startSupplierService(internalSupplierSChan chan rpcclient.RpcClientConnecti
}
}
<-cacheS.GetPrecacheChannel(utils.CacheSupplierProfiles)
<-cacheS.GetPrecacheChannel(utils.CacheSupplierFilterIndexes)
splS, err := engine.NewSupplierService(dm, cfg.GeneralCfg().DefaultTimezone,
filterS, cfg.SupplierSCfg().StringIndexedFields,
@@ -929,6 +935,7 @@ func startDispatcherService(internalDispatcherSChan chan *dispatchers.Dispatcher
filterSChan <- fltrS
<-cacheS.GetPrecacheChannel(utils.CacheDispatcherProfiles)
<-cacheS.GetPrecacheChannel(utils.CacheDispatcherHosts)
<-cacheS.GetPrecacheChannel(utils.CacheDispatcherFilterIndexes)
var err error
var attrSConn *rpcclient.RpcClientPool

1
cmd/cgr-engine/rater.go
View File

@@ -55,6 +55,7 @@ func startRater(internalRaterChan chan rpcclient.RpcClientConnection, cacheS *en
<-chS.GetPrecacheChannel(utils.CacheAccountActionPlans)
<-chS.GetPrecacheChannel(utils.CacheActionTriggers)
<-chS.GetPrecacheChannel(utils.CacheSharedGroups)
<-chS.GetPrecacheChannel(utils.CacheTimings)
}()
var thdS *rpcclient.RpcClientPool