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

added response cache for loggcallcost

Browse Source
This commit is contained in:
Radu Ioan Fericean
2015-07-20 12:23:09 +03:00
parent a7cf099c5c
commit 152debdc77
1 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
engine/responder.go
View File

@@ -45,6 +45,7 @@ var (
maxDebitResponseCache = cache2go.NewResponseCache(5 * time.Second)
refundIncrementsResponseCache = cache2go.NewResponseCache(5 * time.Second)
getSessionRunsResponseCache = cache2go.NewResponseCache(5 * time.Second)
logCallCostResponseCache = cache2go.NewResponseCache(5 * time.Second)
)
type Responder struct {
@@ -304,13 +305,27 @@ func (rs *Responder) ProcessCdr(cdr *StoredCdr, reply *string) error {
}
func (rs *Responder) LogCallCost(ccl *CallCostLog, reply *string) error {
if item, err := logCallCostResponseCache.Get(ccl.CgrId); err == nil && item != nil {
*reply = item.Value.(string)
return item.Err
}
if rs.CdrSrv == nil {
return errors.New("CDR_SERVER_NOT_RUNNING")
err := errors.New("CDR_SERVER_NOT_RUNNING")
logCallCostResponseCache.Cache(ccl.CgrId, &cache2go.CacheItem{
Err: err,
})
return err
}
if err := rs.CdrSrv.LogCallCost(ccl); err != nil {
logCallCostResponseCache.Cache(ccl.CgrId, &cache2go.CacheItem{
Err: err,
})
return err
}
*reply = utils.OK
logCallCostResponseCache.Cache(ccl.CgrId, &cache2go.CacheItem{
Value: utils.OK,
})
return nil
}