valgrind memory leak fixes
[o-du/l2.git] / src / 5gnrmac / mac_msg_hdl.c
index fa8b678..694cd74 100644 (file)
 #   See the License for the specific language governing permissions and        #
 #   limitations under the License.                                             #
 ################################################################################
-*******************************************************************************/
+ *******************************************************************************/
 
 /* header include files -- defines (.h)  */
-#include <stdbool.h>
-#include "envopt.h"        /* environment options */
-#include "envdep.h"        /* environment dependent */
-#include "envind.h"        /* environment independent */
-#include "gen.h"           /* general layer */
-#include "ssi.h"           /* system services */
-#include "cm5.h"           /* common timers defines */
-#include "cm_hash.h"       /* common hash list defines */
-#include "cm_llist.h"      /* common linked list defines */
-#include "cm_mblk.h"       /* memory management */
-#include "cm_tkns.h"       /* common tokens */
-#include "cm_lte.h"        /* common tokens */
-#include "rgu.h"
-#include "tfu.h"
-#include "rg_sch_inf.h"
-#include "rg_env.h"
+#include "common_def.h"
 #include "lrg.h"
-#include "crg.h"
-#include "rg.h"
-#include "du_log.h"
-#include "lwr_mac.h"
-
-/* header/extern include files (.x) */
-#include "gen.x"           /* general layer typedefs */
-#include "ssi.x"           /* system services typedefs */
-#include "cm5.x"           /* common timers */
-#include "cm_hash.x"       /* common hash list */
-#include "cm_lib.x"        /* common library */
-#include "cm_llist.x"      /* common linked list */
-#include "cm_mblk.x"       /* memory management */
-#include "cm_tkns.x"       /* common tokens */
-#include "cm_lte.x"        /* common tokens */
-#include "rgu.x"
-#include "tfu.x"
-#include "rg_sch_inf.x"
 #include "lrg.x"
-#include "crg.x"
-#include "rg_prg.x"
 #include "du_app_mac_inf.h"
+#include "mac_sch_interface.h"
+#include "rlc_mac_inf.h"
 #include "mac_upr_inf_api.h"
-#include "rg.x"
+#include "lwr_mac.h"
+#ifdef INTEL_FAPI
+#include "fapi_interface.h"
+#endif
 #include "lwr_mac_fsm.h"
+#include "lwr_mac_upr_inf.h"
 #include "mac.h"
+#include "mac_utils.h"
 
 /* This file contains message handling functionality for MAC */
 
-extern MacCb  macCb;
+MacCb  macCb;
 
-extern void sendToLowerMac(uint16_t msgType, uint32_t msgLen, void *msg);
-uint16_t buildMacPdu(RlcMacData *dlData);
+uint16_t buildMacPdu(RlcData *dlData);
+#ifdef EGTP_TEST
+void macStubBuildUlData(Buffer *mBuf);
+#endif
 
 /* Function pointer for sending crc ind from MAC to SCH */
 MacSchCrcIndFunc macSchCrcIndOpts[]=
 {
    packMacSchCrcInd,
-   macSchCrcInd,
+   MacSchCrcInd,
    packMacSchCrcInd
 };
 
@@ -80,17 +54,33 @@ MacSchCrcIndFunc macSchCrcIndOpts[]=
 MacSchDlRlcBoInfoFunc macSchDlRlcBoInfoOpts[]=
 {
    packMacSchDlRlcBoInfo,
-   macSchDlRlcBoInfo,
+   MacSchDlRlcBoInfo,
    packMacSchDlRlcBoInfo
 };
 
+/* Function pointer for sending short BSR from MAC to SCH */
+MacSchBsrFunc macSchBsrOpts[]=
+{
+   packMacSchBsr,
+   MacSchBsr,
+   packMacSchBsr
+};
+
+/* Function pointer for sending SR Uci ind from MAC to SCH */
+MacSchSrUciIndFunc macSchSrUciIndOpts[]=
+{
+   packMacSchSrUciInd,
+   MacSchSrUciInd,
+   packMacSchSrUciInd
+};
+
 /*******************************************************************
  *
  * @brief Sends DL BO Info to SCH
  *
  * @details
  *
- *    Function : sendDlRlcBoInfoMacToSch
+ *    Function : sendDlRlcBoInfoToSch
  *
  *    Functionality:
  *       Sends DL BO Info to SCH
@@ -100,13 +90,11 @@ MacSchDlRlcBoInfoFunc macSchDlRlcBoInfoOpts[]=
  *         RFAILED - failure
  *
  ****************************************************************/
