timer.h File Reference

---

Detailed Description

CDiameterPeer Timer Process.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file timer.h.

#include "worker.h"

Go to the source code of this file.

Data Structures
struct	_timer_cb_t
	timer element More...
struct	timer_cb_list_t
	timer list More...
Typedefs
typedef void(*)	callback_f (time_t now, void *ptr)
	callback function for timer event
typedef _timer_cb_t	timer_cb_t
	timer element
Functions
int	add_timer (int expires_in, int one_time, callback_f cb, void *ptr)
	Adds a timer to the timer list.
void	timer_cdp_init ()
	Init the timer structures.
void	timer_cdp_destroy ()
	Destroy the timer structures.
void	timer_process (int returns)
	Timer Process function.

---

Typedef Documentation

typedef void(*) callback_f(time_t now, void *ptr)

callback function for timer event

Definition at line 62 of file timer.h.

typedef struct _timer_cb_t timer_cb_t

timer element

---

Function Documentation

int add_timer	(	int	expires_in,
		int	one_time,
		callback_f	cb,
		void *	ptr
	)

Adds a timer to the timer list.

Parameters:

	expires_in	- time until expiration in seconds
	one_time	- if after expiration it should be removed or kept in the timers list
	cb	- callback function to be called on expiration
	ptr	- generic pointer to pass to the callback on expiration

Returns:

1 on success or 0 on failure

Definition at line 132 of file timer.c.

References _timer_cb_t::cb, _timer_cb_t::expires, timer_cb_list_t::head, _timer_cb_t::interval, LOG_NO_MEM, _timer_cb_t::next, _timer_cb_t::one_time, _timer_cb_t::prev, _timer_cb_t::ptr, timer_cb_list_t::tail, timers, and timers_lock.

Referenced by peer_manager_init(), and trans_init().

{
    timer_cb_t *n;
    if (expires_in==0){
        LOG(L_ERR,"ERROR:add_timer(): Minimum expiration time is 1 second!\n");
        return 0;
    }
    n = shm_malloc(sizeof(timer_cb_t));
    if (!n){
        LOG_NO_MEM("shm",sizeof(timer_cb_t));
        return 0;
    }
    n->ptr = shm_malloc(sizeof(void*));
    if (!n){
        LOG_NO_MEM("shm",sizeof(void*));
        shm_free(n);
        return 0;
    }
    n->expires = expires_in + time(0);
    n->one_time = one_time;
    n->interval = expires_in;
    n->cb = cb;
    *(n->ptr) = ptr;

    lock_get(timers_lock);
        n->prev = timers->tail;
        n->next = 0;
        if (!timers->head) timers->head = n;
        if (timers->tail) timers->tail->next = n;
        timers->tail = n;
    lock_release(timers_lock);
    return 1;
}

void timer_cdp_init

(

)

Init the timer structures.

Definition at line 169 of file timer.c.

References timer_cb_list_t::head, timer_cb_list_t::tail, timers, and timers_lock.

Referenced by diameter_peer_init().

{
    timers = shm_malloc(sizeof(timer_cb_list_t));
    timers->head=0;
    timers->tail=0;
    timers_lock = lock_alloc();
    timers_lock = lock_init(timers_lock);   
}

void timer_cdp_destroy

(

)

Destroy the timer structures.

Definition at line 181 of file timer.c.

References timer_cb_list_t::head, _timer_cb_t::next, _timer_cb_t::ptr, timers, and timers_lock.

Referenced by diameter_peer_destroy().

{
    timer_cb_t *n,*i;
/*  lock_get(timers_lock);*/
    i = timers->head;
    while(i){
        n = i->next;
        if (i->ptr) shm_free(i->ptr);
        shm_free(i);
        i = n;
    }
    shm_free(timers);
    lock_destroy(timers_lock);
    lock_dealloc((void*)timers_lock);
}

void timer_process

(

int

returns

)

Timer Process function.

It calls timer_loop().

Parameters:

returns

- whether on shutdown this function should return or exit

Returns:

if returns is set then on shutdown, else never and on shutdown it exits

Definition at line 203 of file timer.c.

References dp_del_pid(), memlog, and timer_loop().

Referenced by diameter_peer_start().

{
    LOG(L_INFO,"INFO:Timer process starting up...\n");
        
    timer_loop();
    
    LOG(L_INFO,"INFO:... Timer process finished\n");
    if (!returns) {
#ifdef CDP_FOR_SER
#else
#ifdef PKG_MALLOC
    #ifdef PKG_MALLOC
        LOG(memlog, "Timer Memory status (pkg):\n");
        //pkg_status();
        #ifdef pkg_sums
            pkg_sums();
        #endif 
    #endif
#endif
        dp_del_pid(getpid());       
#endif      
        
        exit(0);
    }
}

---