wtp_pack.c File Reference

#include "gwlib/gwlib.h"
#include "wtp_pack.h"
#include "wtp_pdu.h"

Go to the source code of this file.

Enumerations
enum	{ first_byte, second_byte, third_byte, fourth_byte }
enum	{   ERROR_DATA = 0x00, INFO_DATA = 0x01, OPTION = 0x02, PACKET_SEQUENCE_NUMBER = 0x03,   SDU_BOUNDARY = 0x04, FRAME_BOUNDARY = 0x05 }

Functions
static unsigned short	send_tid (unsigned short tid)
WAPEvent *	wtp_pack_invoke (WTPInitMachine *machine, WAPEvent *event)
WAPEvent *	wtp_pack_result (WTPRespMachine *machine, WAPEvent *event)
WAPEvent *	wtp_pack_sar_result (WTPRespMachine *machine, int psn)
void	wtp_pack_set_rid (WAPEvent *dgram, long rid)
WAPEvent *	wtp_pack_abort (long abort_type, long abort_reason, long tid, WAPAddrTuple *address)
WAPEvent *	wtp_pack_ack (long ack_type, int rid_flag, long tid, WAPAddrTuple *address)
WAPEvent *	wtp_pack_sar_ack (long ack_type, long tid, WAPAddrTuple *address, int psn)

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
first_byte
second_byte
third_byte
fourth_byte

Definition at line 71 of file wtp_pack.c.

     {
    first_byte,
    second_byte,
    third_byte,
    fourth_byte
};

anonymous enum

anonymous enum

Enumerator
ERROR_DATA
INFO_DATA
OPTION
PACKET_SEQUENCE_NUMBER
SDU_BOUNDARY
FRAME_BOUNDARY

Definition at line 82 of file wtp_pack.c.

     {
    ERROR_DATA = 0x00,
    INFO_DATA = 0x01,
    OPTION = 0x02,
    PACKET_SEQUENCE_NUMBER = 0x03,
    SDU_BOUNDARY = 0x04,
    FRAME_BOUNDARY = 0x05
};

Function Documentation

send_tid()

static unsigned short send_tid ( unsigned short  tid )

static

Definition at line 291 of file wtp_pack.c.

Referenced by wtp_pack_abort(), wtp_pack_ack(), wtp_pack_invoke(), wtp_pack_result(), wtp_pack_sar_ack(), and wtp_pack_sar_result().

{
       return tid ^ 0x8000;
}

wtp_pack_abort()

WAPEvent* wtp_pack_abort	(	long	abort_type,
		long	abort_reason,
		long	tid,
		WAPAddrTuple *	address
	)

Definition at line 223 of file wtp_pack.c.

References send_tid(), WAPEvent::u, wtp_pdu::u, wap_addr_tuple_duplicate(), wap_event_create, wtp_pdu_create(), wtp_pdu_destroy(), and wtp_pdu_pack().

Referenced by handle_wrong_version(), init_machine_find_or_create(), and send_abort().

{
    WAPEvent *dgram;
    WTP_PDU *pdu;

    pdu = wtp_pdu_create(Abort);
    pdu->u.Abort.con = 0;
    pdu->u.Abort.abort_type = abort_type;
    pdu->u.Abort.tid = send_tid(tid);
    pdu->u.Abort.abort_reason = abort_reason;

    dgram = wap_event_create(T_DUnitdata_Req);
    dgram->u.T_DUnitdata_Req.addr_tuple = wap_addr_tuple_duplicate(address);
    dgram->u.T_DUnitdata_Req.user_data = wtp_pdu_pack(pdu);
    wtp_pdu_destroy(pdu);

    return dgram;
}

wtp_pack_ack()

WAPEvent* wtp_pack_ack	(	long	ack_type,
		int	rid_flag,
		long	tid,
		WAPAddrTuple *	address
	)

Definition at line 243 of file wtp_pack.c.

References send_tid(), WAPEvent::u, wtp_pdu::u, wap_addr_tuple_duplicate(), wap_event_create, wtp_pdu_create(), wtp_pdu_destroy(), and wtp_pdu_pack().

