X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2F5gnrrlc%2Fkw_ul_ex_ms.c;h=fea94dea6ee14bd95d2eab28a6355703669152df;hb=def50dc175cebc67238db5f1acd5ff322a2279bd;hp=108c30addcdedc1aa23e957005967d693cb42a10;hpb=0a26c487f1b6bbb5217e47b15fa8273b2e749283;p=o-du%2Fl2.git diff --git a/src/5gnrrlc/kw_ul_ex_ms.c b/src/5gnrrlc/kw_ul_ex_ms.c index 108c30add..fea94dea6 100755 --- a/src/5gnrrlc/kw_ul_ex_ms.c +++ b/src/5gnrrlc/kw_ul_ex_ms.c @@ -58,6 +58,7 @@ static int RLOG_FILE_ID=206; #include "kw_ul.x" #include "kw_udx.x" +#include "rlc_mac_inf.h" #include "du_app_rlc_inf.h" #ifdef TENB_STATS @@ -88,7 +89,6 @@ S16 rlcUlInitExt S16 rlcUlInitExt() #endif { - TRC2(rlcUlInitExt); return ROK; } /* kwInitExt */ @@ -139,7 +139,6 @@ Reason reason; /* reason */ #endif { RlcCb *tRlcCb; - TRC3(rlcUlActvInit) if (inst >= MAX_RLC_INSTANCES) { @@ -171,7 +170,7 @@ Reason reason; /* reason */ tRlcCb->init.acnt = TRUE; /* enable accounting */ tRlcCb->init.usta = TRUE; /* enable unsolicited status */ tRlcCb->init.trc = FALSE; /* enable trace */ - tRlcCb->init.procId = SFndProcId(); + tRlcCb->init.procId = ODU_GET_PROCID(); rlcCb[inst] = tRlcCb; @@ -218,7 +217,6 @@ Buffer *mBuf; /* message buffer */ { S16 ret = ROK; - TRC3(kwActvTsk); switch(pst->srcEnt) { @@ -239,9 +237,14 @@ Buffer *mBuf; /* message buffer */ break; } - case EVENT_RLC_UL_UE_CREATE_REQ: /* UE Create Request */ + case EVENT_RLC_UE_CREATE_REQ: /* UE Create Request */ { - ret = unpackRlcUlUeCreateReq(RlcUlProcUeCreateReq, pst, mBuf); + ret = unpackRlcUeCreateReq(RlcProcUeCreateReq, pst, mBuf); + break; + } + case EVENT_RLC_UE_RECONFIG_REQ: /* UE Reconfig Request */ + { + ret = unpackRlcUeReconfigReq(RlcProcUeReconfigReq, pst, mBuf); break; } @@ -278,7 +281,7 @@ Buffer *mBuf; /* message buffer */ #endif #endif /* LCLKW */ default: - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); if (pst->dstInst < MAX_RLC_INSTANCES) { RLOG1(L_FATAL,"Received Invalid Event[%d] from SM", @@ -323,7 +326,7 @@ Buffer *mBuf; /* message buffer */ #endif /* LCCKW */ default: - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); if (pst->dstInst < MAX_RLC_INSTANCES) { RLOG1(L_ERROR,"Received Invalid Event[%d] from RLC UL", @@ -375,7 +378,7 @@ Buffer *mBuf; /* message buffer */ } #endif /* LCKWU */ default: - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); if (pst->dstInst < MAX_RLC_INSTANCES) { RLOG1(L_ERROR,"Received Invalid Event[%d] from RRC", @@ -406,7 +409,7 @@ Buffer *mBuf; /* message buffer */ } default: - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); if (pst->dstInst < MAX_RLC_INSTANCES) { RLOG1(L_ERROR,"Received Invalid Event[%d] from PDCP", @@ -430,16 +433,16 @@ Buffer *mBuf; /* message buffer */ break; } - case EVTRLCULDAT: /* Dedicated Channel Data request */ + case EVENT_UL_DATA_TO_RLC: /* UL Data request */ { - ret = unpackRcvdUlData(RlcProcUlData, pst, mBuf); + ret = unpackRlcUlData(RlcProcUlData, pst, mBuf); break; } #endif /* LCRGU */ default: - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); if (pst->dstInst < MAX_RLC_INSTANCES) { RLOG1(L_ERROR,"Received Invalid Event[%d] from MAC", @@ -458,7 +461,7 @@ Buffer *mBuf; /* message buffer */ case KWU_EVT_TTI_IND: { rlcUlBatchProc(); - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); break; } } @@ -478,14 +481,14 @@ Buffer *mBuf; /* message buffer */ tRlcCb = RLC_GET_RLCCB(pst->dstInst); TSL2SendStatsToApp(&(tRlcCb->genCfg.lmPst), 0); - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); break; } default: { printf("\n ERROR Invalid Event[%d] from CL to PDCPUL\n", pst->event); - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); break; } } @@ -499,7 +502,7 @@ Buffer *mBuf; /* message buffer */ { RLOG1(L_ERROR, "Received Invalid Source Entity[%d]",pst->event); } - ODU_PUT_MSG(mBuf); + ODU_PUT_MSG_BUF(mBuf); ret = RFAILED; break; }