-int sendDlRlcBoInfoMacToSch(DlRlcBOInfo *dlBoInfo)
+uint8_t sendDlRlcBoInfoToSch(DlRlcBoInfo *dlBoInfo)
 {
    Pst pst;
-   fillMacToSchPst(&pst);
-   pst.event = EVENT_DL_RLC_BO_INFO_TO_SCH;
+
+   FILL_PST_MAC_TO_SCH(pst, EVENT_DL_RLC_BO_INFO_TO_SCH);
    return(*macSchDlRlcBoInfoOpts[pst.selector])(&pst, dlBoInfo);
 }
 
@@ -125,17 +113,15 @@ int sendDlRlcBoInfoMacToSch(DlRlcBOInfo *dlBoInfo)
  * @return ROK     - success
  *         RFAILED - failure
  *
 ****************************************************************/
-int sendCrcIndMacToSch(CrcIndInfo *crcInd)
+ ****************************************************************/
+uint8_t sendCrcIndMacToSch(CrcIndInfo *crcInd)
 {
    Pst pst;
-   fillMacToSchPst(&pst);
-   pst.event = EVENT_CRC_IND_TO_SCH;
+
+   FILL_PST_MAC_TO_SCH(pst, EVENT_CRC_IND_TO_SCH);
    return(*macSchCrcIndOpts[pst.selector])(&pst, crcInd);
 }
+
 /*******************************************************************
  *
  * @brief Processes CRC Indication from PHY
@@ -153,23 +139,24 @@ int sendCrcIndMacToSch(CrcIndInfo *crcInd)
  *         RFAILED - failure
  *
  * ****************************************************************/
-uint16_t fapiMacCrcInd(Pst *pst, CrcInd *crcInd)
+uint8_t fapiMacCrcInd(Pst *pst, CrcInd *crcInd)
 {
+   uint16_t     cellIdx;
    CrcIndInfo   crcIndInfo;
    DU_LOG("\nMAC : Received CRC indication");
-
+   GET_CELL_IDX(crcInd->cellId, cellIdx);
    /* Considering one pdu and one preamble */ 
-   crcIndInfo.cellId = macCb.macCell->cellId;;
+   crcIndInfo.cellId = macCb.macCell[cellIdx]->cellId;
    crcIndInfo.crnti = crcInd->crcInfo[0].rnti;
    crcIndInfo.timingInfo.sfn = crcInd->timingInfo.sfn;
    crcIndInfo.timingInfo.slot = crcInd->timingInfo.slot;
    crcIndInfo.numCrcInd = crcInd->crcInfo[0].numCb;
    crcIndInfo.crcInd[0] = crcInd->crcInfo[0].cbCrcStatus[0];
+
+   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, crcInd, sizeof(CrcInd));
    return(sendCrcIndMacToSch(&crcIndInfo));
 }
+
 /*******************************************************************
  *
  * @brief Process Rx Data Ind at MAC
@@ -187,19 +174,20 @@ uint16_t fapiMacCrcInd(Pst *pst, CrcInd *crcInd)
  *         RFAILED - failure
  *
  * ****************************************************************/
-uint16_t fapiMacRxDataInd(Pst *pst, RxDataInd *rxDataInd)
+uint8_t fapiMacRxDataInd(Pst *pst, RxDataInd *rxDataInd)
 {
    uint16_t pduIdx;
    DU_LOG("\nMAC : Received Rx Data indication");
-  
    /* TODO : compare the handle received in RxDataInd with handle send in PUSCH
-        * PDU, which is stored in raCb */
+    * PDU, which is stored in raCb */
 
    for(pduIdx = 0; pduIdx < rxDataInd->numPdus; pduIdx++)
    {
-      unpackRxData(&rxDataInd->pdus[pduIdx]);
+      unpackRxData(rxDataInd->cellId, rxDataInd->timingInfo, &rxDataInd->pdus[pduIdx]);
+      MAC_FREE_SHRABL_BUF(pst->region, pst->pool, rxDataInd->pdus[pduIdx].pduData,\
+         rxDataInd->pdus[pduIdx].pduLength);
    }
+   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, rxDataInd, sizeof(RxDataInd));
    return ROK;
 }
 
