X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fdu_app%2Fdu_mgr_msg_router.c;h=da12de625e3440bdffc96f03178aff9d51baf68b;hb=52ca0cf30806914e2f44054932cd2300f12aded8;hp=df6db7bf587243291d628f310626e920de9d75b4;hpb=ca0353e5cb5699aecb6840efe9572934a1150e2b;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 df6db7bf5..da12de625 100644 --- a/src/du_app/du_mgr_msg_router.c +++ b/src/du_app/du_mgr_msg_router.c @@ -104,6 +104,7 @@ uint8_t duActvInit(Ent entity, Inst inst, Region region, Reason reason) } +#ifdef CALL_FLOW_DEBUG_LOG /************************************************************************** * @brief Function prints the src dest and msg reached to egtp. * @@ -224,11 +225,6 @@ void callFlowduActvTsk(Pst *pst) strcpy(message,"EVTLRGCFGCFM"); break; } - case EVTLRGCNTRLCFM: - { - strcpy(message,"EVTLRGCNTRLCFM"); - break; - } case EVTMACSCHGENCFGCFM: { strcpy(message,"EVTMACSCHGENCFGCFM"); @@ -363,6 +359,8 @@ void callFlowduActvTsk(Pst *pst) } DU_LOG("\nCall Flow: %s -> %s : %s\n", sourceTask, destTask, message); } +#endif + /************************************************************************** * @brief Task Activation callback function. * @@ -434,12 +432,12 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) } case EVENT_RLC_UE_CREATE_RSP: { - ret = unpackRlcUeCfgRsp(DuProcRlcUeCfgRsp, pst, mBuf); + ret = unpackRlcUeCreateRsp(DuProcRlcUeCreateRsp, pst, mBuf); break; } case EVENT_RLC_UE_RECONFIG_RSP: { - ret = unpackRlcUeCfgRsp(DuProcRlcUeCfgRsp, pst, mBuf); + ret = unpackRlcUeReconfigRsp(DuProcRlcUeReconfigRsp, pst, mBuf); break; } case EVENT_RLC_UE_DELETE_RSP: @@ -462,6 +460,11 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = unpackRlcDlRrcMsgRspToDu(DuProcRlcDlRrcMsgRsp, pst, mBuf); break; } + case EVENT_RLC_MAX_RETRANSMISSION: + { + ret = unpackRlcMaxRetransInd(DuProcRlcMaxRetransInd, pst, mBuf); + break; + } case EVENT_UL_USER_DATA_TRANS_TO_DU: { ret = unpackRlcUlUserDataToDu(DuProcRlcUlUserDataTrans, pst, mBuf); @@ -472,6 +475,11 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = unpackRlcSlicePm(DuProcRlcSliceMetrics, pst, mBuf); break; } + case EVENT_RLC_UE_REESTABLISH_RSP: + { + ret = unpackRlcUeReestablishRsp(DuProcRlcUeReestablishRsp, pst, mBuf); + break; + } default: { DU_LOG("\nERROR --> DU_APP : Invalid event %d received at duActvTsk from ENTRLC", \ @@ -497,10 +505,6 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = cmUnpkLrgCfgCfm(duHdlMacCfgComplete, pst, mBuf); break; } - case EVTLRGCNTRLCFM: - { - break; - } case EVTMACSCHGENCFGCFM: { ret = cmUnpkLrgSchCfgCfm(duHdlSchCfgComplete, pst, mBuf); @@ -533,7 +537,7 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) } case EVENT_MAC_UE_CREATE_RSP: { - ret = unpackDuMacUeCfgRsp(DuProcMacUeCfgRsp, pst, mBuf); + ret = unpackDuMacUeCreateRsp(DuProcMacUeCreateRsp, pst, mBuf); break; } case EVENT_MAC_UE_RECONFIG_RSP: @@ -556,6 +560,11 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = unpackDuMacSliceCfgRsp(DuProcMacSliceCfgRsp, pst, mBuf); break; } + case EVENT_MAC_UE_SYNC_STATUS_IND: + { + ret = unpackDuMacUeSyncStatusInd(DuProcMacUeSyncStatusInd, pst, mBuf); + break; + } case EVENT_MAC_SLICE_RECFG_RSP: { ret = unpackDuMacSliceRecfgRsp(DuProcMacSliceRecfgRsp, pst, mBuf); @@ -566,6 +575,11 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = unpackDuMacRachRsrcRsp(DuProcMacRachRsrcRsp, pst, mBuf); break; } + case EVENT_MAC_UE_RESET_RSP: + { + ret = unpackDuMacUeResetRsp(DuProcMacUeResetRsp, pst, mBuf); + break; + } default: { DU_LOG("\nERROR --> DU_APP : Invalid event received at duActvTsk from ENTMAC");