wap.h File Reference

#include "wap_events.h"
#include "wap_addr.h"

Go to the source code of this file.

Typedefs
typedef void	wap_dispatch_func_t(WAPEvent *event)

Functions
void	wap_dispatch_datagram (WAPEvent *event)
void	wap_init (wap_dispatch_func_t *datagram_dispatch, wap_dispatch_func_t *application_dispatch)
void	wap_shutdown (void)
void	wtp_resp_init (wap_dispatch_func_t *datagram_dispatch, wap_dispatch_func_t *session_dispatch, wap_dispatch_func_t *push_dispatch, long timer_freq)
void	wtp_resp_dispatch_event (WAPEvent *event)
void	wtp_resp_shutdown (void)
void	wtp_initiator_init (wap_dispatch_func_t *datagram_dispatch, wap_dispatch_func_t *session_dispatch, long timer_freq)
void	wtp_initiator_dispatch_event (WAPEvent *event)
void	wtp_initiator_shutdown (void)
void	wsp_unit_init (wap_dispatch_func_t *datagram_dispatch, wap_dispatch_func_t *application_dispatch)
void	wsp_unit_dispatch_event (WAPEvent *event)
void	wsp_unit_shutdown (void)
void	wsp_session_init (wap_dispatch_func_t *responder_dispatch, wap_dispatch_func_t *initiator_dispatch, wap_dispatch_func_t *application_dispatch, wap_dispatch_func_t *ota_dispatch)
void	wsp_session_dispatch_event (WAPEvent *event)
void	wsp_session_shutdown (void)
void	wsp_push_client_init (wap_dispatch_func_t *dispatch_self, wap_dispatch_func_t *dispatch_wtp_resp)
void	wsp_push_client_shutdown (void)
void	wsp_push_client_dispatch_event (WAPEvent *e)

Typedef Documentation

wap_dispatch_func_t

typedef void wap_dispatch_func_t(WAPEvent *event)

Definition at line 85 of file wap.h.

Function Documentation

wap_dispatch_datagram()

void wap_dispatch_datagram

(

WAPEvent *

event

)

Definition at line 68 of file wap.c.

References CONNECTIONLESS_PORT, debug(), Timer::event, gw_assert(), gwlist_destroy(), gwlist_extract_first(), gwlist_len(), WAPEvent::type, WAPEvent::u, wap_event_destroy(), wap_event_dump(), warning(), wsp_unit_dispatch_event(), WTLS_CONNECTIONLESS_PORT, wtp_event_is_for_responder(), wtp_initiator_dispatch_event(), wtp_resp_dispatch_event(), and wtp_unpack_wdp_datagram().

Referenced by main().

{
   long len;
    gw_assert(dgram != NULL);

    if (dgram->type != T_DUnitdata_Ind) {
    warning(0, "wap_dispatch_datagram got event of unexpected type.");
    wap_event_dump(dgram);
    wap_event_destroy(dgram);
        return;
    }

    /* XXX Assumption does not hold for client side */
    if (dgram->u.T_DUnitdata_Ind.addr_tuple->local->port ==
        CONNECTIONLESS_PORT || dgram->u.T_DUnitdata_Ind.addr_tuple->
        local->port == WTLS_CONNECTIONLESS_PORT) {
    wsp_unit_dispatch_event(dgram);
    } else {
        List *events;

        events = wtp_unpack_wdp_datagram(dgram);

        if (!events) {
            debug("wap.wap", 0, "ignoring truncated datagram");
            wap_event_dump(dgram);
            wap_event_destroy(dgram);
            return;
        }

         len = gwlist_len(events);
         while (len-- > 0)
         {
        WAPEvent *event;

        event = gwlist_extract_first(events);
            if (wtp_event_is_for_responder(event))
                wtp_resp_dispatch_event(event);
            else
                wtp_initiator_dispatch_event(event);
        }

        wap_event_destroy(dgram);
        gwlist_destroy(events, NULL);
    }
}

