transaction.c

Go to the documentation of this file.

#include "transaction.h"

#include "timer.h"
#include "globals.h"


cdp_trans_list_t *trans_list=0;     
int trans_init()
{
    trans_list = shm_malloc(sizeof(cdp_trans_list_t));
    if (!trans_list){
        LOG_NO_MEM("shm",sizeof(cdp_trans_list_t));
        return 0;
    }
    trans_list->head = 0;
    trans_list->tail = 0;
    trans_list->lock = lock_alloc();
    trans_list->lock = lock_init(trans_list->lock);

    add_timer(1,0,trans_timer,0);
    return 1;
}

inline cdp_trans_t* add_trans(AAAMessage *msg,AAATransactionCallback_f *cb, void *ptr,int timeout,int auto_drop)
{
    cdp_trans_t *x;
    x = shm_malloc(sizeof(cdp_trans_t));
    if (!x) {
        LOG_NO_MEM("shm",sizeof(cdp_trans_t));
        return 0;
    }
    x->ptr = shm_malloc(sizeof(void*));
    if (!x->ptr) {
        LOG_NO_MEM("shm",sizeof(void*));
        shm_free(x);
        return 0;
    }
    x->endtoendid = msg->endtoendId;
    x->hopbyhopid = msg->hopbyhopId;
    x->cb = cb;
    *(x->ptr) = ptr;
    x->expires = timeout + time(0);
    x->auto_drop = auto_drop;
    x->next = 0;

    lock_get(trans_list->lock);
    x->prev = trans_list->tail;
    if (trans_list->tail) trans_list->tail->next = x;
    trans_list->tail = x;
    if (!trans_list->head) trans_list->head = x;
    lock_release(trans_list->lock);
    return x;
}

inline void del_trans(AAAMessage *msg)
{
    cdp_trans_t *x;
    lock_get(trans_list->lock);
    x = trans_list->head;
    while(x&& x->endtoendid!=msg->endtoendId && x->hopbyhopid!=msg->hopbyhopId) x = x->next;
    if (x){
        if (x->prev) x->prev->next = x->next;
        else trans_list->head = x->next;
        if (x->next) x->next->prev = x->prev;
        else trans_list->tail = x->prev;
        free_trans(x);
    }
    lock_release(trans_list->lock);
}

inline cdp_trans_t* take_trans(AAAMessage *msg)
{
    cdp_trans_t *x;
    lock_get(trans_list->lock);
    x = trans_list->head;
    while(x&& x->endtoendid!=msg->endtoendId && x->hopbyhopid!=msg->hopbyhopId) x = x->next;
    if (x){
        if (x->prev) x->prev->next = x->next;
        else trans_list->head = x->next;
        if (x->next) x->next->prev = x->prev;
        else trans_list->tail = x->prev;
    }
    lock_release(trans_list->lock);
    return x;
}

inline void free_trans(cdp_trans_t *x)
{
    if (x->ptr) shm_free(x->ptr);
    shm_free(x);
}

void trans_timer(time_t now, void* ptr)
{
    cdp_trans_t *x,*n;  
    LOG(L_DBG,"DBG:trans_timer(): taking care of diameter transactions...\n");
    lock_get(trans_list->lock);
    x = trans_list->head;
    while(x)
    {
        if (now>x->expires){
            x->ans = 0;
            if (x->cb){
                (x->cb)(1,*(x->ptr),0);
            }
            n = x->next;
            
            if (x->prev) x->prev->next = x->next;
            else trans_list->head = x->next;
            if (x->next) x->next->prev = x->prev;
            else trans_list->tail = x->prev;
            if (x->auto_drop) free_trans(x);
            
            x = n;
        } else 
            x = x->next;
    }
    lock_release(trans_list->lock);
}

---