test_timerset.c File Reference

#include "gwlib/gwlib.h"
#include "gwlib/gw-timer.h"
#include "gw/msg.h"

Go to the source code of this file.

Data Structures
struct	TimerItem

Macros
#define	MAX_RETRY   3
#define	FREQ   10

Typedefs
typedef struct TimerItem	TimerItem

Functions
static void	timer_consumer_thread (void *arg)
static void	timer_retry_cb (void *arg)
static void	retry_consumer_thread (void *arg)
int	main ()

Variables
static Timerset *	timerset = NULL
static List *	q_timer = NULL
static List *	q_retry = NULL

Macro Definition Documentation

FREQ

#define FREQ   10

Definition at line 68 of file test_timerset.c.

Referenced by main(), retry_consumer_thread(), and timer_consumer_thread().

MAX_RETRY

#define MAX_RETRY   3

Definition at line 67 of file test_timerset.c.

Referenced by retry_consumer_thread(), and timer_consumer_thread().

Typedef Documentation

TimerItem

typedef struct TimerItem TimerItem

Function Documentation

main()

int main

(

void

)

Definition at line 154 of file test_timerset.c.

References debug(), FREQ, gw_timer_create(), gw_timer_elapsed_start(), gw_timerset_count(), gw_timerset_create(), gw_timerset_destroy(), gwlib_init(), gwlib_shutdown(), gwlist_add_producer(), gwlist_create, gwlist_destroy(), gwlist_remove_producer(), gwthread_create, gwthread_join(), gwthread_sleep(), TimerItem::msg, msg_create, q_retry, q_timer, retry_consumer_thread(), TimerItem::timer, timer_consumer_thread(), timer_retry_cb(), and timerset.

{
    long t_timer;
    long t_retry;
    Msg *msg_a, *msg_b;
    TimerItem *i_timer;
    TimerItem *i_retry;

    gwlib_init();

    timerset = gw_timerset_create();

    /* setup timer thread to consume queue */
    q_timer = gwlist_create();
    gwlist_add_producer(q_timer);
    t_timer = gwthread_create(timer_consumer_thread, q_timer);

    /* setup thread to consume retry callback events */
    q_retry = gwlist_create();
    gwlist_add_producer(q_retry);
    t_retry = gwthread_create(retry_consumer_thread, q_retry);

    msg_a = msg_create(sms);
    msg_b = msg_create(sms);

    msg_a->sms.resend_try = msg_b->sms.resend_try = 0;

    i_timer = gw_malloc(sizeof(TimerItem));
    i_timer->msg = msg_a;
    /* timed events are pushed into q_timer queue */
    i_timer->timer = gw_timer_create(timerset, q_timer, NULL);
    gw_timer_elapsed_start(i_timer->timer, FREQ, i_timer);
    debug("",0,"%s: Msg %p retry %ld", __func__, msg_a, msg_a->sms.resend_try);

    i_retry = gw_malloc(sizeof(TimerItem));
    i_retry->msg = msg_b;
    /* timed events trigged the callback function */
    i_retry->timer = gw_timer_create(timerset, NULL, timer_retry_cb);
    gw_timer_elapsed_start(i_retry->timer, FREQ, i_retry);
    debug("",0,"%s: Msg %p retry %ld", __func__, msg_b, msg_b->sms.resend_try);

    debug("",0,"%s: enter main loop", __func__);
    do {
        gwthread_sleep(2);
    } while (gw_timerset_count(timerset) > 0);
    debug("",0,"%s: exit main loop", __func__);

    gw_timerset_destroy(timerset);

    gwlist_remove_producer(q_timer);
    gwthread_join(t_timer);
    gwlist_destroy(q_timer, NULL);

    gwlist_remove_producer(q_retry);
    gwthread_join(t_retry);
    gwlist_destroy(q_retry, NULL);

    gwlib_shutdown();

    return 0;
}

retry_consumer_thread()

static void retry_consumer_thread ( void *  arg )

static

Definition at line 131 of file test_timerset.c.

References debug(), FREQ, gw_timer_create(), gw_timer_elapsed_start(), gwlist_consume(), MAX_RETRY, TimerItem::msg, msg, msg_destroy(), TimerItem::timer, timer_retry_cb(), timerset, and warning().

Referenced by main().

{
    List *q = arg;
    Msg *msg;
    TimerItem *i;

    while ((msg = gwlist_consume(q)) != NULL) {
        if (++(msg->sms.resend_try) <= MAX_RETRY) {
            i = gw_malloc(sizeof(TimerItem));
            i->msg = msg;
            i->timer = gw_timer_create(timerset, NULL, timer_retry_cb);
            gw_timer_elapsed_start(i->timer, FREQ, i);
            debug("",0,"%s: Msg %p retry %ld", __func__,
                  msg, msg->sms.resend_try);
        } else {
            warning(0,"%s: Msg %p exceeded %d retries, discard!", __func__,
                    msg, MAX_RETRY);
            msg_destroy(msg);
        }
    }
}

timer_consumer_thread()

static void timer_consumer_thread ( void *  arg )

static

Definition at line 87 of file test_timerset.c.

References debug(), FREQ, gw_timer_elapsed_destroy(), gw_timer_elapsed_start(), gwlist_consume(), MAX_RETRY, TimerItem::msg, msg_destroy(), TimerItem::timer, and warning().

Referenced by main().

{
    List *q = arg;
    TimerItem *i;

    while ((i = gwlist_consume(q)) != NULL) {
        if (++(i->msg->sms.resend_try) <= MAX_RETRY) {
            gw_timer_elapsed_start(i->timer, FREQ, i);
            debug("",0,"%s: Msg %p retry %ld", __func__,
                  i->msg, i->msg->sms.resend_try);
        } else {
            warning(0,"%s: Msg %p exceeded %d retries, discard!", __func__,
                    i->msg, MAX_RETRY);
            msg_destroy(i->msg);
            gw_timer_elapsed_destroy(i->timer);
            gw_free(i);
        }
    }
}

timer_retry_cb()

static void timer_retry_cb ( void *  arg )

static

Definition at line 115 of file test_timerset.c.

References gw_timer_elapsed_destroy_cb(), gwlist_produce(), TimerItem::msg, q_retry, and TimerItem::timer.

Referenced by main(), and retry_consumer_thread().

{
    TimerItem *i = arg;

    gwlist_produce(q_retry, i->msg);

    gw_timer_elapsed_destroy_cb(i->timer);
    gw_free(i);
}

Variable Documentation

q_retry

List* q_retry = NULL

static

Definition at line 79 of file test_timerset.c.

Referenced by main(), and timer_retry_cb().

q_timer

List* q_timer = NULL

static

Definition at line 78 of file test_timerset.c.

Referenced by main().

timerset

Timerset* timerset = NULL

static

Definition at line 76 of file test_timerset.c.

Referenced by main(), and retry_consumer_thread().