wap_init()

void wap_init	(	wap_dispatch_func_t *	datagram_dispatch,
		wap_dispatch_func_t *	application_dispatch
	)

wap_shutdown()

void wap_shutdown

(

void

)

wsp_push_client_dispatch_event()

void wsp_push_client_dispatch_event

(

WAPEvent *

e

)

Definition at line 177 of file wsp_push_client.c.

References gwlist_produce(), and push_client_queue.

Referenced by main().

{
    gwlist_produce(push_client_queue, e);
}

wsp_push_client_init()

void wsp_push_client_init	(	wap_dispatch_func_t *	dispatch_self,
		wap_dispatch_func_t *	dispatch_wtp_resp
	)

Definition at line 145 of file wsp_push_client.c.

References counter_create(), dispatch_to_self, dispatch_to_wtp_resp, gw_assert(), gwlist_add_producer(), gwlist_create, gwthread_create, limbo, main_thread(), push_client_machine_id_counter, push_client_machines, push_client_queue, push_client_run_status, and running.

Referenced by main().

{
    push_client_machines = gwlist_create();
    push_client_machine_id_counter = counter_create();

    push_client_queue = gwlist_create();
    gwlist_add_producer(push_client_queue);

    dispatch_to_self = dispatch_self;
    dispatch_to_wtp_resp = dispatch_wtp_resp;

    gw_assert(push_client_run_status == limbo);
    push_client_run_status = running;
    gwthread_create(main_thread, NULL);
}

wsp_push_client_shutdown()

void wsp_push_client_shutdown

(

void

)

Definition at line 162 of file wsp_push_client.c.

References counter_destroy(), debug(), gw_assert(), gwlist_destroy(), gwlist_len(), gwlist_remove_producer(), gwthread_join_every(), main_thread(), push_client_machine_destroy(), push_client_machine_id_counter, push_client_machines, push_client_queue, push_client_run_status, running, terminating, and wap_event_destroy_item().

Referenced by main().

{
    gw_assert(push_client_run_status == running);
    push_client_run_status = terminating;
    gwlist_remove_producer(push_client_queue);
    gwthread_join_every(main_thread);

    debug("wap.wsp", 0, "wsp_push_client_shutdown: %ld push client machines"
          "left", gwlist_len(push_client_machines));
    gwlist_destroy(push_client_machines, push_client_machine_destroy);
    gwlist_destroy(push_client_queue, wap_event_destroy_item);

    counter_destroy(push_client_machine_id_counter);
}

wsp_session_dispatch_event()

void wsp_session_dispatch_event

(

WAPEvent *

event

)

Definition at line 228 of file wsp_session.c.

References gwlist_produce(), queue, and wap_event_assert().

Referenced by main(), main_thread(), response_push_connection(), and return_session_reply().

                                                 {
    wap_event_assert(event);
    gwlist_produce(queue, event);
}

wsp_session_init()

void wsp_session_init	(	wap_dispatch_func_t *	responder_dispatch,
		wap_dispatch_func_t *	initiator_dispatch,
		wap_dispatch_func_t *	application_dispatch,
		wap_dispatch_func_t *	ota_dispatch
	)

Definition at line 193 of file wsp_session.c.

References counter_create(), dispatch_to_appl, dispatch_to_ota, dispatch_to_wtp_init, dispatch_to_wtp_resp, gwlist_add_producer(), gwlist_create, gwthread_create, main_thread(), queue, run_status, running, session_id_counter, session_machines, and wsp_strings_init().

Referenced by main().

                                                              {
    queue = gwlist_create();
    gwlist_add_producer(queue);
    session_machines = gwlist_create();
    session_id_counter = counter_create();
    dispatch_to_wtp_resp = responder_dispatch;
    dispatch_to_wtp_init = initiator_dispatch;
    dispatch_to_appl = application_dispatch;
        dispatch_to_ota = push_ota_dispatch;
        wsp_strings_init();
    run_status = running;
    gwthread_create(main_thread, NULL);
}

