Function register_route_timers

timer.c:329–393

the function will check the timer routes from the current process, * so be carefull where you are running it from */

/* the function will check the timer routes from the current process,
 * so be carefull where you are running it from */
int register_route_timers(void)
{
	struct timer_route_param *tr_param;
	struct os_timer *t, *p;
	int i;

#define move_to_pending( _t) \
	while(_t) { \
		p = (_t)->next; \
		if ((_t)->trigger_time) { \
			(_t)->next = *tr_timer_pending; \
			*tr_timer_pending = (_t); \
		} else { \
			shm_free( (_t)->t_param ); \
			shm_free( (_t) ); \
		} \
		(_t) = p; \
	}

	lock_get(tr_list_lock);

	/* handle the pending list, remove whatever already finished,
	 * otherwise put back into pending */
	t = *tr_timer_pending;
	*tr_timer_pending = NULL;
	move_to_pending( t);

	/* handle the existing list -> free if done or move to pending if
	 * the job is still under execution (for sure triggering cannot be
	 * done anymore as the have the lock here) */
	t = *tr_timer_list;
	move_to_pending( t);
	*tr_timer_list = NULL;

	/* convert timer routes to jobs */
	for(i = 0; i<TIMER_RT_NO && sroutes->timer[i].a ; i++)
	{
		LM_DBG("registering timer route [%s] at %d secs\n",
			sroutes->timer[i].name, sroutes->timer[i].interval);

		tr_param = (struct timer_route_param*)
			shm_malloc( sizeof(struct timer_route_param) );
		if (tr_param==NULL) {
			LM_ERR("no more mem, skipping route timer [%s]\n",
				sroutes->timer[i].name);
		} else {
			tr_param->idx = i;
			tr_param->version = sroutes->version;
			t = new_os_timer( "timer_route", 0, route_timer_f, (void*)tr_param,
				sroutes->timer[i].interval);
			if (t==NULL) {
				LM_ERR("no more mem, skipping route timer [%s]\n",
					sroutes->timer[i].name);
			} else {
				/* insert it into the list*/
				t->next = *tr_timer_list;
				*tr_timer_list = t;
			}