FreeCalypso > hg > fc-magnetite
view src/g23m-aci/aci/sap_dti.c @ 597:f18b29e27be5
First attempt at MCSI voice path automatic switching
The function is implemented at the ACI level in both aci2 and aci3,
successfully avoids triggering the DSP bug on the first call,
but the shutdown of MCSI upon call completion is not working properly yet
in either version.
author | Mychaela Falconia <falcon@freecalypso.org> |
---|---|
date | Wed, 27 Mar 2019 22:18:35 +0000 |
parents | 53929b40109c |
children |
line wrap: on
line source
/* +----------------------------------------------------------------------------- | Project : GSM-PS | 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 : MUX for DTI primitives | | Different entities sends the same DTI primitives. In this | file the correct PSA function will call +----------------------------------------------------------------------------- */ /*==== INCLUDES ===================================================*/ #ifdef DTI #ifndef SAP_DTI_C #define SAP_DTI_C #endif #include "aci_all.h" /*==== INCLUDES ===================================================*/ #include "line_edit.h" #include "aci_cmh.h" #include "ati_cmd.h" #include "aci_cmd.h" #include "dti.h" /* functionality of the dti library */ #include "aci.h" #include "aci_lst.h" #include "dti_conn_mng.h" #include "dti_cntrl_mng.h" #ifdef UART #include "psa_uart.h" #include "cmh_uart.h" #endif #ifdef FF_PSI #include "psa_psi.h" #include "cmh_psi.h" #include "ati_src_psi.h" #endif /*FF_PSI*/ #include "aci_mem.h" #ifdef UART #include "ati_src_uart.h" #endif #include "sap_dti.h" #include "psa.h" #include "cmh.h" #ifdef FF_BAT #include "p_bat.h" #include "aci_bat.h" #ifdef _SIMULATION_ #include "ati_bat.h" #endif #endif EXTERN T_ACI_LIST *ati_src_list; /*==== CONSTANTS ==================================================*/ /*==== TYPES ======================================================*/ /*==== EXPORT =====================================================*/ /*==== VARIABLES ==================================================*/ /*==== FUNCTIONS ==================================================*/ /* LOCAL FUNCTIONS */ /* +------------------------------------------------------------------------------ | Function : sig_dti_connection_opened_ind +------------------------------------------------------------------------------ | PURPOSE : dti connection to UART/PSI has been opened +------------------------------------------------------------------------------ */ LOCAL void sig_dti_connection_opened_ind(UBYTE src_id) { T_DTI_CONN_LINK_ID link_id; #ifdef FF_PSI T_ACI_DTI_PRC_PSI *src_infos = find_element (psi_src_params, src_id, cmhPSItest_srcId); #endif /*FF_PSI*/ /* for tracing of establishing of CMD channels for dual port version */ #ifdef RMV_15_04_03 extern CHAR gob_tst_buf[]; #endif TRACE_FUNCTION("sig_dti_connection_opened_ind()"); link_id = dti_cntrl_get_link_id( DTI_ENTITY_ACI, src_id, DTI_SUB_NO_NOTPRESENT ); /* for tracing of establishing of CMD channels for dual port version */ #ifdef RMV_15_04_03 sprintf(gob_tst_buf+strlen(gob_tst_buf), "oi:%d ", link_id); #endif dti_cntrl_entity_connected( link_id, DTI_ENTITY_ACI, DTI_OK ); aci_src_dti_params[src_id].isDtiConnected = TRUE; if (aci_src_dti_params[src_id].dtxState EQ READY) { /* send buffered data */ #ifdef FF_PSI if (src_infos NEQ NULL) psi_send_buffer_data(src_id); else #endif /*FF_PSI*/ uart_send_buffer_data(src_id); } } /* +------------------------------------------------------------------------------ | Function : sig_dti_connection_closed_ind +------------------------------------------------------------------------------ | PURPOSE : dti connection to UART/PSI has been closed down +------------------------------------------------------------------------------ */ LOCAL void sig_dti_connection_closed_ind(UBYTE src_id) { T_DTI_CONN_LINK_ID link_id; TRACE_FUNCTION("sig_dti_connection_closed_ind()"); link_id = dti_cntrl_get_link_id( DTI_ENTITY_ACI, src_id, DTI_SUB_NO_NOTPRESENT ); dti_cntrl_entity_disconnected( link_id, DTI_ENTITY_ACI ); aci_src_dti_params[src_id].isDtiConnected = FALSE; } /* +------------------------------------------------------------------------------ | Function : sig_dti_data_received_ind +------------------------------------------------------------------------------ | PURPOSE : process reason parameter REASON_DATA_RECEIVED +------------------------------------------------------------------------------ */ GLOBAL void sig_dti_data_received_ind(UBYTE src_id, T_DTI2_DATA_IND *dti_data_ind) { USHORT tot_len; SHORT pos = 0; T_desc2 *p_desc, *old_desc; UBYTE *chars_received; BOOL get_data = TRUE; USHORT new_len = 0; T_ACI_DTI_PRC *src_infos = find_element (uart_src_params, src_id, cmhUARTtest_srcId); #ifdef FF_PSI T_ACI_DTI_PRC_PSI *src_infos_psi = find_element (psi_src_params, src_id, cmhPSItest_srcId); #endif /*FF_PSI*/ TRACE_FUNCTION("sig_dti_data_received_ind()"); /* prevent dti library from automatically sending getdata primitives */ #ifdef FF_PSI if (src_infos EQ NULL AND src_infos_psi EQ NULL) #else if (src_infos EQ NULL) #endif /*FF_PSI*/ { TRACE_EVENT_P1("[ERR] sig_dti_data_received_ind: link_id=%d not found", dti_data_ind->link_id) ; return ; } if (src_infos NEQ NULL) { #ifndef FF_ATI_BAT /* we came from gdd_aci_send_data() --> faked DTI primitive */ dti_stop (aci_hDTI, src_id, DTI_ENTITY_UART, ACI_DTI_DN_CHANNEL); #endif if(src_infos->RecState EQ READY_REC) { src_infos->RecState = RECEIVING; } if (dti_data_ind->parameters.st_lines.st_line_sa EQ DTI_SA_ON) { BITFIELD_SET (src_infos->data_cntr, UART_DTI_SA_BIT); } else { BITFIELD_CLEAR (src_infos->data_cntr, UART_DTI_SA_BIT); } } #ifdef FF_PSI else if (src_infos_psi NEQ NULL) { #ifndef FF_ATI_BAT /* we came from gdd_aci_send_data() --> faked DTI primitive */ dti_stop (aci_hDTI, src_id, DTI_ENTITY_UART, ACI_DTI_DN_CHANNEL); #endif if(src_infos_psi->RecState EQ READY_REC) { src_infos_psi->RecState = RECEIVING; } if (dti_data_ind->parameters.st_lines.st_line_sa EQ DTI_SA_ON) { BITFIELD_SET (src_infos_psi->data_cntr, PSI_DTI_SA_BIT); } else { BITFIELD_CLEAR (src_infos_psi->data_cntr, PSI_DTI_SA_BIT); } } #endif /*FF_PSI*/ tot_len = dti_data_ind -> desc_list2.list_len; p_desc = (T_desc2 *)dti_data_ind -> desc_list2.first; if ( aci_src_dti_params[src_id].isDtiConnected EQ FALSE ) { TRACE_EVENT ("DTI2_DATA_IND: line not connected"); PFREE(dti_data_ind); return; } #ifdef FF_BAT /* we want only to see data from src_infos_psi */ if (aci_cmd_src_mode_get((T_ACI_CMD_SRC)src_id) EQ CMD_MODE_BAT) { #if defined _SIMULATION_ && FF_ATI_BAT /* * Simulation of BAT with ATI as application has the following problem: * test cases uses the TST and UART source, but BAT needs a PSI source maintenance. * Therefore there is in parallel to the TST or UART source a PSI source maintenance and * the TST/UART source has been set to CMD_MODE_BAT. * When the TAP sends an ASCII AT command string the command must be processed * at first with uart_src_proc_chars(). On ATI level we use the BAT lib and the special * BAT adapter GDD_ACI will call this function once again, because we have to simulate * an incoming DTI primitive. This DTI primitive carries now a BAT command. * That's why we have to check the bytes to distinuish between BAT and ASCII commands. */ T_desc2 *tmp = p_desc; int i = 0; get_data = TRUE; /* we use this boolean here to check for valid ASCII AT command chars */ while (i < tmp->len-1) { if ((p_desc->buffer[i] < 0x20) OR (p_desc->buffer[i] > 0x7F)) { if (at.S[3] EQ p_desc->buffer[i]) /* CR */ continue; if (at.S[4] EQ p_desc->buffer[i]) /* LF */ continue; if (at.S[5] EQ p_desc->buffer[i]) /* BS */ continue; if (0x1a EQ p_desc->buffer[i]) /* CTRL-Z = SMS end */ continue; get_data = FALSE; /* not a V25.ter, 07.07 char, so very likely a BAT command */ break; } i++; } if (get_data EQ FALSE) { #endif /* _SIMULATION_ && FF_ATI_BAT */ aci_bat_rcv(src_infos_psi,dti_data_ind); /* clean up the DTI primitive after BAT processing */ while(p_desc NEQ NULL) { old_desc = p_desc; p_desc = (T_desc2 *)p_desc->next; ACI_MFREE( old_desc ); } PFREE(dti_data_ind); return; #if defined _SIMULATION_ && FF_ATI_BAT } #endif /* _SIMULATION && FF_ATI_BAT */ } #endif /* FF_BAT */ ACI_MALLOC(chars_received, tot_len + 1); while(p_desc NEQ NULL) { new_len += p_desc -> len; if( new_len > tot_len) { TRACE_EVENT("inconsistance in datas received from DTI: ACI cannot process"); ACI_MFREE(chars_received); return; } memcpy(chars_received+pos,p_desc -> buffer,p_desc -> len); /* trace_buffer (p_desc->buffer, p_desc->len);*/ pos = new_len; old_desc = p_desc; /* save to free descriptor at the end */ p_desc = (T_desc2 *)p_desc -> next; /* point to next one */ ACI_MFREE( old_desc ); } if (tot_len > 0) { if (src_infos NEQ NULL) get_data = uart_src_proc_chars (chars_received, pos, src_infos); #ifdef FF_PSI else get_data = psi_src_proc_chars (chars_received, pos, src_infos_psi); #endif /*FF_PSI*/ } else { get_data = TRUE; } ACI_MFREE( chars_received ); chars_received = NULL; #ifdef FF_ATI_BAT #ifdef _SIMULATION_ if (aci_cmd_src_mode_get(src_id) EQ CMD_MODE_BAT) /* simulation with BAT library */ { T_ATI_SRC_PARAMS *src_params = find_element (ati_src_list, src_id, search_ati_src_id); T_ACI_DTI_PRC_PSI *src_infos_psi = find_element (psi_src_params, src_id, cmhPSItest_srcId); while (ledit_ctrl(src_params->src_id,LEDIT_CTRL_MORE_CMDS, NULL) EQ LEDIT_CMPL) { ati_bat_response_simulation(&(src_infos_psi->res)); /* intermediate response */ } if (src_params->cmd_state NEQ CMD_IDLE) { if (src_infos_psi->res.response) { ati_bat_response_simulation(&(src_infos_psi->res)); /* final response */ Perform_ati_bat_maint(src_id); } } } #endif /* _SIMULATION_ */ #endif /* FF_ATI_BAT */ if( get_data ) { if (src_infos NEQ NULL) cmhUART_getdata( (T_ACI_CMD_SRC)src_id ); #ifdef FF_PSI else if (src_infos_psi NEQ NULL) cmhPSI_getdata ((T_ACI_CMD_SRC)src_id); #endif /*FF_PSI*/ } PFREE(dti_data_ind); } /* +------------------------------------------------------------------------------ | Function : sig_dti_tx_buffer_full_ind +------------------------------------------------------------------------------ | PURPOSE : +------------------------------------------------------------------------------ */ GLOBAL void sig_dti_tx_buffer_full_ind(UBYTE src_id) { TRACE_FUNCTION("sig_dti_tx_buffer_full_ind"); aci_src_dti_params[src_id].dtxState = NOT_READY; } /* +------------------------------------------------------------------------------ | Function : sig_dti_tx_buffer_ready_ind +------------------------------------------------------------------------------ | PURPOSE : +------------------------------------------------------------------------------ */ GLOBAL void sig_dti_tx_buffer_ready_ind(UBYTE src_id) { T_ACI_DTI_PRC *src_infos = NULL; T_ATI_SRC_PARAMS *src_params = find_element (ati_src_list, src_id, search_ati_src_id); #ifdef FF_PSI T_ACI_DTI_PRC_PSI *src_infos_psi = NULL; T_DTI_ENTITY_ID entity_list[2]; #endif /*FF_PSI*/ TRACE_FUNCTION("sig_dti_tx_buffer_ready_ind()"); aci_src_dti_params[src_id].dtxState = READY; if (aci_src_dti_params[src_id].isDtiConnected) { src_infos = find_element (uart_src_params, src_id, cmhUARTtest_srcId); #ifdef FF_PSI src_infos_psi = find_element (psi_src_params, src_id, cmhPSItest_srcId); #endif /*FF_PSI*/ /* * send data which may have been stored .. */ if (src_infos NEQ NULL) { /* Need to return only when the data_list is not NULL so that the CMUX part of the code will get executed. */ if (src_infos->data_buffer.data_list NEQ NULL) { uart_send_buffer_data(src_id); if (src_infos->data_buffer.data_list EQ NULL) { switch(src_params->curAtCmd) { case AT_CMD_COPN: cmd_PlusCOPN_CB(src_id); break; case AT_CMD_CPBR: cmd_PlusCPBR_CB(src_id); break; default:; /* Do nothing */ } } return; } } #ifdef FF_PSI if (src_infos_psi NEQ NULL) { if (src_infos_psi->data_buffer.data_list NEQ NULL) { #ifdef FF_BAT if (aci_cmd_src_mode_get((T_ACI_CMD_SRC)src_id) EQ CMD_MODE_BAT) { aci_bat_send_buffer_dti_data(src_id); /* * CPBR and similar BAT commands */ aci_bat_check_for_multi_line_response_command(src_id); } else #endif { psi_send_buffer_data(src_id); } if(src_infos_psi->data_buffer.data_list EQ NULL) { switch(src_params->curAtCmd) { case AT_CMD_COPN: cmd_PlusCOPN_CB(src_id); break; case AT_CMD_CPBR: cmd_PlusCPBR_CB(src_id); break; default:; /* Do nothing */ } } return; } } #endif /*FF_PSI*/ { T_ATI_SRC_PARAMS *src_params = find_element (ati_src_list, src_id, search_ati_src_id); if (uartEntcurCmd[src_id] EQ AT_CMD_CMUX) { if (cmhUART_CMUX ((T_ACI_CMD_SRC)src_id) EQ FALSE) { /* * if we are here, we have a problem, because it has been sent an OK in advance to the source, * which works according to GSM 27.010 * So, how to inform the source, that the muxer has not been started ? * see sAT_PlusCMUX() in cmh_uarts.c */ TRACE_EVENT("[ERR] sig_dti_tx_buffer_ready_ind(): UART muxer not ready"); } uartEntcurCmd[src_id] = AT_CMD_NONE; } #ifdef FF_PSI else { if((psi_ato.last_cmd EQ AT_CMD_O) AND (src_infos_psi NEQ NULL)) { entity_list[0] = psi_ato.entity_to_conn; dti_cntrl_est_dpath_indirect (psi_ato.src_id, entity_list, psi_ato.num_entities, psi_ato.mode, psi_ato.cb, psi_ato.capability, psi_ato.cid); memset(&psi_ato,0,sizeof(T_ACI_PSI_CALL_TYPE)); } } #endif /*FF_PSI*/ } } } /* GLOBAL FUNCTIONS */ /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : SAP_DTI | | STATE : code ROUTINE : dti_lib_dti_dti_connect_cnf | +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL void dti_lib_dti_dti_connect_cnf ( T_DTI2_CONNECT_CNF *dti_connect_cnf) { TRACE_FUNCTION("dti_lib_dti_dti_connect_cnf()"); dti_dti_connect_cnf(aci_hDTI, dti_connect_cnf); } /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : SAP_DTI | | STATE : code ROUTINE : dti_lib_dti_dti_connect_ind | +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL void dti_lib_dti_dti_connect_ind ( T_DTI2_CONNECT_IND *dti_connect_ind) { TRACE_FUNCTION("dti_lib_dti_dti_connect_ind()"); dti_dti_connect_ind(aci_hDTI, dti_connect_ind); } /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : SAP_DTI | | STATE : code ROUTINE : dti_lib_dti_dti_disconnect_ind| +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL void dti_lib_dti_dti_disconnect_ind ( T_DTI2_DISCONNECT_IND *dti_disconnect_ind) { TRACE_FUNCTION("dti_lib_dti_dti_disconnect_ind()"); dti_dti_disconnect_ind (aci_hDTI, dti_disconnect_ind); } /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : SAP_DTI | | STATE : code ROUTINE : dti_lib_dti_dti_data_ind | +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL void dti_lib_dti_dti_data_ind ( T_DTI2_DATA_IND *dti_data_ind) { TRACE_FUNCTION("dti_lib_dti_dti_data_ind()"); dti_dti_data_ind (aci_hDTI, dti_data_ind); } /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : SAP_DTI | | STATE : code ROUTINE : dti_lib_dti_dti_ready_ind | +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL void dti_lib_dti_dti_ready_ind ( T_DTI2_READY_IND *dti_ready_ind) { TRACE_FUNCTION("dti_lib_dti_dti_ready_ind()"); dti_dti_ready_ind (aci_hDTI, dti_ready_ind); } #ifdef _SIMULATION_ /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : SAP_DTI | | STATE : code ROUTINE : dti_lib_dti_dti_data_test_ind | +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL const void dti_lib_dti_dti_data_test_ind ( T_DTI2_DATA_TEST_IND *dti_data_test_ind) { TRACE_FUNCTION("dti_lib_dti_dti_data_test_ind()"); dti_dti_data_test_ind (aci_hDTI, dti_data_test_ind); } #endif /* _SIMULATION_ */ /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : SAP_DTI | | STATE : code ROUTINE : psaACI_Init | +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL void psaACI_Init() { UBYTE i; TRACE_FUNCTION("psaACI_Init()"); for (i=0; i<CMD_SRC_MAX; i++) { aci_src_dti_params[i].isDtiConnected = FALSE; aci_src_dti_params[i].dtxState = NOT_READY; } } /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : SAP_DTI | | STATE : code ROUTINE : aci_pei_sig_callback | +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL void aci_pei_sig_callback(U8 instance, U8 interfac, U8 channel, U8 reason, T_DTI2_DATA_IND *dti_data_ind) { UBYTE src_id = instance; TRACE_FUNCTION("aci_pei_sig_callback()"); #ifdef _SIMULATION_ if(channel NEQ ACI_DTI_DN_CHANNEL) { TRACE_ERROR("[DTI_MNG_SIG_CALLBACK] channel not valid!"); return; /* error, not found */ } #endif /* _SIMULATION_ */ if (aci_hDTI NEQ D_NO_DATA_BASE) { switch (reason) { case DTI_REASON_CONNECTION_OPENED: sig_dti_connection_opened_ind(src_id); break; case DTI_REASON_CONNECTION_CLOSED: sig_dti_connection_closed_ind(src_id); break; case DTI_REASON_DATA_RECEIVED: sig_dti_data_received_ind(src_id, dti_data_ind); break; case DTI_REASON_TX_BUFFER_FULL: sig_dti_tx_buffer_full_ind(src_id); break; case DTI_REASON_TX_BUFFER_READY: sig_dti_tx_buffer_ready_ind(src_id); break; default: TRACE_ERROR("unknown DTILIB reason parameter"); break; } /* end switch */ } /* end if */ else { TRACE_ERROR("Pointer to DTILIB database not existing"); } } /* dti_cntrl_mng_cb() */ /* +-----------------------------------------------------------------------+ | PROJECT : GSM-F&D (8411) MODULE : PSA_ACI | | STATE : code ROUTINE : psaACI_Dti_Req | +-----------------------------------------------------------------------+ PURPOSE : */ GLOBAL BOOL psaACI_Dti_Req ( T_DTI_CONN_LINK_ID link_id, T_DTI_ENTITY_ID peer_ent_id, UBYTE dti_conn) { T_DTI_CNTRL info; TRACE_FUNCTION("psaACI_Dti_Req()"); if (dti_cntrl_get_info_from_dti_id( EXTRACT_DTI_ID(link_id), &info) EQ FALSE) { TRACE_EVENT_P1("cannot find info for dti_id=%d", EXTRACT_DTI_ID(link_id)); return FALSE; } if (dti_conn EQ ACI_CONNECT_DTI) { aci_src_dti_params[info.src_id].dtxState = NOT_READY; if (dti_cntrl_set_conn_parms(link_id, DTI_ENTITY_ACI, info.src_id, DTI_SUB_NO_NOTPRESENT) EQ FALSE) { return FALSE; } if( !dti_open( aci_hDTI, /* hDTI */ info.src_id, /* instance */ (U8)peer_ent_id, /* interface */ ACI_DTI_DN_CHANNEL, /* channel */ /* Since DTI-buffering wastes memory we have to implement our own buffers */ /* This is vital for large outputs like AT+COPN, so please do not modify! */ /* 0, */ /* queue_size */ 1, /* limit to 1 DTI buffer */ DTI_CHANNEL_TO_LOWER_LAYER, /* direction */ /* DTI_QUEUE_UNBOUNDED, */ /* link_options */ DTI_QUEUE_WATERMARK, /* to enable ACI Buffers */ DTI_VERSION_10, /* version */ (UBYTE*)dti_entity_name[peer_ent_id].name, /* neighbor_entity */ link_id /* link_id */ )) return FALSE; } else { dti_close ( aci_hDTI, /* hDTI */ info.src_id, /* instance */ (U8)peer_ent_id, /* interface */ ACI_DTI_DN_CHANNEL, /* channel */ TRUE /* flush */ ); } return TRUE; } #endif /* DTI */