rlcTqCp->nxtEnt = 0;
gCb->rlcThpt.inst = gCb->init.inst;
- gCb->rlcThpt.thptTmr.tmrEvnt = TMR_NONE;
- gCb->rlcThpt.numActvUe = 0;
- memset(gCb->rlcThpt.thptPerUe, 0, MAX_NUM_UE * sizeof(RlcThptPerUe));
+ gCb->rlcThpt.ueTputInfo.ueThptTmr.tmrEvnt = TMR_NONE;
+ gCb->rlcThpt.ueTputInfo.numActvUe = 0;
+ memset(gCb->rlcThpt.ueTputInfo.thptPerUe, 0, MAX_NUM_UE * sizeof(RlcThptPerUe));
+ gCb->rlcThpt.snssaiTputInfo.snssaiThptTmr.tmrEvnt = TMR_NONE;
+
if(gCb->genCfg.rlcMode == LKW_RLC_MODE_DL)
{
RLC_ALLOC(gCb,gCb->u.dlCb, sizeof (RlcDlCb));
rlcUtlInitToBeFreed(gCb, &(gCb->u.dlCb->toBeFreed));
rlcUtlInitializeSelfPst(gCb);
- if(SGetMsg(gCb->init.region,
- gCb->init.pool,
- &(gCb->u.dlCb->selfPstMBuf)) != ROK)
+ if(ODU_GET_MSG_BUF(gCb->init.region, gCb->init.pool, &(gCb->u.dlCb->selfPstMBuf)) != ROK)
{
RLC_FREE(gCb,gCb->u.dlCb->udxDlSap, rlcSapSize);
RLC_FREE(gCb,gCb->u.dlCb->rlcKwuDlSap, rlcSapSize);
gCb->init.cfgDone = TRUE;
+ /* TODO : make this generic for DL and UL after support for UL throughput calculation is added */
+ if(gCb->genCfg.rlcMode == LKW_RLC_MODE_DL)
+ {
+ /* Starting timer to print throughput */
+ if((rlcChkTmr(gCb, (PTR)(&gCb->rlcThpt), EVENT_RLC_UE_THROUGHPUT_TMR)) == FALSE)
+ {
+ DU_LOG("\nINFO --> RLC_DL : Starting UE Throughput timer");
+ rlcStartTmr(gCb, (PTR)(&gCb->rlcThpt), EVENT_RLC_UE_THROUGHPUT_TMR);
+ }
+ }
+ /* Starting timer to print throughput */
+ if((rlcChkTmr(gCb, (PTR)(&gCb->rlcThpt), EVENT_RLC_SNSSAI_THROUGHPUT_TMR)) == FALSE)
+ {
+ DU_LOG("\nINFO --> RLC_DL : Starting SNSSAI Throughput timer");
+ rlcStartTmr(gCb, (PTR)(&gCb->rlcThpt), EVENT_RLC_SNSSAI_THROUGHPUT_TMR);
+ }
+
+
return (LCM_REASON_NOT_APPL);
}
return (RFAILED);
}
- DU_LOG("\nDEBUG --> RLC : RlcMiRlcConfigReq elmId(%d)", cfg->hdr.elmId.elmnt);
+ DU_LOG("\nDEBUG --> RLC : RlcMiRlcConfigReq elmId(%d)", cfg->hdr.elmId.elmnt);
switch(cfg->hdr.elmId.elmnt)
{
{
if (gCb->u.dlCb->selfPstMBuf != NULL)
{
- SPutMsg(gCb->u.dlCb->selfPstMBuf);
+ ODU_PUT_MSG_BUF(gCb->u.dlCb->selfPstMBuf);
}
RLC_FREE(gCb,gCb->u.dlCb, sizeof (RlcDlCb));
}
}
}
}
-
+
if(gCb->genCfg.rlcMode == LKW_RLC_MODE_DL)
{
rlcDbmDlShutdown(gCb);
+ rlcDelTputSnssaiList(gCb, DIR_DL);
}
else
{
rlcDbmUlShutdown(gCb);
+ rlcDelTputSnssaiList(gCb, DIR_UL);
}
rlcLmmCleanGblRsrcs(gCb);
return RFAILED;
}
- if (SGetMsg(pst.region, pst.pool, &dstMbuf) != ROK)
+ if (ODU_GET_MSG_BUF(pst.region, pst.pool, &dstMbuf) != ROK)
{
DU_LOG("\nERROR --> RLC : Memory Allocation failed");
return RFAILED;