uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-17 06:09:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

fixed stats calls

Browse Source
This commit is contained in:
Radu Ioan Fericean
2015-11-27 10:56:19 +02:00
parent 83dcafaa66
commit e590329321
3 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
apier/v1/apier.go
View File

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

6
apier/v1/cdrstatsv1.go
View File

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

3
engine/cdrs.go
View File

@@ -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("<CDRS> Could not append cdr to stats: %s", err.Error()))
}
}