--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/g23m-fad/l2r/l2r_ups.c	Sun Jul 15 04:40:46 2018 +0000
@@ -0,0 +1,399 @@
+/* 
++----------------------------------------------------------------------------- 
+|  Project :  CSD (8411)
+|  Modul   :  L2r_ups.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 defines the functions for processing
+|             of incomming signals for the component
+|             L2R of the base station
++----------------------------------------------------------------------------- 
+*/ 
+
+
+#ifndef L2R_UPS_C
+#define L2R_UPS_C
+#endif
+
+#define ENTITY_L2R
+
+/*==== INCLUDES ===================================================*/
+
+#include <string.h>
+#include "typedefs.h"
+#include "pconst.cdg"
+#include "vsi.h"
+#include "macdef.h"
+#include "custom.h"
+#include "gsm.h"
+#include "cus_l2r.h"
+#include "cnf_l2r.h"
+#include "mon_l2r.h"
+#include "prim.h"
+#include "pei.h"
+#include "tok.h"
+#include "dti.h"      /* functionality of the dti library */
+
+#include "cl_ribu.h"
+#include "l2r.h"
+
+/*==== CONST =======================================================*/
+
+/*==== TYPES =======================================================*/
+
+/*==== VAR EXPORT ==================================================*/
+
+/*==== VAR LOCAL ===================================================*/
+
+/*==== FUNCTIONS ===================================================*/
+
+/*
++-------------------------------------------------------------------------------------
+|  Function    : sig_mgt_up_conn_req
++-------------------------------------------------------------------------------------
+|  Description : Process signal SIG_MGT_UP_CONN_REQ received from process management.
+|
+|  Parameters  : framesPerPrim - Number of frames per primitive
+|                frameSize     - Size of the frame
+|                flowCtrlUsed  - Indicates wheather Flow Control is used or not.
+|                riBuSize      - Size of the ring buffer
+|                inst_id       - Instance Number
+|
+|
+|  Return      : -
++-------------------------------------------------------------------------------------
+*/
+
+GLOBAL void sig_mgt_up_conn_req
+            (
+              UBYTE                  framesPerPrim,
+              USHORT                 frameSize,
+              BOOL                   flowCtrlUsed,
+              T_PRIM_DESC_RIBU_SIZE  riBuSize,
+              UBYTE                  inst_id
+            )
+{
+  T_UP *dup = &l2r_data->up;
+
+  TRACE_FUNCTION ("sig_mgt_up_conn_req()");
+
+  switch (GET_STATE (UP))
+  {
+  case UP_DISCONNECTED:
+    dup->FramesPerPrim = framesPerPrim;
+    dup->FrameSize     = frameSize;
+    dup->DataSize      = frameSize - HT_LEN;
+    dup->FlowCtrlUsed  = flowCtrlUsed;
+    dup->RiBu.idx.depth = riBuSize;
+    dup->FlowCtrlUsed  = flowCtrlUsed;
+    dup->InstID        = inst_id; /* ###jkaa: and what about this??  l2r_data->mgt.InstID */
+
+	up_rq_init();
+
+    dup->DiscardRemapData = FALSE;
+
+    if (dup->RiBu.idx.depth < UP_RIBU_PREALLOC + 1)
+    {
+      dup->RiBu.idx.depth = UP_RIBU_PREALLOC + 1;
+    }
+    if (dup->RiBu.idx.depth > MAX_UPRIM_RIBU_SIZE)
+    {
+      dup->RiBu.idx.depth = MAX_UPRIM_RIBU_SIZE;
+    }
+
+    dup->FlowThreshHi = 3 * dup->RiBu.idx.depth / 4;
+    dup->FlowThreshLo = dup->FlowThreshHi - 2;
+    if (dup->FlowThreshLo < 1)
+    {
+      dup->FlowThreshLo = 1;
+    }
+    dup->DnFlow = FL_INACTIVE;
+    dup->UpFlow = FL_INACTIVE;
+    dup->ULFlow = FL_INACTIVE;
+    dup->LLFlow = FL_INACTIVE;
+    up_merge_flow();
+
+    SET_STATE (UP_LL, ISW_IDLE);
+    SET_STATE (UP_UL, IW_IDLE);
+
+    up_init_ribu();
+    up_send_status(   /* status must be sent after connecting */
+      dup->LastSentSa,
+      dup->LastSentSb,
+      dup->MrgFlow,
+      SO_END_EMPTY
+      );
+    up_send_prim_cond();
+    SET_STATE (UP, UP_CONNECTED);
+    break;
+  }
+}
+
+/*
++------------------------------------------------------------------------------
+|  Function    : sig_mgt_up_disc_req
++------------------------------------------------------------------------------
+|  Description : Process signal SIG_MGT_UP_DISC_REQ received from
+|                process management.
+|
+|  Parameters  : -
+|
+|
+|  Return      : -
++------------------------------------------------------------------------------
+*/
+
+
+GLOBAL void sig_mgt_up_disc_req(void)
+{
+  TRACE_FUNCTION ("sig_mgt_up_disc_req()");
+
+  switch (GET_STATE (UP))
+  {
+  case UP_CONNECTED:
+  case UP_REMAP:
+    up_deinit_ribu();
+    SET_STATE (UP, UP_DISCONNECTED);
+    break;
+  }
+}
+
+/*
++------------------------------------------------------------------------------
+|  Function    : sig_mgt_up_break_req
++------------------------------------------------------------------------------
+|  Description : Process signal SIG_MGT_UP_BREAK_REQ received from process management.
+|
+|  Parameters  : sa   - status bit ( general ready signal)
+|                sb   - staus bit  (data are valid or)
+|                flow - flow control staus (active or inactive)
+|
+|  Return      : -
++------------------------------------------------------------------------------
+*/
+
+
+GLOBAL void sig_mgt_up_break_req
+            (
+              T_BIT sa,
+              T_BIT sb,
+              T_FLOW flow
+            )
+{
+  TRACE_FUNCTION ("sig_mgt_up_break_req()");
+
+  switch (GET_STATE (UP))
+  {
+    case UP_CONNECTED:
+    case UP_REMAP:
+      up_deinit_ribu();
+      up_init_ribu();
+      up_store_status(sa, sb, flow);
+      up_send_status(sa, sb, l2r_data->up.MrgFlow, SO_BREAK_REQ); /*jk:030501*/
+      up_send_prim_cond();
+      break;
+  }
+}
+
+
+/*
++------------------------------------------------------------------------------
+|  Function    : sig_mgt_up_clear_req
++------------------------------------------------------------------------------
+|  Description : Process signal SIG_MGT_UP_CLEAR_REQ received from
+|                process management.
+|
+|  Parameters  : -
+|
+|
+|  Return      : -
++------------------------------------------------------------------------------
+*/
+
+
+GLOBAL void sig_mgt_up_clear_req(void)
+{
+  T_UP *dup = &l2r_data->up;
+
+  TRACE_FUNCTION ("sig_mgt_up_clear_req()");
+
+  switch (GET_STATE (UP))
+  {
+    case UP_CONNECTED:
+    case UP_REMAP:
+      up_deinit_ribu();
+      up_init_ribu();
+      /*
+      status must be sent after reset
+      */
+      up_send_status(dup->LastRcvdSa, dup->LastRcvdSb, dup->MrgFlow, SO_END_EMPTY);
+      up_send_prim_cond();
+      break;
+  }
+}
+
+/*
++------------------------------------------------------------------------------
+|  Function    : sig_mgt_up_dti_conn_setup
++------------------------------------------------------------------------------
+|  Description : Process signal SIG_MGT_UP_DTI_CONN_SETUP
+|                received from process management.
+|
+|  Parameters  : link_id            channel id of the link
+|
+|  Return      : -
++------------------------------------------------------------------------------
+*/
+
+GLOBAL void sig_mgt_up_dti_conn_setup (ULONG link_id)
+{
+  TRACE_FUNCTION ("sig_mgt_up_dti_conn_setup()");
+  l2r_data->up.link_id = link_id;
+  SET_STATE (UP_UL, IW_IDLE); /* jk: to IDLE in order to be able to respond with DTI_READY_IND */
+                                   /* when the next condition is fullfilled */
+}
+
+/*
++------------------------------------------------------------------------------
+|  Function    : sig_mgt_up_dti_conn_open
++------------------------------------------------------------------------------
+|  Description : Process signal SIG_MGT_UP_DTI_CONN_OPEN
+|                received from process management.
+|
+|  Parameters  : -
+|  Return      : -
++------------------------------------------------------------------------------
+*/
+
+GLOBAL void sig_mgt_up_dti_conn_open()
+{
+  T_UP *dup = &l2r_data->up;
+
+  TRACE_FUNCTION ("sig_mgt_up_dti_conn_open()");
+
+  dup->DtiConnected = TRUE;
+
+  /* jk: DTI_READY_IND only when the primitive is sent to UL */
+  if (dup->Prim EQ NULL)
+  {
+    up_send_ready();
+  }
+  else if (dup->Prim->desc_list2.first EQ 0)
+  {
+    PFREE (dup->Prim);
+    up_send_ready();
+  }
+}
+
+/*
++------------------------------------------------------------------------------
+|  Function    : sig_dn_up_flow
++------------------------------------------------------------------------------
+|  Description :Process signal SIG_DN_UP_FLOW received from process management.
+|
+|  Parameters  : flow - flow control active or inactive
+|
+|
+|  Return      : -
++------------------------------------------------------------------------------
+*/
+
+GLOBAL void sig_dn_up_flow(T_FLOW flow)
+{
+  T_UP *dup = &l2r_data->up;
+
+  T_FLOW oldFlow;
+
+  TRACE_FUNCTION ("sig_dn_up_flow()");
+
+  switch (GET_STATE (UP))
+  {
+  case UP_CONNECTED:
+    oldFlow = dup->DnFlow;
+    dup->DnFlow = flow;
+    if (flow EQ oldFlow)
+      return;
+
+    up_merge_flow();
+    if ((dup->LastSentFlow EQ dup->MrgFlow) OR (GET_STATE (UP_LL) NEQ ISW_WAIT))
+      return;
+
+    TIMERSTOP (TIMER_TUP_SND);
+    switch (dup->LLFlow)
+    {
+    case FL_INACTIVE:
+      up_send_prim_timeout();
+      break;
+
+    case FL_ACTIVE:
+      up_send_empty_frame(dup->LastSentSa, dup->LastSentSb, dup->MrgFlow);
+      break;
+    }
+
+    if (!dup->RiBu.idx.filled)
+      SET_STATE (UP_LL, ISW_IDLE)
+    else
+      SET_STATE (UP_LL, ISW_SEND)
+    break;
+
+  case UP_REMAP:
+    oldFlow = dup->DnFlow;
+    dup->DnFlow = flow;
+    if (flow NEQ oldFlow)
+    {
+      up_merge_flow();
+    }
+    break;
+  }
+}
+
+/*
++------------------------------------------------------------------------------
+|  Function    : sig_dn_up_ll_flow
++------------------------------------------------------------------------------
+|  Description : Process signal SIG_DN_UP_LL_FLOW received from process management.
+|
+|  Parameters  : flow - flow control status (active - inactive)
+|
+|
+|  Return      : -
++------------------------------------------------------------------------------
+*/
+
+GLOBAL void sig_dn_up_ll_flow(T_FLOW flow)
+{
+  T_UP *dup = &l2r_data->up;
+  TRACE_FUNCTION ("sig_dn_up_ll_flow()");
+
+  switch (GET_STATE (UP))
+  {
+  case UP_CONNECTED:
+    dup->LLFlow = flow;
+
+    if (dup->LLFlow EQ FL_INACTIVE AND GET_STATE (UP_LL) EQ ISW_WAIT AND dup->RiBu.idx.filled)
+    {
+      TIMERSTOP (TIMER_TUP_SND);
+      up_send_current_prim();
+
+      if (!dup->RiBu.idx.filled)
+        SET_STATE (UP_LL, ISW_IDLE)
+      else
+        SET_STATE (UP_LL, ISW_SEND)
+    }
+    break;
+
+  case UP_REMAP:
+    dup->LLFlow = flow;
+    break;
+  }
+}