X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrmac%2Fmac_msg_router.c;h=a34809dbdca45c26510094db5f767e53aa24f9ca;hb=de6a435729e3cad9d4a66329080b8206a64f452c;hp=edb6639853c3a6e87dbf700ce194528439352dcc;hpb=ef723e2e773fc6a6dcff43005569e509201df198;p=o-du%2Fl2.git diff --git a/src/5gnrmac/mac_msg_router.c b/src/5gnrmac/mac_msg_router.c index edb663985..a34809dbd 100755 --- a/src/5gnrmac/mac_msg_router.c +++ b/src/5gnrmac/mac_msg_router.c @@ -104,40 +104,85 @@ Buffer *mBuf /* message buffer */ break; #endif /* LCRGMILRG */ case EVENT_MAC_CELL_CONFIG_REQ: - /* Process MAC cell config */ - unpackDuMacCellCfg(MacProcCellCfgReq, pst, mBuf); - break; + { + /* Process MAC cell config */ + unpackDuMacCellCfg(MacProcCellCfgReq, pst, mBuf); + break; + } case EVENT_MAC_CELL_START: - /* Process MAC cell start request */ - unpackMacCellStart(MacProcCellStart, pst, mBuf); - break; + { + /* Process MAC cell start request */ + unpackMacCellStart(MacProcCellStart, pst, mBuf); + break; + } case EVENT_MAC_CELL_STOP: - /* Process MAC cell stop request */ - unpackMacCellStop(MacProcCellStop, pst, mBuf); - break; + { + /* Process MAC cell stop request */ + unpackMacCellStop(MacProcCellStop, pst, mBuf); + break; + } case EVENT_MAC_DL_CCCH_IND: - /* Process DL CCCH Ind */ - unpackMacDlCcchInd(MacProcDlCcchInd, pst, mBuf); - break; + { + /* Process DL CCCH Ind */ + unpackMacDlCcchInd(MacProcDlCcchInd, pst, mBuf); + break; + } case EVENT_MAC_UE_CREATE_REQ: - /* Process Ue Create Request */ - unpackMacUeCreateReq(MacProcUeCreateReq, pst, mBuf); - break; + { + /* Process Ue Create Request */ + unpackMacUeCreateReq(MacProcUeCreateReq, pst, mBuf); + break; + } case EVENT_MAC_UE_RECONFIG_REQ: - /* Process Ue Reconfig Request */ - unpackMacUeReconfigReq(MacProcUeReconfigReq, pst, mBuf); - break; - case EVENT_MAC_UE_DELETE_REQ: - { - unpackMacUeDeleteReq(MacProcUeDeleteReq, pst, mBuf); - break; - } - case EVENT_MAC_CELL_DELETE_REQ: - { - unpackMacCellDeleteReq(MacProcCellDeleteReq, pst, mBuf); - break; - } - default: + { + /* Process Ue Reconfig Request */ + unpackMacUeReconfigReq(MacProcUeReconfigReq, pst, mBuf); + break; + } + case EVENT_MAC_UE_DELETE_REQ: + { + /* Process UE Delete Request */ + unpackMacUeDeleteReq(MacProcUeDeleteReq, pst, mBuf); + break; + } + case EVENT_MAC_CELL_DELETE_REQ: + { + /* Process Cell Delete Request */ + unpackMacCellDeleteReq(MacProcCellDeleteReq, pst, mBuf); + break; + } + case EVENT_MAC_SLICE_CFG_REQ: + { + /* Process Slice Configuration Request */ + unpackMacSliceCfgReq(MacProcSliceCfgReq, pst, mBuf); + break; + } + case EVENT_MAC_SLICE_RECFG_REQ: + { + /* Process Slice Reconfiguration Request */ + unpackMacSliceCfgReq(MacProcSliceReCfgReq, pst, mBuf); + break; + } + case EVENT_MAC_RACH_RESOURCE_REQ: + { + /* Process Rach Resource Request */ + unpackMacRachRsrcReq(MacProcRachRsrcReq, pst, mBuf); + break; + } + case EVENT_MAC_RACH_RESOURCE_REL: + { + /* Process Rach Resource Release */ + unpackMacRachRsrcRel(MacProcRachRsrcRel, pst, mBuf); + break; + } + case EVENT_MAC_DL_PCCH_IND: + { + /* Process Pcch indication */ + unpackMacDlPcchInd(MacProcDlPcchInd, pst, mBuf); + break; + } + + default: RG_FREE_MSG(mBuf); break; } @@ -391,8 +436,227 @@ Buffer *mBuf /* message buffer */ } } +/** +* @brief Function prints src, dest, msg infor about all the msgs that received. +* +* @details +* +* Function : callFlowRgActvTsk +* +* Function prints src, dest, msg infor about all the msgs that received +* +* @param[in] Pst *pst, Post structure of the primitive. +* +* @return void +**/ + +void callFlowRgActvTsk(Pst *pst) +{ + char sourceTask[50]; + char destTask[50]="ENTMAC"; + char message[100]; + + switch(pst->srcEnt) + { + case ENTDUAPP: + { + strcpy(sourceTask,"ENTDUAPP"); + switch(pst->event) + { +#ifdef LCRGMILRG + case EVTLRGCFGREQ: + strcpy(message,"EVTLRGCFGREQ"); + break; + case EVTMACSCHGENCFGREQ: + strcpy(message,"EVTMACSCHGENCFGREQ"); + break; + case EVTLRGCNTRLREQ: + strcpy(message,"EVTLRGCNTRLREQ"); + break; + case EVTLRGSSTAREQ: + strcpy(message,"EVTLRGSSTAREQ"); + break; + case EVTLRGSTSREQ: + strcpy(message,"EVTLRGSTSREQ"); + break; +#endif /* LCRGMILRG */ + case EVENT_MAC_CELL_CONFIG_REQ: + strcpy(message,"EVENT_MAC_CELL_CONFIG_REQ"); + break; + case EVENT_MAC_CELL_START: + strcpy(message,"EVENT_MAC_CELL_START"); + break; + case EVENT_MAC_CELL_STOP: + strcpy(message,"EVENT_MAC_CELL_STOP"); + break; + case EVENT_MAC_DL_CCCH_IND: + strcpy(message,"EVENT_MAC_DL_CCCH_IND"); + break; + case EVENT_MAC_UE_CREATE_REQ: + strcpy(message,"EVENT_MAC_UE_CREATE_REQ"); + break; + case EVENT_MAC_UE_RECONFIG_REQ: + strcpy(message,"EVENT_MAC_UE_RECONFIG_REQ"); + break; + case EVENT_MAC_UE_DELETE_REQ: + strcpy(message,"EVENT_MAC_UE_DELETE_REQ"); + break; + case EVENT_MAC_CELL_DELETE_REQ: + strcpy(message,"EVENT_MAC_CELL_DELETE_REQ"); + break; + case EVENT_MAC_SLICE_CFG_REQ: + strcpy(message,"EVENT_MAC_SLICE_CFG_REQ"); + break; + case EVENT_MAC_SLICE_RECFG_REQ: + strcpy(message,"EVENT_MAC_SLICE_RECFG_REQ"); + break; + default: + strcpy(message,"Invalid Event"); + break; + } + break; + } + case ENTRLC: + { + strcpy(sourceTask,"ENTRLC"); + switch(pst->event) + { +#ifdef LCRGUIRGU + case EVTRGUBNDREQ: + strcpy(message,"EVTRGUBNDREQ"); + break; + case EVTRGUUBNDREQ: + strcpy(message,"EVTRGUUBNDREQ"); + break; + case EVENT_DL_DATA_TO_MAC: + strcpy(message,"EVENT_DL_DATA_TO_MAC"); + break; + case EVENT_BO_STATUS_TO_MAC: + strcpy(message,"EVENT_BO_STATUS_TO_MAC"); + break; +#endif + default: + strcpy(message,"Invalid Event"); + break; + } + + break; + } + case ENTLWRMAC: + { + strcpy(sourceTask,"ENTLWRMAC"); + switch(pst->event) + { + case EVENT_SLOT_IND_TO_MAC: + strcpy(message,"EVENT_SLOT_IND_TO_MAC"); + break; + case EVENT_STOP_IND_TO_MAC: + strcpy(message,"EVENT_STOP_IND_TO_MAC"); + break; + case EVENT_RACH_IND_TO_MAC: + strcpy(message,"EVENT_RACH_IND_TO_MAC"); + break; + case EVENT_CRC_IND_TO_MAC: + strcpy(message,"EVENT_CRC_IND_TO_MAC"); + break; + case EVENT_RX_DATA_IND_TO_MAC: + strcpy(message,"EVENT_RX_DATA_IND_TO_MAC"); + break; + case EVENT_UCI_IND_TO_MAC: + strcpy(message,"EVENT_UCI_IND_TO_MAC"); + break; + default: + strcpy(message,"Invalid Event"); + break; + } + + break; + } + case ENTMAC: /* When scheduler instance sends msg to MAC */ + { + strcpy(sourceTask,"ENTMAC"); + switch(pst->event) + { +#ifdef LCRG + case EVTINFCELLREGREQ: + strcpy(message,"EVTINFCELLREGREQ"); + break; + case EVTINFSFALLOCREQ: + strcpy(message,"EVTINFSFALLOCREQ"); + break; + case EVTINFRLSHQREQ: + strcpy(message,"EVTINFRLSHQREQ"); + break; + case EVTINFHQENTRESET: + strcpy(message,"EVTINFHQENTRESET"); + break; + case EVTINFRLSRNTIREQ: + strcpy(message,"EVTINFRLSRNTIREQ"); + break; +#ifdef LTEMAC_SPS + case EVTINFSPSLCREG: + strcpy(message,"EVTINFSPSLCREG"); + break; + case EVTINFSPSLCDEREG: + strcpy(message,"EVTINFSPSLCDEREG"); + break; + case EVTINFSPSRESET: + strcpy(message,"EVTINFSPSRESET"); + break; +#endif /* LTEMAC_SPS */ + case EVTINFLCGREG: + strcpy(message,"EVTINFLCGREG"); + break; +#endif +#if defined(LTE_ADV) && defined(LCPRG) + case EVTPRGUESCELLCFGREQ: + strcpy(message,"EVTPRGUESCELLCFGREQ"); + break; + case EVTPRGUESCELLCFGCFM: + strcpy(message,"EVTPRGUESCELLCFGCFM"); + break; + case EVTPRGUESCELLLCHMODCFM: + strcpy(message,"EVTPRGUESCELLLCHMODCFM"); + break; + case EVTPRGUESCELLLCHDELCFMDEL: + strcpy(message,"EVTPRGUESCELLLCHDELCFMDEL"); + break; + case EVTPRGUESCELLLCHADDCFM: + strcpy(message,"EVTPRGUESCELLLCHADDCFM"); + break; + case EVTPRGUESCELLDELREQ: + strcpy(message,"EVTPRGUESCELLDELREQ"); + break; + case EVTPRGUESCELLLCHMODREQ: + strcpy(message,"EVTPRGUESCELLLCHMODREQ"); + break; + case EVTPRGUESCELLLCHDELREQ: + strcpy(message,"EVTPRGUESCELLLCHDELREQ"); + break; + case EVTPRGUESCELLLCHADDREQ: + strcpy(message,"EVTPRGUESCELLLCHADDREQ"); + break; + +#endif + default: + strcpy(message,"Invalid Event"); + break; + } + break; + } + + default: + { + strcpy(sourceTask,"Invalid Source Entity Id"); + break; + } + } + DU_LOG("\nCall Flow: %s -> %s : %s\n", sourceTask, destTask, message); +} +/********************************************************************** + /** * @brief Task Activation callback function. * @@ -417,6 +681,11 @@ Pst *pst, /* post structure */ Buffer *mBuf /* message buffer */ ) { + +#ifdef CALL_FLOW_DEBUG_LOG + callFlowRgActvTsk(pst); +#endif + switch(pst->srcEnt) { /* The originator of this message is the stack manager,