X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fdu_app%2Fdu_mgr_msg_router.c;h=133ef0a59986a4ae1e1c1832af0f4584a95f9ff0;hb=refs%2Fchanges%2F15%2F9315%2F5;hp=75daa2075033df96c4643f8bb95d4eb457d13f2d;hpb=3364273455756ae289662a274d5bcbf391ecd58e;p=o-du%2Fl2.git diff --git a/src/du_app/du_mgr_msg_router.c b/src/du_app/du_mgr_msg_router.c index 75daa2075..133ef0a59 100644 --- a/src/du_app/du_mgr_msg_router.c +++ b/src/du_app/du_mgr_msg_router.c @@ -96,6 +96,7 @@ uint8_t duActvInit(Ent entity, Inst inst, Region region, Reason reason) memset(duCb.ueCcchCtxt, 0, MAX_NUM_UE * sizeof(UeCcchCtxt)); duCb.numCfgCells = 0; duCb.numActvCells = 0; + duCb.gnbDuUeF1apIdGenerator = 0; cmLListInit(&duCb.reservedF1apPduList); ODU_SET_PROC_ID(DU_PROC); @@ -243,6 +244,11 @@ void callFlowduActvTsk(Pst *pst) strcpy(message,"EVENT_MAC_CELL_UP_IND"); break; } + case EVENT_MAC_SLOT_IND: + { + strcpy(message,"EVENT_MAC_SLOT_IND"); + break; + } case EVENT_MAC_STOP_IND: { strcpy(message,"EVENT_MAC_STOP_IND"); @@ -461,6 +467,11 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = unpackRlcUlUserDataToDu(DuProcRlcUlUserDataTrans, pst, mBuf); break; } + case EVENT_RLC_SLICE_PM_TO_DU: + { + ret = unpackRlcSlicePm(DuProcRlcSliceMetrics, pst, mBuf); + break; + } default: { DU_LOG("\nERROR --> DU_APP : Invalid event %d received at duActvTsk from ENTRLC", \ @@ -505,6 +516,11 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = unpackMacCellUpInd(duHandleCellUpInd, pst, mBuf); break; } + case EVENT_MAC_SLOT_IND: + { + ret = unpackDuMacSlotInd(duHandleSlotInd, pst, mBuf); + break; + } case EVENT_MAC_STOP_IND: { ret = unpackMacStopInd(duHandleStopInd, pst, mBuf); @@ -545,6 +561,11 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = unpackDuMacSliceReCfgRsp(DuProcMacSliceReCfgRsp, pst, mBuf); break; } + case EVENT_MAC_RACH_RESOURCE_RSP: + { + ret = unpackDuMacRachRsrcRsp(DuProcMacRachRsrcRsp, pst, mBuf); + break; + } default: { DU_LOG("\nERROR --> DU_APP : Invalid event received at duActvTsk from ENTMAC");