FreeCalypso > hg > fc-tourmaline

view src/g23m-gprs/sndcp/sndcp_sus.c @ 265:e57bfdadf49a

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mmiIcons.c: fix bogus icnType in incoming_call_animate[] The incoming call animation icons are actually drawn in 256-color format, but they were incorrectly declared as BMP_FORMAT_32BIT_COLOUR in the incoming_call_animate[] array. Why were they still getting displayed correctly despite this bogosity? Answer: because the mmi_dialogs_animation_new_CB() function overrides the icon bitmap type to 0x02, which means 256-color format. Needless to say, the icon format should be made correct at the source of the data, and at some later point we may need to remove the override from the animation display function.
author Mychaela Falconia <falcon@freecalypso.org>
date Mon, 17 May 2021 07:18:36 +0000
parents fa8dc04885d8
children
line wrap: on
line source

/*
+-----------------------------------------------------------------------------
|  Project :  GPRS (8441)
|  Modul   :  sndcp_sus.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 (SU-statemachine)
+-----------------------------------------------------------------------------
*/

/*---- HISTORY --------------------------------------------------------------*/
#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_suf.h"     /* to get internal functions of service su */
#include "sndcp_cias.h"     /* to get signal functions to service cia */
#include "sndcp_nus.h"     /* to get signal functions to service nu */
#include "sndcp_sus.h"



/*==== CONST ================================================================*/

/*==== LOCAL VARS ===========================================================*/

