[Epic-ID: ODUHIGH-516][Task-ID: 526] Implementation of ric service update
[o-du/l2.git] / src / du_app / du_msg_hdl.c
index 5ab931b..6444943 100644 (file)
@@ -97,10 +97,18 @@ DuMacSliceCfgReq packMacSliceCfgReqOpts[] =
 
 DuMacSliceRecfgReq packMacSliceRecfgReqOpts[] =
 {
-   packDuMacSliceRecfgReq,       /* Loose coupling */
-   MacProcSliceRecfgReq,         /* TIght coupling */
-   packDuMacSliceRecfgReq        /* Light weight-loose coupling */
+   packDuMacSliceRecfgReq,     /* Loose coupling */
+   MacProcSliceRecfgReq,       /* TIght coupling */
+   packDuMacSliceRecfgReq      /* Light weight-loose coupling */
 };
+
+DuMacStatsReqFunc packMacStatsReqOpts[]=
+{
+   packDuMacStatsReq,          /* Loose Coupling */
+   MacProcStatsReq,            /* Tight Coupling */
+   packDuMacStatsReq           /* Light weight-loose coupling */
+};
+
 /**************************************************************************
  * @brief Function to fill configs required by RLC
  *
@@ -726,7 +734,7 @@ uint8_t duBuildMacGenCfg()
    /*----------- Fill General Configuration Parameters ---------*/
    genCfg->mem.region = MAC_MEM_REGION;
    genCfg->mem.pool   = MAC_POOL;
-   genCfg->tmrRes     = 10;
+   genCfg->tmrRes     = 1;
    genCfg->numRguSaps = 2;
 
    genCfg->lmPst.dstProcId = DU_PROC;
@@ -1299,7 +1307,7 @@ uint8_t duSendSchCfg()
    /* Filling of Gen config */
    cfg->genCfg.mem.region = MAC_MEM_REGION;
    cfg->genCfg.mem.pool = MAC_POOL;
-   cfg->genCfg.tmrRes = 10;
+   cfg->genCfg.tmrRes = 1;
 
 #ifdef LTE_ADV
    cfg->genCfg.forceCntrlSrbBoOnPCel = FALSE;
@@ -2068,6 +2076,246 @@ uint8_t DuProcRlcSliceMetrics(Pst *pst, SlicePmList *sliceStats)
    return ROK;
 }
 
