/* This file contains APIs to send/receive messages from PHY */
-#include <stdio.h>
-#include <stdint.h>
-
-#include "envdep.h"
-#include "gen.h"
-#include "ssi.h"
-#include "gen.x"
-#include "rg.h"
-#include "lwr_mac_phy.h"
+#include "common_def.h"
+#include "lrg.h"
+#include "lrg.x"
+#include "du_app_mac_inf.h"
+#include "mac_sch_interface.h"
+#include "lwr_mac_upr_inf.h"
+#include "mac.h"
#include "lwr_mac_fsm.h"
-
-#ifdef INTEL_WLS
+#include "lwr_mac_phy.h"
+#include "mac_utils.h"
+#include "lwr_mac_utils.h"
+#include "lwr_mac.h"
+#ifdef INTEL_FAPI
+#include "nr5g_fapi_internal.h"
+#include "fapi_vendor_extension.h"
+#endif
+#ifdef INTEL_WLS_MEM
#include "wls_lib.h"
#endif
-EXTERN S16 rgClHndlCfgReq ARGS((void *msg));
-EXTERN void l1ProcessFapiRequest ARGS((uint8_t msgType, uint32_t msgLen, void *msg));
+uint8_t rgClHndlCfgReq ARGS((void *msg));
+void l1ProcessFapiRequest ARGS((uint8_t msgType, uint32_t msgLen, void *msg));
-#ifdef INTEL_WLS
+#ifdef INTEL_WLS_MEM
/*******************************************************************
*
- * @brief Enqueues memory blocks for use by L1
+ * @brief Sends request to start wls receiver thread
*
* @details
*
- * Function : LwrMacEnqueueWlsBlock
+ * Function : LwrMacStartWlsRcvr
*
* Functionality:
- * Enqueues memory blocks for use by L1
+ * Sends request to start wls receiver thread
*
* @params[in]
* @return void
*
* ****************************************************************/
-void LwrMacEnqueueWlsBlock()
+void LwrMacStartWlsRcvr()
{
- void *memPtr;
- void *wlsHdlr;
+ Pst pst;
+ Buffer *mBuf;
- WLS_MEM_ALLOC(memPtr, LWR_MAC_WLS_BUF_SIZE);
-
- if(memPtr)
+ DU_LOG("\nINFO --> LWR MAC : Requesting to start WLS receiver thread");
+
+ /* Filling post */
+ memset(&pst, 0, sizeof(Pst));
+ FILL_PST_LWR_MAC_TO_LWR_MAC(pst, EVT_START_WLS_RCVR);
+
+ if (ODU_GET_MSG_BUF(pst.region, pst.pool, &mBuf) != ROK)
{
- wlsHdlr = mtGetWlsHdl();
-
- /* allocate blocks for UL transmittion */
- while(WLS_EnqueueBlock(wlsHdlr, WLS_VA2PA(wlsHdlr, memPtr)))
- {
- WLS_MEM_ALLOC(memPtr, LWR_MAC_WLS_BUF_SIZE);
- if(!memPtr)
- break;
- }
-
- // free not enqueued block
- if(memPtr)
- {
- WLS_MEM_FREE(memPtr, LWR_MAC_WLS_BUF_SIZE);
- }
+ DU_LOG("\nERROR --> LWR MAC : Memory allocation failed for LwrMacStartWlsRcvr");
+ return;
}
-}/* LwrMacEnqueueWlsBlock */
+
+ ODU_POST_TASK(&pst, mBuf);
+}
/*******************************************************************
*
- * @brief Enqueue N number of blocks
+ * @brief Enqueues memory blocks for use by L1
*
* @details
*
- * Function : enqueueNBlocks
+ * Function : LwrMacEnqueueWlsBlock
*
* Functionality:
- * Enqueue N number of memory blocks
+ * Enqueues memory blocks for use by L1
*
- * @params[in] Number of blocks
- * @return ROK - success
- * RFAILED - failure
+ * @params[in]
+ * @return void
*
* ****************************************************************/
-uint16_t enqueueNBlocks(uint32_t numBlocks)
+void LwrMacEnqueueWlsBlock()
{
- void *memPtr;
- void *wlsHdlr; /* WLS handler */
-
- wlsHdlr = mtGetWlsHdl();
- while(numBlocks)
+ void *memPtr;
+ void *wlsHdlr = NULLP;
+
+ WLS_MEM_ALLOC(memPtr, LWR_MAC_WLS_BUF_SIZE);
+
+ if(memPtr)
{
- numBlocks--;
+ mtGetWlsHdl(&wlsHdlr);
+ /* allocate blocks for UL transmittion */
+ while(WLS_EnqueueBlock(wlsHdlr, WLS_VA2PA(wlsHdlr, memPtr)))
+ {
+ WLS_MEM_ALLOC(memPtr, LWR_MAC_WLS_BUF_SIZE);
+ if(!memPtr)
+ break;
+ }
- memPtr = (void *)NULL;
- WLS_MEM_ALLOC(memPtr, LWR_MAC_WLS_BUF_SIZE);
+ // free not enqueued block
if(memPtr)
{
- WLS_EnqueueBlock(wlsHdlr, WLS_VA2PA(wlsHdlr, memPtr));
+ WLS_MEM_FREE(memPtr, LWR_MAC_WLS_BUF_SIZE);
}
}
- RETVALUE(ROK);
-}/* enqueueNBlocks */
+}/* LwrMacEnqueueWlsBlock */
/*******************************************************************
*
* ****************************************************************/
void addWlsBlockToFree(void *msg, uint32_t msgLen, uint8_t idx)
{
- CmLList *node;
- WlsBlockToFree *block;
+ CmLList *node = NULLP;
+ WlsBlockToFree *block = NULLP;
MAC_ALLOC(block, sizeof(WlsBlockToFree));
if(block)
{
MAC_ALLOC(node, sizeof(CmLList));
if(node)
{
- block->ptr = msg;
- block->size = msgLen;
+ block->ptr = msg;
+ block->size = msgLen;
- node->node = (PTR)block;
- cmLListAdd2Tail(&wlsBlockToFreeList[idx], node);
+ node->node = (PTR)block;
+ cmLListAdd2Tail(&wlsBlockToFreeList[idx], node);
}
}
}/* addWlsBlockToFree */
+
+/*******************************************************************
+ *
+ * @brief Free DL Memory blocks stored in list
+ *
+ * @details
+ *
+ * Function : freeWlsBlockList
+ *
+ * Functionality: Free DL Memory blocks stored in list
+ *
+ * @params[in] Array index to be freed
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
void freeWlsBlockList(uint8_t idx)
{
CmLList *node;
CM_LLIST_FIRST_NODE(&wlsBlockToFreeList[idx], node);
while(node)
{
- block = (WlsBlockToFree *)node->node;
- cmLListDelFrm(&wlsBlockToFreeList[idx], node);
- WLS_MEM_FREE(block->ptr, block->size);
- MAC_FREE(block, sizeof(WlsBlockToFree));
- MAC_FREE(node, sizeof(CmLList));
- node = NULL;
- CM_LLIST_FIRST_NODE(&wlsBlockToFreeList[idx], node);
+ block = (WlsBlockToFree *)node->node;
+ cmLListDelFrm(&wlsBlockToFreeList[idx], node);
+ WLS_MEM_FREE(block->ptr, block->size);
+ MAC_FREE(block, sizeof(WlsBlockToFree));
+ MAC_FREE(node, sizeof(CmLList));
+ node = NULL;
+ CM_LLIST_FIRST_NODE(&wlsBlockToFreeList[idx], node);
}
}
}
* ****************************************************************/
void LwrMacRecvPhyMsg()
{
- uint32_t numL1Msg; /* Number of L1 messaes received */
- uint32_t numToGet; /* Number of Memory blocks to get */
+#ifdef INTEL_FAPI
+ uint32_t numMsgToGet; /* Number of Memory blocks to get */
void *wlsHdlr; /* WLS handler */
uint64_t l1Msg; /* Message received */
void *l1MsgPtr;
uint32_t msgSize;
uint16_t msgType;
- uint16_t flag;
+ uint16_t flag = 0;
+ p_fapi_api_queue_elem_t currElem = NULLP;
- wlsHdlr = mtGetWlsHdl();
- if(WLS_Ready(wlsHdlr))
+ mtGetWlsHdl(&wlsHdlr);
+ if(WLS_Ready(wlsHdlr) == 0)
{
- numToGet = WLS_Wait(wlsHdlr);
-
- numL1Msg = numToGet;
-
- while(numToGet)
- {
- l1Msg = (uint64_t) NULL;
- l1Msg = WLS_Get(wlsHdlr, &msgSize, &msgType, &flag);
- if(l1Msg)
- {
- l1MsgPtr = WLS_PA2VA(wlsHdlr, l1Msg);
- handlePhyMessages(msgType, msgSize, l1MsgPtr);
- }
- numToGet--;
- }
-
- if(numL1Msg)
+ while(true)
{
- enqueueNBlocks(numL1Msg);
- }
+ numMsgToGet = WLS_Wait(wlsHdlr);
+ if(numMsgToGet == 0)
+ {
+ continue;
+ }
+ while(numMsgToGet--)
+ {
+ currElem = NULLP;
+ l1Msg = (uint64_t)NULLP;
+ l1MsgPtr = NULLP;
+ l1Msg = WLS_Get(wlsHdlr, &msgSize, &msgType, &flag);
+ if(l1Msg)
+ {
+ l1MsgPtr = WLS_PA2VA(wlsHdlr, l1Msg);
+ currElem = (p_fapi_api_queue_elem_t) l1MsgPtr;
+ if(currElem->msg_type != FAPI_VENDOR_MSG_HEADER_IND)
+ {
+ procPhyMessages(currElem->msg_type, 0, (void *)(currElem + 1));
+ }
+ WLS_MEM_FREE(currElem, LWR_MAC_WLS_BUF_SIZE);
+ }
+ }
+ LwrMacEnqueueWlsBlock();
+ }
}
+#endif
} /* LwrMacRecvPhyMsg */
-#endif /* INTEL_WLS */
+#endif /* INTEL_WLS_MEM */
/*******************************************************************
- *
- * @brief Sends message to PHY
- *
- * @details
- *
- * Function : LwrMacSendToPhy
- * Functionality:
- * -Sends message to PHY
- *
- * @params[in] Message Type
- * Message Length
- * Messaga Pointer
- *
- * @return void
- *
- * *****************************************************************/
-
-PUBLIC uint16_t LwrMacSendToPhy(uint8_t msgType, uint32_t msgLen, void *msg)
+ *
+ * @brief Send FAPI messages to Intel PHY/Phy stub
+ *
+ * @details
+ *
+ * Function : LwrMacSendToL1
+ *
+ * Functionality: Send FAPI messages to Intel PHY/Phy stub
+ *
+ * @params[in] Message pointer
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+uint8_t LwrMacSendToL1(void *msg)
{
-#ifdef INTEL_WLS
- int ret;
- unsigned long long pMsg;
-
- pMsg = WLS_VA2PA(mtGetWlsHdl(), msg);
- ret = WLS_Put(mtGetWlsHdl(), pMsg, msgLen, msgType, 0);
+ uint8_t ret = ROK;
+#ifdef INTEL_FAPI
+ uint16_t msgLen =0;
+ p_fapi_api_queue_elem_t currMsg = NULLP;
+
+#ifdef CALL_FLOW_DEBUG_LOG
+ char message[100];
- if(ret != 0)
+ currMsg = (p_fapi_api_queue_elem_t)msg;
+ while(currMsg)
{
- printf("\nFailure in sending message to PHY");
- WLS_MEM_FREE(msg, msgLen);
- return RFAILED;
+ switch(currMsg->msg_type)
+ {
+ case FAPI_PARAM_REQUEST:
+ strcpy(message, "FAPI_PARAM_REQUEST");
+ break;
+ case FAPI_CONFIG_REQUEST:
+ strcpy(message, "FAPI_CONFIG_REQUEST");
+ break;
+ case FAPI_START_REQUEST:
+ strcpy(message, "FAPI_START_REQUEST");
+ break;
+ case FAPI_DL_TTI_REQUEST:
+ strcpy(message, "FAPI_DL_TTI_REQUEST");
+ break;
+ case FAPI_TX_DATA_REQUEST:
+ strcpy(message, "FAPI_TX_DATA_REQUEST");
+ break;
+ case FAPI_UL_TTI_REQUEST:
+ strcpy(message, "FAPI_UL_TTI_REQUEST");
+ break;
+ case FAPI_STOP_REQUEST:
+ strcpy(message, "FAPI_STOP_REQUEST");
+ break;
+ case FAPI_UL_DCI_REQUEST:
+ strcpy(message, "FAPI_UL_DCI_REQUEST");
+ break;
+ default:
+ strcpy(message, "INVALID_MSG");
+ break;
+ }
+ DU_LOG("\nCall Flow: ENTLWRMAC -> PHY : %s\n",message);
+ currMsg = currMsg->p_next;
}
- else
+#endif
+
+
+#ifdef INTEL_WLS_MEM
+ void * wlsHdlr = NULLP;
+
+ mtGetWlsHdl(&wlsHdlr);
+ if(msg)
{
- addWlsBlockToFree(msg, msgLen, (slotIndIdx-1));
+ currMsg = (p_fapi_api_queue_elem_t)msg;
+ msgLen = currMsg->msg_len + sizeof(fapi_api_queue_elem_t);
+ addWlsBlockToFree(currMsg, msgLen, (lwrMacCb.phySlotIndCntr-1));
+ if(currMsg->p_next == NULLP)
+ {
+ DU_LOG("\nERROR --> LWR MAC : There cannot be only one block to send");
+ return RFAILED;
+ }
+
+ /* Sending first block */
+ ret = WLS_Put(wlsHdlr, WLS_VA2PA(wlsHdlr, currMsg), msgLen, currMsg->msg_type, WLS_SG_FIRST);
+ if(ret != 0)
+ {
+ DU_LOG("\nERROR --> LWR MAC : Failure in sending message to PHY");
+ return RFAILED;
+ }
+ currMsg = currMsg->p_next;
+
+ while(currMsg)
+ {
+ /* Sending the next msg */
+ msgLen = currMsg->msg_len + sizeof(fapi_api_queue_elem_t);
+ addWlsBlockToFree(currMsg, msgLen, (lwrMacCb.phySlotIndCntr-1));
+ if(currMsg->p_next != NULLP)
+ {
+ ret = WLS_Put(wlsHdlr, WLS_VA2PA(wlsHdlr, currMsg), msgLen, currMsg->msg_type, WLS_SG_NEXT);
+ if(ret != 0)
+ {
+ DU_LOG("\nERROR --> LWR MAC : Failure in sending message to PHY");
+ return RFAILED;
+ }
+ currMsg = currMsg->p_next;
+ }
+ else
+ {
+ /* Sending last msg */
+ ret = WLS_Put(wlsHdlr, WLS_VA2PA(wlsHdlr, currMsg), msgLen, currMsg->msg_type, WLS_SG_LAST);
+ if(ret != 0)
+ {
+ DU_LOG("\nERROR --> LWR MAC : Failure in sending message to PHY");
+ return RFAILED;
+ }
+ currMsg = NULLP;
+ }
+ }
}
#else
- l1ProcessFapiRequest(msgType, msgLen, msg);
+ p_fapi_api_queue_elem_t nextMsg = NULLP;
+
+ /* FAPI header and vendor specific msgs are freed here. Only
+ * the main FAPI messages are sent to phy stub */
+ currMsg = (p_fapi_api_queue_elem_t)msg;
+ while(currMsg)
+ {
+ nextMsg = currMsg->p_next;
+ msgLen = currMsg->msg_len + sizeof(fapi_api_queue_elem_t);
+ if((currMsg->msg_type != FAPI_VENDOR_MSG_HEADER_IND) && \
+ (currMsg->msg_type != FAPI_VENDOR_MESSAGE))
+ {
+ l1ProcessFapiRequest(currMsg->msg_type, msgLen, currMsg);
+ }
+ else
+ {
+ LWR_MAC_FREE(currMsg, msgLen);
+ }
+ currMsg = nextMsg;
+ }
+#endif
#endif
- return ROK;
-} /* LwrMacSendToPhy */
+ return ret;
+}
/**********************************************************************
- End of file
-**********************************************************************/
+ End of file
+ **********************************************************************/
Code Review / o-du / l2.git / blobdiff