Referenced by send_ack().

{
    WAPEvent *dgram = NULL;
    WTP_PDU *pdu;
     
    pdu = wtp_pdu_create(Ack);
    pdu->u.Ack.con = 0;
    pdu->u.Ack.tidverify = ack_type;
    pdu->u.Ack.rid = rid_flag;
    pdu->u.Ack.tid = send_tid(tid);

    dgram = wap_event_create(T_DUnitdata_Req);
    dgram->u.T_DUnitdata_Req.addr_tuple = wap_addr_tuple_duplicate(address);
    dgram->u.T_DUnitdata_Req.user_data = wtp_pdu_pack(pdu);
    wtp_pdu_destroy(pdu);

    return dgram;
}

wtp_pack_invoke()

WAPEvent* wtp_pack_invoke	(	WTPInitMachine *	machine,
		WAPEvent *	event
	)

Definition at line 115 of file wtp_pack.c.

References gw_assert(), octstr_duplicate, send_tid(), WAPEvent::type, WAPEvent::u, wtp_pdu::u, wap_addr_tuple_duplicate(), wap_event_create, wtp_pdu_create(), wtp_pdu_destroy(), and wtp_pdu_pack().

{
    WAPEvent *dgram = NULL;
    WTP_PDU *pdu = NULL;

    gw_assert(event->type == TR_Invoke_Req);
    pdu = wtp_pdu_create(Invoke);
    pdu->u.Invoke.con = 0;
    pdu->u.Invoke.gtr = 1;
    pdu->u.Invoke.ttr = 1;
    pdu->u.Invoke.rid = 0;
    pdu->u.Invoke.version = 0;
    pdu->u.Invoke.tid = send_tid(machine->tid);
    pdu->u.Invoke.tidnew = machine->tidnew;
    pdu->u.Invoke.user_data =
        octstr_duplicate(event->u.TR_Invoke_Req.user_data);
    pdu->u.Invoke.class = event->u.TR_Invoke_Req.tcl;
    pdu->u.Invoke.uack = event->u.TR_Invoke_Req.up_flag;

    dgram = wap_event_create(T_DUnitdata_Req);
    dgram->u.T_DUnitdata_Req.addr_tuple =
    wap_addr_tuple_duplicate(machine->addr_tuple);
    dgram->u.T_DUnitdata_Req.user_data = wtp_pdu_pack(pdu);
    wtp_pdu_destroy(pdu);

    return dgram;
}

wtp_pack_result()

WAPEvent* wtp_pack_result	(	WTPRespMachine *	machine,
		WAPEvent *	event
	)

Definition at line 143 of file wtp_pack.c.

References gw_assert(), octstr_duplicate, send_tid(), WAPEvent::type, WAPEvent::u, wtp_pdu::u, wap_addr_tuple_duplicate(), wap_event_create, wtp_pdu_create(), wtp_pdu_destroy(), and wtp_pdu_pack().

{
    WAPEvent *dgram = NULL;
    WTP_PDU *pdu = NULL;
     
    gw_assert(event->type == TR_Result_Req);
    pdu = wtp_pdu_create(Result);
    pdu->u.Result.con = 0;
    pdu->u.Result.gtr = 1;
    pdu->u.Result.ttr = 1;
    pdu->u.Result.rid = 0;
    pdu->u.Result.tid = send_tid(machine->tid);
    pdu->u.Result.user_data = 
        octstr_duplicate(event->u.TR_Result_Req.user_data);

    dgram = wap_event_create(T_DUnitdata_Req);
    dgram->u.T_DUnitdata_Req.addr_tuple =
    wap_addr_tuple_duplicate(machine->addr_tuple);
    dgram->u.T_DUnitdata_Req.user_data = wtp_pdu_pack(pdu);
    wtp_pdu_destroy(pdu);
  
    return dgram;
}

wtp_pack_sar_ack()

WAPEvent* wtp_pack_sar_ack	(	long	ack_type,
		long	tid,
		WAPAddrTuple *	address,
		int	psn
	)

Definition at line 263 of file wtp_pack.c.

