/******************************************************************************* ################################################################################ # Copyright (c) [2017-2019] [Radisys] # # # # Licensed under the Apache License, Version 2.0 (the "License"); # # you may not use this file except in compliance with the License. # # You may obtain a copy of the License at # # # # http://www.apache.org/licenses/LICENSE-2.0 # # # # Unless required by applicable law or agreed to in writing, software # # distributed under the License is distributed on an "AS IS" BASIS, # # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # # See the License for the specific language governing permissions and # # limitations under the License. # ################################################################################ *******************************************************************************/ /* header include files (.h) */ #include "common_def.h" #include "rgu.h" /* RGU interface includes*/ #include "lkw.h" /* LKW defines */ #include "ckw.h" /* CKW defines */ #include "kwu.h" /* KWU defines */ #include "kw_env.h" /* RLC environment options */ #include "kw.h" /* RLC defines */ #include "kw_udx.h" #include "kw_ul.h" #include "kw_dl.h" /* header/extern include files (.x) */ #include "rgu.x" #include "lkw.x" /* LKW */ #include "ckw.x" /* CKW */ #include "kwu.x" /* KWU */ #include "kw_err.h" #include "kw.x" #include "kw_udx.x" #include "kw_dl.x" #include "kw_ul.x" #include "rlc_mac_inf.h" #include "du_app_rlc_inf.h" #include "rlc_utils.h" #include "rlc_upr_inf_api.h" /******************************************************************* * * @brief Fills RLC UL UE Cfg Rsp from RlcCRsp * * @details * * Function : fillRlcUlUeCfgRsp * * Functionality: * Fills RLC UL UE Cfg Rsp from RlcCRsp * * @params[in] Pointer to RlcCfgCfm * Pointer to RlcUeCfgRsp * * @return void * *****************************************************************/ void fillRlcUlUeCfgRsp(RlcUeCfgRsp *rlcCfgRsp, RlcCfgCfmInfo *rlcCRsp) { uint8_t idx; rlcCfgRsp->cellId = rlcCRsp->cellId; rlcCfgRsp->ueIdx = rlcCRsp->ueId; for(idx = 0; idx < rlcCRsp->numEnt; idx++) { if(rlcCRsp->entCfgCfm[idx].status.status == CKW_CFG_CFM_OK) { rlcCfgRsp->result = RLC_DU_APP_RSP_OK; rlcCfgRsp->reason = rlcCRsp->entCfgCfm[idx].status.reason; } else { rlcCfgRsp->result = RLC_DU_APP_RSP_NOK; rlcCfgRsp->reason = rlcCRsp->entCfgCfm[idx].status.reason; } } } /******************************************************************* * * @brief Fills the entity mode and direction compiling to seed code * * @details * * Function : fillEntModeAndDir * * Functionality: * Fills the entity mode and direction compiling to seed code * * @params[in] Pointer to entMode * Pointer to direction * RlcMode Param * @return void * ****************************************************************/ void fillEntModeAndDir(uint8_t *entMode, uint8_t *direction, RlcMode rlcMode) { switch(rlcMode) { case RLC_AM: *entMode = CM_LTE_MODE_AM; *direction = RLC_CFG_DIR_BOTH; break; case RLC_UM_BI_DIRECTIONAL: *entMode = CM_LTE_MODE_UM; *direction = RLC_CFG_DIR_BOTH; break; case RLC_UM_UNI_DIRECTIONAL_UL: *entMode = CM_LTE_MODE_UM; *direction = RLC_CFG_DIR_UL; break; case RLC_UM_UNI_DIRECTIONAL_DL: *entMode = CM_LTE_MODE_UM; *direction = RLC_CFG_DIR_DL; break; default : DU_LOG("\nRLC: Rlc Mode invalid %d", rlcMode); break; } } /******************************************************************* * * @brief Handles Ue Create Request from DU APP * * @details * * Function : RlcUlProcUeCreateReq * * Functionality: * Handles Ue create Request from DU APP * * @params[in] Post structure pointer * RlcUeCfg pointer * @return ROK - success * RFAILED - failure * * ****************************************************************/ uint8_t RlcUlProcUeCreateReq(Pst *pst, RlcUeCfg *ueCfg) { uint8_t idx; uint8_t ret = ROK; uint8_t lChRbIdx; RlcCfgInfo *rlcUeCfg = NULLP; RlcCb *rlcUeCb = NULLP; rlcUeCb = RLC_GET_RLCCB(pst->dstInst); RLC_ALLOC(rlcUeCb, rlcUeCfg, sizeof(RlcCfgInfo)); if(rlcUeCfg) { memset(rlcUeCfg, 0, sizeof(RlcCfgInfo)); rlcUeCfg->ueId = ueCfg->ueIdx; rlcUeCfg->cellId = ueCfg->cellId; rlcUeCfg->numEnt = ueCfg->numLcs; rlcUeCfg->transId = getTransId(); for(idx = 0; idx < ueCfg->numLcs; idx++) { lChRbIdx = 0; rlcUeCfg->entCfg[idx].rbId = ueCfg->rlcBearerCfg[idx].rbId; rlcUeCfg->entCfg[idx].rbType = ueCfg->rlcBearerCfg[idx].rbType; // SRB or DRB rlcUeCfg->entCfg[idx].lCh[lChRbIdx].lChId = ueCfg->rlcBearerCfg[idx].lcId; rlcUeCfg->entCfg[idx].lCh[lChRbIdx].type = ueCfg->rlcBearerCfg[idx].lcType; fillEntModeAndDir(&rlcUeCfg->entCfg[idx].entMode, &rlcUeCfg->entCfg[idx].dir,\ ueCfg->rlcBearerCfg[idx].rlcMode); rlcUeCfg->entCfg[idx].cfgType = CKW_CFG_ADD; switch(rlcUeCfg->entCfg[idx].entMode) { case CM_LTE_MODE_AM: { /* DL AM INFO */ rlcUeCfg->entCfg[idx].m.amInfo.dl.snLen = ueCfg->rlcBearerCfg[idx].u.amCfg.dlAmCfg.snLenDl; rlcUeCfg->entCfg[idx].m.amInfo.dl.pollRetxTmr = ueCfg->rlcBearerCfg[idx].u.amCfg.dlAmCfg.pollRetxTmr; rlcUeCfg->entCfg[idx].m.amInfo.dl.pollPdu = ueCfg->rlcBearerCfg[idx].u.amCfg.dlAmCfg.pollPdu; rlcUeCfg->entCfg[idx].m.amInfo.dl.pollByte = ueCfg->rlcBearerCfg[idx].u.amCfg.dlAmCfg.pollByte; rlcUeCfg->entCfg[idx].m.amInfo.dl.maxRetx = ueCfg->rlcBearerCfg[idx].u.amCfg.dlAmCfg.maxRetxTh; /* UL AM INFO */ lChRbIdx++; //lChRbIdx = 1, indicates UL AM rlcUeCfg->entCfg[idx].lCh[lChRbIdx].lChId = ueCfg->rlcBearerCfg[idx].lcId; rlcUeCfg->entCfg[idx].lCh[lChRbIdx].type = ueCfg->rlcBearerCfg[idx].lcType; rlcUeCfg->entCfg[idx].m.amInfo.ul.snLen = ueCfg->rlcBearerCfg[idx].u.amCfg.ulAmCfg.snLenUl; rlcUeCfg->entCfg[idx].m.amInfo.ul.staProhTmr = ueCfg->rlcBearerCfg[idx].u.amCfg.ulAmCfg.statProhTmr; rlcUeCfg->entCfg[idx].m.amInfo.ul.reOrdTmr = ueCfg->rlcBearerCfg[idx].u.amCfg.ulAmCfg.reAssemTmr; break; } case CM_LTE_MODE_UM: { /* UL UM CONFIG */ rlcUeCfg->entCfg[idx].m.umInfo.ul.snLen = ueCfg->rlcBearerCfg[idx].u.umBiDirCfg.ulUmCfg.snLenUlUm; rlcUeCfg->entCfg[idx].m.umInfo.ul.reOrdTmr = ueCfg->rlcBearerCfg[idx].u.umBiDirCfg.ulUmCfg.reAssemTmr; /* DL UM CONFIG */ rlcUeCfg->entCfg[idx].m.umInfo.dl.snLen = ueCfg->rlcBearerCfg[idx].u.umBiDirCfg.dlUmCfg.snLenDlUm; break; } default: break; }/* End of switch(entMode) */ } ret = RlcProcCfgReq(pst, rlcUeCfg); } else { DU_LOG("\nRLC: Failed to allocate memory "); ret = RFAILED; } RLC_FREE_SHRABL_BUF(pst->region, pst->pool, ueCfg, sizeof(RlcUeCfg)); return ret; } /******************************************************************* * * @brief filling the structure of rrc delivery msg info * * @details * * Function : BuildAndSendRrcDeliveryReportToDu * * Functionality: filling the structure of rrc delivery msg info * * @return ROK - success * RFAILED - failure * * ****************************************************************/ uint8_t BuildAndSendRrcDeliveryReportToDu( RlcDlRrcMsgInfo *dlRrcMsgInfo ) { Pst pst; RrcDeliveryReport *rrcDelivery; DU_LOG("\nRLC : Filling the RRC Delivery Report"); RLC_ALLOC_SHRABL_BUF(RLC_MEM_REGION_UL, RLC_POOL, rrcDelivery, sizeof(RrcDeliveryReport)); if(rrcDelivery) { rrcDelivery->cellId = dlRrcMsgInfo->cellId; rrcDelivery->ueIdx = dlRrcMsgInfo->ueIdx; rrcDelivery->srbId = dlRrcMsgInfo->lcId ; rrcDelivery->rrcDeliveryStatus.deliveryStatus = PDCP_SN; rrcDelivery->rrcDeliveryStatus.triggeringMessage = PDCP_SN; /* Sending UL RRC Message transfeer to DU APP */ memset(&pst, 0, sizeof(Pst)); FILL_PST_RLC_TO_DUAPP(pst, RLC_UL_INST, EVENT_RRC_DELIVERY_MSG_TRANS_TO_DU); rlcSendRrcDeliveryReportToDu(&pst, rrcDelivery); } else { DU_LOG("\nRLC : Memory allocation failed"); } return ROK; } /* **************************************************************** * * @brief Process the DL RRC Message from DU APP * * @details * * Function : RlcProcDlRrcMsgTransfer * * Functionality: Process the DL RRC Message from DU APP * * @params[in] Post structure * DL RRC Message info * @return ROK - success * RFAILED - failure * * ****************************************************************/ uint8_t RlcProcDlRrcMsgTransfer(Pst *pst, RlcDlRrcMsgInfo *dlRrcMsgInfo) { Buffer *mBuf; KwuDatReqInfo *datReqInfo; RLC_SHRABL_STATIC_BUF_ALLOC(RLC_MEM_REGION_DL, RLC_POOL, datReqInfo, sizeof(KwuDatReqInfo)); if(!datReqInfo) { DU_LOG("\nRLC : Memory allocation failed in RlcProcDlRrcMsgTransfer"); RLC_SHRABL_STATIC_BUF_FREE(pst->region, pst->pool, dlRrcMsgInfo->rrcMsg, dlRrcMsgInfo->msgLen); RLC_SHRABL_STATIC_BUF_FREE(pst->region, pst->pool, dlRrcMsgInfo, sizeof(RlcDlRrcMsgInfo)); return RFAILED; } datReqInfo->rlcId.rbType = dlRrcMsgInfo->rbType; datReqInfo->rlcId.rbId = dlRrcMsgInfo->rbId; datReqInfo->rlcId.ueId = dlRrcMsgInfo->ueIdx; datReqInfo->rlcId.cellId = dlRrcMsgInfo->cellId; datReqInfo->lcType = dlRrcMsgInfo->lcType; datReqInfo->sduId = ++(rlcCb[pst->dstInst]->dlSduId); /* Copy fixed buffer to message */ if(ODU_GET_MSG_BUF(RLC_MEM_REGION_UL, RLC_POOL, &mBuf) != ROK) { DU_LOG("\nRLC : Memory allocation failed at RlcMacProcUlData"); RLC_SHRABL_STATIC_BUF_FREE(RLC_MEM_REGION_DL, RLC_POOL, datReqInfo, sizeof(KwuDatReqInfo)); RLC_SHRABL_STATIC_BUF_FREE(pst->region, pst->pool, dlRrcMsgInfo->rrcMsg, dlRrcMsgInfo->msgLen); RLC_SHRABL_STATIC_BUF_FREE(pst->region, pst->pool, dlRrcMsgInfo, sizeof(RlcDlRrcMsgInfo)); return RFAILED; } oduCpyFixBufToMsg(dlRrcMsgInfo->rrcMsg, mBuf, dlRrcMsgInfo->msgLen); rlcProcDlData(pst, datReqInfo, mBuf); /* RRC Delivery report is only send when RRC Delivery status report is true in DL RRC Message */ if(dlRrcMsgInfo->deliveryStaRpt) { BuildAndSendRrcDeliveryReportToDu(dlRrcMsgInfo); } /* Free memory allocated by du app */ RLC_SHRABL_STATIC_BUF_FREE(RLC_MEM_REGION_DL, RLC_POOL, datReqInfo, sizeof(KwuDatReqInfo)); RLC_SHRABL_STATIC_BUF_FREE(pst->region, pst->pool, dlRrcMsgInfo->rrcMsg, dlRrcMsgInfo->msgLen); RLC_SHRABL_STATIC_BUF_FREE(pst->region, pst->pool, dlRrcMsgInfo, sizeof(RlcDlRrcMsgInfo)); return ROK; } /******************************************************************* * * @brief Process UL data from UE * * @details * * Function : RlcProcUlData * * Functionality: * This function receives the PDU from MAC. * seggregates common and dedicated logical channel * PDU and call respective handler. * * @params[in] * @return ROK - success * RFAILED - failure * * ****************************************************************/ uint8_t RlcProcUlData(Pst *pst, RlcData *ulData) { uint8_t ret = ROK; uint8_t idx, pduIdx; uint8_t lcId; /* Logical Channel */ uint8_t numDLch = 0; /* Number of dedicated logical channel */ bool dLchPduPres; /* PDU received on dedicated logical channel */ RguLchDatInd dLchData[MAX_NUM_LC]; /* PDU info on dedicated logical channel */ RguDDatIndInfo *dLchUlDat; /* UL data on dedicated logical channel */ RguCDatIndInfo *cLchUlDat; /* UL data on common logical channel */ /* Initializing dedicated logical channel Database */ DU_LOG("\nRLC: Received UL Data request from MAC"); for(idx = 0; idx < MAX_NUM_LC; idx++) { dLchData[idx].lcId = idx; dLchData[idx].pdu.numPdu = 0; } dLchPduPres = FALSE; /* Seggregate PDUs received on common and dedicated channels * and call common channel's handler */ for(idx = 0; idx< ulData->numPdu; idx++) { if(ulData->pduInfo[idx].commCh) { RLC_SHRABL_STATIC_BUF_ALLOC(RLC_MEM_REGION_UL, RLC_POOL, cLchUlDat, \ sizeof(RguCDatIndInfo)); if(!cLchUlDat) { DU_LOG("\nRLC : Memory allocation failed at RlcProcUlData"); ret = RFAILED; break; } memset(cLchUlDat, 0, sizeof(RguCDatIndInfo)); cLchUlDat->cellId = ulData->cellId; GET_UE_IDX(ulData->rnti, cLchUlDat->rnti); cLchUlDat->lcId = ulData->pduInfo[idx].lcId; /* Copy fixed buffer to message */ if(ODU_GET_MSG_BUF(RLC_MEM_REGION_UL, RLC_POOL, &cLchUlDat->pdu) != ROK) { DU_LOG("\nRLC : Memory allocation failed at RlcProcUlData"); RLC_SHRABL_STATIC_BUF_FREE(RLC_MEM_REGION_UL, RLC_POOL, cLchUlDat, \ sizeof(RguCDatIndInfo)); ret = RFAILED; break; } oduCpyFixBufToMsg(ulData->pduInfo[idx].pduBuf, cLchUlDat->pdu, \ ulData->pduInfo[idx].pduLen); rlcProcCommLcUlData(pst, 0, cLchUlDat); } else { if(!dLchPduPres) { RLC_SHRABL_STATIC_BUF_ALLOC(RLC_MEM_REGION_UL, RLC_POOL, dLchUlDat, \ sizeof(RguDDatIndInfo)); if(!dLchUlDat) { DU_LOG("\nRLC : Memory allocation failed at RlcMacProcUlData"); ret = RFAILED; break; } dLchPduPres = TRUE; } /* Copy fixed buffer to message */ lcId = ulData->pduInfo[idx].lcId; if(ODU_GET_MSG_BUF(RLC_MEM_REGION_UL, RLC_POOL, \ &dLchData[lcId].pdu.mBuf[dLchData[lcId].pdu.numPdu]) != ROK) { DU_LOG("\nRLC : Memory allocation failed at RlcMacProcUlData"); for(pduIdx=0; pduIdx < dLchData[lcId].pdu.numPdu; pduIdx++) { ODU_PUT_MSG_BUF(dLchData[lcId].pdu.mBuf[dLchData[lcId].pdu.numPdu]); } RLC_SHRABL_STATIC_BUF_FREE(RLC_MEM_REGION_UL, RLC_POOL, dLchUlDat, \ sizeof(RguDDatIndInfo)); ret = RFAILED; break; } oduCpyFixBufToMsg(ulData->pduInfo[idx].pduBuf, \ dLchData[lcId].pdu.mBuf[dLchData[lcId].pdu.numPdu],\ ulData->pduInfo[idx].pduLen); dLchData[lcId].pdu.numPdu++; } } /* If any PDU received on dedicated logical channel, copy into RguDDatIndInfo * and call its handler */ if(ret == ROK) { if(dLchPduPres) { dLchUlDat->cellId = ulData->cellId; dLchUlDat->rnti = ulData->rnti; for(idx = 0; idx < MAX_NUM_LC; idx++) { if(dLchData[idx].pdu.numPdu) { memcpy(&dLchUlDat->lchData[numDLch], &dLchData[idx], sizeof(RguLchDatInd)); numDLch++; } } dLchUlDat->numLch = numDLch; rlcProcDedLcUlData(pst, 0, dLchUlDat); } } for(pduIdx = 0; pduIdx < ulData->numPdu; pduIdx++) { RLC_FREE_SHRABL_BUF(pst->region, pst->pool, ulData->pduInfo[pduIdx].pduBuf, \ ulData->pduInfo[pduIdx].pduLen); } RLC_FREE_SHRABL_BUF(pst->region, pst->pool, ulData, sizeof(RlcData)); return ROK; }/* End of RlcProcUlData */ /******************************************************************* * * @brief Handler for extracting common and dedicated channel * Scheduling result report. * * @details * * Function : RlcProcSchedResultRpt * * Functionality: * Handler for extracting common and dedicated channel * Scheduling result report * * @params[in] * @return ROK - success * RFAILED - failure * * ****************************************************************/ uint8_t RlcProcSchedResultRpt(Pst *pst, RlcSchedResultRpt *schRep) { uint8_t ret = ROK; uint8_t idx; /* Iterator */ uint8_t nmbDLch = 0; /* Number of dedicated logical channles */ RguCStaIndInfo *cLchSchInfo; /* Common logical channel scheduling result */ RguDStaIndInfo *dLchSchInfo; /* Dedicated logical channel scheduling result */ DU_LOG("\nRLC : Received scheduling report from MAC"); for(idx=0; idx < schRep->numLc; idx++) { /* If it is common channel, fill status indication information * and trigger the handler for each common lch separately */ if(schRep->lcSch[idx].commCh) { RLC_SHRABL_STATIC_BUF_ALLOC(RLC_MEM_REGION_DL, RLC_POOL, cLchSchInfo, \ sizeof(RguCStaIndInfo)); if(!cLchSchInfo) { DU_LOG("\nRLC: RlcProcSchedResultRpt: Memory allocation failed for cLchSchInfo"); ret = RFAILED; break; } memset(cLchSchInfo, 0, sizeof(RguCStaIndInfo)); cLchSchInfo->cellId = schRep->cellId; cLchSchInfo->lcId = schRep->lcSch[idx].lcId; cLchSchInfo->transId = schRep->slotInfo.sfn; cLchSchInfo->transId = (cLchSchInfo->transId << 16) | schRep->slotInfo.slot; cLchSchInfo->rnti = schRep->rnti; rlcProcCommLcSchedRpt(pst, 0, cLchSchInfo); } else { /* Fill status info structure if at least one dedicated channel * scheduling report is received */ if(nmbDLch == 0) { RLC_SHRABL_STATIC_BUF_ALLOC(RLC_MEM_REGION_DL, RLC_POOL, dLchSchInfo, \ sizeof(RguDStaIndInfo)); if(!dLchSchInfo) { DU_LOG("\nRLC: RlcProcSchedResultRpt: Memory allocation failed for dLchSchInfo"); ret = RFAILED; break; } dLchSchInfo->cellId = schRep->cellId; dLchSchInfo->nmbOfUeGrantPerTti = 1; /* MAC sends Scheduling report for one UE at a time. Hence filling only the 0th index of staInd */ dLchSchInfo->staInd[0].rnti = schRep->rnti; /* Storing sfn/slot into a single 32-bit variable to be used later*/ dLchSchInfo->staInd[0].transId = schRep->slotInfo.sfn; dLchSchInfo->staInd[0].transId = \ (dLchSchInfo->staInd[0].transId << 16) | schRep->slotInfo.slot; dLchSchInfo->staInd[0].nmbOfTbs = 1; dLchSchInfo->staInd[0].fillCtrlPdu = true; } /* Fill logical channel scheduling info */ dLchSchInfo->staInd[0].staIndTb[0].lchStaInd[nmbDLch].lcId = \ schRep->lcSch[idx].lcId; dLchSchInfo->staInd[0].staIndTb[0].lchStaInd[nmbDLch].totBufSize = \ schRep->lcSch[idx].bufSize; nmbDLch++; } } /* Calling handler for all dedicated channels scheduling*/ if(ret == ROK) { if(nmbDLch) { dLchSchInfo->staInd[0].staIndTb[0].nmbLch = nmbDLch; rlcProcDedLcSchedRpt(pst, 0, dLchSchInfo); } } RLC_SHRABL_STATIC_BUF_FREE(pst->region, pst->pool, schRep, sizeof(RlcSchedResultRpt)); return ret; } /********************************************************************** End of file **********************************************************************/