wtp_tid.h File Reference

#include <math.h>
#include <stdlib.h>
#include "gwlib/gwlib.h"
#include "wap_events.h"
#include "wtp_resp.h"

Go to the source code of this file.

Data Structures
struct	WTPCached_tid

Macros
#define	WTP_TID_WINDOW_SIZE   (1L << 14)

Typedefs
typedef struct WTPCached_tid	WTPCached_tid

Enumerations
enum	{ no_cached_tid, ok, fail }

Functions
void	wtp_tid_cache_init (void)
void	wtp_tid_cache_shutdown (void)
int	wtp_tid_is_valid (WAPEvent *event, WTPRespMachine *machine)
void	wtp_tid_set_by_machine (WTPRespMachine *machine, long tid)

Macro Definition Documentation

WTP_TID_WINDOW_SIZE

#define WTP_TID_WINDOW_SIZE   (1L << 14)

Definition at line 75 of file wtp_tid.h.

Referenced by tid_in_window().

Typedef Documentation

WTPCached_tid

typedef struct WTPCached_tid WTPCached_tid

Definition at line 66 of file wtp_tid.h.

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
no_cached_tid
ok
fail

Definition at line 80 of file wtp_tid.h.

     {
    no_cached_tid,
    ok,
    fail
};

Function Documentation

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