+
+/*******************************************************************
+ *
+ * @brief Send Statistics request to MAC
+ *
+ * @details
+ *
+ *    Function : BuildAndSendStatsReqToMac()
+ *
+ *    Functionality: Send Statistics Request To Mac
+ *
+ * @params[in]
+ *             
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t BuildAndSendStatsReqToMac(MacStatsReq duMacStatsReq)
+{
+   Pst pst;
+   MacStatsReq *macStatsReq = NULLP;
+   
+   DU_LOG("\nINFO  --> DU_APP : Builds Statistics Request to send to MAC");
+
+   DU_ALLOC_SHRABL_BUF(macStatsReq, sizeof(MacStatsReq));
+   if(macStatsReq == NULLP)
+   {
+      DU_LOG("\nERROR  -->  DU_APP : Memory allocation failed for macStatsReq in BuildAndSendStatsReqToMac");
+      return RFAILED;
+   }
+   else
+   {
+      memcpy(macStatsReq, &duMacStatsReq, sizeof(MacStatsReq));
+
+      FILL_PST_DUAPP_TO_MAC(pst, EVENT_MAC_STATISTICS_REQ);
+
+      DU_LOG("\nDEBUG  -->  DU_APP: Sending Statistics Request to MAC ");
+      if( (*packMacStatsReqOpts[pst.selector])(&pst, macStatsReq) == RFAILED)
+      {
+         DU_LOG("\nERROR  -->  DU_APP: Failed to send Statistics Request to MAC");
+         DU_FREE_SHRABL_BUF(DU_APP_MEM_REGION, DU_POOL, macStatsReq, sizeof(MacStatsReq));
+         return RFAILED;
+      }
+   }
+   return ROK;  
+}
+
+/*******************************************************************
+ *
+ * @brief Fetch statistics details from Action Definition Format 1
+ *
+ * @details
+ *
+ *    Function : FetchStatsFromActionDefFormat1()
+ *
+ *    Functionality: Fetch statistics details from Action 
+ *       Definition Format 1 received in an E2 message from 
+ *       RIC.
+ *
+ * @params[in] ActionDefFormat1
+ *
+ * @return Statistics
+ *
+ * ****************************************************************/
+Statistics FetchStatsFromActionDefFormat1(ActionDefFormat1 format1)
+{
+   Statistics stats;
+
+   /* TODO : When E2AP subscription procedure is implemented:
+    * Measurement info list is traveresed 
+    * Based on KPI type, stats.macStatsReq or stats.rlcstatsReq is filled */
+
+   /* Hardcoding values for now for testing purpose 
+    * Will be removed in next gerrit */
+   stats.macStatsReq.subscriptionId = 1;
+   stats.macStatsReq.numStatsGroup = 1;
+   stats.macStatsReq.statsGrpList[0].groupId = 1;
+   stats.macStatsReq.statsGrpList[0].periodicity = 100;
+   stats.macStatsReq.statsGrpList[0].numStats = 2;
+   stats.macStatsReq.statsGrpList[0].statsList[0] = MAC_DL_TOTAL_PRB_USAGE;
+   stats.macStatsReq.statsGrpList[0].statsList[1] = MAC_UL_TOTAL_PRB_USAGE;
+
+   return stats;
+}
+
+/*******************************************************************
+ *
+ * @brief Send Statistics request to DU layers
+ *
+ * @details
+ *
+ *    Function : BuildAndSendStatsReq()
+ *
+ *    Functionality: Check if there is an update in statistics 
+ *       reporting configuration. If so, send the update to 
+ *       respective layer.
+ *
+ * @params[in]
+ *             
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t BuildAndSendStatsReq(ActionDefinition subscribedAction)
+{
+   Statistics stats;
+
+   switch(subscribedAction.styleType)
+   {
+      case 1:
+         stats = FetchStatsFromActionDefFormat1(subscribedAction.choice.format1);
+      case 2:
+      case 3:
+      case 4:
+      case 5:
+      default:
+         break;
+   }
+
+   if(BuildAndSendStatsReqToMac(stats.macStatsReq) != ROK)
+   {
+      DU_LOG("\nERROR  -->  DU_APP : Failed at BuildAndSendStatsReqToMac()");
+      return RFAILED;   
+   }
+
+/* TODO : When KPI collection from RLC will be supported, this function will be 
+ * called to configure KPIs to be colled */
+#if 0
+   if(BuildAndSendStatsReqToRlc(macStatsReq->rlcStatsReq) != ROK)
+   {
+       DU_LOG("\nERROR  -->  DU_APP : Failed at BuildAndSendStatsReqToRlc()");
+       return RFAILED;
+   }
+#endif
+
+   /* TODO : In the caller of this function, change ActionDefinition->action
+    * from CONFIG_ADD to CONFIG_UNKNOWN once configuration is sent 
+    * To be done in next gerrit*/
+    
+
+   return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Process statistics response from MAC
+ *
+ * @details
+ *
+ *    Function : DuProcMacStatsRsp
+ *
+ *    Functionality: Processes statistics configuration response
+ *       from MAC. If configuration is succsessful, DUAPP starts
+ *       reporting period timer for this subscription request 
+ *       from RIC
+ *
+ * @params[in]
+ *
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t DuProcMacStatsRsp(Pst *pst, MacStatsRsp *statsRsp)
+{
+   uint8_t idx = 0;
+
+   DU_LOG("\nINFO  -->  DU_APP : DuProcMacStatsRsp: Received Statistics Response from MAC");
+
+   if(statsRsp)
+   {
+#ifdef DEBUG_PRINT   
+      DU_LOG("\n  Subscription Id [%ld]", statsRsp->subscriptionId);
+
+      DU_LOG("\n  Number of Accepted Groups [%d]", statsRsp->numGrpAccepted);
+      for(idx=0; idx<statsRsp->numGrpAccepted; idx++)
+      {
+         DU_LOG("\n    Group Id [%d]", statsRsp->statsGrpAcceptedList[idx]);
+      }
+
+      DU_LOG("\n  Number of Rejected Groups [%d]", statsRsp->numGrpRejected);
+      for(idx=0; idx<statsRsp->numGrpRejected; idx++)
+      {
+         DU_LOG("\n    Group Id [%d]", statsRsp->statsGrpRejectedList[idx]);
+      }
+#endif      
+
+      DU_FREE_SHRABL_BUF(pst->region, pst->pool, statsRsp, sizeof(MacStatsRsp));
+      return ROK;
+   }
+
+   DU_LOG("\nERROR  -->  DU_APP : DuProcMacStatsRsp: Received NULL Pointer");
+   return RFAILED;
+}
+
+/*******************************************************************
+ *
+ * @brief Process statistics indication from MAC
+ *
+ * @details
+ *
+ *    Function : DuProcMacStatsInd
+ *
+ *    Functionality: Processes statistics indication from MAC.
+ *
+ * @params[in]
+ *
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t DuProcMacStatsInd(Pst *pst, MacStatsInd *statsInd)
+{
+   if(statsInd)
+   {
+#ifdef DEBUG_PRINT   
+      DU_LOG("\nDEBUG  -->  DU_APP : DuProcMacStatsInd: Received Statistics Indication");
+      DU_LOG("\n  Subscription Id [%ld]", statsInd->subscriptionId);
+      DU_LOG("\n  Group Id [%d]", statsInd->groupId);
+      for(int idx = 0; idx < statsInd->numStats; idx++)
+      {
+         DU_LOG("\n  Meas type [%d] Meas Value [%lf]", statsInd->measuredStatsList[idx].type,\
+            statsInd->measuredStatsList[idx].value);
+      }
+#endif      
+
+      /* TODO : When stats indication is received
+       * DU APP searches for the message type in E2AP RIC subscription database
+       * and stores in the value in the list of subscribed measurements
+       *
+       * This will be implemented in next gerrit.
+       */
+
+      DU_FREE_SHRABL_BUF(pst->region, pst->pool, statsInd, sizeof(MacStatsInd));
+      return ROK;
+   }
+   
+   DU_LOG("\nINFO  -->  DU_APP : DuProcMacStatsInd: Received NULL Pointer");
+   return RFAILED;
+}
+
 /**********************************************************************
   End of file
  **********************************************************************/