X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrsch%2Frg_sch_uhm.c;h=770b4ada411b23dd21889be3c16c452132619555;hb=3330932565e15a749fd5dd5039cdea2862ca51cc;hp=a23f1fbe30c7d0e3e780b72830b0969a5e3b0531;hpb=5ea4c59cb4dd37164953218b0bd355284e11d22c;p=o-du%2Fl2.git diff --git a/src/5gnrsch/rg_sch_uhm.c b/src/5gnrsch/rg_sch_uhm.c index a23f1fbe3..770b4ada4 100755 --- a/src/5gnrsch/rg_sch_uhm.c +++ b/src/5gnrsch/rg_sch_uhm.c @@ -33,19 +33,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 */ -#include "ssi.h" /* system services */ - -#include "cm_lte.h" /* Common LTE */ -#include "cm_tkns.h" /* Common Token Defines */ -#include "cm_llist.h" /* Common Link List Defines */ -#include "cm_hash.h" /* Common Hash List Defines */ -#include "cm_mblk.h" /* memory management */ - +#include "common_def.h" #include "rg_env.h" /* MAC Environment Defines */ #include "tfu.h" /* TFU Interface defines */ #include "rgr.h" /* RGR Interface defines */ @@ -56,15 +44,6 @@ #include "rg_sch_err.h" /* MAC error defines */ /* header/extern include files (.x) */ -#include "gen.x" /* general */ -#include "ssi.x" /* system services */ -#include "cm5.x" /* system services */ -#include "cm_lte.x" /* Common LTE */ -#include "cm_tkns.x" /* Common Token Definitions */ -#include "cm_llist.x" /* Common Link List Definitions */ -#include "cm_lib.x" /* Common Library Definitions */ -#include "cm_hash.x" /* Common Hash List Definitions */ -#include "cm_mblk.x" /* memory management */ #include "tfu.x" /* TFU Interface defines */ #include "rgr.x" /* RGR Interface includes */ @@ -84,23 +63,23 @@ /* forward references */ #ifdef EMTC_ENABLE - U32 gUlRetxPassCntr = 0; - /*EXTERN U32 gUlRetxFailCntr; - EXTERN U32 gUlCrcPassCounter; - EXTERN U32 gUlCrcFailCounter;*/ + uint32_t gUlRetxPassCntr = 0; + /*uint32_t gUlRetxFailCntr; + uint32_t gUlCrcPassCounter; + uint32_t gUlCrcFailCounter;*/ #endif -PUBLIC U8 rgRvIdxTable[] = {0, 3, 1, 2}; /* This gives rvIdx for a given rv */ -PUBLIC U8 rgRvTable[] = {0, 2, 3 ,1}; /* This gives rv for a given rvIdx */ +uint8_t rgRvIdxTable[] = {0, 3, 1, 2}; /* This gives rvIdx for a given rv */ +uint8_t rgRvTable[] = {0, 2, 3 ,1}; /* This gives rv for a given rvIdx */ #ifdef EMTC_ENABLE -PUBLIC Void rgSCHCmnEmtcHdlHarqProcFail +Void rgSCHCmnEmtcHdlHarqProcFail ( RgSchCellCb *cell, RgSchUeCb *ue, RgSchUlHqProcCb *hqProc, CmLteTimingInfo frm ); -PUBLIC Void rgSCHEmtcInitUlUeHqEnt +Void rgSCHEmtcInitUlUeHqEnt ( RgSchCellCb *cell, RgrUeCfg *ueCfg, @@ -127,53 +106,25 @@ RgSchUeCb *ueCb * @return Void **/ #ifndef MAC_SCH_STATS -#ifdef ANSI -PUBLIC Void rgSCHUhmProcDatInd -( -RgSchCellCb *cell, -RgSchUeCb *ue, -CmLteTimingInfo frm -) -#else -PUBLIC Void rgSCHUhmProcDatInd(cell, ue, frm) -RgSchCellCb *cell; -RgSchUeCb *ue; -CmLteTimingInfo frm; -#endif +Void rgSCHUhmProcDatInd(RgSchCellCb *cell,RgSchUeCb *ue,CmLteTimingInfo frm) #else /* MAC_SCH_STATS */ -#ifdef ANSI -PUBLIC Void rgSCHUhmProcDatInd -( -RgSchCellCb *cell, -RgSchUeCb *ue, -CmLteTimingInfo frm, -U8 cqi -) -#else -PUBLIC Void rgSCHUhmProcDatInd(cell, ue, frm, cqi) -RgSchCellCb *cell; -RgSchUeCb *ue; -CmLteTimingInfo frm; -U8 cqi; -#endif +Void rgSCHUhmProcDatInd(RgSchCellCb *cell,RgSchUeCb *ue,CmLteTimingInfo frm,uint8_t cqi) #endif /* MAC_SCH_STATS */ { RgSchUlHqProcCb *hqProc; #ifdef UL_LA RgSchCmnUlUe *ueUl = RG_SCH_CMN_GET_UL_UE(ue, cell); S32 iTbs; - U8 maxiTbs = rgSchCmnUlCqiToTbsTbl[cell->isCpUlExtend] + uint8_t maxiTbs = rgSchCmnUlCqiToTbsTbl[cell->isCpUlExtend] [ueUl->maxUlCqi]; #endif - TRC2(rgSCHUhmProcDatInd); - rgSCHUtlUlHqProcForUe(cell, frm, ue, &hqProc); if (hqProc == NULLP) { - printf("UE[%d] failed to find UL HqProc for [%d:%d]\n", + DU_LOG("\nERROR --> SCH : UE[%d] failed to find UL HqProc for [%d:%d]\n", ue->ueId, frm.sfn, frm.slot); - RETVOID; + return; } hqProc->rcvdCrcInd = TRUE; @@ -208,7 +159,7 @@ U8 cqi; } #endif - RETVOID; + return; } /* rgSCHUhmProcDatInd */ /** @@ -226,21 +177,12 @@ U8 cqi; * @param[in,out] *hqProc * @return Void **/ -#ifdef ANSI -PUBLIC Void rgSCHUhmProcMsg3DatInd -( -RgSchUlHqProcCb *hqProc -) -#else -PUBLIC Void rgSCHUhmProcMsg3DatInd(hqProc) -RgSchUlHqProcCb *hqProc; -#endif +Void rgSCHUhmProcMsg3DatInd(RgSchUlHqProcCb *hqProc) { - TRC2(rgSCHUhmProcMsg3DatInd); hqProc->rcvdCrcInd = TRUE; hqProc->remTx = 0; /*Reseting the value of rem Tx*/ - printf("\nrgSCHUhmProcMsg3DatInd,id:%u\n",hqProc->procId); - RETVOID; + DU_LOG("\nINFO --> SCH : rgSCHUhmProcMsg3DatInd,id:%u\n",hqProc->procId); + return; } /* rgSCHUhmProcMsg3DatInd */ /** @@ -258,17 +200,8 @@ RgSchUlHqProcCb *hqProc; * @param[in,out] *hqProc * @return Void **/ -#ifdef ANSI -PUBLIC Void rgSCHUhmProcMsg3Failure -( -RgSchUlHqProcCb *hqProc -) -#else -PUBLIC Void rgSCHUhmProcMsg3Failure(hqProc) -RgSchUlHqProcCb *hqProc; -#endif +Void rgSCHUhmProcMsg3Failure(RgSchUlHqProcCb *hqProc) { - TRC2(rgSCHUhmProcMsg3Failure); #ifdef EMTC_ENABLE RG_SCH_EMTC_IS_CRCIND_RCVD_CHK_RACB(hqProc); #endif @@ -277,7 +210,7 @@ RgSchUlHqProcCb *hqProc; hqProc->rcvdCrcInd = FALSE; } - RETVOID; + return; } /* rgSCHUhmProcMsg3Failure */ /** @@ -301,39 +234,9 @@ RgSchUlHqProcCb *hqProc; * @return Void **/ #ifndef MAC_SCH_STATS -#ifdef ANSI -PUBLIC Void rgSCHUhmProcHqFailure -( -RgSchCellCb *cell, -RgSchUeCb *ue, -CmLteTimingInfo frm, -TknU8 rv -) -#else -PUBLIC Void rgSCHUhmProcHqFailure(cell, ue, frm, rv) -RgSchCellCb *cell; -RgSchUeCb *ue; -CmLteTimingInfo frm; -TknU8 rv; -#endif +Void rgSCHUhmProcHqFailure(RgSchCellCb *cell,RgSchUeCb *ue,CmLteTimingInfo frm,TknUInt8 rv) #else /* MAC_SCH_STATS */ -#ifdef ANSI -PUBLIC Void rgSCHUhmProcHqFailure -( -RgSchCellCb *cell, -RgSchUeCb *ue, -CmLteTimingInfo frm, -TknU8 rv, -U8 cqi -) -#else -PUBLIC Void rgSCHUhmProcHqFailure(cell, ue, frm, rv, cqi) -RgSchCellCb *cell; -RgSchUeCb *ue; -CmLteTimingInfo frm; -TknU8 rv; -U8 cqi; -#endif +Void rgSCHUhmProcHqFailure(RgSchCellCb *cell,RgSchUeCb *ue,CmLteTimingInfo frm,TknUInt8 rv,uint8_t cqi) #endif /* MAC_SCH_STATS */ { RgSchUlHqProcCb *hqProc; @@ -341,14 +244,13 @@ U8 cqi; RgSchCmnUlUe *ueUl = RG_SCH_CMN_GET_UL_UE(ue,cell); S32 iTbs; #endif - TRC2(rgSCHUhmProcHqFailure); rgSCHUtlUlHqProcForUe(cell, frm, ue, &hqProc); if (hqProc == NULLP) { - printf("UE[%d] failed to find UL HqProc for [%d:%d]\n", + DU_LOG("\nERROR --> SCH : UE[%d] failed to find UL HqProc for [%d:%d]\n", ue->ueId, frm.sfn, frm.slot); - RETVOID; + return; } #ifdef UL_LA { @@ -365,7 +267,7 @@ U8 cqi; #ifdef MAC_SCH_STATS /** Stats update over here */ { - static U32 retxCnt = 0; + static uint32_t retxCnt = 0; ++retxCnt; hqFailStats.ulCqiStat[cqi - 1].numOfNacks++; } @@ -386,7 +288,7 @@ U8 cqi; { hqProc->rvIdxPhy.val = rgRvIdxTable[rv.val]; } - RETVOID; + return; } /* rgSCHUhmProcHqFailure */ /** @@ -407,30 +309,17 @@ U8 cqi; * -# Pointer to harq process corresponding to index * -# NULL **/ -#ifdef ANSI -PUBLIC RgSchUlHqProcCb* rgSCHUhmGetUlHqProc -( -RgSchCellCb *cell, -RgSchUeCb *ue, -U8 idx -) -#else -PUBLIC RgSchUlHqProcCb* rgSCHUhmGetUlHqProc(cell, ue, idx) -RgSchCellCb *cell; -RgSchUeCb *ue; -U8 idx; -#endif +RgSchUlHqProcCb* rgSCHUhmGetUlHqProc(RgSchCellCb *cell,RgSchUeCb *ue, uint8_t idx) { RgSchCmnUlUe *ueUl = RG_SCH_CMN_GET_UL_UE(ue, cell); - TRC2(rgSCHUhmGetUlHqProc); #if (ERRCLASS & ERRCLS_DEBUG) if(idx >= ueUl->hqEnt.numHqPrcs) { - RETVALUE(NULLP); + return (NULLP); } #endif - RETVALUE(&(ueUl->hqEnt.hqProcCb[idx])); + return (&(ueUl->hqEnt.hqProcCb[idx])); } /* rgSCHUhmGetUlHqProc */ /** @@ -450,21 +339,8 @@ U8 idx; * @param[in] *alloc * @return Void **/ -#ifdef ANSI -PUBLIC Void rgSCHUhmNewTx -( -RgSchUlHqProcCb *hqProc, -U8 maxHqRetx, -RgSchUlAlloc *alloc -) -#else -PUBLIC Void rgSCHUhmNewTx(hqProc, maxHqRetx, alloc) -RgSchUlHqProcCb *hqProc; -U8 maxHqRetx; -RgSchUlAlloc *alloc; -#endif +Void rgSCHUhmNewTx(RgSchUlHqProcCb *hqProc,uint8_t maxHqRetx,RgSchUlAlloc *alloc) { - TRC2(rgSCHUhmNewTx); hqProc->ndi ^= 1; hqProc->alloc = alloc; @@ -478,7 +354,7 @@ RgSchUlAlloc *alloc; ((RgUeUlHqCb*)hqProc->hqEnt)->numBusyHqProcs++; } #endif - RETVOID; + return; } /* rgSCHUhmNewTx */ /** @@ -497,23 +373,12 @@ RgSchUlAlloc *alloc; * @param[in] RgSchCellCb *cell * @return Void **/ -#ifdef ANSI -PUBLIC Void rgSCHUhmFreeProc -( -RgSchUlHqProcCb *hqProc, -RgSchCellCb *cell -) -#else -PUBLIC Void rgSCHUhmFreeProc(hqProc, cell) -RgSchUlHqProcCb *hqProc; -RgSchCellCb *cell; -#endif +Void rgSCHUhmFreeProc(RgSchUlHqProcCb *hqProc,RgSchCellCb *cell) { #ifdef LTE_L2_MEAS RgSchUeCb *ueCb; - U8 qci = 1; + uint8_t qci = 1; #endif - TRC2(rgSCHUhmFreeProc); #ifdef LTE_L2_MEAS if (hqProc->alloc && hqProc->alloc->ue) @@ -521,7 +386,7 @@ RgSchCellCb *cell; ueCb = hqProc->alloc->ue; if (ueCb && cell) { - U32 nonLcg0ReportedBs = ((RgSchCmnLcg *)(ueCb->ul.lcgArr[1].sch))->reportedBs + \ + uint32_t nonLcg0ReportedBs = ((RgSchCmnLcg *)(ueCb->ul.lcgArr[1].sch))->reportedBs + \ ((RgSchCmnLcg *)(ueCb->ul.lcgArr[2].sch))->reportedBs + \ ((RgSchCmnLcg *)(ueCb->ul.lcgArr[3].sch))->reportedBs; ((RgUeUlHqCb*)hqProc->hqEnt)->numBusyHqProcs--; @@ -546,7 +411,7 @@ RgSchCellCb *cell; { #ifdef UL_ADPT_DBG - printf("\n\n########HARQ FREED HARQPROC ID (%d )after rgSCHUhmFreeProc inuse %ld free %ld \n",hqProc->alloc->grnt.hqProcId, (CmLListCp *)(&((RgUeUlHqCb*)hqProc->hqEnt)->inUse)->count,(CmLListCp *) (&((RgUeUlHqCb*)hqProc->hqEnt)->free)->count); + DU_LOG("\nDEBUG --> SCH : ########HARQ FREED HARQPROC ID (%d )after rgSCHUhmFreeProc inuse %ld free %ld \n",hqProc->alloc->grnt.hqProcId, (CmLListCp *)(&((RgUeUlHqCb*)hqProc->hqEnt)->inUse)->count,(CmLListCp *) (&((RgUeUlHqCb*)hqProc->hqEnt)->free)->count); #endif hqProc->alloc = NULLP; hqProc->ulSfIdx = RGSCH_INVALID_INFO; @@ -560,16 +425,16 @@ RgSchCellCb *cell; cmLListAdd2Tail(&((RgUeUlHqCb*)hqProc->hqEnt)->free, &hqProc->lnk); /* - printf("after rgSCHUhmFreeProc inuse %ld free %ld \n", + DU_LOG("\nINFO --> SCH : after rgSCHUhmFreeProc inuse %ld free %ld \n", (CmLListCp *)(&((RgUeUlHqCb*)hqProc->hqEnt)->inUse)->count, (CmLListCp *) (&((RgUeUlHqCb*)hqProc->hqEnt)->free)->count); */ } else { - printf("\nhqEnt is NULL\n"); + DU_LOG("\nERROR --> SCH : hqEnt is NULL\n"); } - RETVOID; + return; } /* rgSCHUhmFreeProc */ /** @@ -589,25 +454,14 @@ RgSchCellCb *cell; * @param[in,out] *hqProc * @return Void **/ -#ifdef ANSI -PUBLIC Void rgSCHUhmRetx -( -RgSchUlHqProcCb *hqProc, -RgSchUlAlloc *alloc -) -#else -PUBLIC Void rgSCHUhmRetx(hqProc, alloc) -RgSchUlHqProcCb *hqProc; -RgSchUlAlloc *alloc; -#endif +Void rgSCHUhmRetx(RgSchUlHqProcCb *hqProc,RgSchUlAlloc *alloc) { - TRC2(rgSCHUhmRetx); hqProc->alloc = alloc; --hqProc->remTx; hqProc->rvIdx = (hqProc->rvIdx + 1) % 4; hqProc->rvIdxPhy.pres = FALSE; - RETVOID; + return; } /* rgSCHUhmRetx */ @@ -629,25 +483,11 @@ RgSchUlAlloc *alloc; * @param[out] *err * @return Void **/ -#ifdef ANSI -PUBLIC Void rgSCHUhmRgrUeCfg -( -RgSchCellCb *cellCb, -RgSchUeCb *ueCb, -RgrUeCfg *ueCfg -) -#else -PUBLIC Void rgSCHUhmRgrUeCfg(cellCb, ueCb, ueCfg) -RgSchCellCb *cellCb; -RgSchUeCb *ueCb; -RgrUeCfg *ueCfg; -#endif +Void rgSCHUhmRgrUeCfg(RgSchCellCb *cellCb,RgSchUeCb *ueCb,RgrUeCfg *ueCfg) { - U8 i; + uint8_t i; RgSchCmnUlUe *ueUl = RG_SCH_CMN_GET_UL_UE(ueCb, cellCb); - TRC2(rgSCHUhmRgrUeCfg); - ueUl->hqEnt.maxHqRetx = ((ueCfg->ueUlHqCfg.maxUlHqTx) - 1); #ifdef TFU_UPGRADE /* Storing the delta HARQ offset for HARQ + PUSCH */ @@ -674,7 +514,7 @@ RgrUeCfg *ueCfg; #ifdef EMTC_ENABLE rgSCHEmtcInitUlUeHqEnt(cellCb, ueCfg, ueCb); #endif - RETVOID; + return; } /* rgSCHUhmRgrUeCfg */ /** @@ -695,22 +535,9 @@ RgrUeCfg *ueCfg; * @param[out] *err * @return Void **/ -#ifdef ANSI -PUBLIC Void rgSCHUhmRgrUeRecfg -( -RgSchCellCb *cellCb, -RgSchUeCb *ueCb, -RgrUeRecfg *ueRecfg -) -#else -PUBLIC Void rgSCHUhmRgrUeRecfg(cellCb, ueCb, ueRecfg) -RgSchCellCb *cellCb; -RgSchUeCb *ueCb; -RgrUeRecfg *ueRecfg; -#endif +Void rgSCHUhmRgrUeRecfg(RgSchCellCb *cellCb,RgSchUeCb *ueCb,RgrUeRecfg *ueRecfg) { RgSchCmnUlUe *ueUl = RG_SCH_CMN_GET_UL_UE(ueCb, cellCb); - TRC2(rgSCHUhmRgrUeRecfg); /* [ccpu00123958]-ADD- Check for HARQ Reconfig from the bit mask */ if(RGR_UE_ULHARQ_RECFG & ueRecfg->ueRecfgTypes) @@ -718,7 +545,7 @@ RgrUeRecfg *ueRecfg; ueUl->hqEnt.maxHqRetx = (ueRecfg->ueUlHqRecfg.maxUlHqTx - 1); } - RETVOID; + return; } /* rgSCHUhmRgrUeRecfg */ /** @@ -736,19 +563,8 @@ RgrUeRecfg *ueRecfg; * @param[in,out] *ueCb * @return Void **/ -#ifdef ANSI -PUBLIC Void rgSCHUhmFreeUe -( -RgSchCellCb *cellCb, -RgUeUlHqCb *hqEnt -) -#else -PUBLIC Void rgSCHUhmFreeUe(cellCb, hqEnt) -RgSchCellCb *cellCb; -RgUeUlHqCb *hqEnt; -#endif +Void rgSCHUhmFreeUe(RgSchCellCb *cellCb,RgUeUlHqCb *hqEnt) { - TRC2(rgSCHUhmFreeUe); #ifdef LTE_TDD /* ccpu00117052 - MOD - Passing double pointer for proper NULLP assignment*/ @@ -757,7 +573,7 @@ RgUeUlHqCb *hqEnt; hqEnt->numHqPrcs * sizeof(RgSchUlHqProcCb)); #endif - RETVOID; + return; } /* rgSCHUhmFreeUe */ @@ -778,24 +594,12 @@ RgUeUlHqCb *hqEnt; * @param[in] idx * @return Void */ -#ifdef ANSI -PUBLIC S16 rgSCHUhmAppendPhich -( -RgSchCellCb *cellCb, -CmLteTimingInfo frm, -U8 idx -) -#else -PUBLIC S16 rgSCHUhmAppendPhich (cellCb, frm, idx) -RgSchCellCb *cellCb; -CmLteTimingInfo frm; -U8 idx; -#endif +S16 rgSCHUhmAppendPhich(RgSchCellCb *cellCb,CmLteTimingInfo frm,uint8_t idx) { - U8 nDmrs; - U8 rbStart; + uint8_t nDmrs; + uint8_t rbStart; #ifdef LTE_TDD - U8 iPhich; + uint8_t iPhich; #endif RgSchUlAlloc *ulAlloc; #ifdef LTEMAC_HDFDD @@ -803,10 +607,8 @@ U8 idx; #endif /* LTEMAC_HDFDD */ RgSchCmnUlCell *cellUl = RG_SCH_CMN_GET_UL_CELL(cellCb); - TRC2(rgSCHUhmAppendPhich) - #ifdef RG_5GTF - RETVALUE(ROK); + return ROK; #endif if(cellUl->hqFdbkIdx[idx] != RGSCH_INVALID_INFO) { @@ -833,7 +635,7 @@ U8 idx; if (rgSCHUtlGetPhichInfo (ulAlloc->hqProc, &rbStart, &nDmrs) != ROK) #endif { - RETVALUE (RFAILED); + return (RFAILED); } if(nDmrs != RGSCH_INVALID_NDMRS) { @@ -886,7 +688,7 @@ U8 idx; ulAlloc = rgSCHUtlNextHqFdbkAlloc (cellCb, ulAlloc, idx); } } - RETVALUE(ROK); + return ROK; } /* rgSCHUhmAppendPhich */ /** @@ -907,23 +709,12 @@ U8 idx; * -# RFAILED * **/ -#ifdef ANSI -PUBLIC S16 rgSCHUhmHqEntInit -( -RgSchCellCb *cellCb, -RgSchUeCb *ueCb -) -#else -PUBLIC S16 rgSCHUhmHqEntInit(cellCb, ueCb) -RgSchCellCb *cellCb; -RgSchUeCb *ueCb; -#endif +S16 rgSCHUhmHqEntInit(RgSchCellCb *cellCb,RgSchUeCb *ueCb) { RgSchCmnUlUe *ueUl = RG_SCH_CMN_GET_UL_UE(ueCb, cellCb); #ifdef LTE_TDD Inst inst = ueCb->cell->instIdx; #endif - TRC2(rgSCHUhmHqEntInit) #ifndef LTE_TDD /* Init the HARQ processes */ @@ -936,11 +727,11 @@ RgSchUeCb *ueCb; ueUl->hqEnt.numHqPrcs * \ sizeof(RgSchUlHqProcCb)) != ROK) { - RETVALUE(RFAILED); + return RFAILED; } #endif - RETVALUE(ROK); + return ROK; } /* rgSCHUhmHqEntInit */ #ifdef RG_5GTF @@ -969,19 +760,7 @@ RgSchUeCb *ueCb; * -#RFAILED otherwise * **/ -#ifdef ANSI -PUBLIC S16 rgSCHUhmGetAvlHqProc -( -RgSchCellCb *cell, -RgSchUeCb *ue, -RgSchUlHqProcCb **hqP -) -#else -PUBLIC S16 rgSCHUhmGetAvlHqProc (cell, ue, hqP) -RgSchCellCb *cell; -RgSchUeCb *ue; -RgSchUlHqProcCb **hqP; -#endif +S16 rgSCHUhmGetAvlHqProc(RgSchCellCb *cell,RgSchUeCb *ue,RgSchUlHqProcCb **hqP) { RgSchCmnUlCell *cellUl = RG_SCH_CMN_GET_UL_CELL(cell); RgSchCmnUlUe *ueUl = RG_SCH_CMN_GET_UL_UE(ue, cell); @@ -989,21 +768,18 @@ RgSchUlHqProcCb **hqP; CmLList *tmp; RgUeUlHqCb *hqE; - TRC2(rgSCHUhmGetAvlHqProc); - hqE = &ueUl->hqEnt; CM_LLIST_FIRST_NODE(&(hqE->free), tmp); if (NULLP == tmp) { - //RLOG_ARG3(L_ERROR,DBG_CELLID,cell->cellId, - // "rgSCHUhmGetAvlHqProc free %ld inUse %ld ue %d" + //DU_LOG("rgSCHUhmGetAvlHqProc free %ld inUse %ld ue %d" // , hqE->free.count, hqE->inUse.count, ue->ueId); - //printf("5GTF_ERROR rgSCHUhmGetAvlHqProc cellId %d %ld inUse %ld ue %d" + //DU_LOG("5GTF_ERROR rgSCHUhmGetAvlHqProc cellId %d %ld inUse %ld ue %d" //, cell->cellId, hqE->free.count, hqE->inUse.count, ue->ueId); /* No Harq Process available in the free queue. */ - RETVALUE(RFAILED); + return RFAILED; } tmpHqProc = (RgSchUlHqProcCb *)(tmp->node); @@ -1015,13 +791,13 @@ RgSchUlHqProcCb **hqP; cmLListAdd2Tail(&hqE->inUse, &tmpHqProc->lnk); #ifdef UL_ADPT_DBG - printf("rgSCHUhmGetAvlHqProc cellId %d free %ld inUse %ld ue %d time (%d %d)\n",cell->cellId, hqE->free.count, hqE->inUse.count, ue->ueId,cellUl->schdTime.sfn,cellUl->schdTime.slot); + DU_LOG("\nDEBUG --> SCH : rgSCHUhmGetAvlHqProc cellId %d free %ld inUse %ld UE %d time (%d %d)\n",cell->cellId, hqE->free.count, hqE->inUse.count, ue->ueId,cellUl->schdTime.sfn,cellUl->schdTime.slot); #endif tmpHqProc->schdTime = cellUl->schdTime; *hqP = tmpHqProc; - RETVALUE(ROK); + return ROK; } /* rgSCHUhmGetAvlHqProc */ /** @@ -1042,40 +818,28 @@ RgSchUlHqProcCb **hqP; * -# Pointer to harq process corresponding to index * -# NULL **/ -#ifdef ANSI -PUBLIC RgSchUlHqProcCb* rgSCHUhmGetUlProcByTime -( -RgSchCellCb *cell, -RgSchUeCb *ue, -CmLteTimingInfo frm -) -#else -PUBLIC RgSchUlHqProcCb* rgSCHUhmGetUlProcByTime(cell, ue, frm) -RgSchCellCb *cell; -RgSchUeCb *ue; -CmLteTimingInfo frm; -#endif +RgSchUlHqProcCb* rgSCHUhmGetUlProcByTime(RgSchCellCb *cell,RgSchUeCb *ue, CmLteTimingInfo frm) { RgSchCmnUlUe *ueUl = RG_SCH_CMN_GET_UL_UE(ue, cell); CmLListCp *lst = &ueUl->hqEnt.inUse; CmLList *lnk = lst->first; RgSchUlHqProcCb *proc; - TRC2(rgSCHUhmGetUlProcByTime); - while (lnk) { proc = (RgSchUlHqProcCb *)(lnk->node); lnk = lnk->next; - // printf("compare rgSCHUhmGetUlProcByTime time (%d %d) CRC time (%d %d) proc->procId %d \n",proc->schdTime.sfn,proc->schdTime.slot,frm.sfn,frm.slot ,proc->procId); + // DU_LOG("\nINFO --> SCH : compare rgSCHUhmGetUlProcByTime time (%d %d) CRC time (%d %d) proc->procId %d + // \n",\proc->schdTime.sfn,proc->schdTime.slot,frm.sfn,frm.slot ,proc->procId); if (RGSCH_TIMEINFO_SAME(proc->schdTime, frm)) { - // printf("Harq timing Matched rgSCHUhmGetUlProcByTime time (%d %d) proc->procId %d \n",proc->schdTime.sfn,proc->schdTime.slot, proc->procId); - RETVALUE(proc); + // DU_LOG("\nINFO --> SCH : Harq timing Matched rgSCHUhmGetUlProcByTime time (%d %d) proc->procId %d \n",\ + proc->schdTime.sfn,proc->schdTime.slot, proc->procId); + return (proc); } } - RETVALUE(NULLP); + return (NULLP); } /* rgSCHUhmGetUlProcByTime */ #endif