diff --git a/engine/stats.go b/engine/stats.go index 03e4ba5a9..9413ced14 100644 --- a/engine/stats.go +++ b/engine/stats.go @@ -108,7 +108,7 @@ func (s *Stats) ReloadQueues(ids []string, out *int) error { func (s *Stats) ResetQueues(ids []string, out *int) error { if ids == nil { for _, sq := range s.queues { - sq.cdrs = make([]*QCdr, sq.conf.QueueLength) + sq.cdrs = make([]*QCdr, 0) sq.metrics = make(map[string]Metric, len(sq.conf.Metrics)) for _, m := range sq.conf.Metrics { if metric := CreateMetric(m); metric != nil { @@ -123,7 +123,7 @@ func (s *Stats) ResetQueues(ids []string, out *int) error { Logger.Warning(fmt.Sprintf("Cannot reset queue id %v: Not Fund", id)) continue } - sq.cdrs = make([]*QCdr, sq.conf.QueueLength) + sq.cdrs = make([]*QCdr, 0) sq.metrics = make(map[string]Metric, len(sq.conf.Metrics)) for _, m := range sq.conf.Metrics { if metric := CreateMetric(m); metric != nil { diff --git a/engine/stats_queue.go b/engine/stats_queue.go index fce96c1fd..ec308843d 100644 --- a/engine/stats_queue.go +++ b/engine/stats_queue.go @@ -54,7 +54,7 @@ func (sq *StatsQueue) UpdateConf(conf *CdrStats) { sq.mux.Lock() defer sq.mux.Unlock() sq.conf = conf - sq.cdrs = make([]*QCdr, conf.QueueLength) + sq.cdrs = make([]*QCdr, 0) sq.metrics = make(map[string]Metric, len(conf.Metrics)) for _, m := range conf.Metrics { if metric := CreateMetric(m); metric != nil {