diff src/g23m-gprs/sndcp/sndcp_suas.c @ 183:219afcfc6250

src/g23m-gprs: initial import from TCS3.2/LoCosto
author Mychaela Falconia <falcon@freecalypso.org>
date Thu, 13 Oct 2016 04:24:13 +0000
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/g23m-gprs/sndcp/sndcp_suas.c	Thu Oct 13 04:24:13 2016 +0000
@@ -0,0 +1,1220 @@
+/*
++-----------------------------------------------------------------------------
+|  Project :  GPRS (8441)
+|  Modul   :  sndcp_suas.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 modul is part of the entity SNDCP and implements all
+|             functions to handles the incoming process internal signals as
+|             described in the SDL-documentation (SUA-statemachine)
++-----------------------------------------------------------------------------
+*/
+
+
+#define ENTITY_SNDCP
+
+/*==== INCLUDES =============================================================*/
+
+#include "typedefs.h"    /* to get Condat data types */
+#include "vsi.h"        /* to get a lot of macros */
+#include "macdef.h"
+#include "gsm.h"        /* to get a lot of macros */
+#include "prim.h"       /* to get the definitions of used SAP and directions */
+#include <string.h>    /* to get memcpy() */
+#include "dti.h"
+#include "sndcp.h"        /* to get the global entity definitions */
+#include "sndcp_f.h"       /* to get the functions to access the global arrays*/
+#include "sndcp_suaf.h"     /* to get internal functions of service sua */
+#include "sndcp_nus.h"     /* to get signal functions to service nu */
+#include "sndcp_cias.h"     /* to get signal functions to service cia */
+
+/*==== CONST ================================================================*/
+
+/*==== LOCAL VARS ===========================================================*/
+
+/*==== PRIVATE FUNCTIONS ====================================================*/
+#ifdef _SNDCP_DTI_2_
+/*
++------------------------------------------------------------------------------
+| Function    : sua_add_ll_desc_req_params
++------------------------------------------------------------------------------
+| Description : sets the parameters of the given ll_desc_req
+|
+| Parameters  : pdu_ref, ll_desc_req*
+|
++------------------------------------------------------------------------------
+*/
+LOCAL void sua_add_ll_desc_req_params (T_pdu_ref pdu_ref,
+                                       T_LL_DESC_REQ* ll_desc_req)
+{
+  T_snsm_qos snsm_qos; /* initialized later with getter */
+
+  TRACE_FUNCTION( "sua_add_ll_desc_req_params" );
+
+  /*
+   * Set quality of service.
+   */
+  sndcp_get_nsapi_qos(pdu_ref.ref_nsapi, &snsm_qos);
+  sndcp_snsm_qos_to_ll_qos(snsm_qos, &ll_desc_req->ll_qos);
+  /*
+   * Set radio prio.
+   */
+  sndcp_get_nsapi_prio(pdu_ref.ref_nsapi,
+                       &ll_desc_req->radio_prio);
+#ifdef REL99
+  sndcp_get_nsapi_pktflowid(pdu_ref.ref_nsapi,
+                            (U16 *)&ll_desc_req->pkt_flow_id);
+#endif /*REL99*/
+  /*
+   * Set pdu_ref.
+   */
+  ll_desc_req->reference1.ref_nsapi = pdu_ref.ref_nsapi;
+  ll_desc_req->reference1.ref_npdu_num = (UBYTE)pdu_ref.ref_npdu_num;
+  ll_desc_req->reference1.ref_seg_num = pdu_ref.ref_seg_num;
+
+} /* sua_add_ll_desc_req_params() */
+#else /* _SNDCP_DTI_2_ */
+/*
++------------------------------------------------------------------------------
+| Function    : sua_add_ll_data_req_params
++------------------------------------------------------------------------------
+| Description : sets the parameters of the given ll_data_req
+|
+| Parameters  : pdu_ref, ll_data_req*
+|
++------------------------------------------------------------------------------
+*/
+LOCAL void sua_add_ll_data_req_params (T_pdu_ref pdu_ref,
+                                       T_LL_DATA_REQ* ll_data_req)
+{
+  T_snsm_qos snsm_qos; /* initialized later with getter */
+
+  TRACE_FUNCTION( "sua_add_ll_data_req_params" );
+
+  /*
+   * Set quality of service.
+   */
+  sndcp_get_nsapi_qos(pdu_ref.ref_nsapi, &snsm_qos);
+  sndcp_snsm_qos_to_ll_qos(snsm_qos, &ll_data_req->ll_qos);
+  /*
+   * Set radio prio.
+   */
+  sndcp_get_nsapi_prio(pdu_ref.ref_nsapi,
+                       &ll_data_req->radio_prio);
+#ifdef REL99
+  sndcp_get_nsapi_pktflowid(pdu_ref.ref_nsapi,
+                            &ll_data_req->pkt_flow_id);
+#endif /*REL99*/
+
+  /*
+   * Set pdu_ref.
+   */
+  ll_data_req->reference1.ref_nsapi = pdu_ref.ref_nsapi;
+  ll_data_req->reference1.ref_npdu_num = (UBYTE)pdu_ref.ref_npdu_num;
+  ll_data_req->reference1.ref_seg_num = pdu_ref.ref_seg_num;
+
+} /* sua_add_ll_data_req_params() */
+#endif /* _SNDCP_DTI_2_ */
+#ifdef _SNDCP_DTI_2_
+/*
++------------------------------------------------------------------------------
+| Function    : sua_add_sn_header
++------------------------------------------------------------------------------
+| Description : sets the segment header in the given ll_desc_req
+|
+| Parameters  : first and/or last segment , ll_desc_req*, packet type.
+|
++------------------------------------------------------------------------------
+*/
+LOCAL void sua_add_sn_header (U8 seg_pos,
+                              T_pdu_ref pdu_ref,
+                              T_LL_DESC_REQ* ll_desc_req,
+                              U8 packet_type)
+{
+  USHORT offset = ENCODE_OFFSET_BYTE;
+  BOOL compressed = FALSE;
+  T_desc3* desc3 = NULL;
+  U8* sndcp_header = NULL;
+  U8 sapi_index = 0;
+
+  TRACE_FUNCTION( "sua_add_sn_header" );
+
+  /* Get the descriptor describing the memory area with the sndcp header */
+  desc3 = (T_desc3*)ll_desc_req->desc_list3.first;
+  sndcp_header = (U8*)desc3->buffer;
+  sndcp_header[offset] = 0;
+
+  sndcp_get_sapi_index(ll_desc_req->sapi, &sapi_index); 
+  /*
+   * Octet 1, F bit.
+   */
+  if ((seg_pos & SEG_POS_FIRST) > 0)
+  {
+    sndcp_header[offset] += (1 << 6);
+  }
+  /*
+   * Octet 1, 0 for SN_DATA, i.e. nothing.
+   */
+
+  /*
+   * Octet 1, M bit.
+   */
+  if ((seg_pos & SEG_POS_LAST) == 0)
+  {
+    sndcp_header[offset] += (1 << 4);
+  }
+  /*
+   * Octet 1, NSAPI number.
+   */
+  sndcp_header[offset] += pdu_ref.ref_nsapi;
+
+  offset ++;
+  if ((seg_pos & SEG_POS_FIRST) > 0)
+  {
+    sndcp_header[offset] = 0;
+    /*
+     * This is the first bit.
+     * Find d/pcomp values and set them.
+     */
+    /*
+     * Octet 2, dcomp
+     */
+    sndcp_header[offset] +=
+      (U8)(sndcp_data->mg.cur_xid_block[sapi_index].v42.dcomp << 4);
+    /*
+     * Octet 2, pcomp
+     */
+    sndcp_is_nsapi_header_compressed(pdu_ref.ref_nsapi, &compressed);
+    if (compressed) {
+      if (packet_type == TYPE_UNCOMPRESSED_TCP)
+      {
+        /*
+         * Uncompressed TCP.
+         */
+        sndcp_header[offset] =
+          sndcp_data->mg.cur_xid_block[sapi_index].vj.pcomp1;
+      }
+      else if (packet_type == TYPE_IP)
+      {
+        /*
+         * IP.
+         */
+        sndcp_header[offset] = 0;
+      }
+      else
+      {
+        /*
+         * Compressed TCP.
+         */
+        sndcp_header[offset] =
+          sndcp_data->mg.cur_xid_block[sapi_index].vj.pcomp2;
+      }
+    }
+
+    offset ++;
+  }
+
+  /*
+   * Octet 3, N-PDU number, if F bit set to 1.
+   */
+  if ((seg_pos & SEG_POS_FIRST) > 0)
+  {
+    sndcp_header[offset] = (U8)pdu_ref.ref_npdu_num;
+  }
+
+
+} /* sua_add_sn_header() */
+#else /* _SNDCP_DTI_2_ */
+/*
++------------------------------------------------------------------------------
+| Function    : sua_add_sn_header
++------------------------------------------------------------------------------
+| Description : sets the segment header in the given ll_data_req
+|
+| Parameters  : first and/or last segment , ll_data_req*, packet type.
+|
++------------------------------------------------------------------------------
+*/
+LOCAL void sua_add_sn_header (UBYTE seg_pos,
+                              T_pdu_ref pdu_ref,
+                              T_LL_DATA_REQ* ll_data_req,
+                              UBYTE packet_type)
+{
+  USHORT offset = ll_data_req->sdu.o_buf / 8;
+  BOOL compressed = FALSE;
+
+  TRACE_FUNCTION( "sua_add_sn_header" );
+
+  ll_data_req->sdu.buf[offset] = 0;
+  /*
+   * Octet 1, F bit.
+   */
+  if ((seg_pos & SEG_POS_FIRST) > 0) {
+    ll_data_req->sdu.buf[offset] += (1 << 6);
+  }
+  /*
+   * Octet 1, 0 for SN_DATA, i.e. nothing.
+   */
+
+  /*
+   * Octet 1, M bit.
+   */
+  if ((seg_pos & SEG_POS_LAST) == 0) {
+    ll_data_req->sdu.buf[offset] += (1 << 4);
+  }
+  /*
+   * Octet 1, NSAPI number.
+   */
+  ll_data_req->sdu.buf[offset] += pdu_ref.ref_nsapi;
+
+  offset ++;
+  if ((seg_pos & SEG_POS_FIRST) > 0) {
+    ll_data_req->sdu.buf[offset] = 0;
+    /*
+     * This is the first bit.
+     * Find d/pcomp values and set them.
+     */
+    /*
+     * Octet 2, dcomp
+     */
+    ll_data_req->sdu.buf[offset] +=
+      (UBYTE)(sndcp_data->su->cur_xid_block.v42.dcomp << 4);
+    /*
+     * Octet 2, pcomp
+     */
+    sndcp_is_nsapi_header_compressed(pdu_ref.ref_nsapi, &compressed);
+    if (compressed) {
+      if (packet_type == TYPE_UNCOMPRESSED_TCP) {
+        /*
+         * Uncompressed TCP.
+         */
+        ll_data_req->sdu.buf[offset] =
+          sndcp_data->sua->cur_xid_block.vj.pcomp1;
+      } else if (packet_type == TYPE_IP) {
+        /*
+         * IP.
+         */
+        ll_data_req->sdu.buf[offset] = 0;
+      } else {
+        /*
+         * Compressed TCP.
+         */
+        ll_data_req->sdu.buf[offset] =
+          sndcp_data->sua->cur_xid_block.vj.pcomp2;
+      }
+    }
+
+    offset ++;
+  }
+
+  /*
+   * Octet 3, N-PDU number, if F bit set to 1.
+   */
+  if ((seg_pos & SEG_POS_FIRST) > 0) {
+    ll_data_req->sdu.buf[offset] = (UBYTE)pdu_ref.ref_npdu_num;
+  }
+
+
+} /* sua_add_sn_header() */
+#endif /* _SNDCP_DTI_2_ */
+
+/*==== PUBLIC FUNCTIONS =====================================================*/
+#ifdef _SNDCP_DTI_2_
+/*
++------------------------------------------------------------------------------
+| Function    : sig_cia_sua_cia_comp_ind
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_CIA_SUA_CIA_COMP_IND
+|
+| Parameters  : cia_comp_ind*
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_cia_sua_cia_comp_ind (T_CIA_COMP_IND* cia_comp_ind)
+{
+  U8 sapi_index = 0;
+
+  TRACE_ISIG( "sig_cia_cia_sua_comp_ind" );
+
+  /*
+   * Set service instance according to sapi in signal.
+   */
+  sndcp_get_sapi_index(cia_comp_ind->sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+  /*
+   * Mark segment as transmitted for later acknowledgement.
+   */
+  sua_mark_segment((U8)cia_comp_ind->pdu_ref.ref_npdu_num,
+                   cia_comp_ind->pdu_ref.ref_nsapi);
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+    case SUA_LLC_NOT_RECEPTIVE:
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+      {
+
+        /*
+         * Save seg_pos and pdu_ref from cia_comp_ind.
+         */
+        U8 seg_pos = cia_comp_ind->seg_pos;
+        T_pdu_ref pdu_ref = cia_comp_ind->pdu_ref;
+
+        PALLOC(ll_desc_req, LL_DESC_REQ);
+        ll_desc_req->sapi = cia_comp_ind->sapi;
+        ll_desc_req->tlli = cia_comp_ind->tlli;
+        /* Single parameter copy qos needed due to different SAPs */
+        ll_desc_req->ll_qos.delay      = cia_comp_ind->cia_qos.delay;
+        ll_desc_req->ll_qos.relclass   = cia_comp_ind->cia_qos.relclass;
+        ll_desc_req->ll_qos.peak       = cia_comp_ind->cia_qos.peak;
+        ll_desc_req->ll_qos.preced     = cia_comp_ind->cia_qos.preced;
+        ll_desc_req->ll_qos.mean       = cia_comp_ind->cia_qos.mean;
+        /* radio_prio not defined, handled in separate function later */
+        ll_desc_req->reserved_data_req1 = cia_comp_ind->comp_inst;
+        ll_desc_req->reference1.ref_nsapi    = cia_comp_ind->pdu_ref.ref_nsapi;
+        ll_desc_req->reference1.ref_npdu_num = cia_comp_ind->pdu_ref.ref_npdu_num;
+        ll_desc_req->reference1.ref_seg_num  = cia_comp_ind->pdu_ref.ref_seg_num;
+        ll_desc_req->seg_pos = cia_comp_ind->seg_pos;
+        /* attached_counter not copied */
+        /* cipher not copied */
+        ll_desc_req->desc_list3.list_len = cia_comp_ind->desc_list3.list_len;
+        ll_desc_req->desc_list3.first    = cia_comp_ind->desc_list3.first;
+
+        sua_add_ll_desc_req_params(cia_comp_ind->pdu_ref,
+                                   ll_desc_req);
+        sua_add_sn_header(seg_pos, pdu_ref, ll_desc_req, cia_comp_ind->packet_type);
+
+        /* All information has been transferred remove the compression primitive */
+        MFREE(cia_comp_ind);
+
+        /*
+         * Write the ll_desc_req prim to ll_desc_q,
+         * increment write pointer.
+         */
+        sndcp_data->sua->ll_desc_q[sndcp_data->sua->ll_desc_q_write] =
+          ll_desc_req;
+        sndcp_data->sua->ll_desc_q_write =
+          (sndcp_data->sua->ll_desc_q_write + 1) % SNDCP_SEGMENT_NUMBERS_ACK;
+      }
+      break;
+    case SUA_LLC_RECEPTIVE:
+      {
+        /*
+         * Save seg_pos and pdu_ref from cia_comp_ind.
+         */
+        U8 ll_desc_seg_pos;
+        U8 ll_desc_nsapi;
+        U8 ll_desc_sapi;
+
+        U8 seg_pos = cia_comp_ind->seg_pos;
+        T_pdu_ref pdu_ref = cia_comp_ind->pdu_ref;
+
+        PALLOC(ll_desc_req, LL_DESC_REQ);
+        ll_desc_req->sapi = cia_comp_ind->sapi;
+        ll_desc_req->tlli = cia_comp_ind->tlli;
+        ll_desc_req->ll_qos.delay      = cia_comp_ind->cia_qos.delay;
+        ll_desc_req->ll_qos.relclass   = cia_comp_ind->cia_qos.relclass;
+        ll_desc_req->ll_qos.peak       = cia_comp_ind->cia_qos.peak;
+        ll_desc_req->ll_qos.preced     = cia_comp_ind->cia_qos.preced;
+        ll_desc_req->ll_qos.mean       = cia_comp_ind->cia_qos.mean;
+        /* radio_prio not defined, handled in separate function later */
+        ll_desc_req->reserved_data_req1 = cia_comp_ind->comp_inst;
+        ll_desc_req->reference1.ref_nsapi    = cia_comp_ind->pdu_ref.ref_nsapi;
+        ll_desc_req->reference1.ref_npdu_num = cia_comp_ind->pdu_ref.ref_npdu_num;
+        ll_desc_req->reference1.ref_seg_num  = cia_comp_ind->pdu_ref.ref_seg_num;
+        ll_desc_req->seg_pos = cia_comp_ind->seg_pos;
+        /* attached_counter not copied */
+        /* cipher not copied */
+        ll_desc_req->desc_list3.list_len = cia_comp_ind->desc_list3.list_len;
+        ll_desc_req->desc_list3.first    = cia_comp_ind->desc_list3.first;
+
+        sua_add_ll_desc_req_params(cia_comp_ind->pdu_ref,
+                                   ll_desc_req);
+        sua_add_sn_header(seg_pos, pdu_ref, ll_desc_req, cia_comp_ind->packet_type);
+
+        /* All information has been transferred remove the compression primitive */
+        MFREE(cia_comp_ind);
+
+        ll_desc_seg_pos = ll_desc_req->seg_pos;
+        ll_desc_sapi    = ll_desc_req->sapi;
+        ll_desc_nsapi   = sua_get_nsapi(ll_desc_req);
+
+#ifdef _SIMULATION_
+
+#ifndef MULTI_LAYER
+        su_send_ll_data_req_test(ll_desc_req);
+#else
+        PSEND(hCommLLC, ll_desc_req);
+#endif /* MULTI_LAYER */
+#else /* _SIMULATION_ */
+        PSEND(hCommLLC, ll_desc_req);
+#endif /* _SIMULATION_ */
+
+        SET_STATE(SUA, SUA_LLC_NOT_RECEPTIVE);
+
+        if ((ll_desc_seg_pos & SEG_POS_LAST) > 0) {
+          sig_sua_nu_ready_ind( ll_desc_nsapi );
+          sua_next_sn_data_req( ll_desc_sapi );
+          sndcp_data->sua->cia_state = CIA_IDLE;
+        }
+      }
+      break;
+    default:
+      TRACE_ERROR( "SIG_CIA_SUA_CIA_COMP_IND unexpected" );
+      sndcp_cl_desc3_free((T_desc3 *)cia_comp_ind->desc_list3.first);
+      MFREE(cia_comp_ind);
+      break;
+  }
+} /* sig_cia_sua_cia_comp_ind() */
+#else /* _SNDCP_DTI_2_ */
+/*
++------------------------------------------------------------------------------
+| Function    : sig_cia_sua_cia_comp_ind
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_CIA_SUA_CIA_COMP_IND
+|
+| Parameters  : cia_comp_ind*
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_cia_sua_cia_comp_ind (T_CIA_COMP_IND* cia_comp_ind)
+{
+  UBYTE sapi_index = 0;
+
+  TRACE_ISIG( "sig_cia_cia_sua_comp_ind" );
+
+  /*
+   * Set service instance according to sapi in signal.
+   */
+  sndcp_get_sapi_index(cia_comp_ind->sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+  /*
+   * Mark segment as transmitted for later acknowledgement.
+   */
+  sua_mark_segment((UBYTE)cia_comp_ind->pdu_ref.ref_npdu_num,
+                   cia_comp_ind->pdu_ref.ref_nsapi);
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+    case SUA_LLC_NOT_RECEPTIVE:
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+      {
+
+        /*
+         * Save seg_pos and pdu_ref from cia_comp_ind.
+         */
+        UBYTE seg_pos = cia_comp_ind->seg_pos;
+        T_pdu_ref pdu_ref = cia_comp_ind->pdu_ref;
+
+        PPASS(cia_comp_ind, ll_data_req, LL_DATA_REQ);
+
+        sua_add_ll_data_req_params(cia_comp_ind->pdu_ref,
+                                   ll_data_req);
+        sua_add_sn_header(seg_pos, pdu_ref, ll_data_req, cia_comp_ind->packet_type);
+        /*
+         * Write the ll_data_req prim to ll_data_q,
+         * increment write pointer.
+         */
+        sndcp_data->sua->ll_data_q[sndcp_data->sua->ll_data_q_write] =
+          ll_data_req;
+        sndcp_data->sua->ll_data_q_write =
+          (sndcp_data->sua->ll_data_q_write + 1) % SNDCP_SEGMENT_NUMBERS_ACK;
+      }
+      break;
+    case SUA_LLC_RECEPTIVE:
+      {
+        /*
+         * Save seg_pos and pdu_ref from cia_comp_ind.
+         */
+        UBYTE ll_data_seg_pos;
+        UBYTE ll_data_nsapi;
+        UBYTE ll_data_sapi;
+
+        UBYTE seg_pos = cia_comp_ind->seg_pos;
+        T_pdu_ref pdu_ref = cia_comp_ind->pdu_ref;
+
+        PPASS(cia_comp_ind, ll_data_req, LL_DATA_REQ);
+
+        sua_add_ll_data_req_params(cia_comp_ind->pdu_ref,
+                                      ll_data_req);
+        sua_add_sn_header(seg_pos, pdu_ref, ll_data_req, cia_comp_ind->packet_type);
+
+        ll_data_seg_pos = ll_data_req->seg_pos;
+        ll_data_sapi    = ll_data_req->sapi;
+        ll_data_nsapi   = sua_get_nsapi(ll_data_req);
+
+        PSEND(hCommLLC, ll_data_req);
+
+        SET_STATE(SUA, SUA_LLC_NOT_RECEPTIVE);
+
+        if ((ll_data_seg_pos & SEG_POS_LAST) > 0) {
+          sig_sua_nu_ready_ind( ll_data_nsapi );
+          sua_next_sn_data_req( ll_data_sapi );
+          sndcp_data->sua->cia_state = CIA_IDLE;
+        }
+      }
+      break;
+    default:
+      TRACE_ERROR( "SIG_CIA_SUA_CIA_COMP_IND unexpected" );
+      break;
+  }
+} /* sig_cia_sua_cia_comp_ind() */
+#endif /* _SNDCP_DTI_2_ */
+/*
++------------------------------------------------------------------------------
+| Function    : sig_mg_sua_delete_pdus
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_MG_SUA_DELETE_PDUS
+|               The same as the one in service su, but everything is in the
+|               acknowledged version here.
+|               cia_state is set to CIA_IDLE.
+|
+| Parameters  : UBYTE nsapi the affected nsapi, UBYTE sapi the affected sapi,
+|               BOOL destroy defines if data pay load must be freed.
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_mg_sua_delete_pdus (U8 nsapi, U8 sapi, BOOL destroy)
+{
+  U8 sapi_index;
+  BOOL ll_q_affected = FALSE;
+
+  TRACE_ISIG( "sig_mg_sua_delete_pdus" );
+
+  /*
+   * Set service instance according to sapi in signal.
+   */
+  sndcp_get_sapi_index(sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+
+  sndcp_data->sua->cia_state = CIA_IDLE;
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+    case SUA_LLC_NOT_RECEPTIVE:
+    case SUA_LLC_RECEPTIVE:
+      {
+        /*
+         * Delete affected N-PDUS from sn_data_q.
+         */
+        BOOL still = TRUE;
+        U8 index = sndcp_data->sua->sn_data_q_read;
+
+        while (still) {
+          if (index == sndcp_data->sua->sn_data_q_write) {
+            break;
+          }
+          if (sndcp_data->sua->sn_data_q[index]->nsapi == nsapi) {
+            /*
+             * The index for the prims to be shifted when 1 entry is deleted.
+             */
+            U8 i = 0;
+            if (destroy) {
+#ifdef _SNDCP_DTI_2_
+              MFREE_PRIM(sndcp_data->sua->sn_data_q[index]);
+#else /*_SNDCP_DTI_2_*/ 
+              PFREE_DESC(sndcp_data->sua->sn_data_q[index]);
+#endif /*_SNDCP_DTI_2_*/
+            }
+            sndcp_data->sua->sn_data_q[index] = NULL;
+
+            for (i = index;
+                 i != sndcp_data->sua->sn_data_q_write;
+                 i = (i + 1) % SN_DATA_Q_LEN) {
+
+
+              sndcp_data->sua->sn_data_q[i] =
+                sndcp_data->sua->sn_data_q[(i + 1) % SN_DATA_Q_LEN];
+              sndcp_data->sua->sn_data_q[(i + 1) % SN_DATA_Q_LEN] = NULL;
+
+            }
+            sndcp_data->sua->sn_data_q_write =
+              (sndcp_data->sua->sn_data_q_write - 1
+                + SN_DATA_Q_LEN) % SN_DATA_Q_LEN;
+            if (index == sndcp_data->sua->sn_data_q_write) {
+              break;
+            }
+          } else {
+            index = (index + 1) % SN_DATA_Q_LEN;
+          } /* if (sndcp_data->su->sn_unitdata_q[index]->nsapi == nsapi)  */
+
+        }
+#ifdef _SNDCP_DTI_2_
+        /*
+         * Delete affected SN-PDUS from ll_desc_q.
+         */
+        still = TRUE;
+        index = sndcp_data->sua->ll_desc_q_read;
+        while (still) {
+          if (index == sndcp_data->sua->ll_desc_q_write) {
+            break;
+          }
+          if (sua_get_nsapi(sndcp_data->sua->ll_desc_q[index]) == nsapi) {
+            /*
+             * The index for the prims to be shifted when 1 entry is deleted.
+             */
+            U8 i = 0;
+
+            ll_q_affected = TRUE;
+            /*
+             * Free the deleted primitive.
+             */
+            if (sndcp_data->sua->ll_desc_q[index] != NULL) {
+              T_desc3 *free_help, *help =
+             (T_desc3 *)sndcp_data->sua->ll_desc_q[index]->desc_list3.first;
+              while(help != NULL)
+              {
+                if (destroy) {
+                  sndcp_cl_desc3_free(help);/* free help->buffer */
+                }
+                free_help = help;
+                help = (T_desc3 *)free_help->next;
+                MFREE(free_help);
+              }
+
+              PFREE(sndcp_data->sua->ll_desc_q[index]);
+              sndcp_data->sua->ll_desc_q[index] = NULL;
+            }
+
+            for (i = index;
+                 i != sndcp_data->sua->ll_desc_q_write;
+                 i = (i + 1) % SNDCP_SEGMENT_NUMBERS_ACK) {
+
+              sndcp_data->sua->ll_desc_q[i] =
+                sndcp_data->sua->ll_desc_q
+                  [(i + 1) % SNDCP_SEGMENT_NUMBERS_ACK];
+              sndcp_data->sua->ll_desc_q
+                [(i + 1) % SNDCP_SEGMENT_NUMBERS_ACK] = NULL;
+
+            }
+            sndcp_data->sua->ll_desc_q_write =
+              (sndcp_data->sua->ll_desc_q_write - 1
+               + SNDCP_SEGMENT_NUMBERS_ACK) % SNDCP_SEGMENT_NUMBERS_ACK;
+            if (index == sndcp_data->sua->ll_desc_q_write) {
+              break;
+            }
+          } else {
+            index = (index + 1) % SNDCP_SEGMENT_NUMBERS_ACK;
+          } /* if (sndcp_data->sua->sn_data_q[index]->nsapi == nsapi) { */
+
+        }
+#else /* _SNDCP_DTI_2_ */
+        /*
+         * Delete affected SN-PDUS from ll_data_q.
+         */
+        still = TRUE;
+        index = sndcp_data->sua->ll_data_q_read;
+        while (still)
+        {
+          if (index == sndcp_data->sua->ll_data_q_write) {
+            break;
+          }
+          if (sua_get_nsapi(sndcp_data->sua->ll_data_q[index]) == nsapi) {
+            /*
+             * The index for the prims to be shifted when 1 entry is deleted.
+             */
+            UBYTE i = 0;
+
+            ll_q_affected = TRUE;
+            /*
+             * Free the deleted primitive.
+             */
+            if (sndcp_data->sua->ll_data_q[index] != NULL) {
+              PFREE(sndcp_data->sua->ll_data_q[index]);
+              sndcp_data->sua->ll_data_q[index] = NULL;
+            }
+
+            for (i = index;
+                 i != sndcp_data->sua->ll_data_q_write;
+                 i = (i + 1) % SNDCP_SEGMENT_NUMBERS_ACK) {
+
+              sndcp_data->sua->ll_data_q[i] =
+                sndcp_data->sua->ll_data_q
+                  [(i + 1) % SNDCP_SEGMENT_NUMBERS_ACK];
+              sndcp_data->sua->ll_data_q
+                [(i + 1) % SNDCP_SEGMENT_NUMBERS_ACK] = NULL;
+
+            }
+            sndcp_data->sua->ll_data_q_write =
+              (sndcp_data->sua->ll_data_q_write - 1
+               + SNDCP_SEGMENT_NUMBERS_ACK) % SNDCP_SEGMENT_NUMBERS_ACK;
+            if (index == sndcp_data->sua->ll_data_q_write) {
+              break;
+            }
+          } else {
+            index = (index + 1) % SNDCP_SEGMENT_NUMBERS_ACK;
+          } /* if (sndcp_data->sua->sn_data_q[index]->nsapi == nsapi) { */
+
+        }
+#endif /* _SNDCP_DTI_2_ */
+      }
+      /*
+       * if the segments in LL queue were from the affected nsapi then the
+       * next N-PDU is directed to cia.
+       */
+      if (ll_q_affected) {
+        sua_next_sn_data_req (sapi);
+      }
+
+      /*
+       * Delete the segment informations.
+       */
+      {
+        T_SEG_INFO* help = sndcp_data->sua->first_seg_info;
+        while (help != NULL) {
+          T_SEG_INFO* help_next = help->next;
+          if (help->nsapi == nsapi) {
+            if(sndcp_data->sua->first_seg_info == help)
+              sndcp_data->sua->first_seg_info = help_next;
+            MFREE(help);
+          }
+          help = help_next;
+        }
+      }
+
+      break;
+    default:
+      TRACE_ERROR( "SIG_MG_SUA_DELETE_PDUS unexpected" );
+      break;
+  }
+} /* sig_mg_sua_delete_pdus() */
+
+/*
++------------------------------------------------------------------------------
+| Function    : sig_mg_sua_n201
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_MG_SUA_N201
+|
+| Parameters  : UBYTE sapi the affected sapi, USHORT n201
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_mg_sua_n201 (UBYTE sapi,
+                             USHORT n201)
+{
+  UBYTE sapi_index = 0;
+
+  TRACE_ISIG( "sig_mg_sua_n201" );
+
+  /*
+   * Set service instance according to sapi in signal.
+   */
+  sndcp_get_sapi_index(sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+    case SUA_LLC_NOT_RECEPTIVE:
+    case SUA_LLC_RECEPTIVE:
+      sndcp_data->sua->n201_i = n201;
+      break;
+    default:
+      TRACE_ERROR( "SIG_MG_SUA_N201 unexpected" );
+      break;
+  }
+} /* sig_mg_sua_n201() */
+
+/*
++------------------------------------------------------------------------------
+| Function    : sig_mg_sua_reset_ind
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_MG_SUA_RESET_IND
+|
+| Parameters  : UBYTE sapi the affected sapi
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_mg_sua_reset_ind (UBYTE sapi)
+{
+  UBYTE sapi_index = 0;
+
+  TRACE_ISIG( "sig_mg_sua_reset_ind" );
+
+  /*
+   * Set service instance according to sapi in signal.
+   */
+  sndcp_get_sapi_index(sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+    case SUA_LLC_NOT_RECEPTIVE:
+    case SUA_LLC_RECEPTIVE:
+      /*
+       * This is only here:
+       */
+      SET_STATE(SUA, SUA_LLC_NOT_RECEPTIVE);
+
+      break;
+    default:
+      TRACE_ERROR( "SIG_MG_SUA_RESET_IND unexpected" );
+      break;
+  }
+} /* sig_mg_sua_reset_ind() */
+
+#ifdef _SNDCP_DTI_2_
+/*
++------------------------------------------------------------------------------
+| Function    : sig_mg_sua_resume
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_MG_SU_RESUME
+|
+| Parameters  : UBYTE sapi the affected sapi
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_mg_sua_resume (U8 sapi)
+{
+  U8 sapi_index = 0;
+
+  TRACE_ISIG( "sig_mg_sua_resume" );
+
+  /*
+   * Set service instance according to sapi in signal.
+   */
+  sndcp_get_sapi_index(sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+      SET_STATE (SUA, SUA_LLC_NOT_RECEPTIVE);
+      break;
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+      /*
+       * Is queue with LL_DESC_REQ empty?
+       */
+      if (sndcp_data->sua->ll_desc_q_write ==
+          sndcp_data->sua->ll_desc_q_read) {
+        SET_STATE(SUA, SUA_LLC_RECEPTIVE);
+      } else {
+        /*
+         * Get next segment from queue and send it.
+         */
+        T_LL_DESC_REQ* ll_desc_req =
+          sndcp_data->sua->ll_desc_q[sndcp_data->sua->ll_desc_q_read];
+
+        U8 ll_desc_seg_pos = ll_desc_req->seg_pos;
+        U8 ll_desc_nsapi   = sua_get_nsapi(ll_desc_req);
+        U8 ll_desc_sapi    = ll_desc_req->sapi;
+
+        sndcp_data->sua->ll_desc_q[sndcp_data->sua->ll_desc_q_read] = NULL;
+
+        sndcp_data->sua->ll_desc_q_read =
+            (sndcp_data->sua->ll_desc_q_read + 1) % SNDCP_SEGMENT_NUMBERS_ACK;
+
+#ifdef _SIMULATION_
+        su_send_ll_data_req_test(ll_desc_req);
+#else /* _SIMULATION_ */
+        PSEND(hCommLLC, ll_desc_req);
+#endif /* _SIMULATION_ */
+
+        SET_STATE(SUA, SUA_LLC_NOT_RECEPTIVE);
+        if ((ll_desc_seg_pos & SEG_POS_LAST) > 0) {
+          sig_sua_nu_ready_ind( ll_desc_nsapi );
+          sua_next_sn_data_req( ll_desc_sapi );
+          sndcp_data->sua->cia_state = CIA_IDLE;
+        }
+      }
+      break;
+    case SUA_LLC_NOT_RECEPTIVE:
+      break;
+    case SUA_LLC_RECEPTIVE:
+      break;
+    default:
+      TRACE_ERROR( "SIG_MG_SUA_RESUME unexpected" );
+      break;
+  }
+} /* sig_mg_sua_resume() */
+#else /* _SNDCP_DTI_2_ */
+/*
++------------------------------------------------------------------------------
+| Function    : sig_mg_sua_resume
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_MG_SU_RESUME
+|
+| Parameters  : UBYTE sapi the affected sapi
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_mg_sua_resume (UBYTE sapi)
+{
+  UBYTE sapi_index = 0;
+
+  TRACE_ISIG( "sig_mg_sua_resume" );
+
+  /*
+   * Set service instance according to sapi in signal.
+   */
+  sndcp_get_sapi_index(sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+      SET_STATE (SUA, SUA_LLC_NOT_RECEPTIVE);
+      break;
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+      /*
+       * Is queue with LL_DATA_REQ empty?
+       */
+      if (sndcp_data->sua->ll_data_q_write ==
+          sndcp_data->sua->ll_data_q_read) {
+        SET_STATE(SUA, SUA_LLC_RECEPTIVE);
+      } else {
+        /*
+         * Get next segment from queue and send it.
+         */
+        T_LL_DATA_REQ* ll_data_req =
+          sndcp_data->sua->ll_data_q[sndcp_data->sua->ll_data_q_read];
+
+        UBYTE ll_data_seg_pos = ll_data_req->seg_pos;
+        UBYTE ll_data_nsapi   = sua_get_nsapi(ll_data_req);
+        UBYTE ll_data_sapi    = ll_data_req->sapi;
+
+        sndcp_data->sua->ll_data_q[sndcp_data->sua->ll_data_q_read] = NULL;
+
+        sndcp_data->sua->ll_data_q_read =
+            (sndcp_data->sua->ll_data_q_read + 1) % SNDCP_SEGMENT_NUMBERS_ACK;
+
+        PSEND(hCommLLC, ll_data_req);
+
+        SET_STATE(SUA, SUA_LLC_NOT_RECEPTIVE);
+        if ((ll_data_seg_pos & SEG_POS_LAST) > 0) {
+          sig_sua_nu_ready_ind( ll_data_nsapi );
+          sua_next_sn_data_req( ll_data_sapi );
+          sndcp_data->sua->cia_state = CIA_IDLE;
+        }
+      }
+      break;
+    case SUA_LLC_NOT_RECEPTIVE:
+      break;
+    case SUA_LLC_RECEPTIVE:
+      break;
+    default:
+      TRACE_ERROR( "SIG_MG_SUA_RESUME unexpected" );
+      break;
+  }
+} /* sig_mg_sua_resume() */
+#endif /* _SNDCP_DTI_2_ */
+
+
+/*
++------------------------------------------------------------------------------
+| Function    : sig_mg_sua_suspend
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_NU_SUA_SUSPEND
+|
+| Parameters  : SAPI
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_mg_sua_suspend (UBYTE sapi)
+{
+  UBYTE sapi_index = 0;
+
+  TRACE_ISIG( "sig_mg_sua_suspend" );
+
+  /*
+   * Set service instance according to sapi in signal.
+   */
+  sndcp_get_sapi_index(sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+      break;
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+      break;
+    case SUA_LLC_NOT_RECEPTIVE:
+      SET_STATE (SUA, SUA_LLC_NOT_RECEPTIVE_SUSPEND);
+      break;
+    case SUA_LLC_RECEPTIVE:
+      SET_STATE (SUA, SUA_LLC_RECEPTIVE_SUSPEND);
+      break;
+    default:
+      TRACE_ERROR( "SIG_MG_SUA_SUSPEND unexpected" );
+      break;
+  }
+} /* sig_mg_sua_suspend() */
+
+
+/*
++------------------------------------------------------------------------------
+| Function    : sig_nu_sua_data_req
++------------------------------------------------------------------------------
+| Description : Handles the internal signal SIG_NU_SUA_DATA_REQ
+|
+| Parameters  : SN_DATA_REQ primitive, N-PDU number, NSAPI, SAPI
+|
++------------------------------------------------------------------------------
+*/
+GLOBAL void sig_nu_sua_data_req (T_SN_DATA_REQ* sn_data_req,
+                                 UBYTE npdu_number,
+                                 UBYTE nsapi,
+                                 UBYTE sapi
+                                )
+{
+  UBYTE sapi_index = 0;
+
+  TRACE_ISIG( "sig_nu_sua_data_req" );
+
+#ifdef _SNDCP_MEAN_TRACE_
+#ifdef _SNDCP_DTI_2_
+  sndcp_mean_trace(nsapi,
+                   SNDCP_MEAN_UP,
+                   SNDCP_MEAN_ACK,
+                   sn_data_req->desc_list2.list_len);
+#else /*_SNDCP_DTI_2_*/
+  sndcp_mean_trace(nsapi,
+                   SNDCP_MEAN_UP,
+                   SNDCP_MEAN_ACK,
+                   sn_data_req->desc_list.list_len);
+#endif /*_SNDCP_DTI_2_*/
+#endif /* _SNDCP_MEAN_TRACE_ */
+
+  /*
+   * set service instance according to sapi in signal
+   */
+  sndcp_get_sapi_index(sapi, &sapi_index);
+  sndcp_data->sua = & sndcp_data->sua_base[sapi_index];
+
+  switch( GET_STATE( SUA ) )
+  {
+    case SUA_LLC_RECEPTIVE_SUSPEND:
+    case SUA_LLC_NOT_RECEPTIVE_SUSPEND:
+    case SUA_LLC_NOT_RECEPTIVE:
+    case SUA_LLC_RECEPTIVE:
+      /*
+       * If queue with NPDUs is empty, and cia is not busy,
+       * send the NPDU to cia, else
+       * add it to the queue.
+       */
+      if ((sndcp_data->sua->sn_data_q_read ==
+           sndcp_data->sua->sn_data_q_write) &&
+          (sndcp_data->sua->ll_desc_q_read ==
+           sndcp_data->sua->ll_desc_q_write) &&
+          sndcp_data->sua->cia_state == CIA_IDLE) {
+        /*
+         * Send the NPDU to cia.
+         */
+        sndcp_data->sua->cia_state = CIA_BUSY;
+        sig_sua_cia_cia_comp_req(sn_data_req,
+                            npdu_number,
+                            nsapi,
+                            sapi);
+      } else { /* Queue with NPDUs is not empty or cia is busy. */
+        /*
+         * Write the sn_data_req prim to sn_data_q,
+         * increment write pointer.
+         */
+        sndcp_data->sua->sn_data_q[sndcp_data->sua->sn_data_q_write] =
+          sn_data_req;
+        sndcp_data->sua->npdu_number_q[sndcp_data->sua->sn_data_q_write] =
+          npdu_number;
+        sndcp_data->sua->sn_data_q_write =
+          (sndcp_data->sua->sn_data_q_write + 1) % SN_DATA_Q_LEN;
+      } /* Queue with NPDUs is not empty or cia is busy. */
+      break;
+    default:
+      TRACE_ERROR( "SIG_NU_SUA_DATA_REQ unexpected" );
+#ifdef _SNDCP_DTI_2_
+      MFREE_PRIM(sn_data_req);
+#else /*_SNDCP_DTI_2_*/
+      PFREE_DESC(sn_data_req);
+#endif /*_SNDCP_DTI_2_*/
+      break;
+  }
+} /* sig_nu_sua_data_req() */
+
+#ifdef _SIMULATION_
+#ifdef _SNDCP_DTI_2_
+/*
++------------------------------------------------------------------------------
+| Function    : su_send_ll_data_req_test
++------------------------------------------------------------------------------
+| Description : Only for test purposes.
+|               The given LL_DESC_REQ is copied to an
+|               LL_DATA_REQ and sent for the simulated test environment.
+|
+| Parameters  : T_LL_DESC_REQ* pointer descriptor data.
+|
++------------------------------------------------------------------------------
+*/
+void su_send_ll_data_req_test(T_LL_DESC_REQ* ll_desc_req)
+{
+  T_desc3* descriptor = NULL;
+  U8* p_data = NULL;
+  U16 offset = ENCODE_OFFSET_BYTE;
+
+  PALLOC_SDU(ll_data_req, LL_DATA_REQ, (U16)( ll_desc_req->desc_list3.list_len* 8));
+
+  /*
+   * Set parameters in ll_data_req primitive
+   */
+  ll_data_req->sapi = ll_desc_req->sapi;
+  ll_data_req->tlli = ll_desc_req->tlli;
+  ll_data_req->ll_qos = ll_desc_req->ll_qos;
+  ll_data_req->radio_prio = ll_desc_req->radio_prio;
+  ll_data_req->reserved_data_req1 = ll_desc_req->reserved_data_req1;
+  ll_data_req->reference1 = ll_desc_req->reference1;
+  ll_data_req->seg_pos = ll_desc_req->seg_pos;
+  ll_data_req->attached_counter = ll_desc_req->attached_counter;
+  ll_data_req->reserved_data_req4 = ll_desc_req->reserved_data_req4;
+#ifdef REL99
+  ll_data_req->pkt_flow_id = ll_desc_req->pkt_flow_id;
+#endif /*REL99*/
+  /*
+   * Set the ENCODE_OFFSET in the uplink sdu to 0, set sdu.l_buf
+   */
+  ll_data_req->sdu.o_buf = ENCODE_OFFSET;
+  ll_data_req->sdu.l_buf = ll_desc_req->desc_list3.list_len* 8;
+  /*
+   * Copy the data.
+   */
+  descriptor = (T_desc3*)ll_desc_req->desc_list3.first;
+  while (descriptor != NULL)
+  {
+    T_desc3* help = descriptor;
+    p_data = (U8*)descriptor->buffer;
+    if (descriptor->len>0)
+    {
+      memcpy(&ll_data_req->sdu.buf[offset],
+             &p_data[descriptor->offset],
+             descriptor->len);
+    }
+    offset += descriptor->len;
+    descriptor = (T_desc3*)descriptor->next;
+    sndcp_cl_desc3_free(help);
+    MFREE(help);
+    help = NULL;
+  }
+
+  PSEND(hCommLLC, ll_data_req);
+
+  PFREE(ll_desc_req); // MAYBE REMEMBER is this the correct free?
+
+}
+#endif /* _SNDCP_DTI_2_ */
+#endif /* _SIMULATION_ */
+
+
+