return currTransId;
}
+ /*******************************************************************
+ *
+ * @brief add RIC Subs action info
+ *
+ * @details
+ *
+ * Function : addRicSubsAction
+ *
+ * Functionality: add Ric Subs action info
+ *
+ * @parameter
+ * RIC action id
+ * List of action
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ ******************************************************************/
+CmLList *addRicSubsAction(uint8_t ricActionID, CmLListCp *actionSequence)
+{
+ ActionInfo *actionDb = NULLP;
+ CmLList *actionNode=NULLP;
+
+ RIC_ALLOC(actionDb, sizeof(ActionInfo));
+ if(actionDb==NULLP)
+ {
+ DU_LOG("\nERROR --> E2AP : Memory allocation failed in %s at %d",__func__,__LINE__);
+ return NULLP;
+ }
+
+ actionDb->actionId = ricActionID;
+ RIC_ALLOC(actionNode, sizeof(CmLList));
+ if(actionNode)
+ {
+ actionNode->node = (PTR) actionDb;
+ cmLListAdd2Tail(actionSequence, actionNode);
+ }
+ else
+ {
+ DU_LOG("\nERROR --> E2AP : Memory allocation failed in %s at %d",__func__,__LINE__);
+ RIC_FREE(actionDb, sizeof(ActionInfo));
+ return NULLP;
+ }
+
+ return actionNode;
+}
+
/*******************************************************************
*
* @brief Sends E2 msg over SCTP
*
* @params[in] Action ID
* RIC Subscription DB
+ * List of action
* @return Action Info DB
* NULL, in case of failure
*
* ****************************************************************/
-ActionInfo *fetchActionInfoFromActionId(uint8_t actionId, RicSubscription *ricSubscriptionInfo)
+ActionInfo *fetchActionInfoFromActionId(uint8_t actionId, RicSubscription *ricSubscriptionInfo, CmLList ** actionNode)
{
ActionInfo *actionInfoDb = NULLP;
- if(ricSubscriptionInfo->actionSequence[actionId].actionId == actionId)
+
+ CM_LLIST_FIRST_NODE(&ricSubscriptionInfo->actionSequence, *actionNode);
+ while(*actionNode)
{
- actionInfoDb = &ricSubscriptionInfo->actionSequence[actionId];
+ actionInfoDb = (ActionInfo*)((*actionNode)->node);
+ if(actionInfoDb->actionId == actionId)
+ {
+ break;
+ }
+ *actionNode= (*actionNode)->next;
}
- else
+ if(actionInfoDb==NULLP)
{
DU_LOG("\nERROR --> E2AP : fetchActionInfoFromActionId: Action Id [%d] not found in \
- subscription info [Requestor id : %d] [Instance Id : %d]", actionId,\
- ricSubscriptionInfo->requestId.requestorId, ricSubscriptionInfo->requestId.instanceId);
+ subscription info [Requestor id : %d] [Instance Id : %d]", actionId,\
+ ricSubscriptionInfo->requestId.requestorId, ricSubscriptionInfo->requestId.instanceId);
}
return actionInfoDb;
uint8_t fillActionToBeSetup(RICaction_ToBeSetup_ItemIEs_t *actionItem, RicSubscription *ricSubsDb)
{
static uint8_t ricActionId = 0;
-
+ CmLList *actionNode=NULLP;
if(actionItem == NULLP)
{
DU_LOG("\nERROR --> E2AP : Failed at [%s] : line [%d]", __func__, __LINE__);
/* RIC Action ID */
actionItem->value.choice.RICaction_ToBeSetup_Item.ricActionID = ricActionId;
- ricSubsDb->actionSequence[ricActionId].actionId = \
- actionItem->value.choice.RICaction_ToBeSetup_Item.ricActionID;
+ actionNode = addRicSubsAction(ricActionId, &ricSubsDb->actionSequence);
ricActionId++;
/* RIC Action Type */
break;
}
- ricSubsDb->numOfActions++;
return ROK;
}
-
- memset(&ricSubsDb->actionSequence[ricActionId], 0, sizeof(ActionInfo));
- ricSubsDb->actionSequence[ricActionId].actionId = -1;
+
+ if(actionNode)
+ {
+ cmLListDelFrm(&ricSubsDb->actionSequence, actionNode);
+ deleteActionSequence(actionNode);
+ }
return RFAILED;
}
DU_LOG("\nERROR --> E2AP : Memory allocation failed at [%s] : line [%d]", __func__, __LINE__);
return RFAILED;
}
- for(actionIdx = 0; actionIdx < MAX_RIC_ACTION; actionIdx++)
- {
- ricSubsInfo->actionSequence[actionIdx].actionId = -1;
- }
while(true)
{
RanFunction *ranFuncDb = NULLP;
RicSubscription *ricSubs = NULLP;
CmLList *ricSubsNode = NULLP;
+ CmLList *actionNode = NULLP;
ActionInfo *action = NULLP;
RICsubscriptionResponse_IEs_t *ricSubsRspIe = NULLP;
RICaction_NotAdmitted_List_t *notAdmitList = NULLP;
notAdmitList = &ricSubsRspIe->value.choice.RICaction_NotAdmitted_List;
for(notAdmitIdx = 0; notAdmitIdx < notAdmitList->list.count; notAdmitIdx++)
{
+ actionNode=NULLP;
actionId = ((RICaction_NotAdmitted_ItemIEs_t *)(notAdmitList->list.array[notAdmitIdx]))->\
value.choice.RICaction_NotAdmitted_Item.ricActionID;
ricSubs = fetchSubsInfoFromRicReqId(ricReqId, ranFuncDb, &ricSubsNode);
if(ricSubs)
{
- action = fetchActionInfoFromActionId(actionId, ricSubs);
+ action = fetchActionInfoFromActionId(actionId, ricSubs, &actionNode);
if(action)
{
- memset(action, 0, sizeof(ActionInfo));
- ricSubs->actionSequence[actionId].actionId = -1;
- ricSubs->numOfActions--;
+ cmLListDelFrm(&ricSubs->actionSequence, actionNode);
+ deleteActionSequence(actionNode);
}
}
}
RanFunction *ranFuncDb = NULLP;
RicSubscription *ricSubs = NULLP;
CmLList *ricSubsNode = NULLP;
+ CmLList *actionNode = NULLP;
ActionInfo *action = NULLP;
RICsubscriptionModificationRequired_IEs_t *ricSubsModReqdIe = NULLP;
RICactions_RequiredToBeModified_List_t *actionToBeModList = NULLP;
actionToBeModList = &ricSubsModReqdIe->value.choice.RICactions_RequiredToBeModified_List;
for(actionIdx = 0; actionIdx < actionToBeModList->list.count; actionIdx++)
{
+ actionNode=NULLP;
actionToBeMod = (RICaction_RequiredToBeModified_ItemIEs_t *)actionToBeModList->list.array[actionIdx];
actionId = actionToBeMod->value.choice.RICaction_RequiredToBeModified_Item.ricActionID;
- action = fetchActionInfoFromActionId(actionId, ricSubs);
+ action = fetchActionInfoFromActionId(actionId, ricSubs, &actionNode);
if(action)
{
/* No modification required as of now, hence directly adding to the list */
actionToBeRmvList = &ricSubsModReqdIe->value.choice.RICactions_RequiredToBeRemoved_List;
for(actionIdx = 0; actionIdx < actionToBeRmvList->list.count; actionIdx++)
{
+ actionNode=NULLP;
actionToBeRmv = (RICaction_RequiredToBeRemoved_ItemIEs_t *)actionToBeRmvList->list.array[actionIdx];
actionId = actionToBeRmv->value.choice.RICaction_RequiredToBeRemoved_Item.ricActionID;
- action = fetchActionInfoFromActionId(actionId, ricSubs);
+ action = fetchActionInfoFromActionId(actionId, ricSubs, &actionNode);
if(action)
{
tmpActionList.actionRemovedList[tmpActionList.numActionRemoved++] = actionId;
- memset(action, 0, sizeof(ActionInfo));
- action->actionId = -1;
- ricSubs->numOfActions--;
+ cmLListDelFrm(&ricSubs->actionSequence, actionNode);
+ deleteActionSequence(actionNode);
}
}
break;
return ret;
}
+/******************************************************************
+ *
+ * @brief Delete Ric subscription action
+ *
+ * @details
+ *
+ * Function : deleteActionSequence
+ *
+ * Functionality: Delete Ric subscription action
+ *
+ * @params[in] Action info
+ *
+ * @return void
+ *
+ * ****************************************************************/
+void deleteActionSequence(CmLList *actionNode)
+{
+ ActionInfo *action = NULLP;
+
+ if(actionNode)
+ {
+ action = (ActionInfo*)actionNode->node;
+ memset(action, 0, sizeof(ActionInfo));
+ RIC_FREE(actionNode->node, sizeof(ActionInfo));
+ RIC_FREE(actionNode, sizeof(CmLList));
+ }
+}
+
+/******************************************************************
+ *
+ * @brief Delete Ric subscription action list
+ *
+ * @details
+ *
+ * Function : deleteActionSequenceList
+ *
+ * Functionality: Delete Ric subscription action list
+ *
+ * @params[in] Action info list
+ *
+ * @return void
+ *
+ * ****************************************************************/
+void deleteActionSequenceList(CmLListCp *actionList)
+{
+ CmLList *actionNode=NULLP;
+
+ CM_LLIST_FIRST_NODE(actionList, actionNode);
+ while(actionNode)
+ {
+ cmLListDelFrm(actionList, actionNode);
+ deleteActionSequence(actionNode);
+ CM_LLIST_FIRST_NODE(actionList, actionNode);
+ }
+
+}
+
/******************************************************************
*
* @brief Delete Ric subscription node
RicSubscription *ricSubscriptionInfo = NULLP;
ricSubscriptionInfo = (RicSubscription*)subscriptionNode->node;
-
- for(actionIdx = 0; actionIdx < MAX_RIC_ACTION; actionIdx++)
- {
- if(ricSubscriptionInfo->actionSequence[actionIdx].actionId > -1)
- {
- memset(&ricSubscriptionInfo->actionSequence[actionIdx], 0, sizeof(ActionInfo));
- }
- }
+
+ deleteActionSequenceList(&ricSubscriptionInfo->actionSequence);
+
memset(ricSubscriptionInfo, 0, sizeof(RicSubscription));
RIC_FREE(subscriptionNode->node, sizeof(RicSubscription));
RIC_FREE(subscriptionNode, sizeof(CmLList));
uint8_t BuildRicSubsActionToBeAdded(RICactions_ToBeAddedForModification_List_t *addedActionList, RicSubscription **ricSubsInfo, uint8_t numOfActionToBeAdded, ActionInfo *actionToBeAdded)
{
uint8_t arrIdx=0;
+ CmLList *actionNode=NULLP;
RICaction_ToBeAddedForModification_ItemIEs_t *addedActionItemIe;
addedActionList->list.count = numOfActionToBeAdded;
DU_LOG("\nERROR --> E2AP : Failed at [%s] : line [%d]", __func__, __LINE__);
break;
}
- (*ricSubsInfo)->actionSequence[(*ricSubsInfo)->numOfActions].actionId = (*ricSubsInfo)->numOfActions;
- (*ricSubsInfo)->numOfActions++;
+
+ actionNode = addRicSubsAction((*ricSubsInfo)->actionSequence.count, &(*ricSubsInfo)->actionSequence);
+ if(actionNode == NULLP)
+ {
+ DU_LOG("\nERROR --> E2AP : Failed at [%s] : line [%d]", __func__, __LINE__);
+ return RFAILED;
+ }
}
return ROK;
}
void BuildRicSubsModificationReq(DuDb *duDb, RicSubscription *ricSubsInfo)
{
+ CmLList *actionNode=NULLP;
uint8_t actionToBeAdded =0;
uint8_t actionIdx =0, tmpActionIdx=0;
+ ActionInfo *actionInfoDb = NULLP;
RicSubsModReq ricSubsModReq;
if(ricSubsInfo)
{
memset(&ricSubsModReq, 0, sizeof(RicSubsModReq));
- for(actionIdx=0; actionIdx<ricSubsInfo->numOfActions; actionIdx++)
+
+
+ CM_LLIST_FIRST_NODE(&ricSubsInfo->actionSequence, actionNode);
+ while(actionNode)
{
+ actionInfoDb = (ActionInfo*)(actionNode->node);
/* Change the condition based on the action required to be modiified or removed */
- if(actionIdx%2 == 0)
+ if(((actionInfoDb->actionId+1)%2) == 0)
{
tmpActionIdx = ricSubsModReq.numOfActionToBeModify;
- ricSubsModReq.actionToBeModify[tmpActionIdx].actionId = ricSubsInfo->actionSequence[actionIdx].actionId;
+ ricSubsModReq.actionToBeModify[tmpActionIdx].actionId = actionInfoDb->actionId;
ricSubsModReq.numOfActionToBeModify++;
}
else
{
tmpActionIdx = ricSubsModReq.numOfActionToBeRemove;
- ricSubsModReq.actionToBeRemove[tmpActionIdx].actionId = ricSubsInfo->actionSequence[actionIdx].actionId;
+ ricSubsModReq.actionToBeRemove[tmpActionIdx].actionId = actionInfoDb->actionId;
ricSubsModReq.numOfActionToBeRemove++;
}
+ actionNode= actionNode->next;
}
/* Change the value of actionToBeAdded based on the number of action required to be added */
actionToBeAdded =1;
- tmpActionIdx = ricSubsInfo->numOfActions;
+ tmpActionIdx = ricSubsInfo->actionSequence.count;
for(actionIdx=0; actionIdx<actionToBeAdded; actionIdx++)
{
ricSubsModReq.actionToBeAdded[actionIdx].actionId = tmpActionIdx;
}
}
+/****************************************************************
+ *
+ * @brief Processing RIC Subscription action modified list
+ *
+ * @details
+ *
+ * Function :ProcessingRicSubsActionModified
+ *
+ * Functionality: Processing the RIC Subscription action modified list
+ *
+ * @params[in] RICactions_AddedForModification_List_t
+ * @return void
+ *
+ * ****************************************************************/
+void ProcessingRicSubsActionModified(RICactions_ModifiedForModification_List_t *actionModifiedList)
+{
+ uint8_t actionId=0;
+ uint8_t elementIdx = 0;
+ ActionInfo *action=NULLP;
+ CmLList *actionNode =NULLP;
+ RICaction_ModifiedForModification_ItemIEs_t *modifiedActionItemIe =NULLP;
+
+ if(actionModifiedList->list.array)
+ {
+ for(elementIdx = 0; elementIdx < actionModifiedList->list.count; elementIdx++)
+ {
+ if(actionModifiedList->list.array[elementIdx])
+ {
+ modifiedActionItemIe=(RICaction_ModifiedForModification_ItemIEs_t*)actionModifiedList->list.array[elementIdx];
+ actionId = modifiedActionItemIe->value.choice.RICaction_ModifiedForModification_Item.ricActionID;
+ DU_LOG("\nInfo --> E2AP : Action id %d modified successfully", actionId);
+ }
+
+ }
+
+ }
+}
+
+/****************************************************************
+ *
+ * @brief Processing RIC Subscription action added list
+ *
+ * @details
+ *
+ * Function : ProcessingRicSubsActionAdded
+ *
+ * Functionality: Processing RIC Subscription action added list
+ *
+ * @params[in] RICactions_AddedForModification_List_t
+ * @return void
+ *
+ * ****************************************************************/
+void ProcessingRicSubsActionAdded(RICactions_AddedForModification_List_t *actionAddedList)
+{
+ uint8_t actionId=0;
+ uint8_t elementIdx = 0;
+ ActionInfo *action=NULLP;
+ CmLList *actionNode =NULLP;
+ RICaction_AddedForModification_ItemIEs_t *addedActionItemIe =NULLP;
+
+ if(actionAddedList->list.array)
+ {
+ for(elementIdx = 0; elementIdx < actionAddedList->list.count; elementIdx++)
+ {
+ if(actionAddedList->list.array[elementIdx])
+ {
+ addedActionItemIe=(RICaction_AddedForModification_ItemIEs_t*)actionAddedList->list.array[elementIdx];
+ actionId = addedActionItemIe->value.choice.RICaction_AddedForModification_Item.ricActionID;
+ DU_LOG("\nInfo --> E2AP : Action id %d added successfully", actionId);
+ }
+
+ }
+
+ }
+}
+
+/****************************************************************
+ *
+ * @brief Processing RIC Subscription action deleted list
+ *
+ * @details
+ *
+ * Function : ProcessingRicSubsActionRemoved
+ *
+ * Functionality: Processing RIC Subscription action deleted list
+ *
+ * @params[in] RICactions_RemovedForModification_List_t
+ * Ric Subscription info
+ * @return void
+ *
+ * ****************************************************************/
+void ProcessingRicSubsActionRemoved(RICactions_RemovedForModification_List_t *actionRemovedList, RicSubscription *ricSubs)
+{
+ uint8_t actionId=0;
+ uint8_t elementIdx = 0;
+ ActionInfo *action=NULLP;
+ CmLList *actionNode =NULLP;
+ RICaction_RemovedForModification_ItemIEs_t *removedActionItemIe =NULLP;
+
+ if(actionRemovedList->list.array)
+ {
+ for(elementIdx = 0; elementIdx < actionRemovedList->list.count; elementIdx++)
+ {
+ if(actionRemovedList->list.array[elementIdx])
+ {
+ removedActionItemIe=(RICaction_RemovedForModification_ItemIEs_t*)actionRemovedList->list.array[elementIdx];
+ actionId = removedActionItemIe->value.choice.RICaction_RemovedForModification_Item.ricActionID;
+ action = fetchActionInfoFromActionId(actionId, ricSubs, &actionNode);
+ if(action)
+ {
+ cmLListDelFrm(&ricSubs->actionSequence, actionNode);
+ deleteActionSequence(actionNode);
+ DU_LOG("\nInfo --> E2AP : Action id %d removed successfully", actionId);
+ }
+ }
+
+ }
+
+ }
+}
+
+/*******************************************************************
+ *
+ * @brief Processing RIC Subscription action failed to be
+ * removed list
+ *
+ * @details
+ *
+ * Function : ProcessingRicSubsActionFailedToBeRemoved
+ *
+ * Functionality: Processing the RIC Subscription action failed
+ * to be removed list
+ *
+ * @params[in] RICactions_FailedToBeRemovedForModification_List_t
+ * @return void
+ *
+ * ****************************************************************/
+void ProcessingRicSubsActionFailedToBeRemoved(RICactions_FailedToBeRemovedForModification_List_t *actionFailedToBeRemoved)
+{
+ uint8_t actionId=0;
+ uint8_t elementIdx = 0;
+ RICaction_FailedToBeRemovedForModification_ItemIEs_t *failedToBeRemovedActionItemIe =NULLP;
+
+ if(actionFailedToBeRemoved->list.array)
+ {
+ for(elementIdx = 0; elementIdx < actionFailedToBeRemoved->list.count; elementIdx++)
+ {
+ if(actionFailedToBeRemoved->list.array[elementIdx])
+ {
+ failedToBeRemovedActionItemIe=(RICaction_FailedToBeRemovedForModification_ItemIEs_t*)actionFailedToBeRemoved->list.array[elementIdx];
+ actionId = failedToBeRemovedActionItemIe->value.choice.RICaction_FailedToBeRemovedForModification_Item.ricActionID;
+ DU_LOG("\nERROR --> E2AP : Failed to remove action id %d in %s", actionId, __func__);
+ printE2ErrorCause(&failedToBeRemovedActionItemIe->value.choice.RICaction_FailedToBeRemovedForModification_Item.cause);
+ }
+
+ }
+
+ }
+}
+
+/****************************************************************
+ *
+ * @brief Processing RIC Subscription action failed to be
+ * add list
+ *
+ * @details
+ *
+ * Function : ProcessingRicSubsActionFailedToBeAdded
+ *
+ * Functionality: Processing the RIC Subscription action failed
+ * to be add list
+ *
+ * @params[in] RICactions_FailedToBeAddedForModification_List_t
+ * @return void
+ *
+ * ****************************************************************/
+void ProcessingRicSubsActionFailedToBeAdded(RICactions_FailedToBeAddedForModification_List_t *actionfailedToBeAddedList, RicSubscription *ricSubs)
+{
+ uint8_t actionId=0;
+ uint8_t elementIdx = 0;
+ ActionInfo *action=NULLP;
+ CmLList *actionNode =NULLP;
+ RICaction_FailedToBeAddedForModification_ItemIEs_t *failedToBeAddedActionItemIe =NULLP;
+
+ if(actionfailedToBeAddedList->list.array)
+ {
+ for(elementIdx = 0; elementIdx < actionfailedToBeAddedList->list.count; elementIdx++)
+ {
+ if(actionfailedToBeAddedList->list.array[elementIdx])
+ {
+ failedToBeAddedActionItemIe=(RICaction_FailedToBeAddedForModification_ItemIEs_t*)actionfailedToBeAddedList->list.array[elementIdx];
+ actionId = failedToBeAddedActionItemIe->value.choice.RICaction_FailedToBeAddedForModification_Item.ricActionID;
+ action = fetchActionInfoFromActionId(actionId, ricSubs, &actionNode);
+ if(action)
+ {
+ cmLListDelFrm(&ricSubs->actionSequence, actionNode);
+ deleteActionSequence(actionNode);
+ }
+ DU_LOG("\nERROR --> E2AP : Failed to remove action id %d in %s", actionId,__func__);
+ printE2ErrorCause(&failedToBeAddedActionItemIe->value.choice.RICaction_FailedToBeAddedForModification_Item.cause);
+ }
+
+ }
+
+ }
+}
+
+/*******************************************************************
+ *
+ * @brief Processing RIC Subscription action failed to be
+ * modified list
+ *
+ * @details
+ *
+ * Function :ProcessingRicSubsActionFailedToBeModified
+ *
+ * Functionality: Processing the RIC Subscription action failed
+ * to be modified list
+ *
+ * @params[in] RICactions_FailedToBeModifiedForModification_List_t
+ * @return void
+ *
+ * ****************************************************************/
+void ProcessingRicSubsActionFailedToBeModified(RICactions_FailedToBeModifiedForModification_List_t *actionFailedToBeModifiedList)
+{
+ uint8_t actionId=0;
+ uint8_t elementIdx = 0;
+ RICaction_FailedToBeModifiedForModification_ItemIEs_t *failedToBeModifiedActionItemIe =NULLP;
+
+ if(actionFailedToBeModifiedList->list.array)
+ {
+ for(elementIdx = 0; elementIdx < actionFailedToBeModifiedList->list.count; elementIdx++)
+ {
+ if(actionFailedToBeModifiedList->list.array[elementIdx])
+ {
+ failedToBeModifiedActionItemIe=(RICaction_FailedToBeModifiedForModification_ItemIEs_t*)actionFailedToBeModifiedList->list.array[elementIdx];
+ actionId = failedToBeModifiedActionItemIe->value.choice.RICaction_FailedToBeModifiedForModification_Item.ricActionID;
+ DU_LOG("\nERROR --> E2AP : Failed to remove action id %d in %s", actionId,__func__);
+ printE2ErrorCause(&failedToBeModifiedActionItemIe->value.choice.RICaction_FailedToBeModifiedForModification_Item.cause);
+ }
+
+ }
+
+ }
+}
+
+/******************************************************************
+ *
+ * @brief Processes the Ric Subs modification rsp msg
+ *
+ * @details
+ *
+ * Function : ProcRicSubsModificationRsp
+ *
+ * Functionality: Processes the Ric Subs modification rsp msg
+ *
+ * @params[in]
+ * Ric Subs modification rsp information
+ *
+ * @return void
+ *
+ * ****************************************************************/
+void ProcRicSubsModificationRsp(uint32_t duId, RICsubscriptionModificationResponse_t *ricSubsModificationRsp)
+{
+ uint8_t ieIdx = 0;
+ uint8_t duIdx= 0;
+ uint16_t ranFuncId=0;
+ RanFunction *ranFuncDb = NULLP;
+ RicRequestId ricReqId;
+ DuDb *duDb = NULLP;
+ RicSubscription *ricSubs = NULLP;
+ CmLList *ricSubsNode = NULLP;
+
+ SEARCH_DU_DB(duIdx, duId, duDb);
+ if(duDb == NULLP)
+ {
+ DU_LOG("\nERROR --> E2AP : duDb is not present for duId %d",duId);
+ return;
+ }
+
+ if(!ricSubsModificationRsp)
+ {
+ DU_LOG("\nERROR --> E2AP : ricSubsModificationRsp pointer is null");
+ return;
+ }
+
+ if(!ricSubsModificationRsp->protocolIEs.list.array)
+ {
+ DU_LOG("\nERROR --> E2AP : ricSubsModificationRsp array pointer is null");
+ return;
+ }
+
+ for(ieIdx=0; ieIdx < ricSubsModificationRsp->protocolIEs.list.count; ieIdx++)
+ {
+ if(ricSubsModificationRsp->protocolIEs.list.array[ieIdx])
+ {
+ switch(ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->id)
+ {
+ case ProtocolIE_IDE2_id_RICrequestID:
+ {
+ ricReqId.requestorId = ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RICrequestID.ricRequestorID;
+ ricReqId.instanceId = ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RICrequestID.ricInstanceID;
+ break;
+ }
+ case ProtocolIE_IDE2_id_RANfunctionID:
+ {
+ ranFuncId = ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RANfunctionID;
+ ranFuncDb = fetchRanFuncFromRanFuncId(duDb, ranFuncId);
+ if(!ranFuncDb)
+ {
+ DU_LOG("\nERROR --> E2AP : Invalid Ran Function id %d received",ranFuncId);
+ return;
+ }
+
+ ricSubs = fetchSubsInfoFromRicReqId(ricReqId, ranFuncDb, &ricSubsNode);
+ if(!ricSubs)
+ {
+ DU_LOG("\nERROR --> E2AP : Ric subscription node is not present ");
+ return;
+ }
+ break;
+ }
+ case ProtocolIE_IDE2_id_RICactionsRemovedForModification_List:
+ {
+ ProcessingRicSubsActionRemoved(&ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RICactions_RemovedForModification_List, ricSubs);
+ break;
+ }
+ case ProtocolIE_IDE2_id_RICactionsFailedToBeRemovedForModification_List:
+ {
+ ProcessingRicSubsActionFailedToBeRemoved(&ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RICactions_FailedToBeRemovedForModification_List);
+ break;
+ }
+ case ProtocolIE_IDE2_id_RICactionsModifiedForModification_List:
+ {
+ ProcessingRicSubsActionModified(&ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RICactions_ModifiedForModification_List);
+ break;
+ }
+ case ProtocolIE_IDE2_id_RICactionsFailedToBeModifiedForModification_List:
+ {
+ ProcessingRicSubsActionFailedToBeModified(&ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RICactions_FailedToBeModifiedForModification_List);
+ break;
+ }
+ case ProtocolIE_IDE2_id_RICactionsAddedForModification_List:
+ {
+ ProcessingRicSubsActionAdded(&ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RICactions_AddedForModification_List);
+ break;
+ }
+ case ProtocolIE_IDE2_id_RICactionsFailedToBeAddedForModification_List:
+ {
+ ProcessingRicSubsActionFailedToBeAdded(&ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->value.choice.RICactions_FailedToBeAddedForModification_List, ricSubs);
+ break;
+ }
+ default:
+ {
+ DU_LOG("\nERROR --> E2AP : Received Invalid Ie [%ld]", ricSubsModificationRsp->protocolIEs.list.array[ieIdx]->id);
+ break;
+ }
+ }
+ }
+ }
+}
+
/*******************************************************************
*
* @brief Handles received E2AP message and sends back response
ProcRicSubsDeleteRsp(*duId, &e2apMsg->choice.successfulOutcome->value.choice.RICsubscriptionDeleteResponse);
break;
}
+ case SuccessfulOutcomeE2__value_PR_RICsubscriptionModificationResponse:
+ {
+ ProcRicSubsModificationRsp(*duId, &e2apMsg->choice.successfulOutcome->value.choice.RICsubscriptionModificationResponse);
+ break;
+ }
default:
{
DU_LOG("\nERROR --> E2AP : Invalid type of successfulOutcome message [%d]", \
Code Review / o-du / l2.git / blobdiff