/* This file contains APIs to send/receive messages from PHY */
-#include "stdio.h"
-#include "envdep.h"
-#include "ssi.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"
+#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
-#include "rg_cl_phy.h"
-#include "fapi.h"
+uint8_t rgClHndlCfgReq ARGS((void *msg));
+void l1ProcessFapiRequest ARGS((uint8_t msgType, uint32_t msgLen, void *msg));
+#ifdef INTEL_WLS_MEM
-EXTERN S16 rgClHndlCfgReq ARGS((void *msg));
-EXTERN void macToPhy ARGS((U16 msgType, U32 msgLen, void *msg));
-EXTERN void processRequest ARGS((U16 msgType, U32 msgLen, void *msg));
-/******************************************************************
+/*******************************************************************
*
- * @brief Receives message to PHY
+ * @brief Sends request to start wls receiver thread
*
* @details
*
- * Function : phyToMac
+ * Function : LwrMacStartWlsRcvr
*
* Functionality:
- * -Receives Msg from PHY
+ * Sends request to start wls receiver thread
+ *
+ * @params[in]
+ * @return void
+ *
+ * ****************************************************************/
+void LwrMacStartWlsRcvr()
+{
+ Pst pst;
+ Buffer *mBuf;
+
+ 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)
+ {
+ DU_LOG("\nERROR --> LWR MAC : Memory allocation failed for LwrMacStartWlsRcvr");
+ return;
+ }
+
+ ODU_POST_TASK(&pst, mBuf);
+}
+
+/*******************************************************************
+ *
+ * @brief Enqueues memory blocks for use by L1
+ *
+ * @details
*
- * @params[in] Message Pointer
+ * Function : LwrMacEnqueueWlsBlock
*
+ * Functionality:
+ * Enqueues memory blocks for use by L1
+ *
+ * @params[in]
* @return void
*
- ******************************************************************/
+ * ****************************************************************/
+void LwrMacEnqueueWlsBlock()
+{
+ void *memPtr;
+ void *wlsHdlr = NULLP;
+
+ WLS_MEM_ALLOC(memPtr, LWR_MAC_WLS_BUF_SIZE);
+
+ if(memPtr)
+ {
+ 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;
+ }
+
+ // free not enqueued block
+ if(memPtr)
+ {
+ WLS_MEM_FREE(memPtr, LWR_MAC_WLS_BUF_SIZE);
+ }
+ }
+}/* LwrMacEnqueueWlsBlock */
-void phyToMac(U16 msgType, U32 msgLen,void *msg)
+/*******************************************************************
+ *
+ * @brief Add memory block (to be freed later) to list
+ *
+ * @details
+ *
+ * Function : addWlsBlockToFree
+ *
+ * Functionality:
+ * Add memory block (to be freed later) to list
+ *
+ * @params[in]
+ * @return ROK - success
+ * RFAILED - failure
+ *
+ * ****************************************************************/
+void addWlsBlockToFree(void *msg, uint32_t msgLen, uint8_t idx)
{
- switch(msgType)
+ CmLList *node = NULLP;
+ WlsBlockToFree *block = NULLP;
+ MAC_ALLOC(block, sizeof(WlsBlockToFree));
+ if(block)
{
- case MSG_TYPE_CONFIG_RSP:
- rgClHndlCfgReq(msg);
- break;
+ MAC_ALLOC(node, sizeof(CmLList));
+ if(node)
+ {
+ block->ptr = msg;
+ block->size = msgLen;
+
+ node->node = (PTR)block;
+ cmLListAdd2Tail(&wlsBlockToFreeList[idx], node);
+ }
+ }
+}/* addWlsBlockToFree */
- default:
- printf("\nInvalid message type[%x] from PHY", msgType);
+
+/*******************************************************************
+ *
+ * @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;
+ WlsBlockToFree *block;
+ if(wlsBlockToFreeList[idx].count)
+ {
+ 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);
+ }
}
}
/*******************************************************************
*
- * @brief Sends message to PHY
+ * @brief Receives msg from L1
*
* @details
*
- * Function : sendToPhy
+ * Function :LwrMacRecvPhyMsg
*
* Functionality:
- * -Sends message to PHY
+ * Receives L1 Msg and enqueues memort for UL msg
+ *
+ * @params[in]
+ * @return
+ * ****************************************************************/
+void LwrMacRecvPhyMsg()
+{
+#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 = 0;
+ p_fapi_api_queue_elem_t currElem = NULLP;
+
+ mtGetWlsHdl(&wlsHdlr);
+ if(WLS_Ready(wlsHdlr) == 0)
+ {
+ while(true)
+ {
+ 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_MEM */
+
+/*******************************************************************
*
- * @params[in] Message Type
- * Message Length
- * Messaga Pointer
+ * @brief Send FAPI messages to Intel PHY/Phy stub
*
- * @return void
+ * @details
*
-******************************************************************/
-
-PUBLIC S16 sendToPhy(U16 msgType, U32 msgLen, void *msg)
+ * 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)
{
-#if 0
- S8 ret;
- void *pMsg;
+ uint8_t ret = ROK;
+#ifdef INTEL_FAPI
+ uint16_t msgLen =0;
+ p_fapi_api_queue_elem_t currMsg = NULLP;
- pMsg = (void *)WLS_VA2PA(mtGetWlsHdl(), msg);
- ret = WLS_put(mtGetWlsHdl(), (PTR)pMsg, msgLen, msgType, 0);
+#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");
- RETVALUE(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;
}
#endif
- processRequest(msgType, msgLen, msg);
+
+#ifdef INTEL_WLS_MEM
+ void * wlsHdlr = NULLP;
+
+ mtGetWlsHdl(&wlsHdlr);
+ if(msg)
+ {
+ 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
+ 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 ret;
}
/**********************************************************************
- End of file
-**********************************************************************/
+ End of file
+ **********************************************************************/
Code Review / o-du / l2.git / blobdiff