SessionS v2ForkSessions using ChargerS

This commit is contained in:
DanB
2018-08-29 13:40:35 +02:00
parent 3a6ebb88ad
commit f079d6f3dc
4 changed files with 134 additions and 368 deletions

View File

@@ -688,7 +688,7 @@ func (cdrS *CdrServer) statSProcessEvent(cgrEv *utils.CGREvent) {
// rarethsta will RAte/STOtore/REplicate/THresholds/STAts the CDR received
// used by both chargerS as well as re-/rating
func (cdrS *CdrServer) rastorethstaCDR(cdr *CDR) {
func (cdrS *CdrServer) raStoReThStaCDR(cdr *CDR) {
ratedCDRs, err := cdrS.rateCDR(cdr)
if err != nil {
utils.Logger.Warning(
@@ -737,7 +737,7 @@ func (cdrS *CdrServer) chrgrSProcessEvent(cgrEv *utils.CGREvent) {
utils.CDRs, err.Error(), cgrEv, utils.ChargerS))
continue
}
cdrS.rastorethstaCDR(cdr)
cdrS.raStoReThStaCDR(cdr)
}
}
@@ -787,7 +787,7 @@ func (cdrS *CdrServer) V2RateCDRs(attrs *utils.RPCCDRsFilter, reply *string) err
return err
}
for _, cdr := range cdrs {
go cdrS.rastorethstaCDR(cdr)
go cdrS.raStoReThStaCDR(cdr)
}
*reply = utils.OK
return nil