uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-20 22:58:44 +05:00
Code Issues Packages Projects Releases Wiki Activity

another cdrstats purge fix

Browse Source
This commit is contained in:
Radu Ioan Fericean
2016-04-04 21:43:37 +03:00
parent 28f409934c
commit c85f3bdf23
2 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
engine/stats_queue.go
View File

@@ -184,19 +184,21 @@ func (sq *StatsQueue) purgeObsoleteCdrs() {
}
}
if sq.conf.TimeWindow > 0 {
var index int
index := -1
for i, cdr := range sq.Cdrs {
if time.Now().Sub(cdr.SetupTime) > sq.conf.TimeWindow {
sq.removeFromMetrics(cdr)
index = i
continue
}
index = i
break
}
if index > 0 {
sq.Cdrs = sq.Cdrs[index:]
} else {
sq.Cdrs = make([]*QCdr, 0)
if index != -1 {
if index > 0 {
sq.Cdrs = sq.Cdrs[index:]
} else {
sq.Cdrs = make([]*QCdr, 0)
}
}
}
}

2
engine/stats_test.go
View File

@@ -227,7 +227,7 @@ func TestStatsAppendCdr(t *testing.T) {
if len(cdrStats.queues) != 2 ||
len(cdrStats.queues["CDRST1"].Cdrs) != 0 ||
len(cdrStats.queues["CDRST2"].Cdrs) != 1 {
t.Error("Error appending cdr to queue: ", len(cdrStats.queues))
t.Error("Error appending cdr to queue: ", utils.ToIJSON(cdrStats.queues))
}
}