Module: sip-router Branch: master Commit: ade0f159ac0aa28006c12b6116d5d7a69aa62488 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=ade0f15… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: Wed Jul 8 22:55:14 2009 +0200 kex: several K core stats implemented in callbacks --- modules_k/kex/core_stats.c | 30 +++++++++++++++++++++++++++++- 1 files changed, 29 insertions(+), 1 deletions(-) diff --git a/modules_k/kex/core_stats.c b/modules_k/kex/core_stats.c index d46cb0d..121bb15 100644 --- a/modules_k/kex/core_stats.c +++ b/modules_k/kex/core_stats.c @@ -38,6 +38,8 @@ #include "../../lib/kmi/mi.h" #include "../../dprint.h" #include "../../timer.h" +#include "../../parser/msg_parser.h" +#include "../../script_cb.h" #include "../../mem/meminfo.h" #include "../../mem/shm_mem.h" @@ -102,12 +104,29 @@ static mi_export_t mi_stat_cmds[] = { int register_mi_stats(void) { /* register MI commands */ - if (register_mi_mod( "core", mi_stat_cmds)<0) { + if (register_mi_mod("core", mi_stat_cmds)<0) { LM_ERR("unable to register MI cmds\n"); return -1; } return 0; } + +static int km_cb_req_stats(struct sip_msg *msg, + unsigned int flags, void *param) +{ + update_stat(rcv_reqs, 1); + if(msg->first_line.u.request.method_value==METHOD_OTHER) + update_stat(unsupported_methods, 1); + return 1; +} + +static int km_cb_rpl_stats(struct sip_msg *msg, + unsigned int flags, void *param) +{ + update_stat(rcv_rpls, 1); + return 1; +} + int register_core_stats(void) { /* register core statistics */ @@ -120,6 +139,15 @@ int register_core_stats(void) LM_ERR("failed to register sh_mem statistics\n"); return -1; } + if (register_script_cb(km_cb_req_stats, PRE_SCRIPT_CB|REQUEST_CB, 0)<0 ) { + LM_ERR("failed to register PRE request callback\n"); + return -1; + } + if (register_script_cb(km_cb_rpl_stats, PRE_SCRIPT_CB|ONREPLY_CB, 0)<0 ) { + LM_ERR("failed to register PRE request callback\n"); + return -1; + } + return 0; }