@@ -209,7 +197,7 @@ uint16_t fapiMacRxDataInd(Pst *pst, RxDataInd *rxDataInd)
  *
  * @details
  *
- *    Function : MacRlcProcDlData 
+ *    Function : MacProcRlcDlData 
  *
  *    Functionality:
  *      Processes DL data from RLC
@@ -220,18 +208,125 @@ uint16_t fapiMacRxDataInd(Pst *pst, RxDataInd *rxDataInd)
  *         RFAILED - failure
  *
  * ****************************************************************/
-uint16_t MacRlcProcDlData(Pst* pst, SpId spId, RlcMacData *dlData)
+uint8_t MacProcRlcDlData(Pst* pstInfo, RlcData *dlData)
+{
+   uint8_t   pduIdx =0;
+   uint8_t   *txPdu =NULLP;
+   uint16_t  tbSize =0;
+   MacDlData macDlData;
+   MacDlSlot *currDlSlot = NULLP;
+  
+   memset(&macDlData , 0, sizeof(MacDlData));
+   DU_LOG("\nMAC: Received DL data for sfn=%d slot=%d", \
+      dlData->slotInfo.sfn, dlData->slotInfo.slot);
+   /* Copy the pdus to be muxed into mac Dl data */
+   macDlData.numPdu = dlData->numPdu;
+   for(pduIdx = 0;  pduIdx < dlData->numPdu; pduIdx++)
+   {
+      macDlData.pduInfo[pduIdx].lcId = dlData->pduInfo[pduIdx].lcId;
+      macDlData.pduInfo[pduIdx].pduLen = dlData->pduInfo[pduIdx].pduLen;
+      macDlData.pduInfo[pduIdx].dlPdu = dlData->pduInfo[pduIdx].pduBuf;
+   }
+
+   /* Store DL data in the scheduled slot */
+   currDlSlot = &macCb.macCell[dlData->cellId -1]->dlSlot[dlData->slotInfo.slot];
+   if(currDlSlot)
+   {
+      if(currDlSlot->dlInfo.dlMsgAlloc)
+      {
+        tbSize = currDlSlot->dlInfo.dlMsgAlloc->dlMsgPdschCfg.codeword[0].tbSize;
+        MAC_ALLOC(txPdu, tbSize);
+        if(!txPdu)
+        {
+           DU_LOG("\nMAC : Memory allocation failed in MacProcRlcDlData");
+           return RFAILED;
+        }
+        macMuxPdu(&macDlData, NULLP, txPdu, tbSize);
+
+        currDlSlot->dlInfo.dlMsgAlloc->dlMsgInfo.dlMsgPduLen = tbSize;
+        currDlSlot->dlInfo.dlMsgAlloc->dlMsgInfo.dlMsgPdu = txPdu;
+      }
+   }
+
+   /* Free memory */
+   for(pduIdx = 0; pduIdx < dlData->numPdu; pduIdx++)
+   {
+      MAC_FREE_SHRABL_BUF(pstInfo->region, pstInfo->pool, dlData->pduInfo[pduIdx].pduBuf,\
+         dlData->pduInfo[pduIdx].pduLen);
+   }
+   if(pstInfo->selector == ODU_SELECTOR_LWLC)
+   {
+      MAC_FREE_SHRABL_BUF(pstInfo->region, pstInfo->pool, dlData, sizeof(RlcData));
+   }
+
+   return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Builds and Sends UL Data to RLC
+ *
+ * @details
+ *
+ *    Function : macProcUlData
+ *
+ *    Functionality: Builds and Sends UL Data to RLC
+ *
+ * @params[in] CellId
+ *             CRNTI
+ *             Slot information
+ *             LC Id on which payload was received
+ *             Pointer to the payload
+ *             Length of payload
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t macProcUlData(uint16_t cellId, uint16_t rnti, SlotIndInfo slotInfo, \
+uint8_t lcId, uint16_t pduLen, uint8_t *pdu)
 {
+   Pst         pst;
+   RlcData     *ulData;
+
+   /* Filling RLC Ul Data*/
+   MAC_ALLOC_SHRABL_BUF(ulData, sizeof(RlcData));
+   if(!ulData)
+   {
+      DU_LOG("\nMAC : Memory allocation failed while sending UL data to RLC");
+      return RFAILED;
+   }
+   memset(ulData, 0, sizeof(RlcData));
+   ulData->cellId = cellId; 
+   ulData->rnti = rnti;
+   memcpy(&ulData->slotInfo, &slotInfo, sizeof(SlotIndInfo));
+   ulData->slotInfo.cellId = cellId;
+
+   /* Filling pdu info */
+   if(lcId == SRB1_LCID || lcId == SRB2_LCID)
+   {
+      ulData->pduInfo[ulData->numPdu].commCh = true;
+   }
+   ulData->pduInfo[ulData->numPdu].lcId = lcId;
+   ulData->pduInfo[ulData->numPdu].pduBuf = pdu;
+   ulData->pduInfo[ulData->numPdu].pduLen = pduLen;
+   ulData->numPdu++;
+
+   /* Filling Post and send to RLC */
+   memset(&pst, 0, sizeof(Pst));
+   FILL_PST_MAC_TO_RLC(pst, 0, EVENT_UL_DATA_TO_RLC);
+   MacSendUlDataToRlc(&pst, ulData);
+
    return ROK;
 }
 
+
 /*******************************************************************
  *
  * @brief Processes BO status from RLC
  *
  * @details
  *
- *    Function : MacRlcProcBOStatus
+ *    Function : MacProcRlcBOStatus
  *
  *    Functionality:
  *      Processes BO status from RLC
@@ -242,11 +337,78 @@ uint16_t MacRlcProcDlData(Pst* pst, SpId spId, RlcMacData *dlData)
  *         RFAILED - failure
  *
  * ****************************************************************/
-uint16_t MacRlcProcBOStatus(Pst* pst, SpId spId, RlcMacBOStatus*      boStatus)
+uint8_t MacProcRlcBoStatus(Pst* pst, RlcBoStatus* boStatus)
 {
+   DlRlcBoInfo  dlBoInfo;
+
+   dlBoInfo.cellId = boStatus->cellId;
+   GET_CRNTI(dlBoInfo.crnti, boStatus->ueIdx);
+   dlBoInfo.lcId = boStatus->lcId;
+   dlBoInfo.dataVolume = boStatus->bo;
+
+   sendDlRlcBoInfoToSch(&dlBoInfo); 
+
+   if(pst->selector == ODU_SELECTOR_LWLC)
+   {
+      MAC_FREE_SHRABL_BUF(pst->region, pst->pool, boStatus, sizeof(RlcBoStatus));
+   }
+
    return ROK;
 }
 
+/*******************************************************************
+ *
+ * @brief Send LC schedule result report to RLC
+ *
+ * @details
+ *
+ *    Function : sendSchRptToRlc 
+ *
+ *    Functionality: Send LC schedule result report to RLC
+ *
+ * @params[in] 
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t sendSchedRptToRlc(DlSchedInfo dlInfo, SlotIndInfo slotInfo)
+{
+   Pst      pst;
+   uint8_t  lcIdx;
+   RlcSchedResultRpt  *schedRpt = NULLP;
+   
+   MAC_ALLOC_SHRABL_BUF(schedRpt, sizeof(RlcSchedResultRpt));
+   if(!schedRpt)
+   {
+      DU_LOG("\nMAC: Memory allocation failure in sendSchResultRepToRlc");
+      return RFAILED;
+   }
+
+   DU_LOG("\nMAC: Send scheduled result report for sfn %d slot %d", slotInfo.sfn, slotInfo.slot);
+   schedRpt->cellId = dlInfo.cellId;
+   schedRpt->rnti = dlInfo.dlMsgAlloc->crnti;
+   schedRpt->numLc = dlInfo.dlMsgAlloc->numLc;
+   schedRpt->slotInfo.sfn = slotInfo.sfn;
+   schedRpt->slotInfo.slot = slotInfo.slot;
+
+   for(lcIdx = 0; lcIdx < schedRpt->numLc; lcIdx++)
+   {
+      schedRpt->lcSch[lcIdx].lcId = dlInfo.dlMsgAlloc->lcSchInfo[lcIdx].lcId;
+      schedRpt->lcSch[lcIdx].bufSize = dlInfo.dlMsgAlloc->lcSchInfo[lcIdx].schBytes;
+      schedRpt->lcSch[lcIdx].commCh = false;
+   }
+
+   /* Fill Pst */
+   FILL_PST_MAC_TO_RLC(pst, RLC_DL_INST, EVENT_SCHED_RESULT_TO_RLC);
+   if(MacSendSchedResultRptToRlc(&pst, schedRpt) != ROK)
+   {
+      DU_LOG("\nMAC: Failed to send Schedule result report to RLC");
+      MAC_FREE_SHRABL_BUF(MAC_MEM_REGION, MAC_POOL, schedRpt, sizeof(RlcSchedResultRpt));
+      return RFAILED;
+   }
+
+   return ROK;
+}
 
 /*******************************************************************
  *
@@ -254,55 +416,63 @@ uint16_t MacRlcProcBOStatus(Pst* pst, SpId spId, RlcMacBOStatus*      boStatus)
  *
  * @details
  *
- *    Function : MacHdlCellStartReq
+ *    Function : MacProcCellStart
  *
  *    Functionality:
  *      Handles cell start reuqest from DU APP
  *
  * @params[in] Post structure pointer
- *             Cell Start Request info pointer 
+ *             Cell Id 
  * @return ROK     - success
  *         RFAILED - failure
  *
  * ****************************************************************/