wsp_session_shutdown()

void wsp_session_shutdown

(

void

)

Definition at line 211 of file wsp_session.c.

References counter_destroy(), debug(), gw_assert(), gwlist_destroy(), gwlist_len(), gwlist_remove_producer(), gwthread_join_every(), machine_destroy(), main_thread(), queue, run_status, running, session_id_counter, session_machines, terminating, wap_event_destroy_item(), and wsp_strings_shutdown().

Referenced by main().

                                {
    gw_assert(run_status == running);
    run_status = terminating;
    gwlist_remove_producer(queue);
    gwthread_join_every(main_thread);

    gwlist_destroy(queue, wap_event_destroy_item);

    debug("wap.wsp", 0, "WSP: %ld session machines left.",
        gwlist_len(session_machines));
    gwlist_destroy(session_machines, machine_destroy);

    counter_destroy(session_id_counter);
        wsp_strings_shutdown();
}

wsp_unit_dispatch_event()

void wsp_unit_dispatch_event

(

WAPEvent *

event

)

Definition at line 124 of file wsp_unit.c.

References gwlist_produce(), queue, and wap_event_assert().

Referenced by main(), return_unit_reply(), and wap_dispatch_datagram().

{
    wap_event_assert(event);
    gwlist_produce(queue, event);
}

wsp_unit_init()

void wsp_unit_init	(	wap_dispatch_func_t *	datagram_dispatch,
		wap_dispatch_func_t *	application_dispatch
	)

Definition at line 100 of file wsp_unit.c.

References dispatch_to_appl, dispatch_to_wdp, gwlist_add_producer(), gwlist_create, gwthread_create, main_thread(), queue, run_status, running, and wsp_strings_init().

Referenced by main().

{
    queue = gwlist_create();
    gwlist_add_producer(queue);
    dispatch_to_wdp = datagram_dispatch;
    dispatch_to_appl = application_dispatch;
    wsp_strings_init();
    run_status = running;
    gwthread_create(main_thread, NULL);
}

wsp_unit_shutdown()

void wsp_unit_shutdown

(

void

)

Definition at line 113 of file wsp_unit.c.

References gw_assert(), gwlist_destroy(), gwlist_remove_producer(), gwthread_join_every(), main_thread(), queue, run_status, running, terminating, wap_event_destroy_item(), and wsp_strings_shutdown().

Referenced by main().

{
    gw_assert(run_status == running);
    run_status = terminating;
    gwlist_remove_producer(queue);
    gwthread_join_every(main_thread);
    gwlist_destroy(queue, wap_event_destroy_item);
    wsp_strings_shutdown();
}

wtp_initiator_dispatch_event()

void wtp_initiator_dispatch_event

(

WAPEvent *

event

)

Definition at line 204 of file wtp_init.c.

References gwlist_produce(), and queue.

Referenced by main(), and wap_dispatch_datagram().

{
    gwlist_produce(queue, event);
}

wtp_initiator_init()

void wtp_initiator_init	(	wap_dispatch_func_t *	datagram_dispatch,
		wap_dispatch_func_t *	session_dispatch,
		long	timer_freq
	)

Definition at line 168 of file wtp_init.c.

References counter_create(), dispatch_to_wdp, dispatch_to_wsp, gw_assert(), gwlist_add_producer(), gwlist_create, gwthread_create, init_machine_id_counter, init_machines, init_timer_freq, initiator_run_status, limbo, main_thread(), queue, running, timer_freq, and timers_init().

Referenced by main().

