FreeCalypso > hg > fc-tourmaline
diff src/g23m-fad/tcpip/tcpip_pei.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/tcpip/tcpip_pei.c Fri Oct 16 06:25:50 2020 +0000 @@ -0,0 +1,452 @@ +/* ++------------------------------------------------------------------------------ +| File: tcpip_pei.c ++------------------------------------------------------------------------------ +| 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 module implements the PEI interface +| for the entity TCPIP. ++----------------------------------------------------------------------------- +*/ + +#define TCPIP_PEI_C + +#define ENTITY_TCPIP + +/*==== INCLUDES =============================================================*/ + +#include "typedefs.h" /* to get Condat data types */ +#include "vsi.h" /* to get a lot of macros */ +#include "custom.h" +#include "gsm.h" /* to get a lot of macros */ +#include "prim.h" /* to get the definitions of used SAP and directions */ +#include "pei.h" /* to get PEI interface */ +#include "tools.h" /* to get common tools */ +#include "dti.h" /* For DTI library definitions. */ +#include "tcpip.h" /* to get the global entity definitions */ +#define RNET_CFG_REAL_TRANSPORT +#include "rnet_api.h" +#include "rnet_rt_env.h" +#include "rv_general.h" +#include "rnet_rt_i.h" +#include <ngip/if.h> +#include "string.h" +#include "stdio.h" + +T_RNET_DESC *desc; + +/*==== CONSTS ================================================================*/ + +#define TCPIP_STACK_SIZE 2048 +#define TCPIP_QUEUE_SIZE 15 +#define TCPIP_PRIORITY 80 +#define TCPIP_NUM_TIMER 1 + +#define PRIM_OFFSET_DTI2 0x50 /* We must subtract this from the DTI2 + * opcodes. No, I don't know why. And, to be + * honest, I do not really care. */ + +/*==== TYPES =================================================================*/ + +/*==== LOCALS ================================================================*/ + +static BOOL first_access = TRUE; + +static const T_FUNC tcpip_table[] = +{ + MAK_FUNC_0(tcpip_initialize_req, TCPIP_INITIALIZE_REQ), + MAK_FUNC_0(tcpip_shutdown_req, TCPIP_SHUTDOWN_REQ), + MAK_FUNC_0(tcpip_ifconfig_req, TCPIP_IFCONFIG_REQ), + MAK_FUNC_0(tcpip_dti_req, TCPIP_DTI_REQ), + MAK_FUNC_0(tcpip_create_req, TCPIP_CREATE_REQ), + MAK_FUNC_0(tcpip_close_req, TCPIP_CLOSE_REQ), + MAK_FUNC_0(tcpip_bind_req, TCPIP_BIND_REQ), + MAK_FUNC_0(tcpip_listen_req, TCPIP_LISTEN_REQ), + MAK_FUNC_0(tcpip_connect_req, TCPIP_CONNECT_REQ), + MAK_FUNC_0(tcpip_data_req, TCPIP_DATA_REQ), + MAK_FUNC_0(tcpip_data_res, TCPIP_DATA_RES), + MAK_FUNC_0(tcpip_sockname_req, TCPIP_SOCKNAME_REQ), + MAK_FUNC_0(tcpip_peername_req, TCPIP_PEERNAME_REQ), + MAK_FUNC_0(tcpip_hostinfo_req, TCPIP_HOSTINFO_REQ), + MAK_FUNC_0(tcpip_mtu_size_req, TCPIP_MTU_SIZE_REQ), + MAK_FUNC_0(tcpip_internal_ind, TCPIP_INTERNAL_IND) +} ; + +static const T_FUNC dti_dl_table[] = +{ + MAK_FUNC_0(tcpip_dti_connect_ind , DTI2_CONNECT_IND ), + MAK_FUNC_0(tcpip_dti_connect_cnf , DTI2_CONNECT_CNF ), + MAK_FUNC_0(tcpip_dti_disconnect_ind , DTI2_DISCONNECT_IND) , + MAK_FUNC_0(tcpip_dti_ready_ind , DTI2_READY_IND ), + MAK_FUNC_0(tcpip_dti_data_ind , DTI2_DATA_IND ) +#if defined (_SIMULATION_) + , + MAK_FUNC_S(tcpip_dti_data_test_ind , DTI2_DATA_TEST_IND ) +#endif +} ; + + +static const T_FUNC dti_ul_table[] = +{ + MAK_FUNC_0(tcpip_dti_connect_req , DTI2_CONNECT_REQ ), + MAK_FUNC_0(tcpip_dti_connect_res , DTI2_CONNECT_RES ), + MAK_FUNC_0(tcpip_dti_disconnect_req, DTI2_DISCONNECT_REQ) , + MAK_FUNC_0(tcpip_dti_getdata_req , DTI2_GETDATA_REQ ), + MAK_FUNC_0(tcpip_dti_data_req , DTI2_DATA_REQ ) + +#if defined (_SIMULATION_) + , + MAK_FUNC_S(tcpip_dti_data_test_req , DTI2_DATA_TEST_REQ ) +#endif +} ; + + +/*==== PRIVATE FUNCTIONS ====================================================*/ + +/* ++------------------------------------------------------------------------------ +| Function : primitive_not_supported ++------------------------------------------------------------------------------ +| Description : This function handles unsupported primitives. +| +| Parameters : data - not used +| +| Return : void ++------------------------------------------------------------------------------ +*/ +static void primitive_not_supported (void *data) +{ + TRACE_FUNCTION ("primitive_not_supported"); + + PFREE (data); +} + +/* ++------------------------------------------------------------------------------ +| Function : pei_primitive ++------------------------------------------------------------------------------ +| Description : Process protocol specific primitive. +| +| Parameters : prim - pointer to the received primitive +| +| Return : PEI_OK - function succeeded +| PEI_ERROR - function failed ++-----------------------------------------------------------------------------*/ +static short pei_primitive (void * ptr) +{ + T_PRIM *prim = (T_PRIM*)ptr; + + TRACE_FUNCTION ("pei_primitive"); + + if (prim NEQ NULL) + { + unsigned long opc = prim->custom.opc; + unsigned short n; + const T_FUNC *table; + + PTRACE_IN (opc); + + switch (SAP_NR(opc)) + { + case SAP_NR(TCPIP_UL): + table = tcpip_table; + n = TAB_SIZE (tcpip_table); + break; + case SAP_NR(DTI2_UL): /* defined in prim.h */ + table = dti_ul_table; + n = TAB_SIZE (dti_ul_table); + opc -= PRIM_OFFSET_DTI2 ; /* Don't ask. */ + break; + case SAP_NR(DTI2_DL): /* defined in prim.h */ + table = dti_dl_table; + n = TAB_SIZE (dti_dl_table); + opc -= PRIM_OFFSET_DTI2 ; /* Don't ask here either. */ + break; + default: + table = NULL; + n = 0; + break; + } + + if (table NEQ NULL) + { + if (PRIM_NR(opc) < n) + { + table += PRIM_NR(opc) ; + #ifdef PALLOC_TRANSITION + P_SDU(prim) = table->soff ? (T_sdu*) (((char*)&prim->data) + table->soff) : 0; + #ifndef NO_COPY_ROUTING + P_LEN(prim) = table->size + sizeof (T_PRIM_HEADER); + #endif /* NO_COPY_ROUTING */ + #endif /* PALLOC_TRANSITION */ + JUMP (table->func) (P2D(prim)); + } + else + { + primitive_not_supported (P2D(prim)); + } + return PEI_OK; + } + + /* + * primitive is not a GSM primitive - forward it to the environment + */ + if (opc & SYS_MASK) + vsi_c_primitive (VSI_CALLER prim); + else + { + PFREE (P2D(prim)); + return PEI_ERROR; + } + } + return PEI_OK; +} + +/* ++------------------------------------------------------------------------------ +| Function : pei_init ++------------------------------------------------------------------------------ +| Description : Initialize Protocol Stack Entity +| +| Parameters : handle - task handle +| +| Return : PEI_OK - entity initialised +| PEI_ERROR - entity not (yet) initialised ++------------------------------------------------------------------------------ +*/ +static short pei_init (T_HANDLE handle) +{ + TRACE_FUNCTION ("pei_init"); + + /* Initialize entity handle */ + tcpip_handle = handle; + + /* + * Open communication channels + */ + if (hCommMMI < VSI_OK) + { + if ((hCommMMI = vsi_c_open (tcpip_handle, ACI_NAME)) < VSI_OK) + { + return PEI_ERROR; + } + } + + if (hCommTCPIP < VSI_OK) + { + if ((hCommTCPIP = vsi_c_open (tcpip_handle, TCPIP_NAME)) < VSI_OK) + { + return PEI_ERROR; + } + } + + /* + * Initialize global pointer tcpip_data. This is required to access all + * entity data. + */ + tcpip_data = &tcpip_data_base; + + tcpip_data->dti_handle = dti_init(TCPIP_MAX_DTI_LINKS, tcpip_handle, + DTI_DEFAULT_OPTIONS, tcpip_dti_callback) ; + return (PEI_OK); +} + +/* ++------------------------------------------------------------------------------ +| Function : pei_timeout ++------------------------------------------------------------------------------ +| Description : Process timeout. +| +| Parameters : index - timer index +| +| Return : PEI_OK - timeout processed +| PEI_ERROR - timeout not processed ++------------------------------------------------------------------------------ +*/ +static short pei_timeout (unsigned short index) +{ +/* TRACE_FUNCTION ("pei_timeout"); */ + + /* Process timeout */ + switch (index) + { + case RNET_RT_NGIP_TIMER: + /* Call of timeout routine */ + rnet_rt_handle_timer(NULL) ; + break; + default: + TRACE_ERROR("Unknown Timeout"); + return PEI_ERROR; + } + + return PEI_OK; +} + + +/* ++------------------------------------------------------------------------------ +| Function : pei_exit ++------------------------------------------------------------------------------ +| Description : Close Resources and terminate. +| +| Parameters : - +| +| Return : PEI_OK - exit sucessful ++------------------------------------------------------------------------------ +*/ +static short pei_exit (void) +{ + TRACE_FUNCTION ("pei_exit"); + + tcpip_do_shutdown() ; + if (tcpip_data->dti_handle NEQ NULL) + { + dti_deinit(tcpip_data->dti_handle) ; + tcpip_data->dti_handle = NULL ; + } + + /* Close communication channels */ + vsi_c_close (tcpip_handle,hCommMMI); + hCommMMI = VSI_ERROR; + vsi_c_close (tcpip_handle,hCommTCPIP); + hCommTCPIP = VSI_ERROR; + + + return PEI_OK; +} + +/* ++------------------------------------------------------------------------------ +| Function : pei_config ++------------------------------------------------------------------------------ +| Description : Dynamic Configuration. +| +| Parameters : in_string - configuration string +| +| Return : PEI_OK - sucessful +| PEI_ERROR - not successful ++------------------------------------------------------------------------------ +*/ + + +static short pei_config (char *in_string) +{ + TRACE_FUNCTION ("pei_config"); + TRACE_FUNCTION (in_string); + + if (!strcmp (in_string, "TCPIP_INITIALIZE_REQ") ) + { + tcpip_initialize_req(NULL) ; + } + else if (!strcmp (in_string, "TCPIP_SHUTDOWN_REQ") ) + { + tcpip_shutdown_req(NULL) ; + } + else if (!strcmp (in_string, "TCPIP_CREATE_REQ") ) + { + T_RV_RETURN_PATH return_path = { 0, 0 } ; + rnet_new(RNET_IPPROTO_TCP, &desc, return_path); + } + else if (!strcmp (in_string, "TCPIP_BIND_REQ") ) + { + rnet_bind(desc, RNET_IP_ADDR_ANY, 32000); + } + else if (!strcmp (in_string, "TCPIP_CONNECT_REQ") ) + { + rnet_connect(desc, RNET_IP_ADDR_ANY, 32000); + } + else if (!strcmp (in_string, "TCPIP_LISTEN_REQ") ) + { + rnet_listen(desc); + } + else if (!strcmp (in_string, "TCPIP_CLOSE_REQ") ) + { + rnet_close(desc); + } + else if (!strncmp(in_string, "dns ", 4)) + { + U8 *addrbyte ; + int o1, o2, o3, o4 ; + + if (sscanf(in_string + 4, "%d.%d.%d.%d", &o1, &o2, &o3, &o4) != 4) + { + TRACE_EVENT("cannot parse argument as an IP address") ; + return PEI_OK ; + } + addrbyte = (U8 *) &tcpip_data->config_dns_address ; + addrbyte[0] = (U8) o1 ; + addrbyte[1] = (U8) o2 ; + addrbyte[2] = (U8) o3 ; + addrbyte[3] = (U8) o4 ; + TRACE_EVENT("DNS address saved") ; + } + /* + * further dynamic configuration + */ + return PEI_OK; +} + + +/*==== PUBLIC FUNCTIONS =====================================================*/ + +/* ++------------------------------------------------------------------------------ +| Function : pei_create ++------------------------------------------------------------------------------ +| Description : Create the Protocol Stack Entity. +| +| Parameters : info - Pointer to the structure of entity parameters +| +| Return : PEI_OK - entity created successfully +| ++------------------------------------------------------------------------------ +*/ +short tcpip_pei_create (T_PEI_INFO **info) +{ + static T_PEI_INFO pei_info = + { + "TCP", /* name */ + { /* pei-table */ + pei_init, + pei_exit, + pei_primitive, + pei_timeout, + NULL, /* pei_signal */ + NULL, /* pei_run */ + pei_config, + NULL /* pei_monitor */ + }, + TCPIP_STACK_SIZE, /* stack size */ + TCPIP_QUEUE_SIZE, /* queue entries */ + TCPIP_PRIORITY, /* priority (1->low, 255->high) */ + TCPIP_NUM_TIMER, /* number of timers */ + COPY_BY_REF|PASSIVE_BODY /* flags: bit 0 active(0) body/passive(1) */ + }; /* bit 1 com by copy(0)/reference(1) */ + + TRACE_FUNCTION ("pei_create()"); + + /* Close Resources if open */ + if (first_access) { + first_access = FALSE; + } + else { + pei_exit (); + } + + /* Export startup configuration data */ + *info = &pei_info; + + return PEI_OK; +} + +/*==== END OF FILE ==========================================================*/ +