Code Review
/
o-du
/
l2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
[JIRA ID - ODUHIGH-275] Part -1 classifying of logs of sch folder
[o-du/l2.git]
/
src
/
5gnrsch
/
rg_sch_dhm.c
diff --git
a/src/5gnrsch/rg_sch_dhm.c
b/src/5gnrsch/rg_sch_dhm.c
index
2e51df9
..
a2ef173
100755
(executable)
--- a/
src/5gnrsch/rg_sch_dhm.c
+++ b/
src/5gnrsch/rg_sch_dhm.c
@@
-32,9
+32,6
@@
@brief APIs related to Downlink HARQ for the scheduler.
*/
@brief APIs related to Downlink HARQ for the scheduler.
*/
-static const char* RLOG_MODULE_NAME="MAC";
-static int RLOG_FILE_ID=242;
-static int RLOG_MODULE_ID=4096;
/* header include files -- defines (.h) */
#include "common_def.h"
/* header include files -- defines (.h) */
#include "common_def.h"
@@
-321,8
+318,7
@@
RgSchDlHqEnt *rgSCHDhmHqEntInit(RgSchCellCb *cell)
/* Init the HARQ data structure */
if (rgSCHUtlAllocSBuf(inst, (Data **)&hqE, sizeof(RgSchDlHqEnt)) != ROK)
{
/* Init the HARQ data structure */
if (rgSCHUtlAllocSBuf(inst, (Data **)&hqE, sizeof(RgSchDlHqEnt)) != ROK)
{
- RLOG_ARG0(L_DEBUG,DBG_CELLID,cell->cellId,
- "rgSCHDhmHqEntInit hqE alloc fail");
+ DU_LOG("\nERROR --> SCH: rgSCHDhmHqEntInit hqE alloc fail");
return (NULLP);
}
#ifdef LTE_TDD
return (NULLP);
}
#ifdef LTE_TDD
@@
-331,8
+327,7
@@
RgSchDlHqEnt *rgSCHDhmHqEntInit(RgSchCellCb *cell)
if (rgSCHUtlAllocSBuf(inst, (Data **)&hqE->procs,
hqE->numHqPrcs * sizeof(RgSchDlHqProcCb)) != ROK)
{
if (rgSCHUtlAllocSBuf(inst, (Data **)&hqE->procs,
hqE->numHqPrcs * sizeof(RgSchDlHqProcCb)) != ROK)
{
- RLOG_ARG0(L_DEBUG,DBG_CELLID,cell->cellId,
- "rgSCHDhmHqEntInit hqP alloc fail in hqE");
+ DU_LOG("\nERROR --> SCH: rgSCHDhmHqEntInit hqP alloc fail in hqE");
return (NULLP);
}
#else
return (NULLP);
}
#else
@@
-391,7
+386,7
@@
S16 rgSCHDhmGetAvlHqProc(RgSchCellCb *cell,RgSchUeCb *ue,CmLteTimingInfo timing
if (hqE == NULLP)
{
if (hqE == NULLP)
{
-
RLOG_ARG1(L_ERROR,DBG_CELLID,cell->cellId, "
rgSCHDhmGetAvlHqProc hqE NULL ue %d"
+
DU_LOG("\nERROR --> SCH :
rgSCHDhmGetAvlHqProc hqE NULL ue %d"
, ue->ueId);
return RFAILED;
}
, ue->ueId);
return RFAILED;
}
@@
-401,8
+396,7
@@
S16 rgSCHDhmGetAvlHqProc(RgSchCellCb *cell,RgSchUeCb *ue,CmLteTimingInfo timing
if (NULLP == tmp)
{
if (NULLP == tmp)
{
- RLOG_ARG3(L_ERROR,DBG_CELLID,cell->cellId,
- "rgSCHDhmGetAvlHqProc free %ld inUse %ld ue %d"
+ DU_LOG("\nERROR --> SCH : rgSCHDhmGetAvlHqProc free %d inUse %d ue %d"
, hqE->free.count, hqE->inUse.count, ue->ueId);
/* No Harq Process available in the free queue. */
return RFAILED;
, hqE->free.count, hqE->inUse.count, ue->ueId);
/* No Harq Process available in the free queue. */
return RFAILED;
@@
-866,8
+860,8
@@
rgEmtcsetNullSubFrm(hqP);
if (hqE->free.count > 8)
{
int *p = NULL;
if (hqE->free.count > 8)
{
int *p = NULL;
- printf("Crashing invalid hq count after free \n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing invalid hq count after free \n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-1109,7
+1103,7
@@
static Void rgSCHDhmFdbkIndHndlTa(RgSchDlHqProcCb *hqP,uint8_t tbIdx,uint8_t fdb
else
{
#ifdef DEBUGP
else
{
#ifdef DEBUGP
-
RLOG_ARG1(L_ERROR,DBG_CELLID,cell->cellId, "
Trying to add CRNTI:%d into TA"
+
DU_LOG("\nERROR --> SCH :
Trying to add CRNTI:%d into TA"
"ACK List twice", ueCb->ueId);
#endif
}
"ACK List twice", ueCb->ueId);
#endif
}
@@
-1125,8
+1119,7
@@
static Void rgSCHDhmFdbkIndHndlTa(RgSchDlHqProcCb *hqP,uint8_t tbIdx,uint8_t fdb
hqP->hqE->ue->dl.taCb.state = RGSCH_TA_IDLE;
rgSCHUtlReTxTa(cell, ueCb);
hqP->hqE->ue->dl.taCb.state = RGSCH_TA_IDLE;
rgSCHUtlReTxTa(cell, ueCb);
- RLOG_ARG0(L_DEBUG,DBG_CELLID,cell->cellId,
- "Nack Rcvd for TA. Max Tries Attempted");
+ DU_LOG("\nERROR --> SCH : Nack Rcvd for TA. Max Tries Attempted");
}
break;
case TFU_HQFDB_DTX:
}
break;
case TFU_HQFDB_DTX:
@@
-1371,8
+1364,7
@@
Void rgSCHDhmHqTbTrnsFail(RgSchCellCb *cell,RgSchDlHqProcCb *hqP,uint8_t tbCnt,B
#ifdef RGR_V1
if(hqP->hqE->raCb->expiryTime.sfn == RGSCH_CONTRES_EXP)
{
#ifdef RGR_V1
if(hqP->hqE->raCb->expiryTime.sfn == RGSCH_CONTRES_EXP)
{
- RLOG_ARG1(L_DEBUG,DBG_CELLID,cell->cellId,
- "rgSCHDhmHqTbTrnsFail contRes exp(): tmpCRNTI = %u",
+ DU_LOG("\nDEBUG --> SCH : rgSCHDhmHqTbTrnsFail contRes exp(): tmpCRNTI = %u",
hqP->hqE->raCb->tmpCrnti);
rgSCHRamMsg4Done(cell, (RgSchRaCb *)hqP->hqE->raCb);
return;
hqP->hqE->raCb->tmpCrnti);
rgSCHRamMsg4Done(cell, (RgSchRaCb *)hqP->hqE->raCb);
return;
@@
-1505,8
+1497,7
@@
Void rgSCHDhmHqTbTrnsFail(RgSchCellCb *cell,RgSchDlHqProcCb *hqP,uint8_t tbCnt,B
#endif
/* Perform RAM MSG4 done processing */
#endif
/* Perform RAM MSG4 done processing */
- RLOG_ARG1(L_DEBUG,DBG_CELLID,cell->cellId,
- "rgSCHDhmHqTbTrnsFail(): hq max retx fail: tmpCRNTI = %u",
+ DU_LOG("\nDEBUG --> SCH : rgSCHDhmHqTbTrnsFail(): hq max retx fail: tmpCRNTI = %u",
hqP->hqE->raCb->tmpCrnti);
rgSCHRamMsg4Done(cell, (RgSchRaCb *)hqP->hqE->raCb);
}
hqP->hqE->raCb->tmpCrnti);
rgSCHRamMsg4Done(cell, (RgSchRaCb *)hqP->hqE->raCb);
}
@@
-2439,8
+2430,7
@@
RgSchErrInfo *err
if ( found == FALSE )
{
RGSCH_NULL_CHECK(cellCb->instIdx, ue);
if ( found == FALSE )
{
RGSCH_NULL_CHECK(cellCb->instIdx, ue);
- RLOG_ARG3(L_ERROR,DBG_CELLID,cellCb->cellId,"CRNTI:%d"
- " NO HARQ proc available for feedback:timeInfo:snf %d,slot %d",
+ DU_LOG("\nERROR --> SCH : NO HARQ proc available for feedback:timeInfo:snf %d,slot %d",
ue->ueId,timeInfo.sfn, timeInfo.slot);
err->errType = RGSCHERR_DHM_FDBK_IND;
err->errCause = RGSCHERR_DHM_FDBK_IND_INVALID_CB;
ue->ueId,timeInfo.sfn, timeInfo.slot);
err->errType = RGSCHERR_DHM_FDBK_IND;
err->errCause = RGSCHERR_DHM_FDBK_IND_INVALID_CB;
@@
-2653,20
+2643,19
@@
RgSchErrInfo *err
{
raCb = rgSCHDbmGetRaCb(cell, rnti);
}
{
raCb = rgSCHDbmGetRaCb(cell, rnti);
}
- RGSCHDBGINFO(cell->instIdx,
- (rgSchPBuf(cell->instIdx), "Ack Rcvd. FdbkInd for Msg4Done\n"));
+ DU_LOG("\nDEBUG --> SCH: Ack Rcvd. FdbkInd for Msg4Done\n");
/* Inform Random Access Module regarding the ack received */
if (raCb != NULLP)
{
/*RRC Connection Setup failure issue where RRC connection
* setup was not reaching UE due to message 4 HARQ failure */
/* Inform Random Access Module regarding the ack received */
if (raCb != NULLP)
{
/*RRC Connection Setup failure issue where RRC connection
* setup was not reaching UE due to message 4 HARQ failure */
- printf("\nMSG4 Ack ,calling rgSCHRamMsg4Done\n");
+ printf("\n
DEBUG --> SCH:
MSG4 Ack ,calling rgSCHRamMsg4Done\n");
ret = rgSCHRamMsg4Done(cell, raCb);
hqFreed = TRUE;
}
else
{
ret = rgSCHRamMsg4Done(cell, raCb);
hqFreed = TRUE;
}
else
{
- printf("\nraCb is NULLP\n");
+ printf("\n
DEBUG --> SCH:
raCb is NULLP\n");
}
}
else /*ccpu00114124- HARQ Release for Msg4 */
}
}
else /*ccpu00114124- HARQ Release for Msg4 */
@@
-3191,8
+3180,7
@@
RgSchErrInfo *err
{
if (!sf->relPdcch)
{
{
if (!sf->relPdcch)
{
- RLOG_ARG3(L_ERROR,DBG_CELLID,cell->cellId,
- "CRNTI:%d NO HARQ proc available for feedback: TimingInfo: "
+ DU_LOG("\nERROR --> SCH : CRNTI:%d NO HARQ proc available for feedback: TimingInfo: "
"sfn %d slot %d", ue->ueId, timingInfo.sfn,
timingInfo.slot);
return RFAILED;
"sfn %d slot %d", ue->ueId, timingInfo.sfn,
timingInfo.slot);
return RFAILED;
@@
-3871,8
+3859,7
@@
S16 rgSCHDhmRlsDlsfHqProc(RgSchCellCb *cellCb,CmLteTimingInfo uciTimingInfo)
rgSCHUtlReTxTa(cellCb, ue);
rgSCHUtlReTxTa(cellCb, ue);
- RLOG_ARG0(L_DEBUG,DBG_CELLID,cellCb->cellId,
- "Nack/DTX Rcvd for TA. Max Tries Attempted");
+ DU_LOG("\nDEBUG --> SCH : Nack/DTX Rcvd for TA. Max Tries Attempted");
}
}
}
}
}
}
@@
-3956,8
+3943,7
@@
S16 rgSCHDhmRlsDlsfHqProc(RgSchCellCb *cellCb,CmLteTimingInfo uciTimingInfo)
ue->dl.taCb.state = RGSCH_TA_IDLE;
rgSCHUtlReTxTa(cellCb, ue);
ue->dl.taCb.state = RGSCH_TA_IDLE;
rgSCHUtlReTxTa(cellCb, ue);
- RLOG_ARG0(L_DEBUG,DBG_CELLID,cellCb->cellId,
- "Nack/DTX Rcvd for TA. Max Tries Attempted");
+ DU_LOG("\nDEBUG --> SCH : Nack/DTX Rcvd for TA. Max Tries Attempted");
}
}
}
}
@@
-4350,7
+4336,7
@@
static S16 rgSCHDhmUpdateAckNackHistory(RgSchCellCb *cell,RgSchUeCb *ueCb,uint8_
ueDl->laCb[tbCnt].deltaiTbs = ueDl->laCb[tbCnt].deltaiTbs - DL_LA_STEPDOWN;
}
/*
ueDl->laCb[tbCnt].deltaiTbs = ueDl->laCb[tbCnt].deltaiTbs - DL_LA_STEPDOWN;
}
/*
- printf("deltaiTbs[%d] cqibasediTbs[%d] iTbs[%d] tbCnt[%d]\n",
+ printf("
\nDEBUG --> SCH:
deltaiTbs[%d] cqibasediTbs[%d] iTbs[%d] tbCnt[%d]\n",
ueDl->laCb[tbCnt].deltaiTbs, ueDl->laCb[tbCnt].cqiBasediTbs,
(ueDl->laCb[tbCnt].deltaiTbs + ueDl->laCb[tbCnt].cqiBasediTbs)/100,
tbCnt);
ueDl->laCb[tbCnt].deltaiTbs, ueDl->laCb[tbCnt].cqiBasediTbs,
(ueDl->laCb[tbCnt].deltaiTbs + ueDl->laCb[tbCnt].cqiBasediTbs)/100,
tbCnt);
@@
-4486,8
+4472,8
@@
Void rgSCHDhmHqPAdd2FreeLst(RgSchDlHqProcCb *hqP)
if (hqP->hqPLst)
{
int *p = NULL;
if (hqP->hqPLst)
{
int *p = NULL;
- printf("Crashing already part of free lst\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing already part of free lst\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-4499,8
+4485,8
@@
Void rgSCHDhmHqPAdd2FreeLst(RgSchDlHqProcCb *hqP)
if (hqP->hqE->free.count > 8)
{
int *p = NULL;
if (hqP->hqE->free.count > 8)
{
int *p = NULL;
- printf("Crashing invalid hq count\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing invalid hq count\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-4534,8
+4520,8
@@
Void rgSCHDhmHqPAdd2InUseLst(RgSchDlHqProcCb *hqP)
if (hqP->hqPLst)
{
int *p = NULL;
if (hqP->hqPLst)
{
int *p = NULL;
- printf("Crashing already part of inuse lst\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing already part of inuse lst\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-4547,8
+4533,8
@@
Void rgSCHDhmHqPAdd2InUseLst(RgSchDlHqProcCb *hqP)
if (hqP->hqE->inUse.count > 8)
{
int *p = NULL;
if (hqP->hqE->inUse.count > 8)
{
int *p = NULL;
- printf("Crashing invalid hq count \n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing invalid hq count \n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-4577,8
+4563,8
@@
Void rgSCHDhmHqPDelFrmFreeLst(RgSchDlHqProcCb *hqP)
if (!hqP->hqPLst)
{
int *p = NULL;
if (!hqP->hqPLst)
{
int *p = NULL;
- printf("Crashing not part of any lst\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing not part of any lst\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-4586,8
+4572,8
@@
Void rgSCHDhmHqPDelFrmFreeLst(RgSchDlHqProcCb *hqP)
if (hqP->hqPLst != &hqP->hqE->free)
{
int *p = NULL;
if (hqP->hqPLst != &hqP->hqE->free)
{
int *p = NULL;
- printf("Crashing del from wrong lst\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing del from wrong lst\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-4599,8
+4585,8
@@
Void rgSCHDhmHqPDelFrmFreeLst(RgSchDlHqProcCb *hqP)
if (hqP->hqE->free.count > 8)
{
int *p = NULL;
if (hqP->hqE->free.count > 8)
{
int *p = NULL;
- printf("Crashing invalid hq count\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing invalid hq count\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-4631,8
+4617,8
@@
Void rgSCHDhmHqPDelFrmInUseLst(RgSchDlHqProcCb *hqP)
if (!hqP->hqPLst)
{
int *p = NULL;
if (!hqP->hqPLst)
{
int *p = NULL;
- printf("Crashing not part of any lst\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing not part of any lst\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
*p = 10;
}
@@
-4641,8
+4627,8
@@
Void rgSCHDhmHqPDelFrmInUseLst(RgSchDlHqProcCb *hqP)
if (hqP->hqPLst != &hqP->hqE->inUse)
{
int *p = NULL;
if (hqP->hqPLst != &hqP->hqE->inUse)
{
int *p = NULL;
- printf("Crashing del from wrong lst\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing del from wrong lst\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif
@@
-4654,8
+4640,8
@@
Void rgSCHDhmHqPDelFrmInUseLst(RgSchDlHqProcCb *hqP)
if (hqP->hqE->inUse.count > 8)
{
int *p = NULL;
if (hqP->hqE->inUse.count > 8)
{
int *p = NULL;
- printf("Crashing invalid hq count\n");
- printf("Crashing %d \n", *p);
+ printf("
\nDEBUG --> SCH:
Crashing invalid hq count\n");
+ printf("
\nDEBUG --> SCH:
Crashing %d \n", *p);
*p = 10;
}
#endif
*p = 10;
}
#endif