X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrmac%2Frg_prg.c;h=a8dbcb7634cccb6ad94c205c2a793c5366cb2ed2;hb=5d74fef7c9fe6b65a965ceac6bfe812872dab323;hp=b4d3f9cfb95e22b1b884139cace8bedac3c4b92b;hpb=5625a52ad68f6ad93684e68bbbdbaef0d462cf9a;p=o-du%2Fl2.git diff --git a/src/5gnrmac/rg_prg.c b/src/5gnrmac/rg_prg.c index b4d3f9cfb..a8dbcb763 100755 --- a/src/5gnrmac/rg_prg.c +++ b/src/5gnrmac/rg_prg.c @@ -29,16 +29,7 @@ **********************************************************************/ /* 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 service interface */ -#include "cm_hash.h" /* common hash list */ -#include "cm_mblk.h" /* common memory link list library */ -#include "cm_llist.h" /* common linked list library */ -#include "cm_err.h" /* common error */ -#include "cm_lte.h" /* common LTE */ +#include "common_def.h" #include "lrg.h" #include "crg.h" #include "rgu.h" @@ -50,21 +41,13 @@ #include "rg_err.h" /* 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 */ #include "crg.x" /* layer management typedefs for MAC */ #include "rg_sch_inf.x" /* layer management typedefs for MAC */ #include "rg_prg.x" /* Prg(MAC-MAC)interface includes */ +#include "du_app_mac_inf.h" #include "rg.x" /* typedefs for MAC */ #ifdef LTE_ADV @@ -83,35 +66,33 @@ * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmPkPrgPMacSMacUeSCellCfgReq +S16 cmPkPrgPMacSMacUeSCellCfgReq ( Pst *pst, RgPrgUeSCellCfgInfo *ueSCellCfgInfo ) #else -PUBLIC S16 cmPkPrgPMacSMacUeSCellCfgReq(pst, ueSCellCfgInfo) +S16 cmPkPrgPMacSMacUeSCellCfgReq(pst, ueSCellCfgInfo) Pst *pst; RgPrgUeSCellCfgInfo *ueSCellCfgInfo; #endif { Buffer *mBuf = NULLP; - TRC2(cmPkPrgPMacSMacUeSCellCfgReq) - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) { - RETVALUE(RFAILED); + return RFAILED; } if(SAddPstMsgMult((Data *)ueSCellCfgInfo, sizeof(RgPrgUeSCellCfgInfo),\ mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } pst->event = (Event) EVTPRGUESCELLCFGREQ; - RETVALUE(SPstTsk(pst,mBuf)); + return (SPstTsk(pst,mBuf)); } /** @@ -128,14 +109,14 @@ RgPrgUeSCellCfgInfo *ueSCellCfgInfo; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellCfgReq +S16 cmUnpkPrgPMacSMacUeSCellCfgReq ( RgPrgUeSCellCfgReq func, Pst *pst, Buffer *mBuf ) #else -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellCfgReq(func, pst, mBuf) +S16 cmUnpkPrgPMacSMacUeSCellCfgReq(func, pst, mBuf) RgPrgUeSCellCfgReq func; Pst *pst; Buffer *mBuf; @@ -143,16 +124,14 @@ Buffer *mBuf; { RgPrgUeSCellCfgInfo ueSCellCfgInfo; - TRC2(cmUnpkPrgPMacSMacUeSCellCfgReq) - if(SRemPreMsgMult((Data *)&ueSCellCfgInfo, sizeof(RgPrgUeSCellCfgInfo), mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } RGPRG_FREE_MSG(mBuf); - RETVALUE((*func)(pst, &ueSCellCfgInfo)); + return ((*func)(pst, &ueSCellCfgInfo)); } /** @@ -169,30 +148,28 @@ Buffer *mBuf; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmPkPrgSMacPMacCfgCfm +S16 cmPkPrgSMacPMacCfgCfm ( Pst *pst, RgPrgCfgCfmInfo *cfgCfm ) #else -PUBLIC S16 cmPkPrgSMacPMacCfgCfm(pst, cfgCfm) +S16 cmPkPrgSMacPMacCfgCfm(pst, cfgCfm) Pst *pst; RgPrgCfgCfmInfo *cfgCfm; #endif { Buffer *mBuf = NULLP; - TRC2(cmPkPrgSMacPMacCfgCfm) - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) { - RETVALUE(RFAILED); + return RFAILED; } if(SAddPstMsgMult((Data *)cfgCfm, sizeof(RgPrgCfgCfmInfo), mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } switch(cfgCfm->event) { @@ -217,7 +194,7 @@ RgPrgCfgCfmInfo *cfgCfm; } break; } - RETVALUE(SPstTsk(pst,mBuf)); + return (SPstTsk(pst,mBuf)); } /** @@ -235,14 +212,14 @@ RgPrgCfgCfmInfo *cfgCfm; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmUnpkPrgSMacPMacCfgCfm +S16 cmUnpkPrgSMacPMacCfgCfm ( RgSMacPMacCfgCfm func, Pst *pst, Buffer *mBuf ) #else -PUBLIC S16 cmUnpkPrgSMacPMacCfgCfm(func, pst, mBuf) +S16 cmUnpkPrgSMacPMacCfgCfm(func, pst, mBuf) RgSMacPMacCfgCfm func; Pst *pst; Buffer *mBuf; @@ -250,16 +227,14 @@ Buffer *mBuf; { RgPrgCfgCfmInfo cfgCfm; - TRC2(cmUnpkPrgSMacPMacCfgCfm) - if(SRemPreMsgMult((Data *)&cfgCfm, sizeof(RgPrgCfgCfmInfo), mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } RGPRG_FREE_MSG(mBuf); - RETVALUE((*func)(pst, &cfgCfm)); + return ((*func)(pst, &cfgCfm)); } /** @@ -276,35 +251,33 @@ Buffer *mBuf; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmPkPrgPMacSMacUeSCellDelReq +S16 cmPkPrgPMacSMacUeSCellDelReq ( Pst *pst, RgPrgUeSCellDelInfo *ueSCellDelInfo ) #else -PUBLIC S16 cmPkPrgPMacSMacUeSCellDelReq(pst, ueSCellDelInfo) +S16 cmPkPrgPMacSMacUeSCellDelReq(pst, ueSCellDelInfo) Pst *pst; RgPrgUeSCellDelInfo *ueSCellDelInfo; #endif { Buffer *mBuf = NULLP; - TRC2(cmPkPrgPMacSMacUeSCellDelReq) - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) { - RETVALUE(RFAILED); + return RFAILED; } if(SAddPstMsgMult((Data *)ueSCellDelInfo, sizeof(RgPrgUeSCellDelInfo), mBuf)\ != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } pst->event = (Event) EVTPRGUESCELLDELREQ; - RETVALUE(SPstTsk(pst,mBuf)); + return (SPstTsk(pst,mBuf)); } /** @@ -322,14 +295,14 @@ RgPrgUeSCellDelInfo *ueSCellDelInfo; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellDelReq +S16 cmUnpkPrgPMacSMacUeSCellDelReq ( RgUeSCellDelReq func, Pst *pst, Buffer *mBuf ) #else -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellDelReq(func, pst, mBuf) +S16 cmUnpkPrgPMacSMacUeSCellDelReq(func, pst, mBuf) RgUeSCellDelReq func; Pst *pst; Buffer *mBuf; @@ -337,17 +310,15 @@ Buffer *mBuf; { RgPrgUeSCellDelInfo ueSCellDelInfo; - TRC2(cmUnpkPrgPMacSMacUeSCellDelReq) - if(SRemPreMsgMult((Data *)&ueSCellDelInfo, sizeof(RgPrgUeSCellDelInfo),\ mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } RGPRG_FREE_MSG(mBuf); - RETVALUE((*func)(pst, &ueSCellDelInfo)); + return ((*func)(pst, &ueSCellDelInfo)); } /** @@ -364,35 +335,33 @@ Buffer *mBuf; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmPkPrgPMacSMacUeSCellLchAddReq +S16 cmPkPrgPMacSMacUeSCellLchAddReq ( Pst *pst, RgPrgUeSCellLchAddInfo *lchCfgInfo, ) #else -PUBLIC S16 cmPkPrgPMacSMacUeSCellLchAddReq(pst, lchCfgInfo) +S16 cmPkPrgPMacSMacUeSCellLchAddReq(pst, lchCfgInfo) Pst *pst; RgPrgUeSCellLchAddInfo *lchCfgInfo; #endif { Buffer *mBuf = NULLP; - TRC2(cmPkPrgPMacSMacUeSCellLchAddReq) - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) { - RETVALUE(RFAILED); + return RFAILED; } if(SAddPstMsgMult((Data *)lchCfgInfo, sizeof(RgPrgUeSCellLchAddInfo),\ mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } pst->event = (Event) EVTPRGUESCELLLCHADDREQ; - RETVALUE(SPstTsk(pst,mBuf)); + return (SPstTsk(pst,mBuf)); } /** @@ -410,14 +379,14 @@ RgPrgUeSCellLchAddInfo *lchCfgInfo; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellLchAddReq +S16 cmUnpkPrgPMacSMacUeSCellLchAddReq ( RgPrgUeSCellLchAddInfo func, Pst *pst, Buffer *mBuf ) #else -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellLchAddReq(func, pst, mBuf) +S16 cmUnpkPrgPMacSMacUeSCellLchAddReq(func, pst, mBuf) RgPrgUeSCellLchAddInfo func; Pst *pst; Buffer *mBuf; @@ -425,16 +394,14 @@ Buffer *mBuf; { RgPrgLchRecfgInfo lchCfgInfo; - TRC2(cmUnpkPrgPMacSMacUeSCellLchAddReq) - if(SRemPreMsgMult((Data *)&lchCfgInfo, sizeof(RgPrgUeSCellLchAddInfo), mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } RGPRG_FREE_MSG(mBuf); - RETVALUE((*func)(pst, &lchCfgInfo)); + return ((*func)(pst, &lchCfgInfo)); } /** @@ -451,35 +418,33 @@ Buffer *mBuf; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmPkPrgPMacSMacUeSCellLchDelReq +S16 cmPkPrgPMacSMacUeSCellLchDelReq ( Pst *pst, RgPrgUeSCellLchDelInfo *delLcCb ) #else -PUBLIC S16 cmPkPrgPMacSMacUeSCellLchDelReq(pst, delLcCb) +S16 cmPkPrgPMacSMacUeSCellLchDelReq(pst, delLcCb) Pst *pst; RgPrgUeSCellLchDelInfo *delLcCb; #endif { Buffer *mBuf = NULLP; - TRC2(cmPkPrgPMacSMacUeSCellLchDelReq) - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) { - RETVALUE(RFAILED); + return RFAILED; } if(SAddPstMsgMult((Data *)delLcCb, sizeof(RgPrgUeSCellLchDelInfo),\ mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } pst->event = (Event) EVTPRGUESCELLLCHDELREQ; - RETVALUE(SPstTsk(pst,mBuf)); + return (SPstTsk(pst,mBuf)); } @@ -497,35 +462,33 @@ RgPrgUeSCellLchDelInfo *delLcCb; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmPkPrgPMacSMacUeSCellLchModReq +S16 cmPkPrgPMacSMacUeSCellLchModReq ( Pst *pst, RgPrgUeSCellLchModInfo *lchCfgInfo ) #else -PUBLIC S16 cmPkPrgPMacSMacUeSCellLchModReq(pst, lchCfgInfo) +S16 cmPkPrgPMacSMacUeSCellLchModReq(pst, lchCfgInfo) Pst *pst; RgPrgUeSCellLchModInfo *lchCfgInfo; #endif { Buffer *mBuf = NULLP; - TRC2(cmPkPrgPMacSMacUeSCellLchModReq) - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) { - RETVALUE(RFAILED); + return RFAILED; } if(SAddPstMsgMult((Data *)lchCfgInfo, sizeof(RgPrgUeSCellLchModInfo),\ mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } pst->event = (Event) EVTPRGUESCELLLCHMODREQ; - RETVALUE(SPstTsk(pst,mBuf)); + return (SPstTsk(pst,mBuf)); } @@ -544,14 +507,14 @@ RgPrgUeSCellLchModInfo *lchCfgInfo; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellLchModReq +S16 cmUnpkPrgPMacSMacUeSCellLchModReq ( RgPrgUeScellModLchReq func, Pst *pst, Buffer *mBuf ) #else -PUBLIC S16 cmUnpkPrgPMacSMacAddLchCfgReq(func, pst, mBuf) +S16 cmUnpkPrgPMacSMacAddLchCfgReq(func, pst, mBuf) RgPrgUeScellModLchReq func; Pst *pst; Buffer *mBuf; @@ -559,16 +522,14 @@ Buffer *mBuf; { RgPrgUeSCellLchModInfo lchCfgInfo; - TRC2(cmUnpkPrgPMacSMacAddLchCfgReq) - if(SRemPreMsgMult((Data *)&lchCfgInfo, sizeof(RgPrgUeSCellLchModInfo), mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } RGPRG_FREE_MSG(mBuf); - RETVALUE((*func)(pst, &lchCfgInfo)); + return ((*func)(pst, &lchCfgInfo)); } @@ -587,14 +548,14 @@ Buffer *mBuf; * -# ROK **/ #ifdef ANSI -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellLchDelReq +S16 cmUnpkPrgPMacSMacUeSCellLchDelReq ( RgPrgUeScellDelLchReq func, Pst *pst, Buffer *mBuf ) #else -PUBLIC S16 cmUnpkPrgPMacSMacUeSCellLchDelReq(func, pst, mBuf) +S16 cmUnpkPrgPMacSMacUeSCellLchDelReq(func, pst, mBuf) RgPrgUeScellDelLchReq func; Pst *pst; Buffer *mBuf; @@ -602,16 +563,14 @@ Buffer *mBuf; { RgPrgUeSCellLchDelInfo lchCfgInfo; - TRC2(cmUnpkPrgPMacSMacUeSCellLchDelReq) - if(SRemPreMsgMult((Data *)&lchCfgInfo, sizeof(RgPrgUeSCellLchDelInfo), mBuf) != ROK) { RGPRG_FREE_MSG(mBuf); - RETVALUE(RFAILED); + return RFAILED; } RGPRG_FREE_MSG(mBuf); - RETVALUE((*func)(pst, &lchCfgInfo)); + return ((*func)(pst, &lchCfgInfo)); } #endif /*LCPRG*/