[sr-dev] git:master:2c09f405: core: wheel timer implementation

Module: kamailio Branch: master Commit: 2c09f405cf28a42d551714e800310ec08e50f24e URL: https://github.com/kamailio/kamailio/commit/2c09f405cf28a42d551714e800310ec… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2016-01-21T14:17:37+01:00 core: wheel timer implementation - to be shared by modules needing to execute timer tasks, don't want to interfere with main core timers, but don't do lots of operations to create own timer --- Modified: timer_proc.c Modified: timer_proc.h --- Diff: https://github.com/kamailio/kamailio/commit/2c09f405cf28a42d551714e800310ec… Patch: https://github.com/kamailio/kamailio/commit/2c09f405cf28a42d551714e800310ec… --- diff --git a/timer_proc.c b/timer_proc.c index 76b54ee..a0a4c17 100644 --- a/timer_proc.c +++ b/timer_proc.c @@ -278,4 +278,116 @@ int fork_sync_utimer(int child_id, char* desc, int make_sock, } +#define SR_WTIMER_SIZE 16 + +typedef struct sr_wtimer_node { + struct sr_wtimer_node *next; + uint32_t interval; + uint32_t steps; + uint32_t cycles; + timer_function* f; + void* param; +} sr_wtimer_node_t; + +typedef struct sr_wtimer { + uint32_t itimer; + sr_wtimer_node_t *wlist[SR_WTIMER_SIZE]; +} sr_wtimer_t; + +static sr_wtimer_t *_sr_wtimer = NULL;; + +/** + * + */ +int sr_wtimer_init(void) +{ + if(_sr_wtimer!=NULL) + return 0; + _sr_wtimer = (sr_wtimer_t *)pkg_malloc(sizeof(sr_wtimer_t)); + if(_sr_wtimer!=NULL) { + LM_ERR("no more pkg memory\n"); + return -1; + } + + memset(_sr_wtimer, 0, sizeof(sr_wtimer_t)); + register_sync_timers(1); + return 0; +} + +/** + * + */ +int sr_wtimer_add(timer_function* f, void* param, int interval) +{ + sr_wtimer_node_t *wt; + if(_sr_wtimer!=NULL) { + LM_ERR("wtimer not intialized\n"); + return -1; + } + + wt = (sr_wtimer_node_t*)pkg_malloc(sizeof(sr_wtimer_node_t)); + if(wt==NULL) { + LM_ERR("no more pkg memory\n"); + return -1; + } + memset(wt, 0, sizeof(sr_wtimer_node_t)); + wt->f = f; + wt->param = param; + wt->interval = interval; + wt->steps = interval % SR_WTIMER_SIZE; + wt->cycles = interval / SR_WTIMER_SIZE; + wt->next = _sr_wtimer->wlist[wt->steps]; + _sr_wtimer->wlist[wt->steps] = wt; + + return 0; +} + +/** + * + */ +void sr_wtimer_exec(unsigned int ticks, void *param) +{ + sr_wtimer_node_t *wt; + uint32_t i; + uint32_t c; + + if(_sr_wtimer!=NULL) { + LM_ERR("wtimer not intialized\n"); + return; + } + + _sr_wtimer->itimer++; + c = _sr_wtimer->itimer / SR_WTIMER_SIZE; + + for(i=1; i<=SR_WTIMER_SIZE; i++) { + if(_sr_wtimer->itimer % i == 0) { + for(wt=_sr_wtimer->wlist[i % SR_WTIMER_SIZE]; + wt!=NULL; wt = wt->next) { + if(wt->cycles==0 || (c % wt->cycles==0)) { + wt->f(ticks, wt->param); + } + } + } + } +} + +/** + * + */ +int sr_wtimer_start(void) +{ + if(_sr_wtimer!=NULL) { + LM_ERR("wtimer not intialized\n"); + return -1; + } + + if(fork_sync_timer(-1 /*PROC_TIMER*/, "WTIMER", 1, + sr_wtimer_exec, NULL, 1)<0) { + LM_ERR("wtimer starting failed\n"); + return -1; + } + + return 0; +} + /* vi: set ts=4 sw=4 tw=79:ai:cindent: */ diff --git a/timer_proc.h b/timer_proc.h index bfeddd0..37f14b2 100644 --- a/timer_proc.h +++ b/timer_proc.h @@ -122,6 +122,10 @@ int fork_sync_timer(int child_id, char* desc, int make_sock, int fork_sync_utimer(int child_id, char* desc, int make_sock, utimer_function* f, void* param, int uinterval); +int sr_wtimer_init(void); +int sr_wtimer_add(timer_function* f, void* param, int interval); +int sr_wtimer_start(void); + #endif /*__timer_proc_h*/ /* vi: set ts=4 sw=4 tw=79:ai:cindent: */