-uint16_t MacHdlCellStartReq(Pst *pst, MacCellStartInfo  *cellStartInfo)
+uint8_t MacProcCellStart(Pst *pst, OduCellId  *cellId)
 {
    DU_LOG("\nMAC : Handling cell start request");
-   sendToLowerMac(START_REQUEST, 0, cellStartInfo);
+   gSlotCount = 0;
+   sendToLowerMac(START_REQUEST, 0, cellId);
 
-   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, cellStartInfo, \
-          sizeof(MacCellStartInfo));
+   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, cellId, \
+        sizeof(OduCellId));
 
    return ROK;
 }
 
 /*******************************************************************
  *
- * @brief Handles cell stop request from DU APP
+ * @brief Handles cell stop from DU APP
  *
  * @details
  *
- *    Function : MacHdlCellStartReq
+ *    Function : MacProcCellStop
  *
  *    Functionality:
- *        Handles cell stop request from DU APP
+ *        Handles cell stop from DU APP
  *
  * @params[in] Post structure pointer
- *             Mac Cell stop information
+ *             Cell Id
  * @return ROK     - success
  *         RFAILED - failure
  *
  * ****************************************************************/
-uint16_t MacHdlCellStopReq(Pst *pst, MacCellStopInfo  *cellStopInfo)
+uint8_t MacProcCellStop(Pst *pst, OduCellId  *cellId)
 {
-   #ifdef FAPI
+#ifdef INTEL_FAPI
+   uint16_t      cellIdx; 
+   SlotIndInfo   slotInfo;
+
    DU_LOG("\nMAC : Sending cell stop request to Lower Mac");
-   sendToLowerMac(FAPI_STOP_REQUEST, 0, cellStopInfo);
-   #endif
+   GET_CELL_IDX(cellId->cellId, cellIdx);
+   slotInfo.cellId = cellId->cellId;
+   slotInfo.sfn = macCb.macCell[cellIdx]->currTime.sfn;
+   slotInfo.slot = macCb.macCell[cellIdx]->currTime.slot;
+   sendToLowerMac(FAPI_STOP_REQUEST, 0, &slotInfo);
+#endif
+
+   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, cellId, \
+        sizeof(OduCellId));
 
