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

Revert "Removing CDR replication debug statements"

Browse Source 
This reverts commit d74784206b.
This commit is contained in:
DanB
2015-07-24 15:05:29 +02:00
parent 51cb6c388f
commit 3b2668b22c
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
engine/cdrs.go
View File

@@ -270,7 +270,9 @@ func (self *CdrServer) getCostFromRater(storedCdr *StoredCdr) (*CallCost, error)
DurationIndex: storedCdr.Usage,
}
if utils.IsSliceMember([]string{utils.META_PSEUDOPREPAID, utils.META_POSTPAID, utils.META_PREPAID, utils.PSEUDOPREPAID, utils.POSTPAID, utils.PREPAID}, storedCdr.ReqType) { // Prepaid - Cost can be recalculated in case of missing records from SM
//Logger.Debug(utils.ToJSON(cd))
if err = self.rater.Debit(cd, cc); err == nil { // Debit has occured, we are forced to write the log, even if CDR store is disabled
//Logger.Debug(utils.ToJSON(cc))
self.cdrDb.LogCallCost(storedCdr.CgrId, utils.CDRS_SOURCE, storedCdr.MediationRunId, cc)
}
} else {
@@ -314,7 +316,9 @@ func (self *CdrServer) rateCDR(storedCdr *StoredCdr) error {
// ToDo: Add websocket support
func (self *CdrServer) replicateCdr(cdr *StoredCdr) error {
Logger.Debug(fmt.Sprintf("replicateCdr cdr: %+v, configuration: %+v", cdr, self.cgrCfg.CDRSCdrReplication))
for _, rplCfg := range self.cgrCfg.CDRSCdrReplication {
Logger.Debug(fmt.Sprintf("Replicating CDR with configuration: %+v", rplCfg))
passesFilters := true
for _, cdfFltr := range rplCfg.CdrFilter {
if fltrPass, _ := cdr.PassesFieldFilter(cdfFltr); !fltrPass {