/*==== PRIVATE FUNCTIONS ====================================================*/
#ifdef _SNDCP_DTI_2_
/*
+------------------------------------------------------------------------------
| Function    : su_add_ll_unitdesc_req_params
+------------------------------------------------------------------------------
| Description : sets the parameters of the given ll_unitdata_req
|
| Parameters  : nsapi, ll_unitdata_req*
|
+------------------------------------------------------------------------------
*/
LOCAL void su_add_ll_unitdesc_req_params (UBYTE nsapi,
                                           T_LL_UNITDESC_REQ* ll_unitdesc_req)
{
  T_snsm_qos snsm_qos; /* Initialized with getter later */

  TRACE_FUNCTION( "su_add_ll_unitdesc_req_params" );

  /*
   * Set quality of service.
   */
  sndcp_get_nsapi_qos(nsapi, &snsm_qos);
  sndcp_snsm_qos_to_ll_qos(snsm_qos, &ll_unitdesc_req->ll_qos);
  /*
   * Set radio prio.
   */
  sndcp_get_nsapi_prio(nsapi,
                       &ll_unitdesc_req->radio_prio);
#ifdef REL99
  sndcp_get_nsapi_pktflowid(nsapi,
                            (U16*)&ll_unitdesc_req->pkt_flow_id);
#endif /*REL99*/


} /* su_add_ll_unitdesc_req_params() */
#else /* _SNDCP_DTI_2_ */
/*
+------------------------------------------------------------------------------
| Function    : su_add_ll_unitdata_req_params
+------------------------------------------------------------------------------
| Description : sets the parameters of the given ll_unitdata_req
|
| Parameters  : nsapi, ll_unitdata_req*
|
+------------------------------------------------------------------------------
*/
LOCAL void su_add_ll_unitdata_req_params (UBYTE nsapi,
                                           T_LL_UNITDATA_REQ* ll_unitdata_req)
{
  T_snsm_qos snsm_qos; /* Initialized with getter later */

  TRACE_FUNCTION( "su_add_ll_unitdata_req_params" );

  /*
   * Set quality of service.
   */
  sndcp_get_nsapi_qos(nsapi, &snsm_qos);
  sndcp_snsm_qos_to_ll_qos(snsm_qos, &ll_unitdata_req->ll_qos);
  /*
   * Set radio prio.
   */
  sndcp_get_nsapi_prio(nsapi,
                       &ll_unitdata_req->radio_prio);
#ifdef REL99	
  sndcp_get_nsapi_pktflowid(nsapi,
                            &ll_unitdata_req->pkt_flow_id);
#endif /*REL99*/

} /* su_add_ll_unitdata_req_params() */
#endif /* _SNDCP_DTI_2_ */
#ifdef _SNDCP_DTI_2_
/*
+------------------------------------------------------------------------------
| Function    : su_add_sn_header
+------------------------------------------------------------------------------
| Description : sets the segment header in the given ll_unitdesc_req
|
| Parameters  : first and/or last segment , ll_unitdesc_req*, packet type
|
+------------------------------------------------------------------------------
*/
LOCAL void su_add_sn_header (UBYTE seg_pos,
                              T_pdu_ref pdu_ref,
                              T_LL_UNITDESC_REQ* ll_unitdesc_req,
                              UBYTE packet_type)
{
  USHORT offset = ENCODE_OFFSET_BYTE;
  BOOL compressed = FALSE;
  UBYTE sapi_index = 0;
  T_desc3* desc3 = NULL;
  U8* sndcp_header = NULL;

  TRACE_FUNCTION( "su_add_sn_header" );

  sndcp_get_sapi_index(ll_unitdesc_req->sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  /* Get the descriptor describing the memory area with the sndcp header */
  desc3 = (T_desc3*)ll_unitdesc_req->desc_list3.first;
  sndcp_header = (U8*)desc3->buffer;
  sndcp_header[offset] = 0;
  /*
   * Octet 1, F bit.
   */
  if ((seg_pos & SEG_POS_FIRST) > 0)
  {
    sndcp_header[offset] += (1 << 6);
  }
  /*
   * Octet 1, 1 for SN_UNITDATA.
   */
  sndcp_header[offset] += (1 << 5);
  /*
   * 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 ++;
  sndcp_header[offset] = 0;

  if ((seg_pos & SEG_POS_FIRST) > 0) {
    /*
     * This is the first bit.
     * Find d/pcomp values and set them.
     */
    /*
     * Octet 2, dcomp
     */
    sndcp_header[offset] +=
      (UBYTE)(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 2 or 3, segment number
   */
  sndcp_header[offset] = 0;
  sndcp_header[offset] += (UBYTE)(pdu_ref.ref_seg_num << 4);
  /*
   * Octet 2 or 3, N-PDU number, MSB.
   */
  sndcp_header[offset] += ((pdu_ref.ref_npdu_num >> 8) & 0xf);

  offset ++;

  /*
   * Octet 3 or 4, N-PDU number, LSB.
   */
  sndcp_header[offset] = (pdu_ref.ref_npdu_num & 0xff);

} /* su_add_sn_header() */
#else /* _SNDCP_DTI_2_ */
/*
+------------------------------------------------------------------------------
| Function    : su_add_sn_header
+------------------------------------------------------------------------------
| Description : sets the segment header in the given ll_unitdata_req
|
| Parameters  : first and/or last segment , ll_unitdata_req*, packet type
|
+------------------------------------------------------------------------------
*/
LOCAL void su_add_sn_header (UBYTE seg_pos,
                              T_pdu_ref pdu_ref,
                              T_LL_UNITDATA_REQ* ll_unitdata_req,
                              UBYTE packet_type)
{
  USHORT offset = ll_unitdata_req->sdu.o_buf / 8;
  BOOL compressed = FALSE;
  UBYTE sapi_index = 0;

  TRACE_FUNCTION( "su_add_sn_header" );

  sndcp_get_sapi_index(ll_unitdata_req->sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  ll_unitdata_req->sdu.buf[offset] = 0;
  /*
   * Octet 1, F bit.
   */
  if ((seg_pos & SEG_POS_FIRST) > 0) {
    ll_unitdata_req->sdu.buf[offset] += (1 << 6);
  }
  /*
   * Octet 1, 1 for SN_UNITDATA.
   */
  ll_unitdata_req->sdu.buf[offset] += (1 << 5);
  /*
   * Octet 1, M bit.
   */
  if ((seg_pos & SEG_POS_LAST) == 0) {
    ll_unitdata_req->sdu.buf[offset] += (1 << 4);
  }
  /*
   * Octet 1, NSAPI number.
   */
  ll_unitdata_req->sdu.buf[offset] += pdu_ref.ref_nsapi;

  offset ++;
  ll_unitdata_req->sdu.buf[offset] = 0;

  if ((seg_pos & SEG_POS_FIRST) > 0) {
    /*
     * This is the first bit.
     * Find d/pcomp values and set them.
     */
    /*
     * Octet 2, dcomp
     */
    ll_unitdata_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_unitdata_req->sdu.buf[offset] =
          sndcp_data->su->cur_xid_block.vj.pcomp1;
      } else if (packet_type == TYPE_IP) {
        /*
         * IP.
         */
        ll_unitdata_req->sdu.buf[offset] = 0;
      } else {
        /*
         * Compressed TCP.
         */
        ll_unitdata_req->sdu.buf[offset] =
          sndcp_data->su->cur_xid_block.vj.pcomp2;
      }
    }

    offset ++;
  }
  /*
   * Octet 2 or 3, segment number
   */
  ll_unitdata_req->sdu.buf[offset] = 0;
  ll_unitdata_req->sdu.buf[offset] += (UBYTE)(pdu_ref.ref_seg_num << 4);
  /*
   * Octet 2 or 3, N-PDU number, MSB.
   */
  ll_unitdata_req->sdu.buf[offset] += ((pdu_ref.ref_npdu_num >> 8) & 0xf);

  offset ++;

  /*
   * Octet 3 or 4, N-PDU number, LSB.
   */
  ll_unitdata_req->sdu.buf[offset] = (pdu_ref.ref_npdu_num & 0xff);

} /* su_add_sn_header() */
#endif /* _SNDCP_DTI_2_ */


/*==== PUBLIC FUNCTIONS =====================================================*/
#ifdef _SNDCP_DTI_2_
/*
+------------------------------------------------------------------------------
| Function    : sig_cia_su_cia_comp_ind
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_CIA_su_CIA_COMP_IND
|
| Parameters  : cia_comp_ind*
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_cia_su_cia_comp_ind (T_CIA_COMP_IND* cia_comp_ind)
{
  UBYTE sapi_index = 0;


  TRACE_ISIG( "sig_cia_su_cia_comp_ind" );

  /*
   * Set service instance according to sapi in signal.
   */
  sndcp_get_sapi_index(cia_comp_ind->sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_RECEPTIVE_SUSPEND:
    case SU_LLC_NOT_RECEPTIVE:
    case SU_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;
        UBYTE nsapi = cia_comp_ind->pdu_ref.ref_nsapi;
        UBYTE packet_type = cia_comp_ind->packet_type;

        PALLOC(ll_unitdesc_req, LL_UNITDESC_REQ);
        ll_unitdesc_req->sapi = cia_comp_ind->sapi;
        ll_unitdesc_req->tlli = cia_comp_ind->tlli;
        ll_unitdesc_req->ll_qos.delay      = cia_comp_ind->cia_qos.delay;
        ll_unitdesc_req->ll_qos.relclass   = cia_comp_ind->cia_qos.relclass;
        ll_unitdesc_req->ll_qos.peak       = cia_comp_ind->cia_qos.peak;
        ll_unitdesc_req->ll_qos.preced     = cia_comp_ind->cia_qos.preced;
        ll_unitdesc_req->ll_qos.mean       = cia_comp_ind->cia_qos.mean;
        /* attached_counter not copied */
        /* cipher not copied */
        ll_unitdesc_req->reserved_unitdata_req1.ref_nsapi    = cia_comp_ind->pdu_ref.ref_nsapi;
        ll_unitdesc_req->reserved_unitdata_req1.ref_npdu_num = cia_comp_ind->pdu_ref.ref_npdu_num;
        ll_unitdesc_req->reserved_unitdata_req1.ref_seg_num  = cia_comp_ind->pdu_ref.ref_seg_num;
        ll_unitdesc_req->seg_pos = cia_comp_ind->seg_pos;
        ll_unitdesc_req->desc_list3.list_len = cia_comp_ind->desc_list3.list_len;
        ll_unitdesc_req->desc_list3.first    = cia_comp_ind->desc_list3.first;

        su_add_ll_unitdesc_req_params(nsapi,
                                      ll_unitdesc_req);
        su_add_sn_header(seg_pos, pdu_ref,
                         ll_unitdesc_req,
                         packet_type);

        /* All information has been transferred remove the compression primitive */
        MFREE(cia_comp_ind);

        /*
         * Write the ll_unitdesc_req prim to ll_unitdesc_q,
         * increment write pointer.
         */
        sndcp_data->su->ll_unitdesc_q[sndcp_data->su->ll_unitdesc_q_write] =
          ll_unitdesc_req;
        sndcp_data->su->ll_unitdesc_q_write =
          (sndcp_data->su->ll_unitdesc_q_write + 1) % SNDCP_SEGMENT_NUMBERS_UNACK;

      }
      break;
    case SU_LLC_RECEPTIVE:
      {
        /*
         * Save seg_pos and pdu_ref from cia_comp_ind.
         */
        UBYTE ll_unitdesc_sapi;
        UBYTE seg_pos = cia_comp_ind->seg_pos;
        T_pdu_ref pdu_ref = cia_comp_ind->pdu_ref;
        UBYTE nsapi = cia_comp_ind->pdu_ref.ref_nsapi;
        UBYTE packet_type = cia_comp_ind->packet_type;

        PALLOC(ll_unitdesc_req, LL_UNITDESC_REQ);
        ll_unitdesc_req->sapi = cia_comp_ind->sapi;
        ll_unitdesc_req->tlli = cia_comp_ind->tlli;
        ll_unitdesc_req->ll_qos.delay      = cia_comp_ind->cia_qos.delay;
        ll_unitdesc_req->ll_qos.relclass   = cia_comp_ind->cia_qos.relclass;
        ll_unitdesc_req->ll_qos.peak       = cia_comp_ind->cia_qos.peak;
        ll_unitdesc_req->ll_qos.preced     = cia_comp_ind->cia_qos.preced;
        ll_unitdesc_req->ll_qos.mean       = cia_comp_ind->cia_qos.mean;
        /* attached_counter not copied */
        /* cipher not copied */
        ll_unitdesc_req->reserved_unitdata_req1.ref_nsapi    = cia_comp_ind->pdu_ref.ref_nsapi;
        ll_unitdesc_req->reserved_unitdata_req1.ref_npdu_num = cia_comp_ind->pdu_ref.ref_npdu_num;
        ll_unitdesc_req->reserved_unitdata_req1.ref_seg_num  = cia_comp_ind->pdu_ref.ref_seg_num;
        ll_unitdesc_req->seg_pos = cia_comp_ind->seg_pos;
        ll_unitdesc_req->desc_list3.list_len = cia_comp_ind->desc_list3.list_len;
        ll_unitdesc_req->desc_list3.first    = cia_comp_ind->desc_list3.first;

        /* All information has been transferred remove the compression primitive */
        MFREE(cia_comp_ind);

        su_add_ll_unitdesc_req_params(nsapi,
                                      ll_unitdesc_req);
        su_add_sn_header(seg_pos, pdu_ref,
                         ll_unitdesc_req,
                         packet_type);


#ifdef SNDCP_TRACE_ALL
        TRACE_EVENT("uplink with sn header at LL SAP: ");
        TRACE_EVENT_P1("%d octets",
            ll_unitdesc_req->desc_list3.list_len);

        sndcp_trace_desc_list3_content(ll_unitdesc_req->desc_list3);
#endif

#ifdef FLOW_TRACE
        sndcp_trace_flow_control(FLOW_TRACE_SNDCP,
                                 FLOW_TRACE_UP,
                                 FLOW_TRACE_BOTTOM,
                                 FALSE);
#endif
        ll_unitdesc_sapi = ll_unitdesc_req->sapi;


#ifdef _SIMULATION_
#ifndef MULTI_LAYER
        su_send_ll_unitdata_req_test(ll_unitdesc_req);
#else
        PSEND(hCommLLC, ll_unitdesc_req);
#endif /* MULTI_LAYER */
#else /* _SIMULATION_ */
        PSEND(hCommLLC, ll_unitdesc_req);
#endif /* _SIMULATION_ */

        SET_STATE(SU, SU_LLC_NOT_RECEPTIVE);
        /*
         * If segment is the last of the N-PDU then send ready_ind to nsapi
         * and get next entry from sn q..
         */
        if ((seg_pos & SEG_POS_LAST) > 0) {
          sndcp_data->su->cia_state = CIA_IDLE;
          su_next_sn_unitdata_req( ll_unitdesc_sapi );
          sig_su_nu_ready_ind(nsapi);
        }

      }
      break;
    default:
      TRACE_ERROR( "SIG_CIA_SU_CIA_COMP_IND unexpected" );
      sndcp_cl_desc3_free((T_desc3*)cia_comp_ind->desc_list3.first);
      MFREE(cia_comp_ind);
      break;
  }
} /* sig_cia_su_cia_comp_ind() */
#else /* _SNDCP_DTI_2_ */
/*
+------------------------------------------------------------------------------
| Function    : sig_cia_su_cia_comp_ind
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_CIA_su_CIA_COMP_IND
|
| Parameters  : cia_comp_ind*
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_cia_su_cia_comp_ind (T_CIA_COMP_IND* cia_comp_ind)
{
  UBYTE sapi_index = 0;


  TRACE_ISIG( "sig_cia_su_cia_comp_ind" );

  /*
   * Set service instance according to sapi in signal.
   */
  sndcp_get_sapi_index(cia_comp_ind->sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_RECEPTIVE_SUSPEND:
    case SU_LLC_NOT_RECEPTIVE:
    case SU_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;
        UBYTE nsapi = cia_comp_ind->pdu_ref.ref_nsapi;
        UBYTE packet_type = cia_comp_ind->packet_type;

        PPASS(cia_comp_ind, ll_unitdata_req, LL_UNITDATA_REQ);

        su_add_ll_unitdata_req_params(nsapi,
                                      ll_unitdata_req);
        su_add_sn_header(seg_pos, pdu_ref,
                         ll_unitdata_req,
                         packet_type);
        /*
         * Write the ll_unitdata_req prim to ll_unitdata_q,
         * increment write pointer.
         */
        sndcp_data->su->ll_unitdata_q[sndcp_data->su->ll_unitdata_q_write] =
          ll_unitdata_req;
        sndcp_data->su->ll_unitdata_q_write =
          (sndcp_data->su->ll_unitdata_q_write + 1) % SNDCP_SEGMENT_NUMBERS_UNACK;

      }
      break;
    case SU_LLC_RECEPTIVE:
      {
        /*
         * Save seg_pos and pdu_ref from cia_comp_ind.
         */
        UBYTE ll_unitdata_sapi;
        UBYTE seg_pos = cia_comp_ind->seg_pos;
        T_pdu_ref pdu_ref = cia_comp_ind->pdu_ref;
        UBYTE nsapi = cia_comp_ind->pdu_ref.ref_nsapi;
        UBYTE packet_type = cia_comp_ind->packet_type;

        PPASS(cia_comp_ind, ll_unitdata_req, LL_UNITDATA_REQ);

        su_add_ll_unitdata_req_params(nsapi,
                                      ll_unitdata_req);
        su_add_sn_header(seg_pos, pdu_ref,
                         ll_unitdata_req,
                         packet_type);


#ifdef SNDCP_TRACE_ALL
        TRACE_EVENT("uplink with sn header at LL SAP: ");
        TRACE_EVENT_P1("%d octets",
                       (ll_unitdata_req->sdu.l_buf + 7) / 8);

        sndcp_trace_sdu(& ll_unitdata_req->sdu);
#endif

#ifdef FLOW_TRACE
        sndcp_trace_flow_control(FLOW_TRACE_SNDCP,
                                 FLOW_TRACE_UP,
                                 FLOW_TRACE_BOTTOM,
                                 FALSE);
#endif
        ll_unitdata_sapi = ll_unitdata_req->sapi;

        PSEND(hCommLLC, ll_unitdata_req);

        SET_STATE(SU, SU_LLC_NOT_RECEPTIVE);
        /*
         * If segment is the last of the N-PDU then send ready_ind to nsapi
         * and get next entry from sn q..
         */
        if ((seg_pos & SEG_POS_LAST) > 0) {
          sndcp_data->su->cia_state = CIA_IDLE;
          su_next_sn_unitdata_req( ll_unitdata_sapi );
          sig_su_nu_ready_ind(nsapi);
        }

      }
      break;
    default:
      TRACE_ERROR( "SIG_CIA_SU_CIA_COMP_IND unexpected" );
      break;
  }
} /* sig_cia_su_cia_comp_ind() */
#endif /* _SNDCP_DTI_2_ */
/*
+------------------------------------------------------------------------------
| Function    : sig_mg_su_delete_pdus
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_MG_SU_DELETE_PDUS
|               The same as the one in service sua, but everything is in the
|               unacknowledged version here.
|
| Parameters  : UBYTE nsapi the affected nsapi, UBYTE sapi the affected sapi
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_mg_su_delete_pdus (UBYTE nsapi, UBYTE sapi)
{
  UBYTE sapi_index = 0;
  BOOL ll_q_affected = FALSE;

  TRACE_ISIG( "sig_mg_su_delete_pdus" );

  /*
   * Set service instance according to sapi in signal.
   */
  sndcp_get_sapi_index(sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];
  sndcp_data->su->cia_state = CIA_IDLE;

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_NOT_RECEPTIVE_SUSPEND:
    case SU_LLC_RECEPTIVE_SUSPEND:
    case SU_LLC_NOT_RECEPTIVE:
    case SU_LLC_RECEPTIVE:
      {
        /*
         * Delete affected N-PDUS from sn_unitdata_q.
         */
        BOOL still = TRUE;
        UBYTE index = sndcp_data->su->sn_unitdata_q_read;

        while (still) {
          if (index == sndcp_data->su->sn_unitdata_q_write) {
            break;
          }
          if (sndcp_data->su->sn_unitdata_q[index]->nsapi == nsapi) {
            /*
             * The index for the prims to be shifted when 1 entry is deleted.
             */
            UBYTE i = 0;

            if (sndcp_data->su->sn_unitdata_q[index] != NULL) {
#ifdef _SNDCP_DTI_2_
              MFREE_PRIM(sndcp_data->su->sn_unitdata_q[index]);
#else /*_SNDCP_DTI_2_*/ 
              PFREE_DESC(sndcp_data->su->sn_unitdata_q[index]);
#endif /*_SNDCP_DTI_2_*/
              sndcp_data->su->sn_unitdata_q[index] = NULL;
            }

            for (i = index;
                 i != sndcp_data->su->sn_unitdata_q_write;
                 i = (i + 1) % SN_UNITDATA_Q_LEN) {


              sndcp_data->su->sn_unitdata_q[i] =
                sndcp_data->su->sn_unitdata_q[(i + 1) % SN_UNITDATA_Q_LEN];

              sndcp_data->su->sn_unitdata_q[(i + 1) % SN_UNITDATA_Q_LEN] =
                NULL;

            }
            sndcp_data->su->sn_unitdata_q_write =
              (sndcp_data->su->sn_unitdata_q_write - 1
               + SN_UNITDATA_Q_LEN) % SN_UNITDATA_Q_LEN;
          } else {
            index = (index + 1) % SN_UNITDATA_Q_LEN;
          } /* else (sndcp_data->su->sn_unitdata_q[index]->nsapi == nsapi) */

        }
#ifdef _SNDCP_DTI_2_
        /*
         * Delete affected SN-PDUS from ll_unitdata_q.
         */
        still = TRUE;
        index = sndcp_data->su->ll_unitdesc_q_read;
        while (still) {
          if (index == sndcp_data->su->ll_unitdesc_q_write) {
            break;
          }
          if (su_get_nsapi(sndcp_data->su->ll_unitdesc_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->su->ll_unitdesc_q[index] != NULL) {
              T_desc3 *free_help, *help =
             (T_desc3 *)sndcp_data->su->ll_unitdesc_q[index]->desc_list3.first;
              while(help != NULL)
              {
                 sndcp_cl_desc3_free(help);
                 free_help = help;
                 help = (T_desc3 *)free_help->next;
                 MFREE(free_help);
              }
              sndcp_data->su->ll_unitdesc_q[index]->desc_list3.first = NULL;
              PFREE(sndcp_data->su->ll_unitdesc_q[index]);
              sndcp_data->su->ll_unitdesc_q[index] = NULL;
            }

            for (i = index;
                 i != sndcp_data->su->ll_unitdesc_q_write;
                 i = (i + 1) % SNDCP_SEGMENT_NUMBERS_UNACK) {

              sndcp_data->su->ll_unitdesc_q[i] =
                sndcp_data->su->ll_unitdesc_q
                  [(i + 1) % SNDCP_SEGMENT_NUMBERS_UNACK];
            }
            sndcp_data->su->ll_unitdesc_q_write =
              (sndcp_data->su->ll_unitdesc_q_write - 1
               + SNDCP_SEGMENT_NUMBERS_UNACK) % SNDCP_SEGMENT_NUMBERS_UNACK;

          } else {
            index = (index + 1) % SNDCP_SEGMENT_NUMBERS_UNACK;
          } /* else (sndcp_data->su->sn_unitdata_q[index]->nsapi == nsapi) { */


        }
#else /* _SNDCP_DTI_2_ */
        /*
         * Delete affected SN-PDUS from ll_unitdata_q.
         */
        still = TRUE;
        index = sndcp_data->su->ll_unitdata_q_read;
        while (still) {
          if (index == sndcp_data->su->ll_unitdata_q_write) {
            break;
          }
          if (su_get_nsapi(sndcp_data->su->ll_unitdata_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->su->ll_unitdata_q[index] != NULL) {
              PFREE(sndcp_data->su->ll_unitdata_q[index]);
              sndcp_data->su->ll_unitdata_q[index] = NULL;
            }

            for (i = index;
                 i != sndcp_data->su->ll_unitdata_q_write;
                 i = (i + 1) % SNDCP_SEGMENT_NUMBERS_UNACK) {

              sndcp_data->su->ll_unitdata_q[i] =
                sndcp_data->su->ll_unitdata_q
                  [(i + 1) % SNDCP_SEGMENT_NUMBERS_UNACK];
            }
            sndcp_data->su->ll_unitdata_q_write =
              (sndcp_data->su->ll_unitdata_q_write - 1
               + SNDCP_SEGMENT_NUMBERS_UNACK) % SNDCP_SEGMENT_NUMBERS_UNACK;

          } else {
            index = (index + 1) % SNDCP_SEGMENT_NUMBERS_UNACK;
          } /* else (sndcp_data->su->sn_unitdata_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) {
        su_next_sn_unitdata_req (sapi);
      }
      break;
    default:
      TRACE_ERROR( "SIG_MG_SU_DELETE_PDUS unexpected" );
      break;
  }
} /* sig_mg_su_delete_pdus() */



/*
+------------------------------------------------------------------------------
| Function    : sig_mg_su_n201
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_MG_SU_N201
|
| Parameters  : UBYTE sapi the affected sapi, USHORT n201
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_mg_su_n201 (UBYTE sapi,
                            USHORT n201)
{
  UBYTE sapi_index = 0;

  TRACE_ISIG( "sig_mg_su_n201" );

  /*
   * Set service instance according to sapi in signal.
   */
  sndcp_get_sapi_index(sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_NOT_RECEPTIVE_SUSPEND:
    case SU_LLC_RECEPTIVE_SUSPEND:
    case SU_LLC_NOT_RECEPTIVE:
    case SU_LLC_RECEPTIVE:
      sndcp_data->su->n201_u = n201;
      break;
    default:
      TRACE_ERROR( "SIG_MG_SU_N201 unexpected" );
      break;
  }
} /* sig_mg_su_n201() */



/*
+------------------------------------------------------------------------------
| Function    : sig_mg_su_suspend
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_MG_SU_SUSPEND
|
| Parameters  : UBYTE sapi the affected sapi
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_mg_su_suspend (UBYTE sapi)
{
  UBYTE sapi_index = 0;

  TRACE_ISIG( "sig_mg_su_suspend" );

  /*
   * Set service instance according to sapi in signal.
   */
  sndcp_get_sapi_index(sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_NOT_RECEPTIVE_SUSPEND:
      break;
    case SU_LLC_RECEPTIVE_SUSPEND:
      break;
    case SU_LLC_NOT_RECEPTIVE:
      SET_STATE (SU, SU_LLC_NOT_RECEPTIVE_SUSPEND);
      break;
    case SU_LLC_RECEPTIVE:
      SET_STATE (SU, SU_LLC_RECEPTIVE_SUSPEND);
      break;
    default:
      TRACE_ERROR( "SIG_MG_SU_SUSPEND unexpected" );
      break;
  }
} /* sig_mg_su_suspend() */