-   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, cellStopInfo, \
-          sizeof(MacCellStopInfo));
    return ROK;
 }
 
@@ -312,7 +482,7 @@ uint16_t MacHdlCellStopReq(Pst *pst, MacCellStopInfo  *cellStopInfo)
  *
  * @details
  *
- *    Function : MacHdlDlCcchInd 
+ *    Function : MacProcDlCcchInd 
  *
  *    Functionality:
  *      Handles DL CCCH Ind from DU APP
@@ -323,46 +493,48 @@ uint16_t MacHdlCellStopReq(Pst *pst, MacCellStopInfo  *cellStopInfo)
  *         RFAILED - failure
  *
  * ****************************************************************/
-uint16_t MacHdlDlCcchInd(Pst *pst, DlCcchIndInfo *dlCcchIndInfo)
+uint8_t MacProcDlCcchInd(Pst *pst, DlCcchIndInfo *dlCcchIndInfo)
 {
-   uint16_t idx;
-   DlRlcBOInfo  dlBoInfo;
-       memset(&dlBoInfo, 0, sizeof(DlRlcBOInfo));
+   uint8_t      ueIdx = 0;
+   uint16_t     cellIdx;
+   uint16_t     idx;
+   DlRlcBoInfo  dlBoInfo;
+   memset(&dlBoInfo, 0, sizeof(DlRlcBoInfo));
 
    DU_LOG("\nMAC : Handling DL CCCH IND");
-   
-   /* TODO : Fill DL RLC Buffer status info */
+
+   GET_CELL_IDX(dlCcchIndInfo->cellId, cellIdx);
+
    dlBoInfo.cellId = dlCcchIndInfo->cellId;
    dlBoInfo.crnti = dlCcchIndInfo->crnti;
-   dlBoInfo.numLc = 0;
-   
+
    if(dlCcchIndInfo->msgType == RRC_SETUP)
    {
-      dlBoInfo.boInfo[dlBoInfo.numLc].lcId = SRB_ID_0;    // SRB ID 0 for msg4
-      dlBoInfo.boInfo[SRB_ID_0].dataVolume = \
-        dlCcchIndInfo->dlCcchMsgLen;
-      dlBoInfo.numLc++;
+      dlBoInfo.lcId = SRB0_LCID;    // SRB ID 0 for msg4
+      dlBoInfo.dataVolume = dlCcchIndInfo->dlCcchMsgLen;
 
       /* storing Msg4 Pdu in raCb */
-      if(macCb.macCell->macRaCb[0].crnti == dlCcchIndInfo->crnti)
+      GET_UE_IDX(dlBoInfo.crnti, ueIdx);
+      ueIdx = ueIdx -1;
+      if(macCb.macCell[cellIdx]->macRaCb[ueIdx].crnti == dlCcchIndInfo->crnti)
       {
-         macCb.macCell->macRaCb[0].msg4PduLen = dlCcchIndInfo->dlCcchMsgLen;
-         MAC_ALLOC(macCb.macCell->macRaCb[0].msg4Pdu, macCb.macCell->macRaCb[0]\
-         .msg4PduLen);
-         if(macCb.macCell->macRaCb[0].msg4Pdu)
-         {
-                          for(idx = 0; idx < dlCcchIndInfo->dlCcchMsgLen; idx++)
-                               {
-               macCb.macCell->macRaCb[0].msg4Pdu[idx] =\
-                                         dlCcchIndInfo->dlCcchMsg[idx];
-                          }
-         }
+        macCb.macCell[cellIdx]->macRaCb[ueIdx].msg4PduLen = dlCcchIndInfo->dlCcchMsgLen;
+        MAC_ALLOC(macCb.macCell[cellIdx]->macRaCb[ueIdx].msg4Pdu, \
+           macCb.macCell[cellIdx]->macRaCb[ueIdx].msg4PduLen);
+        if(macCb.macCell[cellIdx]->macRaCb[ueIdx].msg4Pdu)
+        {
+           for(idx = 0; idx < dlCcchIndInfo->dlCcchMsgLen; idx++)
+           {
+              macCb.macCell[cellIdx]->macRaCb[ueIdx].msg4Pdu[idx] =\
+                 dlCcchIndInfo->dlCcchMsg[idx];
+           }
+        }
       }
    }
-   sendDlRlcBoInfoMacToSch(&dlBoInfo);
-   
+   sendDlRlcBoInfoToSch(&dlBoInfo);
+
    MAC_FREE_SHRABL_BUF(pst->region, pst->pool, dlCcchIndInfo->dlCcchMsg, \
-      dlCcchIndInfo->dlCcchMsgLen);
+        dlCcchIndInfo->dlCcchMsgLen);
    MAC_FREE_SHRABL_BUF(pst->region, pst->pool, dlCcchIndInfo, sizeof(DlCcchIndInfo));
    return ROK;
 
