X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fcm%2Frgm.c;h=2804c43aab3c88d39802e8a828775f44d33c7661;hb=dfe84998d9dba8389ee232aa184bc3b5ae383db3;hp=9857653176205cbcd1a5b2fa5e7ed56ee0d8aea9;hpb=87c35884595a3166121854c3ae6e6e856f004ff4;p=o-du%2Fl2.git diff --git a/src/cm/rgm.c b/src/cm/rgm.c index 985765317..2804c43aa 100755 --- a/src/cm/rgm.c +++ b/src/cm/rgm.c @@ -41,816 +41,6 @@ /* header/extern include files (.x) */ #include "rgm.x" /* RGM Interface includes */ -#ifdef RGM_LWLC - - -/** -* @brief Request from RRM to MAC to bind the interface saps -* -* @details -* -* Function : cmPkLwLcRgmBndReq -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] SpId spId -* @return S16 -* -# ROK -**/ -S16 cmPkLwLcRgmBndReq -( -Pst* pst, -SuId suId, -SpId spId -) -{ - Buffer *mBuf = NULLP; - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) - { - return RFAILED; - } - - if (SPkS16(spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (SPkS16(suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - pst->event = (Event) EVTRGMBNDREQ; - return (SPstTsk(pst,mBuf)); -} - - -/** -* @brief Request from RRM to MAC to bind the interface saps -* -* @details -* -* Function : cmUnpkLwLcRgmBndReq -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] SpId spId -* @return S16 -* -# ROK -**/ -S16 cmUnpkLwLcRgmBndReq -( -RgmBndReq func, -Pst *pst, -Buffer *mBuf -) -{ - SuId suId; - SpId spId; - S16 ret; - - - if (SUnpkS16(&suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (SUnpkS16(&spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - ret = ((*func)(pst, suId, spId)); - - SPutMsg(mBuf); - - return (ret); -} - -/** -* @brief Request from RRM to MAC to Unbind the interface saps -* -* @details -* -* Function : cmPkLwLcRgmUbndReq -* -* @param[in] Pst* pst -* @param[in] SpId spId -* @param[in] Reason reason -* @return S16 -* -# ROK -**/ -S16 cmPkLwLcRgmUbndReq -( -Pst* pst, -SpId spId, -Reason reason -) -{ - Buffer *mBuf = NULLP; - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) - { - return RFAILED; - } - if (SPkS16(reason, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - if (SPkS16(spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - pst->event = (Event) EVTRGMUBNDREQ; - return (SPstTsk(pst,mBuf)); -} - -/** -* @brief Confirmation from MAC to RRM for the bind/Unbind - * request for the interface saps -* -* @details -* -* Function : cmPkLwLcRgmBndCfm -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] uint8_t status -* @return S16 -* -# ROK -**/ -S16 cmPkLwLcRgmBndCfm -( -Pst* pst, -SuId suId, -uint8_t status -) -{ - Buffer *mBuf = NULLP; - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) - { - return RFAILED; - } - - if (SPkS16(suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (oduUnpackUInt8(status, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - pst->event = (Event) EVTRGMBNDCFM; - return (SPstTsk(pst,mBuf)); -} - - -/** -* @brief Confirmation from MAC to RRM for the bind/Unbind - * request for the interface saps -* -* @details -* -* Function : cmUnpkLwLcRgmBndCfm -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] uint8_t status -* @return S16 -* -# ROK -**/ -S16 cmUnpkLwLcRgmBndCfm -( -RgmBndCfm func, -Pst *pst, -Buffer *mBuf -) -{ - SuId suId; - uint8_t status; - - - if (oduPackUInt8(&status, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (SUnpkS16(&suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - SPutMsg(mBuf); - return ((*func)(pst, suId, status)); -} - - -/** -* @brief Configure the PRB Report Preparation Start/Stop from RRM to MAC -* -* @details -* -* Function : cmPkLwLcRgmCfgPrbRprt -* -* @param[in] Pst* pst -* @param[in] SpId spId -* @param[in] RgmPrbRprtCfg * prbRprtCfg -* @return S16 -* -# ROK -**/ -S16 cmPkLwLcRgmCfgPrbRprt -( -Pst* pst, -SpId spId, -RgmPrbRprtCfg * prbRprtCfg -) -{ - Buffer *mBuf = NULLP; - uint32_t len = sizeof(RgmPrbRprtCfg); - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) - { - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtCfg, sizeof(RgmPrbRprtCfg)); - return RFAILED; - } - - if(oduPackPointer((PTR)prbRprtCfg, mBuf) != ROK) - { - SPutMsg(mBuf); - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data*)prbRprtCfg, len); - return RFAILED; - } - - if (SPkS16(spId, mBuf) != ROK) - { - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtCfg, sizeof(RgmPrbRprtCfg)); - SPutMsg(mBuf); - return RFAILED; - } - - pst->event = (Event) EVTRGMCFGPRBRPRT; - return (SPstTsk(pst,mBuf)); -} - - -/** -* @brief Configure the PRB Report Preparation Start/Stop from RRM to MAC -* -* @details -* -* Function : cmUnpkLwLcRgmCfgPrbRprt -* -* @param[in] Pst* pst -* @param[in] SpId spId -* @param[in] RgmPrbRprtCfg * prbRprtCfg -* @return S16 -* -# ROK -**/ -S16 cmUnpkLwLcRgmCfgPrbRprt -( -RgmCfgPrbRprtFptr func, -Pst *pst, -Buffer *mBuf -) -{ - S16 ret; - SpId spId; - RgmPrbRprtCfg *prbRprtCfg; - - - if (SUnpkS16(&spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (oduUnpackPointer((PTR *)&prbRprtCfg, mBuf) != ROK) - { - SPutMsg(mBuf); - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtCfg, sizeof(RgmPrbRprtCfg)); - return RFAILED; - } - - ret = ((*func)(pst, spId, prbRprtCfg)); - - SPutMsg(mBuf); - return (ret); -} - - -/** -* @brief PRB Usage Report Indication from MAC to RRM -* -* @details -* -* Function : cmPkLwLcRgmPrbRprtInd -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] RgmPrbRprtInd * prbRprtInd -* @return S16 -* -# ROK -**/ -S16 cmPkLwLcRgmPrbRprtInd -( -Pst* pst, -SuId suId, -RgmPrbRprtInd * prbRprtInd -) -{ - Buffer *mBuf = NULLP; - - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) { - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtInd, sizeof(RgmPrbRprtInd)); - return RFAILED; - } - - if(oduPackPointer((PTR)prbRprtInd, mBuf) != ROK) - { - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtInd, sizeof(RgmPrbRprtInd)); - SPutMsg(mBuf); - return RFAILED; - } - - if (SPkS16(suId, mBuf) != ROK) - { - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtInd, sizeof(RgmPrbRprtInd)); - SPutMsg(mBuf); - return RFAILED; - } - - pst->event = (Event) EVTRGMCFGPRBRPRT; - return (SPstTsk(pst,mBuf)); -} - - -/** -* @brief PRB Usage Report Indication from MAC to RRM -* -* @details -* -* Function : cmUnpkLwLcRgmPrbRprtInd -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] RgmPrbRprtInd * prbRprtInd -* @return S16 -* -# ROK -**/ -S16 cmUnpkLwLcRgmPrbRprtInd -( -RgmPrbRprtIndFptr func, -Pst *pst, -Buffer *mBuf -) -{ - SuId suId; - RgmPrbRprtInd *prbRprtInd; - S16 ret; - - - if (SUnpkS16(&suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (oduUnpackPointer((PTR *)&prbRprtInd, mBuf) != ROK) - { - SPutMsg(mBuf); - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtInd, sizeof(RgmPrbRprtInd)); - return RFAILED; - } - - - ret = ((*func)(pst, suId, prbRprtInd)); - - SPutMsg(mBuf); - - return (ret); -} -#endif - - -/** -* @brief Request from RRM to MAC to bind the interface saps -* -* @details -* -* Function : cmPkRgmBndReq -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] SpId spId -* @return S16 -* -# ROK -**/ -S16 cmPkRgmBndReq -( -Pst* pst, -SuId suId, -SpId spId -) -{ - Buffer *mBuf = NULLP; - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) - { - return RFAILED; - } - - if (SPkS16(spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (SPkS16(suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - pst->event = (Event) EVTRGMBNDREQ; - return (SPstTsk(pst,mBuf)); -} - - -/** -* @brief Request from RRM to MAC to bind the interface saps -* -* @details -* -* Function : cmUnpkRgmBndReq -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] SpId spId -* @return S16 -* -# ROK -**/ -S16 cmUnpkRgmBndReq -( -RgmBndReq func, -Pst *pst, -Buffer *mBuf -) -{ - SuId suId; - SpId spId; - S16 ret; - - - if (SUnpkS16(&suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (SUnpkS16(&spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - ret = ((*func)(pst, suId, spId)); - - SPutMsg(mBuf); - - return (ret); -} - -/** -* @brief Request from RRM to MAC to Unbind the interface saps -* -* @details -* -* Function : cmPkRgmUbndReq -* -* @param[in] Pst* pst -* @param[in] SpId spId -* @param[in] Reason reason -* @return S16 -* -# ROK -**/ -S16 cmPkRgmUbndReq -( -Pst* pst, -SpId spId, -Reason reason -) -{ - Buffer *mBuf = NULLP; - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) - { - return RFAILED; - } - if (SPkS16(reason, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - if (SPkS16(spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - pst->event = (Event) EVTRGMUBNDREQ; - return (SPstTsk(pst,mBuf)); -} - -#if 1 - -/** -* @brief Request from RRM to MAC to Unbind the interface saps -* -* @details -* -* Function : cmUnpkRgmUbndReq -* -* @param[in] Pst* pst -* @param[in] SpId spId -* @param[in] Reason reason -* @return S16 -* -# ROK -**/ -S16 cmUnpkRgmUbndReq -( -RgmUbndReq func, -Pst *pst, -Buffer *mBuf -) -{ - SpId spId; - Reason reason; - - - if (SUnpkS16(&spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - if (SUnpkS16(&reason, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - SPutMsg(mBuf); - return ((*func)(pst, spId, reason)); -} -#endif - -/** -* @brief Confirmation from MAC to RRM for the bind/Unbind - * request for the interface saps -* -* @details -* -* Function : cmPkRgmBndCfm -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] uint8_t status -* @return S16 -* -# ROK -**/ -S16 cmPkRgmBndCfm -( -Pst* pst, -SuId suId, -uint8_t status -) -{ - Buffer *mBuf = NULLP; - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) - { - return RFAILED; - } - - if (SPkS16(suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (oduUnpackUInt8(status, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - pst->event = (Event) EVTRGMBNDCFM; - return (SPstTsk(pst,mBuf)); -} - - -/** -* @brief Confirmation from MAC to RRM for the bind/Unbind - * request for the interface saps -* -* @details -* -* Function : cmUnpkRgmBndCfm -* -* @param[in] Pst* pst -* @param[in] SuId suId -* @param[in] uint8_t status -* @return S16 -* -# ROK -**/ -S16 cmUnpkRgmBndCfm -( -RgmBndCfm func, -Pst *pst, -Buffer *mBuf -) -{ - SuId suId; - uint8_t status; - - - if (oduPackUInt8(&status, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (SUnpkS16(&suId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - SPutMsg(mBuf); - return ((*func)(pst, suId, status)); -} - - - - -/** -* @brief Configure the PRB Report Preparation Start/Stop from RRM to MAC -* -* @details -* -* Function : cmPkCfgPrbRprt -* -* @param[in] RgmPrbRprtCfg *prbRprtCfg -* @param[in] Buffer *mBuf -* @return S16 -* -# ROK -**/ -S16 cmPkCfgPrbRprt -( -RgmPrbRprtCfg * prbRprtCfg, -Buffer *mBuf -) -{ - CMCHKPK(oduUnpackUInt16, prbRprtCfg->usPrbAvgPeriodicty, mBuf); - CMCHKPK(oduUnpackUInt8, prbRprtCfg->bConfigType, mBuf); - CMCHKPK(oduUnpackUInt8, prbRprtCfg->bCellId, mBuf); - return ROK; -} -/** -* @brief Configure the PRB Report Preparation Start/Stop from RRM to MAC -* -* @details -* -* Function : cmUnPkCfgPrbRprt -* -* @param[in] RgmPrbRprtCfg *prbRprtCfg -* @param[in] Buffer *mBuf -* @return S16 -* -# ROK -**/ -S16 cmUnPkCfgPrbRprt -( -RgmPrbRprtCfg * prbRprtCfg, -Buffer *mBuf -) -{ - CMCHKUNPK(oduPackUInt8, &prbRprtCfg->bCellId, mBuf); - CMCHKUNPK(oduPackUInt8, &prbRprtCfg->bConfigType, mBuf); - CMCHKUNPK(oduPackUInt16, &prbRprtCfg->usPrbAvgPeriodicty, mBuf); - return ROK; -} - - - - -/** -* @brief Configure the PRB Report Preparation Start/Stop from RRM to MAC -* -* @details -* -* Function : cmPkRgmCfgPrbRprt -* -* @param[in] Pst* pst -* @param[in] SpId spId -* @param[in] RgmPrbRprtCfg *prbRprtCfg -* @return S16 -* -# ROK -**/ -S16 cmPkRgmCfgPrbRprt -( -Pst* pst, -SpId spId, -RgmPrbRprtCfg * prbRprtCfg -) -{ - Buffer *mBuf = NULLP; - uint32_t len = sizeof(RgmPrbRprtCfg); - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) - { - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtCfg, sizeof(RgmPrbRprtCfg)); - return RFAILED; - } - - if(cmPkCfgPrbRprt(prbRprtCfg, mBuf) != ROK) - { - SPutMsg(mBuf); - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data*)prbRprtCfg, len); - return RFAILED; - } - - if (SPkS16(spId, mBuf) != ROK) - { - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtCfg, sizeof(RgmPrbRprtCfg)); - SPutMsg(mBuf); - return RFAILED; - } - - SPutSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data *)prbRprtCfg, sizeof(RgmPrbRprtCfg)); - - pst->event = (Event) EVTRGMCFGPRBRPRT; - return (SPstTsk(pst,mBuf)); -} - - - -/** -* @brief Configure the PRB Report Preparation Start/Stop from RRM to MAC -* -* @details -* -* Function : cmUnpkRgmCfgPrbRprt -* -* @param[in] Pst* pst -* @param[in] SpId spId -* @param[in] RgmPrbRprtCfg * prbRprtCfg -* @return S16 -* -# ROK -**/ -S16 cmUnpkRgmCfgPrbRprt -( -RgmCfgPrbRprtFptr func, -Pst *pst, -Buffer *mBuf -) -{ - SpId spId; - RgmPrbRprtCfg *prbRprtCfg; - - if ((SGetSBufNewForDebug(__FILE__,__FUNCTION__,__LINE__,pst->region, pst->pool, (Data **)&prbRprtCfg, sizeof(RgmPrbRprtCfg))) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (SUnpkS16(&spId, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - if (cmUnPkCfgPrbRprt(prbRprtCfg, mBuf) != ROK) - { - SPutMsg(mBuf); - return RFAILED; - } - - SPutMsg(mBuf); - return ((*func)(pst, spId, prbRprtCfg)); -} - /* RRM_SP1_START */ /** * @brief Packing of PRB Usage Report for qci for sending