* ****************************************************************/
uint8_t MacSchCrcInd(Pst *pst, CrcIndInfo *crcInd)
{
+ Inst inst = pst->dstInst-SCH_INST_START;
#ifdef CALL_FLOW_DEBUG_LOG
DU_LOG("\nCall Flow: ENTMAC -> ENTSCH : EVENT_CRC_IND_TO_SCH\n");
#endif
- switch(crcInd->crcInd[0])
- {
- case CRC_FAILED:
- DU_LOG("\nDEBUG --> SCH : Received CRC indication. CRC Status [FAILURE]");
- break;
- case CRC_PASSED:
- DU_LOG("\nDEBUG --> SCH : Received CRC indication. CRC Status [PASS]");
- break;
- default:
- DU_LOG("\nDEBUG --> SCH : Invalid CRC state %d", crcInd->crcInd[0]);
- return RFAILED;
- }
+ schProcessCrcInd(crcInd, inst);
return ROK;
}
cellCb->actvUeBitMap = 0;
cellCb->boIndBitMap = 0;
+ cellCb->cellCfg.schHqCfg.maxDlDataHqTx = SCH_MAX_NUM_DL_HQ_TX;
+ cellCb->cellCfg.schHqCfg.maxMsg4HqTx = SCH_MAX_NUM_MSG4_TX;
+ cellCb->cellCfg.schHqCfg.maxUlDataHqTx = SCH_MAX_NUM_UL_HQ_TX;
+ cellCb->cellCfg.schRachCfg.maxMsg3Tx = SCH_MAX_NUM_MSG3_TX;
+
/* Fill and send Cell config confirm */
memset(&rspPst, 0, sizeof(Pst));
FILL_PST_SCH_TO_MAC(rspPst, pst->dstInst);
bool isLcIdValid = false;
SchUeCb *ueCb = NULLP;
SchCellCb *cell = NULLP;
- Inst inst = pst->dstInst-SCH_INST_START;
- CmLListCp *lcLL = NULLP;
+ Inst inst = pst->dstInst-SCH_INST_START;
#ifdef CALL_FLOW_DEBUG_LOG
DU_LOG("\nCall Flow: ENTMAC -> ENTSCH : EVENT_DL_RLC_BO_INFO_TO_SCH\n");
-#endif
-
+#endif
DU_LOG("\nDEBUG --> SCH : Received RLC BO Status indication LCId [%d] BO [%d]", dlBoInfo->lcId, dlBoInfo->dataVolume);
cell = schCb[inst].cells[inst];
*Thus clearing out the LC from the Lc priority list*/
if(dlBoInfo->dataVolume == 0)
{
- /*Check the LC is Dedicated or default and accordingly LCList will
- * be used*/
- if(ueCb->dlInfo.dlLcCtxt[lcId].isDedicated)
- {
- lcLL = &(ueCb->dlLcPrbEst.dedLcInfo->dedLcList);
- }
- else
- {
- lcLL = &(ueCb->dlLcPrbEst.defLcList);
- }
- handleLcLList(lcLL, lcId, DELETE);
+ /* TODO : Check the LC is Dedicated or default and accordingly LCList
+ * will be used*/
return ROK;
}
if(lcId == SRB0_LCID)
{
cell->raCb[ueId -1].msg4recvd = true;
- cell->raCb[ueId -1].dlMsgPduLen = dlBoInfo->dataVolume;
-
+ cell->raCb[ueId -1].dlMsgPduLen = dlBoInfo->dataVolume;
}
else
{
+ /* TODO : These part of changes will be corrected during DL scheduling as
+ * per K0 - K1 -K2 */
SET_ONE_BIT(ueId, cell->boIndBitMap);
if(ueCb->dlInfo.dlLcCtxt[lcId].lcId == lcId)
{
return RFAILED;
}
}
-
/* Adding UE Id to list of pending UEs to be scheduled */
addUeToBeScheduled(cell, ueId);
return ROK;
}
if(uciInd->numSrBits)
{
- ueCb->srRcvd = true;
-
+ ueCb->srRcvd = true;
/* Adding UE Id to list of pending UEs to be scheduled */
addUeToBeScheduled(cellCb, ueCb->ueId);
}
return ROK;
}
+/*******************************************************************
+ *
+ * @brief Processes HARQ UCI indication from MAC
+ *
+ * @details
+ *
+ * Function : MacSchHarqUciInd
+ *
+ * Functionality:
+ * Processes HARQ UCI indication from MAC
+ *
+ * @params[in] Post structure
+ * UCI Indication
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t MacSchHarqUciInd(Pst *pst, HarqUciIndInfo *uciInd)
+{
+ Inst inst = pst->dstInst-SCH_INST_START;
+ SchUeCb *ueCb;
+ SchCellCb *cellCb = schCb[inst].cells[inst];
+
+#ifdef CALL_FLOW_DEBUG_LOG
+ DU_LOG("\nCall Flow: ENTMAC -> ENTSCH : EVENT_UCI_IND_TO_SCH\n");
+#endif
+
+ DU_LOG("\nDEBUG --> SCH : Received HARQ");
+
+ ueCb = schGetUeCb(cellCb, uciInd->crnti);
+
+ if(ueCb->state == SCH_UE_STATE_INACTIVE)
+ {
+ DU_LOG("\nERROR --> SCH : Crnti %d is inactive", uciInd->crnti);
+ return ROK;
+ }
+
+ schUpdateHarqFdbk(ueCb, uciInd->numHarq, uciInd->harqPayload, &uciInd->slotInd);
+
+ return ROK;
+}
+
/*******************************************************************
*
* @brief Allocates requested PRBs for DL
while(firstNodeOfList)
{
tempNode = (SchPageInfo*)(firstNodeOfList->node);
- if ((recvdNode->TxTime.slot < tempNode->TxTime.slot))
+ if ((recvdNode->pageTxTime.slot < tempNode->pageTxTime.slot))
{
cmLListInsCrnt(storedPageList, currentNodeInfo);
break;
}
- else if ((recvdNode->TxTime.slot == tempNode->TxTime.slot))
+ else if ((recvdNode->pageTxTime.slot == tempNode->pageTxTime.slot))
{
- DU_LOG("\nERROR --> SCH : schAddPagingIndtoList() : Slot[%d] is already present in the list", recvdNode->TxTime.slot);
+ DU_LOG("\nERROR --> SCH : schAddPagingIndtoList() : Slot[%d] is already present in the list", recvdNode->pageTxTime.slot);
return RFAILED;
}
else
{
cmLListAdd2Tail(storedPageList, currentNodeInfo);
}
- DU_LOG("\nINFO --> SCH : Paging information is stored sucessfully");
+ DU_LOG("\nDEBUG --> SCH : Paging information is stored successfully for PF:%d, Slot:%d",\
+ recvdNode->pageTxTime.sfn, recvdNode->pageTxTime.slot);
return ROK;
}
if(pageInd)
{
- DU_LOG("\nINFO --> SCH : Received paging indication form MAC for cellId[%d]",pageInd->cellId);
+ 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++)
{
pageInfo->pf = pageInd->pf;
pageInfo->i_s = pageInd->i_s;
- pageInfo->TxTime.cellId = pageInd->cellId;
- pageInfo->TxTime.sfn = (pageInd->pf + cellCb->pageCb.pagMonOcc[pageInd->i_s].frameOffset) % MAX_SFN;
- pageInfo->TxTime.slot = cellCb->pageCb.pagMonOcc[pageInd->i_s].pagingOccSlot;
+ 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);
else
{
memcpy(pageInfo->pagePdu, pageInd->pagePdu, pageInfo->msgLen);
- ret = schAddPagingIndtoList(&cellCb->pageCb.pageIndInfoRecord[pageInfo->TxTime.sfn], pageInfo);
+ ret = schAddPagingIndtoList(&cellCb->pageCb.pageIndInfoRecord[pageInfo->pageTxTime.sfn], pageInfo);
if(ret != ROK)
{
DU_LOG("\nERROR --> SCH : MacSchPagingInd(): Failed to store paging record");