wtp_tid.c File Reference

#include "gwlib/gwlib.h"
#include "wtp_tid.h"

Go to the source code of this file.

Enumerations
enum	{ no_cache = -1, iniatilised = -2, not_iniatilised = -3, cached = 0 }

Functions
static WTPCached_tid *	cache_item_create_empty (void)
static void	cache_item_destroy (void *item)
static void	add_tid (WTPRespMachine *resp_machine, long tid)
static void	set_tid_by_item (WTPCached_tid *item, long tid)
static int	tid_in_window (long rcv_tid, long last_tid)
static WTPCached_tid *	tid_cached (WTPRespMachine *resp_machine)
void	wtp_tid_cache_init (void)
void	wtp_tid_cache_shutdown (void)
int	wtp_tid_is_valid (WAPEvent *event, WTPRespMachine *resp_machine)
void	wtp_tid_set_by_machine (WTPRespMachine *resp_machine, long tid)
static int	tid_is_cached (void *a, void *b)

Variables
static List *	tid_cache = NULL

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
no_cache
iniatilised
not_iniatilised
cached

Definition at line 70 of file wtp_tid.c.

     {
    no_cache = -1,
    iniatilised = -2,
    not_iniatilised = -3,
    cached = 0
};

Function Documentation

add_tid()

static void add_tid ( WTPRespMachine *  resp_machine, long  tid  )

static

Definition at line 287 of file wtp_tid.c.

References cache_item_create_empty(), gwlist_append(), new_item(), tid_cache, and wap_addr_tuple_duplicate().

Referenced by wtp_tid_is_valid().

{
    WTPCached_tid *new_item = NULL;
       
    new_item = cache_item_create_empty(); 
    new_item->addr_tuple = wap_addr_tuple_duplicate(resp_machine->addr_tuple);
    new_item->tid = tid; 

    gwlist_append(tid_cache, new_item);
}

cache_item_create_empty()

static WTPCached_tid * cache_item_create_empty ( void  )

static

Definition at line 236 of file wtp_tid.c.

References WTPCached_tid::addr_tuple, and WTPCached_tid::tid.

Referenced by add_tid().

{
    WTPCached_tid *item = NULL;

    item = gw_malloc(sizeof(*item));
    item->addr_tuple = NULL;
    item->tid = 0;

    return item;
}

cache_item_destroy()

static void cache_item_destroy ( void *  item )

static

Definition at line 247 of file wtp_tid.c.

References WTPCached_tid::addr_tuple, and wap_addr_tuple_destroy().

Referenced by wtp_tid_cache_shutdown().

{
    WTPCached_tid *item;
    
    item = p;
    wap_addr_tuple_destroy(item->addr_tuple);
    gw_free(item);
}

set_tid_by_item()

static void set_tid_by_item ( WTPCached_tid *  item, long  tid  )

static

Definition at line 301 of file wtp_tid.c.

References gwlist_lock(), gwlist_unlock(), WTPCached_tid::tid, and tid_cache.

Referenced by wtp_tid_is_valid(), and wtp_tid_set_by_machine().

{
    gwlist_lock(tid_cache);
    item->tid = tid;
    gwlist_unlock(tid_cache);
}

tid_cached()

static WTPCached_tid * tid_cached ( WTPRespMachine *  resp_machine )

static

Definition at line 274 of file wtp_tid.c.

References gwlist_search(), tid_cache, and tid_is_cached().

Referenced by wtp_tid_is_valid(), and wtp_tid_set_by_machine().

{
    WTPCached_tid *item = NULL;

    item = gwlist_search(tid_cache, resp_machine->addr_tuple, tid_is_cached);

    return item;
}

tid_in_window()

static int tid_in_window ( long  rcv_tid, long  last_tid  )

static

Definition at line 204 of file wtp_tid.c.

References debug(), rcv_tid(), and WTP_TID_WINDOW_SIZE.

Referenced by wtp_tid_is_valid().

