This commit is contained in:
DanB
2014-08-01 20:01:43 +02:00
2 changed files with 3 additions and 3 deletions

View File

@@ -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 {

View File

@@ -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 {