X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrrlc%2Fkw_utl_ul.c;h=b8a56f479c9a6152dfdb1a5e6b5764abea5a1c3a;hb=b9a6860b8d95b57307e3e30b95642c83a762241e;hp=f11e7cc6e7154e9856b6035d8f3be7c81ff34d0a;hpb=def50dc175cebc67238db5f1acd5ff322a2279bd;p=o-du%2Fl2.git diff --git a/src/5gnrrlc/kw_utl_ul.c b/src/5gnrrlc/kw_utl_ul.c index f11e7cc6e..b8a56f479 100755 --- a/src/5gnrrlc/kw_utl_ul.c +++ b/src/5gnrrlc/kw_utl_ul.c @@ -120,7 +120,7 @@ uint8_t rlcUtlRcvFrmMac(RlcCb *gCb, KwDatIndInfo *datIndInfo) { if(datIndInfo->lchData[i].pdu.mBuf[j]) { - RLC_FREE_BUF_WC(datIndInfo->lchData[i].pdu.mBuf[j]); + ODU_PUT_MSG_BUF(datIndInfo->lchData[i].pdu.mBuf[j]); } } } @@ -155,7 +155,7 @@ uint8_t rlcUtlRcvFrmMac(RlcCb *gCb, KwDatIndInfo *datIndInfo) { if(pduInfo->mBuf[j]) { - RLC_FREE_BUF_WC(pduInfo->mBuf[j]); + ODU_PUT_MSG_BUF(pduInfo->mBuf[j]); } } continue; @@ -221,7 +221,7 @@ uint8_t rlcUtlSendUlDataToDu(RlcCb *gCb, RlcUlRbCb *rbCb, Buffer *sdu) { DU_LOG("\nRLC : rlcUtlSendUlDataToDu: Memory allocation failed UEID:%d \ CELLID:%d", rbCb->rlcId.ueId, rbCb->rlcId.cellId); - RLC_FREE_BUF(sdu); + ODU_PUT_MSG_BUF(sdu); return RFAILED; } #endif /* ERRCLASS & ERRCLS_ADD_RES */ @@ -270,7 +270,7 @@ uint8_t rlcUtlSendUlDataToDu(RlcCb *gCb, RlcUlRbCb *rbCb, Buffer *sdu) } /* rlcUtlSendUlDataToDu */ -PRIVATE Void dumpRLCUlRbInformation(RlcUlRbCb* ulRbCb) +static Void dumpRLCUlRbInformation(RlcUlRbCb* ulRbCb) { if(ulRbCb->mode == CM_LTE_MODE_UM) { @@ -400,21 +400,9 @@ S16 rlcUtlL2MeasUlInit(RlcCb *gCb) * @return Void * */ -#ifdef ANSI - Void rlcUtlCalUlIpThrPutIncTTI -( -RlcCb *gCb, -RlcUlRbCb *rbCb, -uint32_t ttiCnt -) -#else -Void rlcUtlCalUlIpThrPutIncTTI(gCb, rbCb, ttiCnt) -RlcCb *gCb; -RlcUlRbCb *rbCb; -uint32_t ttiCnt; -#endif +Void rlcUtlCalUlIpThrPutIncTTI(RlcCb *gCb,RlcUlRbCb *rbCb,uint32_t ttiCnt) { - VOLATILE uint32_t startTime = 0; + volatile uint32_t startTime = 0; /*starting Task*/ SStartTask(&startTime, PID_RLC_IP_TPT_INCTTI); @@ -478,24 +466,16 @@ uint32_t ttiCnt; * @return Void * */ -#ifdef ANSI - Void rlcUtlCalUlIpThrPut +Void rlcUtlCalUlIpThrPut ( RlcCb *gCb, RlcUlRbCb *rbCb, Buffer *pdu, uint32_t ttiCnt ) -#else -Void rlcUtlCalUlIpThrPut(gCb, rbCb, pdu, ttiCnt) -RlcCb *gCb; -RlcUlRbCb *rbCb; -Buffer *pdu; -uint32_t ttiCnt; -#endif { MsgLen rlcSduSz = 0; /*Holds length of Rlc Sdu*/ - VOLATILE uint32_t startTime = 0; + volatile uint32_t startTime = 0; /*starting Task*/ SStartTask(&startTime, PID_RLC_IP_TPT_INCVOL); @@ -533,17 +513,7 @@ uint32_t ttiCnt; * -# ROK */ -#ifdef ANSI -S16 rlcUtlHdlL2TmrExp -( -RlcCb *gCb, -RlcL2MeasEvtCb *measEvtCb -) -#else -S16 rlcUtlHdlL2TmrExp(measEvtCb) -RlcCb *gCb; -RlcL2MeasEvtCb *measEvtCb; -#endif +S16 rlcUtlHdlL2TmrExp(RlcCb *gCb,RlcL2MeasEvtCb *measEvtCb) { #ifdef LTE_L2_MEAS_RLC @@ -588,17 +558,7 @@ RlcL2MeasEvtCb *measEvtCb; * -# ROK */ -#ifdef ANSI -S16 rlcUtlSndUlL2MeasCfm -( -RlcCb *gCb, -RlcL2MeasEvtCb *measEvtCb -) -#else -S16 rlcUtlSndUlL2MeasCfm(gCb, measEvtCb) -RlcCb *gCb; -RlcL2MeasEvtCb *measEvtCb; -#endif +S16 rlcUtlSndUlL2MeasCfm(RlcCb *gCb,RlcL2MeasEvtCb *measEvtCb) { uint32_t qciIdx; RlcL2MeasCb *measCb; @@ -693,19 +653,7 @@ RlcL2MeasEvtCb *measEvtCb; * -# ROK */ -#ifdef ANSI -S16 rlcUtlSndUlL2MeasNCfm -( -RlcCb *gCb, -RlcL2MeasReqEvt *measReqEvt, -RlcL2MeasCfmEvt *measCfmEvt -) -#else -S16 rlcUtlSndUlL2MeasNCfm(gCb, measReqEvt, measCfmEvt) -RlcCb *gCb; -RlcL2MeasReqEvt *measReqEvt; -RlcL2MeasCfmEvt *measCfmEvt; -#endif +S16 rlcUtlSndUlL2MeasNCfm(RlcCb *gCb,RlcL2MeasReqEvt *measReqEvt,RlcL2MeasCfmEvt *measCfmEvt) { RlcMiLkwL2MeasCfm(&gCb->genCfg.lmPst, measCfmEvt); @@ -727,21 +675,13 @@ RlcL2MeasCfmEvt *measCfmEvt; * @param[out] numLCh Number of LCh in array lChId. **/ -#ifdef ANSI S16 rlcUtlValidateL2Meas ( RlcL2MeasReqEvt *measReqEvt, RlcL2MeasCfmEvt *measCfmEvt, -CmLteLcId *lChId, -uint8_t *numLCh +CmLteLcId *lChId, +uint8_t *numLCh ) -#else -S16 rlcUtlValidateL2Meas(measReqEvt, measCfmEvt, lChId, numLCh) -RlcL2MeasReqEvt *measReqEvt; -RlcL2MeasCfmEvt *measCfmEvt; -CmLteLcId *lChId; -uint8_t *numLCh; -#endif { uint8_t measType; S16 ret; @@ -868,17 +808,7 @@ uint8_t *numLCh; }/* rlcUtlValidateL2Meas */ #endif -#ifdef ANSI -S16 rlcUtlValidateIpThL2Meas -( -RlcL2MeasReqEvt *measReqEvt, -RlcL2MeasCfmEvt *measCfmEvt -) -#else -S16 rlcUtlValidateIpThL2Meas(measReqEvt, measCfmEvt) -RlcL2MeasReqEvt *measReqEvt; -RlcL2MeasCfmEvt *measCfmEvt; -#endif +S16 rlcUtlValidateIpThL2Meas(RlcL2MeasReqEvt *measReqEvt,RlcL2MeasCfmEvt *measCfmEvt) { uint8_t measType; uint8_t lsbNibble = 0; @@ -926,20 +856,8 @@ RlcL2MeasCfmEvt *measCfmEvt; * * @return Void */ -#ifdef ANSI -Void rlcUtlResetUlL2MeasInRlcRb -( -RlcCb *gCb, -RlcL2MeasCb *measCb, -uint8_t measType -) -#else -Void rlcUtlResetUlL2MeasInRlcRb(measCb, measType) -RlcCb *gCb; -RlcL2MeasCb *measCb; -uint8_t measType; -#endif +Void rlcUtlResetUlL2MeasInRlcRb(RlcCb *gCb,RlcL2MeasCb *measCb,uint8_t measType) { uint32_t rbIdx; uint32_t ueIdx; @@ -997,19 +915,7 @@ uint8_t measType; * @return S16 * -# ROK */ -#ifdef ANSI -Void rlcUtlPlcMeasDatInL2Sts -( -RlcL2Cntr *measData, -RlcL2MeasRbCb *rbL2Cb, -uint8_t measType -) -#else -Void rlcUtlPlcMeasDatInL2Sts(measData, rbL2Cb, measType) -RlcL2Cntr *measData; -RlcL2MeasRbCb *rbL2Cb; -uint8_t measType; -#endif +Void rlcUtlPlcMeasDatInL2Sts(RlcL2Cntr *measData,RlcL2MeasRbCb *rbL2Cb,uint8_t measType) { /* We should check the number of measType in the request. This can be done * by looking at each bit in the measType. Also store the measData in the @@ -1104,7 +1010,7 @@ RlcAmRecBuf* rlcUtlGetRecBuf(CmLListCp *recBufLst, RlcSn sn) CM_LLIST_NEXT_NODE(recBufLstCp, node); } return NULLP; -} /* rlcUtlStoreRecBuf */ +} /* rlcUtlGetRecBuf */ /** * * @brief Delete the UL buffer from the list @@ -1128,12 +1034,74 @@ void rlcUtlDelRecBuf(CmLListCp *recBufLst, RlcAmRecBuf *recBuf, RlcCb *gCb) recBufLstCp = &recBufLst[hashKey]; cmLListDelFrm(recBufLstCp, &recBuf->lnk); - RLC_FREE_WC(gCb, recBuf, sizeof(RlcAmRecBuf)); + RLC_FREE(gCb, recBuf, sizeof(RlcAmRecBuf)); return; } /* rlcUtlDelRecBuf */ +#ifdef NR_RLC_UL +/** + * + * @brief Store the UL buffer in hashList + * + * + * @b Description + * + * Use the SN % binSize as key and store the received UL buffer + * @param[in] recBufLst List CP array + * @param[in] recBuf received buffer + * @param[in] sn sn of the received buffer + * + * + * @return Void + */ +void rlcUtlStoreUmRecBuf(CmLListCp *recBufLst, RlcUmRecBuf *recBuf, RlcSn sn) +{ + uint32_t hashKey; + + hashKey = (sn % RLC_RCV_BUF_BIN_SIZE ); + recBuf->lnk.node = (PTR)recBuf; + cmLListAdd2Tail(&(recBufLst[hashKey]), &recBuf->lnk); + + return; +} /* rlcUtlStoreUmRecBuf */ +/** + * + * @brief Retrieve the UL buffer from the list + * + * + * @Description + * + * Use the SN % binSize as key and retrieve the UL buffer + * @param[in] recBufLst List CP array + * @param[in] sn sn of the received buffer + * + * + * @return Void + */ +RlcUmRecBuf* rlcUtlGetUmRecBuf(CmLListCp *recBufLst, RlcSn sn) +{ + uint32_t hashKey; + CmLListCp *recBufLstCp; + RlcUmRecBuf *recBuf; + CmLList *node = NULLP; + hashKey = (sn % RLC_RCV_BUF_BIN_SIZE ); + + recBufLstCp = &recBufLst[hashKey]; + CM_LLIST_FIRST_NODE(recBufLstCp, node); + while(node) + { + recBuf = (RlcUmRecBuf *) node->node; + if(recBuf->umHdr.sn == sn) + { + return recBuf; + } + CM_LLIST_NEXT_NODE(recBufLstCp, node); + } + return NULLP; +} /* rlcUtlGetUmRecBuf */ +#endif /********************************************************************30**