{
#if 0
    debug("wap.wtp.tid", 0, "tids were rcv_tid, %ld and last_tid, %ld"
          " and test window %ld", rcv_tid, last_tid, WTP_TID_WINDOW_SIZE); 
#endif
    if (last_tid == rcv_tid) {
    return 0;
    } 

    if (rcv_tid > last_tid) {
    if (abs(rcv_tid - last_tid) <= WTP_TID_WINDOW_SIZE) {
            return 1;
        } else {
            return 0;
        }
    }
       
    if (rcv_tid < last_tid) {
        if (abs(rcv_tid - last_tid) >= WTP_TID_WINDOW_SIZE){
            return 1;
        } else {
           return 0;
        }
    }

/*
 * Following return is unnecessary but our compiler demands it
 */
       return 0;
}

tid_is_cached()

static int tid_is_cached ( void *  a, void *  b  )

static

Definition at line 263 of file wtp_tid.c.

References WTPCached_tid::addr_tuple, and wap_addr_tuple_same().

Referenced by tid_cached().

{
    WAPAddrTuple *initiator_profile;
    WTPCached_tid *item;

    item = a;
    initiator_profile = b;

    return wap_addr_tuple_same(item->addr_tuple, initiator_profile);
}

wtp_tid_cache_init()

void wtp_tid_cache_init

(

void

)

Definition at line 102 of file wtp_tid.c.

References gwlist_create, and tid_cache.

Referenced by wtp_resp_init().

{
    tid_cache = gwlist_create();
}

wtp_tid_cache_shutdown()

void wtp_tid_cache_shutdown

(

void

)

Definition at line 107 of file wtp_tid.c.

References cache_item_destroy(), debug(), gwlist_destroy(), gwlist_len(), and tid_cache.

Referenced by wtp_resp_shutdown().

{
    debug("wap.wtp_tid", 0, "%ld items left in the tid cache", 
          gwlist_len(tid_cache));
    gwlist_destroy(tid_cache, cache_item_destroy);
}

wtp_tid_is_valid()

int wtp_tid_is_valid	(	WAPEvent *	event,
		WTPRespMachine *	resp_machine
	)

Definition at line 119 of file wtp_tid.c.

References add_tid(), debug(), fail, info(), no_cached_tid, ok, rcv_tid(), WAPEvent::RcvInvoke, set_tid_by_item(), WTPCached_tid::tid, tid_cached(), tid_in_window(), and WAPEvent::u.

{
    long rcv_tid = -1,
         last_tid = -1;

    WTPCached_tid *item = NULL;

#if 0
    debug("wap.wtp.tid", 0, "starting validation");
#endif
    rcv_tid = resp_machine->tid;
   
    if (!event->u.RcvInvoke.tid_new) {
/*
 * First we check whether the current initiator has a cache item for it.
 */      
        if ((item = tid_cached(resp_machine)) == NULL) {
            if (event->u.RcvInvoke.no_cache_supported)
                return no_cached_tid;
            else {
#if 0
             debug("wap.wtp.tid", 0, "empty cache");    
#endif
            add_tid(resp_machine, rcv_tid);
                return ok;
            }
        }
/*
 * If it has, we check if the message is a duplicate or has tid wrapped up 
 * confusingly.
 */      
        last_tid = item->tid; 
      
        if (tid_in_window(rcv_tid, last_tid) == 0){
            info(0, "WTP_TID: tid out of the window");
            return fail;
        } else {
#if 0
            debug("wap.wtp.tid", 0, "tid in the window");
#endif
            set_tid_by_item(item, rcv_tid);
            return ok;
        }

    } else {
        info(0, "WTP_TID: tid_new flag on");
        rcv_tid = 0;

        if (item == NULL) {
            add_tid(resp_machine, rcv_tid);
        } else {
            set_tid_by_item(item, rcv_tid);
        }
     
        return fail;
   }
/*
 * This return is unnecessary but the compiler demands it
 */
   return fail;
}

wtp_tid_set_by_machine()

void wtp_tid_set_by_machine	(	WTPRespMachine *	resp_machine,
		long	tid
	)

Definition at line 185 of file wtp_tid.c.

References set_tid_by_item(), and tid_cached().

{
    WTPCached_tid *item = NULL;
       
    item = tid_cached(resp_machine);
    set_tid_by_item(item, tid);
}

Variable Documentation

tid_cache

List* tid_cache = NULL

static

Definition at line 82 of file wtp_tid.c.

Referenced by add_tid(), set_tid_by_item(), tid_cached(), wtp_tid_cache_init(), and wtp_tid_cache_shutdown().