/*
+------------------------------------------------------------------------------
| Function    : sig_mg_su_reset_ind
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_MG_SU_RESET_IND
|
| Parameters  : UBYTE sapi the affected sapi
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_mg_su_reset_ind (UBYTE sapi)
{
  UBYTE sapi_index = 0;

  TRACE_ISIG( "sig_mg_su_reset_ind" );

  /*
   * Set service instance according to sapi in signal.
   */
  sndcp_get_sapi_index(sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_NOT_RECEPTIVE_SUSPEND:
    case SU_LLC_RECEPTIVE_SUSPEND:
    case SU_LLC_NOT_RECEPTIVE:
    case SU_LLC_RECEPTIVE:
      break;
    default:
      TRACE_ERROR( "SIG_MG_SU_RESET_IND unexpected" );
      break;
  }
} /* sig_mg_su_reset_ind() */

#ifdef _SNDCP_DTI_2_
/*
+------------------------------------------------------------------------------
| Function    : sig_mg_su_resume
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_MG_SU_RESUME
|
| Parameters  : UBYTE sapi the affected sapi
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_mg_su_resume (UBYTE sapi)
{
  UBYTE sapi_index = 0;


  TRACE_ISIG( "sig_mg_su_resume" );
  /*
   * Set service instance according to sapi in signal.
   */
  sndcp_get_sapi_index(sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_NOT_RECEPTIVE_SUSPEND:
      SET_STATE (SU, SU_LLC_NOT_RECEPTIVE);
      break;
    case SU_LLC_RECEPTIVE_SUSPEND:
      /*
       * Is queue with LL_UNITDESC_REQ empty?
       */
      if (sndcp_data->su->ll_unitdesc_q_write ==
          sndcp_data->su->ll_unitdesc_q_read) {
        SET_STATE(SU, SU_LLC_RECEPTIVE);
      } else {
        /*
         * Get next segment from queue and send it.
         */
        U8 ll_unitdesc_seg_pos;
        U8 ll_unitdesc_nsapi;
        U8 ll_unitdesc_sapi;

        T_LL_UNITDESC_REQ* ll_unitdesc_req =
          sndcp_data->su->ll_unitdesc_q[sndcp_data->su->ll_unitdesc_q_read];

        sndcp_data->su->ll_unitdesc_q[sndcp_data->su->ll_unitdesc_q_read] =
          NULL;

        sndcp_data->su->ll_unitdesc_q_read =
            (sndcp_data->su->ll_unitdesc_q_read + 1) %
              SNDCP_SEGMENT_NUMBERS_UNACK;


        /*
         * trace output
         */
#ifdef SNDCP_TRACE_ALL
        TRACE_EVENT("uplink with sn header at LL SAP: ");
        TRACE_EVENT_P1("%d octets",
                       ll_unitdesc_req->desc_list3.list_len);

        sndcp_trace_desc_list3_content(ll_unitdesc_req->desc_list3);
#endif
#ifdef FLOW_TRACE
        sndcp_trace_flow_control(FLOW_TRACE_SNDCP,
                                 FLOW_TRACE_UP,
                                 FLOW_TRACE_BOTTOM,
                                 FALSE);
#endif
        ll_unitdesc_seg_pos = ll_unitdesc_req->seg_pos;
        ll_unitdesc_nsapi   = su_get_nsapi(ll_unitdesc_req);
        ll_unitdesc_sapi    = ll_unitdesc_req->sapi;

#ifdef _SIMULATION_
        su_send_ll_unitdata_req_test(ll_unitdesc_req);
#else /* _SIMULATION_ */
        PSEND(hCommLLC, ll_unitdesc_req);
#endif /* _SIMULATION_ */

        SET_STATE(SU, SU_LLC_NOT_RECEPTIVE);
        /*
         * If segment is the last of the N-PDU then send ready_ind to nsapi
         * and get next entry from sn q..
         */
        if ((ll_unitdesc_seg_pos & SEG_POS_LAST) > 0) {
          sndcp_data->su->cia_state = CIA_IDLE;
          su_next_sn_unitdata_req( ll_unitdesc_sapi );
          sig_su_nu_ready_ind( ll_unitdesc_nsapi );
        }
      }

      break;
    case SU_LLC_NOT_RECEPTIVE:
      break;
    case SU_LLC_RECEPTIVE:
      break;
    default:
      TRACE_ERROR( "SIG_MG_SU_RESUME unexpected" );
      break;
  }
} /* sig_mg_su_resume() */
#else /* _SNDCP_DTI_2_ */
/*
+------------------------------------------------------------------------------
| Function    : sig_mg_su_resume
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_MG_SU_RESUME
|
| Parameters  : UBYTE sapi the affected sapi
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_mg_su_resume (UBYTE sapi)
{
  UBYTE sapi_index = 0;


  TRACE_ISIG( "sig_mg_su_resume" );
  /*
   * Set service instance according to sapi in signal.
   */
  sndcp_get_sapi_index(sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_NOT_RECEPTIVE_SUSPEND:
      SET_STATE (SU, SU_LLC_NOT_RECEPTIVE);
      break;
    case SU_LLC_RECEPTIVE_SUSPEND:
      /*
       * Is queue with LL_UNITDATA_REQ empty?
       */
      if (sndcp_data->su->ll_unitdata_q_write ==
          sndcp_data->su->ll_unitdata_q_read) {
        SET_STATE(SU, SU_LLC_RECEPTIVE);
      } else {
        /*
         * Get next segment from queue and send it.
         */
        UBYTE ll_unitdata_seg_pos;
        UBYTE ll_unitdata_nsapi;
        UBYTE ll_unitdata_sapi;

        T_LL_UNITDATA_REQ* ll_unitdata_req =
          sndcp_data->su->ll_unitdata_q[sndcp_data->su->ll_unitdata_q_read];

        sndcp_data->su->ll_unitdata_q[sndcp_data->su->ll_unitdata_q_read] =
          NULL;

        sndcp_data->su->ll_unitdata_q_read =
            (sndcp_data->su->ll_unitdata_q_read + 1) %
              SNDCP_SEGMENT_NUMBERS_UNACK;


        /*
         * trace output
         */
#ifdef SNDCP_TRACE_ALL
        TRACE_EVENT("uplink with sn header at LL SAP: ");
        TRACE_EVENT_P1("%d octets",
                       (ll_unitdata_req->sdu.l_buf + 7) / 8);
        sndcp_trace_sdu(& ll_unitdata_req->sdu);


#endif
#ifdef FLOW_TRACE
        sndcp_trace_flow_control(FLOW_TRACE_SNDCP,
                                 FLOW_TRACE_UP,
                                 FLOW_TRACE_BOTTOM,
                                 FALSE);
#endif
        ll_unitdata_seg_pos = ll_unitdata_req->seg_pos;
        ll_unitdata_nsapi   = su_get_nsapi(ll_unitdata_req);
        ll_unitdata_sapi    = ll_unitdata_req->sapi;

        PSEND(hCommLLC, ll_unitdata_req);

        SET_STATE(SU, SU_LLC_NOT_RECEPTIVE);
        /*
         * If segment is the last of the N-PDU then send ready_ind to nsapi
         * and get next entry from sn q..
         */
        if ((ll_unitdata_seg_pos & SEG_POS_LAST) > 0) {
          sndcp_data->su->cia_state = CIA_IDLE;
          su_next_sn_unitdata_req( ll_unitdata_sapi );
          sig_su_nu_ready_ind( ll_unitdata_nsapi );
        }
      }

      break;
    case SU_LLC_NOT_RECEPTIVE:
      break;
    case SU_LLC_RECEPTIVE:
      break;
    default:
      TRACE_ERROR( "SIG_MG_SU_RESUME unexpected" );
      break;
  }
} /* sig_mg_su_resume() */
#endif /* _SNDCP_DTI_2_ */
/*
+------------------------------------------------------------------------------
| Function    : sig_nu_su_unitdata_req
+------------------------------------------------------------------------------
| Description : Handles the internal signal SIG_NU_SU_UNITDATA_REQ
|
| Parameters  : T_SN_UNITDATA_REQ ,  N-PDU to be sent to sapiup in form of
|                                    prim struct
|                                    USHORT,  the send N-PDU number of this N-PDU
|                                    UBYTE, the number of the NSAPI who sent the N-PDU
|                                    UBYTE), the SAPI that is supposed to compute the N-PDU
|
|
+------------------------------------------------------------------------------
*/
GLOBAL void sig_nu_su_unitdata_req (T_SN_UNITDATA_REQ* sn_unitdata_req,
                                    USHORT npdu_number,
                                    UBYTE nsapi,
                                    UBYTE sapi
                                    )
{
  UBYTE sapi_index = 0;

#ifdef _SNDCP_MEAN_TRACE_
#ifdef _SNDCP_DTI_2_
  sndcp_mean_trace(nsapi,
                   SNDCP_MEAN_UP,
                   SNDCP_MEAN_UNACK,
                   sn_unitdata_req->desc_list2.list_len);
#else /*_SNDCP_DTI_2_*/
  sndcp_mean_trace(nsapi,
                   SNDCP_MEAN_UP,
                   SNDCP_MEAN_UNACK,
                   sn_unitdata_req->desc_list.list_len);
#endif /*_SNDCP_DTI_2_*/
#endif /* _SNDCP_MEAN_TRACE_ */

  TRACE_ISIG( "sig_nu_su_unitdata_req" );


  /*
   * set service instance according to sapi in signal
   */
  sndcp_get_sapi_index(sapi, &sapi_index);
  sndcp_data->su = & sndcp_data->su_base[sapi_index];

  switch( GET_STATE( SU ) )
  {
    case SU_LLC_RECEPTIVE_SUSPEND:
    case SU_LLC_NOT_RECEPTIVE_SUSPEND:
    case SU_LLC_NOT_RECEPTIVE:
    case SU_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->su->sn_unitdata_q_read ==
           sndcp_data->su->sn_unitdata_q_write) &&
          (sndcp_data->su->ll_unitdesc_q_read ==
           sndcp_data->su->ll_unitdesc_q_write) &&
          sndcp_data->su->cia_state == CIA_IDLE) {
        /*
         * Send the NPDU to cia.
         */
        sndcp_data->su->cia_state = CIA_BUSY;
        sig_su_cia_cia_comp_req(sn_unitdata_req,
                            npdu_number,
                            nsapi,
                            sapi);
      } else { /* Queue with NPDUs is not empty or cia is busy. */
        /*
         * Write the sn_unitdata_req prim to sn_unitdata_q,
         * increment write pointer.
         */
        sndcp_data->su->sn_unitdata_q[sndcp_data->su->sn_unitdata_q_write] =
          sn_unitdata_req;
        sndcp_data->su->npdu_number_q[sndcp_data->su->sn_unitdata_q_write] =
          npdu_number;
        sndcp_data->su->sn_unitdata_q_write =
          (sndcp_data->su->sn_unitdata_q_write + 1) % SN_UNITDATA_Q_LEN;
      } /* Queue with NPDUs is not empty or cia is busy. */
      break;
    default:
      TRACE_ERROR( "SIG_NU_SU_UNITDATA_REQ unexpected" );
