X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fdu_app%2Fdu_ue_mgr.c;h=9c660efe069f3a206b96f06b04d1567cb85380c2;hb=9f07d42c8d327e4009833fc4c673e4086c4e726e;hp=96a496ffed3a09b1b9fd6cf429d923a0dec361bf;hpb=fe5d6711157dc1d3308a9754893b58b3872cd81a;p=o-du%2Fl2.git diff --git a/src/du_app/du_ue_mgr.c b/src/du_app/du_ue_mgr.c index 96a496ffe..9c660efe0 100644 --- a/src/du_app/du_ue_mgr.c +++ b/src/du_app/du_ue_mgr.c @@ -514,36 +514,6 @@ uint8_t duProcDlRrcMsg(F1DlRrcMsg *dlRrcMsg) return ret; } -/****************************************************************** - * - * @brief Generates GNB DU Ue F1AP ID - * - * @details - * - * Function : genGnbDuUeF1apId - * - * Functionality: Generates GNB DU Ue F1AP ID - * - * @params[in] void - * @return gnbDuF1apId - * - * ****************************************************************/ -int32_t genGnbDuUeF1apId(uint8_t cellId) -{ - uint8_t cellIdx =0; - - GET_CELL_IDX(cellId, cellIdx); - if(duCb.actvCellLst[cellIdx]) - { - return ++duCb.gnbDuUeF1apIdGenerator; - } - else - { - DU_LOG("ERROR --> DU_APP : genGnbDuUeF1apId(): CellId[%d] does not exist", cellId); - } - return -1; -} - /****************************************************************** * * @brief Processes UL CCCH Ind recvd from MAC @@ -565,14 +535,16 @@ uint8_t duProcUlCcchInd(UlCcchIndInfo *ulCcchIndInfo) uint8_t ret = ROK; int32_t gnbDuUeF1apId = 0; - gnbDuUeF1apId = genGnbDuUeF1apId(ulCcchIndInfo->cellId); - - if(gnbDuUeF1apId == -1) + if(ulCcchIndInfo->crnti) + { + GET_UE_ID(ulCcchIndInfo->crnti, gnbDuUeF1apId); + } + else { - DU_LOG("ERROR --> DU_APP : duProcUlCcchInd(): Received cellId[%d] does not exist", ulCcchIndInfo->cellId); + DU_LOG("\nERROR --> DU_APP : Received invalid CRNTI [%d] ", ulCcchIndInfo->crnti); return RFAILED; } - + /* Store Ue mapping */ duCb.ueCcchCtxt[duCb.numUe].gnbDuUeF1apId = (uint32_t)gnbDuUeF1apId; duCb.ueCcchCtxt[duCb.numUe].crnti = ulCcchIndInfo->crnti; @@ -3012,11 +2984,13 @@ void deleteMacUeCfg(MacUeCfg *ueCfg) * RFAILED - failure * * ****************************************************************/ -uint8_t deleteUeCfg(uint16_t cellIdx, uint8_t ueId) +uint8_t deleteUeCfg(uint16_t cellId, uint8_t ueId) { uint8_t tnlIdx = 0; + uint16_t cellIdx = 0; DuUeCb *ueCb = NULLP; + GET_CELL_IDX(cellId, cellIdx); if(duCb.actvCellLst[cellIdx] != NULLP) { if((duCb.actvCellLst[cellIdx]->ueCb[ueId-1].macUeCfg.macUeCfgState == UE_DELETE_COMPLETE)\ @@ -3039,6 +3013,7 @@ uint8_t deleteUeCfg(uint16_t cellIdx, uint8_t ueId) else tnlIdx++; } + unsetBitInUeBitMap(cellId, ueId-1); duCb.actvCellLst[cellIdx]->numActvUes--; memset(ueCb, 0, sizeof(DuUeCb)); } @@ -3088,9 +3063,9 @@ uint8_t DuProcMacUeDeleteRsp(Pst *pst, MacUeDeleteRsp *deleteRsp) { duCb.actvCellLst[cellIdx]->ueCb[deleteRsp->ueId -1].macUeCfg.macUeCfgState = UE_DELETE_COMPLETE; ueId = deleteRsp->ueId; - gnbCuUeF1apId = duCb.actvCellLst[cellIdx]->ueCb[ueId-1].gnbDuUeF1apId; - gnbDuUeF1apId = duCb.actvCellLst[cellIdx]->ueCb[ueId-1].gnbCuUeF1apId; - if(deleteUeCfg(cellIdx, ueId) == ROK) + gnbCuUeF1apId = duCb.actvCellLst[cellIdx]->ueCb[ueId-1].gnbCuUeF1apId; + gnbDuUeF1apId = duCb.actvCellLst[cellIdx]->ueCb[ueId-1].gnbDuUeF1apId; + if(deleteUeCfg(deleteRsp->cellId, ueId) == ROK) { ret = BuildAndSendUeContextReleaseComplete(deleteRsp->cellId, gnbCuUeF1apId, gnbDuUeF1apId); if(ret != ROK)