{
    init_machines = gwlist_create();
    init_machine_id_counter = counter_create();
     
    queue = gwlist_create();
    gwlist_add_producer(queue);

    dispatch_to_wdp = datagram_dispatch;
    dispatch_to_wsp = session_dispatch;

    timers_init();
    init_timer_freq = timer_freq;

    gw_assert(initiator_run_status == limbo);
    initiator_run_status = running;
    gwthread_create(main_thread, NULL);
}

wtp_initiator_shutdown()

void wtp_initiator_shutdown

(

void

)

Definition at line 188 of file wtp_init.c.

References counter_destroy(), debug(), gw_assert(), gwlist_destroy(), gwlist_len(), gwlist_remove_producer(), gwthread_join_every(), init_machine_destroy(), init_machine_id_counter, init_machines, initiator_run_status, main_thread(), queue, running, terminating, timers_shutdown(), and wap_event_destroy_item().

Referenced by main().

{
    gw_assert(initiator_run_status == running);
    initiator_run_status = terminating;
    gwlist_remove_producer(queue);
    gwthread_join_every(main_thread);

    debug("wap.wtp", 0, "wtp_initiator_shutdown: %ld init_machines left",
          gwlist_len(init_machines));
    gwlist_destroy(init_machines, init_machine_destroy);
    gwlist_destroy(queue, wap_event_destroy_item);

    counter_destroy(init_machine_id_counter);
    timers_shutdown();
}

wtp_resp_dispatch_event()

void wtp_resp_dispatch_event

(

WAPEvent *

event

)

Definition at line 253 of file wtp_resp.c.

References gwlist_produce(), and resp_queue.

Referenced by main(), push_client_event_handle(), and wap_dispatch_datagram().

{
    gwlist_produce(resp_queue, event);
}

wtp_resp_init()

void wtp_resp_init	(	wap_dispatch_func_t *	datagram_dispatch,
		wap_dispatch_func_t *	session_dispatch,
		wap_dispatch_func_t *	push_dispatch,
		long	timer_freq
	)

Definition at line 211 of file wtp_resp.c.

References counter_create(), dispatch_to_push, dispatch_to_wdp, dispatch_to_wsp, gw_assert(), gwlist_add_producer(), gwlist_create, gwthread_create, limbo, main_thread(), resp_machine_id_counter, resp_machines, resp_queue, resp_run_status, resp_timer_freq, running, timer_freq, timers_init(), and wtp_tid_cache_init().

Referenced by main().

{
    resp_machines = gwlist_create();
    resp_machine_id_counter = counter_create();

    resp_queue = gwlist_create();
    gwlist_add_producer(resp_queue);

    dispatch_to_wdp = datagram_dispatch;
    dispatch_to_wsp = session_dispatch;
    dispatch_to_push = push_dispatch;

    timers_init();
    resp_timer_freq = timer_freq;
    wtp_tid_cache_init();

    gw_assert(resp_run_status == limbo);
    resp_run_status = running;
    gwthread_create(main_thread, NULL);
}

wtp_resp_shutdown()

void wtp_resp_shutdown

(

void

)

Definition at line 235 of file wtp_resp.c.

References counter_destroy(), debug(), gw_assert(), gwlist_destroy(), gwlist_len(), gwlist_remove_producer(), gwthread_join_every(), main_thread(), resp_machine_destroy(), resp_machine_id_counter, resp_machines, resp_queue, resp_run_status, running, terminating, timers_shutdown(), wap_event_destroy_item(), and wtp_tid_cache_shutdown().

Referenced by main().

{
    gw_assert(resp_run_status == running);
    resp_run_status = terminating;
    gwlist_remove_producer(resp_queue);
    gwthread_join_every(main_thread);

    debug("wap.wtp", 0, "wtp_resp_shutdown: %ld resp_machines left",
          gwlist_len(resp_machines));
    gwlist_destroy(resp_machines, resp_machine_destroy);
    gwlist_destroy(resp_queue, wap_event_destroy_item);

    counter_destroy(resp_machine_id_counter);

    wtp_tid_cache_shutdown();
    timers_shutdown();
}