--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/g23m-aci/aci/dcm_utils.c	Sun Jul 15 04:40:46 2018 +0000
@@ -0,0 +1,1327 @@
+/*
++-----------------------------------------------------------------------------
+|  Project :  DCM and TCPIP
+|  Modul   :  ACI
++-----------------------------------------------------------------------------
+|  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.
++-----------------------------------------------------------------------------
+|  Description :  This file contains Useful DCM (Data connection manager)functions.
++-----------------------------------------------------------------------------
+*/
+
+/************************************  INCLUDES ********************************************/
+#include "aci_all.h"
+
+#include "aci.h"
+#include "aci_cmh.h"
+#include "Gaci_cmh.h"
+#include "dcm.h"
+#include "dcm_utils.h"
+#include "dcm_state.h"
+#include "dcm_env.h"
+#include "dcm_f.h"
+#include "psa_dcm.h"
+#include "socket_api.h"
+
+#include "wap_aci.h"
+
+/**************************** LOCAL VARIABLE DEFINITION  ************************************/
+
+/**************************** EXTERN VARIABLE DEFINITION  ***********************************/
+EXTERN T_DCM_ENV_CTRL_BLK *dcm_env_ctrl_blk_p;
+
+
+/**************************** LOCAL FUCNTION DEFINITION  ************************************/
+LOCAL T_DCM_RET dcm_send_cgdcont_get_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_cgdcont_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_cgatt_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_cgdeact_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_cgpco_auth_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_cgpco_get_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_cgerep_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_cgpaddr_cmd(U8 current_row);
+LOCAL T_DCM_RET dcm_send_percentppp_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_sat_dn_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_percentppp_get_cmd(U8 row);
+LOCAL T_DCM_RET dcm_send_percentcal_get_cmd(UBYTE row);
+LOCAL T_DCM_RET dcm_send_sat_abort_cmd(U8 row);
+
+LOCAL ULONG dcm_ipaddr_htonl(ULONG horder_ipaddr);
+
+LOCAL void set_state_from_ctrl_blk();
+
+/************************** EXTERN FUCNTION DEFINITION  *********************************/
+EXTERN T_DCM_RET dcm_handle_message (T_DCM_HDR *msg_p);
+EXTERN void psaTCPIP_Shutdown_Req(void);
+
+
+BOOL is_netdrop = FALSE  ;  //pinghua added patch for DCM open/close
+
+/***************************************************************************************
+*   Function       :  dcm_process_unwaited_events_state_intermediate_conn
+*   Parameter      :  T_DCM_HDR *
+*                     -Pointer on the header of the message.
+*   Return         :  T_DCM_RET
+*                     DCM_OK or DCM errors
+*   Description    :  Function used in all intermediate states where events is unwaited,
+*                     but must be processed.
+***************************************************************************************/
+T_DCM_RET dcm_process_unwaited_events_state_intermediate_conn(T_DCM_HDR * msg_p)
+{
+  T_DCM_OPEN_CONN_REQ_MSG * dcm_open_conn_req_msg_p;
+  T_DCM_CLOSE_CONN_REQ_MSG * dcm_close_conn_req_msg_p;
+
+  TRACE_FUNCTION("DCM: dcm_process_unwaited_events_state_intermediate_conn()");
+
+  switch(msg_p->msg_id)
+  {
+    case DCM_ERROR_IND_MSG:
+      return dcm_process_event_error_reception(msg_p);
+      /*lint -e527 suppress Warning -- Unreachable */
+      /* break is removed ,as case is returning before break so it is not needed */
+      /*lint +e527 */
+    case DCM_OPEN_CONN_REQ_MSG:
+      dcm_open_conn_req_msg_p = (T_DCM_OPEN_CONN_REQ_MSG*)msg_p;
+      psaDCM_open_conn_cnf(DCM_BUSY,
+                                 dcm_open_conn_req_msg_p->conn_req.api_instance);
+      return (DCM_BUSY);  /* It is replaced with return in next line to avoid warning */	  
+      /*lint -e527 suppress Warning -- Unreachable */
+      /* break is removed ,as case is returning before break so it is not needed */	  
+      /*lint +e527 */
+    case DCM_CLOSE_CONN_REQ_MSG:
+      dcm_close_conn_req_msg_p = (T_DCM_CLOSE_CONN_REQ_MSG*)msg_p;
+      /*  DCM CLOSE REQ have to be accepted in ACTVATING STATE  */
+      if(dcm_env_ctrl_blk_p->state[0] EQ DCM_ACTIVATING_CONN)
+      {
+        dcm_process_close_conn_event(dcm_close_conn_req_msg_p);
+      }
+      else
+      {
+        psaDCM_close_conn_cnf(DCM_BUSY,
+                              dcm_close_conn_req_msg_p->close_req.api_instance);
+      }
+      return DCM_OK;
+      /*lint -e527 suppress Warning -- Unreachable */
+      /* break is removed ,as case is returning before break so it is not needed */	  
+      /*lint +e527 */
+    default:
+      /* Ignore event - Stay in the same state. */
+      return DCM_UNKNOWN_EVENT;
+  }
+}
+
+
+/*
+ * Function used to close a connection (with PS and later with api_instance)
+ *
+ * The closing is always on demand of the IPU_id, or may be internally launched.
+ * The closing of the connection begin by the closing of the port with the PS.
+ * - Close the connection with the PS.
+ *
+ * @param   T_DCM_CLOSE_CONN_REQ_MSG*
+ * @return  DCM_OK or DCM errors
+ */
+/***************************************************************************************
+*   Function       :  dcm_process_close_conn_event
+*   Parameter      :  T_APPLI_USER
+*                     -Pointer on the header of the message.
+*   Return         :  T_DCM_RET
+*                     DCM_OK or DCM errors
+*   Description    :  Function used in all intermediate states where events is unwaited,
+*                     but must be processed.
+***************************************************************************************/
+T_DCM_RET dcm_process_close_conn_event(T_DCM_CLOSE_CONN_REQ_MSG *close_conn_p )
+{
+  U8 i;
+  U8 current_bearer_count;
+//pinghua DCM_OPEN_CLOSE patch 20080429  start 
+  T_P_CGREG_STAT status = (T_P_CGREG_STAT)0;
+  USHORT lac, ci;
+
+
+  TRACE_FUNCTION("DCM: dcm_process_close_conn_event()");
+
+  qAT_PercentCGREG(CMD_SRC_LCL, &status, &lac, &ci);
+  TRACE_EVENT_P1("NOW NET STATA is %d", status);
+  if(status>=P_CGREG_STAT_LIMITED )
+  {
+		psaDCM_close_conn_cnf(DCM_NO_NETWORK, close_conn_p->close_req.api_instance);
+       	return DCM_NO_NETWORK;
+
+  }
+// pinghua DCM_OPEN_CLOSE patch 20080429  end
+
+  for (i=0; i < DCM_MAX_NUMBER_IPU; i++)
+  {
+    if( (dcm_env_ctrl_blk_p->ipu_list[i].api_instance EQ
+         close_conn_p->close_req.api_instance) AND
+         (dcm_env_ctrl_blk_p->ipu_list[i].row_state) )
+    {
+      if(dcm_env_ctrl_blk_p->ipu_list[i].bearer_type EQ DCM_BEARER_GPRS)
+      {
+        current_bearer_count = dcm_env_ctrl_blk_p->gprs_current_total_row;
+      }
+      else
+      {
+        current_bearer_count = dcm_env_ctrl_blk_p->gsm_current_total_row;
+      }
+      /* raise the flag that indicates a disconnection */
+      dcm_env_ctrl_blk_p->ipu_list[i].row_state = ROW_CLOSING;
+      dcm_new_state(DCM_CLOSING_CONN , DCM_SUB_NO_ACTION);
+
+      if(current_bearer_count EQ 1)
+      {
+        if(dcm_env_ctrl_blk_p->ipu_list[i].bearer_type EQ DCM_BEARER_GPRS)
+        {
+          dcm_send_cgdeact_cmd(i);
+        }
+        else
+        {
+          dcm_send_percentcal_get_cmd(i);
+        }
+      }
+      else
+      {
+        psaDCM_close_conn_cnf(DCM_OK,close_conn_p->close_req.api_instance);
+        /* free the row used */
+        dcm_free_row(i);
+        set_state_from_ctrl_blk();
+      }
+    }
+  }
+  return DCM_OK;
+}
+
+// pinghua DCM_OPEN_CLOSE patch 20080429  start here  
+T_DCM_RET dcm_process_network_drop(T_DCM_CLOSE_CONN_REQ_MSG *close_conn_p )
+{
+  U8 i;
+  U8 current_bearer_count;
+  
+
+  TRACE_FUNCTION("DCM: dcm_process_network_drop()");
+
+  for (i=0; i < DCM_MAX_NUMBER_IPU; i++)
+  {
+    if( (dcm_env_ctrl_blk_p->ipu_list[i].api_instance EQ
+         close_conn_p->close_req.api_instance) AND
+         (dcm_env_ctrl_blk_p->ipu_list[i].row_state) )
+    {
+      if(dcm_env_ctrl_blk_p->ipu_list[i].bearer_type EQ DCM_BEARER_GPRS)
+      {
+        current_bearer_count = dcm_env_ctrl_blk_p->gprs_current_total_row;
+      }
+      else
+      {
+        current_bearer_count = dcm_env_ctrl_blk_p->gsm_current_total_row;
+      }
+      /* raise the flag that indicates a disconnection */
+      dcm_env_ctrl_blk_p->ipu_list[i].row_state = ROW_CLOSING;
+      dcm_new_state(DCM_CLOSING_CONN , DCM_SUB_NO_ACTION);
+
+      if(current_bearer_count EQ 1)
+      {
+        if(dcm_env_ctrl_blk_p->ipu_list[i].bearer_type EQ DCM_BEARER_GPRS)
+        {
+          dcm_send_cgdeact_cmd(i);
+          is_netdrop = TRUE  ; 	 // pinghua added DCM_OPEN_CLOSE patch	  
+        }
+        else
+        {
+          dcm_send_percentcal_get_cmd(i);
+        }
+      }
+      else
+      {
+        psaDCM_close_conn_cnf(DCM_OK,close_conn_p->close_req.api_instance);
+        /* free the row used */
+        dcm_free_row(i);
+        set_state_from_ctrl_blk();
+      }
+    }
+  }
+  return DCM_OK;
+}
+//pinghua DCM_OPEN_CLOSE patch 20080429  end
+
+/*******************************************************************************
+ * Function used to open a connection (with PS)
+ *
+ * The opening is always on demand of the IPU_id.
+ * - Open the connection with the PS.
+ *
+ * @return  DCM_OK or DCM errors
+*******************************************************************************/
+
+EXTERN T_ACI_WAP_STATES wap_state;
+T_DCM_RET dcm_process_open_conn_event(T_DCM_OPEN_CONN_REQ_MSG *open_conn_p)
+{
+  U8 row_id, row_id_free;
+// pinghua DCM_OPEN_CLOSE patch 20080429  start 
+  T_P_CGREG_STAT status = (T_P_CGREG_STAT)0;
+  USHORT lac, ci;
+  TRACE_FUNCTION("DCM: dcm_process_open_conn_event()");
+
+
+  qAT_PercentCGREG(CMD_SRC_LCL, &status, &lac, &ci);
+  TRACE_EVENT_P1("NOW NET STATA is %d", status);
+  if(status>=P_CGREG_STAT_LIMITED )
+  {
+		psaDCM_open_conn_cnf(DCM_NO_NETWORK, open_conn_p->conn_req.api_instance);
+       	return DCM_NO_NETWORK;
+
+  }
+if( wap_state != Wap_Not_Init  )
+  {   
+//       if(dcm_env_ctrl_blk_p->state[0]==DCM_CONN_ACTIVATED ||
+//	   dcm_env_ctrl_blk_p->state[0]==DCM_CLOSING_CONN  || dcm_env_ctrl_blk_p->state[0] ==DCM_ACTIVATING_CONN )
+	{
+		psaDCM_open_conn_cnf(DCM_NOT_READY, open_conn_p->conn_req.api_instance);
+       	return DCM_NOT_READY;
+       }
+	   
+  }
+
+// pinghua DCM_OPEN_CLOSE patch 20080429 end
+
+
+  /* check if the max number of IPU is reached */
+  if (( dcm_env_ctrl_blk_p->gsm_current_total_row +
+        dcm_env_ctrl_blk_p->gprs_current_total_row ) >= DCM_MAX_NUMBER_IPU )
+  {
+    /* Too many IPU_id opened */
+    /* send the negative confirmation to the IPU */
+    psaDCM_open_conn_cnf(DCM_NOT_READY,
+                                open_conn_p->conn_req.api_instance);
+    return (DCM_NOT_READY);  /* It is replaced with return in next line to avoid warning */
+  }
+
+  /* if possible, get the next row */
+  for (row_id = 0, row_id_free = DCM_MAX_NUMBER_IPU; row_id < DCM_MAX_NUMBER_IPU; row_id++)
+  {
+    if (dcm_env_ctrl_blk_p->ipu_list[row_id].row_state)
+    {
+      /* send a negative confirmation whether the IPU already exists */
+      if (dcm_env_ctrl_blk_p->ipu_list[row_id].api_instance EQ
+          open_conn_p->conn_req.api_instance)
+      {
+        /* send the negative confirmation to the IPU */
+        psaDCM_open_conn_cnf(DCM_ALREADY_ACTIVATED,
+                                    open_conn_p->conn_req.api_instance);
+        return( DCM_ALREADY_ACTIVATED );  /* It is replaced with return in next line to avoid warning */
+      }
+    }
+    else
+    {
+      /* get the first entry */
+      if (row_id_free EQ DCM_MAX_NUMBER_IPU)
+      {
+        row_id_free = row_id;
+      }
+    }
+  }
+
+  if (row_id_free EQ DCM_MAX_NUMBER_IPU)
+  {
+    /* send the negative confirmation to the IPU */
+    psaDCM_open_conn_cnf(DCM_NOT_READY,
+                                open_conn_p->conn_req.api_instance);
+    return( DCM_NOT_READY );  /* It is replaced with return in next line to avoid warning */
+  }
+  /* Check the bearer type */
+  /* check best one bearer */
+  if(open_conn_p->conn_req.bearer_select EQ DCM_BEARER_ANY)
+  {
+    T_CGATT_STATE  cgatt_state;
+    qAT_PlusCGATT(CMD_SRC_LCL,&cgatt_state);
+
+    if(cgatt_state EQ CGATT_STATE_ATTACHED)
+      open_conn_p->conn_req.bearer_select = DCM_BEARER_GPRS;
+    else
+      open_conn_p->conn_req.bearer_select = DCM_BEARER_GSM;
+  }
+
+  /* If application doesn't give any connection parameters than use default */
+  if(open_conn_p->conn_req.bearer_select EQ DCM_BEARER_GSM   OR
+     open_conn_p->conn_req.bearer_select EQ DCM_BEARER_GPRS)
+  {
+    psaDCM_open_conn_cnf(DCM_INVALID_PARAMETER,open_conn_p->conn_req.api_instance);
+    return DCM_INVALID_PARAMETER;
+  }
+
+  /* If application gives the necessary parameters for a connection use these */
+  else if(open_conn_p->conn_req.bearer_select EQ DCM_BEARER_AS_SPECIFIED)
+  {
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].bearer_handle =
+      open_conn_p->conn_req.dcm_info_conn.bearer_handle;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].app_handle    =
+      open_conn_p->conn_req.dcm_info_conn.app_handle;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].bearer_type   =
+      open_conn_p->conn_req.dcm_info_conn.bearer_type;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].apn_valid     =
+      open_conn_p->conn_req.dcm_info_conn.apn_valid;
+    if(dcm_env_ctrl_blk_p->ipu_list[row_id_free].apn_valid)
+    {
+      strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row_id_free].apn,
+             (char*)open_conn_p->conn_req.dcm_info_conn.apn);
+    }
+    else
+    {
+      strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row_id_free].apn,"");
+    }
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].phone_number_valid =
+      open_conn_p->conn_req.dcm_info_conn.phone_number_valid;
+    if(dcm_env_ctrl_blk_p->ipu_list[row_id_free].phone_number_valid)
+    {
+      strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row_id_free].phone_number,
+             (char*)open_conn_p->conn_req.dcm_info_conn.phone_number);
+    }
+    else
+    {
+      strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row_id_free].phone_number,"");
+    }
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].user_id_valid =
+      open_conn_p->conn_req.dcm_info_conn.user_id_valid;
+    if(dcm_env_ctrl_blk_p->ipu_list[row_id_free].user_id_valid)
+    {
+      strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row_id_free].user_id,
+             (char*)open_conn_p->conn_req.dcm_info_conn.user_id);
+    }
+    else
+    {
+      strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row_id_free].user_id,"");
+    }
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].password_valid =
+      open_conn_p->conn_req.dcm_info_conn.password_valid;
+    if(dcm_env_ctrl_blk_p->ipu_list[row_id_free].password_valid)
+    {
+      strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row_id_free].password,
+             (char*)open_conn_p->conn_req.dcm_info_conn.password);
+    }
+    else
+    {
+      strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row_id_free].password,"");
+    }
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].cid             = open_conn_p->conn_req.dcm_info_conn.cid;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].ip_address      = open_conn_p->conn_req.dcm_info_conn.ip_address;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].dns1            = open_conn_p->conn_req.dcm_info_conn.dns1;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].dns2            = open_conn_p->conn_req.dcm_info_conn.dns2;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].gateway         = open_conn_p->conn_req.dcm_info_conn.gateway;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].auth_type       = open_conn_p->conn_req.dcm_info_conn.auth_type;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].data_compr      = open_conn_p->conn_req.dcm_info_conn.data_compr;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].header_compr    = open_conn_p->conn_req.dcm_info_conn.header_compr;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].precedence      = open_conn_p->conn_req.dcm_info_conn.precedence;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].delay           = open_conn_p->conn_req.dcm_info_conn.delay;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].reliability     = open_conn_p->conn_req.dcm_info_conn.reliability;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].peak_throughput = open_conn_p->conn_req.dcm_info_conn.peak_throughput;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].mean_throughput = open_conn_p->conn_req.dcm_info_conn.mean_throughput;
+    dcm_env_ctrl_blk_p->ipu_list[row_id_free].shareable       = open_conn_p->conn_req.dcm_info_conn.shareable;
+  }
+
+  dcm_env_ctrl_blk_p->ipu_list[row_id_free].api_instance =
+    open_conn_p->conn_req.api_instance;
+
+  /* keep the curretn row */
+  dcm_env_ctrl_blk_p->current_row = row_id_free;
+
+  /* mark the row as used */
+  dcm_env_ctrl_blk_p->ipu_list[row_id_free].row_state = ROW_ASSIGNED;
+
+  /* sum the total of actual rows */
+  if(dcm_env_ctrl_blk_p->ipu_list[row_id_free].bearer_type EQ DCM_BEARER_GPRS)
+  {
+    dcm_env_ctrl_blk_p->gprs_current_total_row++;
+  }
+  else
+  {
+    dcm_env_ctrl_blk_p->gsm_current_total_row++;
+  }
+
+  if(dcm_env_ctrl_blk_p->gprs_current_total_row > 1 OR
+     dcm_env_ctrl_blk_p->gsm_current_total_row > 1)
+  {
+    psaDCM_open_conn_cnf(DCM_ALREADY_ACTIVATED,open_conn_p->conn_req.api_instance);
+    return DCM_ALREADY_ACTIVATED;
+  }
+
+  set_gpf_tcpip_call();
+
+  /* DCM state change */
+  dcm_new_state(DCM_ACTIVATING_CONN,DCM_SUB_NO_ACTION);
+
+  /* if GPRS: send first GPRS AT Command qAT_CGDCONT  */
+  if(dcm_env_ctrl_blk_p->ipu_list[row_id_free].bearer_type EQ DCM_BEARER_GPRS)
+  {
+    dcm_send_cgdcont_get_cmd(dcm_env_ctrl_blk_p->current_row);
+  }
+  else /*send first GSM AT Command sAT_PercentPPP */
+  {
+    dcm_send_percentppp_cmd(dcm_env_ctrl_blk_p->current_row);
+  }
+
+  return DCM_OK;
+}
+
+
+/******************************************************************************/
+T_DCM_RET dcm_process_get_current_conn_event(T_DCM_GET_CURRENT_CONN_REQ_MSG *current_conn_p)
+{
+  TRACE_FUNCTION("DCM: dcm_process_get_current_conn_event()");
+
+  if(dcm_env_ctrl_blk_p->ipu_list[dcm_env_ctrl_blk_p->current_row].row_state EQ
+     ROW_ASSIGNED) {
+    psaDCM_get_current_conn_cnf(DCM_OK,
+                                current_conn_p->current_conn_req.api_instance,
+                                dcm_env_ctrl_blk_p);
+  }
+  else {
+    psaDCM_get_current_conn_cnf(DCM_NOT_READY,
+                                current_conn_p->current_conn_req.api_instance,
+                                dcm_env_ctrl_blk_p);
+  }
+  return DCM_OK;
+}
+
+
+/******************************************************************************/
+T_DCM_RET dcm_process_unknown_event_in_idle(T_DCM_HDR* msg_p)
+{
+  T_DCM_CLOSE_CONN_REQ_MSG *close_conn_req_p;
+  T_DCM_RET ret;
+
+  TRACE_FUNCTION("DCM: dcm_process_unknown_event_in_idle()");
+
+  if(msg_p EQ NULL)
+    return DCM_INVALID_PARAMETER;
+
+  switch(msg_p->msg_id)
+  {
+    case DCM_CLOSE_CONN_REQ_MSG :
+      close_conn_req_p =(T_DCM_CLOSE_CONN_REQ_MSG *)msg_p;
+      psaDCM_close_conn_cnf(DCM_UNKNOWN_EVENT,
+                            close_conn_req_p->close_req.api_instance);
+      set_state_from_ctrl_blk();
+      ret = DCM_OK;
+      break;
+    default:
+      ret = DCM_UNKNOWN_EVENT;
+      break;
+  }
+  return ret;
+}
+
+
+/******************************************************************************/
+T_DCM_RET dcm_free_row(U8 current_row)
+{
+  TRACE_FUNCTION("DCM: dcm_free_row()");
+
+  /* Decrease the current number of IPU */
+  dcm_env_ctrl_blk_p->ipu_list[current_row].row_state = ROW_FREE;
+  if(dcm_env_ctrl_blk_p->ipu_list[current_row].bearer_type EQ DCM_BEARER_GPRS)
+    dcm_env_ctrl_blk_p->gprs_current_total_row--;
+  else
+    dcm_env_ctrl_blk_p->gsm_current_total_row--;
+
+  /* clear the row in the structure of IP Users */
+  dcm_clear_ipu_info(current_row);
+  return DCM_OK;
+}
+
+
+/*
+ * Function used to store some IPU informations
+ *
+ * @param   row to access [0, 256],
+ * @param   IPU id
+ * @param   bearer type
+ * @param   apn, mtu, pdp@, cid, user, password, dns1, dns2, gateway
+ * @return    DCM_OK or DCM errors
+ */
+T_DCM_RET dcm_store_ipu_info(U8 row, T_BEARER_TYPE bearer_type, char *apn,
+                             char *number, char *pdp_addr, U8 cid_used,
+                             char *user, char *password, U32 dns1, U32 dns2,
+                             U32 gateway)
+{
+  TRACE_FUNCTION("DCM: dcm_store_ipu_info()");
+
+  if(bearer_type EQ DCM_BEARER_GPRS)
+    strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].apn, apn);
+  else if (bearer_type EQ DCM_BEARER_GSM)
+    strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].phone_number,number);
+  else
+    return DCM_INVALID_PARAMETER;
+  dcm_env_ctrl_blk_p->ipu_list[row].bearer_type = bearer_type;
+  dcm_env_ctrl_blk_p->ipu_list[row].cid = cid_used;
+  strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].user_id, user);
+  strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].password, password);
+  dcm_env_ctrl_blk_p->ipu_list[row].dns1 = dns1;
+  dcm_env_ctrl_blk_p->ipu_list[row].dns2 = dns2;
+  dcm_env_ctrl_blk_p->ipu_list[row].gateway = gateway;
+
+  return DCM_OK;
+}
+
+
+/* resets parameters of a row */
+T_DCM_RET dcm_clear_ipu_info(U8 row)
+{
+  char empty[] = "";
+  TRACE_FUNCTION("DCM: dcm_clear_ipu_info()");
+
+  dcm_env_ctrl_blk_p->ipu_list[row].bearer_type = DCM_BEARER_NO;
+  strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].apn, empty);
+  strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].phone_number,empty);
+  dcm_env_ctrl_blk_p->ipu_list[row].cid = 0;
+  strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].user_id, empty);
+  strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].password, empty);
+  dcm_env_ctrl_blk_p->ipu_list[row].dns1 = 0;
+  dcm_env_ctrl_blk_p->ipu_list[row].dns2 = 0;
+  dcm_env_ctrl_blk_p->ipu_list[row].gateway = 0;
+
+  return DCM_OK;
+}
+
+/*
+ * Function used to send the <AT+CGDCONT=?> command
+ *
+ * This command is used to get the next Context IDentifier available in the PS.
+ * This cid will be used very often in the suite
+ *
+ * @param   row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+LOCAL T_DCM_RET dcm_send_cgdcont_get_cmd(U8 row)
+{
+  /*T_GPRS_CONT_REC defCtxts[MAX_CID_PLUS_EINS]; */
+  T_PDP_CONTEXT defCtxts[PDP_CONTEXT_CID_MAX];
+  SHORT cid_array[PDP_CONTEXT_CID_MAX];
+  UBYTE i;
+
+  TRACE_FUNCTION("DCM: dcm_send_cgdcont_get_cmd()");
+
+  if(qAT_PlusCGDCONT(CMD_SRC_LCL,defCtxts,cid_array) NEQ AT_CMPL)
+  {
+    psaDCM_open_conn_cnf( DCM_NOT_READY, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+    return DCM_OK;
+  }
+  else
+  {
+    for( i= 0; i < MAX_CID_PLUS_EINS ; i++)
+    {
+      if(cid_array[i] EQ dcm_env_ctrl_blk_p->ipu_list[row].cid)
+      {
+        TRACE_EVENT_P2("DCM: dcm cid is the same %d=%d",
+                       cid_array[i],
+                       dcm_env_ctrl_blk_p->ipu_list[row].cid);
+      }
+    }
+    return  dcm_send_cgdcont_cmd(row);
+  }
+
+}
+
+
+/*
+ * Function used to send the <AT+CGDCONT=cid, "IP", "apn", "", 0, 0> command
+ *
+ * This command is used to declare the PDP Context.
+ *
+ * @param   row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+LOCAL T_DCM_RET dcm_send_cgdcont_cmd(U8 row)
+{
+  /*T_GPRS_CONT_REC input_txt; */
+  T_PDP_CONTEXT input_txt;
+
+  TRACE_FUNCTION("DCM: dcm_send_cgdcont_cmd()");
+  TRACE_EVENT_P1("DCM: ipu_list[row].apn = %s",dcm_env_ctrl_blk_p->ipu_list[row].apn);
+
+  strcpy(input_txt.pdp_apn,(char*)dcm_env_ctrl_blk_p->ipu_list[row].apn);
+  strcpy(input_txt.pdp_type,"IP");
+  memset(&input_txt.pdp_addr,0,sizeof(T_NAS_ip));
+  input_txt.d_comp = PDP_CONTEXT_D_COMP_OMITTED;
+  input_txt.h_comp = PDP_CONTEXT_H_COMP_OMITTED;
+
+  if(sAT_PlusCGDCONT(CMD_SRC_LCL,dcm_env_ctrl_blk_p->ipu_list[row].cid, &input_txt) NEQ AT_CMPL)
+  {
+    psaDCM_open_conn_cnf(DCM_NOT_READY, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+    return DCM_OK;
+  }
+  else
+  {
+    dcm_send_cgatt_cmd(row);
+    return DCM_OK;
+  }
+}
+
+
+/*
+ * Function used to send the <AT+CGATT=cid> command
+ *
+ * This command is used to force attachment to the network.
+ *
+ * @param   row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+LOCAL T_DCM_RET dcm_send_cgatt_cmd(U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_send_cgatt_cmd()");
+
+  /* prepare the AT command including some dynamic info like cid */
+  switch(sAT_PlusCGATT(CMD_SRC_LCL, CGATT_STATE_ATTACHED))
+  {
+    case AT_FAIL:
+    case AT_BUSY:
+      psaDCM_open_conn_cnf(DCM_NOT_READY, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+      dcm_free_row(row);
+      set_state_from_ctrl_blk();
+      break;
+
+    case AT_CMPL:
+      dcm_send_cgpco_auth_cmd(row);
+      break;
+
+    case AT_EXCT:
+      dcm_env_ctrl_blk_p->dcm_call_back = dcm_handle_message;
+      dcm_new_state(DCM_ACTIVATING_CONN, DCM_SUB_WAIT_CGATT_CNF);
+      break;
+
+    default :
+      break;
+  }
+  return DCM_OK;
+}
+
+
+/*
+ * Function used to send the <AT%CGPCO=0, cid, "PAP, username,
+ * password, 0.0.0.0, 0.0.0.0"> command
+ *
+ * This command is used to configure the PS to TCPIP over SNDCP
+ *
+ * @param   row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+LOCAL T_DCM_RET dcm_send_cgpco_auth_cmd(U8 row)
+{
+  CHAR dns[2];
+  strcpy(dns, "");
+
+  TRACE_FUNCTION("DCM: dcm_send_cgpco_auth_cmd()");
+  TRACE_EVENT_P2("DCM: user=%s, password=%s",
+                 dcm_env_ctrl_blk_p->ipu_list[row].user_id,
+                 dcm_env_ctrl_blk_p->ipu_list[row].password);
+
+  if(sAT_PercentCGPCO(CMD_SRC_LCL,dcm_env_ctrl_blk_p->ipu_list[row].cid,
+                      ACI_PCO_AUTH_PROT_PAP,
+                      (char*)dcm_env_ctrl_blk_p->ipu_list[row].user_id,
+                      (char*)dcm_env_ctrl_blk_p->ipu_list[row].password,
+                      dns,dns) NEQ AT_CMPL)
+  {
+    psaDCM_open_conn_cnf(DCM_NOT_READY, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+    return DCM_OK;
+  }
+  else
+  {
+    dcm_send_cgerep_cmd(row);
+    return DCM_OK;
+  }
+}
+
+
+/*
+ * Function used to send the <AT+CGEREP=cid, 0> command
+ *
+ * This command is used to configure the PS to send EVENT to us
+ *
+ * @param   row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+LOCAL T_DCM_RET dcm_send_cgerep_cmd(U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_send_cgerep_cmd()");
+
+  /* prepare the AT command including some dynamic info like cid */
+  if (sAT_PlusCGEREP(CMD_SRC_LCL,CGEREP_MODE_BUFFER,CGEREP_BFR_CLEAR) NEQ AT_CMPL)
+  {
+    psaDCM_open_conn_cnf(DCM_NOT_READY, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+    return DCM_OK;
+  }
+  else
+  {
+    strcpy((char*)dcm_env_ctrl_blk_p->ipu_list[row].phone_number,"*98*1#");
+    /*  reset the WAP-data if not done at call termination before */
+    sAT_PercentWAP(CMD_SRC_LCL,0);
+    sAT_PercentWAP(CMD_SRC_LCL,1);
+    dcm_send_sat_dn_cmd(row);
+    return DCM_OK;
+  }
+}
+
+
+/*
+ * Function used to send the <AT+CGACT=cid, 0> command
+ *
+ * This command is used to deactivate the PDP decontext.
+ *
+ * @param   row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+LOCAL T_DCM_RET dcm_send_cgdeact_cmd(U8 row)
+{
+  T_CGATT_STATE gprs_attach_state;
+  SHORT cids[MAX_CID_PLUS_EINS] = {GPRS_CID_1,PDP_CONTEXT_CID_INVALID};
+
+
+  TRACE_FUNCTION("DCM: dcm_send_cgdeact_cmd()");
+
+  /* Packet Counter */
+  sAT_PercentSNCNT(CMD_SRC_LCL,NAS_RESET_YES);
+
+  qAT_PlusCGATT(CMD_SRC_LCL,&gprs_attach_state);
+  TRACE_EVENT_P1("DCM: Attatch State %d",gprs_attach_state);
+
+#if 0   //// pinghua DCM_OPEN_CLOSE patch 20080429
+ 
+  if(gprs_attach_state NEQ CGATT_STATE_ATTACHED)
+  {
+    psaDCM_close_conn_cnf(DCM_OK,dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+    return DCM_OK;
+  }
+ #endif  // // pinghua DCM_OPEN_CLOSE patch 20080429 end
+
+  /* GPRS BEARER CLOSING */
+  switch(sAT_PlusCGACT(CMD_SRC_LCL,CGACT_STATE_DEACTIVATED,cids))
+  {
+    case AT_FAIL:
+    case AT_BUSY:
+      psaDCM_close_conn_cnf(DCM_NOT_READY,
+                            dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+      set_state_from_ctrl_blk();
+      break;
+
+    case AT_CMPL:
+      psaDCM_close_conn_cnf(DCM_OK, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+      dcm_free_row(row);
+      set_state_from_ctrl_blk();
+      break;
+
+    case AT_EXCT:
+      dcm_new_state(DCM_CLOSING_CONN, DCM_SUB_WAIT_CGDEACT_CNF);
+      dcm_env_ctrl_blk_p->dcm_call_back = dcm_handle_message;
+      break;
+
+    default :
+      break;
+  }
+  return DCM_OK;
+}
+
+
+LOCAL T_DCM_RET dcm_send_sat_h_cmd(U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_send_sat_h_cmd()");
+
+  switch(sAT_H(CMD_SRC_LCL))
+  {
+    case AT_FAIL:
+    case AT_BUSY:
+      psaDCM_close_conn_cnf(DCM_NOT_READY, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+      set_state_from_ctrl_blk();
+      break;
+
+    case AT_CMPL:
+      break;
+
+    case AT_EXCT:
+      dcm_new_state(DCM_CLOSING_CONN, DCM_SUB_WAIT_SATH_CNF);
+      dcm_env_ctrl_blk_p->dcm_call_back = dcm_handle_message;
+      break;
+
+    default :
+      break;
+  }
+  return DCM_OK;
+}
+
+
+/*
+ * Function used to send the <AT+CGPADDR=cid> command
+ *
+ * This command is used to get back the pdp@ of the module
+ *
+ * @param   row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+LOCAL T_DCM_RET dcm_send_cgpaddr_cmd(U8 row)
+{
+  T_NAS_ip pdp_address[MAX_CID];
+  SHORT cid_array[MAX_CID];
+  cid_array[0] = dcm_env_ctrl_blk_p->ipu_list[row].cid;
+  cid_array[1] = PDP_CONTEXT_CID_INVALID;
+
+  TRACE_FUNCTION("DCM: dcm_send_cgpaddr_cmd()");
+
+  memset(pdp_address , 0x00, sizeof(T_NAS_ip)*MAX_CID);
+
+  /* prepare the AT command including some dynamic info like cid */
+  if(sAT_PlusCGPADDR(CMD_SRC_LCL,cid_array,pdp_address) NEQ AT_CMPL)
+  {
+    psaDCM_open_conn_cnf(DCM_NOT_READY,
+                         dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+    return DCM_OK;
+  }
+  else
+  {
+    memcpy(dcm_env_ctrl_blk_p->ipu_list[row].pdp_addr,
+           pdp_address[0].ip_address.ipv4_addr.a4,
+           sizeof(NAS_SIZE_IPv4_ADDR));
+    TRACE_EVENT_P1("DCM: PDP addr=%s",dcm_env_ctrl_blk_p->ipu_list[row].pdp_addr);
+    dcm_send_cgpco_get_cmd(row);
+    return DCM_OK;
+  }
+}
+
+
+/*
+ * Function used to send the <AT%CGPCO=1,1,,cid> command
+ *
+ * This command is used to get back the dns1, dns2 and gateway @
+ *
+ * @param   row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+LOCAL T_DCM_RET dcm_send_cgpco_get_cmd(U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_send_cgpco_get_cmd()");
+
+  psaDCM_open_conn_cnf(DCM_OK, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+  dcm_env_ctrl_blk_p->dcm_call_back = dcm_handle_message;
+  dcm_new_state(DCM_CONN_ACTIVATED, DCM_SUB_NO_ACTION);
+
+  return DCM_OK;
+}
+
+
+T_DCM_RET dcm_send_percentppp_cmd(U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_send_percentppp_cmd()");
+  if(sAT_PercentPPP(CMD_SRC_LCL,
+                    A_PAP,
+                    (char*)dcm_env_ctrl_blk_p->ipu_list[row].user_id,
+                    (char*)dcm_env_ctrl_blk_p->ipu_list[row].password,
+                    USE_NO_PPP_FOR_AAA) NEQ AT_CMPL)
+  {
+    psaDCM_open_conn_cnf(DCM_NOT_READY,
+                         dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();  
+  }
+  else
+  {
+    /*  reset the WAP-data if not done at call termination before */
+    sAT_PercentWAP(CMD_SRC_LCL,0);
+    sAT_PercentWAP(CMD_SRC_LCL,1);
+    dcm_send_sat_dn_cmd(row);
+  }
+
+  return DCM_OK;
+}
+
+
+LOCAL T_DCM_RET dcm_send_sat_dn_cmd(U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_send_sat_dn_cmd()");
+
+  switch(sAT_Dn(CMD_SRC_LCL,
+                (char*)dcm_env_ctrl_blk_p->ipu_list[row].phone_number,
+                D_CLIR_OVRD_Default,
+                D_CUG_CTRL_NotPresent,
+                D_TOC_Data))
+  {
+    case AT_FAIL:
+    case AT_BUSY:
+    case AT_CMPL:
+      psaDCM_open_conn_cnf(DCM_NOT_READY,
+                           dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+      dcm_free_row(row);
+      set_state_from_ctrl_blk();
+      break;
+
+    case AT_EXCT:
+      dcm_env_ctrl_blk_p->dcm_call_back = dcm_handle_message;
+      if(dcm_env_ctrl_blk_p->ipu_list[row].bearer_type EQ DCM_BEARER_GPRS) {
+        dcm_new_state(DCM_ACTIVATING_CONN, DCM_SUB_WAIT_CGACT_CNF);
+      }
+      else {
+        dcm_new_state(DCM_ACTIVATING_CONN, DCM_SUB_WAIT_SATDN_CNF);
+      }
+      break;
+
+    default:
+      break;
+  }
+
+  return DCM_OK;
+}
+
+
+LOCAL T_DCM_RET dcm_send_percentppp_get_cmd(U8 row)
+{
+  ULONG dns1=0;
+  ULONG dns2 =0;
+  ULONG ipaddr = 0 ;
+
+  TRACE_FUNCTION("DCM: dcm_send_percentppp_get_cmd()");
+
+  if(qAT_PercentPPP(CMD_SRC_LCL, &ipaddr,&dns1,&dns2) NEQ AT_CMPL)
+  {
+    psaDCM_open_conn_cnf(DCM_NOT_READY,
+                         dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+  }
+  else
+  {
+    psaDCM_open_conn_cnf(DCM_OK,
+                         dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_env_ctrl_blk_p->dcm_call_back = dcm_handle_message;
+    dcm_new_state(DCM_CONN_ACTIVATED,DCM_SUB_NO_ACTION);
+  }
+
+  return DCM_OK;
+}
+
+
+/*
+ * Function used to process the events and errors received from PS
+ *
+ * @param   received message
+ * @return  DCM_OK or DCM errors
+ */
+T_DCM_RET dcm_process_event_error_reception(T_DCM_HDR * msg_p)
+{
+  U8 row = dcm_env_ctrl_blk_p->current_row;;
+
+  TRACE_FUNCTION("DCM: dcm_process_event_error_reception()");
+
+  /* check if this port number is really used by DCM */
+  if(dcm_env_ctrl_blk_p->ipu_list[row].row_state)
+  {
+    psaDCM_error_ind((T_DCM_STATUS_IND_MSG*)msg_p,
+                      dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    /* We cannot use this function call here (set_state_from_ctrl_blk();)
+       since this will execute reset_gpf_tcpip_call() immediately, but we need
+       to evaulate this flag later on */
+    if((dcm_env_ctrl_blk_p->gsm_current_total_row +
+       dcm_env_ctrl_blk_p->gprs_current_total_row ) > 0)
+    {
+      /* another active connection */
+      dcm_new_state(DCM_CONN_ACTIVATED, DCM_SUB_NO_ACTION);
+    }
+    else
+    {
+      dcm_new_state(DCM_IDLE, DCM_SUB_NO_ACTION);
+    }
+  }
+  return DCM_OK;
+}
+
+
+/*
+ * Function used to process the reception of the answer to AT+CGATT=...
+ *
+ * @param   received message, and row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+T_DCM_RET dcm_process_cgatt_ans(T_DCM_HDR * msg_p, U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_process_cgatt_ans()");
+
+  if(msg_p->msg_id EQ DCM_NEXT_CMD_READY_MSG)
+  {
+    /* send next AT command */
+    return dcm_send_cgpco_auth_cmd(row);
+  }
+  else
+  {
+    psaDCM_open_conn_cnf(DCM_NOT_READY,
+                         dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+    return DCM_OK;
+  }
+}
+
+
+/*
+ * Function used to process the reception of the answer to AT+CGACT=...
+ *
+ * @param   received message, and row in the IPU structure related to the actual command
+ * @return  DCM_OK or DCM errors
+ */
+T_DCM_RET dcm_process_cgact_ans(T_DCM_HDR * msg_p, U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_process_cgact_ans()");
+
+  if (msg_p->msg_id EQ DCM_NEXT_CMD_READY_MSG)
+  {
+    return dcm_send_cgpaddr_cmd(row);
+  }
+  else
+  {
+    psaDCM_open_conn_cnf(DCM_NOT_READY,
+                         dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    /*set_state_from_ctrl_blk();*/
+    /* We cannot use this function call here (set_state_from_ctrl_blk();)
+       since this will execute reset_gpf_tcpip_call() immediately, but we need
+       to evaulate this flag later on */
+
+    if((dcm_env_ctrl_blk_p->gsm_current_total_row +
+       dcm_env_ctrl_blk_p->gprs_current_total_row ) > 0)
+    {
+      /* another active connection */
+      dcm_new_state(DCM_CONN_ACTIVATED, DCM_SUB_NO_ACTION);
+    }
+    else
+    {
+      dcm_new_state(DCM_IDLE, DCM_SUB_NO_ACTION);
+    }
+    return DCM_OK;
+  }
+}
+
+
+T_DCM_RET dcm_process_cgdeact_ans(T_DCM_HDR * msg_p, U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_process_cgdeact_ans()");
+
+  if(msg_p->msg_id EQ DCM_NEXT_CMD_READY_MSG)
+  {
+//pinghua add one broken messaged indiction for net drop !
+   if(is_netdrop == TRUE )
+   {
+
+	psaDCM_error_ind((T_DCM_STATUS_IND_MSG*)msg_p,
+                         dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+
+   }	
+  else    	
+    	psaDCM_close_conn_cnf(DCM_OK,
+                          dcm_env_ctrl_blk_p->ipu_list[row].api_instance); 
+//end 
+   
+    dcm_free_row(row);
+  }
+  else
+  {
+    psaDCM_close_conn_cnf(DCM_NOT_READY,
+                          dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_env_ctrl_blk_p->ipu_list[row].row_state = ROW_ASSIGNED;
+  }
+  set_state_from_ctrl_blk();
+  return DCM_OK;
+}
+
+
+T_DCM_RET dcm_process_sat_dn_ans(T_DCM_HDR * msg_p, U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_process_sat_dn_ans()");
+
+  if(msg_p->msg_id EQ DCM_NEXT_CMD_READY_MSG)
+  {
+    return dcm_send_percentppp_get_cmd(row);
+  }
+  else
+  {
+    T_DCM_STATUS_IND_MSG * message = (T_DCM_STATUS_IND_MSG *)msg_p;
+    /* We need to check if TCPIP has been already initialised successfully or not*/
+    if ( wap_state EQ TCPIP_Activation)
+    {
+      /* Make shure we shutdown TCPIP properly */
+      wap_state = TCPIP_Deactivation;
+      psaTCPIP_Shutdown_Req();
+    }
+    psaDCM_open_conn_cnf(message->result, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+    set_state_from_ctrl_blk();
+    return DCM_OK;
+  }
+}
+
+
+T_DCM_RET dcm_process_sat_h_ans(T_DCM_HDR * msg_p, U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_process_sat_h_ans()");
+
+  if(msg_p->msg_id EQ DCM_NEXT_CMD_READY_MSG)
+  {
+    psaDCM_close_conn_cnf(DCM_OK,dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+    dcm_free_row(row);
+  }
+  else
+  {
+    psaDCM_close_conn_cnf(DCM_NOT_READY,
+                          dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+  }
+  set_state_from_ctrl_blk();
+  return DCM_OK;
+}
+
+
+GLOBAL ULONG bytes2ipv4addr(UBYTE *host)
+{
+  UBYTE c1;
+  ULONG addr = 0;
+  char *tmp;
+  if (!host OR host[0]>'9' OR host[0]<'0') return((ULONG)-1);
+
+  tmp=(char *)host;
+  c1 = atoi(tmp);
+  addr = addr | c1 << 24;
+  tmp = strstr(tmp, ".");
+  if(!tmp) return((ULONG)-1);
+  tmp++;
+  c1 = atoi(tmp);
+  addr = addr | c1 << 16;
+  tmp = strstr(tmp, ".");
+  if(!tmp) return((ULONG)-1);
+  tmp++;
+  c1 = atoi(tmp);
+  addr = addr | c1 <<8 ;
+  tmp = strstr(tmp, ".");
+  if(!tmp) return((ULONG)-1);
+  tmp++;
+  c1 = atoi(tmp);
+  addr = addr | c1 ;
+  return dcm_ipaddr_htonl(addr);
+}
+
+
+LOCAL ULONG dcm_ipaddr_htonl(ULONG horder_ipaddr)
+{
+  return((U32)((((U32)(horder_ipaddr) & 0x000000ffU) << 24) |
+          (((U32)(horder_ipaddr) & 0x0000ff00U) <<  8) |
+          (((U32)(horder_ipaddr) & 0x00ff0000U) >>  8) |
+          (((U32)(horder_ipaddr) & 0xff000000U) >> 24)));
+}
+
+
+LOCAL T_DCM_RET dcm_send_percentcal_get_cmd(UBYTE row)
+{
+  T_ACI_CAL_ENTR call_tab[MAX_CALL_NR];
+  UBYTE i;
+  UBYTE count = 0;
+
+  TRACE_FUNCTION("DCM: dcm_send_percentcal_get_cmd()");
+
+  if(qAT_PercentCAL(CMD_SRC_LCL, call_tab) EQ AT_CMPL)
+  {
+    for(i=0; i<MAX_CALL_NR; i++)
+    {
+      if(call_tab[i].index EQ -1)
+      {
+        count++;
+        /* in other  words no active call*/
+        if(count EQ (MAX_CALL_NR -1) )
+        {
+          TRACE_EVENT("DCM: No active call");
+          psaDCM_close_conn_cnf(DCM_OK, dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+          dcm_free_row(row);
+          set_state_from_ctrl_blk();
+        }
+        break;
+      }
+      switch(call_tab[i].status)
+      {
+        case CAL_STAT_Active:
+          dcm_send_sat_h_cmd(row);
+          break;
+        case CAL_STAT_Dial:
+        case CAL_STAT_Alerting:
+          dcm_send_sat_abort_cmd(row);
+          break;
+
+        default:
+          TRACE_EVENT("DCM: dcm_send_percentcal_get_cmd DEFAULT call status");
+          break;
+      }
+    }
+    return DCM_OK;
+  }
+  return DCM_OK;
+}
+
+
+LOCAL T_DCM_RET dcm_send_sat_abort_cmd(U8 row)
+{
+  TRACE_FUNCTION("DCM: dcm_send_sat_h_cmd()");
+
+  switch(sAT_Abort(CMD_SRC_LCL,AT_CMD_D))
+  {
+    case AT_FAIL:
+    case AT_BUSY:
+      psaDCM_close_conn_cnf(DCM_NOT_READY,
+                            dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+      set_state_from_ctrl_blk();
+      break;
+
+    case AT_CMPL:
+      psaDCM_close_conn_cnf(DCM_OK,dcm_env_ctrl_blk_p->ipu_list[row].api_instance);
+      dcm_free_row(row);
+      set_state_from_ctrl_blk();
+      break;
+
+    case AT_EXCT:
+      dcm_new_state(DCM_CLOSING_CONN, DCM_SUB_WAIT_SATH_CNF);
+      dcm_env_ctrl_blk_p->dcm_call_back = dcm_handle_message;
+      break;
+
+    default :
+      break;
+  }
+  return DCM_OK;
+}
+
+
+/* This functions checks if antother conneciton is active and changes the
+   DCM state corresponding */
+LOCAL void set_state_from_ctrl_blk()
+{
+  if((dcm_env_ctrl_blk_p->gsm_current_total_row +
+      dcm_env_ctrl_blk_p->gprs_current_total_row ) > 0)
+  {
+    /* another active connection */
+    dcm_new_state(DCM_CONN_ACTIVATED, DCM_SUB_NO_ACTION);
+  }
+  else
+  {
+    dcm_new_state(DCM_IDLE, DCM_SUB_NO_ACTION);
+    reset_gpf_tcpip_call();
+  }
+}