################################################################################
*******************************************************************************/
-/* This file contains message handling functionality for DU cell management */
-
+/* This file contains message handling functionality for DU APP */
+#include "common_def.h"
+#include "lrg.h"
+#include "legtp.h"
+#include "lkw.h"
+#include "lrg.x"
+#include "lkw.x"
+#include "du_cfg.h"
#include "du_mgr.h"
#include "du_sctp.h"
#include "du_f1ap_msg_hdl.h"
+#include "du_ue_mgr.h"
#include "lsctp.h"
#include "legtp.h"
#include "lphy_stub.h"
extern S16 cmPkLkwCfgReq(Pst *pst, KwMngmt *cfg);
extern S16 cmPkLkwCntrlReq(Pst *pst, KwMngmt *cfg);
extern S16 cmPkLrgCfgReq(Pst *pst, RgMngmt *cfg);
+extern S16 BuildAndSendE2SetupReq();
+extern S16 egtpHdlDatInd(EgtpMsg egtpMsg);
+extern uint8_t BuildAndSendDUConfigUpdate();
+extern U16 getTransId();
+extern S16 cmPkLrgSchCfgReq(Pst * pst,RgMngmt * cfg);
packMacCellCfgReq packMacCellCfgOpts[] =
{
packMacCellCfg, /* packing for light weight loosly coupled */
};
+DuMacCellStartReq packMacCellStartReqOpts[] =
+{
+ packMacCellStartReq, /* Loose coupling */
+ MacHdlCellStartReq, /* TIght coupling */
+ packMacCellStartReq /* Light weight-loose coupling */
+};
+
+DuMacCellStopReq packMacCellStopReqOpts[] =
+{
+ packMacCellStopReq, /* Loose coupling */
+ MacHdlCellStopReq, /* TIght coupling */
+ packMacCellStopReq /* Light weight-loose coupling */
+};
+
/**************************************************************************
* @brief Function to fill configs required by RLC
*
genCfg->lmPst.region = (inst == RLC_UL_INST) ?
RLC_UL_MEM_REGION:RLC_DL_MEM_REGION;
genCfg->lmPst.pool = RLC_POOL;
- genCfg->lmPst.selector = DU_SELECTOR_LC;
+ genCfg->lmPst.selector = ODU_SELECTOR_LC;
/* Fill Header */
kwMngmt.hdr.msgType = TCFG;
kwMngmt.hdr.response.mem.region = (inst == RLC_UL_INST) ?
RLC_UL_MEM_REGION:RLC_DL_MEM_REGION;
kwMngmt.hdr.response.mem.pool = DU_POOL;
- kwMngmt.hdr.response.selector = DU_SELECTOR_LC;
+ kwMngmt.hdr.response.selector = ODU_SELECTOR_LC;
/* Fill Pst */
- pst.selector = DU_SELECTOR_LC;
+ pst.selector = ODU_SELECTOR_LC;
pst.srcEnt = ENTDUAPP;
pst.dstEnt = ENTKW;
pst.dstInst = inst;
kwMngmt.hdr.response.mem.pool = RLC_POOL;
/* Fill Pst */
- pst.selector = DU_SELECTOR_LC;
+ pst.selector = ODU_SELECTOR_LC;
pst.srcEnt = ENTDUAPP;
pst.dstEnt = ENTKW;
pst.dstProcId = DU_PROC;
lSap->ent = ENTRG;
lSap->inst = lsapInst;
lSap->sapId = lsapInst; /* SapId will be stored as suId in MAC */
- lSap->selector = (inst == RLC_UL_INST) ? DU_SELECTOR_LWLC : DU_SELECTOR_TC;
+ lSap->selector = (inst == RLC_UL_INST) ? ODU_SELECTOR_LWLC : ODU_SELECTOR_TC;
kwMngmt.hdr.elmId.elmnt = STRGUSAP;
DU_LOG("\nDU_APP : RLC MAC Lower Sap Cfg Req sent for inst %d", inst);
lSap->inst = (inst == RLC_UL_INST) ?
RLC_DL_INST : RLC_UL_INST;
lSap->sapId = 0;
- lSap->selector = DU_SELECTOR_LC;
+ lSap->selector = ODU_SELECTOR_LC;
kwMngmt.hdr.elmId.elmnt = STUDXSAP;
DU_LOG("\nDU_APP : RLC DL/UL Lower Sap Cfg Req sent for inst %d", inst);
}
uSap = &(kwMngmt.t.cfg.s.sap);
- uSap->selector = DU_SELECTOR_LC;
+ uSap->selector = ODU_SELECTOR_LC;
uSap->mem.region = (inst == RLC_UL_INST) ?
RLC_UL_MEM_REGION:RLC_DL_MEM_REGION;
uSap->mem.pool = RLC_POOL;
kwMngmt.hdr.response.mem.pool = RLC_POOL;
/* Fill Pst */
- pst.selector = DU_SELECTOR_LC;
+ pst.selector = ODU_SELECTOR_LC;
pst.srcEnt = ENTDUAPP;
pst.dstEnt = ENTKW;
pst.dstProcId = DU_PROC;
U16 idx;
for(idx=0; idx< DEFAULT_CELLS; idx++)
{
- DuCellCb *cell;
+ DuCellCb *cell = NULLP;
DU_ALLOC(cell, sizeof(DuCellCb))
if(cell == NULLP)
{
else
{
U32 nci;
- U8 idx;
-
+ U8 idx1;
memset(cell, 0, sizeof(DuCellCb));
- cell->cellId = cellId++;
+ cell->cellId = ++cellId;
cell->cellInfo.nrEcgi.plmn.mcc[0] = PLMN_MCC0;
cell->cellInfo.nrEcgi.plmn.mcc[1] = PLMN_MCC1;
cell->cellInfo.nrEcgi.plmn.mcc[2] = PLMN_MCC2;
cell->cellInfo.nrEcgi.cellId = NR_CELL_ID;
cell->cellInfo.nrPci = NR_PCI;
cell->cellInfo.fiveGsTac = DU_TAC;
- for(idx=0; idx<MAX_PLMN; idx++)
+ for(idx1=0; idx1<MAX_PLMN; idx1++)
{
- cell->cellInfo.plmn[idx].mcc[0] = PLMN_MCC0;
- cell->cellInfo.plmn[idx].mcc[1] = PLMN_MCC1;
- cell->cellInfo.plmn[idx].mcc[2] = PLMN_MCC2;
- cell->cellInfo.plmn[idx].mnc[0] = PLMN_MNC0;
- cell->cellInfo.plmn[idx].mnc[1] = PLMN_MNC1;
- cell->cellInfo.plmn[idx].mnc[2] = PLMN_MNC2;
- }
+ cell->cellInfo.plmn[idx1].mcc[0] = PLMN_MCC0;
+ cell->cellInfo.plmn[idx1].mcc[1] = PLMN_MCC1;
+ cell->cellInfo.plmn[idx1].mcc[2] = PLMN_MCC2;
+ cell->cellInfo.plmn[idx1].mnc[0] = PLMN_MNC0;
+ cell->cellInfo.plmn[idx1].mnc[1] = PLMN_MNC1;
+ cell->cellInfo.plmn[idx1].mnc[2] = PLMN_MNC2;
+ }
cell->cellInfo.maxUe = duCfgParam.maxUe;
cell->cellStatus = CELL_OUT_OF_SERVICE;
nci = (U16)cell->cellInfo.nrEcgi.cellId;
genCfg = &(rgMngmt.t.cfg.s.genCfg);
/*----------- Fill General Configuration Parameters ---------*/
- genCfg->mem.region = RG_MEM_REGION;
+ genCfg->mem.region = MAC_MEM_REGION;
genCfg->mem.pool = RG_POOL;
genCfg->tmrRes = 10;
genCfg->numRguSaps = 2;
genCfg->lmPst.srcInst = macCfgInst;
genCfg->lmPst.prior = PRIOR0;
genCfg->lmPst.route = RTESPEC;
- genCfg->lmPst.region = RG_MEM_REGION;
+ genCfg->lmPst.region = MAC_MEM_REGION;
genCfg->lmPst.pool = RG_POOL;
- genCfg->lmPst.selector = DU_SELECTOR_LC;
+ genCfg->lmPst.selector = ODU_SELECTOR_LC;
/* Fill Header */
rgMngmt.hdr.msgType = TCFG;
rgMngmt.hdr.response.prior = PRIOR0;
rgMngmt.hdr.response.route = RTESPEC;
- rgMngmt.hdr.response.mem.region = RG_MEM_REGION;
+ rgMngmt.hdr.response.mem.region = MAC_MEM_REGION;
rgMngmt.hdr.response.mem.pool = RG_POOL;
- rgMngmt.hdr.response.selector = DU_SELECTOR_LC;
+ rgMngmt.hdr.response.selector = ODU_SELECTOR_LC;
/* Fill Pst */
- pst.selector = DU_SELECTOR_LC;
+ pst.selector = ODU_SELECTOR_LC;
pst.srcEnt = ENTDUAPP;
pst.dstEnt = ENTRG;
pst.dstInst = macCfgInst;
uSap = &(rgMngmt.t.cfg.s.rguSap);
- uSap->mem.region = RG_MEM_REGION;
+ uSap->mem.region = MAC_MEM_REGION;
uSap->mem.pool = RG_POOL;
uSap->suId = 0;
uSap->spId = sapId;
uSap->inst = sapId;
uSap->prior = PRIOR0;
uSap->route = RTESPEC;
- uSap->selector = DU_SELECTOR_LC ;
+ uSap->selector = ODU_SELECTOR_LC ;
/* fill header */
rgMngmt.hdr.msgType = TCFG;
rgMngmt.hdr.entId.ent = ENTRG;
rgMngmt.hdr.entId.inst = (Inst)0;
rgMngmt.hdr.elmId.elmnt = STRGUSAP;
- rgMngmt.hdr.response.mem.region = RG_MEM_REGION;
+ rgMngmt.hdr.response.mem.region = MAC_MEM_REGION;
rgMngmt.hdr.response.mem.pool = RG_POOL;
/* fill pst */
- pst.selector = DU_SELECTOR_LC;
+ pst.selector = ODU_SELECTOR_LC;
pst.srcEnt = ENTDUAPP;
pst.dstEnt = ENTRG;
pst.dstInst = macCfgInst;
kwMngmt.hdr.response.mem.pool = RLC_POOL;
/* Fill pst */
- pst.selector = DU_SELECTOR_LC;
+ pst.selector = ODU_SELECTOR_LC;
pst.srcEnt = ENTDUAPP;
pst.dstEnt = ENTKW;
pst.dstProcId = DU_PROC;
pst->dstInst = (Inst)EGTP_INST;
pst->dstProcId = pst->srcProcId;
pst->event = event;
- pst->selector = DU_SELECTOR_LC;
+ pst->selector = ODU_SELECTOR_LC;
pst->pool= DU_POOL;
RETVALUE(ROK);
cmMemcpy((U8 *)&egtpCfg, (U8 *)&duCfgParam.egtpParams, (PTR)sizeof(EgtpConfig));
duFillEgtpPst(&pst, EVTCFGREQ);
- cmPkEgtpCfgReq(&pst, egtpCfg);
+ packEgtpCfgReq(&pst, egtpCfg);
RETVALUE(ROK);
}
DU_LOG("\nDU_APP : Sending EGTP server open request");
duFillEgtpPst(&pst, EVTSRVOPENREQ);
- cmPkEgtpSrvOpenReq(&pst);
+ packEgtpSrvOpenReq(&pst);
RETVALUE(ROK);
}
DU_LOG("\nDU_APP : Sending EGTP tunnel management request");
duFillEgtpPst(&pst, EVTTNLMGMTREQ);
- cmPkEgtpTnlMgmtReq(&pst, tnlEvt);
+ packEgtpTnlMgmtReq(&pst, tnlEvt);
RETVALUE(ROK);
}
duSendUeCreateReqToRlc();
duSendEgtpTestData();
-
- /* For testing purpose. TTI thread should actually be in L1 */
- duStartTtiThread();
#endif
}
else
/* Filling of Instance Id */
cfg->instId = DEFAULT_CELLS + 1;
/* Filling of Gen config */
- cfg->genCfg.mem.region = RG_MEM_REGION;
+ cfg->genCfg.mem.region = MAC_MEM_REGION;
cfg->genCfg.mem.pool = RG_POOL;
cfg->genCfg.tmrRes = 10;
cfg->genCfg.lmPst.srcInst = DEFAULT_CELLS + 1;
cfg->genCfg.lmPst.prior = PRIOR0;
cfg->genCfg.lmPst.route = RTESPEC;
- cfg->genCfg.lmPst.region = RG_MEM_REGION;
+ cfg->genCfg.lmPst.region = MAC_MEM_REGION;
cfg->genCfg.lmPst.pool = RG_POOL;
- cfg->genCfg.lmPst.selector = DU_SELECTOR_LC;
+ cfg->genCfg.lmPst.selector = ODU_SELECTOR_LC;
/* Fill Header */
rgMngmt.hdr.msgType = TCFG;
rgMngmt.hdr.entId.ent = ENTRG;
rgMngmt.hdr.entId.inst = DU_INST;
rgMngmt.hdr.elmId.elmnt = STSCHINST;
- rgMngmt.hdr.response.mem.region = RG_MEM_REGION;
+ rgMngmt.hdr.response.mem.region = MAC_MEM_REGION;
rgMngmt.hdr.response.mem.pool = RG_POOL;
/* Fill Pst */
- pst.selector = DU_SELECTOR_LC;
+ pst.selector = ODU_SELECTOR_LC;
pst.srcEnt = ENTDUAPP;
pst.dstEnt = ENTRG;
pst.dstProcId = DU_PROC;
/*******************************************************************
*
- * @brief Handles TTI indication
+ * @brief Sends Slot indication to EGTP
*
* @details
*
- * Function : duSendEgtpTTIInd
+ * Function : duSendEgtpSlotInd
*
* Functionality:
- * Handles TTI indication received from PHY
+ * Sends Slot indication to EGTP
*
* @params[in]
* @return ROK - success
* RFAILED - failure
*
* ****************************************************************/
-S16 duSendEgtpTTIInd()
+S16 duSendEgtpSlotInd()
{
Pst pst;
- duFillEgtpPst(&pst, EVTTTIIND);
- cmPkEgtpTTIInd(&pst);
+ duFillEgtpPst(&pst, EVTSLOTIND);
+ packEgtpSlotInd(&pst);
RETVALUE(ROK);
duMacCellCfg->transId = getTransId(); /* transaction ID */
/* Fill Pst */
- pst.selector = DU_SELECTOR_LWLC;
+ pst.selector = ODU_SELECTOR_LWLC;
pst.srcEnt = ENTDUAPP;
pst.dstEnt = ENTRG;
pst.dstInst = 0;
* RFAILED - failure
*
***************************************************************************/
-S16 duHandleMacCellCfgCfm(MacCellCfgCfm *macCellCfgCfm)
+int duHandleMacCellCfgCfm(Pst *pst, MacCellCfgCfm *macCellCfgCfm)
{
S16 ret = ROK;
- if(macCellCfgCfm->transId == duCb.duMacCellCfg->transId)
+ if(macCellCfgCfm->rsp == ROK)
+ {
+ if(macCellCfgCfm->transId == duCb.duMacCellCfg->transId)
+ {
+ /* free the memory allocated during sending macCellCfg request */
+ DU_FREE(duCb.duMacCellCfg->sib1Cfg.sib1Pdu, duCfgParam.srvdCellLst[0].duSysInfo.sib1Len);
+ DU_FREE(duCb.duMacCellCfg,sizeof(MacCellCfg));
+ duCb.duMacCellCfg = NULLP;
+
+ /* Build and send GNB-DU config update */
+ ret = BuildAndSendDUConfigUpdate();
+
+ /* TODO: Trigger cell start req once cell up slot ind is received*/
+ /* Build and Send Cell Start Req to MAC */
+ ret = duBuildAndSendMacCellStartReq();
+
+ }
+ else
+ {
+ /* transaction ID missmatch */
+ DU_LOG("\n transaction ID mismatch in macCellCfg");
+ ret = RFAILED;
+ }
+ }
+ else
+ {
+ DU_LOG("\nMac cell cfg failed");
+ ret = RFAILED;
+ }
+ return ret;
+}
+
+/*******************************************************************
+ *
+ * @brief Handles slot indication from MAC
+ *
+ * @details
+ *
+ * Function : duHandleSlotInd
+ *
+ * Functionality:
+ * Handles slot indication from MAC
+ *
+ * @params[in] Post structure pointer
+ * Slot Info pointer
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint16_t duHandleSlotInd(Pst *pst, SlotInfo *slotInfo)
+{
+
+ DU_LOG("\nDU APP : Slot Indication received");
+
+ if(slotInfo->cellId <=0 || slotInfo->cellId > DU_MAX_CELLS)
{
- /* free the memory allocated during sending macCellCfg request */
- DU_FREE(duCb.duMacCellCfg,sizeof(MacCellCfg));
- duCb.duMacCellCfg = NULLP;
+ DU_LOG("\nDU APP : Invalid Cell Id %d", slotInfo->cellId);
+ }
+ if(!duCb.actvCellLst[slotInfo->cellId-1]->firstSlotIndRcvd)
+ {
+ duCb.actvCellLst[slotInfo->cellId-1]->firstSlotIndRcvd = true;
+ if((duCb.actvCellLst[slotInfo->cellId-1] != NULL) && \
+ (duCb.actvCellLst[slotInfo->cellId-1]->cellStatus == \
+ ACTIVATION_IN_PROGRESS))
+ {
+ DU_LOG("\nDU APP : 5G-NR Cell %d is UP", slotInfo->cellId);
+ duCb.actvCellLst[slotInfo->cellId-1]->cellStatus = ACTIVATED;
+ }
+
+ }
+
+ /* TODO : Slot Indication to be moved out of EGTP_TEST when
+ * data path is established */
+#ifdef EGTP_TEST
+ duSendEgtpSlotInd();
+#endif
+
+ if((pst->selector == ODU_SELECTOR_LWLC) || (pst->selector == ODU_SELECTOR_TC))
+ DU_FREE_SHRABL_BUF(MAC_MEM_REGION, pst->pool, slotInfo, sizeof(SlotInfo));
+
+ return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Builds and sends cell start request to MAC
+ *
+ * @details
+ *
+ * Function : duBuildAndSendMacCellStartReq
+ *
+ * Functionality:
+ * Builds and sends cell start request to MAC
+ *
+ * @params[in]
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint16_t duBuildAndSendMacCellStartReq()
+{
+ Pst pst;
+ MacCellStartInfo *cellStartInfo = NULL;
+
+ DU_LOG("\nDU APP : Building and Sending cell start request to MAC");
- /* Build and send GNB-DU config update */
- ret = BuildAndSendDUConfigUpdate();
+ /* Send Cell Start Request to MAC */
+ DU_ALLOC_SHRABL_BUF(cellStartInfo, sizeof(MacCellStartInfo));
+ if(!cellStartInfo)
+ {
+ DU_LOG("\nDU APP : Memory alloc failed while building cell start request");
+ return RFAILED;
}
- else
+
+ for(uint8_t id = 0; id < DU_MAX_CELLS; id++)
{
- /* transaction ID missmatch */
- DU_LOG("\n transaction ID mismatch in macCellCfg");
- ret = RFAILED;
+ if(duCb.actvCellLst[id])
+ {
+ duCb.actvCellLst[id]->firstSlotIndRcvd = FALSE;
+ cellStartInfo->cellId = duCb.actvCellLst[id]->cellInfo.nrEcgi.cellId;
+
+ /* Fill Pst */
+ pst.selector = ODU_SELECTOR_LWLC;
+ pst.srcEnt = ENTDUAPP;
+ pst.dstEnt = ENTRG;
+ pst.dstInst = 0;
+ pst.srcInst = 0;
+ pst.dstProcId = DU_PROC;
+ pst.srcProcId = DU_PROC;
+ pst.region = DU_APP_MEM_REGION;
+ pst.pool = DU_POOL;
+ pst.event = EVENT_MAC_CELL_START_REQ;
+
+ return (*packMacCellStartReqOpts[pst.selector])(&pst, cellStartInfo);
+ }
}
+ return ROK;
+}
- return ret;
+/*******************************************************************
+ *
+ * @brief Builds and sends cell stop request to MAC
+ *
+ * @details
+ *
+ * Function : duBuildAndSendMacCellStopReq
+ *
+ * Functionality:
+ * Builds and sends cell stop request to MAC
+ *
+ * @params[in]
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint16_t duBuildAndSendMacCellStopReq()
+{
+ Pst pst;
+ MacCellStopInfo *cellStopInfo = NULL;
+
+ DU_LOG("\nDU APP : Building and Sending cell stop request to MAC");
+
+ /* Send Cell Stop Request to MAC */
+ DU_ALLOC_SHRABL_BUF(cellStopInfo, sizeof(MacCellStopInfo));
+ if(!cellStopInfo)
+ {
+ DU_LOG("\nDU APP : Memory alloc failed while building cell stop request");
+ return RFAILED;
+ }
+ cellStopInfo->cellId = duCb.actvCellLst[0]->cellId;
+
+ /* Fill Pst */
+ pst.selector = ODU_SELECTOR_LWLC;
+ pst.srcEnt = ENTDUAPP;
+ pst.dstEnt = ENTRG;
+ pst.dstInst = 0;
+ pst.srcInst = 0;
+ pst.dstProcId = DU_PROC;
+ pst.srcProcId = DU_PROC;
+ pst.region = DU_APP_MEM_REGION;
+ pst.pool = DU_POOL;
+ pst.event = EVENT_MAC_CELL_STOP_REQ;
+
+ return (*packMacCellStopReqOpts[pst.selector])(&pst, cellStopInfo);
+}
+
+/*******************************************************************
+ *
+ * @brief Handles stop indication from MAC
+ *
+ * @details
+ *
+ * Function : duHandleStopInd
+ *
+ * Functionality:
+ * Handles stop indication from MAC
+ *
+ * @params[in] Post structure pointer
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint16_t duHandleStopInd(Pst *pst, MacCellStopInfo *cellStopId)
+{
+ if(cellStopId->cellId <=0 || cellStopId->cellId > DU_MAX_CELLS)
+ {
+ DU_LOG("\nDU APP : Invalid Cell Id %d", cellStopId->cellId);
+ }
+ if(duCb.actvCellLst[cellStopId->cellId-1] != NULL)
+ {
+ if(duCb.actvCellLst[cellStopId->cellId-1]->firstSlotIndRcvd)
+ {
+ duCb.actvCellLst[cellStopId->cellId-1]->firstSlotIndRcvd = false;
+ if((duCb.actvCellLst[cellStopId->cellId-1]->cellStatus == \
+ ACTIVATED))
+ {
+ DU_LOG("\nDU APP : 5G-NR Cell %d is DOWN", cellStopId->cellId);
+ duCb.actvCellLst[cellStopId->cellId-1]->cellStatus = DELETION_IN_PROGRESS;
+ }
+ }
+ }
+ if((pst->selector == ODU_SELECTOR_LWLC) || (pst->selector == ODU_SELECTOR_TC))
+ DU_FREE_SHRABL_BUF(MAC_MEM_REGION, pst->pool, cellStopId, sizeof(MacCellStopInfo));
+
+ return ROK;
}
+/*******************************************************************
+ *
+ * @brief Handles slot indication from MAC
+ *
+ * @details
+ *
+ * Function : duHandleUlCcchInd
+ *
+ * Functionality:
+ * Handles UL CCCH indication from MAC
+ *
+ * @params[in] Post structure pointer
+ * UL CCCH Ind pointer
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint16_t duHandleUlCcchInd(Pst *pst, UlCcchIndInfo *ulCcchIndInfo)
+{
+
+ DU_LOG("\nDU APP : UL CCCH Indication received");
+
+ return (duProcUlCcchInd(ulCcchIndInfo));
+}
+
+
/**********************************************************************
End of file
**********************************************************************/
Code Review / o-du / l2.git / blobdiff