Module: sip-router Branch: master Commit: b306eb10e6943e7ab9b973f18734b9c9c719fcad URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=b306eb10...

Author: Daniel-Constantin Mierla miconda@gmail.com Committer: Daniel-Constantin Mierla miconda@gmail.com Date: Thu May 28 15:32:00 2009 +0300

kex: implemented shmem:* K statistics

- shared memory related statistics are now implemented in kex module

---

modules_k/kex/core_stats.c | 73 ++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 70 insertions(+), 3 deletions(-)

diff --git a/modules_k/kex/core_stats.c b/modules_k/kex/core_stats.c index b72fa0e..d46cb0d 100644 --- a/modules_k/kex/core_stats.c +++ b/modules_k/kex/core_stats.c @@ -37,6 +37,9 @@ #include "../../lib/kcore/statistics.h" #include "../../lib/kmi/mi.h" #include "../../dprint.h" +#include "../../timer.h" +#include "../../mem/meminfo.h" +#include "../../mem/shm_mem.h"

#ifdef STATISTICS @@ -70,6 +73,23 @@ stat_export_t core_stats[] = { {0,0,0} };

+unsigned long shm_stats_get_size(void); +unsigned long shm_stats_get_used(void); +unsigned long shm_stats_get_rused(void); +unsigned long shm_stats_get_mused(void); +unsigned long shm_stats_get_free(void); +unsigned long shm_stats_get_frags(void); + +stat_export_t shm_stats[] = { + {"total_size" , STAT_IS_FUNC, (stat_var**)shm_stats_get_size }, + {"used_size" , STAT_IS_FUNC, (stat_var**)shm_stats_get_used }, + {"real_used_size" , STAT_IS_FUNC, (stat_var**)shm_stats_get_rused }, + {"max_used_size" , STAT_IS_FUNC, (stat_var**)shm_stats_get_mused }, + {"free_size" , STAT_IS_FUNC, (stat_var**)shm_stats_get_free }, + {"fragments" , STAT_IS_FUNC, (stat_var**)shm_stats_get_frags }, + {0,0,0} +}; + static struct mi_root *mi_get_stats(struct mi_root *cmd, void *param); static struct mi_root *mi_reset_stats(struct mi_root *cmd, void *param);

@@ -82,7 +102,7 @@ static mi_export_t mi_stat_cmds[] = { int register_mi_stats(void) { /* register MI commands */ - if (register_mi_mod( "statistics", mi_stat_cmds)<0) { + if (register_mi_mod( "core", mi_stat_cmds)<0) { LM_ERR("unable to register MI cmds\n"); return -1; } @@ -95,13 +115,11 @@ int register_core_stats(void) LM_ERR("failed to register core statistics\n"); return -1; } -#if 0 /* register sh_mem statistics */ if (register_module_stats( "shmem", shm_stats)!=0 ) { LM_ERR("failed to register sh_mem statistics\n"); return -1; } -#endif return 0; }

@@ -244,4 +262,53 @@ static struct mi_root *mi_reset_stats(struct mi_root *cmd, void *param) return rpl_tree; }

+/*** shm stats ***/ + +static struct mem_info _stats_shm_mi; +static ticks_t _stats_shm_tm = 0; +void stats_shm_update(void) +{ + ticks_t t; + t = get_ticks(); + if(t!=_stats_shm_tm) { + shm_info(&_stats_shm_mi); + _stats_shm_tm = t; + } +} +unsigned long shm_stats_get_size(void) +{ + stats_shm_update(); + return _stats_shm_mi.total_size; +} + +unsigned long shm_stats_get_used(void) +{ + stats_shm_update(); + return _stats_shm_mi.used; +} + +unsigned long shm_stats_get_rused(void) +{ + stats_shm_update(); + return _stats_shm_mi.real_used; +} + +unsigned long shm_stats_get_mused(void) +{ + stats_shm_update(); + return _stats_shm_mi.max_used; +} + +unsigned long shm_stats_get_free(void) +{ + stats_shm_update(); + return _stats_shm_mi.free; +} + +unsigned long shm_stats_get_frags(void) +{ + stats_shm_update(); + return _stats_shm_mi.total_frags; +} + #endif