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

update threshold to set snooze time after actions

Browse Source
This commit is contained in:
gezimbll
2024-05-07 10:57:38 -04:00
committed by Dan Christian Bogos
parent bd571376a7
commit 07ea67e638
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
engine/thresholds.go
View File

@@ -172,14 +172,18 @@ func processEventWithThreshold(ctx *context.Context, connMgr *ConnManager, actio
var reply string
if !t.tPrfl.Async {
return connMgr.Call(ctx, actionsConns, utils.ActionSv1ExecuteActions, args, &reply)
}
go func() {
if errExec := connMgr.Call(context.Background(), actionsConns, utils.ActionSv1ExecuteActions,
args, &reply); errExec != nil {
utils.Logger.Warning(fmt.Sprintf("<ThresholdS> failed executing actions for threshold: %s, error: %s", t.TenantID(), errExec.Error()))
if err = connMgr.Call(ctx, actionsConns, utils.ActionSv1ExecuteActions, args, &reply); err != nil {
return
}
}()
} else {
go func() {
if errExec := connMgr.Call(context.Background(), actionsConns, utils.ActionSv1ExecuteActions,
args, &reply); errExec != nil {
utils.Logger.Warning(fmt.Sprintf("<ThresholdS> failed executing actions for threshold: %s, error: %s", t.TenantID(), errExec.Error()))
}
}()
}
t.Snooze = time.Now().Add(t.tPrfl.MinSleep)
return
}
@@ -465,7 +469,7 @@ func (tS *ThresholdS) processEvent(ctx *context.Context, tnt string, args *utils
}
continue
}
t.Snooze = time.Now().Add(t.tPrfl.MinSleep)
// recurrent threshold
*t.dirty = true // mark it to be saved
if tS.cfg.ThresholdSCfg().StoreInterval == -1 {