FAPI TM, WLS_LIB and ODULOW documentation

[o-du/phy.git] / fapi_5g / source / framework / workers / nr5g_fapi_phy2mac_thread.c

diff --git a/fapi_5g/source/framework/workers/nr5g_fapi_phy2mac_thread.c b/fapi_5g/source/framework/workers/nr5g_fapi_phy2mac_thread.c
new file mode 100644 (file)
index 0000000..0cf650b
--- /dev/null
+++ b/fapi_5g/source/framework/workers/nr5g_fapi_phy2mac_thread.c
@@ -0,0 +1,198 @@
+/******************************************************************************
+*
+*   Copyright (c) 2019 Intel.
+*
+*   Licensed under the Apache License, Version 2.0 (the "License");
+*   you may not use this file except in compliance with the License.
+*   You may obtain a copy of the License at
+*
+*       http://www.apache.org/licenses/LICENSE-2.0
+*
+*   Unless required by applicable law or agreed to in writing, software
+*   distributed under the License is distributed on an "AS IS" BASIS,
+*   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+*   See the License for the specific language governing permissions and
+*   limitations under the License.
+*
+*******************************************************************************/
+#include "nr5g_fapi_framework.h"
+#include "nr5g_fapi_fapi2phy_wls.h"
+#include "nr5g_fapi_phy2mac_thread.h"
+#include "nr5g_fapi_fapi2mac_api.h"
+#include "nr5g_fapi_fapi2mac_p5_proc.h"
+#include "nr5g_fapi_fapi2mac_p7_proc.h"
+
+//------------------------------------------------------------------------------
+/** @ingroup nr5g_fapi_source_framework_workers_phy2mac_group
+ *
+ *  @param[in,out]   void
+ *
+ *  @return none
+ *
+ *  @description
+ *  DOXYGEN_TO_DO
+ *
+**/
+//------------------------------------------------------------------------------
+void *nr5g_fapi_phy2mac_thread_func(
+    void *config)
+{
+    cpu_set_t cpuset;
+    pthread_t thread;
+    PMAC2PHY_QUEUE_EL p_msg_list = NULL;
+    p_nr5g_fapi_phy_ctx_t p_phy_ctx = (p_nr5g_fapi_phy_ctx_t) config;
+
+    NR5G_FAPI_LOG(INFO_LOG, ("[PHY2MAC] Thread %s launched LWP:%ld on "
+            "Core: %d\n", __func__, pthread_self(),
+            p_phy_ctx->phy2mac_worker_core_id));
+
+    thread = p_phy_ctx->phy2mac_tid = pthread_self();
+    CPU_ZERO(&cpuset);
+    CPU_SET(p_phy_ctx->phy2mac_worker_core_id, &cpuset);
+    pthread_setaffinity_np(thread, sizeof(cpu_set_t), &cpuset);
+
+    usleep(1000);
+    while (!p_phy_ctx->process_exit) {
+        p_msg_list = nr5g_fapi_fapi2phy_wls_recv();
+        if (p_msg_list)
+            nr5g_fapi_phy2mac_api_recv_handler(config, p_msg_list);
+
+        nr5g_fapi_fapi2mac_send_api_list();
+    }
+    pthread_exit(NULL);
+}
+
+//------------------------------------------------------------------------------
+/** @ingroup nr5g_fapi_source_framework_workers_mac2phy_group
+ *
+ *  @param[in,out]   void
+ *
+ *  @return none
+ *
+ *  @description
+ *  DOXYGEN_TO_DO
+ *
+**/
+//------------------------------------------------------------------------------
+void nr5g_fapi_phy2mac_api_recv_handler(
+    void *config,
+    PMAC2PHY_QUEUE_EL p_msg_list)
+{
+    PMAC2PHY_QUEUE_EL p_curr_msg;
+    PL1L2MessageHdr p_msg_header = NULL;
+
+    NR5G_FAPI_LOG(TRACE_LOG, ("[PHY2MAC] %s:", __func__));
+
+    nr5g_fapi_message_header((p_nr5g_fapi_phy_ctx_t) config);
+
+    p_curr_msg = (PMAC2PHY_QUEUE_EL) p_msg_list;
+    while (p_curr_msg) {
+        p_msg_header = (PL1L2MessageHdr) (p_curr_msg + 1);
+        switch (p_msg_header->nMessageType) {
+                /*  P5 Vendor Message Processing */
+#ifdef DEBUG_MODE
+            case MSG_TYPE_PHY_DL_IQ_SAMPLES:
+                {
+                    nr5g_fapi_dl_iq_samples_response((p_nr5g_fapi_phy_ctx_t)
+                        config, (PADD_REMOVE_BBU_CORES) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_UL_IQ_SAMPLES:
+                {
+                    nr5g_fapi_ul_iq_samples_response((p_nr5g_fapi_phy_ctx_t)
+                        config, (PADD_REMOVE_BBU_CORES) p_msg_header);
+                }
+                break;
+#endif
+            case MSG_TYPE_PHY_SHUTDOWN_RESP:
+                {
+                    nr5g_fapi_shutdown_response((p_nr5g_fapi_phy_ctx_t) config,
+                        (PSHUTDOWNRESPONSEStruct) p_msg_header);
+                }
+                break;
+
+                /*  P5 Message Processing */
+            case MSG_TYPE_PHY_CONFIG_RESP:
+                {
+                    nr5g_fapi_config_response((p_nr5g_fapi_phy_ctx_t) config,
+                        (PCONFIGRESPONSEStruct) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_START_RESP:
+                {
+                    nr5g_fapi_start_resp((p_nr5g_fapi_phy_ctx_t) config,
+                        (PSTARTRESPONSEStruct) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_STOP_RESP:
+                {
+                    nr5g_fapi_stop_indication((p_nr5g_fapi_phy_ctx_t) config,
+                        (PSTOPRESPONSEStruct) p_msg_header);
+                }
+                break;
+
+                /*  P7 Message Processing */
+            case MSG_TYPE_PHY_RX_ULSCH_IND:
+                {
+                    nr5g_fapi_rx_data_indication((p_nr5g_fapi_phy_ctx_t) config,
+                        (PRXULSCHIndicationStruct) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_RX_ULSCH_UCI_IND:
+                {
+                    //Not Supported
+                }
+                break;
+
+            case MSG_TYPE_PHY_CRC_IND:
+                {
+                    nr5g_fapi_crc_indication((p_nr5g_fapi_phy_ctx_t) config,
+                        (PCRCIndicationStruct) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_UCI_IND:
+                {
+                    nr5g_fapi_uci_indication((p_nr5g_fapi_phy_ctx_t) config,
+                        (PRXUCIIndicationStruct) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_RX_RACH_IND:
+                {
+                    nr5g_fapi_rach_indication((p_nr5g_fapi_phy_ctx_t) config,
+                        (PRXRACHIndicationStruct) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_RX_SRS_IND:
+                {
+                    nr5g_fapi_srs_indication((p_nr5g_fapi_phy_ctx_t) config,
+                        (PRXSRSIndicationStruct) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_SLOT_IND:
+                {
+                    nr5g_fapi_slot_indication((p_nr5g_fapi_phy_ctx_t) config,
+                        (PSlotIndicationStruct) p_msg_header);
+                }
+                break;
+
+            case MSG_TYPE_PHY_ERR_IND:
+                {
+                }
+                break;
+
+            default:
+                printf("%s: Unknown Message type: %x\n", __func__,
+                    p_msg_header->nMessageType);
+                break;
+        }
+        p_curr_msg = p_curr_msg->pNext;
+    }
+}