X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fdu_app%2Fdu_e2ap_mgr.c;h=58f5845e7780ef5ef3471829f45dfa70b5089107;hb=3740878d9d4bf9ab3d2639f0495b77f3f45bd3cb;hp=57d3cbb4923adab19c5d37e890433644a983258f;hpb=c35b0ec59aa6469d563405a418145a8a4564fc70;p=o-du%2Fl2.git

diff --git a/src/du_app/du_e2ap_mgr.c b/src/du_app/du_e2ap_mgr.c
index 57d3cbb49..58f5845e7 100644
--- a/src/du_app/du_e2ap_mgr.c
+++ b/src/du_app/du_e2ap_mgr.c
@@ -656,6 +656,138 @@ void e2ProcStatsInd(MacStatsInd *statsInd)
    }
 }
 
+/******************************************************************
+ *
+ * @brief Search E2 node component with the help of action type
+ *
+ * @details
+ *
+ *    Function : fetchE2NodeComponentInfo 
+ *
+ *    Functionality: Search E2 node component with the help of action type 
+ *
+ * @params[in] 
+ *       Type of interface 
+ *       Component action type
+ *       Pointer to E2 component node to be searched 
+ * @return CmLList
+ *
+ * ****************************************************************/
+
+E2NodeComponent *fetchE2NodeComponentInfo(InterfaceType interfaceType, uint8_t componentActionType, CmLList **e2ComponentNode)
+{
+   E2NodeComponent *e2NodeComponentInfo=NULLP;
+
+   if(duCb.e2apDb.e2NodeComponentList.count)
+   {
+      CM_LLIST_FIRST_NODE(&duCb.e2apDb.e2NodeComponentList, *e2ComponentNode);
+      while(*e2ComponentNode)
+      {
+         e2NodeComponentInfo = (E2NodeComponent*)((*e2ComponentNode)->node);
+         if((e2NodeComponentInfo->interfaceType == interfaceType) && (e2NodeComponentInfo->componentActionType == componentActionType))
+         {
+            
+            break;
+         }
+         
+         *e2ComponentNode = (*e2ComponentNode)->next;
+         e2NodeComponentInfo = NULLP;
+      }
+   }
+   return e2NodeComponentInfo; 
+}
+
+/*******************************************************************
+ *
+ * @brief add or modify E2NodeComponent list
+ *
+ * @details
+ *
+ *    Function : addOrModifyE2NodeComponent 
+ *
+ * Functionality: add or modify E2NodeComponent list 
+ *
+ * @parameter
+ *       Type of interface 
+ *       Component action type
+ *       boolean variable to check req or rsp msg type
+ *       Size of buffer which needs to be store
+ *       buffer string which needs to be store 
+ * @return ROK     - success
+ *         RFAILED - failure
+ *
+ ******************************************************************/
+
+uint8_t addOrModifyE2NodeComponent(InterfaceType interfaceType, uint8_t action, bool reqPart, uint8_t bufSize, char *bufString)
+{
+   E2NodeComponent *e2NodeComponentInfo= NULL;
+   CmLList  *node = NULLP;
+   
+   if(reqPart == true)
+   {
+      DU_ALLOC(e2NodeComponentInfo, sizeof(E2NodeComponent));
+      if(!e2NodeComponentInfo)
+      {
+         DU_LOG("\nERROR  -->  E2AP : Memory allocation failed for e2NodeComponentInfo in %s",__func__);
+         return RFAILED;
+      }
+      e2NodeComponentInfo->interfaceType =interfaceType;
+      e2NodeComponentInfo->componentId=duCfgParam.duId;
+      e2NodeComponentInfo->componentActionType = action;
+      e2NodeComponentInfo->reqBufSize = bufSize;
+
+      DU_ALLOC(e2NodeComponentInfo->componentRequestPart, bufSize);
+      if(e2NodeComponentInfo->componentRequestPart == NULLP)
+      {
+         DU_LOG("\nERROR  -->  E2AP : Memory allocation failed for componentRequestPart");
+         DU_FREE(e2NodeComponentInfo, sizeof(E2NodeComponent));
+         return RFAILED;
+      }
+      memcpy(e2NodeComponentInfo->componentRequestPart, bufString, e2NodeComponentInfo->reqBufSize);
+      DU_ALLOC(node, sizeof(CmLList));
+      if(node)
+      {
+         node->node = (PTR) e2NodeComponentInfo;
+         cmLListAdd2Tail(&duCb.e2apDb.e2NodeComponentList, node);
+      }
+      else
+      {
+         DU_LOG("\nERROR  -->  E2AP : Memory allocation failed for e2NodeComponentList node");
+         DU_FREE(e2NodeComponentInfo->componentRequestPart, bufSize);
+         DU_FREE(e2NodeComponentInfo, sizeof(E2NodeComponent));
+         return RFAILED;
+      }
+   }
+   else
+   {
+      if(duCb.e2apDb.e2NodeComponentList.count)
+      {
+         e2NodeComponentInfo = fetchE2NodeComponentInfo(interfaceType, action, &node);
+         if(e2NodeComponentInfo->componentRequestPart== NULLP)
+         {
+            DU_LOG("\nERROR  -->  E2AP : E2 node Component request part is not present");
+            return RFAILED;
+         }
+         
+         e2NodeComponentInfo->rspBufSize = bufSize;
+         DU_ALLOC(e2NodeComponentInfo->componentResponsePart, bufSize);
+         if(e2NodeComponentInfo->componentResponsePart == NULLP)
+         {
+            DU_LOG("\nERROR  -->  E2AP : Memory allocation failed to store the encoding of rsp");
+            return RFAILED;
+         }
+         memcpy(e2NodeComponentInfo->componentResponsePart, bufString, e2NodeComponentInfo->rspBufSize);
+         return ROK;
+      }
+      else
+      {
+         DU_LOG("\nERROR  -->  E2AP : Unable to find the node");
+         return RFAILED;
+      }
+   } 
+   return ROK;
+}
+
 /**********************************************************************
   End of file
  **********************************************************************/