FreeCalypso > hg > fc-tourmaline
diff src/g23m-fad/ip/ip_kerp.c @ 1:fa8dc04885d8
src/g23m-*: import from Magnetite
| author | Mychaela Falconia <falcon@freecalypso.org> |
|---|---|
| date | Fri, 16 Oct 2020 06:25:50 +0000 |
| parents | |
| children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/g23m-fad/ip/ip_kerp.c Fri Oct 16 06:25:50 2020 +0000 @@ -0,0 +1,1237 @@ +/* ++---------------------------------------------------------------------------- +| Project : +| Modul : ++---------------------------------------------------------------------------- +| Copyright 2002 Texas Instruments Berlin, AG +| All rights reserved. +| +| This file is confidential and a trade secret of Texas +| Instruments Berlin, AG +| The receipt of or possession of this file does not convey +| any rights to reproduce or disclose its contents or to +| manufacture, use, or sell anything it may describe, in +| whole, or in part, without the specific written consent of +| Texas Instruments Berlin, AG. ++---------------------------------------------------------------------------- +| Purpose : This Modul defines the functions for processing +| of incomming primitives for the component +| Internet Protocol of the mobile station ++---------------------------------------------------------------------------- +*/ + +#define ENTITY_IP + +/*==== INCLUDES ===================================================*/ + +#include <string.h> +#include "typedefs.h" +#include "pconst.cdg" +#include "vsi.h" +#include "macdef.h" /* Get PFREE_DESC2 */ +#include "pconst.cdg" +#include "custom.h" +#include "gsm.h" +#include "cnf_ip.h" +#include "mon_ip.h" +#include "prim.h" +#include "pei.h" +#include "tok.h" +#include "ccdapi.h" + +#include "dti.h" /* To get DTI lib */ +#include "ip.h" +#include "ip_udp.h" + +/*==== CONST =======================================================*/ + +/*==== TYPES =======================================================*/ + +/*==== VAR EXPORT ==================================================*/ + +/*==== VAR LOCAL ===================================================*/ + +/*==== MACROS ======================================================*/ + +/*==== Prototypes ==================================================*/ + +/*==== FUNCTIONS ===================================================*/ + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP | +| STATE : code ROUTINE : ker_ipa_dti_req | ++--------------------------------------------------------------------+ + + PURPOSE : Process IPA_DTI_REQ primitive +*/ +void ker_ipa_dti_req (T_IPA_DTI_REQ * ipa_dti_req) +{ + T_KER * p_ker = & ip_data->ker; + BOOL confirm = TRUE; + UBYTE dti_conn = IPA_DISCONNECT_DTI; + + PACCESS (ipa_dti_req); + TRACE_FUNCTION ("ker_ipa_dti_req()"); + + switch (GET_STATE (KER)) { + case DEACTIVATED: + switch (ipa_dti_req->dti_conn) { + case IPA_CONNECT_DTI: + switch (ipa_dti_req->dti_direction) { + case IPA_DTI_TO_HIGHER_LAYER: + if (p_ker->entity_name_hl[0] EQ 0) + { + hCommHL = vsi_c_open ( + VSI_CALLER (char *) ipa_dti_req->entity_name + ); + if (hCommHL > VSI_OK) + { + p_ker->link_id_hl = ipa_dti_req->link_id; + strcpy ( + p_ker->entity_name_hl, + (char *) ipa_dti_req->entity_name + ); + SET_STATE (HILA, CONNECTING); + if (dti_open ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL, + IP_DTI_UPLINK_QUEUE_SIZE, + DTI_CHANNEL_TO_HIGHER_LAYER, + FLOW_CNTRL_ENABLED, + DTI_VERSION_10, + (U8 *) ipa_dti_req->entity_name, + ipa_dti_req->link_id + ) == TRUE) + { + confirm = FALSE; + } + else + { /* dti_open failed, close vsi handle */ + vsi_c_close (VSI_CALLER hCommHL); + hCommHL = VSI_ERROR; + } + } + } + else + { + TRACE_ERROR ("DTI link to higher layer already requested"); + } + break; + case IPA_DTI_TO_LOWER_LAYER: + if (p_ker->entity_name_ll[0] EQ 0) + { + p_ker->link_id_ll = ipa_dti_req->link_id; + strcpy ( + p_ker->entity_name_ll, + (char *) ipa_dti_req->entity_name + ); + SET_STATE (LOLA, CONNECTING); + if (dti_open ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL, + IP_DTI_DOWNLINK_QUEUE_SIZE, + DTI_CHANNEL_TO_LOWER_LAYER, + FLOW_CNTRL_ENABLED, + DTI_VERSION_10, + (U8 *) ipa_dti_req->entity_name, + ipa_dti_req->link_id + ) == TRUE) + { + confirm = FALSE; + } + } + else + { + TRACE_ERROR ("DTI link to lower layer already requested"); + } + break; + default: + TRACE_ERROR ("illegal parameter (ipa_dti_req->dti_direction)"); + } /* End "switch (ipa_dti_req->dti_direction)" */ + dti_conn = IPA_DISCONNECT_DTI; + break; + case IPA_DISCONNECT_DTI: + if (p_ker->link_id_hl == ipa_dti_req->link_id) + { + dti_close ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL, + FALSE + ); + p_ker->link_id_hl = IPA_LINK_ID_DEFAULT; + p_ker->entity_name_hl[0] = '\0'; + vsi_c_close (VSI_CALLER hCommHL); + hCommHL = VSI_ERROR; + SET_STATE (HILA, DOWN); + dti_conn = IPA_DISCONNECT_DTI; + /*XXX check for remaining UP/DOWN-LINK DTI connections, XXX*/ + /*XXX terminate_ip() if nothing left open XXX*/ + } + else if (p_ker->link_id_ll == ipa_dti_req->link_id) + { + dti_close ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL, + FALSE + ); + p_ker->link_id_ll = IPA_LINK_ID_DEFAULT; + p_ker->entity_name_ll[0] = '\0'; + SET_STATE (LOLA, DOWN); + dti_conn = IPA_DISCONNECT_DTI; + /*XXX check for remaining UP/DOWN-LINK DTI connections, XXX*/ + /*XXX terminate_ip() if nothing left open XXX*/ + } + else + { + TRACE_ERROR ("illegal parameter (ipa_dti_req->dti_conn)"); + dti_conn = IPA_CONNECT_DTI; + } + break; + } /* End "switch (ipa_dti_req->dti_conn)" */ + break; + case ACTIVE_NC: + switch (ipa_dti_req->dti_conn) { + case IPA_DISCONNECT_DTI: + if (p_ker->link_id_hl == ipa_dti_req->link_id) + { + dti_close ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL, + FALSE + ); + p_ker->link_id_hl = IPA_LINK_ID_DEFAULT; + p_ker->entity_name_hl[0] = '\0'; + vsi_c_close (VSI_CALLER hCommHL); + hCommHL = VSI_ERROR; + SET_STATE (HILA, DOWN); + dti_conn = IPA_DISCONNECT_DTI; + SET_STATE (KER, DEACTIVATED); + } + else if (p_ker->link_id_ll == ipa_dti_req->link_id) + { + dti_close ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL, + FALSE + ); + p_ker->link_id_ll = IPA_LINK_ID_DEFAULT; + p_ker->entity_name_ll[0] = '\0'; + SET_STATE (LOLA, DOWN); + dti_conn = IPA_DISCONNECT_DTI; + SET_STATE (KER, DEACTIVATED); + } + break; + default: + TRACE_ERROR ("unexpected parameter (ipa_dti_req->dti_conn)"); + dti_conn = IPA_DISCONNECT_DTI; + break; + } /* End "switch (ipa_dti_req->dti_conn)" */ + break; + case CONNECTED: + default: + TRACE_ERROR ("unexpected IPA_DTI_REQ"); + if (ipa_dti_req->dti_conn == IPA_CONNECT_DTI) + dti_conn = IPA_DISCONNECT_DTI; + else + dti_conn = IPA_CONNECT_DTI; + break; + } /* End "switch (GET_STATE (KER))" */ + + if (confirm) + { + PALLOC (ipa_dti_cnf, IPA_DTI_CNF); + ipa_dti_cnf->dti_conn = dti_conn; + ipa_dti_cnf->link_id = ipa_dti_req->link_id; + PSENDX (MMI, ipa_dti_cnf); + } + PFREE (ipa_dti_req); +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP | +| STATE : code ROUTINE : sig_dti_ker_connection_opened_hl_ind | ++--------------------------------------------------------------------+ + + PURPOSE : Process signal SIG_DTI_KER_CONNECTION_OPENED_HL_IND +*/ +void sig_dti_ker_connection_opened_hl_ind () +{ + T_KER * p_ker = & ip_data->ker; + + TRACE_FUNCTION ("sig_dti_ker_connection_opened_hl_ind()"); + + if (GET_STATE (HILA) EQ CONNECTING) + { + SET_STATE (HILA, IDLE); + switch (GET_STATE (LOLA)) { + case IDLE: + case SEND: + case WAIT: + SET_STATE (KER, ACTIVE_NC); + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + break; + default: + break; + } + { + PALLOC (ipa_dti_cnf, IPA_DTI_CNF); + ipa_dti_cnf->link_id = p_ker->link_id_hl; + ipa_dti_cnf->dti_conn = IPA_CONNECT_DTI; + PSENDX (MMI, ipa_dti_cnf); + } + } else { + TRACE_ERROR ("unexpected dti_connect_ind (from higher layer)"); + } +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP | +| STATE : code ROUTINE : sig_dti_ker_connection_opened_ll_ind | ++--------------------------------------------------------------------+ + + PURPOSE : Process signal SIG_DTI_KER_CONNECTION_OPENED_LL_IND +*/ +void sig_dti_ker_connection_opened_ll_ind () +{ + T_KER * p_ker = & ip_data->ker; + + TRACE_FUNCTION ("sig_dti_ker_connection_opened_ll_ind()"); + + if (GET_STATE (LOLA) EQ CONNECTING) + { + SET_STATE (LOLA, IDLE); + switch (GET_STATE (HILA)) { + case IDLE: + case SEND: + case WAIT: + SET_STATE (KER, ACTIVE_NC); + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + break; + default: + break; + } + { + PALLOC (ipa_dti_cnf, IPA_DTI_CNF); + ipa_dti_cnf->link_id = p_ker->link_id_ll; + ipa_dti_cnf->dti_conn = IPA_CONNECT_DTI; + PSENDX (MMI, ipa_dti_cnf); + } + } else { + TRACE_ERROR ("unexpected dti_connect_ind (from lower layer)"); + } +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP | +| STATE : code ROUTINE : sig_dti_ker_connection_closed_hl_ind | ++--------------------------------------------------------------------+ + + PURPOSE : Process signal SIG_DTI_KER_CONNECTION_CLOSED_HL_IND +*/ +void sig_dti_ker_connection_closed_hl_ind () +{ + T_KER * p_ker = & ip_data->ker; + + TRACE_FUNCTION ("sig_dti_ker_connection_closed_hl_ind()"); + + SET_STATE (HILA, DOWN); + + switch (GET_STATE (KER)) { + case CONNECTED: + /*XXX bad case, switch to DEACTIVATED, prune buffers ... XXX*/ + TRACE_ERROR ("unexpected DTI connection close by peer (UPLINK)"); + SET_STATE (KER, DEACTIVATED); + break; + case ACTIVE_NC: + SET_STATE (KER, DEACTIVATED); + break; + default: + break; + } /* End "switch (GET_STATE (KER))" */ + + { + PALLOC (ipa_dti_ind, IPA_DTI_IND); + ipa_dti_ind->link_id = p_ker->link_id_hl; + p_ker->link_id_hl = IPA_LINK_ID_DEFAULT; + vsi_c_close (VSI_CALLER hCommHL); + hCommHL = VSI_ERROR; + p_ker->entity_name_hl[0] = '\0'; + PSENDX (MMI, ipa_dti_ind); + } +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP | +| STATE : code ROUTINE : sig_dti_ker_connection_closed_ll_ind | ++--------------------------------------------------------------------+ + + PURPOSE : Process signal SIG_DTI_KER_CONNECTION_CLOSED_LL_IND +*/ +void sig_dti_ker_connection_closed_ll_ind () +{ + T_KER * p_ker = & ip_data->ker; + + TRACE_FUNCTION ("sig_dti_ker_connection_closed_ll_ind()"); + + /* Caution!!! this return is absolut necessary for WAP over GPRS. Otherwise IP will + close itself after SNDCP went down. Unfortunately not everything is deinitialized and + IP will never come up on subsequent activation requests (eg. p_ker->entity_name_ll[0] + is not wiped). Since the Dti-Manager of ACI closes each DTI-Connection itself, we can + suspend this automatism for now */ + /* return; out-commented at the moment: jk */ + + /* If this automatism is re-enabled at least the following lines are necessary + and were missing in previous versions!!! But at least we should not store an indication + of an connected peer inside the p_ker->entity_name_ll ... */ + + /* p_ker->link_id_ll = IPA_LINK_ID_DEFAULT; out-commented at the moment: jk */ + /* p_ker->entity_name_ll[0] = '\0'; out-commented at the moment: jk */ + /* SET_STATE (LOLA, DOWN); out-commented at the moment: jk */ + + switch (GET_STATE (KER)) { + case CONNECTED: + /*XXX bad case, switch to DEACTIVATED, prune buffers ... XXX*/ + TRACE_ERROR ("unexpected DTI connection close by peer (DOWNLINK)"); + SET_STATE (KER, DEACTIVATED); + break; + case ACTIVE_NC: + SET_STATE (KER, DEACTIVATED); + break; + default: + break; + } /* End "switch (GET_STATE (KER))" */ + + { + PALLOC (ipa_dti_ind, IPA_DTI_IND); + + ipa_dti_ind->link_id = p_ker->link_id_ll; /* Initialize the only one parameter of the prim */ + p_ker->link_id_ll = IPA_LINK_ID_DEFAULT; /* Set the state of the entity properly */ + p_ker->entity_name_ll[0] = '\0'; + SET_STATE (LOLA, DOWN); + SET_STATE (KER, DEACTIVATED); + + PSENDX (MMI, ipa_dti_ind); /* Send indication to the MMI */ + } +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP | +| STATE : code ROUTINE : sig_dti_ker_tx_buffer_full_ll_ind | ++--------------------------------------------------------------------+ + + PURPOSE : Process signal SIG_DTI_KER_TX_BUFFER_FULL_LL_IND +*/ +void sig_dti_ker_tx_buffer_full_ll_ind () +{ + TRACE_FUNCTION ("sig_dti_ker_tx_buffer_full_ll_ind()"); +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP +| STATE : code ROUTINE : sig_dti_ker_tx_buffer_full_hl_ind | ++--------------------------------------------------------------------+ + + PURPOSE : Process signal SIG_DTI_KER_TX_BUFFER_FULL_HL_IND +*/ +void sig_dti_ker_tx_buffer_full_hl_ind () +{ + TRACE_FUNCTION ("sig_dti_ker_tx_buffer_full_hl_ind()"); +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP | +| STATE : code ROUTINE : ker_ipa_config_req | ++--------------------------------------------------------------------+ + + PURPOSE : Process primitive IPA_CONFIG_REQ received from ACI +*/ +void ker_ipa_config_req (T_IPA_CONFIG_REQ * ipa_config_req) +{ + T_KER * p_ker = & ip_data->ker; + PALLOC (ipa_config_cnf, IPA_CONFIG_CNF); + + TRACE_FUNCTION ("ker_ipa_config_req()"); + + PACCESS (ipa_config_req); + + switch (GET_STATE (KER)) { + case DEACTIVATED: + ipa_config_cnf->ack_flag = IPA_CONFIG_NAK; + ipa_config_cnf->all_down = IPA_ALLDOWN_TRUE; + break; + case ACTIVE_NC: + switch (ipa_config_req->cmd) { + case IPA_CONFIG_UP: + p_ker->source_addr= ipa_config_req->ip; + p_ker->peer_addr = ipa_config_req->peer_ip; + p_ker->mtu = ipa_config_req->mtu; + SET_STATE (KER, CONNECTED); + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + ipa_config_cnf->ack_flag = IPA_CONFIG_ACK; + ipa_config_cnf->all_down = IPA_ALLDOWN_FALSE; + break; + case IPA_CONFIG_DOWN: + ipa_config_cnf->ack_flag = IPA_CONFIG_NAK; + ipa_config_cnf->all_down = IPA_ALLDOWN_TRUE; + break; + } + break; + case CONNECTED: + switch (ipa_config_req->cmd) { + case IPA_CONFIG_UP: + ipa_config_cnf->ack_flag = IPA_CONFIG_NAK; + ipa_config_cnf->all_down = IPA_ALLDOWN_FALSE; + break; + case IPA_CONFIG_DOWN: + /*XXX prune buffers + config data XXX*/ + SET_STATE (KER, ACTIVE_NC); + ipa_config_cnf->ack_flag = IPA_CONFIG_ACK; + ipa_config_cnf->all_down = IPA_ALLDOWN_TRUE; + config_down_ll (); + break; + } + break; + } /* End "switch (GET_STATE (KER))" */ + + PSENDX (MMI, ipa_config_cnf); + PFREE (ipa_config_req); +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : IP_KERP | +| STATE : code ROUTINE : ker_ip_addr_req | ++--------------------------------------------------------------------+ + + PURPOSE : Process primitive IP_ADDR_REQ received from higher layer +*/ +void ker_ip_addr_req (T_IP_ADDR_REQ * ip_addr_req) +{ + T_KER * p_ker = & ip_data->ker; + + TRACE_FUNCTION ("ker_ip_addr_req()"); + + PACCESS (ip_addr_req); + + switch (GET_STATE (KER)) { + case DEACTIVATED: + if (GET_STATE (HILA) NEQ DOWN) + { + PALLOC (ip_addr_cnf, IP_ADDR_CNF); + ip_addr_cnf->src_addr = p_ker->source_addr; + ip_addr_cnf->err = IP_ADDR_NOROUTE; + ip_addr_cnf->trans_prot = ip_addr_req->trans_prot; + PSENDX (HL, ip_addr_cnf); + } + else + { + TRACE_ERROR ("IP_ADDR_REQ received but no higher layer known"); + } + break; + case ACTIVE_NC: + { + PALLOC (ip_addr_cnf, IP_ADDR_CNF); + ip_addr_cnf->src_addr = p_ker->source_addr; + ip_addr_cnf->err = IP_ADDR_NOROUTE; + ip_addr_cnf->trans_prot = ip_addr_req->trans_prot; + PSENDX (HL, ip_addr_cnf); + } + break; + case CONNECTED: + { + PALLOC (ip_addr_cnf, IP_ADDR_CNF); + ip_addr_cnf->src_addr = p_ker->source_addr; + ip_addr_cnf->err = IP_ADDR_NOERROR; + ip_addr_cnf->trans_prot = ip_addr_req->trans_prot; + PSENDX (HL, ip_addr_cnf); + } + break; + } /* End "switch (GET_STATE (KER))" */ + + PFREE (ip_addr_req); +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : ip_kerp.c | +| STATE : code ROUTINE : sig_dti_ker_data_received_hl_ind | ++--------------------------------------------------------------------+ + + UDP + | + V + IP + + PURPOSE : Process signal SIG_DTI_KER_DATA_RECEIVED_HL_IND +*/ +void sig_dti_ker_data_received_hl_ind (T_DTI2_DATA_REQ * dti_data_req) +{ + T_HILA * p_hl = & ip_data->hila; + T_KER * p_ker = & ip_data->ker; + BOOL dest_addresses[MAX_ADDR_TYPES]; + BOOL src_addresses[MAX_ADDR_TYPES]; + BOOL send_ready = FALSE; + + TRACE_FUNCTION ("sig_dti_ker_data_received_hl_ind()"); + + if (dti_data_req == NULL) + return; + + PACCESS (dti_data_req); + + switch (GET_STATE (KER)) { + case DEACTIVATED: + case ACTIVE_NC: /* Fall through */ + PFREE_DESC2 (dti_data_req); + break; + case CONNECTED: + if (ip_packet_validator (& dti_data_req->desc_list2)) + { + T_desc_list2 * desc_list; + T_desc2 * desc; + UBYTE * ip_header, to_do; + USHORT packet_len; + + p_hl->dti_data_req = dti_data_req; + desc_list = & p_hl->dti_data_req->desc_list2; + desc = (T_desc2 *) desc_list->first; + ip_header = desc->buffer; + to_do = B_NORMAL_PACKET; + + dti_stop ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + + /* Check destination and source address */ + { + ULONG dest_addr = GET_IP_DEST_ADDR (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + check_ip_address ( + dest_addresses, + src_addresses, + dest_addr, + p_ker->source_addr + ); + if (src_addresses[BAD_UL_SRC_ADDR] OR dest_addresses[BAD_UL_DEST_ADDR]) + p_hl->drop_packet = TRUE; + } + + /* Check if ICMP message from higher layer and build the ICMP packet */ + if ((GET_IP_PROT (ip_header) EQ ICMP_PROT) AND (! p_hl->drop_packet))/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + build_ip_packet (TRUE, B_ICMP_PACKET); + + /* Check if fragmenting necessary - build the fragment */ + packet_len = p_hl->dti_data_req->desc_list2.list_len; + + if ((packet_len > p_ker->mtu) AND (! p_hl->drop_packet)) + { + to_do = B_SEGMENT; + build_ip_packet (TRUE, to_do); + } + + /* Build "normal" IP packet */ + if ((to_do EQ B_NORMAL_PACKET) AND (! p_hl->drop_packet)) + build_ip_packet (TRUE, to_do); + + /* Check if ICMP message is to be send */ + if ((p_ker->send_icmp) AND (GET_STATE (HILA) EQ WAIT)) + { + T_DTI2_DATA_REQ * data_req = p_ker->icmp_dti_data_req; + data_req->parameters.p_id = DTI_PID_IP; + data_req->parameters.st_lines.st_flow = DTI_FLOW_ON; + data_req->parameters.st_lines.st_line_sa = DTI_SA_ON; + data_req->parameters.st_lines.st_line_sb = DTI_SB_ON; + data_req->parameters.st_lines.st_break_len = DTI_BREAK_OFF; + + { + PPASS (data_req, dti_data_ind, DTI2_DATA_IND); + dti_send_data ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL, + dti_data_ind + ); + } + SET_STATE (HILA, IDLE); + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + } + + /* Bad packet - drop */ + if (p_hl->drop_packet) + { + p_hl->drop_packet = FALSE; + PFREE_DESC2 (p_hl->dti_data_req); + send_ready = TRUE; + } + else + { + if (GET_STATE (HILA) EQ WAIT) + { + /* Send dti2_data_req */ + dti_data_req->parameters.p_id = DTI_PID_IP; + dti_data_req->parameters.st_lines.st_flow = DTI_FLOW_ON; + dti_data_req->parameters.st_lines.st_line_sa = DTI_SA_ON; + dti_data_req->parameters.st_lines.st_line_sb = DTI_SB_ON; + dti_data_req->parameters.st_lines.st_break_len = DTI_BREAK_OFF; + + PACCESS (dti_data_req); + { + PPASS (dti_data_req, dti_data_ind, DTI2_DATA_IND); + dti_send_data ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL, + dti_data_ind + ); + } + p_hl->dti_data_req = NULL; + if (p_hl->state_segment EQ NO_SEGMENTS) + { + SET_STATE (HILA, IDLE); + send_ready = TRUE; + } + else + { + /* When the ready_ind is received, we don't know whether + * the first segment has been sent or not (state is sent + * in any case), so we don't know whether we have to transmit + * the first or to build the next one. To avoid the problem + * we build the next packet here. */ + build_ip_packet (TRUE, B_SEGMENT); + SET_STATE (HILA, SEND); + send_ready = FALSE; + } + } + else + { + SET_STATE (HILA, SEND); + } + } + /* Send ready indication to higher layer */ + if (send_ready) + { + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + } + } + else + { + PFREE_DESC2 (dti_data_req); + } + break; + } /* End "switch (GET_STATE (KER))" */ +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : ip_kerp.c | +| STATE : code ROUTINE : sig_dti_ker_data_received_ll_ind | ++--------------------------------------------------------------------+ + + IP + ^ + | + PPP + + PURPOSE : Process signal SIG_DTI_KER_DATA_RECEIVED_LL_IND +*/ +void sig_dti_ker_data_received_ll_ind (T_DTI2_DATA_IND * dti_data_ind) +{ + T_LOLA * p_ll = & ip_data->lola; + T_KER * p_ker = & ip_data->ker; + + TRACE_FUNCTION ("sig_dti_ker_data_received_ll_ind()"); + + if (dti_data_ind == NULL) + return; + + PACCESS (dti_data_ind); + + switch (GET_STATE (KER)) { + case DEACTIVATED: + case ACTIVE_NC: /* Fall through */ + PFREE_DESC2 (dti_data_ind); + break; + case CONNECTED: + if (ip_packet_validator (& dti_data_ind->desc_list2)) + { + BOOL send_getdata_req; + T_desc_list2 * desc_list; + T_desc2 * desc; + UBYTE * ip_header, to_do, ip_prot; + USHORT header_len_b; + USHORT header_chksum, chksum; + ULONG source_addr, dest_addr; + BOOL dest_addresses[MAX_ADDR_TYPES]; + BOOL src_addresses[MAX_ADDR_TYPES]; + + send_getdata_req = FALSE; + p_ll->dti_data_ind = dti_data_ind; + desc_list = & p_ll->dti_data_ind->desc_list2; + desc = (T_desc2 *) desc_list->first; + ip_header = desc->buffer; + to_do = BUILD_NO_PACKET; + header_len_b = (USHORT) GET_IP_HEADER_LEN_B (ip_header); + source_addr = p_ker->source_addr; + ip_prot = GET_IP_PROT (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + + /* Check IP protocol */ + if (GET_IP_VERSION (ip_header) NEQ IP_VERSION) + p_ll->drop_packet = TRUE; + else + { + UBYTE chk_len_ind; + USHORT desc_len; + + /* Check the datagram length */ + chk_len_ind = chk_packet_len (ip_header, desc_list); + + if (chk_len_ind NEQ NO_ERROR) + { + /* Datagram > length indicated in header - truncate */ + if (chk_len_ind EQ CHANGE_PACKET_LEN) + { + desc_len = (USHORT) GET_IP_TOTAL_LEN (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + truncate_descs (desc_list, desc_len); + } + else + p_ll->drop_packet = TRUE; + } + } + + /* Checksum */ + if (! p_ll->drop_packet) + { + desc = (T_desc2 *) desc_list->first; + header_chksum = (USHORT) GET_IP_CHECKSUM (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + RESET_IP_CHECKSUM (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + chksum = inet_checksum (ip_header, header_len_b); + SET_IP_CHECKSUM (ip_header, chksum);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + if (header_chksum NEQ chksum) + { + p_ll->drop_packet = TRUE; + TRACE_EVENT ("header checksum error indicated") ; + } + } + + /* Check destination address and source address */ + if (! p_ll->drop_packet) + { + dest_addr = GET_IP_DEST_ADDR (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + check_ip_address ( + dest_addresses, + src_addresses, + dest_addr, + source_addr + ); + if (src_addresses[BAD_DL_SRC_ADDR] OR dest_addresses[BAD_DL_DEST_ADDR]) + p_ll->drop_packet = TRUE; + + if (dest_addresses[NO_DEST_ADDR]) + { + /* Send ICMP message if the IP address is ok and + * we have not got more than one segment. */ + if ( + (ip_prot EQ ICMP_PROT) OR + (p_ll->state_reassembly[p_ll->pos_server] EQ READ_SEGMENT) OR + dest_addresses[LINK_LAYER_BCAST] OR + dest_addresses[BCAST_ADDR_255] OR + src_addresses[BCAST_ADDR_255] OR + src_addresses[MCAST_ADDR] OR + src_addresses[NETW_ADDR] OR + src_addresses[LOOP_BACK_ADDR] OR + src_addresses[CLASS_E_ADDR] + ) + p_ll->drop_packet = TRUE; + else + { + to_do = B_ICMP_NO_FORWARD; + p_ker->send_icmp = TRUE; + } + } + } + + /* Check fragmenting */ + if ((! p_ll->drop_packet) AND (to_do NEQ B_ICMP_NO_FORWARD)) + { + BOOL df_flag, mf_flag; + USHORT fragm_offset; + BOOL first_segment, middle_segment, last_segment; + + df_flag = GET_IP_DF_FLAG (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + mf_flag = GET_IP_MF_FLAG (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + + fragm_offset = (USHORT) GET_IP_FRAG_OFFSET (ip_header);/*lint !e415 !e416 (Warning -- access/creation of out-of-bounds pointer) */ + first_segment = + (df_flag EQ FLAG_NOT_SET) AND + (mf_flag EQ FLAG_SET) AND + (fragm_offset EQ 0); + middle_segment = + (df_flag EQ FLAG_NOT_SET) AND + (mf_flag EQ FLAG_SET) AND + (fragm_offset > 0); + last_segment = + (df_flag EQ FLAG_NOT_SET) AND + (mf_flag EQ FLAG_NOT_SET) AND + (fragm_offset > 0); + + if (first_segment OR middle_segment OR last_segment) + + /* Filter out ICMP fragments - not supported */ + if (ip_prot EQ ICMP_PROT) + p_ll->drop_packet = TRUE; + else + /* Start reassemble fragments */ + reassemble_fragments ( + & p_ll->dti_data_ind, + p_ll, + ip_header, + first_segment, + /* middle_segment, */ + last_segment /*,*/ + /* fragm_offset */ + ); + } + + /* Incoming ICMP message */ + if (! p_ll->drop_packet) + if (ip_prot EQ ICMP_PROT) + if (GET_ICMP_TYPE (ip_header, header_len_b) EQ ICMP_TYP_ECHO) + { + to_do = B_ICMP_ECHO_REPLY; + p_ker->send_icmp = TRUE; + } + + /* Build selected packets */ + if ((! p_ll->drop_packet) AND (to_do NEQ BUILD_NO_PACKET)) + build_ip_packet (FALSE, to_do); + + /* Skip by reading fragments - only send dti_getdata_req */ + if (p_ll->state_reassembly[p_ll->pos_server] EQ READ_SEGMENT) + send_getdata_req = TRUE; + + /* Drop packet and free resources */ + else if (p_ll->drop_packet) + { + p_ll->drop_packet = FALSE; + PFREE_DESC2 (p_ll->dti_data_ind); + p_ll->dti_data_ind = NULL; + send_getdata_req = TRUE; + } + else + { + /* Send an ICMP message first */ + if (p_ker->send_icmp EQ TRUE) + { + if (GET_STATE (HILA) EQ WAIT) + { + T_DTI2_DATA_REQ * data_req; + p_ker->send_icmp = FALSE; + + data_req = p_ker->icmp_dti_data_req; + data_req->parameters.p_id = DTI_PID_IP; + data_req->parameters.st_lines.st_flow = DTI_FLOW_ON; + data_req->parameters.st_lines.st_line_sa = DTI_SA_ON; + data_req->parameters.st_lines.st_line_sb = DTI_SB_ON; + data_req->parameters.st_lines.st_break_len = DTI_BREAK_OFF; + + PACCESS (data_req); + { + PPASS (data_req, dti_data_indication, DTI2_DATA_IND); + dti_send_data ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL, + dti_data_indication + ); + SET_STATE (HILA, IDLE); + p_ker->send_icmp = FALSE; + p_ker->icmp_dti_data_req = NULL; + send_getdata_req = TRUE; /*XXX not clear to me XXX*/ + } + } + } + else + { + /* Check we are not in the middle of a reassembly process */ + if (p_ll->state_reassembly[p_ll->pos_server] EQ NO_SEGMENTS) + { + if (GET_STATE (LOLA) EQ WAIT) + { + T_DTI2_DATA_IND * data_ind; + + SET_STATE (LOLA, IDLE); + + data_ind = p_ll->dti_data_ind; + data_ind->parameters.p_id = DTI_PID_IP; + data_ind->parameters.st_lines.st_flow = DTI_FLOW_ON; + data_ind->parameters.st_lines.st_line_sa = DTI_SA_ON; + data_ind->parameters.st_lines.st_line_sb = DTI_SB_ON; + data_ind->parameters.st_lines.st_break_len = DTI_BREAK_OFF; + dti_send_data ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL, + data_ind + ); + p_ll->dti_data_ind = NULL; + + send_getdata_req = TRUE; + } + else + { + SET_STATE (LOLA, SEND); + } + } + } + } + + if (send_getdata_req) + { + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + } + } + else + { + PFREE_DESC2 (dti_data_ind); + } + break; + } /* End "switch (GET_STATE (KER))" */ +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : ip_kerp.c | +| STATE : code ROUTINE : sig_dti_ker_tx_buffer_ready_ll_ind | ++--------------------------------------------------------------------+ + + "DTI2_READY_IND received" + PURPOSE : Process signal SIG_DTI_KER_TX_BUFFER_READY_LL_IND +*/ +void sig_dti_ker_tx_buffer_ready_ll_ind () +{ + T_HILA * p_hl = & ip_data->hila; + T_KER * p_ker = & ip_data->ker; + BOOL send_ready = FALSE; + + TRACE_FUNCTION ("sig_dti_ker_tx_buffer_ready_ll_ind()"); + + switch (GET_STATE (KER)) { + case DEACTIVATED: + case ACTIVE_NC: /* Fall through */ + SET_STATE (HILA, WAIT); + break; + case CONNECTED: + { + /* Check if ICMP message */ + if (p_ker->send_icmp) + { + T_DTI2_DATA_REQ * dti_data_req; + p_ker->send_icmp = FALSE; + dti_data_req = p_ker->icmp_dti_data_req; + dti_data_req->parameters.p_id = DTI_PID_IP; + dti_data_req->parameters.st_lines.st_flow = DTI_FLOW_ON; + dti_data_req->parameters.st_lines.st_line_sa = DTI_SA_ON; + dti_data_req->parameters.st_lines.st_line_sb = DTI_SB_ON; + dti_data_req->parameters.st_lines.st_break_len = DTI_BREAK_OFF; + + PACCESS (dti_data_req); + { + PPASS (dti_data_req, dti_data_ind, DTI2_DATA_IND); + dti_send_data ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL, + dti_data_ind + ); + } + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + p_ker->send_icmp = FALSE; + p_ker->icmp_dti_data_req = NULL; + } + else if (GET_STATE (HILA) EQ SEND) + { + /* Send waiting data packet */ + p_hl->dti_data_req->parameters.p_id = DTI_PID_IP; + p_hl->dti_data_req->parameters.st_lines.st_flow = DTI_FLOW_ON; + p_hl->dti_data_req->parameters.st_lines.st_line_sa = DTI_SA_ON; + p_hl->dti_data_req->parameters.st_lines.st_line_sb = DTI_SB_ON; + p_hl->dti_data_req->parameters.st_lines.st_break_len = DTI_BREAK_OFF; + + PACCESS (p_hl->dti_data_req); + { + PPASS (p_hl->dti_data_req, dti_data_ind, DTI2_DATA_IND); + dti_send_data ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL, + dti_data_ind + ); + } + p_hl->dti_data_req = NULL; + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + p_hl->dti_data_req = NULL; + + /* Check if fragmenting - stay in the same state */ + if (p_hl->state_segment EQ NO_SEGMENTS) + { + SET_STATE (HILA, IDLE); + send_ready = TRUE; + } + else + { + /* Fragmentation -> build next packet */ + build_ip_packet (TRUE, B_SEGMENT); + if (p_hl->drop_packet) + { + p_hl->drop_packet = FALSE; + PFREE_DESC2 (p_hl->dti_data_req); + SET_STATE (HILA, IDLE); + send_ready = TRUE; + } + } + if (send_ready) + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + } + else + { + SET_STATE (HILA, WAIT); + } + } + break; + } /* End "switch (GET_STATE (KER))" */ +} + +/* ++--------------------------------------------------------------------+ +| PROJECT : WAP MODULE : ip_kerp.c | +| STATE : code ROUTINE : sig_dti_ker_tx_buffer_ready_hl_ind | ++--------------------------------------------------------------------+ + + "DTI2_GETDATA_REQ received" + PURPOSE : Process signal SIG_DTI_KER_TX_BUFFER_READY_HL_IND +*/ +void sig_dti_ker_tx_buffer_ready_hl_ind () +{ + T_LOLA * p_ll = & ip_data->lola; + + TRACE_FUNCTION ("sig_dti_ker_tx_buffer_ready_hl_ind()"); + + switch (GET_STATE (KER)) { + case DEACTIVATED: + case ACTIVE_NC: /* Fall through */ + /*XXX ???? XXX*/ + break; + case CONNECTED: + { + /* state_send - primitive can be sended */ + if (GET_STATE (LOLA) EQ SEND) + { + SET_STATE (LOLA, IDLE); + p_ll->dti_data_ind->parameters.p_id = DTI_PID_IP; + p_ll->dti_data_ind->parameters.st_lines.st_flow = DTI_FLOW_ON; + p_ll->dti_data_ind->parameters.st_lines.st_line_sa = DTI_SA_ON; + p_ll->dti_data_ind->parameters.st_lines.st_line_sb = DTI_SB_ON; + p_ll->dti_data_ind->parameters.st_lines.st_break_len = DTI_BREAK_OFF; + + dti_send_data ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_HL_INTERFACE, + IP_DTI_DEF_CHANNEL, + p_ll->dti_data_ind + ); + p_ll->dti_data_ind = NULL; + + /* Send DTI2_GETDATA_REQ and indicate ready for new packet */ + dti_start ( + ip_hDTI, + IP_DTI_DEF_INSTANCE, + IP_DTI_LL_INTERFACE, + IP_DTI_DEF_CHANNEL + ); + SET_STATE (LOLA, IDLE); + } + else + { + SET_STATE (LOLA, WAIT); + } + } + break; + } /* End "switch (GET_STATE (KER))" */ +} + +/*-------------------------------------------------------------------------*/ +