transaction.c File Reference

---

Detailed Description

CDiameterPeer Transaction Procedures.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file transaction.c.

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

Go to the source code of this file.

Functions
int	trans_init ()
	Initializes the transaction structure.
cdp_trans_t *	add_trans (AAAMessage *msg, AAATransactionCallback_f *cb, void *ptr, int timeout, int auto_drop)
	Create and add a transaction to the transaction list.
void	del_trans (AAAMessage *msg)
	Remove from the list and deallocate a transaction.
cdp_trans_t *	take_trans (AAAMessage *msg)
	Return and remove the transaction from the transaction list.
void	free_trans (cdp_trans_t *x)
	Deallocate the memory taken by a transaction.
void	trans_timer (time_t now, void *ptr)
	Timer callback for checking the transaction status.
Variables
cdp_trans_list_t *	trans_list = 0
	list of transactions

---

Function Documentation

int trans_init

(

)

Initializes the transaction structure.

Also adds a timer callback for checking the transaction statuses

Returns:

1 if success or 0 on error

Definition at line 69 of file transaction.c.

References add_timer(), cdp_trans_list_t::head, cdp_trans_list_t::lock, LOG_NO_MEM, cdp_trans_list_t::tail, trans_list, and trans_timer().

Referenced by diameter_peer_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;
}

cdp_trans_t* add_trans	(	AAAMessage *	msg,
		AAATransactionCallback_f *	cb,
		void *	ptr,
		int	timeout,
		int	auto_drop
	)			[inline]

Create and add a transaction to the transaction list.

Parameters:

	msg	- the message that this related to
	cb	- callback to be called on response or time-out
	ptr	- generic pointer to pass to the callback on call
	timeout	- timeout time in seconds
	auto_drop	- whether to auto drop the transaction on event, or let the application do it later

Returns:

the created cdp_trans_t* or NULL on error

Definition at line 94 of file transaction.c.

References _cdp_trans_t::auto_drop, _cdp_trans_t::cb, _cdp_trans_t::endtoendid, _message_t::endtoendId, _cdp_trans_t::expires, cdp_trans_list_t::head, _cdp_trans_t::hopbyhopid, _message_t::hopbyhopId, cdp_trans_list_t::lock, LOG_NO_MEM, _cdp_trans_t::next, _cdp_trans_t::prev, _cdp_trans_t::ptr, cdp_trans_list_t::tail, and trans_list.

Referenced by AAASendMessage(), AAASendMessageToPeer(), AAASendRecvMessage(), and AAASendRecvMessageToPeer().

{
    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;
}

void del_trans

(

AAAMessage *

msg

)

[inline]

Remove from the list and deallocate a transaction.

Parameters:

msg

- the message that relates to that particular transaction

Definition at line 129 of file transaction.c.

References _cdp_trans_t::endtoendid, _message_t::endtoendId, free_trans(), cdp_trans_list_t::head, _cdp_trans_t::hopbyhopid, _message_t::hopbyhopId, cdp_trans_list_t::lock, _cdp_trans_t::next, _cdp_trans_t::prev, cdp_trans_list_t::tail, and trans_list.

{
    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);
}

cdp_trans_t* take_trans

(

AAAMessage *

msg

)

[inline]

Return and remove the transaction from the transaction list.

Parameters:

msg

- the message that this transaction relates to

Returns:

the cdp_trans_t* if found or NULL if not

Definition at line 150 of file transaction.c.

References _cdp_trans_t::endtoendid, _message_t::endtoendId, cdp_trans_list_t::head, _cdp_trans_t::hopbyhopid, _message_t::hopbyhopId, cdp_trans_list_t::lock, _cdp_trans_t::next, _cdp_trans_t::prev, cdp_trans_list_t::tail, and trans_list.

Referenced by api_callback().

{
    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;
}

void free_trans

(

cdp_trans_t *

x

)

[inline]

Deallocate the memory taken by a transaction.

Parameters:

x

- the transaction to deallocate

Definition at line 170 of file transaction.c.

References _cdp_trans_t::ptr.

Referenced by AAASendRecvMessage(), AAASendRecvMessageToPeer(), api_callback(), del_trans(), and trans_timer().

{
    if (x->ptr) shm_free(x->ptr);
    shm_free(x);
}

void trans_timer	(	time_t	now,
		void *	ptr
	)

Timer callback for checking the transaction status.

Parameters:

	now	- time of call
	ptr	- generic pointer, passed to the transactional callbacks

Definition at line 181 of file transaction.c.

References _cdp_trans_t::ans, _cdp_trans_t::auto_drop, _cdp_trans_t::cb, _cdp_trans_t::expires, free_trans(), cdp_trans_list_t::head, cdp_trans_list_t::lock, _cdp_trans_t::next, _cdp_trans_t::prev, _cdp_trans_t::ptr, cdp_trans_list_t::tail, and trans_list.

Referenced by trans_init().

{
    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);
}

---

Variable Documentation

cdp_trans_list_t* trans_list = 0

list of transactions

Definition at line 62 of file transaction.c.

Referenced by add_trans(), del_trans(), take_trans(), trans_init(), and trans_timer().

---