PUSCH PDU for msg3 and UL-CCCH Ind flow completion

[o-du/l2.git] / src / 5gnrmac / mac_msg_hdl.c

diff --git a/src/5gnrmac/mac_msg_hdl.c b/src/5gnrmac/mac_msg_hdl.c
index 9458930..5f75dc7 100644 (file)
--- a/src/5gnrmac/mac_msg_hdl.c
+++ b/src/5gnrmac/mac_msg_hdl.c
@@ -55,13 +55,17 @@
 #include "crg.x"
 #include "rg_prg.x"
 #include "du_app_mac_inf.h"
+#include "mac_upr_inf_api.h"
 #include "rg.x"
 #include "lwr_mac_fsm.h"
 #include "mac.h"
 
 /* This file contains message handling functionality for MAC */
 
+extern MacCb  macCb;
+
 extern void sendToLowerMac(uint16_t msgType, uint32_t msgLen, void *msg);
+uint16_t buildMacPdu(RlcMacData *dlData);
 
 /* Function pointer for sending crc ind from MAC to SCH */
 MacSchCrcIndFunc macSchCrcIndOpts[]=
@@ -71,6 +75,40 @@ MacSchCrcIndFunc macSchCrcIndOpts[]=
    packMacSchCrcInd
 };
 
+/* Function pointer for sending DL RLC BO Info from MAC to SCH */
+MacSchDlRlcBoInfoFunc macSchDlRlcBoInfoOpts[]=
+{
+   packMacSchDlRlcBoInfo,
+   macSchDlRlcBoInfo,
+   packMacSchDlRlcBoInfo
+};
+
+/*******************************************************************
+ *
+ * @brief Sends DL BO Info to SCH
+ *
+ * @details
+ *
+ *    Function : sendDlRlcBoInfoMacToSch
+ *
+ *    Functionality:
+ *       Sends DL BO Info to SCH
+ *
+ * @params[in] 
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ ****************************************************************/
+int sendDlRlcBoInfoMacToSch(DlRlcBOInfo *dlBoInfo)
+{
+   Pst pst;
+ 
+   fillMacToSchPst(&pst);
+   pst.event = EVENT_DL_RLC_BO_INFO_TO_SCH;
+ 
+   return(*macSchDlRlcBoInfoOpts[pst.selector])(&pst, dlBoInfo);
+}
+
 /*******************************************************************
  *
  * @brief Sends CRC Indication to SCH
@@ -153,9 +191,13 @@ uint16_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 */
+
    for(pduIdx = 0; pduIdx < rxDataInd->numPdus; pduIdx++)
    {
-      unpackRxData(rxDataInd->timingInfo, &rxDataInd->pdus[pduIdx]);
+      unpackRxData(&rxDataInd->pdus[pduIdx]);
    }
    return ROK;
 }
@@ -263,6 +305,124 @@ uint16_t MacHdlCellStopReq(Pst *pst, MacCellStopInfo  *cellStopInfo)
    return ROK;
 }
 
+/*******************************************************************
+ *
+ * @brief Handles DL CCCH Ind from DU APP
+ *
+ * @details
+ *
+ *    Function : MacHdlDlCcchInd 
+ *
+ *    Functionality:
+ *      Handles DL CCCH Ind from DU APP
+ *
+ * @params[in] Post structure pointer
+ *             DL CCCH Ind pointer 
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint16_t MacHdlDlCcchInd(Pst *pst, DlCcchIndInfo *dlCcchIndInfo)
+{
+   DlRlcBOInfo  dlBoInfo;
+
+   DU_LOG("\nMAC : Handling DL CCCH IND");
+   
+   /* TODO : Fill DL RLC Buffer status info */
+   dlBoInfo.cellId = dlCcchIndInfo->cellId;
+   dlBoInfo.crnti = dlCcchIndInfo->crnti;
+   dlBoInfo.numLc = 0;
+   
+   if(dlCcchIndInfo->msgType == RRC_SETUP)
+   {
+      dlBoInfo.numLc++;
+      dlBoInfo.boInfo[dlBoInfo.numLc].lcId = 0;    // SRB 0 for msg4
+      dlBoInfo.boInfo[dlBoInfo.numLc].dataVolume = \
+      strlen((const char*)dlCcchIndInfo->dlCcchMsg);
+
+      /* storing Msg4 Pdu in raCb */
+      if(macCb.macCell->macRaCb[0].crnti == dlCcchIndInfo->crnti)
+      {
+         macCb.macCell->macRaCb[0].msg4PduLen = strlen((const char*)dlCcchIndInfo\
+         ->dlCcchMsg);
+         MAC_ALLOC(macCb.macCell->macRaCb[0].msg4Pdu, macCb.macCell->macRaCb[0]\
+         .msg4PduLen);
+         if(macCb.macCell->macRaCb[0].msg4Pdu)
+         {
+            memcpy(macCb.macCell->macRaCb[0].msg4Pdu, dlCcchIndInfo->dlCcchMsg,\
+            macCb.macCell->macRaCb[0].msg4PduLen);
+         }
+      }
+   }
+   sendDlRlcBoInfoMacToSch(&dlBoInfo);
+   
+   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, dlCcchIndInfo->dlCcchMsg, \
+      strlen((const char*)dlCcchIndInfo->dlCcchMsg));
+   MAC_FREE_SHRABL_BUF(pst->region, pst->pool, dlCcchIndInfo, sizeof(DlCcchIndInfo));
+   return ROK;
+
+}
+
+/*******************************************************************
+ *
+ * @brief Sends UL CCCH Ind to DU APP
+ *
+ * @details
+ *
+ *    Function : macSendUlCcchInd
+ *
+ *    Functionality:
+ *        MAC sends UL CCCH Ind to DU APP
+ *
+ * @params[in] Post structure pointer
+ *            
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint16_t macSendUlCcchInd(uint8_t *rrcContainer, uint16_t cellId, uint16_t crnti)
+{
+   Pst pst;
+       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;
+}
+
 /**********************************************************************
          End of file
 **********************************************************************/