X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fcm%2Frgr.c;h=a42533251c53bed1b5544db134c2f595ac584dfc;hb=f56e7aa2f07c03f3b30eda22a2260d038e0214e9;hp=b288a0c3e187eb614a82afb2a75beb8916ecc5f1;hpb=829bbd114f1c3dc00c1da47bca0a8207c049df3f;p=o-du%2Fl2.git diff --git a/src/cm/rgr.c b/src/cm/rgr.c index b288a0c3e..a42533251 100755 --- a/src/cm/rgr.c +++ b/src/cm/rgr.c @@ -426,95 +426,6 @@ Buffer *mBuf; } -/*********************************************************** -* -* Func : cmPkRgrCfgReq -* -* -* Desc : Configuration Request from RRM to MAC for - * configuring Cell/Ue/Lc -* -* -* Ret : S16 -* -* Notes: -* -* File : -* -**********************************************************/ -#ifdef ANSI -PUBLIC S16 cmPkRgrCfgReq -( -Pst* pst, -SpId spId, -RgrCfgTransId transId, -RgrCfgReqInfo * cfgReqInfo -) -#else -PUBLIC S16 cmPkRgrCfgReq(pst, spId, transId, cfgReqInfo) -Pst* pst; -SpId spId; -RgrCfgTransId transId; -RgrCfgReqInfo * cfgReqInfo; -#endif -{ - Buffer *mBuf = NULLP; - TRC3(cmPkRgrCfgReq) - - if (SGetMsg(pst->region, pst->pool, &mBuf) != ROK) { -#if (ERRCLASS & ERRCLS_ADD_RES) - SLogError(pst->srcEnt, pst->srcInst, pst->srcProcId, - __FILE__, __LINE__, (ErrCls)ERRCLS_ADD_RES, - (ErrVal)ERGR016, (ErrVal)0, "Packing failed"); -#endif - SPutSBuf(pst->region, pst->pool, (Data *)cfgReqInfo, sizeof(RgrCfgReqInfo)); - RETVALUE(RFAILED); - } - if (cmPkRgrCfgReqInfo(cfgReqInfo, mBuf) != ROK) { -#if (ERRCLASS & ERRCLS_ADD_RES) - SLogError(pst->srcEnt, pst->srcInst, pst->srcProcId, - __FILE__, __LINE__, (ErrCls)ERRCLS_ADD_RES, - (ErrVal)ERGR017, (ErrVal)0, "Packing failed"); -#endif - SPutSBuf(pst->region, pst->pool, (Data *)cfgReqInfo, sizeof(RgrCfgReqInfo)); - SPutMsg(mBuf); - RETVALUE(RFAILED); - } - if (cmPkRgrCfgTransId(&transId, mBuf) != ROK) { -#if (ERRCLASS & ERRCLS_ADD_RES) - SLogError(pst->srcEnt, pst->srcInst, pst->srcProcId, - __FILE__, __LINE__, (ErrCls)ERRCLS_ADD_RES, - (ErrVal)ERGR018, (ErrVal)0, "Packing failed"); -#endif - SPutSBuf(pst->region, pst->pool, (Data *)cfgReqInfo, sizeof(RgrCfgReqInfo)); - SPutMsg(mBuf); - RETVALUE(RFAILED); - } - if (SPkS16(spId, mBuf) != ROK) { -#if (ERRCLASS & ERRCLS_ADD_RES) - SLogError(pst->srcEnt, pst->srcInst, pst->srcProcId, - __FILE__, __LINE__, (ErrCls)ERRCLS_ADD_RES, - (ErrVal)ERGR019, (ErrVal)0, "Packing failed"); -#endif - SPutSBuf(pst->region, pst->pool, (Data *)cfgReqInfo, sizeof(RgrCfgReqInfo)); - SPutMsg(mBuf); - RETVALUE(RFAILED); - } - if (SPutSBuf(pst->region, pst->pool, (Data *)cfgReqInfo, sizeof(RgrCfgReqInfo)) != ROK) { -#if (ERRCLASS & ERRCLS_ADD_RES) - SLogError(pst->srcEnt, pst->srcInst, pst->srcProcId, - __FILE__, __LINE__, (ErrCls)ERRCLS_ADD_RES, - (ErrVal)ERGR020, (ErrVal)0, "Packing failed"); -#endif - SPutMsg(mBuf); - RETVALUE(RFAILED); - } - - pst->event = (Event) EVTRGRCFGREQ; - RETVALUE(SPstTsk(pst,mBuf)); -} - - /*********************************************************** * * Func : cmUnpkRgrCfgReq @@ -545,12 +456,11 @@ Pst *pst; Buffer *mBuf; #endif { - SpId spId; RgrCfgTransId transId; RgrCfgReqInfo *cfgReqInfo; TRC3(cmUnpkRgrCfgReq) - +#if 0 if (SUnpkS16(&spId, mBuf) != ROK) { SPutMsg(mBuf); #if (ERRCLASS & ERRCLS_ADD_RES) @@ -560,6 +470,8 @@ Buffer *mBuf; #endif RETVALUE(RFAILED); } +#endif + if (cmUnpkRgrCfgTransId(&transId, mBuf) != ROK) { SPutMsg(mBuf); #if (ERRCLASS & ERRCLS_ADD_RES) @@ -591,7 +503,7 @@ Buffer *mBuf; RETVALUE(RFAILED); } SPutMsg(mBuf); - RETVALUE((*func)(pst, spId, transId, cfgReqInfo)); + RETVALUE((*func)(pst, transId, cfgReqInfo)); } /* rgr_c_001.main_3: Added TTI indication from MAC to RGR user */ @@ -820,14 +732,12 @@ Buffer *mBuf; PUBLIC S16 cmPkRgrCfgCfm ( Pst* pst, -SuId suId, RgrCfgTransId transId, U8 status ) #else -PUBLIC S16 cmPkRgrCfgCfm(pst, suId, transId, status) +PUBLIC S16 cmPkRgrCfgCfm(pst, transId, status) Pst* pst; -SuId suId; RgrCfgTransId transId; U8 status; #endif @@ -861,16 +771,7 @@ U8 status; SPutMsg(mBuf); RETVALUE(RFAILED); } - if (SPkS16(suId, mBuf) != ROK) { -#if (ERRCLASS & ERRCLS_ADD_RES) - SLogError(pst->srcEnt, pst->srcInst, pst->srcProcId, - __FILE__, __LINE__, (ErrCls)ERRCLS_ADD_RES, - (ErrVal)ERGR034, (ErrVal)0, "Packing failed"); -#endif - SPutMsg(mBuf); - RETVALUE(RFAILED); - } - pst->event = (Event) EVTRGRCFGCFM; + pst->event = (Event) EVTMACSCHCFGCFM; RETVALUE(SPstTsk(pst,mBuf)); } @@ -904,21 +805,11 @@ Pst *pst; Buffer *mBuf; #endif { - SuId suId; RgrCfgTransId transId; U8 status; TRC3(cmUnpkRgrCfgCfm) - if (SUnpkS16(&suId, mBuf) != ROK) { - SPutMsg(mBuf); -#if (ERRCLASS & ERRCLS_ADD_RES) - SLogError(pst->srcEnt, pst->srcInst, pst->srcProcId, - __FILE__, __LINE__, (ErrCls)ERRCLS_ADD_RES, - (ErrVal)ERGR035, (ErrVal)0, "Packing failed"); -#endif - RETVALUE(RFAILED); - } if (cmUnpkRgrCfgTransId(&transId, mBuf) != ROK) { SPutMsg(mBuf); #if (ERRCLASS & ERRCLS_ADD_RES) @@ -938,7 +829,7 @@ Buffer *mBuf; RETVALUE(RFAILED); } SPutMsg(mBuf); - RETVALUE((*func)(pst, suId, transId, status)); + RETVALUE((*func)(pst, transId, status)); } /* rgr_c_001.main_4: ADD-Added for SI Enhancement. */ @@ -3687,9 +3578,6 @@ Buffer *mBuf { CMCHKPK(SPkU32, param->dynConfig[(U8)idx], mBuf); -#if 0 - printf("\npk dyn:%u\n",param->dynConfig[(U8)idx]); -#endif } CMCHKPK(SPkU8, param->uePerGrp, mBuf); CMCHKPK(SPkU8, param->ueGrpPerTti, mBuf); @@ -3697,13 +3585,6 @@ Buffer *mBuf CMCHKPK(SPkU8, param->numOfCC, mBuf); CMCHKPK(SPkU8, param->bwPerCC, mBuf); CMCHKPK(SPkU8, param->cfi, mBuf); -#if 0 - printf("\npk uePerGrp%:%u\n",param->uePerGrp); - printf("\npk ueGrpPerTti:%u\n",param->ueGrpPerTti); - printf("\npk num of UEs:%u\n",param->numUes); - printf("\npk Num of CC:%u\n",param->numOfCC); - printf("\npk bw per cc:%u\n",param->bwPerCC); -#endif RETVALUE(ROK); } @@ -3721,20 +3602,10 @@ Buffer *mBuf CMCHKUNPK(SUnpkU8, ¶m->numUes, mBuf); CMCHKUNPK(SUnpkU8, ¶m->ueGrpPerTti, mBuf); CMCHKUNPK(SUnpkU8, ¶m->uePerGrp, mBuf); -#if 0 - printf("\nunpk uePerGrp:%u\n",param->uePerGrp); - printf("\nunpk ueGrpPerTti:%u\n",param->ueGrpPerTti); - printf("\nunpk num of ues:%u\n",param->numUes); - printf("\nunpk num of cc:%u\n",param->numOfCC); - printf("\nunpk bw per cc:%u\n",param->bwPerCC); -#endif for (idx = 0; idx < MAX_5GTF_SUBFRAME_INFO ; ++idx) { CMCHKUNPK(SUnpkU32, ¶m->dynConfig[(U8)idx], mBuf); -#if 0 - printf("\nunpk dyn:%u\n",param->dynConfig[(U8)idx]); -#endif } RETVALUE(ROK); } @@ -4201,9 +4072,9 @@ PUBLIC S16 cmUnpkRgrCellLteAdvancedFeatureCfg(param, mBuf) /*********************************************************** * -* Func : cmPkRgrSchedEnbCfg +* Func : cmPkMacSchedGnbCfg * -* Desc : SCH ENB Configurations +* Desc : SCH GNB Configurations * * Ret : S16 * @@ -4213,53 +4084,34 @@ PUBLIC S16 cmUnpkRgrCellLteAdvancedFeatureCfg(param, mBuf) * **********************************************************/ #ifdef ANSI -PUBLIC S16 cmPkRgrSchedEnbCfg +PUBLIC S16 cmPkMacSchedGnbCfg ( -RgrSchedEnbCfg *param, +MacSchedGnbCfg *param, Buffer *mBuf ) #else -PUBLIC S16 cmPkRgrSchedEnbCfg(param, mBuf) +PUBLIC S16 cmPkMacSchedGnbCfg(param, mBuf) RgrSchedEnbCfg *param; Buffer *mBuf; #endif { + TRC3(cmPkMacSchedGnbCfg) - //S32 i; - TRC3(cmPkRgrSchedEnbCfg) - -#ifdef RG_5GTF - CMCHKPK(SPkU8, param->isDynTddEnbld, mBuf); -#endif - CMCHKPK(SPkU32, param->accsMode, mBuf); - switch(param->ulSchdType) - { - case RGR_SCH_TYPE_PFS: - CMCHKPK(cmPkRgrEnbPfs, ¶m->ulSchInfo.ulPfs, mBuf); - break; - default : - break; - } - CMCHKPK(SPkU8, param->ulSchdType, mBuf); - switch(param->dlSchdType) - { - case RGR_SCH_TYPE_PFS: - CMCHKPK(cmPkRgrEnbPfs, ¶m->dlSchInfo.dlPfs, mBuf); - break; - default : - break; - } + CMCHKPK(SPkU8, param->maxDlUePerTti, mBuf); + CMCHKPK(SPkU8, param->maxUlUePerTti, mBuf); + CMCHKPK(SPkU8, param->numCells, mBuf); CMCHKPK(SPkU8, param->dlSchdType, mBuf); + CMCHKPK(SPkU8, param->ulSchdType, mBuf); CMCHKPK(SPkU8, param->numTxAntPorts, mBuf); RETVALUE(ROK); } /* cmPkRgrSchedEnbCfg */ /*********************************************************** * -* Func : cmUnpkRgrSchedEnbCfg +* Func : cmUnpkMacSchedGnbCfg * * -* Desc : SCH Enodeb Configuration to SCH +* Desc : SCH Gnodeb Configuration to SCH * * * Ret : S16 @@ -4270,48 +4122,28 @@ Buffer *mBuf; * **********************************************************/ #ifdef ANSI -PUBLIC S16 cmUnpkRgrSchedEnbCfg +PUBLIC S16 cmUnpkMacSchedGnbCfg ( -RgrSchedEnbCfg *param, +MacSchedGnbCfg *param, Buffer *mBuf ) #else -PUBLIC S16 cmUnpkRgrSchedEnbCfg(param, mBuf) -RgrSchedEnbCfg *param; +PUBLIC S16 cmUnpkMacSchedGnbCfg(param, mBuf) +MacSchedGnbCfg *param; Buffer *mBuf; #endif { - //S32 i; - U32 tmpEnum; - TRC3(cmUnpkRgrSchedEnbCfg) + TRC3(cmUnpkMacSchedGnbCfg) CMCHKUNPK(SUnpkU8, ¶m->numTxAntPorts, mBuf); - CMCHKUNPK(SUnpkU8, ¶m->dlSchdType, mBuf); - switch(param->dlSchdType) - { - case RGR_SCH_TYPE_PFS: - CMCHKUNPK(cmUnpkRgrEnbPfs, ¶m->dlSchInfo.dlPfs, mBuf); - break; - default : - break; - } CMCHKUNPK(SUnpkU8, ¶m->ulSchdType, mBuf); - switch(param->ulSchdType) - { - case RGR_SCH_TYPE_PFS: - CMCHKUNPK(cmUnpkRgrEnbPfs, ¶m->ulSchInfo.ulPfs, mBuf); - break; - default : - break; - } - CMCHKUNPK(SUnpkU32, (U32 *)&tmpEnum, mBuf); - param->accsMode = (RgrCellAccsMode) tmpEnum; -#ifdef RG_5GTF - CMCHKUNPK(SUnpkU8, ¶m->isDynTddEnbld, mBuf); -#endif + CMCHKUNPK(SUnpkU8, ¶m->dlSchdType, mBuf); + CMCHKUNPK(SUnpkU8, ¶m->numCells, mBuf); + CMCHKUNPK(SUnpkU8, ¶m->maxUlUePerTti, mBuf); + CMCHKUNPK(SUnpkU8, ¶m->maxDlUePerTti, mBuf); RETVALUE(ROK); -} /* cmUnpkRgrSchedEnbCfg */ +} /* cmUnpkMacSchedGnbCfg */ /*********************************************************** @@ -6889,9 +6721,6 @@ PUBLIC S16 cmUnpkRgr5gtfUeCfg CMCHKUNPK(SUnpkU8, ¶m->numCC, mBuf); CMCHKUNPK(SUnpkU8, ¶m->mcs, mBuf); CMCHKUNPK(SUnpkU8, ¶m->maxPrb, mBuf); -#if 0 - printf("\nunpk %u,%u,%u,%u,%u\n",param->grpId,param->BeamId,param->numCC,param->mcs,param->maxPrb); -#endif RETVALUE(ROK); } @@ -6906,9 +6735,6 @@ PUBLIC S16 cmPkRgr5gtfUeCfg CMCHKPK(SPkU8, param->numCC, mBuf); CMCHKPK(SPkU8, param->BeamId, mBuf); CMCHKPK(SPkU8, param->grpId, mBuf); -#if 0 - printf("\npk %u,%u,%u,%u,%u\n",param->grpId,param->BeamId,param->numCC,param->mcs,param->maxPrb); -#endif RETVALUE(ROK); } #endif @@ -7742,8 +7568,8 @@ Buffer *mBuf; case RGR_CELL_CFG: CMCHKPK(cmPkRgrCellCfg, ¶m->u.cellCfg, mBuf); break; - case RGR_ENB_CFG: - CMCHKPK(cmPkRgrSchedEnbCfg, ¶m->u.schedEnbCfg, mBuf); + case MAC_GNB_CFG: + CMCHKPK(cmPkMacSchedGnbCfg, ¶m->u.schedGnbCfg, mBuf); break; default : RETVALUE(RFAILED); @@ -7786,8 +7612,8 @@ Buffer *mBuf; CMCHKUNPK(SUnpkU8, ¶m->cfgType, mBuf); switch(param->cfgType) { - case RGR_ENB_CFG: - CMCHKUNPK(cmUnpkRgrSchedEnbCfg, ¶m->u.schedEnbCfg, mBuf); + case MAC_GNB_CFG: + CMCHKUNPK(cmUnpkMacSchedGnbCfg, ¶m->u.schedGnbCfg, mBuf); break; case RGR_CELL_CFG: CMCHKUNPK(cmUnpkRgrCellCfg, ¶m->u.cellCfg, mBuf); @@ -9225,7 +9051,7 @@ Buffer *mBuf; case RGR_RECONFIG: CMCHKPK(cmPkRgrRecfg, ¶m->u.recfgInfo, mBuf); break; - case RGR_CONFIG: + case SCH_CONFIG: CMCHKPK(cmPkRgrCfg, ¶m->u.cfgInfo, mBuf); break; #ifdef LTE_ADV @@ -9276,7 +9102,7 @@ Buffer *mBuf; CMCHKUNPK(SUnpkU8, ¶m->action, mBuf); switch(param->action) { - case RGR_CONFIG: + case SCH_CONFIG: CMCHKUNPK(cmUnpkRgrCfg, ¶m->u.cfgInfo, mBuf); break; case RGR_RECONFIG: @@ -11372,9 +11198,6 @@ Buffer *mBuf; #endif { S8 idx; -#if 0 - Ptr ptr; -#endif /* dsfr_pal_fixes ** 21-March-2013 ** SKS */ TknStrOSXL *tknStr; @@ -11392,9 +11215,6 @@ Buffer *mBuf; } else { -#if 0 - ptr =(Ptr)param; -#endif /* dsfr_pal_fixes ** 21-March-2013 ** SKS ** Start */ tknStr = ¶m->u.rntpInfo;