--- /dev/null
+/******************************************************************************
+*
+* 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_config_loader.h"
+#include "nr5g_fapi_dpdk.h"
+#include "sched.h"
+
+#define NR5G_FAPI_MAX_SHMSIZE (2126512128)
+char *fgets_s(
+ char *string,
+ size_t len,
+ FILE * fp);
+
+p_nr5g_fapi_cfg_t nr5g_fapi_config_loader(
+ char *prgname,
+ const char *cfg_fname)
+{
+ struct rte_cfgfile *cfg_file;
+ p_nr5g_fapi_cfg_t cfg;
+ const char *entry;
+ size_t dev_name_len;
+ unsigned int num_cpus = 0;
+ char check_core_count[255], *max_core;
+ FILE *fp = NULL;
+
+ if (cfg_fname == NULL) {
+ printf("Error: Configuration filename was not passed.");
+ return NULL;
+ }
+
+ cfg_file = rte_cfgfile_load(cfg_fname, 0);
+ if (cfg_file == NULL) {
+ printf("Error: Cofiguration file loading failed.");
+ return NULL;
+ }
+
+ cfg = (p_nr5g_fapi_cfg_t) calloc(1, sizeof(nr5g_fapi_cfg_t));
+ if (!cfg) {
+ printf("Error: not enough memory in the system");
+ return NULL;
+ }
+ cfg->prgname = prgname;
+ fp = popen("cat /proc/cpuinfo | grep processor | wc -l", "r");
+ if (NULL == fp) {
+ printf("Error: In getting maximum number of lcores in the system.");
+ free(cfg);
+ return NULL;
+ }
+ max_core = fgets_s(check_core_count, 255, fp);
+ if (NULL == max_core) {
+ printf("Error: In getting maximum number of lcores in the system.");
+ free(cfg);
+ pclose(fp);
+ return NULL;
+ }
+ num_cpus = atoi(max_core);
+ entry = rte_cfgfile_get_entry(cfg_file, "MAC2PHY_WORKER", "core_id");
+ if (entry) {
+ cfg->mac2phy_worker.core_id = (uint8_t) atoi(entry);
+ if (cfg->mac2phy_worker.core_id >= (uint8_t) num_cpus) {
+ printf("Core Id is not in the range 0 to %d: configured: %d\n",
+ num_cpus, cfg->mac2phy_worker.core_id);
+ exit(-1);
+ }
+ }
+
+ entry =
+ rte_cfgfile_get_entry(cfg_file, "MAC2PHY_WORKER", "thread_sched_policy");
+ if (entry) {
+ cfg->mac2phy_worker.thread_sched_policy = (uint8_t) atoi(entry);
+ if (cfg->mac2phy_worker.thread_sched_policy != SCHED_FIFO &&
+ cfg->mac2phy_worker.thread_sched_policy != SCHED_RR) {
+ printf("Thread Poicy valid range is Schedule Policy [0: SCHED_FIFO"
+ " 1: SCHED_RR]: configured: %d\n",
+ cfg->mac2phy_worker.thread_sched_policy);
+ exit(-1);
+ }
+ }
+
+ int min_prio =
+ sched_get_priority_min(cfg->mac2phy_worker.thread_sched_policy);
+ int max_prio =
+ sched_get_priority_max(cfg->mac2phy_worker.thread_sched_policy);
+ entry =
+ rte_cfgfile_get_entry(cfg_file, "MAC2PHY_WORKER", "thread_priority");
+ if (entry) {
+ cfg->mac2phy_worker.thread_priority = (uint8_t) atoi(entry);
+ if (cfg->mac2phy_worker.thread_priority < min_prio &&
+ cfg->mac2phy_worker.thread_priority > max_prio) {
+ printf("Thread priority valid range is %d to %d: configured: %d\n",
+ min_prio, max_prio, cfg->mac2phy_worker.thread_priority);
+ exit(-1);
+ }
+ }
+
+ entry = rte_cfgfile_get_entry(cfg_file, "PHY2MAC_WORKER", "core_id");
+ if (entry) {
+ cfg->phy2mac_worker.core_id = (uint8_t) atoi(entry);
+ if (cfg->phy2mac_worker.core_id >= (uint8_t) num_cpus) {
+ printf("Core Id is not in the range 0 to %d configured: %d\n",
+ num_cpus, cfg->phy2mac_worker.core_id);
+ exit(-1);
+ }
+ }
+
+ entry =
+ rte_cfgfile_get_entry(cfg_file, "PHY2MAC_WORKER", "thread_sched_policy");
+ if (entry) {
+ cfg->phy2mac_worker.thread_sched_policy = (uint8_t) atoi(entry);
+ if (cfg->phy2mac_worker.thread_sched_policy != SCHED_FIFO &&
+ cfg->phy2mac_worker.thread_sched_policy != SCHED_RR) {
+ printf("Thread Poicy valid range is Schedule Policy [0: SCHED_FIFO"
+ " 1: SCHED_RR] configured: %d\n",
+ cfg->phy2mac_worker.thread_sched_policy);
+ exit(-1);
+ }
+ }
+
+ entry =
+ rte_cfgfile_get_entry(cfg_file, "PHY2MAC_WORKER", "thread_priority");
+ if (entry) {
+ cfg->phy2mac_worker.thread_priority = (uint8_t) atoi(entry);
+ if (cfg->phy2mac_worker.thread_priority < min_prio &&
+ cfg->phy2mac_worker.thread_priority > max_prio) {
+ printf("Thread priority valid range is %d to %d configured: %d\n",
+ min_prio, max_prio, cfg->phy2mac_worker.thread_priority);
+ exit(-1);
+ }
+ }
+
+ entry = rte_cfgfile_get_entry(cfg_file, "WLS_CFG", "device_name");
+ if (entry) {
+ dev_name_len = (strlen(entry) > (NR5G_FAPI_DEVICE_NAME_LEN)) ?
+ (NR5G_FAPI_DEVICE_NAME_LEN) : strlen(entry);
+ rte_strlcpy(cfg->wls.device_name, entry, dev_name_len + 1);
+ }
+
+ entry = rte_cfgfile_get_entry(cfg_file, "WLS_CFG", "shmem_size");
+ if (entry) {
+ cfg->wls.shmem_size = (uint64_t) atoll(entry);
+ if (cfg->wls.shmem_size > NR5G_FAPI_MAX_SHMSIZE) {
+ printf("The memory range cannot exceed %d", NR5G_FAPI_MAX_SHMSIZE);
+ exit(-1);
+ }
+ }
+
+ entry = rte_cfgfile_get_entry(cfg_file, "LOGGER", "level");
+ if (entry) {
+ if (!strcmp(entry, "info"))
+ cfg->logger.level = INFO_LOG;
+ else if (!strcmp(entry, "debug"))
+ cfg->logger.level = DEBUG_LOG;
+ else if (!strcmp(entry, "error"))
+ cfg->logger.level = ERROR_LOG;
+ else if (!strcmp(entry, "trace"))
+ cfg->logger.level = TRACE_LOG;
+ else if (!strcmp(entry, "hexdump"))
+ cfg->logger.level = HEXDUMP_LOG;
+ else
+ cfg->logger.level = NONE_LOG;
+ }
+
+ pclose(fp);
+
+ return cfg;
+}
+
+char *fgets_s(
+ char *string,
+ size_t len,
+ FILE * fp)
+{
+ if (fgets(string, len, fp) != 0) {
+ string[strcspn(string, "\n")] = '\0';
+ return string;
+ }
+ return 0;
+}
Code Review / o-du / phy.git / blobdiff