X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Fdu_app%2Fdu_mgr_msg_router.c;h=a1112d0515c65abb093e34ce2da21edc68c59350;hb=6dc8a4c17da24847b3a3aee91b37151f77a8a5bc;hp=79f7cc7c241fa38e859d22cc0d80ce68cf7af446;hpb=40d79285fedc8551f3f0e43ba01123d367c09248;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 79f7cc7c2..a1112d051 100644 --- a/src/du_app/du_mgr_msg_router.c +++ b/src/du_app/du_mgr_msg_router.c @@ -18,6 +18,7 @@ /* File : du_mgr_msg_router.c */ /* This file contains message handling functionality for DU APP */ #include "common_def.h" +#include "du_tmr.h" #include "lrg.h" #include "legtp.h" #include "lsctp.h" @@ -29,13 +30,14 @@ #include "kwu.x" #include "du_app_mac_inf.h" #include "du_app_rlc_inf.h" +#include "du_e2ap_mgr.h" +#include "du_e2ap_msg_hdl.h" #include "du_cfg.h" #include "du_mgr.h" #include "E2AP-PDU.h" #include "du_sctp.h" #include "F1AP-PDU.h" #include "du_f1ap_msg_hdl.h" -#include "du_e2ap_msg_hdl.h" #include "du_app_mac_inf.h" #include "du_ue_mgr.h" #include "du_utils.h" @@ -285,6 +287,21 @@ void callFlowduActvTsk(Pst *pst) strcpy(message,"EVENT_MAC_SLICE_RECFG_RSP"); break; } + case EVENT_MAC_STATISTICS_RSP: + { + strcpy(message,"EVENT_MAC_STATISTICS_RSP"); + break; + } + case EVENT_MAC_STATISTICS_IND: + { + strcpy(message,"EVENT_MAC_STATISTICS_IND"); + break; + } + case EVENT_MAC_STATS_DELETE_RSP: + { + strcpy(message,"EVENT_MAC_STATS_DELETE_RSP"); + break; + } default: { strcpy(message,"Invalid Event"); @@ -432,12 +449,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: @@ -460,6 +477,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); @@ -532,7 +554,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: @@ -575,6 +597,21 @@ uint8_t duActvTsk(Pst *pst, Buffer *mBuf) ret = unpackDuMacUeResetRsp(DuProcMacUeResetRsp, pst, mBuf); break; } + case EVENT_MAC_STATISTICS_RSP: + { + ret = unpackDuMacStatsRsp(DuProcMacStatsRsp, pst, mBuf); + break; + } + case EVENT_MAC_STATISTICS_IND: + { + ret = unpackDuMacStatsInd(DuProcMacStatsInd, pst, mBuf); + break; + } + case EVENT_MAC_STATS_DELETE_RSP: + { + ret = unpackDuMacStatsDeleteRsp(DuProcMacStatsDeleteRsp, pst, mBuf); + break; + } default: { DU_LOG("\nERROR --> DU_APP : Invalid event received at duActvTsk from ENTMAC");