X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?p=o-du%2Fphy.git;a=blobdiff_plain;f=fapi_5g%2Fsource%2Fframework%2Fworkers%2Fnr5g_fapi_phy2mac_thread.c;fp=fapi_5g%2Fsource%2Fframework%2Fworkers%2Fnr5g_fapi_phy2mac_thread.c;h=0cf650b317161db0b1da247cd7b14d64981e28e5;hp=0000000000000000000000000000000000000000;hb=9d66fca5c45c8b3e0d6eab6d51a90c8e9d2614dc;hpb=2fbf70096f64af622da983e88c5a64e90ad9bdbd 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 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; + } +}