X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrmac%2Fmac_slot_ind.c;h=7949523879bba8bede58962e8c35435369ce390e;hb=51bd2af5867794ba058365581a7ad3c2eba0d1c3;hp=e502fbb43ba6975203651d384db3d707992cc5f5;hpb=18376996c17ece8306c1fe9539a00010bea607d5;p=o-du%2Fl2.git

diff --git a/src/5gnrmac/mac_slot_ind.c b/src/5gnrmac/mac_slot_ind.c
index e502fbb43..794952387 100644
--- a/src/5gnrmac/mac_slot_ind.c
+++ b/src/5gnrmac/mac_slot_ind.c
@@ -16,6 +16,7 @@
 ################################################################################
  *******************************************************************************/
 /* header include files (.h) */
+#include "stdbool.h"
 #include "envopt.h"        /* environment options */
 #include "envdep.h"        /* environment dependent */
 #include "envind.h"        /* environment independent */
@@ -26,8 +27,14 @@
 #include "cm_hash.h"       /* Common Hash List Defines */
 #include "cm_mblk.h"       /* common memory link list library */
 #include "cm_lte.h"        /* Common LTE Defines */
+#include "rgu.h"
 #include "tfu.h"           /* RGU Interface includes */
 #include "lrg.h"
+#include "crg.h"           /* layer management defines for LTE-MAC */
+#include "rg_sch_inf.h"           /* layer management defines for LTE-MAC */
+#include "rg_env.h"   
+#include "rg.h"
+
 #include "gen.x"           /* general */
 #include "ssi.x"           /* system services */
 #include "cm5.x"           /* system services */
@@ -37,11 +44,25 @@
 #include "cm_hash.x"       /* Common Hash List Definitions */
 #include "cm_mblk.x"       /* common memory link list library */
 #include "cm_lte.x"        /* Common LTE Defines */
+#include "rgu.x"
 #include "tfu.x"           /* RGU Interface includes */
 #include "lrg.x"
+#include "crg.x"           /* layer management typedefs for MAC */
+#include "rg_sch_inf.x"    /* SCH interface typedefs */
+#include "rg_prg.x"
 #include "du_app_mac_inf.h"
 #include "mac.h"
 #include "du_log.h"
+#include "rg.x"
+#include "mac_upr_inf_api.h"
+
+/* function pointers for packing slot ind from mac to sch */
+MacSchSlotIndFunc macSchSlotIndOpts[] =
+{
+   packMacSchSlotInd,
+   macSchSlotInd,
+   packMacSchSlotInd
+};
 
 /**
  * @brief process DL allocation from scheduler
@@ -58,17 +79,170 @@
  *      -# ROK 
  *      -# RFAILED 
  **/