References octstr_create_from_data, send_tid(), WAPEvent::u, wtp_pdu::u, wap_addr_tuple_duplicate(), wap_event_create, wtp_pdu_append_tpi(), wtp_pdu_create(), wtp_pdu_destroy(), and wtp_pdu_pack().

Referenced by process_sar_transaction().

{
    WAPEvent *dgram = NULL;
    WTP_PDU *pdu;
    unsigned char cpsn = psn;
    
    pdu = wtp_pdu_create(Ack);
    pdu->u.Ack.con = 1;
    pdu->u.Ack.tidverify = ack_type;
    pdu->u.Ack.rid = 0;
    pdu->u.Ack.tid = send_tid(tid);

    wtp_pdu_append_tpi(pdu, 3, octstr_create_from_data((char*) &cpsn, 1));

    dgram = wap_event_create(T_DUnitdata_Req);
    dgram->u.T_DUnitdata_Req.addr_tuple = wap_addr_tuple_duplicate(address);
    dgram->u.T_DUnitdata_Req.user_data = wtp_pdu_pack(pdu);
    wtp_pdu_destroy(pdu);

    return dgram;
}

wtp_pack_sar_result()

WAPEvent* wtp_pack_sar_result	(	WTPRespMachine *	machine,
		int	psn
	)

Definition at line 167 of file wtp_pack.c.

References gw_assert(), octstr_copy, SAR_GROUP_LEN, SAR_SEGM_SIZE, send_tid(), WAPEvent::u, wtp_pdu::u, wap_addr_tuple_duplicate(), wap_event_create, wtp_pdu_create(), wtp_pdu_destroy(), and wtp_pdu_pack().

Referenced by begin_sar_result(), continue_sar_result(), and resend_sar_result().

{
    WAPEvent *dgram = NULL;
    WTP_PDU *pdu = NULL;
    Octstr *data = NULL;
    int gtr, ttr;

    gw_assert(machine->sar && machine->sar->data);

    if (psn > machine->sar->nsegm)
        return dgram;

    ttr = psn == machine->sar->nsegm ? 1 : 0;
    gtr = ttr ? 0 : (psn+1)%SAR_GROUP_LEN ? 0 : 1;

    if (gtr || ttr) 
        machine->sar->tr = 1;

    data = octstr_copy(machine->sar->data,psn*SAR_SEGM_SIZE,SAR_SEGM_SIZE);

    if (!psn) {
        pdu = wtp_pdu_create(Result);
        pdu->u.Result.con = 0;
        pdu->u.Result.gtr = gtr;
        pdu->u.Result.ttr = ttr;
        pdu->u.Result.rid = 0;
        pdu->u.Result.tid = send_tid(machine->tid);
        pdu->u.Result.user_data = data;
    } else {
        pdu = wtp_pdu_create(Segmented_result);
        pdu->u.Segmented_result.con = 0;
        pdu->u.Segmented_result.gtr = gtr;
        pdu->u.Segmented_result.ttr = ttr;
        pdu->u.Segmented_result.rid = 0;
        pdu->u.Segmented_result.tid = send_tid(machine->tid);
        pdu->u.Segmented_result.psn = psn;
        pdu->u.Segmented_result.user_data = data;
    }

    dgram = wap_event_create(T_DUnitdata_Req);
    dgram->u.T_DUnitdata_Req.addr_tuple =
        wap_addr_tuple_duplicate(machine->addr_tuple);
    dgram->u.T_DUnitdata_Req.user_data = wtp_pdu_pack(pdu);
    wtp_pdu_destroy(pdu);

    return dgram;
}

wtp_pack_set_rid()

void wtp_pack_set_rid	(	WAPEvent *	dgram,
		long	rid
	)

Definition at line 215 of file wtp_pack.c.

References gw_assert(), octstr_set_bits(), WAPEvent::type, and WAPEvent::u.

Referenced by resend_sar_result().

{
    gw_assert(dgram != NULL);
    gw_assert(dgram->type == T_DUnitdata_Req);

    octstr_set_bits(dgram->u.T_DUnitdata_Req.user_data, 7, 1, rid);
}