@@ -374,7 +546,7 @@ uint16_t MacHdlDlCcchInd(Pst *pst, DlCcchIndInfo *dlCcchIndInfo)
  *
  * @details
  *
- *    Function : macSendUlCcchInd
+ *    Function : macProcUlCcchInd
  *
  *    Functionality:
  *        MAC sends UL CCCH Ind to DU APP
@@ -385,50 +557,176 @@ uint16_t MacHdlDlCcchInd(Pst *pst, DlCcchIndInfo *dlCcchIndInfo)
  *         RFAILED - failure
  *
  * ****************************************************************/
-uint16_t macSendUlCcchInd(uint8_t *rrcContainer, uint16_t cellId, uint16_t crnti)
+uint8_t macProcUlCcchInd(uint16_t cellId, uint16_t crnti, uint16_t rrcContSize, uint8_t *rrcContainer)
 {
    Pst pst;
-       uint8_t ret = ROK;
+   uint8_t ret = ROK;
    UlCcchIndInfo *ulCcchIndInfo = NULLP;
 
    MAC_ALLOC_SHRABL_BUF(ulCcchIndInfo, sizeof(UlCcchIndInfo));
    if(!ulCcchIndInfo)
    {
-               DU_LOG("\nMAC: Memory failed in macSendUlCcchInd");
-               return RFAILED;
-       }
-
-       ulCcchIndInfo->cellId = cellId;
-       ulCcchIndInfo->crnti  = crnti;
-       ulCcchIndInfo->ulCcchMsg = rrcContainer;
-
-       /* Fill Pst */
-       pst.selector  = DU_MAC_LWLC;
-       pst.srcEnt    = ENTRG;
-       pst.dstEnt    = ENTDUAPP;
-       pst.dstInst   = 0;
-       pst.srcInst   = macCb.macInst;
-       pst.dstProcId = rgCb[pst.srcInst].rgInit.procId;
-       pst.srcProcId = rgCb[pst.srcInst].rgInit.procId;
-       pst.region    = MAC_MEM_REGION;
-       pst.pool      = MAC_POOL;
-       pst.event     = EVENT_MAC_UL_CCCH_IND;
-       pst.route     = 0;
-       pst.prior     = 0;
-       pst.intfVer   = 0;
-
-       if(MacDuAppUlCcchInd(&pst, ulCcchIndInfo) != ROK)
-       {
-               DU_LOG("\nMAC: Failed to send UL CCCH Ind to DU APP");
-               MAC_FREE_SHRABL_BUF(MAC_MEM_REGION, MAC_POOL, ulCcchIndInfo->ulCcchMsg,
-                               strlen((const char*)ulCcchIndInfo->ulCcchMsg));
-               MAC_FREE_SHRABL_BUF(MAC_MEM_REGION, MAC_POOL, ulCcchIndInfo, sizeof(UlCcchIndInfo));
-               ret = RFAILED;
-       }
-       return ret;
+      DU_LOG("\nMAC: Memory failed in macProcUlCcchInd");
+      return RFAILED;
+   }
+
+   ulCcchIndInfo->cellId = cellId;
+   ulCcchIndInfo->crnti  = crnti;
+   ulCcchIndInfo->ulCcchMsgLen = rrcContSize;
+   ulCcchIndInfo->ulCcchMsg = rrcContainer;
+
+   /* Fill Pst */
+   FILL_PST_MAC_TO_DUAPP(pst, EVENT_MAC_UL_CCCH_IND);
+
+   if(MacDuAppUlCcchInd(&pst, ulCcchIndInfo) != ROK)
+   {
+      DU_LOG("\nMAC: Failed to send UL CCCH Ind to DU APP");
+      MAC_FREE_SHRABL_BUF(MAC_MEM_REGION, MAC_POOL, ulCcchIndInfo->ulCcchMsg, ulCcchIndInfo->ulCcchMsgLen);
+      MAC_FREE_SHRABL_BUF(MAC_MEM_REGION, MAC_POOL, ulCcchIndInfo, sizeof(UlCcchIndInfo));
+      ret = RFAILED;
+   }
+   return ret;
 }
 
