X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrmac%2Frg_ex_ms.c;h=b3bf9a7e0ad13df0dd6d8b55bf287092cb81af64;hb=65443172dd60a6ea312bd3a15959dbf54ad7f045;hp=335a3671e11d66dba568778dd8c45e8ce4f8987e;hpb=e006592159c0a16a4c2f24cc50f712ff9461a000;p=o-du%2Fl2.git diff --git a/src/5gnrmac/rg_ex_ms.c b/src/5gnrmac/rg_ex_ms.c index 335a3671e..b3bf9a7e0 100755 --- a/src/5gnrmac/rg_ex_ms.c +++ b/src/5gnrmac/rg_ex_ms.c @@ -33,17 +33,7 @@ registered with SSI during the LTE MAC Task initialization. */ /* header include files -- defines (.h) */ -#include "envopt.h" /* environment options */ -#include "envdep.h" /* environment dependent */ -#include "envind.h" /* environment independent */ -#include "gen.h" /* general layer */ -#include "ssi.h" /* system services */ -#include "cm5.h" /* common timers defines */ -#include "cm_hash.h" /* common hash list defines */ -#include "cm_llist.h" /* common linked list defines */ -#include "cm_mblk.h" /* memory management */ -#include "cm_tkns.h" /* common tokens */ -#include "cm_lte.h" /* common tokens */ +#include "common_def.h" #include "rgu.h" /* RGU defines */ #include "tfu.h" /* RGU defines */ #include "lrg.h" /* layer management defines for LTE-MAC */ @@ -57,15 +47,6 @@ registered with SSI during the LTE MAC Task initialization. /* header/extern include files (.x) */ -#include "gen.x" /* general layer typedefs */ -#include "ssi.x" /* system services typedefs */ -#include "cm5.x" /* common timers */ -#include "cm_hash.x" /* common hash list */ -#include "cm_lib.x" /* common library */ -#include "cm_llist.x" /* common linked list */ -#include "cm_mblk.x" /* memory management */ -#include "cm_tkns.x" /* common tokens */ -#include "cm_lte.x" /* common tokens */ #include "rgu.x" /* RGU types */ #include "tfu.x" /* RGU types */ #include "lrg.x" /* layer management typedefs for MAC */ @@ -75,7 +56,7 @@ registered with SSI during the LTE MAC Task initialization. #include "rg_prg.x" /*PRG interface includes*/ #include "du_app_mac_inf.h" #include "rg.x" /* typedefs for MAC */ -int unpackDuMacCellCfg(DuMacCellCfgReq func,Pst *pst,Buffer *mBuf); +#include "rlc_mac_inf.h" /** * @brief Task Activation callback function Entity SM. @@ -92,19 +73,17 @@ int unpackDuMacCellCfg(DuMacCellCfgReq func,Pst *pst,Buffer *mBuf); * @return void **/ #ifdef ANSI -PRIVATE INLINE void rgHdlSMEvents +static inline void rgHdlSMEvents ( Pst *pst, /* post structure */ Buffer *mBuf /* message buffer */ ) #else -PRIVATE INLINE void rgHdlSMEvents(pst, mBuf) +static inline void rgHdlSMEvents(pst, mBuf) Pst *pst; /* post structure */ Buffer *mBuf; /* message buffer */ #endif { - TRC2(rgHdlSMEvents) - switch(pst->event) { #ifdef LCRGMILRG @@ -131,20 +110,28 @@ Buffer *mBuf; /* message buffer */ #endif /* LCRGMILRG */ case EVENT_MAC_CELL_CONFIG_REQ: /* Process MAC cell config */ - unpackDuMacCellCfg(MacHdlCellCfgReq, pst, mBuf); + unpackDuMacCellCfg(MacProcCellCfgReq, pst, mBuf); break; case EVENT_MAC_CELL_START_REQ: - /* Process MAC cell start request */ - unpackMacCellStartReq(MacHdlCellStartReq, pst, mBuf); - break; - case EVENT_MAC_CELL_STOP_REQ: - /* Process MAC cell stop request */ - unpackMacCellStopReq(MacHdlCellStopReq, pst, mBuf); - break; - case EVENT_MAC_DL_CCCH_IND: - /* Process DL CCCH Ind */ - unpackMacDlCcchInd(MacHdlDlCcchInd, pst, mBuf); - break; + /* Process MAC cell start request */ + unpackMacCellStartReq(MacProcCellStartReq, pst, mBuf); + break; + case EVENT_MAC_CELL_STOP_REQ: + /* Process MAC cell stop request */ + unpackMacCellStopReq(MacProcCellStopReq, pst, mBuf); + break; + case EVENT_MAC_DL_CCCH_IND: + /* Process DL CCCH Ind */ + unpackMacDlCcchInd(MacProcDlCcchInd, pst, mBuf); + break; + case EVENT_MAC_UE_CREATE_REQ: + /* Process Ue Create Request */ + unpackMacUeCreateReq(MacProcUeCreateReq, pst, mBuf); + break; + case EVENT_MAC_UE_RECONFIG_REQ: + /* Process Ue Reconfig Request */ + unpackMacUeReconfigReq(MacProcUeReconfigReq, pst, mBuf); + break; default: RG_FREE_MSG(mBuf); break; @@ -167,19 +154,17 @@ Buffer *mBuf; /* message buffer */ * @return void **/ #ifdef ANSI -PRIVATE INLINE void rgHdlNHEvents +static inline void rgHdlNHEvents ( Pst *pst, /* post structure */ Buffer *mBuf /* message buffer */ ) #else -PRIVATE INLINE void rgHdlNHEvents(pst, mBuf) +static inline void rgHdlNHEvents(pst, mBuf) Pst *pst; /* post structure */ Buffer *mBuf; /* message buffer */ #endif { - TRC2(rgHdlNHEvents) - switch(pst->event) { #ifdef LCRGUICRG @@ -214,19 +199,17 @@ Buffer *mBuf; /* message buffer */ * @return void **/ #ifdef ANSI -PRIVATE INLINE void rgHdlKWEvents +static inline void rgHdlKWEvents ( Pst *pst, /* post structure */ Buffer *mBuf /* message buffer */ ) #else -PRIVATE INLINE void rgHdlKWEvents(pst, mBuf) +static inline void rgHdlKWEvents(pst, mBuf) Pst *pst; /* post structure */ Buffer *mBuf; /* message buffer */ #endif { - TRC2(rgHdlKWEvents) - switch(pst->event) { #ifdef LCRGUIRGU @@ -236,11 +219,11 @@ Buffer *mBuf; /* message buffer */ case EVTRGUUBNDREQ: cmUnpkRguUbndReq(RgUiRguUbndReq, pst, mBuf); break; - case EVTRLCDLDAT: - unpackDlData(MacRlcProcDlData, pst, mBuf); + case EVENT_DL_DATA_TO_MAC: + unpackRlcDlData(MacProcRlcDlData, pst, mBuf); break; - case EVTRLCBOSTA: - unpackBOStatus(MacRlcProcBOStatus, pst, mBuf); + case EVENT_BO_STATUS_TO_MAC: + unpackRlcBoStatus(MacProcRlcBoStatus, pst, mBuf); break; #ifdef LTE_L2_MEAS @@ -271,19 +254,17 @@ Buffer *mBuf; /* message buffer */ * @return void **/ #ifdef ANSI -PRIVATE INLINE void rgHdlTFEvents +static inline void rgHdlTFEvents ( Pst *pst, /* post structure */ Buffer *mBuf /* message buffer */ ) #else -PRIVATE INLINE void rgHdlTFEvents(pst, mBuf) +static inline void rgHdlTFEvents(pst, mBuf) Pst *pst; /* post structure */ Buffer *mBuf; /* message buffer */ #endif { - TRC2(rgHdlTFEvents) - switch(pst->event) { #if (defined(LCRGLITFU) || defined(LWLCRGLITFU)) @@ -293,9 +274,6 @@ Buffer *mBuf; /* message buffer */ case EVTTFUDATIND: cmUnpkTfuDatInd(RgLiTfuDatInd, pst, mBuf); break; - case EVENT_SLOT_IND_TO_MAC: - cmUnpackSlotInd(fapiMacSlotInd, pst, mBuf); - break; #if defined(TENB_T2K3K_SPECIFIC_CHANGES) && defined(LTE_TDD) case EVTTFUNONRTIND: cmUnpkTfuNonRtInd(RgLiTfuNonRtInd, pst, mBuf); @@ -324,19 +302,17 @@ Buffer *mBuf; /* message buffer */ * @return void **/ #ifdef ANSI -PRIVATE INLINE void rgHdlRGEvents +static inline void rgHdlRGEvents ( Pst *pst, /* post structure */ Buffer *mBuf /* message buffer */ ) #else -PRIVATE INLINE void rgHdlRGEvents(pst, mBuf) +static inline void rgHdlRGEvents(pst, mBuf) Pst *pst; /* post structure */ Buffer *mBuf; /* message buffer */ #endif { - TRC2(rgHdlRGEvents) - switch(pst->event) { #ifdef LCRG @@ -450,19 +426,17 @@ Buffer *mBuf; /* message buffer */ * -# ROK **/ #ifdef ANSI -PUBLIC S16 rgActvTsk +S16 rgActvTsk ( Pst *pst, /* post structure */ Buffer *mBuf /* message buffer */ ) #else -PUBLIC S16 rgActvTsk(pst, mBuf) +S16 rgActvTsk(pst, mBuf) Pst *pst; /* post structure */ Buffer *mBuf; /* message buffer */ #endif { - TRC2(rgActvTsk) - switch(pst->srcEnt) { /* The originator of this message is the stack manager, @@ -473,21 +447,21 @@ Buffer *mBuf; /* message buffer */ case ENTNH: rgHdlNHEvents(pst, mBuf); break; - case ENTKW: + case ENTRLC: rgHdlKWEvents(pst, mBuf); break; - case ENTTF: + case ENTLWRMAC: rgHdlTFEvents(pst, mBuf); break; - case ENTRG: /* When scheduler instance sends msg to MAC */ + case ENTMAC: /* When scheduler instance sends msg to MAC */ rgHdlRGEvents(pst, mBuf); break; default: RG_FREE_MSG(mBuf); break; } - SExitTsk(); - RETVALUE(ROK); + ODU_EXIT_TASK(); + return ROK; }/* end of rgActvTsk */