diff --git a/modules/tm/t_reply.c b/modules/tm/t_reply.c index 3b8e16b348c..9011c87e5dd 100644 --- a/modules/tm/t_reply.c +++ b/modules/tm/t_reply.c @@ -554,8 +554,8 @@ static int _reply_light( struct cell *trans, char* buf, unsigned int len, /* t_update_timers_after_sending_reply( rb ); */ update_reply_stats( code ); trans->relayed_reply_branch=-2; - t_stats_relayed_locally(); - t_stats_relayed_total(); + t_stats_rpl_generated(); + t_stats_rpl_sent(); if (lock) UNLOCK_REPLIES( trans ); /* do UAC cleanup procedures in case we generated @@ -1867,7 +1867,7 @@ enum rps relay_reply( struct cell *t, struct sip_msg *p_msg, int branch, } } update_reply_stats( relayed_code ); - t_stats_relayed_total(); + t_stats_rpl_sent(); if (!buf) { LOG(L_ERR, "ERROR: relay_reply: " "no mem for outbound reply buffer\n"); @@ -1890,7 +1890,7 @@ enum rps relay_reply( struct cell *t, struct sip_msg *p_msg, int branch, memcpy( uas_rb->buffer, buf, res_len ); if (relayed_msg==FAKED_REPLY) { /* to-tags for local replies */ update_local_tags(t, &bm, uas_rb->buffer, buf); - t_stats_relayed_locally(); + t_stats_rpl_generated(); } /* update the status ... */ @@ -2041,7 +2041,7 @@ enum rps local_reply( struct cell *t, struct sip_msg *p_msg, int branch, winning_msg= branch==local_winner ? p_msg : t->uac[local_winner].reply; if (winning_msg==FAKED_REPLY) { - t_stats_relayed_locally(); + t_stats_rpl_generated(); winning_code = branch==local_winner ? msg_status : t->uac[local_winner].last_received; } else { @@ -2049,7 +2049,7 @@ enum rps local_reply( struct cell *t, struct sip_msg *p_msg, int branch, } t->uas.status = winning_code; update_reply_stats( winning_code ); - t_stats_relayed_total(); + t_stats_rpl_sent(); if (unlikely(is_invite(t) && winning_msg!=FAKED_REPLY && winning_code>=200 && winning_code <300 && has_tran_tmcbs(t, TMCB_LOCAL_COMPLETED) )) { @@ -2143,8 +2143,8 @@ int reply_received( struct sip_msg *p_msg ) if ( (t==0)||(t==T_UNDEFINED)) goto trans_not_found; - /* if transaction found, increment the received_replies counter */ - t_stats_received_replies(); + /* if transaction found, increment the rpl_received counter */ + t_stats_rpl_received(); if (unlikely(branch==T_BR_UNDEFINED)) BUG("invalid branch, please report to sr-dev@sip-router.org\n"); diff --git a/modules/tm/t_stats.c b/modules/tm/t_stats.c index 28fe04e0997..e4778d08dc2 100644 --- a/modules/tm/t_stats.c +++ b/modules/tm/t_stats.c @@ -93,9 +93,9 @@ void free_tm_stats() (res)->completed_5xx=(s1)->completed_5xx+(s2)->completed_5xx; \ (res)->completed_6xx=(s1)->completed_6xx+(s2)->completed_6xx; \ (res)->completed_2xx=(s1)->completed_2xx+(s2)->completed_2xx; \ - (res)->received_replies=(s1)->received_replies+(s2)->received_replies; \ - (res)->relayed_locally=(s1)->relayed_locally+(s2)->relayed_locally; \ - (res)->relayed_total=(s1)->relayed_total+(s2)->relayed_total; \ + (res)->rpl_received=(s1)->rpl_received+(s2)->rpl_received; \ + (res)->rpl_generated=(s1)->rpl_generated+(s2)->rpl_generated; \ + (res)->rpl_sent=(s1)->rpl_sent+(s2)->rpl_sent; \ (res)->deleted=(s1)->deleted+(s2)->deleted; \ }while(0) @@ -138,9 +138,9 @@ void tm_rpc_stats(rpc_t* rpc, void* c) (unsigned) waiting); rpc->struct_add(st, "d", "total", (unsigned) all.transactions); rpc->struct_add(st, "d", "total_local", (unsigned)all.client_transactions); - rpc->struct_add(st, "d", "received_replies", (unsigned)all.received_replies); - rpc->struct_add(st, "d", "relayed_locally", (unsigned)all.relayed_locally); - rpc->struct_add(st, "d", "relayed_total", (unsigned)all.relayed_total); + rpc->struct_add(st, "d", "rpl_received", (unsigned)all.rpl_received); + rpc->struct_add(st, "d", "rpl_generated", (unsigned)all.rpl_generated); + rpc->struct_add(st, "d", "rpl_sent", (unsigned)all.rpl_sent); rpc->struct_add(st, "ddddd", "6xx", (unsigned int)all.completed_6xx, "5xx", (unsigned int)all.completed_5xx, diff --git a/modules/tm/t_stats.h b/modules/tm/t_stats.h index 5be3c701d9c..108336ef2cf 100644 --- a/modules/tm/t_stats.h +++ b/modules/tm/t_stats.h @@ -43,9 +43,9 @@ struct t_proc_stats { /* number of transactions which completed with this status */ stat_counter completed_3xx, completed_4xx, completed_5xx, completed_6xx, completed_2xx; - stat_counter received_replies; - stat_counter relayed_locally; - stat_counter relayed_total; + stat_counter rpl_received; + stat_counter rpl_generated; + stat_counter rpl_sent; stat_counter deleted; #ifdef TM_MORE_STATS /* number of created transactions */ @@ -122,19 +122,19 @@ inline static void update_reply_stats( int code ) { } } -inline void static t_stats_received_replies(void) +inline void static t_stats_rpl_received(void) { - tm_stats[process_no].s.received_replies++; + tm_stats[process_no].s.rpl_received++; } -inline void static t_stats_relayed_locally(void) +inline void static t_stats_rpl_generated(void) { - tm_stats[process_no].s.relayed_locally++; + tm_stats[process_no].s.rpl_generated++; } -inline void static t_stats_relayed_total(void) +inline void static t_stats_rpl_sent(void) { - tm_stats[process_no].s.relayed_total++; + tm_stats[process_no].s.rpl_sent++; } diff --git a/modules/tmx/doc/tmx_admin.xml b/modules/tmx/doc/tmx_admin.xml index 705113f4fb1..8c2dcfe1ba0 100644 --- a/modules/tmx/doc/tmx_admin.xml +++ b/modules/tmx/doc/tmx_admin.xml @@ -691,35 +691,35 @@ event_route [tm:branch-failure:contact] {
- received_replies + rpl_received Total number of replies received by TM module.
- received_replies_absorbed + rpl_absorbed Total number of replies received and not relayed by TM module.
- tmx:relayed_locally + rpl_relayed - Total number of replies locally generated and relayed by TM module. + Total number of replies received and relayed by TM module.
- relayed_received + rpl_generated - Total number of replies received and relayed by TM module. + Total number of replies locally generated and relayed by TM module.
- relayed_total + rpl_sent Total number of replies relayed by TM module. diff --git a/modules/tmx/tmx_mod.c b/modules/tmx/tmx_mod.c index 38a73ff2d0b..b6a9cce7b59 100644 --- a/modules/tmx/tmx_mod.c +++ b/modules/tmx/tmx_mod.c @@ -114,21 +114,21 @@ unsigned long tmx_stats_rld_loc_rpls(void); unsigned long tmx_stats_rld_tot_rpls(void); static stat_export_t mod_stats[] = { - {"UAS_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_uas_trans }, - {"UAC_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_uac_trans }, - {"2xx_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_trans_2xx }, - {"3xx_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_trans_3xx }, - {"4xx_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_trans_4xx }, - {"5xx_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_trans_5xx }, - {"6xx_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_trans_6xx }, - {"inuse_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_trans_inuse }, - {"active_transactions" , STAT_IS_FUNC, (stat_var**)tmx_stats_trans_active}, - {"received_replies" , STAT_IS_FUNC, (stat_var**)tmx_stats_rcv_rpls }, - {"received_replies_absorbed", STAT_IS_FUNC, (stat_var**)tmx_stats_abs_rpls }, - {"relayed_locally" , STAT_IS_FUNC, (stat_var**)tmx_stats_rld_loc_rpls}, - {"relayed_received" , STAT_IS_FUNC, (stat_var**)tmx_stats_rld_rcv_rpls}, - {"relayed_total" , STAT_IS_FUNC, (stat_var**)tmx_stats_rld_tot_rpls}, - {0,0,0} + {"UAS_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_uas_trans }, + {"UAC_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_uac_trans }, + {"2xx_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_trans_2xx }, + {"3xx_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_trans_3xx }, + {"4xx_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_trans_4xx }, + {"5xx_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_trans_5xx }, + {"6xx_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_trans_6xx }, + {"inuse_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_trans_inuse }, + {"active_transactions", STAT_IS_FUNC, (stat_var**)tmx_stats_trans_active}, + {"rpl_received", STAT_IS_FUNC, (stat_var**)tmx_stats_rcv_rpls }, + {"rpl_absorbed", STAT_IS_FUNC, (stat_var**)tmx_stats_abs_rpls }, + {"rpl_generated", STAT_IS_FUNC, (stat_var**)tmx_stats_rld_loc_rpls}, + {"rpl_relayed", STAT_IS_FUNC, (stat_var**)tmx_stats_rld_rcv_rpls}, + {"rpl_sent", STAT_IS_FUNC, (stat_var**)tmx_stats_rld_tot_rpls}, + {0, 0, 0} }; #endif @@ -814,31 +814,31 @@ unsigned long tmx_stats_trans_active(void) unsigned long tmx_stats_rcv_rpls(void) { tmx_stats_update(); - return _tmx_stats_all.received_replies; + return _tmx_stats_all.rpl_received; } unsigned long tmx_stats_abs_rpls(void) { tmx_stats_update(); - return _tmx_stats_all.received_replies - tmx_stats_rld_rcv_rpls(); + return _tmx_stats_all.rpl_received - tmx_stats_rld_rcv_rpls(); } unsigned long tmx_stats_rld_loc_rpls(void) { tmx_stats_update(); - return _tmx_stats_all.relayed_locally; + return _tmx_stats_all.rpl_generated; } unsigned long tmx_stats_rld_tot_rpls(void) { tmx_stats_update(); - return _tmx_stats_all.relayed_total; + return _tmx_stats_all.rpl_sent; } unsigned long tmx_stats_rld_rcv_rpls(void) { tmx_stats_update(); - return _tmx_stats_all.relayed_total - _tmx_stats_all.relayed_locally; + return _tmx_stats_all.rpl_sent - _tmx_stats_all.rpl_generated; } #endif