#ifdef _SNDCP_DTI_2_
      MFREE_PRIM(sn_unitdata_req);
#else /*_SNDCP_DTI_2_*/
      PFREE_DESC(sn_unitdata_req);
#endif /*_SNDCP_DTI_2_*/
      break;
  }
} /* sig_nu_su_unitdata_req() */

#ifdef _SIMULATION_
#ifdef  _SNDCP_DTI_2_
/*
+------------------------------------------------------------------------------
| Function    : su_send_ll_unitdata_req_test
+------------------------------------------------------------------------------
| Description : Only for test purposes.
|               The given LL_UNITDESC_REQ is copied to an
|               LL_UNITDATA_REQ and sent for the simulated test environment.
|
| Parameters  :
|
+------------------------------------------------------------------------------
*/
void su_send_ll_unitdata_req_test(T_LL_UNITDESC_REQ* ll_unitdesc_req)
{
  T_desc3* descriptor = NULL;
  U8* p_data = NULL;
  U16 offset = ENCODE_OFFSET_BYTE;

  PALLOC_SDU(ll_unitdata_req, LL_UNITDATA_REQ, (U16)( ll_unitdesc_req->desc_list3.list_len* 8));

  /*
   * Set parameters in ll_unitdata_req primitive
   */
  ll_unitdata_req->sapi = ll_unitdesc_req->sapi;
  ll_unitdata_req->tlli = ll_unitdesc_req->tlli;
  ll_unitdata_req->ll_qos = ll_unitdesc_req->ll_qos;
  ll_unitdata_req->radio_prio = ll_unitdesc_req->radio_prio;
  ll_unitdata_req->cipher = ll_unitdesc_req->cipher;
  ll_unitdata_req->reserved_unitdata_req1 = ll_unitdesc_req->reserved_unitdata_req1;
  ll_unitdata_req->seg_pos = ll_unitdesc_req->seg_pos;
  ll_unitdata_req->attached_counter = ll_unitdesc_req->attached_counter;
  ll_unitdata_req->reserved_unitdata_req4 = ll_unitdesc_req->reserved_unitdata_req4;
#ifdef REL99
  ll_unitdata_req->pkt_flow_id = ll_unitdesc_req->pkt_flow_id;
#endif /*REL99*/
  /*
   * Set the ENCODE_OFFSET in the uplink sdu, set sdu.l_buf
   */
  ll_unitdata_req->sdu.o_buf = ENCODE_OFFSET;
  ll_unitdata_req->sdu.l_buf = ll_unitdesc_req->desc_list3.list_len* 8;
  /*
   * Copy the data.
   */
  descriptor = (T_desc3*)ll_unitdesc_req->desc_list3.first;
  while (descriptor != NULL)
  {
    T_desc3* help = descriptor;
    p_data = (U8*)descriptor->buffer;
    if (descriptor->len>0)
    {
      memcpy(&ll_unitdata_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_unitdata_req);

  PFREE(ll_unitdesc_req); // MAYBE REMEMBER is this the correct free?

} /* su_send_ll_unitdata_req_test */

#endif /* _SNDCP_DTI_2_ */
#endif /* _SIMULATION_ */