From e590329321dc3c527bee5203cf5bfeb3a91a94b1 Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Fri, 27 Nov 2015 10:56:19 +0200 Subject: [PATCH] fixed stats calls --- apier/v1/apier.go | 3 ++- apier/v1/cdrstatsv1.go | 6 ++++-- engine/cdrs.go | 3 ++- 3 files changed, 8 insertions(+), 4 deletions(-) diff --git a/apier/v1/apier.go b/apier/v1/apier.go index 53b56fb46..78d3bf10f 100644 --- a/apier/v1/apier.go +++ b/apier/v1/apier.go @@ -1188,7 +1188,8 @@ func (self *ApierV1) LoadTariffPlanFromFolder(attrs utils.AttrLoadTpFromFolder, self.Sched.Restart() } if len(cstKeys) != 0 && self.CdrStatsSrv != nil { - if err := self.CdrStatsSrv.Call("CDRStatsV1.ReloadQueues", cstKeys, nil); err != nil { + var out int + if err := self.CdrStatsSrv.Call("CDRStatsV1.ReloadQueues", cstKeys, &out); err != nil { return err } } diff --git a/apier/v1/cdrstatsv1.go b/apier/v1/cdrstatsv1.go index a9bef703f..9820cfa68 100644 --- a/apier/v1/cdrstatsv1.go +++ b/apier/v1/cdrstatsv1.go @@ -55,7 +55,8 @@ func (sts *CDRStatsV1) GetQueueTriggers(id string, ats *engine.ActionTriggers) e } func (sts *CDRStatsV1) ReloadQueues(attr utils.AttrCDRStatsReloadQueues, reply *string) error { - if err := sts.CdrStats.Call("CDRStatsV1.ReloadQueues", attr.StatsQueueIds, nil); err != nil { + var out int + if err := sts.CdrStats.Call("CDRStatsV1.ReloadQueues", attr.StatsQueueIds, &out); err != nil { return err } *reply = utils.OK @@ -63,7 +64,8 @@ func (sts *CDRStatsV1) ReloadQueues(attr utils.AttrCDRStatsReloadQueues, reply * } func (sts *CDRStatsV1) ResetQueues(attr utils.AttrCDRStatsReloadQueues, reply *string) error { - if err := sts.CdrStats.Call("CDRStatsV1.ResetQueues", attr.StatsQueueIds, nil); err != nil { + var out int + if err := sts.CdrStats.Call("CDRStatsV1.ResetQueues", attr.StatsQueueIds, &out); err != nil { return err } *reply = utils.OK diff --git a/engine/cdrs.go b/engine/cdrs.go index 2d02a7fd1..39f576c35 100644 --- a/engine/cdrs.go +++ b/engine/cdrs.go @@ -255,7 +255,8 @@ func (self *CdrServer) rateStoreStatsReplicate(cdr *StoredCdr) error { } // Attach CDR to stats if self.stats != nil { // Send CDR to stats - if err := self.stats.Call("Stats.AppendCDR", cdr, nil); err != nil { + var out int + if err := self.stats.Call("CDRStatsV1.AppendCDR", cdr, &out); err != nil { utils.Logger.Err(fmt.Sprintf(" Could not append cdr to stats: %s", err.Error())) } }