+ ueCb->srRcvd = true;
+ /* Adding UE Id to list of pending UEs to be scheduled */
+ cellCb->api->SchSrUciInd(cellCb, ueCb->ueId);
+ }
+ return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Processes DL HARQ indication from MAC
+ *
+ * @details
+ *
+ * Function : SchProcDlHarqInd
+ *
+ * Functionality:
+ * Processes DL HARQ indication from MAC
+ *
+ * @params[in] Post structure
+ * DL HARQ Indication
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchProcDlHarqInd(Pst *pst, DlHarqInd *dlHarqInd)
+{
+ Inst inst = pst->dstInst-SCH_INST_START;
+ SchUeCb *ueCb;
+ SchCellCb *cellCb = schCb[inst].cells[inst];
+
+ DU_LOG("\nDEBUG --> SCH : Received HARQ");
+
+ ueCb = schGetUeCb(cellCb, dlHarqInd->crnti);
+
+ if(ueCb->state == SCH_UE_STATE_INACTIVE)
+ {
+ DU_LOG("\nERROR --> SCH : Crnti %d is inactive", dlHarqInd->crnti);
+ return ROK;
+ }
+
+ schUpdateHarqFdbk(ueCb, dlHarqInd->numHarq, dlHarqInd->harqPayload, &dlHarqInd->slotInd);
+
+ return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Allocates requested PRBs for DL
+ *
+ * @details
+ *
+ * Function : allocatePrbDl
+ *
+ * Functionality:
+ * Allocates requested PRBs in DL
+ * Keeps track of allocated PRB (using bitmap) and remaining PRBs
+ *
+ * @params[in] prbAlloc table
+ * Start symbol
+ * Number of symbols
+ * Start PRB
+ * Number of PRBs
+ *
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t allocatePrbDl(SchCellCb *cell, SlotTimingInfo slotTime, \
+ uint8_t startSymbol, uint8_t symbolLength, uint16_t *startPrb, uint16_t numPrb)
+{
+ uint8_t symbol = 0;
+ uint16_t broadcastPrbStart=0, broadcastPrbEnd=0;
+ FreePrbBlock *freePrbBlock = NULLP;
+ CmLList *freePrbNode = NULLP;
+ PduTxOccsaion ssbOccasion=0, sib1Occasion=0;
+ SchDlSlotInfo *schDlSlotInfo = cell->schDlSlotInfo[slotTime.slot];
+ SchPrbAlloc *prbAlloc = &schDlSlotInfo->prbAlloc;
+
+ /* If startPrb is set to MAX_NUM_RB, it means startPrb is not known currently.
+ * Search for an appropriate location in PRB grid and allocate requested resources */
+ if(*startPrb == MAX_NUM_RB)
+ {
+ /* Check if SSB/SIB1 is also scheduled in this slot */
+ ssbOccasion = schCheckSsbOcc(cell, slotTime);
+ sib1Occasion = schCheckSib1Occ(cell, slotTime);
+
+ if(ssbOccasion && sib1Occasion)
+ {
+ broadcastPrbStart = cell->cellCfg.dlCfgCommon.schFreqInfoDlSib.offsetToPointA;
+ broadcastPrbEnd = broadcastPrbStart + SCH_SSB_NUM_PRB + cell->sib1SchCfg.sib1PdcchCfg.dci[0].pdschCfg.pdschFreqAlloc.numPrb -1;
+ }
+ else if(ssbOccasion)
+ {
+ broadcastPrbStart = cell->cellCfg.dlCfgCommon.schFreqInfoDlSib.offsetToPointA;
+ broadcastPrbEnd = broadcastPrbStart + SCH_SSB_NUM_PRB -1;
+ }
+ else if(sib1Occasion)
+ {
+ broadcastPrbStart = cell->sib1SchCfg.sib1PdcchCfg.dci[0].pdschCfg.pdschFreqAlloc.startPrb;
+ broadcastPrbEnd = broadcastPrbStart + cell->sib1SchCfg.sib1PdcchCfg.dci[0].pdschCfg.pdschFreqAlloc.numPrb -1;
+ }
+
+ /* Iterate through all free PRB blocks */
+ freePrbNode = prbAlloc->freePrbBlockList.first;
+ while(freePrbNode)
+ {
+ freePrbBlock = (FreePrbBlock *)freePrbNode->node;
+
+ /* If broadcast message is scheduled in this slot, then check if its PRBs belong to the current free block.
+ * Since SSB/SIB1 PRB location is fixed, these PRBs cannot be allocated to other message in same slot */
+ if((ssbOccasion || sib1Occasion) &&
+ ((broadcastPrbStart >= freePrbBlock->startPrb) && (broadcastPrbStart <= freePrbBlock->endPrb)) && \
+ ((broadcastPrbEnd >= freePrbBlock->startPrb) && (broadcastPrbEnd <= freePrbBlock->endPrb)))
+ {
+ /* Implmentation is done such that highest-numbered free-RB is allocated first */
+ if((freePrbBlock->endPrb > broadcastPrbEnd) && ((freePrbBlock->endPrb - broadcastPrbEnd) >= numPrb))
+ {
+ /* If sufficient free PRBs are available above bradcast message then,
+ * endPrb = freePrbBlock->endPrb
+ * startPrb = endPrb - numPrb +1;
+ */
+ *startPrb = freePrbBlock->endPrb - numPrb +1;
+ break;
+ }
+ else if((broadcastPrbStart > freePrbBlock->startPrb) && ((broadcastPrbStart - freePrbBlock->startPrb) >= numPrb))
+ {
+ /* If free PRBs are available below broadcast message then,
+ * endPrb = broadcastPrbStart - 1
+ * startPrb = endPrb - numPrb +1
+ */
+ *startPrb = broadcastPrbStart - numPrb;
+ break;
+ }
+ else
+ {
+ freePrbNode = freePrbNode->next;
+ continue;
+ }
+ }
+ else
+ {
+ /* Check if requested number of blocks can be allocated from the current block */
+ if (freePrbBlock->numFreePrb < numPrb)
+ {
+ freePrbNode = freePrbNode->next;
+ continue;
+ }
+ *startPrb = freePrbBlock->endPrb - numPrb +1;
+ break;
+ }
+ }
+
+ /* If no free block can be used to allocated request number of RBs */
+ if(*startPrb == MAX_NUM_RB)
+ return RFAILED;
+ }
+
+ /* If startPrb is known already, check if requested PRBs are available for allocation */
+ else
+ {
+ freePrbNode = isPrbAvailable(&prbAlloc->freePrbBlockList, *startPrb, numPrb);
+ if(!freePrbNode)
+ {
+ DU_LOG("\nERROR --> SCH: Requested DL PRB unavailable");
+ return RFAILED;
+ }
+ }
+
+ /* Update bitmap to allocate PRBs */
+ for(symbol=startSymbol; symbol < (startSymbol+symbolLength); symbol++)
+ {
+ if(fillPrbBitmap(prbAlloc->prbBitMap[symbol], *startPrb, numPrb) != ROK)
+ {
+ DU_LOG("\nERROR --> SCH: fillPrbBitmap() failed for symbol [%d] in DL", symbol);
+ return RFAILED;
+ }
+ }
+
+ /* Update statistics of PRB usage if stats calculation is enabled */
+ if(schCb[cell->instIdx].statistics.activeKpiList.dlTotPrbUseList.count)
+ prbAlloc->numPrbAlloc += numPrb;
+
+ /* Update the remaining number for free PRBs */
+ removeAllocatedPrbFromFreePrbList(&prbAlloc->freePrbBlockList, freePrbNode, *startPrb, numPrb);
+
+ return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Allocates requested PRBs for UL
+ *
+ * @details
+ *
+ * Function : allocatePrbUl
+ *
+ * Functionality:
+ * Allocates requested PRBs in UL
+ * Keeps track of allocated PRB (using bitmap) and remaining PRBs
+ *
+ * @params[in] prbAlloc table
+ * Start symbol
+ * Number of symbols
+ * Start PRB
+ * Number of PRBs
+ *
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t allocatePrbUl(SchCellCb *cell, SlotTimingInfo slotTime, \
+ uint8_t startSymbol, uint8_t symbolLength, uint16_t *startPrb, uint16_t numPrb)
+{
+ uint8_t symbol = 0;
+ uint16_t prachStartPrb, prachNumPrb, prachEndPrb;
+ bool isPrachOccasion;
+ FreePrbBlock *freePrbBlock = NULLP;
+ CmLList *freePrbNode = NULLP;
+ SchPrbAlloc *prbAlloc = NULLP;
+
+ if(cell == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : allocatePrbUl(): Received cellCb is null");
+ return RFAILED;
+ }
+
+ prbAlloc = &cell->schUlSlotInfo[slotTime.slot]->prbAlloc;
+ /* If startPrb is set to MAX_NUM_RB, it means startPrb is not known currently.
+ * Search for an appropriate location in PRB grid and allocate requested resources */
+ if(*startPrb == MAX_NUM_RB)
+ {
+ /* Check if PRACH is also scheduled in this slot */
+ isPrachOccasion = schCheckPrachOcc(cell, slotTime);
+ if(isPrachOccasion)
+ {
+ prachStartPrb = cell->cellCfg.ulCfgCommon.schInitialUlBwp.schRachCfg.prachCfgGeneric.msg1FreqStart;
+ prachNumPrb = schCalcPrachNumRb(cell);
+ prachEndPrb = prachStartPrb + prachNumPrb -1;
+ }
+
+ /* Iterate through all free PRB blocks */
+ freePrbNode = prbAlloc->freePrbBlockList.first;
+ while(freePrbNode)
+ {
+ freePrbBlock = (FreePrbBlock *)freePrbNode->node;
+
+ /* If PRACH is scheduled in this slot, then check if its PRBs belong to the current free block.
+ * PRBs required for PRACH cannot be allocated to any other message */
+ if((isPrachOccasion) &&
+ ((prachStartPrb >= freePrbBlock->startPrb) && (prachStartPrb <= freePrbBlock->endPrb)) &&
+ ((prachEndPrb >= freePrbBlock->startPrb) && (prachEndPrb <= freePrbBlock->endPrb)))
+ {
+ /* Implmentation is done such that highest-numbered free-RB is allocated first */
+ if((freePrbBlock->endPrb > prachEndPrb) && ((freePrbBlock->endPrb - prachEndPrb) >= numPrb))
+ {
+ /* If sufficient free PRBs are available above PRACH message then,
+ * endPrb = freePrbBlock->endPrb
+ * startPrb = endPrb - numPrb +1;
+ */
+ *startPrb = freePrbBlock->endPrb - numPrb +1;
+ break;
+ }
+ else if((prachStartPrb > freePrbBlock->startPrb) && ((prachStartPrb - freePrbBlock->startPrb) >= numPrb))
+ {
+ /* If free PRBs are available below PRACH message then,
+ * endPrb = prachStartPrb - 1
+ * startPrb = endPrb - numPrb +1
+ */
+ *startPrb = prachStartPrb - numPrb;
+ break;
+ }
+ else
+ {
+ freePrbNode = freePrbNode->next;
+ continue;
+ }
+ }
+ else
+ {
+ /* Check if requested number of PRBs can be allocated from currect block */
+ if(freePrbBlock->numFreePrb < numPrb)
+ {
+ freePrbNode = freePrbNode->next;
+ continue;
+ }
+ *startPrb = freePrbBlock->endPrb - numPrb +1;
+ break;
+ }
+ }
+
+ /* If no free block can be used to allocated requested number of RBs */
+ if(*startPrb == MAX_NUM_RB)
+ return RFAILED;
+ }
+ else
+ {
+ /* If startPrb is known already, check if requested PRBs are available for allocation */
+ freePrbNode = isPrbAvailable(&prbAlloc->freePrbBlockList, *startPrb, numPrb);
+ if(!freePrbNode)
+ {
+ DU_LOG("\nERROR --> SCH: Requested UL PRB unavailable");
+ return RFAILED;
+ }
+ }
+
+ /* Update bitmap to allocate PRBs */
+ for(symbol=startSymbol; symbol < (startSymbol+symbolLength); symbol++)
+ {
+ if(fillPrbBitmap(prbAlloc->prbBitMap[symbol], *startPrb, numPrb) != ROK)
+ {
+ DU_LOG("\nERROR --> SCH: fillPrbBitmap() failed for symbol [%d] in UL", symbol);
+ return RFAILED;
+ }
+ }
+
+ /* Update statistics of PRB usage if stats calculation is enabled */
+ if(schCb[cell->instIdx].statistics.activeKpiList.ulTotPrbUseList.count)
+ prbAlloc->numPrbAlloc += numPrb;
+
+ /* Update the remaining number for free PRBs */
+ removeAllocatedPrbFromFreePrbList(&prbAlloc->freePrbBlockList, freePrbNode, *startPrb, numPrb);
+
+ return ROK;
+}
+
+/*******************************************************************************
+ *
+ * @brief Try to find Best Free Block with Max Num PRB
+ *
+ * @details
+ *
+ * Function : searchLargestFreeBlock
+ *
+ * Functionality:
+ * Finds the FreeBlock with MaxNum of FREE PRB considering SSB/SIB1 ocassions.
+ *
+ * @params[in] I/P > prbAlloc table (FreeBlock list)
+ * I/P > Slot timing Info
+ * O/P > Start PRB
+ * I/P > Direction (UL/DL)
+ *
+ *
+ * @return Max Number of Free PRB
+ * If 0, then no Suitable Free Block
+ *
+ * ********************************************************************************/
+
+uint16_t searchLargestFreeBlock(SchCellCb *cell, SlotTimingInfo slotTime,uint16_t *startPrb, Direction dir)
+{
+ uint16_t reservedPrbStart=0, reservedPrbEnd=0, maxFreePRB = 0;
+ FreePrbBlock *freePrbBlock = NULLP;
+ CmLList *freePrbNode = NULLP;
+ SchPrbAlloc *prbAlloc = NULLP;
+ bool checkOccasion = FALSE;
+
+ *startPrb = 0; /*Initialize the StartPRB to zero*/
+
+ /*Based on Direction, Reserved Messsages will differi.e.
+ * DL >> SSB and SIB1 ocassions wheres for UL, PRACH ocassions to be checked
+ * and reserved before allocation for dedicated DL/UL msg*/
+ if(dir == DIR_DL)
+ {
+ SchDlSlotInfo *schDlSlotInfo = cell->schDlSlotInfo[slotTime.slot];
+ PduTxOccsaion ssbOccasion=0, sib1Occasion=0;
+
+ prbAlloc = &schDlSlotInfo->prbAlloc;
+
+ ssbOccasion = schCheckSsbOcc(cell, slotTime);
+ sib1Occasion = schCheckSib1Occ(cell, slotTime);
+
+ checkOccasion = TRUE;
+ if(ssbOccasion && sib1Occasion)
+ {
+ reservedPrbStart = cell->cellCfg.dlCfgCommon.schFreqInfoDlSib.offsetToPointA;
+ reservedPrbEnd = reservedPrbStart + SCH_SSB_NUM_PRB + \
+ cell->sib1SchCfg.sib1PdcchCfg.dci[0].pdschCfg.pdschFreqAlloc.numPrb -1;
+ }
+ else if(ssbOccasion)
+ {
+ reservedPrbStart = cell->cellCfg.dlCfgCommon.schFreqInfoDlSib.offsetToPointA;
+ reservedPrbEnd = reservedPrbStart + SCH_SSB_NUM_PRB -1;
+ }
+ else if(sib1Occasion)
+ {
+ reservedPrbStart = cell->sib1SchCfg.sib1PdcchCfg.dci[0].pdschCfg.pdschFreqAlloc.startPrb;
+ reservedPrbEnd = reservedPrbStart + cell->sib1SchCfg.sib1PdcchCfg.dci[0].pdschCfg.pdschFreqAlloc.numPrb -1;
+ }
+ else
+ {
+ checkOccasion = FALSE;
+ }
+ }
+ else if(dir == DIR_UL)
+ {
+ prbAlloc = &cell->schUlSlotInfo[slotTime.slot]->prbAlloc;
+
+ /* Check if PRACH is also scheduled in this slot */
+ checkOccasion = schCheckPrachOcc(cell, slotTime);
+ if(checkOccasion)
+ {
+ reservedPrbStart = cell->cellCfg.ulCfgCommon.schInitialUlBwp.schRachCfg.prachCfgGeneric.msg1FreqStart;
+ reservedPrbEnd = reservedPrbStart + (schCalcPrachNumRb(cell)) -1;
+ }
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH: Invalid Direction!");
+ return (maxFreePRB);
+ }
+
+ freePrbNode = prbAlloc->freePrbBlockList.first;
+ while(freePrbNode)
+ {
+ freePrbBlock = (FreePrbBlock *)freePrbNode->node;
+
+ /*For block with same numFreeBlocks, choose the one with HighestPRB range
+ *Since FreeBLockList are arranged in Descending order of PRB range thus Skipping this block*/
+ if(maxFreePRB >= freePrbBlock->numFreePrb)
+ {
+ //skip this block
+ freePrbNode = freePrbNode->next;
+ continue;
+ }
+
+ /* If Broadcast/Prach message is scheduled in this slot, then check if its PRBs belong to the current free block.
+ * Since SSB/SIB1 PRB location is fixed, these PRBs cannot be allocated to other message in same slot */
+ if(checkOccasion &&
+ ((reservedPrbStart >= freePrbBlock->startPrb) && (reservedPrbStart <= freePrbBlock->endPrb)) && \
+ ((reservedPrbEnd >= freePrbBlock->startPrb) && (reservedPrbEnd <= freePrbBlock->endPrb)))
+ {
+
+ /* Implmentation is done such that highest-numbered free-RB is Checked first
+ and freePRB in this block is greater than Max till now */
+ if((freePrbBlock->endPrb > reservedPrbEnd) && ((freePrbBlock->endPrb - reservedPrbEnd) > maxFreePRB))
+ {
+ /* If sufficient free PRBs are available above reserved message*/
+ *startPrb = reservedPrbEnd + 1;
+ maxFreePRB = (freePrbBlock->endPrb - reservedPrbEnd);
+ }
+ /*Also check the other freeBlock (i.e. Above the reserved message) for MAX FREE PRB*/
+ if((reservedPrbStart > freePrbBlock->startPrb) && ((reservedPrbStart - freePrbBlock->startPrb) > maxFreePRB))
+ {
+ /* If free PRBs are available below reserved message*/
+ *startPrb = freePrbBlock->startPrb;
+ maxFreePRB = (reservedPrbStart - freePrbBlock->startPrb);
+ }
+ }
+ else //Best Block
+ {
+ if(maxFreePRB < freePrbBlock->numFreePrb)
+ {
+ *startPrb = freePrbBlock->startPrb;
+ maxFreePRB = freePrbBlock->numFreePrb;
+ }
+
+ }
+ freePrbNode = freePrbNode->next;
+ }
+ return(maxFreePRB);
+}
+
+/*******************************************************************************
+ *
+ * @brief This function is used to send Slice Cfg rsp to MAC
+ *
+ * @details
+ *
+ * Function : SchSendSliceCfgRspToMac
+ *
+ * Functionality:
+ * function is used to send Slice Cfg rsp to MAC
+ *
+ * @params[in] Pst *pst, SchSliceCfgRsp sliceCfgRsp
+ *
+ * @return- void
+ *
+ * ********************************************************************************/
+void SchSendSliceCfgRspToMac(Inst inst, SchSliceCfgRsp sliceCfgRsp)
+{
+ Pst rspPst;
+
+ memset(&rspPst, 0, sizeof(Pst));
+ FILL_PST_SCH_TO_MAC(rspPst, inst);
+ rspPst.event = EVENT_SLICE_CFG_RSP_TO_MAC;
+
+ MacMessageRouter(&rspPst, (void *)&sliceCfgRsp);
+
+}
+
+/*******************************************************************************
+ *
+ * @brief This function is used to store or modify the slice configuration Sch DB
+ *
+ * @details
+ *
+ * Function : addOrModifySliceCfgInSchDb
+ *
+ * Functionality:
+ * function is used to store or modify the slice configuration Sch DB
+ *
+ * @params[in] SchSliceCfg *storeSliceCfg, SchSliceCfgReq *cfgReq,
+ * SchSliceCfgRsp cfgRsp, uint8_t count
+ *
+ * @return
+ * ROK - Success
+ * RFAILED - Failure
+ *
+ * ********************************************************************************/
+uint8_t addSliceCfgInSchDb(CmLListCp *sliceCfgInDb, SchRrmPolicyOfSlice *cfgReq)
+{
+ SchRrmPolicyOfSlice *sliceToStore;
+
+ SCH_ALLOC(sliceToStore, sizeof(SchRrmPolicyOfSlice));
+ if(sliceToStore)
+ {
+ memcpy(&sliceToStore->snssai, &cfgReq->snssai, sizeof(Snssai));
+ memcpy(&sliceToStore->rrmPolicyRatioInfo, &cfgReq->rrmPolicyRatioInfo, sizeof(SchRrmPolicyRatio));
+ addNodeToLList(sliceCfgInDb, sliceToStore, NULL);
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : Memory allocation failed in addOrModifySliceCfgInSchDb");
+ return RFAILED;
+ }
+ return ROK;
+}
+
+/*******************************************************************************
+ *
+ * @brief fill slice configuration response
+ *
+ * @details
+ *
+ * Function : fillSliceCfgRsp
+ *
+ * Functionality:
+ * fill slice configuration response
+ *
+ * @params[in] SchCellCb, SchSliceCfgReq, SchSliceCfgRsp,uint8_t count
+ *
+ * @return
+ * ROK - Success
+ * RFAILED - Failure
+ *
+ * ********************************************************************************/
+uint8_t fillSliceCfgRsp(Inst inst, CmLListCp *storedSliceCfg, SchCellCb *cellCb, SchSliceCfgReq *schSliceCfgReq)
+{
+ SchMacRsp sliceFound;
+ uint8_t cfgIdx = 0, sliceIdx = 0, plmnIdx = 0, ret =ROK;
+ SchSliceCfgRsp schSliceCfgRsp;
+
+ for(cfgIdx = 0; cfgIdx<schSliceCfgReq->numOfConfiguredSlice; cfgIdx++)
+ {
+ sliceFound = RSP_NOK;
+ /* Here comparing the slice cfg request with the slice stored in cellCfg */
+ for(plmnIdx = 0; plmnIdx < MAX_PLMN; plmnIdx++)
+ {
+ for(sliceIdx = 0; sliceIdx<cellCb->cellCfg.plmnInfoList[plmnIdx].suppSliceList.numSupportedSlices; sliceIdx++)
+ {
+ /* If we find the SliceCfgReq's SNSSAI in CellCb's SNSSAI DB, we mark this slice as configured and add it to Sch's DB. */
+ if(!memcmp(&schSliceCfgReq->listOfSlices[cfgIdx]->snssai, cellCb->cellCfg.plmnInfoList[plmnIdx].suppSliceList.snssai[sliceIdx], sizeof(Snssai)))
+ {
+ if(addSliceCfgInSchDb(storedSliceCfg, schSliceCfgReq->listOfSlices[cfgIdx]) == ROK)
+ {
+ sliceFound = RSP_OK;
+ schSliceCfgRsp.cause = SUCCESSFUL;
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : Failed to store slice configuration in SchDb");
+ schSliceCfgRsp.cause = RESOURCE_UNAVAILABLE;
+ ret = RFAILED;
+ }
+ plmnIdx = MAX_PLMN;
+ break;
+ }
+ }
+ }
+
+ if((sliceFound == RSP_NOK) && (schSliceCfgRsp.cause != RESOURCE_UNAVAILABLE))
+ schSliceCfgRsp.cause = SLICE_NOT_FOUND;
+
+ schSliceCfgRsp.snssai = schSliceCfgReq->listOfSlices[cfgIdx]->snssai;
+ schSliceCfgRsp.rsp = sliceFound;
+ SchSendSliceCfgRspToMac(inst, schSliceCfgRsp);
+ }
+ return ret;
+}
+
+/*******************************************************************************
+ *
+ * @brief This function is used to free the slice cfg and re cfg request pointer
+ *
+ * @details
+ *
+ * Function : freeSchSliceCfgReq
+ *
+ * Functionality:
+ * function is used to free the slice cfg and re cfg request pointer
+ *
+ * @params[in] Pst *pst, SchSliceCfgReq *schSliceCfgReq
+ *
+ * @return
+ * ROK - Success
+ * RFAILED - Failure
+ * ********************************************************************************/
+void freeSchSliceCfgReq(SchSliceCfgReq *sliceCfgReq)
+{
+ uint8_t cfgIdx = 0;
+
+ if(sliceCfgReq)
+ {
+ if(sliceCfgReq->numOfConfiguredSlice)
+ {
+ for(cfgIdx = 0; cfgIdx<sliceCfgReq->numOfConfiguredSlice; cfgIdx++)
+ {
+ if(sliceCfgReq->listOfSlices[cfgIdx])
+ {
+ SCH_FREE(sliceCfgReq->listOfSlices[cfgIdx], sizeof(SchRrmPolicyOfSlice));
+ }
+ }
+ SCH_FREE(sliceCfgReq->listOfSlices, sliceCfgReq->numOfConfiguredSlice * sizeof(SchRrmPolicyOfSlice*));
+ }
+ SCH_FREE(sliceCfgReq, sizeof(SchSliceCfgReq));
+ }
+}
+/*******************************************************************************
+ *
+ * @brief This function is used to store the slice configuration Sch DB
+ *
+ * @details
+ *
+ * Function : SchProcSliceCfgReq
+ *
+ * Functionality:
+ * function is used to store the slice configuration Sch DB
+ *
+ * @params[in] Pst *pst, SchSliceCfgReq *schSliceCfgReq
+ *
+ * @return
+ * ROK - Success
+ * RFAILED - Failure
+ *
+ * ********************************************************************************/
+uint8_t SchProcSliceCfgReq(Pst *pst, SchSliceCfgReq *schSliceCfgReq)
+{
+ uint8_t ret = ROK;
+ Inst inst = pst->dstInst - SCH_INST_START;
+
+ DU_LOG("\nINFO --> SCH : Received Slice Cfg request from MAC");
+ if(schSliceCfgReq)
+ {
+ if(schSliceCfgReq->listOfSlices)
+ {
+ /* filling the slice configuration response of each slice */
+ if(fillSliceCfgRsp(inst, &schCb[inst].sliceCfg, schCb[inst].cells[0], schSliceCfgReq) != ROK)
+ {
+ DU_LOG("\nERROR --> SCH : Failed to fill the slice cfg rsp");
+ ret = RFAILED;
+ }
+ freeSchSliceCfgReq(schSliceCfgReq);
+ }
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : Received SchSliceCfgReq is NULL");
+ ret = RFAILED;
+ }
+ return ret;
+}
+
+/*******************************************************************************
+ *
+ * @brief This function is used to send Slice re Cfg rsp to MAC
+ *
+ * @details
+ *
+ * Function : SchSendSliceRecfgRspToMac
+ *
+ * Functionality:
+ * function is used to send Slice re Cfg rsp to MAC
+ *
+ * @params[in] Pst *pst, SchSliceRecfgRsp schSliceRecfgRsp
+ *
+ * @return- void
+ *
+ * ********************************************************************************/
+void SchSendSliceRecfgRspToMac(Inst inst, SchSliceRecfgRsp schSliceRecfgRsp)
+{
+ Pst rspPst;
+
+ memset(&rspPst, 0, sizeof(Pst));
+ FILL_PST_SCH_TO_MAC(rspPst, inst);
+ rspPst.event = EVENT_SLICE_RECFG_RSP_TO_MAC;
+
+ MacMessageRouter(&rspPst, (void *)&schSliceRecfgRsp);
+}
+
+/*******************************************************************************
+ *
+ * @brief fill slice configuration response
+ *
+ * @details
+ *
+ * Function : fillSliceRecfgRsp
+ *
+ * Functionality: fill slice reconfiguration response
+ *
+ * @params[in] SchCellCb, SchSliceCfgReq, SchSliceCfgRsp,uint8_t count
+ *
+ * @return
+ * ROK - Success
+ * RFAILED - Failure
+ *
+ * ********************************************************************************/
+
+uint8_t fillSliceRecfgRsp(Inst inst, CmLListCp *storedSliceCfg, SchSliceRecfgReq *schSliceRecfgReq)
+{
+ SchMacRsp sliceFound;
+ uint8_t cfgIdx = 0;
+ SchRrmPolicyOfSlice *rrmPolicyOfSlices;
+ SchSliceRecfgRsp schSliceRecfgRsp;
+
+ for(cfgIdx = 0; cfgIdx<schSliceRecfgReq->numOfConfiguredSlice; cfgIdx++)
+ {
+ sliceFound = RSP_NOK;
+ /* Here comparing the slice recfg request with the StoredSliceCfg */
+ CmLList *sliceCfg = storedSliceCfg->first;
+
+ while(sliceCfg)
+ {
+ rrmPolicyOfSlices = (SchRrmPolicyOfSlice*)sliceCfg->node;
+
+ if(rrmPolicyOfSlices && (memcmp(&schSliceRecfgReq->listOfSlices[cfgIdx]->snssai, &(rrmPolicyOfSlices->snssai), sizeof(Snssai)) == 0))
+ {
+ memcpy(&rrmPolicyOfSlices->rrmPolicyRatioInfo, &schSliceRecfgReq->listOfSlices[cfgIdx]->rrmPolicyRatioInfo, sizeof(SchRrmPolicyRatio));
+ sliceFound = RSP_OK;
+ break;
+ }
+ sliceCfg = sliceCfg->next;
+ }
+
+ schSliceRecfgRsp.snssai = schSliceRecfgReq->listOfSlices[cfgIdx]->snssai;
+ schSliceRecfgRsp.rsp = sliceFound;
+ if(schSliceRecfgRsp.rsp == RSP_OK)
+ schSliceRecfgRsp.cause = SUCCESSFUL;
+ else
+ schSliceRecfgRsp.cause = SLICE_NOT_FOUND;
+ SchSendSliceRecfgRspToMac(inst, schSliceRecfgRsp);
+ }
+ return ROK;
+}
+/*******************************************************************************
+ *
+ * @brief This function is used to store the slice reconfiguration Sch DB
+ *
+ * @details
+ *
+ * Function : SchProcSliceRecfgReq
+ *
+ * Functionality:
+ * function is used to store the slice re configuration Sch DB
+ *
+ * @params[in] Pst *pst, SchSliceRecfgReq *schSliceRecfgReq
+ *
+ * @return
+ * ROK - Success
+ * RFAILED - Failure
+ *
+ * ********************************************************************************/
+uint8_t SchProcSliceRecfgReq(Pst *pst, SchSliceRecfgReq *schSliceRecfgReq)
+{
+ uint8_t ret = ROK;
+ Inst inst = pst->dstInst - SCH_INST_START;
+
+ DU_LOG("\nINFO --> SCH : Received Slice ReCfg request from MAC");
+ if(schSliceRecfgReq)
+ {
+ if(schSliceRecfgReq->listOfSlices)
+ {
+ /* filling the slice configuration response of each slice */
+ if(fillSliceRecfgRsp(inst, &schCb[inst].sliceCfg, schSliceRecfgReq) != ROK)
+ {
+ DU_LOG("\nERROR --> SCH : Failed to fill sch slice cfg response");
+ ret = RFAILED;
+ }
+ freeSchSliceCfgReq(schSliceRecfgReq);
+ }
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : Received SchSliceRecfgReq is NULL");
+
+ }
+ return ret;
+}
+
+/****************************************************************************
+ *
+ * @brief Stores the Paging Configuration from DU APP in CellCb
+ *
+ * @details
+ *
+ * Function : schProcPagingParam
+ *
+ * Functionality:
+ * Process the Paging Configuration when FirstPDCCHMonitoring for
+ * Paging Ocassion is not present.
+ *
+ * As per 38.304 Sec 7.1,
+ * "When firstPDCCH-MonitoringOccasionOfPO is present, the
+ * starting PDCCH monitoring occasion number of (i_s + 1)th PO is the
+ * (i_s + 1)th value of the firstPDCCHMonitoringOccasionOfPO
+ * parameter; otherwise, it is equal to i_s * S."
+ * "S = number of actual transmitted SSBs determined according
+ * to ssb-PositionsInBurst in SIB1"
+ *
+ * @params[in] SchCellCb *cell
+ *
+ * @return void
+ *
+ *************************************************************************/
+void schProcPagingCfg(SchCellCb *cell)
+{
+ SchPcchCfg *pageCfgRcvd = NULL;
+ uint8_t i_sIdx = 0;
+
+ pageCfgRcvd = &(cell->cellCfg.dlCfgCommon.schPcchCfg);
+
+ if(pageCfgRcvd->poPresent == TRUE)
+ {
+ /*Fetching first Pdcch Monitoring Occasion for SFN (i_s + 1)th*/
+ for(i_sIdx = 0; i_sIdx < pageCfgRcvd->numPO; i_sIdx++)
+ {
+ cell->pageCb.pagMonOcc[i_sIdx].pagingOccSlot = pageCfgRcvd->pagingOcc[i_sIdx] / MAX_SYMB_PER_SLOT ;
+ if ((pageCfgRcvd->pagingOcc[i_sIdx] % MAX_SYMB_PER_SLOT) != 0 )
+ {
+ cell->pageCb.pagMonOcc[i_sIdx].pagingOccSlot++;
+ }
+
+ cell->pageCb.pagMonOcc[i_sIdx].frameOffset = 0;
+
+ }
+ }
+ else
+ {
+ schCfgPdcchMonOccOfPO(cell);
+ }
+}
+
+/****************************************************************************
+ *
+ * @brief Calculate PO if not present in Configuration
+ *
+ * @details
+ *
+ * Function : schCfgPdcchMonOccOfPO
+ *
+ * Functionality: In this function, PO are calculated i_s * S because
+ * FirstPDCCHMonitoring_ForPO is not present.
+ *
+ * @params[in] SchCellCb *cellCb
+ *
+ * @return void
+ *
+ *************************************************************************/
+void schCfgPdcchMonOccOfPO(SchCellCb *cell)
+{
+ uint8_t cnt = 0, incr = 1, i_sIdx = 0, frameOffSet = 0;
+ uint8_t nsValue = cell->cellCfg.dlCfgCommon.schPcchCfg.numPO;
+ uint8_t totalNumSsb = countSetBits(cell->cellCfg.ssbPosInBurst[0]);
+ SlotTimingInfo tmpTimingInfo, pdcchTime;
+
+ /*Starting with First Sfn and slot*/
+ tmpTimingInfo.sfn = 0;
+ tmpTimingInfo.slot = 0;
+
+ pdcchTime = tmpTimingInfo;
+
+ while(i_sIdx < nsValue)
+ {
+ /*Increment frame Offset if PO falls on next SFN*/
+ if(pdcchTime.sfn != tmpTimingInfo.sfn)
+ {
+ frameOffSet++;
+ }
+ pdcchTime = tmpTimingInfo;
+ schIncrSlot(&(tmpTimingInfo), incr, cell->numSlots);
+
+ if (i_sIdx == 0)
+ {
+ cell->pageCb.pagMonOcc[i_sIdx].pagingOccSlot = pdcchTime.slot;
+ cell->pageCb.pagMonOcc[i_sIdx].frameOffset = frameOffSet;
+ i_sIdx++;
+ }
+ else
+ {
+ cnt++;
+ if((cnt == totalNumSsb) && (i_sIdx < MAX_PO_PER_PF))
+ {
+ cell->pageCb.pagMonOcc[i_sIdx].pagingOccSlot = pdcchTime.slot;
+ cell->pageCb.pagMonOcc[i_sIdx].frameOffset = frameOffSet;
+ cnt = 0;
+ i_sIdx++;
+ }
+ }
+ }
+}
+
+/****************************************************************************
+ *
+ * @brief Storing the paging information in SCH database
+ *
+ * @details
+ *
+ * Function : schAddPagingIndtoList
+ *
+ * Functionality: Storing the paging information in SCH database
+ *
+ * @params[in] CmLListCp *storedPageList, CmLList *pageIndInfo
+ *
+ * @return ROK - sucess
+ * RFAILED - failure
+ *
+ *************************************************************************/
+uint8_t schAddPagingIndtoList(CmLListCp *storedPageList,void * pageIndInfo)
+{
+ CmLList *firstNodeOfList = NULLP;
+ CmLList *currentNodeInfo = NULLP;
+ SchPageInfo *tempNode = NULLP, *recvdNode = NULLP;
+
+ recvdNode = (SchPageInfo*) pageIndInfo;
+ CM_LLIST_FIRST_NODE(storedPageList,firstNodeOfList);
+
+ SCH_ALLOC(currentNodeInfo, sizeof(CmLList));
+ if(!currentNodeInfo)
+ {
+ DU_LOG("\nERROR --> SCH : schAddPagingIndtoList() : Memory allocation failed");
+ return RFAILED;
+ }
+
+ currentNodeInfo->node = (PTR)pageIndInfo;
+ while(firstNodeOfList)
+ {
+ tempNode = (SchPageInfo*)(firstNodeOfList->node);
+ if ((recvdNode->pageTxTime.slot < tempNode->pageTxTime.slot))
+ {
+ cmLListInsCrnt(storedPageList, currentNodeInfo);
+ break;
+ }
+ else if ((recvdNode->pageTxTime.slot == tempNode->pageTxTime.slot))
+ {
+ DU_LOG("\nERROR --> SCH : schAddPagingIndtoList() : Slot[%d] is already present in the list", recvdNode->pageTxTime.slot);
+ return RFAILED;
+ }
+ else
+ {
+ CM_LLIST_NEXT_NODE(storedPageList, firstNodeOfList);
+ }
+ }
+
+ if(!firstNodeOfList)
+ {
+ cmLListAdd2Tail(storedPageList, currentNodeInfo);
+ }
+ DU_LOG("\nDEBUG --> SCH : Paging information is stored successfully for PF:%d, Slot:%d",\
+ recvdNode->pageTxTime.sfn, recvdNode->pageTxTime.slot);
+ return ROK;
+}
+
+/****************************************************************************
+ *
+ * @brief Process paging indication at SCH recevied form MAC
+ *
+ * @details
+ *
+ * Function : SchProcPagingInd
+ *
+ * Functionality: Process paging indication at SCH recevied form MAC
+ *
+ * @params[in] Pst *pst, SchPageInd *pageInd
+ *
+ * @return void
+ *
+ *************************************************************************/
+uint8_t SchProcPagingInd(Pst *pst, SchPageInd *pageInd)
+{
+ uint8_t ret = RFAILED;
+ uint16_t cellIdx = 0;
+ Inst inst = pst->dstInst - SCH_INST_START;
+ SchCellCb *cellCb = NULLP;
+ SchPageInfo *pageInfo = NULLP;
+
+ if(pageInd)
+ {
+ DU_LOG("\nDEBUG --> SCH : Received paging indication from MAC for cellId[%d]",\
+ pageInd->cellId);
+
+ /* Fetch Cell CB */
+ for(cellIdx = 0; cellIdx < MAX_NUM_CELL; cellIdx++)
+ {
+ if((schCb[inst].cells[cellIdx]) && (schCb[inst].cells[cellIdx]->cellId == pageInd->cellId))
+ {
+ cellCb = schCb[inst].cells[cellIdx];
+ break;
+ }
+ }
+ if(cellCb)
+ {
+ if(pageInd->i_s > cellCb->cellCfg.dlCfgCommon.schPcchCfg.numPO)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcPagingInd(): i_s should not be greater than number of paging occasion");
+ }
+ else
+ {
+ SCH_ALLOC(pageInfo, sizeof(SchPageInfo));
+ if(pageInfo)
+ {
+ pageInfo->pf = pageInd->pf;
+ pageInfo->i_s = pageInd->i_s;
+ pageInfo->pageTxTime.cellId = pageInd->cellId;
+ pageInfo->pageTxTime.sfn = (pageInd->pf + cellCb->pageCb.pagMonOcc[pageInd->i_s].frameOffset) % MAX_SFN;
+ pageInfo->pageTxTime.slot = cellCb->pageCb.pagMonOcc[pageInd->i_s].pagingOccSlot;
+ pageInfo->mcs = DEFAULT_MCS;
+ pageInfo->msgLen = pageInd->pduLen;
+ SCH_ALLOC(pageInfo->pagePdu, pageInfo->msgLen);
+ if(!pageInfo->pagePdu)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcPagingInd(): Failed to allocate memory");
+ }
+ else
+ {
+ memcpy(pageInfo->pagePdu, pageInd->pagePdu, pageInfo->msgLen);
+ ret = schAddPagingIndtoList(&cellCb->pageCb.pageIndInfoRecord[pageInfo->pageTxTime.sfn], pageInfo);
+ if(ret != ROK)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcPagingInd(): Failed to store paging record");
+ }
+ }
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : SchProcPagingInd(): Failed to allocate memory");
+ }
+ }
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : Cell ID [%d] not found", pageInd->cellId);
+ }
+ SCH_FREE(pageInd->pagePdu, pageInd->pduLen);
+ SCH_FREE(pageInd, sizeof(SchPageInd));
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : SchProcPagingInd(): Received null pointer");
+ }
+ return ret;
+}
+
+\f
+/***********************************************************
+ *
+ * Func : SchFillCfmPst
+ *
+ *
+ * Desc : Fills the Confirmation Post Structure cfmPst using the reqPst
+ * and the cfm->hdr.response.
+ *
+ *
+ * Ret : Void
+ *
+ * Notes:
+ *
+ * File : rg_sch_lmm.c
+ *
+ **********************************************************/
+Void SchFillCfmPst
+(
+Pst *reqPst,
+Pst *cfmPst,
+RgMngmt *cfm
+)
+{
+ Inst inst;
+
+ inst = (reqPst->dstInst - SCH_INST_START);
+
+ cfmPst->srcEnt = ENTMAC;
+ cfmPst->srcInst = (Inst) 1;
+ cfmPst->srcProcId = schCb[inst].schInit.procId;
+ cfmPst->dstEnt = ENTMAC;
+ cfmPst->dstInst = (Inst) 0;
+ cfmPst->dstProcId = reqPst->srcProcId;
+
+ cfmPst->selector = cfm->hdr.response.selector;
+ cfmPst->region = cfm->hdr.response.mem.region;
+ cfmPst->pool = cfm->hdr.response.mem.pool;
+
+ return;
+}
+
+/*******************************************************************
+ *
+ * @brief Processes DL CQI ind from MAC
+ *
+ * @details
+ *
+ * Function : SchProcDlCqiInd
+ *
+ * Functionality:
+ * Processes DL CQI ind from MAC
+ *
+ * @params[in]
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchProcDlCqiInd(Pst *pst, SchDlCqiInd *dlCqiInd)
+{
+ uint8_t ret = ROK;
+ uint16_t ueId = 0, cellIdx = 0;
+ SchUeCb *ueCb = NULLP;
+ SchCellCb *cell = NULLP;
+ Inst inst = pst->dstInst-SCH_INST_START;
+
+ if(!dlCqiInd)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcDlCqiInd(): CQI Ind is empty");
+ ret = RFAILED;
+ }
+ else
+ {
+ GET_CELL_IDX(dlCqiInd->cellId, cellIdx);
+ cell = schCb[inst].cells[cellIdx];
+ if(cell == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcDlCqiInd(): cell Id[%d] not found", dlCqiInd->cellId);
+ ret = RFAILED;
+ }
+ else
+ {
+ if(cell->cellId == dlCqiInd->cellId)
+ {
+ GET_UE_ID(dlCqiInd->crnti, ueId);
+ ueCb = &cell->ueCb[ueId-1];
+ if(ueCb->crnti != dlCqiInd->crnti)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcDlCqiInd(): UeCb for received crnti[%d] not found", dlCqiInd->crnti);
+ ret = RFAILED;
+ }
+ else
+ {
+ /*TODO: complete the processing of DL CQI Ind*/
+ }
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : SchProcDlCqiInd(): Received cell Id[%d] from MAC is not matching with CellID[%d] in SCH Cb",\
+ dlCqiInd->cellId, cell->cellId);
+ ret = RFAILED;
+ }
+ }
+ }
+ return ret;
+}
+
+/*******************************************************************
+ *
+ * @brief Processes UL CQI ind from MAC
+ *
+ * @details
+ *
+ * Function : SchProcUlCqiInd
+ *
+ * Functionality:
+ * Processes UL CQI ind from MAC
+ *
+ * @params[in]
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchProcUlCqiInd(Pst *pst, SchUlCqiInd *ulCqiInd)
+{
+ uint8_t ret = ROK;
+ uint16_t ueId = 0, cellIdx = 0;
+ SchUeCb *ueCb = NULLP;
+ SchCellCb *cell = NULLP;
+ Inst inst = pst->dstInst-SCH_INST_START;
+
+ if(!ulCqiInd)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcUlCqiInd(): CQI Ind is empty");
+ ret = RFAILED;
+ }
+ else
+ {
+ GET_CELL_IDX(ulCqiInd->cellId, cellIdx);
+ cell = schCb[inst].cells[cellIdx];
+ if(cell == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcUlCqiInd(): cell Id[%d] not found", ulCqiInd->cellId);
+ ret = RFAILED;
+ }
+ else
+ {
+ if(cell->cellId == ulCqiInd->cellId)
+ {
+ GET_UE_ID(ulCqiInd->crnti, ueId);
+ ueCb = &cell->ueCb[ueId-1];
+ if(ueCb->crnti != ulCqiInd->crnti)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcUlCqiInd(): UeCb for received crnti[%d] not found",ulCqiInd->crnti);
+ ret = RFAILED;
+ }
+ else
+ {
+ /*TODO: complete the processing of UL CQI Ind*/
+ }
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : SchProcUlCqiInd(): Received cell Id[%d] from MAC is not matching with CellId[%d] in SCH Cb",\
+ ulCqiInd->cellId, cell->cellId);
+ ret = RFAILED;
+ }
+ }
+ }
+ return ret;
+}
+
+/*******************************************************************
+ *
+ * @brief Processes PHR ind from MAC
+ *
+ * @details
+ *
+ * Function : SchProcPhrInd
+ *
+ * Functionality:
+ * Processes PHR ind from MAC
+ *
+ * @params[in]
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchProcPhrInd(Pst *pst, SchPwrHeadroomInd *schPhrInd)
+{
+ uint8_t ret = ROK;
+ uint16_t ueId = 0, cellIdx = 0;
+ SchUeCb *ueCb = NULLP;
+ SchCellCb *cell = NULLP;
+ Inst inst = pst->dstInst-SCH_INST_START;
+
+ if(!schPhrInd)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcPhrInd(): PHR is empty");
+ ret = RFAILED;
+ }
+ else
+ {
+ GET_CELL_IDX(schPhrInd->cellId, cellIdx);
+ cell = schCb[inst].cells[cellIdx];
+ if(cell == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : schProcPhrInd(): cell Id[%d] is not found", schPhrInd->cellId);
+ ret = RFAILED;
+ }
+ else
+ {
+ if(cell->cellId == schPhrInd->cellId)
+ {
+ GET_UE_ID(schPhrInd->crnti, ueId);
+ ueCb = &cell->ueCb[ueId-1];
+ if(ueCb->crnti != schPhrInd->crnti)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcPhrInd(): UeCb for received crnti[%d] not found",schPhrInd->crnti);
+ ret = RFAILED;
+ }
+ else
+ {
+ /*TODO: complete the processing of PHR Ind*/
+ }
+ }
+ else
+ {
+ DU_LOG("\nERROR --> SCH : SchProcPhrInd(): Mismatch between Received cell Id[%d] from MAC and CellID[%d] in SCH CB ",\
+ schPhrInd->cellId, cell->cellId);
+ ret = RFAILED;
+ }
+ }
+ }
+ return ret;
+}
+
+/*******************************************************************
+ *
+ * @brief Fill and send statistics response to MAC
+ *
+ * @details
+ *
+ * Function : SchSendStatsRspToMac
+ *
+ * Functionality: Fill and send statistics response to MAC
+ *
+ * @params[in] Inst inst, SchMacRsp result
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchSendStatsRspToMac(SchStatsRsp *statsRsp)
+{
+ Pst rspPst;
+ uint8_t ret = ROK;
+ SchStatsRsp *schStatsRsp;
+
+ DU_LOG("\nINFO --> SCH : Filling statistics response");
+ SCH_ALLOC(schStatsRsp, sizeof(SchStatsRsp));
+ if(schStatsRsp == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : Failed to allocate memory in SchSendStatsRspToMac()");
+ return RFAILED;
+ }
+
+ memcpy(schStatsRsp, statsRsp, sizeof(SchStatsRsp));
+ memset(statsRsp, 0, sizeof(SchStatsRsp));
+
+ /* Filling response post */
+ memset(&rspPst, 0, sizeof(Pst));
+ FILL_PST_SCH_TO_MAC(rspPst, inst);
+ rspPst.event = EVENT_STATISTICS_RSP_TO_MAC;
+
+ ret = MacMessageRouter(&rspPst, (void *)schStatsRsp);
+ if(ret == RFAILED)
+ {
+ DU_LOG("\nERROR --> SCH : SchSendStatsRspToMac(): Failed to send Statistics Response");
+ return ret;
+ }
+ return ret;
+}
+
+/*******************************************************************
+ *
+ * @brief Rejects all statistics group requested by MAC
+ *
+ * @details
+ *
+ * Function : SchRejectAllStats
+ *
+ * Functionality: Add all statistics group received in statistics
+ * request from MAC, to Reject-Stats-Group-List in statistics
+ * response to MAC
+ *
+ * @params[in] Statistics request from MAC
+ * Cause of rejection
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchRejectAllStats(SchStatsReq *schStatsReq, CauseOfResult cause)
+{
+ uint8_t grpIdx = 0;
+ SchStatsRsp schStatsRsp;
+
+ memset(&schStatsRsp, 0, sizeof(SchStatsRsp));
+
+ /* Copying all stats group from stats request to stats response */
+ schStatsRsp.subscriptionId = schStatsReq->subscriptionId;
+ for(grpIdx = 0; grpIdx < schStatsReq->numStatsGroup; grpIdx++)
+ {
+ schStatsRsp.statsGrpRejectedList[grpIdx].groupId = schStatsReq->statsGrpList[grpIdx].groupId;
+ schStatsRsp.statsGrpRejectedList[grpIdx].cause = cause;
+ }
+ schStatsRsp.numGrpRejected = schStatsReq->numStatsGroup;
+
+ return SchSendStatsRspToMac(&schStatsRsp);
+}
+
+/*******************************************************************
+ *
+ * @brief Add active KPI pointers to KPI-Active-List
+ *
+ * @details
+ *
+ * Function : schAddToKpiActiveList
+ *
+ * Functionality: For each active statistics group for which timer
+ * is running, add its KPI pointer to KPI-Active-List.
+ * Use case :
+ * When it is needed to update a KPI parameters, we need not
+ * traverse all statistics group and all KPIs within a group
+ * to get the specific KPI pointer to be updated.
+ * Instead, we can traverse through KPI-Active-List and update
+ * all entries in this list.
+ *
+ * @params[in] Pointer to the prb usage info link list
+ * Pointer to the stats ccnfig which we need to add
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t schAddToKpiActiveList(CmLListCp *kpiList, PTR kpiStatsInfo)
+{
+ CmLList *node = NULLP;
+
+ SCH_ALLOC(node, sizeof(CmLList));
+ if(node)
+ {
+ node->node = kpiStatsInfo;
+ cmLListAdd2Tail(kpiList, node);
+ return ROK;
+ }
+ DU_LOG("\nERROR --> E2AP : Memory allocation failed in %s at line %d",__func__, __LINE__);
+ return RFAILED;
+}
+
+ /*******************************************************************
+ *
+ * @brief add the stats group information in statistics's statsGrpList
+ *
+ * @details
+ *
+ * Function : schAddToStatsGrpList
+ *
+ * Functionality: add the stats group information in statsGrpList
+ * [Step 1] - Allocating the memory for the stats group in which
+ * we need to fill into the list as a node.
+ * [Step 2] - If allocation is successful then start traversing
+ * each measurment cfg index of received group info.
+ * [Step 2.1] Validate all measurements. If validation succeeds, go
+ * to [step 2.2]. Otherwise, reject the stats group and go to step 3.
+ * [Step 2.2] Add each KPI/measurementCfg into activeKpiList one by one.
+ * If it fails for any KPI, reject the whole statsGrp and go to step 3..
+ * [Step 2.3] Fill other group related information
+ * [Step 2.4] Initialise and start timer
+ * [Step 2.5] Once all validation and configuration is successful, add
+ * statsGrp node into statistic's StatsGrpList.
+ * [Step 2.5.1] If node successfully added to the list, then
+ * fill the group related info in stats rsp's accepted list.
+ * [Step 2.5.2] Else goto step 3
+ * [Step 3] - If failed fill the group related info in stats rsp's
+ * rejected list.
+ *
+ * @params[in]
+ * Inst
+ * Pointer to the stats rsp
+ * Subscription Id
+ * Stats Grp Info which needs to be store in the list
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+
+uint8_t schAddToStatsGrpList(Inst inst, struct schStatsRsp *statsRsp, uint64_t subscriptionId, SchStatsGrpInfo *grpInfo)
+{
+ uint8_t ret =ROK;
+ uint8_t grpIdx=0;
+ uint8_t reqMeasIdx=0;
+ CauseOfResult cause;
+ bool measTypeInvalid=false;
+ CmLList *statsGrpNode=NULLP;
+ SchStatsGrp *grpInfoDb = NULLP;
+
+ /* Step 1 */
+ SCH_ALLOC(grpInfoDb, sizeof(SchStatsGrp));
+ if(grpInfoDb == NULLP)
+ {
+ DU_LOG("\nERROR --> E2AP : Memory allocation failed in %s at line %d",__func__, __LINE__);
+ cause = RESOURCE_UNAVAILABLE;
+ ret = RFAILED;
+ }
+ else
+ {
+ /* Step 2 */
+ for(reqMeasIdx = 0; reqMeasIdx < grpInfo->numStats; reqMeasIdx++)
+ {
+ /* Step 2.1 */
+ switch(grpInfo->statsList[reqMeasIdx])
+ {
+ case SCH_DL_TOTAL_PRB_USAGE:
+ {
+ SCH_ALLOC(grpInfoDb->kpiStats.dlTotalPrbUsage, sizeof(TotalPrbUsage));
+ if(!grpInfoDb->kpiStats.dlTotalPrbUsage)
+ {
+ DU_LOG("\nERROR --> E2AP : Memory allocation failed in %s at line %d",__func__, __LINE__);
+ measTypeInvalid = true;
+ cause = RESOURCE_UNAVAILABLE;
+ break;
+ }
+ break;
+ }
+
+ case SCH_UL_TOTAL_PRB_USAGE:
+ {
+ SCH_ALLOC(grpInfoDb->kpiStats.ulTotalPrbUsage, sizeof(TotalPrbUsage));
+ if(!grpInfoDb->kpiStats.ulTotalPrbUsage)
+ {
+ DU_LOG("\nERROR --> E2AP : Memory allocation failed in %s at line %d",__func__, __LINE__);
+ measTypeInvalid = true;
+ cause = RESOURCE_UNAVAILABLE;
+ break;
+ }
+ break;
+ }
+
+ default:
+ {
+ DU_LOG("\nERROR --> SCH : SchProcStatsReq: Invalid measurement type [%d]", \
+ grpInfo->statsList[reqMeasIdx]);
+ measTypeInvalid = true;
+ cause = PARAM_INVALID;
+ break;
+ }
+ }
+
+ if(measTypeInvalid)
+ {
+ ret =RFAILED;
+ break;
+ }
+ }
+
+ while(measTypeInvalid==false)
+ {
+ if(grpInfoDb->kpiStats.dlTotalPrbUsage)
+ {
+ /* Step 2.2 */
+ if(schAddToKpiActiveList(&schCb[inst].statistics.activeKpiList.dlTotPrbUseList, (PTR)grpInfoDb->kpiStats.dlTotalPrbUsage)!=ROK)
+ {
+ DU_LOG("\nERROR --> E2AP : KPI addition failed in %s at %d",__func__,__LINE__);
+ cause = RESOURCE_UNAVAILABLE;
+ ret =RFAILED;
+ break;
+ }
+ }
+
+ if(grpInfoDb->kpiStats.ulTotalPrbUsage)
+ {
+ /* Step 2.2 */
+ if(schAddToKpiActiveList(&schCb[inst].statistics.activeKpiList.ulTotPrbUseList, (PTR)grpInfoDb->kpiStats.ulTotalPrbUsage) != ROK)
+ {
+ DU_LOG("\nERROR --> E2AP : KPI addition failed in %s at %d",__func__,__LINE__);
+ cause = RESOURCE_UNAVAILABLE;
+ ret =RFAILED;
+ break;
+ }
+ }
+
+ /* Step 2.3 */
+ grpInfoDb->schInst = inst;
+ grpInfoDb->groupId = grpInfo->groupId;
+ grpInfoDb->periodicity = grpInfo->periodicity;
+ grpInfoDb->subscriptionId = subscriptionId;
+
+ /* Step 2.4 */
+ cmInitTimers(&(grpInfoDb->periodTimer), 1);
+ schStartTmr(&schCb[inst], (PTR)(grpInfoDb), EVENT_STATISTICS_TMR, grpInfoDb->periodicity);
+
+ /* Step 2.5 */
+ SCH_ALLOC(statsGrpNode, sizeof(CmLList));
+ if(statsGrpNode)
+ {
+ /* Step 2.5.1 */
+ statsGrpNode->node = (PTR) grpInfoDb;
+ cmLListAdd2Tail(&schCb[inst].statistics.statsGrpList, statsGrpNode);
+ statsRsp->statsGrpAcceptedList[statsRsp->numGrpAccepted] = grpInfo->groupId;
+ statsRsp->numGrpAccepted++;
+ grpIdx++;
+ ret = ROK;
+ break;
+ }
+ else
+ {
+ /* Step 2.5.2 */
+ DU_LOG("\nERROR --> E2AP : Memory allocation failed in %s at %d",__func__,__LINE__);
+ cause = RESOURCE_UNAVAILABLE;
+ ret = RFAILED;
+ break;
+ }
+ }
+ }
+
+ if(ret != ROK)
+ {
+ /* Step 3 */
+ if(grpInfoDb)
+ {
+ deleteStatsGrpInfo(inst, grpInfoDb);
+ SCH_FREE(grpInfoDb, sizeof(SchStatsGrp));
+ }
+ statsRsp->statsGrpRejectedList[statsRsp->numGrpRejected].groupId = grpInfo->groupId;
+ statsRsp->statsGrpRejectedList[statsRsp->numGrpRejected].cause = cause;
+ statsRsp->numGrpRejected++;
+ return RFAILED;
+ }
+ return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Processes Statistics Request from MAC
+ *
+ * @details
+ *
+ * Function : SchProcStatsReq
+ *
+ * Functionality:
+ *
+ * This function process the statistics request from MAC:
+ * [Step 1] Basic validation. If fails, all stats group in stats request are
+ * rejected.
+ * [Step 2] If basic validations passed, traverse all stats group and
+ * validate each measurement types in each group.
+ * [Step 3] If any measurement type validation fails in a group, that group
+ * is not configured and it is added to stats-group-rejected-list in
+ * sch-stats-response message.
+ * [Step 4] If a group passes all validation, it is added to SCH database.
+ * And the group is added to stats-group-accepted-list in sch-stats-response message.
+ * [Step 5] sch-stats-response is sent to du app with stats-group-rejected-list
+ * and stats-group-accepted-list.
+ *
+ * @params[in] Post structure
+ * Statistics Request from MAC
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchProcStatsReq(Pst *pst, SchStatsReq *statsReq)
+{
+ bool allocFailed = false;
+ uint8_t grpIdx = 0, reqGrpIdx = 0;
+ SchStatsGrpInfo *grpInfo = NULLP;
+ SchStatsRsp schStatsRsp;
+ Inst inst = pst->dstInst - SCH_INST_START;
+
+ DU_LOG("\nINFO --> SCH : Received Statistics Request from MAC");
+
+ if(statsReq == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcStatsReq(): Received Null pointer");
+ return RFAILED;
+ }
+
+ /*Step -1*/
+ if(schCb[inst].statistics.statsGrpList.count >= MAX_NUM_STATS_GRP)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcStatsReq: Maximum number of statistics configured. \
+ Cannot process new request.");
+ SchRejectAllStats(statsReq, RESOURCE_UNAVAILABLE);
+ SCH_FREE(statsReq, sizeof(SchStatsReq));
+ return RFAILED;
+ }
+
+ memset(&schStatsRsp, 0, sizeof(SchStatsRsp));
+
+ /*Step -2*/
+ for(reqGrpIdx=0; reqGrpIdx<statsReq->numStatsGroup && grpIdx<MAX_NUM_STATS; reqGrpIdx++)
+ {
+ grpInfo = &statsReq->statsGrpList[reqGrpIdx];
+ /*Step -3 */
+ if(allocFailed == true)
+ {
+ schStatsRsp.statsGrpRejectedList[schStatsRsp.numGrpRejected].groupId = grpInfo->groupId;
+ schStatsRsp.statsGrpRejectedList[schStatsRsp.numGrpRejected].cause = RESOURCE_UNAVAILABLE;
+ schStatsRsp.numGrpRejected++;
+ }
+ else
+ {
+ /*Step -4 */
+ if(schAddToStatsGrpList(inst, &schStatsRsp, statsReq->subscriptionId, grpInfo) != ROK)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcStatsReq(): Failed to fill the stats group list");
+ if((schStatsRsp.statsGrpRejectedList[schStatsRsp.numGrpRejected-1].groupId == grpInfo->groupId &&\
+ (schStatsRsp.statsGrpRejectedList[schStatsRsp.numGrpRejected-1].cause == RESOURCE_UNAVAILABLE)))
+ {
+ allocFailed = true;
+ }
+ }
+ }
+ }
+
+ schStatsRsp.subscriptionId = statsReq->subscriptionId;
+ SCH_FREE(statsReq, sizeof(SchStatsReq));
+
+ /*Step -5 */
+ SchSendStatsRspToMac(&schStatsRsp);
+
+ return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Fill and send statistics indication to MAC
+ *
+ * @details
+ *
+ * Function : SchSendStatsIndToMac
+ *
+ * Functionality: Fill and send statistics indication to MAC
+ *
+ * @params[in] SCH Instance
+ * Measurement Type
+ * Measurement Value
+ * Size of value parameter
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchSendStatsIndToMac(Inst inst, SchStatsInd *statsInd)
+{
+ Pst pst;
+ uint8_t ret = ROK;
+
+#ifdef DEBUG_PRINT
+ DU_LOG("\nDEBUG --> SCH : Filling statistics indication");
+#endif
+
+ /* Filling post structure */
+ memset(&pst, 0, sizeof(Pst));
+ FILL_PST_SCH_TO_MAC(pst, inst);
+ pst.event = EVENT_STATISTICS_IND_TO_MAC;
+
+ ret = MacMessageRouter(&pst, (void *)statsInd);
+ if(ret == RFAILED)
+ {
+ DU_LOG("\nERROR --> SCH : SchSendStatsIndToMac(): Failed to send Statistics Indication");
+ }
+ return ret;
+}
+
+/**
+ * @brief Handler to process Timer expiry of DL Total PRB Usage calculation
+ *
+ * @param[in] cb Control block depending on the type of the timer event.
+ * @param[in] tmrEvnt Timer event to be started
+ *
+ * @return Bool indicating whether the timer is running or not
+ * -# ROK
+ * -# RFAILED
+*/
+double calcDlTotalPrbUsage(TotalPrbUsage *dlTotalPrbUsage)
+{
+ double percentageOfTotalPrbUsed = 0;
+
+ if(dlTotalPrbUsage->totalPrbAvailForTx)
+ percentageOfTotalPrbUsed = ((100.0 * dlTotalPrbUsage->numPrbUsedForTx) / dlTotalPrbUsage->totalPrbAvailForTx);
+
+ memset(dlTotalPrbUsage, 0, sizeof(TotalPrbUsage));
+
+ return percentageOfTotalPrbUsed;
+}
+
+/**
+ * @brief Handler to check if the timer is running
+ *
+ * @param[in] cb Control block depending on the type of the timer event.
+ * @param[in] tmrEvnt Timer event to be started
+ *
+ * @return Bool indicating whether the timer is running or not
+ * -# ROK
+ * -# RFAILED
+*/
+uint8_t calcUlTotalPrbUsage(TotalPrbUsage *ulTotalPrbUsage)
+{
+ double percentageOfTotalPrbUsed = 0;
+
+ if(ulTotalPrbUsage->totalPrbAvailForTx)
+ percentageOfTotalPrbUsed = ((100.0 * ulTotalPrbUsage->numPrbUsedForTx) / ulTotalPrbUsage->totalPrbAvailForTx);
+
+ memset(ulTotalPrbUsage, 0, sizeof(TotalPrbUsage));
+
+ return percentageOfTotalPrbUsed;
+}
+
+/**
+ * @brief Calculates statistics in a group and sends
+ * statistics indication for this group
+ *
+ * @param[in] Statistics group info
+ *
+ * @return
+ * -# ROK
+ * -# RFAILED
+*/
+uint8_t schCalcAndSendGrpStats(SchStatsGrp *grpInfo)
+{
+ uint8_t measStatsIdx = 0;
+ SchStatsInd statsInd;
+
+ memset(&statsInd, 0, sizeof(SchStatsInd));
+ statsInd.subscriptionId = grpInfo->subscriptionId;
+ statsInd.groupId = grpInfo->groupId;
+
+ if(grpInfo->kpiStats.dlTotalPrbUsage)
+ {
+ statsInd.measuredStatsList[measStatsIdx].type = SCH_DL_TOTAL_PRB_USAGE;
+ statsInd.measuredStatsList[measStatsIdx].value = calcDlTotalPrbUsage(grpInfo->kpiStats.dlTotalPrbUsage);
+ measStatsIdx++;
+ }
+
+ if(grpInfo->kpiStats.ulTotalPrbUsage)
+ {
+ statsInd.measuredStatsList[measStatsIdx].type = SCH_UL_TOTAL_PRB_USAGE;
+ statsInd.measuredStatsList[measStatsIdx].value = calcUlTotalPrbUsage(grpInfo->kpiStats.ulTotalPrbUsage);
+ measStatsIdx++;
+ }
+
+ statsInd.numStats = measStatsIdx;
+
+ return SchSendStatsIndToMac(grpInfo->schInst, &statsInd);
+}
+
+/*******************************************************************
+ *
+ * @brief Delete node from active kpi list
+ *
+ * @details
+ *
+ * Function :deleteNodeFrmKpiList
+ *
+ * Functionality:
+ * Delete statistics group
+ *
+ * @params[in]
+ * Kpi list from which a node needs to be deleted
+ * Nodes info which a node needs to be deleted
+ * @return void
+ * ****************************************************************/
+
+void deleteNodeFrmKpiList(CmLListCp *kpiList, PTR kpiNodeInfoToDel)
+{
+ CmLList *kpiNode=NULLP;
+
+ CM_LLIST_FIRST_NODE(kpiList, kpiNode);
+ while(kpiNode)
+ {
+ if(kpiNode->node == kpiNodeInfoToDel)
+ {
+ cmLListDelFrm(kpiList, kpiNode);
+ SCH_FREE(kpiNode, sizeof(CmLList));
+ break;
+ }
+ kpiNode = kpiNode->next;
+ }
+
+}
+
+/*******************************************************************
+ *
+ * @brief Delete statistics group info
+ *
+ * @details
+ *
+ * Function : deleteStatsGrpInfo
+ *
+ * Functionality:
+ * Delete statistics group info
+ *
+ * @params[in]
+ * Inst
+ * Stats Grp info
+ * @return void
+ *
+ * ****************************************************************/
+void deleteStatsGrpInfo(Inst inst, SchStatsGrp *statsGrpInfo)
+{
+ if(statsGrpInfo)
+ {
+ if(statsGrpInfo->kpiStats.dlTotalPrbUsage)
+ {
+ deleteNodeFrmKpiList(&schCb[inst].statistics.activeKpiList.dlTotPrbUseList, (PTR) statsGrpInfo->kpiStats.dlTotalPrbUsage);
+ SCH_FREE(statsGrpInfo->kpiStats.dlTotalPrbUsage, sizeof(TotalPrbUsage));
+ }
+
+ if(statsGrpInfo->kpiStats.ulTotalPrbUsage)
+ {
+ deleteNodeFrmKpiList(&schCb[inst].statistics.activeKpiList.ulTotPrbUseList, (PTR) statsGrpInfo->kpiStats.ulTotalPrbUsage);
+ SCH_FREE(statsGrpInfo->kpiStats.ulTotalPrbUsage, sizeof(TotalPrbUsage));
+ }
+
+ if(schChkTmr((PTR)statsGrpInfo, EVENT_STATISTICS_TMR) == true)
+ {
+ schStopTmr(&schCb[inst], (PTR)statsGrpInfo, EVENT_STATISTICS_TMR);
+ }
+
+ memset(statsGrpInfo, 0, sizeof(SchStatsGrp));
+ }
+}
+
+/*******************************************************************
+ *
+ * @brief Delete statistics group Node
+ *
+ * @details
+ *
+ * Function : deleteStatsGrpNode
+ *
+ * Functionality:
+ * Delete statistics group node
+ *
+ * @params[in]
+ * Inst
+ * Stats Grp Node
+ * @return void
+ *
+ * ****************************************************************/
+void deleteStatsGrpNode(Inst inst, CmLList *grpNode)
+{
+ SchStatsGrp *statsGrpInfo=NULLP;
+
+ if(grpNode)
+ {
+ statsGrpInfo = (SchStatsGrp*)grpNode->node;
+ deleteStatsGrpInfo(inst, statsGrpInfo);
+ memset(statsGrpInfo, 0, sizeof(SchStatsGrp));
+ SCH_FREE(grpNode->node, sizeof(SchStatsGrp));
+ SCH_FREE(grpNode, sizeof(CmLList));
+ }
+}
+
+/******************************************************************
+ *
+ * @brief Deletion of node from statistics group list
+ *
+ * @details
+ *
+ * Function : deleteFromStatsGrpList
+ *
+ * Functionality: Deletion of node from statistics group list
+ * [Step 1]: Traverse each and every node of stats group list
+ * stored in the database
+ * [Step 2]: Check if the node's subscription id is same
+ * as the subscription id received. If same then go to step 3
+ * else move to the next node of the list.
+ * [Step 3]: If deleteAllGrp == true, then delete the node and
+ * move to the next node of the list.
+ * [Step 4]: If deleteAllGrp != true, then check if the node's group
+ * id is same as group id received then delete the node and mark the
+ * status found true else move to the next node of the list.
+ * [Step 5]: Once the traversing complete,
+ * if deleteAllGrp is true, then return successful rsp;
+ * else if status found is true, then return successful rsp;
+ * else return failure.
+ * @params[in]
+ * Inst
+ * Stats Grp List
+ * Subscription Id
+ * Group Id
+ * boolen of deleteAllGrp
+ * @return void
+ *
+ * ****************************************************************/
+uint8_t deleteFromStatsGrpList(Inst inst, CmLListCp *statsGrpList, uint64_t subscriptionId, uint8_t groupId, bool deleteAllGrp)
+{
+ bool statsFound=false;
+ SchStatsGrp *statsGrpInfo=NULLP;
+ CmLList *grpNode=NULLP;
+
+ /* [Step 1] */
+ CM_LLIST_FIRST_NODE(statsGrpList, grpNode);
+ while(grpNode)
+ {
+ statsGrpInfo = (SchStatsGrp*)grpNode->node;
+
+ /* [Step 2] */
+ if(statsGrpInfo->subscriptionId== subscriptionId)
+ {
+ if(deleteAllGrp == true)
+ {
+ /* [Step 3] */
+ cmLListDelFrm(statsGrpList, grpNode);
+ deleteStatsGrpNode(inst, grpNode);
+ }
+ else
+ {
+ /* [Step 4] */
+ if(statsGrpInfo->groupId== groupId)
+ {
+ cmLListDelFrm(statsGrpList, grpNode);
+ deleteStatsGrpNode(inst, grpNode);
+ statsFound = true;
+ }
+ }
+ }
+ CM_LLIST_FIRST_NODE(statsGrpList, grpNode);
+ }
+
+ /* [Step 5] */
+ if(deleteAllGrp == true)
+ {
+ return ROK;
+ }
+ else
+ {
+ if(statsFound == true)
+ return ROK;
+ }
+ return RFAILED;
+}
+
+/*******************************************************************
+ *
+ * @brief Delete statistics information
+ *
+ * @details
+ *
+ * Function : deleteStatsInfo
+ *
+ * Functionality:
+ * Delete statistics information base on numStatsGroup
+ * Info- If numStatsGroup = 0' indicates the Deletion procedure triggered by
+ * 'SUBS_DELETION_REQ' wherein all the groups of this particular
+ * Subscription has to be removed
+ * else when numStatsGroup != 0 then this is
+ * for SUBS_MOD_REQ's actionToBeDeleted wherein particular action(s) has
+ * to be removed thus need to pass groupId belonging to that subscription
+ * which has to be deleted.'
+ *
+ * [Step-1] If numStatsGroup = 0, Deletion of all stats group belonging to
+ * received subscription Id.
+ * [Step-2] Else if numStatsGroup > 0, Deletion of individual stats group
+ * from list whose information are present in stats delete request.
+ * [Step-3] Fill the result of the stats deletion in the SCH stats delete
+ * response
+ * @params[in]
+ * Instance
+ * Subscription delete req
+ * Subscription delete rsp
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t deleteStatsInfo(Inst inst, SchStatsDeleteReq *statsDeleteReq, SchStatsDeleteRsp *schStatsDeleteRsp)
+{
+ uint8_t statsGrpIdx=0;
+ CmLListCp *statsGrpList =NULLP;
+
+ statsGrpList = &schCb[inst].statistics.statsGrpList;
+
+ if(!statsDeleteReq->numStatsGroupToBeDeleted)
+ {
+ /* [Step-1] */
+ if(deleteFromStatsGrpList(inst,statsGrpList, statsDeleteReq->subscriptionId, 0, true) == ROK)
+ {
+ /* [Step 3]*/
+ schStatsDeleteRsp->subsDelRsp = RSP_OK;
+ schStatsDeleteRsp->subsDelCause = SUCCESSFUL;
+ }
+ else
+ {
+ /* [Step-3]*/
+ schStatsDeleteRsp->subsDelRsp = RSP_NOK;
+ schStatsDeleteRsp->subsDelCause = STATS_ID_NOT_FOUND;
+ }
+ }
+ else
+ {
+ for(statsGrpIdx=0; statsGrpIdx<statsDeleteReq->numStatsGroupToBeDeleted; statsGrpIdx++)
+ {
+ /* [Step-2] */
+ if(deleteFromStatsGrpList(inst, statsGrpList, statsDeleteReq->subscriptionId,\
+ statsDeleteReq->statsGrpIdToBeDelList[statsGrpIdx], false) == ROK)
+ {
+ /* [Step-3]*/
+ schStatsDeleteRsp->statsGrpDelInfo[statsGrpIdx].statsGrpDelRsp = RSP_OK;
+ schStatsDeleteRsp->statsGrpDelInfo[statsGrpIdx].statsGrpDelCause = SUCCESSFUL;
+ }
+ else
+ {
+ /* [Step-3]*/
+ schStatsDeleteRsp->statsGrpDelInfo[statsGrpIdx].statsGrpDelRsp = RSP_NOK;
+ schStatsDeleteRsp->statsGrpDelInfo[statsGrpIdx].statsGrpDelCause = STATS_ID_NOT_FOUND;
+ }
+ }
+ schStatsDeleteRsp->numStatsGroupDeleted = statsDeleteReq->numStatsGroupToBeDeleted;
+ }
+ return ROK;
+}
+
+/*******************************************************************
+ *
+ * @brief Processes Statistics Delete Request from MAC
+ *
+ * @details
+ *
+ * Function : SchProcStatsDeleteReq
+ *
+ * Functionality:
+ * This function process the statistics delete request from MAC:
+ *
+ * @params[in] Post structure
+ * Statistics Delete Request from MAC
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchProcStatsDeleteReq(Pst *pst, SchStatsDeleteReq *statsDeleteReq)
+{
+ Pst rspPst;
+ uint8_t ret =ROK;
+ SchStatsDeleteRsp *schStatsDeleteRsp;
+ Inst inst = pst->dstInst - SCH_INST_START;
+
+ DU_LOG("\nINFO --> SCH : Received Statistics Delete Request from MAC");
+
+ if(statsDeleteReq == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcStatsDeleteReq(): Received Null pointer");
+ return RFAILED;
+ }
+
+ /* Process Stats delete request and fill stats delete response simultaneously */
+ SCH_ALLOC(schStatsDeleteRsp, sizeof(SchStatsDeleteRsp));
+ if(schStatsDeleteRsp == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : Failed to allocate memory in SchProcStatsDeleteReq()");
+ return RFAILED;
+ }
+ schStatsDeleteRsp->subscriptionId=statsDeleteReq->subscriptionId;
+ deleteStatsInfo(inst, statsDeleteReq, schStatsDeleteRsp);
+
+ memset(&rspPst, 0, sizeof(Pst));
+ FILL_PST_SCH_TO_MAC(rspPst, inst);
+ rspPst.event = EVENT_STATISTICS_DELETE_RSP_TO_MAC;
+
+ ret = MacMessageRouter(&rspPst, (void *)schStatsDeleteRsp);
+ if(ret == RFAILED)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcStatsDeleteReq(): Failed to send Statistics Response");
+ }
+ SCH_FREE(statsDeleteReq, sizeof(SchStatsDeleteReq));
+
+ return ret;
+} /* End of SchProcStatsDeleteReq */
+
+/*******************************************************************
+ *
+ * @brief Fill and send statistics modification response to MAC
+ *
+ * @details
+ *
+ * Function : SchSendStatsRspToMac
+ *
+ * Functionality: Fill and send statistics
+ * modification response to MAC
+ *
+ * @params[in] Inst inst, SchMacRsp result
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchSendStatsModificationRspToMac(SchStatsModificationRsp *tmpSchStatsModRsp)
+{
+ Pst rspPst;
+ uint8_t ret = ROK;
+ SchStatsModificationRsp *schStatsModificationRsp=NULLP;
+
+ DU_LOG("\nINFO --> SCH : Filling statistics modification response");
+ SCH_ALLOC(schStatsModificationRsp, sizeof(SchStatsModificationRsp));
+ if(schStatsModificationRsp == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : Failed to allocate memory in SchSendStatsModificationRspToMac()");
+ return RFAILED;
+ }
+
+ memcpy(schStatsModificationRsp, tmpSchStatsModRsp, sizeof(SchStatsModificationRsp));
+ memset(tmpSchStatsModRsp, 0, sizeof(SchStatsModificationRsp));
+
+ /* Filling response post */
+ memset(&rspPst, 0, sizeof(Pst));
+ FILL_PST_SCH_TO_MAC(rspPst, inst);
+ rspPst.event = EVENT_STATISTICS_MODIFY_RSP_TO_MAC;
+
+ ret = MacMessageRouter(&rspPst, (void *)schStatsModificationRsp);
+ if(ret == RFAILED)
+ {
+ DU_LOG("\nERROR --> SCH : SchSendStatsModificationRspToMac(): Failed to send Statistics Modification Response");
+ return ret;
+ }
+ return ret;
+}
+
+/*******************************************************************
+ *
+ * @brief Rejects all statistics modification group requested by MAC
+ *
+ * @details
+ *
+ * Function : SchRejectAllStatsModification
+ *
+ * Functionality: Add all statistics modification group received in statistics
+ * request from MAC, to Reject-StatsModification-Group-List in statistics
+ * response to MAC
+ *
+ * @params[in] Statistics request from MAC
+ * Cause of rejection
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t SchRejectAllStatsModification(SchStatsModificationReq *statsModificationReq, CauseOfResult cause)
+{
+ uint8_t grpIdx = 0;
+ SchStatsModificationRsp statsModificationRsp;
+
+ memset(&statsModificationRsp, 0, sizeof(SchStatsModificationRsp));
+
+ /* fill the subscriptionId and the rejected list in stats modification rsp */
+ statsModificationRsp.subscriptionId = statsModificationReq->subscriptionId;
+ for(grpIdx = 0; grpIdx < statsModificationReq->numStatsGroup; grpIdx++)
+ {
+ statsModificationRsp.statsGrpRejectedList[grpIdx].groupId = statsModificationReq->statsGrpList[grpIdx].groupId;
+ statsModificationRsp.statsGrpRejectedList[grpIdx].cause = cause;
+ }
+ statsModificationRsp.numGrpRejected = statsModificationReq->numStatsGroup;
+
+ return SchSendStatsModificationRspToMac(&statsModificationRsp);
+}
+
+/****************************************************************************************
+*
+* @brief Processes Statistics modification Request from MAC
+*
+* @details
+*
+* Function :SchProcStatsModificationReq
+*
+* Functionality:
+* This function process the statistics modification request from MAC:
+* [Step -1] Check the stored stats group list empty.
+* [Step - 1.1] If empty Send the rejected group list to MAC as a stats
+* modification response.
+* [Step - 1.2] Else go to step 2.
+* [Step -2] Traverse all stats group and validate each measurement types in
+* each group.
+* [Step -3] Check for any failure and if failed fill the remaining group's
+* info in rejected list.
+* [Step -4] Else Check if the received subscriptionId and groupId match the
+* values with the database node.
+* [Step -4.1] If matches then follow the below mentioned steps.
+* [Step -4.1.1] Stop the timer.
+* [Step -4.1.2] Reconfigure stats group by adding a new entry for this
+* statsGroup with updated configuration in database.
+* [Step -4.1.3] if configured successfully, store stats info into
+* stats mod rsp's accepted list, restart timer and go to step 4.1.4
+* [Step -4.1.4] Delete the old entry of this stats group..
+* [Step -4.2] Else fill the group related info in stats modification rsp's
+* rejected list.
+* [Step -5] Send the stats modification rsp to MAC
+* @params[in] Post structure
+* Statistics modification Request from MAC
+* @return ROK - success
+* RFAILED - failure
+*
+* *******************************************************************************************/
+uint8_t SchProcStatsModificationReq(Pst *pst, SchStatsModificationReq *statsModificationReq)
+{
+ Inst inst;
+ uint8_t reqGrpIdx=0;
+ uint64_t subscriptionId =0;
+ bool allocFailed = false;
+ bool statsGrpFound= false;
+ CmLList *grpNode = NULLP;
+ SchStatsGrp *statsGrpInfo=NULLP;
+ SchStatsGrpInfo statsGrpToModify;
+ SchStatsModificationRsp statsModificationRsp;
+
+ inst=pst->dstInst - SCH_INST_START;
+
+ DU_LOG("\nINFO --> SCH : Received Statistics modification request from MAC");
+
+ if(statsModificationReq == NULLP)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcStatsModificationReq(): Received Null pointer");
+ return RFAILED;
+ }
+ memset(&statsModificationRsp, 0, sizeof(SchStatsRsp));
+
+ /* [Step -1] */
+ if(schCb[inst].statistics.statsGrpList.count)
+ {
+ /* [Step -1.2] */
+ subscriptionId = statsModificationReq->subscriptionId;
+
+ /* [Step - 2] */
+ for(reqGrpIdx=0; reqGrpIdx<statsModificationReq->numStatsGroup; reqGrpIdx++)
+ {
+ /* [Step - 3] */
+ statsGrpToModify = statsModificationReq->statsGrpList[reqGrpIdx];
+ if(allocFailed != true)
+ {
+ CM_LLIST_FIRST_NODE(&schCb[inst].statistics.statsGrpList, grpNode);
+ while(grpNode)
+ {
+ /* [Step - 4] */
+ statsGrpInfo = (SchStatsGrp*)grpNode->node;
+ if((statsGrpInfo->subscriptionId== subscriptionId) && (statsGrpInfo->groupId== statsGrpToModify.groupId))
+ {
+ statsGrpFound= true;
+ break;
+ }
+ grpNode = grpNode->next;
+ }
+
+ /* [Step - 4.1] */
+ if(statsGrpFound== true)
+ {
+ /* [Step - 4.1.1] */
+ if(schChkTmr((PTR)statsGrpInfo, EVENT_STATISTICS_TMR) == true)
+ {
+ schStopTmr(&schCb[inst], (PTR)statsGrpInfo, EVENT_STATISTICS_TMR);
+ }
+
+ /* [Step - 4.1.2] */
+ if(schAddToStatsGrpList(inst, &statsModificationRsp, subscriptionId, &statsGrpToModify) != ROK)
+ {
+ DU_LOG("\nERROR --> SCH : SchProcStatsReq(): Failed to fill the stats group list");
+ if(statsModificationRsp.statsGrpRejectedList[statsModificationRsp.numGrpRejected-1].groupId == statsGrpToModify.groupId)
+ {
+ /* [Step - 4.1.3] */
+ schStartTmr(&schCb[inst], (PTR)(statsGrpInfo), EVENT_STATISTICS_TMR, statsGrpInfo->periodicity);
+ if(statsModificationRsp.statsGrpRejectedList[statsModificationRsp.numGrpRejected-1].cause == RESOURCE_UNAVAILABLE)
+ {
+ allocFailed = true;
+ break;
+ }
+ }
+ }
+ else
+ {
+ /* [Step - 4.1.4] */
+ deleteStatsGrpNode(inst, grpNode);
+ }
+ }
+ else
+ {
+ /* [Step - 4.2] */
+ statsModificationRsp.statsGrpRejectedList[statsModificationRsp.numGrpRejected].groupId = statsGrpToModify.groupId;
+ statsModificationRsp.statsGrpRejectedList[statsModificationRsp.numGrpRejected].cause = STATS_ID_NOT_FOUND;
+ statsModificationRsp.numGrpRejected++;
+ }
+ }
+ else
+ {
+ statsModificationRsp.statsGrpRejectedList[statsModificationRsp.numGrpRejected].groupId = statsGrpToModify.groupId;
+ statsModificationRsp.statsGrpRejectedList[statsModificationRsp.numGrpRejected].cause = RESOURCE_UNAVAILABLE;
+ statsModificationRsp.numGrpRejected++;
+ }
+ }
+
+ statsModificationRsp.subscriptionId = statsModificationReq->subscriptionId;
+ SchSendStatsModificationRspToMac(&statsModificationRsp);
+ }
+ else
+ {
+ /* [Step -1.1] */
+ SchRejectAllStatsModification(statsModificationReq, STATS_ID_NOT_FOUND);