X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrrlc%2Fkw_uim.c;h=22765324fc21cf27f74a4be1dcb77f6f2ef9bbac;hb=9341af1ac8be8131df466501cace55c1e2ed26a3;hp=3ec50f5b7cc754fccfbd3dba564e185e5738f080;hpb=5625a52ad68f6ad93684e68bbbdbaef0d462cf9a;p=o-du%2Fl2.git diff --git a/src/5gnrrlc/kw_uim.c b/src/5gnrrlc/kw_uim.c index 3ec50f5b7..22765324f 100755 --- a/src/5gnrrlc/kw_uim.c +++ b/src/5gnrrlc/kw_uim.c @@ -269,6 +269,40 @@ Reason reason; RETVALUE(ROK); } +/******************************************************************* + * + * @brief Handler for UE create request + * + * @details + * + * Function : RlcDuappProcUeCreateReq + * + * Functionality: + * Handler for UE create request + * + * @params[in] pst - Post Structure + * cfg - Configuration information for one or more RLC entities + * @return ROK - success + * RFAILED - failure + * + * ****************************************************************/ +PUBLIC S16 RlcDuappProcUeCreateReq(Pst *pst, CkwCfgInfo *ueCfg) +{ + U8 idx; + S16 ret=ROK; + + ueCfg->transId = 1; + + for(idx = 0; idx < ueCfg->numEnt; idx++) + { + ueCfg->entCfg[idx].cfgType = CKW_CFG_ADD; + } + + ret = KwUiCkwCfgReq(pst, ueCfg); + return ret; + +} /* RlcDuappUeCreateReq */ + /** * @brief @@ -290,17 +324,17 @@ Reason reason; PUBLIC S16 KwUiCkwCfgReq ( Pst *pst, -SpId spId, +//SpId spId, CkwCfgInfo *cfg ) #else -PUBLIC S16 KwUiCkwCfgReq(pst, spId, cfg) +//PUBLIC S16 KwUiCkwCfgReq(pst, spId, cfg) +PUBLIC S16 KwUiCkwCfgReq(pst, cfg) Pst *pst; -SpId spId; +//SpId spId; CkwCfgInfo *cfg; #endif { - S16 ret = ROK; KwCb *tKwCb; KwUlCfgTmpData *cfgTmpData; @@ -318,16 +352,6 @@ CkwCfgInfo *cfg; #endif tKwCb = KW_GET_KWCB(pst->dstInst); - RLOG1(L_DEBUG, "spId(%d)", spId); - - /* Validate SAP ID under ERRORCLS */ - KW_VALDATE_SAP(tKwCb, spId, (&(tKwCb->u.ulCb->ckwSap)), ret); - if (ret != ROK) - { - KW_PST_FREE(pst->region, pst->pool, cfg, sizeof(CkwCfgInfo)); - RETVALUE(RFAILED); - } - KW_ALLOC(tKwCb, cfgTmpData, sizeof (KwUlCfgTmpData)); if (cfgTmpData == NULLP) @@ -825,29 +849,26 @@ Reason reason; PUBLIC S16 KwUiKwuDatReq ( Pst *pst, -SpId spId, KwuDatReqInfo *datReq, Buffer *mBuf ) #else -PUBLIC S16 KwUiKwuDatReq(pst, spId, datReq, mBuf) +PUBLIC S16 KwUiKwuDatReq(pst, datReq, mBuf) Pst *pst; -SpId spId; KwuDatReqInfo *datReq; Buffer *mBuf; #endif { S16 ret = ROK; /* Return Value */ KwDlRbCb *rbCb; /* RB Control Block */ - KwKwuSapCb *kwuSap; /* SAP Config Block */ KwCb *tKwCb; TRC3(KwUiKwuDatReq) + DU_LOG("\nRLC : Received DL Data"); + #if (ERRCLASS & ERRCLS_INT_PAR) - if ((pst->dstInst >= KW_MAX_RLC_INSTANCES) || - (spId >= (S16) kwCb[pst->dstInst]->genCfg.maxKwuSaps) || - (spId < 0)) + if(pst->dstInst >= KW_MAX_RLC_INSTANCES) { SPutMsg(mBuf); RETVALUE(RFAILED); @@ -856,17 +877,6 @@ Buffer *mBuf; tKwCb = KW_GET_KWCB(pst->dstInst); - /* Get Sap control block */ - kwuSap = tKwCb->u.dlCb->kwuDlSap + spId; - - /* Validate SAP ID under ERRORCLS */ - KW_VALDATE_SAP(tKwCb,spId, kwuSap, ret); - if (ret != ROK) - { - KW_FREE_BUF(mBuf); - RETVALUE(RFAILED); - } - /* Fetch the RbCb */ kwDbmFetchDlRbCbByRbId(tKwCb, &datReq->rlcId, &rbCb); if(!rbCb) @@ -878,8 +888,6 @@ Buffer *mBuf; RETVALUE(RFAILED); } - /* kw005.201 update the spId received in datReq to update statistics */ - rbCb->kwuSapId = spId; /* Dispatch according to mode of the rbCb */ switch (rbCb->mode) { @@ -897,23 +905,17 @@ Buffer *mBuf; } kwTmmQSdu(tKwCb,rbCb, datReq, mBuf); - /* kw005.201 ccpu00117318, updated statistics */ - kwuSap->sts.sduRx++; break; } case CM_LTE_MODE_UM: { kwUmmQSdu(tKwCb,rbCb, datReq, mBuf); - /* kw005.201 ccpu00117318, updated statistics */ - kwuSap->sts.sduRx++; break; } case CM_LTE_MODE_AM: { kwAmmQSdu(tKwCb,rbCb, mBuf, datReq); - /* kw005.201 ccpu00117318, updated statistics */ - kwuSap->sts.sduRx++; break; } default: