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

send status events to all profiles if none set

Browse Source
This commit is contained in:
ionutboangiu
2025-10-07 20:37:47 +03:00
committed by Dan Christian Bogos
parent 880942352b
commit 84728ec4aa
2 changed files with 9 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
agents/diam_conn_stats_test.go
View File

@@ -73,7 +73,7 @@ func TestDiamConnStats(t *testing.T) {
"enabled": true,
"stats_conns": ["*localhost"],
// "thresholds_conns": ["*localhost"],
"conn_status_stat_queue_ids": ["SQ_CONN_1", "SQ_CONN_2", "SQ_CONN_3"],
// "conn_status_stat_queue_ids": ["SQ_CONN_1", "SQ_CONN_2", "SQ_CONN_3"],
// "conn_status_threshold_ids": [],
"conn_health_check_interval": "100ms"
}

19
agents/diamagent.go
View File

@@ -454,9 +454,8 @@ func (da *DiameterAgent) handleRAA(c diam.Conn, m *diam.Message) {
// sendConnStatusReport reports connection status changes to StatS and ThresholdS.
func (da *DiameterAgent) sendConnStatusReport(metadata *smpeer.Metadata, status string, localAddr, remoteAddr net.Addr) {
sqIDs := da.cgrCfg.DiameterAgentCfg().ConnStatusStatQueueIDs
thIDs := da.cgrCfg.DiameterAgentCfg().ConnStatusThresholdIDs
if len(sqIDs) == 0 && len(thIDs) == 0 {
daCfg := da.cgrCfg.DiameterAgentCfg()
if len(daCfg.StatSConns) == 0 && len(daCfg.ThresholdSConns) == 0 {
return // nothing to do
}
@@ -477,22 +476,20 @@ func (da *DiameterAgent) sendConnStatusReport(metadata *smpeer.Metadata, status
},
}
if len(sqIDs) != 0 {
ev.APIOpts[utils.OptsStatsProfileIDs] = sqIDs
if len(daCfg.StatSConns) != 0 {
ev.APIOpts[utils.OptsStatsProfileIDs] = daCfg.ConnStatusStatQueueIDs
var reply []string
if err := da.connMgr.Call(context.TODO(),
da.cgrCfg.DiameterAgentCfg().StatSConns,
if err := da.connMgr.Call(context.TODO(), daCfg.StatSConns,
utils.StatSv1ProcessEvent, ev, &reply); err != nil {
utils.Logger.Err(fmt.Sprintf("failed to process %s event in %s: %v",
utils.EventConnectionStatusReport, utils.StatS, err))
}
delete(ev.APIOpts, utils.OptsStatsProfileIDs)
}
if len(thIDs) != 0 {
ev.APIOpts[utils.OptsThresholdsProfileIDs] = thIDs
if len(daCfg.ThresholdSConns) != 0 {
ev.APIOpts[utils.OptsThresholdsProfileIDs] = daCfg.ConnStatusThresholdIDs
var reply []string
if err := da.connMgr.Call(context.TODO(),
da.cgrCfg.DiameterAgentCfg().ThresholdSConns,
if err := da.connMgr.Call(context.TODO(), daCfg.ThresholdSConns,
utils.ThresholdSv1ProcessEvent, ev, &reply); err != nil {
utils.Logger.Err(fmt.Sprintf("failed to process %s event in %s: %v",
utils.EventConnectionStatusReport, utils.ThresholdS, err))