From cdac60015867bb718217589158b080c9ae074e9e Mon Sep 17 00:00:00 2001 From: DanB Date: Tue, 20 Feb 2018 15:54:50 +0100 Subject: [PATCH] CDRS attempt compressing the timestaps before storing costs to StorDB --- engine/cdrs.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/engine/cdrs.go b/engine/cdrs.go index a2a5591f3..5e8df8783 100644 --- a/engine/cdrs.go +++ b/engine/cdrs.go @@ -289,6 +289,7 @@ func (self *CdrServer) deriveRateStoreStatsReplicate(cdr *CDR, store, cdrstats, if ratedCDR.CostDetails != nil { ratedCDR.CostDetails.UpdateCost() ratedCDR.CostDetails.UpdateRatedUsage() + ratedCDR.CostDetails.Timespans.Compress() } if err := self.cdrDb.SetCDR(ratedCDR, true); err != nil { utils.Logger.Err(fmt.Sprintf(" Storing rated CDR %+v, got error: %s", ratedCDR, err.Error())) @@ -503,7 +504,7 @@ func (self *CdrServer) replicateCDRs(cdrs []*CDR) (err error) { continue } if err = cdre.ExportCDRs(); err != nil { - utils.Logger.Err(fmt.Sprintf(" Replicating CDR: %+v, got error: <%s>",cdrs, err.Error())) + utils.Logger.Err(fmt.Sprintf(" Replicating CDR: %+v, got error: <%s>", cdrs, err.Error())) continue } } @@ -595,6 +596,7 @@ func (cdrs *CdrServer) V2StoreSMCost(args ArgsV2CDRSStoreSMCost, reply *string) utils.Logger.Err(fmt.Sprintf(" RefundRounding for cc: %+v, got error: %s", cc, err.Error())) } } + cc.Timespans.Compress() // Compress increments before storing the cost if err := cdrs.storeSMCost(&SMCost{ CGRID: args.Cost.CGRID, RunID: args.Cost.RunID,