X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fdu_app%2Fdu_e2ap_msg_hdl.c;h=5a3c425a612f9706744b4e0c66283860119d6c73;hb=a0b19d81aa8c12107f409b1d06a5e900614697c2;hp=593fd3d8a7f974863c45fc71522998ab72c0a370;hpb=7be3f80c289304edaa42f6f46a30015aad04747a;p=o-du%2Fl2.git diff --git a/src/du_app/du_e2ap_msg_hdl.c b/src/du_app/du_e2ap_msg_hdl.c index 593fd3d8a..5a3c425a6 100644 --- a/src/du_app/du_e2ap_msg_hdl.c +++ b/src/du_app/du_e2ap_msg_hdl.c @@ -29,6 +29,7 @@ #include "du_sctp.h" #include "du_mgr.h" #include "du_mgr_main.h" +#include "du_msg_hdl.h" #include "du_utils.h" #include "GlobalE2node-gNB-ID.h" #include "ProtocolIE-FieldE2.h" @@ -3244,6 +3245,108 @@ uint8_t extractRicActionDef(RanFunction *ranFuncDb, ActionDefinition *actionDefD return RFAILED; } +/******************************************************************* + * + * @brief add RIC Subs action info + * + * @details + * + * Function : addRicSubsAction + * + * Functionality: add Ric Subs action info + * + * @parameter + * RAN function DB + * Pointer to Ric Subc info + * Action Sequence list + * Procedure Code + * E2 Failure Cause + * @return ROK - success + * RFAILED - failure + * + ******************************************************************/ + +CmLList *addRicSubsAction(RanFunction *ranFuncDb, PTR ricSubsInfo, CmLListCp *actionSequence, uint8_t procedureCode, E2FailureCause *failureCause) +{ + CmLList *actionNode = NULLP; + ActionInfo *actionDb = NULLP; + RICactionID_t ricActionID; + RICactionType_t ricActionType; + RICactionDefinition_t *ricActionDefinition= NULLP; + RICaction_ToBeSetup_Item_t *setupItem= NULLP; + RICaction_ToBeAddedForModification_Item_t *addIem= NULLP; + RICaction_ToBeModifiedForModification_Item_t *modifiedItem= NULLP; + + switch(procedureCode) + { + case ProtocolIE_IDE2_id_RICaction_ToBeSetup_Item: + { + setupItem = (RICaction_ToBeSetup_Item_t *)ricSubsInfo; + ricActionID= setupItem->ricActionID; + ricActionType= setupItem->ricActionType; + if(setupItem->ricActionDefinition) + { + ricActionDefinition = setupItem->ricActionDefinition; + } + break; + } + case ProtocolIE_IDE2_id_RICaction_ToBeAddedForModification_Item: + { + addIem = (RICaction_ToBeAddedForModification_Item_t*) ricSubsInfo; + ricActionID= addIem->ricActionID; + ricActionType= addIem->ricActionType; + ricActionDefinition = &addIem->ricActionDefinition; + + break; + } + case ProtocolIE_IDE2_id_RICaction_ToBeModifiedForModification_Item: + { + modifiedItem= (RICaction_ToBeModifiedForModification_Item_t*)ricSubsInfo; + ricActionID= modifiedItem->ricActionID; + /* Added since ricActionType IE is not present in case of + * modification */ + ricActionType = RICactionType_report; + if(modifiedItem->ricActionDefinition) + { + ricActionDefinition = modifiedItem->ricActionDefinition; + } + break; + } + } + + + DU_ALLOC(actionDb, sizeof(ActionInfo)); + if(actionDb==NULLP) + { + DU_LOG("\nERROR --> E2AP : Memory allocation failed in %s at %d",__func__,__LINE__); + return NULLP; + } + if(ricActionType== RICactionType_report) + { + actionDb->actionId = ricActionID; + actionDb->type = REPORT; + + if(extractRicActionDef(ranFuncDb, &actionDb->definition, ricActionDefinition, failureCause) == ROK) + { + actionDb->action = CONFIG_ADD; + } + + DU_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__); + DU_FREE(actionDb, sizeof(ActionInfo)); + return NULLP; + } + } + return actionNode; + +} /******************************************************************* * * @brief Extract RIC Action to be setup @@ -3266,6 +3369,7 @@ uint8_t extractRicActionDef(RanFunction *ranFuncDb, ActionDefinition *actionDefD uint8_t extractRicActionToBeSetup(RanFunction *ranFuncDb, RicSubscription *ricSubscriptionInfo, \ RICactions_ToBeSetup_List_t *actionList, E2FailureCause *failureCause, PendingSubsRspInfo *subsRsp) { + CmLList *actionNode = NULLP; uint8_t actionIdx = 0; uint8_t ricActionId = 0; RICaction_ToBeSetup_ItemIEs_t *actionItem = NULLP; @@ -3283,35 +3387,23 @@ uint8_t extractRicActionToBeSetup(RanFunction *ranFuncDb, RicSubscription *ricSu * If RIC action definition's extraction and validation passes, * Then : * This action is added to action sequence list of subscription info */ - ricActionId = actionItem->value.choice.RICaction_ToBeSetup_Item.ricActionID; - - if(actionItem->value.choice.RICaction_ToBeSetup_Item.ricActionType == RICactionType_report) + actionNode = addRicSubsAction(ranFuncDb, (PTR)&actionItem->value.choice.RICaction_ToBeSetup_Item,\ + &ricSubscriptionInfo->actionSequence, ProtocolIE_IDE2_id_RICaction_ToBeSetup_Item, failureCause); + + if(!actionNode) { - ricSubscriptionInfo->actionSequence[ricActionId].actionId = ricActionId; - ricSubscriptionInfo->actionSequence[ricActionId].type = REPORT; - - if(extractRicActionDef(ranFuncDb, &ricSubscriptionInfo->actionSequence[ricActionId].definition, \ - actionItem->value.choice.RICaction_ToBeSetup_Item.ricActionDefinition, failureCause) == ROK) + /* In case of any failure, action is rejected + * Added to rejected-action-list in subscription response */ + subsRsp->rejectedActionList[subsRsp->numOfRejectedActions].id = ricActionId; + if(failureCause->causeType == E2_NOTHING) { - ricSubscriptionInfo->actionSequence[ricActionId].action = CONFIG_ADD; - ricSubscriptionInfo->numOfActions++; - break; + failureCause->causeType = E2_RIC_REQUEST; + failureCause->cause = E2_CONTROL_FAILED_TO_EXECUTE; } + memcpy(&subsRsp->rejectedActionList[subsRsp->numOfRejectedActions].failureCause, \ + failureCause, sizeof(E2FailureCause)); + subsRsp->numOfRejectedActions++; } - - /* In case of any failure, action is rejected - * Added to rejected-action-list in subscription response */ - deleteActionSequence(&ricSubscriptionInfo->actionSequence[ricActionId]); - - subsRsp->rejectedActionList[subsRsp->numOfRejectedActions].id = ricActionId; - if(failureCause->causeType == E2_NOTHING) - { - failureCause->causeType = E2_RIC_REQUEST; - failureCause->cause = E2_ACTION_NOT_SUPPORTED; - } - memcpy(&subsRsp->rejectedActionList[subsRsp->numOfRejectedActions].failureCause, \ - failureCause, sizeof(E2FailureCause)); - subsRsp->numOfRejectedActions++; break; } default: @@ -3322,7 +3414,7 @@ uint8_t extractRicActionToBeSetup(RanFunction *ranFuncDb, RicSubscription *ricSu } /* If there is even 1 action that can be added, return ROK */ - if(ricSubscriptionInfo->numOfActions) + if(ricSubscriptionInfo->actionSequence.count) return ROK; if(failureCause->causeType == E2_NOTHING) @@ -3350,7 +3442,7 @@ uint8_t extractRicActionToBeSetup(RanFunction *ranFuncDb, RicSubscription *ricSu * ****************************************************************/ uint8_t procRicSubscriptionRequest(E2AP_PDU_t *e2apMsg) { - uint8_t idx = 0, actionIdx = 0; + uint8_t idx = 0; uint8_t ret = ROK; uint16_t ranFuncId = 0; RicRequestId ricReqId; @@ -3417,11 +3509,6 @@ uint8_t procRicSubscriptionRequest(E2AP_PDU_t *e2apMsg) ricSubscriptionInfo->requestId.instanceId = ricReqId.instanceId; ricSubscriptionInfo->ranFuncId = ranFuncId; - for(actionIdx = 0; actionIdx < MAX_RIC_ACTION; actionIdx++) - { - ricSubscriptionInfo->actionSequence[actionIdx].actionId = -1; - } - memset(&ranFuncDb->pendingSubsRspInfo[ranFuncDb->numPendingSubsRsp], 0, sizeof(PendingSubsRspInfo)); memcpy(&ranFuncDb->pendingSubsRspInfo[ranFuncDb->numPendingSubsRsp].requestId, &ricReqId, sizeof(RicRequestId)); @@ -6207,10 +6294,12 @@ void FreeRicSubsModRequired(E2AP_PDU_t *e2apMsg) * RFAILED - failure * ******************************************************************/ -uint8_t FillActionReqdToBeModList(RICactions_RequiredToBeModified_List_t *actionToBeModList, uint8_t numActionsMod, \ - RicSubscription *ricSubscription) +uint8_t FillActionReqdToBeModList(RICactions_RequiredToBeModified_List_t *actionToBeModList, uint8_t numActionsMod,\ + RicSubscription *ricSubscription) { - uint8_t arrIdx = 0, actionIdx = 0; + uint8_t arrIdx = 0; + CmLList *actionNode = NULLP; + ActionInfo *actionDb = NULLP; RICaction_RequiredToBeModified_ItemIEs_t *actionToBeMod = NULL; actionToBeModList->list.count = numActionsMod; @@ -6223,9 +6312,11 @@ uint8_t FillActionReqdToBeModList(RICactions_RequiredToBeModified_List_t *action } arrIdx = 0; - for(actionIdx = 0; actionIdx < MAX_RIC_ACTION; actionIdx++) + CM_LLIST_FIRST_NODE(&ricSubscription->actionSequence, actionNode); + while(actionNode) { - if(ricSubscription->actionSequence[actionIdx].action == CONFIG_MOD) + actionDb = (ActionInfo*)(actionNode->node); + if(actionDb->action == CONFIG_MOD) { DU_ALLOC(actionToBeModList->list.array[arrIdx], sizeof(RICaction_RequiredToBeModified_ItemIEs_t)); if(!actionToBeModList->list.array[arrIdx]) @@ -6240,7 +6331,7 @@ uint8_t FillActionReqdToBeModList(RICactions_RequiredToBeModified_List_t *action actionToBeMod->value.present = \ RICaction_RequiredToBeModified_ItemIEs__value_PR_RICaction_RequiredToBeModified_Item; actionToBeMod->value.choice.RICaction_RequiredToBeModified_Item.ricActionID = \ - ricSubscription->actionSequence[actionIdx].actionId; + actionDb->actionId; actionToBeMod->value.choice.RICaction_RequiredToBeModified_Item.ricTimeToWait = RICtimeToWait_w5ms; arrIdx++; @@ -6250,7 +6341,6 @@ uint8_t FillActionReqdToBeModList(RICactions_RequiredToBeModified_List_t *action return ROK; } #endif - /******************************************************************* * * @brief Fill Action required to be removed list @@ -6271,7 +6361,9 @@ uint8_t FillActionReqdToBeModList(RICactions_RequiredToBeModified_List_t *action uint8_t FillActionReqdToBeRmvList(RICactions_RequiredToBeRemoved_List_t *actionToBeRmvList, uint8_t numActionsRmv, \ RicSubscription *ricSubscription) { - uint8_t arrIdx = 0, actionIdx = 0; + uint8_t arrIdx = 0; + CmLList *actionNode = NULLP; + ActionInfo *actionDb = NULLP; RICaction_RequiredToBeRemoved_ItemIEs_t *actionToBeRmv = NULL; actionToBeRmvList->list.count = numActionsRmv; @@ -6284,9 +6376,11 @@ uint8_t FillActionReqdToBeRmvList(RICactions_RequiredToBeRemoved_List_t *actionT } arrIdx = 0; - for(actionIdx = 0; actionIdx < MAX_RIC_ACTION; actionIdx++) + CM_LLIST_FIRST_NODE(&ricSubscription->actionSequence, actionNode); + while(actionNode) { - if(ricSubscription->actionSequence[actionIdx].action == CONFIG_DEL) + actionDb = (ActionInfo*)(actionNode->node); + if(actionDb->action == CONFIG_DEL) { DU_ALLOC(actionToBeRmvList->list.array[arrIdx], sizeof(RICaction_RequiredToBeRemoved_ItemIEs_t)); if(!actionToBeRmvList->list.array[arrIdx]) @@ -6300,11 +6394,8 @@ uint8_t FillActionReqdToBeRmvList(RICactions_RequiredToBeRemoved_List_t *actionT actionToBeRmv->criticality = CriticalityE2_reject; actionToBeRmv->value.present = \ RICaction_RequiredToBeRemoved_ItemIEs__value_PR_RICaction_RequiredToBeRemoved_Item; - actionToBeRmv->value.choice.RICaction_RequiredToBeRemoved_Item.ricActionID = \ - ricSubscription->actionSequence[actionIdx].actionId; - fillE2Cause(&actionToBeRmv->value.choice.RICaction_RequiredToBeRemoved_Item.cause, \ - ricSubscription->actionSequence[actionIdx].failureCause); - + actionToBeRmv->value.choice.RICaction_RequiredToBeRemoved_Item.ricActionID = actionDb->actionId; + fillE2Cause(&actionToBeRmv->value.choice.RICaction_RequiredToBeRemoved_Item.cause, actionDb->failureCause); arrIdx++; } } @@ -6330,7 +6421,9 @@ uint8_t FillActionReqdToBeRmvList(RICactions_RequiredToBeRemoved_List_t *actionT ******************************************************************/ uint8_t FillRicSubsModRequired(RICsubscriptionModificationRequired_t *ricSubsModReqd, RicSubscription *ricSubscription) { - uint8_t ieIdx = 0, elementCnt=0, actionIdx = 0; + ActionInfo * actionDb=NULLP; + CmLList *actionNode = NULLP; + uint8_t ieIdx = 0, elementCnt=0; uint8_t numActionsMod = 0, numActionsRmv = 0; RICsubscriptionModificationRequired_IEs_t *ricSubsModReqdIe = NULLP; RICactions_RequiredToBeRemoved_List_t *actionToBeRmvList = NULLP; @@ -6341,12 +6434,15 @@ uint8_t FillRicSubsModRequired(RICsubscriptionModificationRequired_t *ricSubsMod #endif /* Count number of Actions to be modified or deleted */ - for(actionIdx = 0; actionIdx < MAX_RIC_ACTION; actionIdx++) + CM_LLIST_FIRST_NODE(&ricSubscription->actionSequence, actionNode); + while(actionNode) { - if(ricSubscription->actionSequence[actionIdx].action == CONFIG_MOD) - numActionsMod++; - else if(ricSubscription->actionSequence[actionIdx].action == CONFIG_DEL) - numActionsRmv++; + actionDb = (ActionInfo*)(actionNode->node); + if(actionDb->action == CONFIG_MOD) + numActionsMod++; + else if(actionDb->action == CONFIG_DEL) + numActionsRmv++; + actionNode = actionNode->next; } /* Count number of IEs to be added to messages */ @@ -6659,6 +6755,7 @@ void procRicSubscriptionModificationConfirm(E2AP_PDU_t *e2apMsg) RicRequestId ricReqId; RanFunction *ranFuncDb = NULLP; CmLList *ricSubsNode = NULLP; + CmLList *actionNode= NULLP; RicSubscription *ricSubsDb = NULLP; ActionInfo *actionDb = NULLP; @@ -6758,7 +6855,7 @@ void procRicSubscriptionModificationConfirm(E2AP_PDU_t *e2apMsg) modCfmListItem = (RICaction_ConfirmedForModification_ItemIEs_t *)modCfmList->list.array[arrIdx]; actionId = modCfmListItem->value.choice.RICaction_ConfirmedForModification_Item.ricActionID; - actionDb = fetchActionInfoFromActionId(actionId, ricSubsDb); + actionDb = fetchActionInfoFromActionId(actionId, ricSubsDb, &actionNode, CONFIG_UNKNOWN); if(!actionDb) { DU_LOG("\nERROR --> E2AP : %s: Action ID [%d] not found", __func__, actionId); @@ -6781,7 +6878,7 @@ void procRicSubscriptionModificationConfirm(E2AP_PDU_t *e2apMsg) { modRefusedListItem = (RICaction_RefusedToBeModified_ItemIEs_t *)modRefusedList->list.array[arrIdx]; actionId = modRefusedListItem->value.choice.RICaction_RefusedToBeModified_Item.ricActionID; - actionDb = fetchActionInfoFromActionId(actionId, ricSubsDb); + actionDb = fetchActionInfoFromActionId(actionId, ricSubsDb, &actionNode, CONFIG_UNKNOWN); if(!actionDb) { DU_LOG("\nERROR --> E2AP : %s: Action ID [%d] not found", __func__, actionId); @@ -6806,16 +6903,16 @@ void procRicSubscriptionModificationConfirm(E2AP_PDU_t *e2apMsg) { rmvCfmListItem = (RICaction_ConfirmedForRemoval_ItemIEs_t *)rmvCfmList->list.array[arrIdx]; actionId = rmvCfmListItem->value.choice.RICaction_ConfirmedForRemoval_Item.ricActionID; - actionDb = fetchActionInfoFromActionId(actionId, ricSubsDb); + actionDb = fetchActionInfoFromActionId(actionId, ricSubsDb, &actionNode, CONFIG_UNKNOWN); if(!actionDb) { DU_LOG("\nERROR --> E2AP : %s: Action ID [%d] not found", __func__, actionId); } else { - deleteActionSequence(actionDb); + cmLListDelFrm(&ricSubsDb->actionSequence, actionNode); + deleteActionSequence(actionNode); actionDb =NULLP; - ricSubsDb->numOfActions--; /* Further handling can include : * Deletion of this action from all DU layers */ @@ -6832,7 +6929,7 @@ void procRicSubscriptionModificationConfirm(E2AP_PDU_t *e2apMsg) { rmvFailListItem = (RICaction_RefusedToBeRemoved_ItemIEs_t *)rmvFailList->list.array[arrIdx]; actionId = rmvFailListItem->value.choice.RICaction_RefusedToBeRemoved_Item.ricActionID; - actionDb = fetchActionInfoFromActionId(actionId, ricSubsDb); + actionDb = fetchActionInfoFromActionId(actionId, ricSubsDb, &actionNode, CONFIG_UNKNOWN); if(!actionDb) { DU_LOG("\nERROR --> E2AP : %s: Action ID [%d] not found", __func__, actionId); @@ -7974,7 +8071,7 @@ void procRicSubscriptionDeleteRequest(E2AP_PDU_t *e2apMsg) break; } - if(BuildAndSendStatsDeleteReq(ricSubsDb) != ROK) + if(BuildAndSendStatsDeleteReq(ricSubsDb, true) != ROK) { DU_LOG("\nERROR --> E2AP : Failed to build and send ric subscription delete req to du layers"); } @@ -9608,6 +9705,289 @@ void freeAperDecodingOfRicSubsModificationReq(E2AP_PDU_t *e2apRicMsg) free(ricSubscriptionModReq->protocolIEs.list.array); } } +/******************************************************************* + * + * @brief Extract RIC Action to be added + * + * @details + * + * Function : extractRicActionToBeAddedForModification + * + * Functionality : This function : + * - [Step -1] Traverse each AddedForModification item indexes. + * - [Step -2] Add each action id related information in + * RicSubscription Db. + * - [Step -3] If failed to store then add action related info in + * pending rsp's rejectedActionList. + * - [Step -4] Else increment action added count + * - [Step -5] If there is even 1 action that can be added, + * return ROK, else RFAILED. + * + * @params[in] RAN Function Database structure + * RIC Subscription Info to be added to RAN function + * RIC Action To Be AddedForModification List received from RIC + * failure Cause + * Pending Subs Mod Rsp Info + * @return ROK - success + * RFAILED - failure + * + ******************************************************************/ +uint8_t extractRicActionToBeAddedForModification(RanFunction *ranFuncDb, RicSubscription *ricSubscriptionInfo, \ + RICactions_ToBeAddedForModification_List_t *actionList, E2FailureCause *failureCause, PendingSubsModRspInfo *subsModRsp) +{ + uint8_t actionAdded=0; + CmLList *actionNode = NULLP; + uint8_t actionIdx = 0; + uint8_t ricActionId = 0; + RICaction_ToBeAddedForModification_ItemIEs_t *actionItem = NULLP; + + if(actionList->list.array) + { + for(actionIdx = 0; actionIdx < actionList->list.count; actionIdx++) + { + /* Step -1 */ + actionItem =(RICaction_ToBeAddedForModification_ItemIEs_t *)actionList->list.array[actionIdx]; + switch(actionItem->id) + { + case ProtocolIE_IDE2_id_RICaction_ToBeAddedForModification_Item: + { + /* Step -2 */ + actionNode = addRicSubsAction(ranFuncDb, (PTR)&actionItem->value.choice.RICaction_ToBeAddedForModification_Item,\ + &ricSubscriptionInfo->actionSequence, ProtocolIE_IDE2_id_RICaction_ToBeAddedForModification_Item, failureCause); + + if(!actionNode) + { + /* Step -3 */ + subsModRsp->addActionStatus.rejectedActionList[subsModRsp->addActionStatus.numOfRejectedActions].id = ricActionId; + if(failureCause->causeType == E2_NOTHING) + { + failureCause->causeType = E2_RIC_REQUEST; + failureCause->cause = E2_CONTROL_FAILED_TO_EXECUTE; + } + memcpy(&subsModRsp->addActionStatus.rejectedActionList[subsModRsp->addActionStatus.numOfRejectedActions].failureCause, \ + failureCause, sizeof(E2FailureCause)); + subsModRsp->addActionStatus.numOfRejectedActions++; + } + else + { + /* Step -4 */ + actionAdded++; + } + break; + } + default: + DU_LOG("\nERROR --> E2AP : Invalid IE received in RicAddedForModificationLst:%ld",actionItem->id); + break; + } + } + } + + /* Step -5 */ + if(actionAdded) + return ROK; + + if(failureCause->causeType == E2_NOTHING) + { + failureCause->causeType = E2_RIC_REQUEST; + failureCause->cause = E2_ACTION_NOT_SUPPORTED; + } + return RFAILED; +} + +/******************************************************************* + * + * @brief Extract RIC Action to be Modified + * + * @details + * + * Function : extractRicActionToBeModifiedForModification + * + * Functionality : This function : + * - [Step -1] Traverse each Modification item indexes. + * - [Step -2] Find each action id related information in + * RicSubscription Db. + * - [Step -3] If not found store the action related info in pending + * rsp's action rejected. + * - [Step -4] If found store the new node in action seq list. + * [Step -4.1] If action failed to store, add the action + * info in pending subscription rsp's rejected list. + * [Step -4.2] If action stored successfully, change the status + * of added action to modified because action added as part of + * ric subscription modification req. + * - [Step -5] If there is even 1 action that can be modified, + * return ROK, else RFAILED. + * + * @params[in] RAN Function Database structure + * RIC Subscription Info to be Modified to RAN function + * RIC Action To Be ModifiedForModification List received from RIC + * failure Cause + * Pending Subs Mod Rsp Info + * @return ROK - success + * RFAILED - failure + * + ******************************************************************/ +uint8_t extractRicActionToBeModifiedForModification(RanFunction *ranFuncDb, RicSubscription *ricSubscriptionInfo, \ + RICactions_ToBeModifiedForModification_List_t *actionList, E2FailureCause *failureCause, PendingSubsModRspInfo *subsModRsp) +{ + uint8_t actionId=0; + uint8_t actionIdx = 0; + uint8_t actionFound=0; + CmLList *actionNode = NULLP; + ActionInfo *actionDb = NULLP; + RICaction_ToBeModifiedForModification_ItemIEs_t *actionItem = NULLP; + + if(actionList->list.array) + { + for(actionIdx = 0; actionIdx < actionList->list.count; actionIdx++) + { + /* [Step -1] */ + actionItem =(RICaction_ToBeModifiedForModification_ItemIEs_t *)actionList->list.array[actionIdx]; + switch(actionItem->id) + { + case ProtocolIE_IDE2_id_RICaction_ToBeModifiedForModification_Item: + { + /* [Step -2] */ + actionId=actionItem->value.choice.RICaction_ToBeModifiedForModification_Item.ricActionID; + actionDb = fetchActionInfoFromActionId(actionId, ricSubscriptionInfo, &actionNode, CONFIG_UNKNOWN); + if(!actionNode) + { + /* [Step -3] */ + subsModRsp->removeActionStatus.rejectedActionList[subsModRsp->modActionStatus.numOfRejectedActions].id = actionDb->actionId; + failureCause->causeType = E2_RIC_REQUEST; + failureCause->cause = E2_ACTION_NOT_SUPPORTED; + memcpy(&subsModRsp->removeActionStatus.rejectedActionList[subsModRsp->modActionStatus.numOfRejectedActions].failureCause, \ + failureCause, sizeof(E2FailureCause)); + subsModRsp->modActionStatus.numOfRejectedActions++; + } + else + { + /* [Step -4] */ + actionNode = NULLP; + actionNode = addRicSubsAction(ranFuncDb, (PTR)&actionItem->value.choice.RICaction_ToBeModifiedForModification_Item,\ + &ricSubscriptionInfo->actionSequence, ProtocolIE_IDE2_id_RICaction_ToBeModifiedForModification_Item, failureCause); + + if(!actionNode) + { + /* [Step -4.1] */ + subsModRsp->modActionStatus.rejectedActionList[subsModRsp->modActionStatus.numOfRejectedActions].id = actionId; + if(failureCause->causeType == E2_NOTHING) + { + failureCause->causeType = E2_RIC_REQUEST; + failureCause->cause = E2_CONTROL_FAILED_TO_EXECUTE; + } + memcpy(&subsModRsp->modActionStatus.rejectedActionList[subsModRsp->modActionStatus.numOfRejectedActions].failureCause, \ + failureCause, sizeof(E2FailureCause)); + subsModRsp->addActionStatus.numOfRejectedActions++; + } + else + { + /* [Step -4.2] */ + actionDb = (ActionInfo*)actionNode->node; + actionDb->action=CONFIG_MOD; + actionFound++; + } + break; + } + break; + } + default: + DU_LOG("\nERROR --> E2AP : Invalid IE received in RicModifiedForModificationLst:%ld",actionItem->id); + break; + } + } + } + + /* [Step -5] */ + if(actionFound) + return ROK; + + return RFAILED; +} + +/******************************************************************* + * + * @brief Extract RIC Action to be Removed + * + * @details + * + * Function : extractRicActionToBeRemovedForModification + * + * Functionality : This function : + * - [Step -1] Traverse each RemovedForModification item indexes. + * - [Step -2] Find each action id related information in + * RicSubscription Db. + * - [Step -3] If not found store the action related info in pending + * rsp's rejectedActionList. + * - [Step -4] If found mark action's status CONFIG_DEL. + * - [Step -5] If there is even 1 action that can be Removed, + * return ROK, else RFAILED. + * + * @params[in] RAN Function Database structure + * RIC Subscription Info to be Removed to RAN function + * RIC Action To Be RemovedForModification List received from RIC + * failure Cause + * Pending ric subs mod Rsp Info to store failure result + * @return ROK - success + * RFAILED - failure + * + ******************************************************************/ +uint8_t extractRicActionToBeRemovedForModification(RanFunction *ranFuncDb, RicSubscription *ricSubscriptionInfo, \ + RICactions_ToBeRemovedForModification_List_t *actionList, E2FailureCause *failureCause, PendingSubsModRspInfo *subsModRsp) +{ + uint8_t actionId=0; + uint8_t actionIdx = 0; + uint8_t actionFound=0; + CmLList *actionNode = NULLP; + ActionInfo *actionDb = NULLP; + RICaction_ToBeRemovedForModification_ItemIEs_t *actionItem = NULLP; + + if(actionList->list.array) + { + for(actionIdx = 0; actionIdx < actionList->list.count; actionIdx++) + { + /* [Step -1] */ + actionItem =(RICaction_ToBeRemovedForModification_ItemIEs_t *)actionList->list.array[actionIdx]; + switch(actionItem->id) + { + case ProtocolIE_IDE2_id_RICaction_ToBeRemovedForModification_Item: + { + /* [Step -2] */ + actionId = actionItem->value.choice.RICaction_ToBeRemovedForModification_Item.ricActionID; + actionDb = fetchActionInfoFromActionId(actionId, ricSubscriptionInfo, &actionNode, CONFIG_UNKNOWN); + if(!actionNode) + { + /* [Step -3] */ + subsModRsp->removeActionStatus.rejectedActionList[subsModRsp->removeActionStatus.numOfRejectedActions].id = actionDb->actionId; + if(failureCause->causeType == E2_NOTHING) + { + failureCause->causeType = E2_RIC_REQUEST; + failureCause->cause = E2_ACTION_NOT_SUPPORTED; + } + memcpy(&subsModRsp->removeActionStatus.rejectedActionList[subsModRsp->removeActionStatus.numOfRejectedActions].failureCause, \ + failureCause, sizeof(E2FailureCause)); + subsModRsp->removeActionStatus.numOfRejectedActions++; + } + else + { + /* [Step -4] */ + actionDb->action=CONFIG_DEL; + actionFound++; + } + break; + } + default: + DU_LOG("\nERROR --> E2AP : Invalid IE received in RicRemovedForModificationLst:%ld",actionItem->id); + break; + } + } + } + + /* [Step -5] */ + if(actionFound) + return ROK; + + return RFAILED; +} /******************************************************************* * @@ -9627,14 +10007,18 @@ void procRicSubscriptionModificationRequest(E2AP_PDU_t *e2apMsg) { uint8_t ieIdx = 0; uint16_t ranFuncId = 0; - bool procFailure = false; RicRequestId ricReqId; - RanFunction *ranFuncDb = NULLP; + E2FailureCause failureCause; + bool procFailure = false; + bool addActionIeProcessed=false; + bool modActionIeProcessed =false; + bool removeActionIeProcessed =false; CmLList *ricSubsNode = NULLP; + RanFunction *ranFuncDb = NULLP; RicSubscription *ricSubsDb = NULLP; RICsubscriptionModificationRequest_t *ricSubsModifyReq = NULLP; RICsubscriptionModificationRequest_IEs_t *ricSubsModifyReqIe = NULLP; - + DU_LOG("\nINFO --> E2AP : %s: Received RIC Subscription Modification Request", __func__); do{ @@ -9649,7 +10033,7 @@ void procRicSubscriptionModificationRequest(E2AP_PDU_t *e2apMsg) DU_LOG("\nERROR --> E2AP : %s: Initiating Message in E2AP PDU is NULL", __func__); break; } - + ricSubsModifyReq = &e2apMsg->choice.initiatingMessage->value.choice.RICsubscriptionModificationRequest; for(ieIdx = 0; ieIdx < ricSubsModifyReq->protocolIEs.list.count; ieIdx++) { @@ -9689,10 +10073,44 @@ void procRicSubscriptionModificationRequest(E2AP_PDU_t *e2apMsg) procFailure = true; break; } + memset(&ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp], 0, sizeof(PendingSubsModRspInfo)); + memcpy(&ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp].requestId, + &ricReqId, sizeof(RicRequestId)); + ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp].ranFuncId = ranFuncId; break; } + case ProtocolIE_IDE2_id_RICactionsToBeRemovedForModification_List: + { + if(extractRicActionToBeRemovedForModification(ranFuncDb, ricSubsDb,\ + &ricSubsModifyReqIe->value.choice.RICactions_ToBeRemovedForModification_List,\ + &failureCause, &ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp]) == ROK) + { + removeActionIeProcessed= true; + } + break; + } + case ProtocolIE_IDE2_id_RICactionsToBeModifiedForModification_List: + { + if(extractRicActionToBeModifiedForModification(ranFuncDb, ricSubsDb,\ + &ricSubsModifyReqIe->value.choice.RICactions_ToBeModifiedForModification_List,\ + &failureCause, &ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp]) == ROK) + { + modActionIeProcessed = true; + } + break; + } + case ProtocolIE_IDE2_id_RICactionsToBeAddedForModification_List: + { + if(extractRicActionToBeAddedForModification(ranFuncDb, ricSubsDb,\ + &ricSubsModifyReqIe->value.choice.RICactions_ToBeAddedForModification_List,\ + &failureCause, &ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp]) == ROK) + { + addActionIeProcessed = true; + } + break; + } default: break; } /* End of switch for Protocol IE Id */ @@ -9703,6 +10121,50 @@ void procRicSubscriptionModificationRequest(E2AP_PDU_t *e2apMsg) break; }while(true); + + if(!removeActionIeProcessed && !addActionIeProcessed && !modActionIeProcessed) + { + BuildAndSendRicSubscriptionModificationFailure(ranFuncId, ricReqId, failureCause); + } + else + { + ricSubsDb->action = CONFIG_MOD; + ranFuncDb->numPendingSubsModRsp++; + + /*If the remove-action ie is present, send a stats delete request; + * otherwise, change removeActionCompleted to true in the pendingSubsModRspInfo. */ + if(removeActionIeProcessed) + { + BuildAndSendStatsDeleteReq(ricSubsDb, false); + } + else + { + ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp-1].removeActionCompleted = true; + } + + /*If the mod-action ie is present, send a stats modification request; + * otherwise, change modActionCompleted to true in the pendingSubsModRspInfo. */ + if(modActionIeProcessed) + { + BuildAndSendStatsModificationReq(ricSubsDb); + } + else + { + ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp-1].modActionCompleted= true; + } + + /*If the add-action ie is present, send a stats add request; + * otherwise, change addActionCompleted to true in the pendingSubsModRspInfo. */ + if(addActionIeProcessed) + { + BuildAndSendStatsReq(ricSubsDb); + } + else + { + ranFuncDb->pendingSubsModRspInfo[ranFuncDb->numPendingSubsModRsp-1].addActionCompleted= true; + } + + } freeAperDecodingOfRicSubsModificationReq(e2apMsg); }