+/*******************************************************************
+ *
+ * @brief Processes received short BSR
+ *
+ * @details
+ *
+ *    Function : macProcShortBsr
+ *
+ *    Functionality:
+ *        MAC sends Short BSR to SCH
+ *
+ * @params[in] cell ID
+ *             crnti
+ *             lcg ID
+ *             buffer size
+ *
+ *
+ * ****************************************************************/
+uint8_t macProcShortBsr(uint16_t cellId, uint16_t crnti, uint8_t lcgId, uint32_t bufferSize)
+{
+   Pst                  pst;
+   UlBufferStatusRptInd bsrInd;
+
+   memset(&pst, 0, sizeof(Pst));
+   memset(&bsrInd, 0, sizeof(UlBufferStatusRptInd));
+
+   bsrInd.cellId                 = cellId;
+   bsrInd.crnti                  = crnti;
+   bsrInd.bsrType                = SHORT_BSR;
+   bsrInd.numLcg                 = 1; /* short bsr reports one lcg at a time */
+   bsrInd.dataVolInfo[0].lcgId   = lcgId;
+   bsrInd.dataVolInfo[0].dataVol = bufferSize;
+
+   FILL_PST_MAC_TO_SCH(pst, EVENT_SHORT_BSR);
+   return(*macSchBsrOpts[pst.selector])(&pst, &bsrInd);
+}
+
+/*******************************************************************
+ *
+ * @brief Builds and send SR UCI Indication to SCH
+ *
+ * @details
+ *
+ *    Function : buildAndSendSrInd
+ *
+ *    Functionality:
+ *       Builds and send SR UCI Indication to SCH
+ *
+ * @params[in] SrUciIndInfo Pointer
+ *             crnti value
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t buildAndSendSrInd(UciInd *macUciInd, uint8_t crnti)
+{
+   uint16_t cellIdx;
+   Pst pst;
+   SrUciIndInfo   srUciInd;
+   memset(&pst, 0, sizeof(Pst));
+   memset(&srUciInd, 0, sizeof(SrUciIndInfo));
+
+   GET_CELL_IDX(macUciInd->cellId, cellIdx);
+   srUciInd.cellId       = macCb.macCell[cellIdx]->cellId;
+   srUciInd.crnti        = crnti;
+   srUciInd.slotInd.sfn  = macUciInd->slotInd.sfn;
+   srUciInd.slotInd.slot = macUciInd->slotInd.slot;
+   srUciInd.numSrBits++;
+   memset(srUciInd.srPayload, 0, MAX_SR_BITS_IN_BYTES);
+
+   /* Fill Pst */
+   FILL_PST_MAC_TO_SCH(pst, EVENT_UCI_IND_TO_SCH);
+
+   return(*macSchSrUciIndOpts[pst.selector])(&pst, &srUciInd);
+}
+
+/*******************************************************************
+ *
+ * @brief Processes UCI Indication from PHY
+ *
+ * @details
+ *
+ *    Function : fapiMacUciInd
+ *
+ *    Functionality:
+ *       Processes UCI Indication from PHY
+ *
+ * @params[in] Post Structure Pointer
+ *             UCI Indication Pointer
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t FapiMacUciInd(Pst *pst, UciInd *macUciInd)
+{
+   uint8_t     pduIdx = 0;
+   uint8_t     ret = ROK;
+   uint16_t    nPdus;
+   uint16_t    crnti;
+
+   if(macUciInd)
+   {
+      nPdus = macUciInd->numUcis;
+      while(nPdus)
+      {
+         switch(macUciInd->pdus[pduIdx].pduType)
+         {
+            case UCI_IND_PUSCH:
+               break;
+            case UCI_IND_PUCCH_F0F1:
+               if(macUciInd->pdus[pduIdx].uci.uciPucchF0F1.srInfo.srIndPres)
+               {
+                  DU_LOG("\nMAC : Received SR UCI indication");
+                 crnti = macUciInd->pdus[pduIdx].uci.uciPucchF0F1.crnti; 
+                 ret = buildAndSendSrInd(macUciInd, crnti);
+               }
+               break;
+            case UCI_IND_PUCCH_F2F3F4:
+               break;
+            default:
+               DU_LOG("\nMAC: Invalid Pdu Type %d at FapiMacUciInd", macUciInd->pdus[pduIdx].pduType);
+               ret = RFAILED;
+               break;
+         }
+         pduIdx++;
+         nPdus--;
+      }
+   }
+   else
+   {
+      DU_LOG("\nMAC: Received Uci Ind is NULL at FapiMacUciInd()");
+      ret = RFAILED;
+   }
+   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, macUciInd, sizeof(UciInd));
+   return ret;
+}
+
+
 /**********************************************************************
-         End of file
-**********************************************************************/
+  End of file
+ **********************************************************************/