-int MacProcDlAlloc(Pst *pst, DlAlloc *dlAlloc)
+int MacProcDlAlloc(Pst *pst, DlSchedInfo *dlSchedInfo)
 {
-   if(dlAlloc != NULLP)
+   MacDlSlot *currDlSlot = NULLP;
+
+   if(dlSchedInfo != NULLP)
    {
-		MacDlSlot *currDlSlot =
-		&macCb.macCell->dlSlot[dlAlloc->slotIndInfo.slot % MAX_SLOT_SUPPORTED];
-      memcpy(&currDlSlot->dlInfo, dlAlloc, sizeof(DlAlloc)); 
+		if(dlSchedInfo->isBroadcastPres)
+		{
+		   currDlSlot = &macCb.macCell->dlSlot[dlSchedInfo->schSlotValue.broadcastTime.slot];
+		   currDlSlot->dlInfo.isBroadcastPres = true;
+			memcpy(&currDlSlot->dlInfo.brdcstAlloc, &dlSchedInfo->brdcstAlloc, sizeof(DlBrdcstAlloc));
+		}
+
+		if(dlSchedInfo->rarAlloc != NULLP)
+		{
+		   currDlSlot = &macCb.macCell->dlSlot[dlSchedInfo->schSlotValue.rarTime.slot];
+			currDlSlot->dlInfo.rarAlloc = dlSchedInfo->rarAlloc;
+
+         /* MUXing of RAR */
+			fillRarPdu(&currDlSlot->dlInfo.rarAlloc->rarInfo);
+		}
+
+		if(dlSchedInfo->msg4Alloc != NULLP)
+      {
+         Msg4Alloc *msg4Alloc = NULLP;
+         MacDlData msg4DlData;
+         MacCeInfo  macCeData;
+
+		   currDlSlot = &macCb.macCell->dlSlot[dlSchedInfo->schSlotValue.msg4Time.slot];
+			currDlSlot->dlInfo.msg4Alloc = dlSchedInfo->msg4Alloc; /* copy msg4 alloc pointer in MAC slot info */
+			msg4Alloc = dlSchedInfo->msg4Alloc;
+
+         memset(&msg4DlData, 0, sizeof(MacDlData));
+         memset(&macCeData, 0, sizeof(MacCeInfo));
+
+         macCb.macCell->macRaCb[0].msg4TbSize = msg4Alloc->msg4PdschCfg.codeword[0].tbSize;
+ 
+         if(macCb.macCell->macRaCb[0].msg4Pdu != NULLP)
+         {
+            MAC_ALLOC(msg4DlData.pduInfo[0].dlPdu, \
+              macCb.macCell->macRaCb[0].msg4PduLen);
+            if(msg4DlData.pduInfo[0].dlPdu != NULLP)
+            {
+               fillMsg4DlData(&msg4DlData);
+            }
+         }
+
+         /* MUXing for msg4 */
+         fillMacCe(&macCeData);
+         macMuxPdu(&msg4DlData, &macCeData, macCb.macCell->macRaCb[0].msg4TbSize);
+      
+         /* storing msg4 Pdu in macDlSlot */
+			if(macCb.macCell->macRaCb[0].msg4TxPdu)
+			{
+            msg4Alloc->msg4Info.msg4PduLen = macCb.macCell->macRaCb[0].msg4TbSize;
+            MAC_ALLOC(msg4Alloc->msg4Info.msg4Pdu, msg4Alloc->msg4Info.msg4PduLen);
+            if(msg4Alloc->msg4Info.msg4Pdu != NULLP)
+            {
+				   memcpy(msg4Alloc->msg4Info.msg4Pdu, macCb.macCell->macRaCb[0].msg4TxPdu, \
+				        msg4Alloc->msg4Info.msg4PduLen);
+            }
+			}
+			else
+			{
+            DU_LOG("\nMAC: Failed at macMuxPdu()");
+				return RFAILED;
+			}
+         /* TODO: Free all allocated memory, after the usage */
+         /* MAC_FREE(macCb.macCell->macRaCb[0].msg4TxPdu, \
+              macCb.macCell->macRaCb[0].msg4TbSize); // TODO: To be freed after re-transmission is successful.
+            MAC_FREE(dlSchedInfo->msg4Alloc->msg4Info.msg4Pdu,\
+              macCb.macCell->macRaCb[0].msg4PduLen); //TODO: To be freed after lower-mac is succesfull
+            MAC_FREE(msg4DlData.pduInfo[0].dlPdu, macCb.macCell->macRaCb[0].msg4PduLen);
+            MAC_FREE(macCb.macCell->macRaCb[0].msg4Pdu, macCb.macCell->macRaCb[0].msg4PduLen); */
+      }
    }
    return ROK;
 }
 
+/**
+ * @brief Transmission time interval indication from PHY.
+ *
+ * @details
+ *
+ *     Function : sendSlotIndMacToSch
+ * 
+ *      This API is invoked by MAC to send slot ind to scheduler.
+ *           
+ *  @param[in]  SlotIndInfo    *slotInd
+ *  @return  S16
+ *      -# ROK 
+ *      -# RFAILED 
+ **/
+int sendSlotIndMacToSch(SlotIndInfo *slotInd)
+{
+   /* fill Pst structure to send to lwr_mac to MAC */
+   Pst pst;
+
+   fillMacToSchPst(&pst);
+   pst.event = EVENT_SLOT_IND_TO_SCH;
+
+   return(*macSchSlotIndOpts[pst.selector])(&pst,slotInd);
+}
+
+/*******************************************************************
+ *
+ * @brief Send slot indication to DU APP
+ *
+ * @details
+ *
+ *    Function : sendSlotIndMacToDuApp
+ *
+ *    Functionality:
+ *       Send slot indication to DU APP
+ *
+ * @params[in] Slot indication info 
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+int sendSlotIndMacToDuApp(SlotIndInfo *slotInd)
+{
+   Pst pst;
+   uint16_t ret;
+   SlotInfo  *slotInfo;
+ 
+   /*  Allocate sharable memory */
+   MAC_ALLOC_SHRABL_BUF(slotInfo, sizeof(SlotInfo));
+   if(!slotInfo)
+   {
+      DU_LOG("\nMAC : Slot Indication memory allocation failed");
+      return RFAILED;
+  }
+ 
+  slotInfo->cellId = macCb.macCell->cellId;
+  slotInfo->sfn = slotInd->sfn;
+  slotInfo->slot = slotInd->slot;
+ 
+  /* 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_SLOT_IND;
+  pst.route = 0;
+  pst.prior = 0;
+  pst.intfVer = 0;
+ 
+  ret = MacDuAppSlotInd(&pst, slotInfo);
+  if(ret != ROK)
+  {
+     DU_LOG("\nMAC: Failed to send slot indication to DU APP");
+     MAC_FREE_SHRABL_BUF(MAC_MEM_REGION, MAC_POOL, slotInfo, sizeof(SlotInfo));
+  }
+ 
+  return ret;
+} /* sendSlotIndMacToDuApp */
+
+
 /**
  * @brief Transmission time interval indication from PHY.
  *