1 /******************************************************************************
3 * Copyright (c) 2020 Intel.
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
17 *******************************************************************************/
20 * @brief Main module of sample application. Demonstration of usage of xRAN library for ORAN
24 * @author Intel Corporation
30 #include <immintrin.h>
31 #include <sys/syscall.h>
32 #include <sys/sysinfo.h>
50 #include "xran_mlog_lnx.h"
52 #include "xran_fh_o_du.h"
53 #include "xran_sync_api.h"
54 #include "xran_mlog_task_id.h"
55 #include "app_io_fh_xran.h"
56 #include "app_profile_xran.h"
57 #include "xran_ecpri_owd_measurements.h"
59 #define MAX_BBU_POOL_CORE_MASK (4)
61 #define NS_PER_SEC 1E9
63 #define MAIN_PRIORITY 98
64 #define CPU_HZ ticks_per_usec /* us */
66 struct sample_app_params {
71 char vf_pcie_addr[XRAN_PORTS_NUM][XRAN_VF_MAX][32];
74 struct app_sym_cb_ctx {
76 struct xran_sense_of_time sense_of_time;
79 static enum app_state state;
80 static uint64_t ticks_per_usec;
81 static volatile uint64_t timer_last_irq_tick = 0;
82 static uint64_t tsc_resolution_hz = 0;
84 UsecaseConfig* p_usecaseConfiguration = {NULL};
85 RuntimeConfig* p_startupConfiguration[XRAN_PORTS_NUM] = {NULL,NULL,NULL,NULL};
87 struct app_sym_cb_ctx cb_sym_ctx[XRAN_CB_SYM_MAX];
89 long old_rx_counter[XRAN_PORTS_NUM] = {0,0,0,0};
90 long old_tx_counter[XRAN_PORTS_NUM] = {0,0,0,0};
95 puts("+---------------------------------------+");
96 puts("| Press 1 to start 5G NR XRAN traffic |");
97 puts("| Press 2 reserved for future use |");
98 puts("| Press 3 to quit |");
99 puts("+---------------------------------------+");
103 app_timer_get_ticks(void)
116 __asm volatile("rdtsc" :
120 ret = ((uint64_t)tsc.tsc_64);
124 //-------------------------------------------------------------------------------------------
129 * @return 0 if SUCCESS
132 * This function gets the clock speed of the core and figures out number of ticks per usec.
133 * It is used by l1app and testmac applications to initialize the mlog utility
136 //-------------------------------------------------------------------------------------------
138 app_timer_set_tsc_freq_from_clock(void)
140 struct timespec sleeptime = {.tv_nsec = 5E8 }; /* 1/2 second */
141 struct timespec t_start, t_end;
142 uint64_t tsc_resolution_hz = 0;
144 if (clock_gettime(CLOCK_MONOTONIC_RAW, &t_start) == 0) {
145 unsigned long ns, end, start = app_timer_get_ticks();
146 nanosleep(&sleeptime,NULL);
147 clock_gettime(CLOCK_MONOTONIC_RAW, &t_end);
148 end = app_timer_get_ticks();
149 ns = ((t_end.tv_sec - t_start.tv_sec) * NS_PER_SEC);
150 ns += (t_end.tv_nsec - t_start.tv_nsec);
152 double secs = (double)ns/NS_PER_SEC;
153 tsc_resolution_hz = (unsigned long)((end - start)/secs);
155 ticks_per_usec = (tsc_resolution_hz / 1000000);
156 printf("System clock (rdtsc) resolution %lu [Hz]\n", tsc_resolution_hz);
157 printf("Ticks per us %lu\n", ticks_per_usec);
165 app_version_print(void)
167 char sysversion[100];
168 char *compilation_date = __DATE__;
169 char *compilation_time = __TIME__;
173 snprintf(sysversion, 99, "Version: %s", VERSIONX);
174 nLen = strlen(sysversion);
177 printf("===========================================================================================================\n");
178 printf("SAMPLE-APP VERSION\n");
179 printf("===========================================================================================================\n");
181 printf("%s\n", sysversion);
182 printf("build-date: %s\n", compilation_date);
183 printf("build-time: %s\n", compilation_time);
189 char help_content[] = \
190 "sample application\n\n"\
191 "Usage: sample-app --usecasefile ./usecase_du.cfg --num_eth_vfs 12"\
192 "--vf_addr_o_xu_a \"0000:51:01.0,0000:51:01.1,0000:51:01.2,0000:51:01.3\""\
193 "--vf_addr_o_xu_b \"0000:51:01.4,0000:51:01.5,0000:51:01.6,0000:51:01.7\""\
194 "--vf_addr_o_xu_c \"0000:51:02.0,0000:51:02.1,0000:51:02.2,0000:51:02.3\"\n\n"\
195 "or sample-app --usecasefile ./usecase_du.cfg --num_eth_vfs 2"\
196 "--vf_addr_o_xu_a \"0000:51:01.0,0000:51:01.1\""\
197 "supports the following options:\n\n"\
198 "-p | --num_eth_pfs <number of ETH ports to connect to O-RU|O-DU> 2 - default\n"
199 "-a | --vf_addr_o_xu_a <list of PCIe Bus Address separated by comma for VFs of O-xU0 >"
200 "-b | --vf_addr_o_xu_b <list of PCIe Bus Address separated by comma for VFs of O-xU1 >"
201 "-c | --vf_addr_o_xu_c <list of PCIe Bus Address separated by comma for VFs of O-xU2 >"
202 "-d | --vf_addr_o_xu_d <list of PCIe Bus Address separated by comma for VFs of O-xU3 >"
203 "-u | --usecasefile <name of use case file for multiple O-DU|O-RUs>\n"\
204 "-h | --help print usage\n";
206 printf("%s", help_content);
210 *******************************************************************************
213 * @brief is used to parse incoming app args
216 * The routine is parse input args and convert them into app startup params
222 ******************************************************************************/
224 app_parse_cmdline_args(int argc, char ** argv, struct sample_app_params* params)
232 char *saveptr = NULL;
236 static struct option long_options[] = {
237 {"cfgfile", required_argument, 0, 'z'},
238 {"usecasefile", required_argument, 0, 'u'},
239 {"num_eth_vfs", required_argument, 0, 'p'},
240 {"vf_addr_o_xu_a", required_argument, 0, 'a'},
241 {"vf_addr_o_xu_b", required_argument, 0, 'b'},
242 {"vf_addr_o_xu_c", required_argument, 0, 'c'},
243 {"vf_addr_o_xu_d", required_argument, 0, 'd'},
244 {"help", no_argument, 0, 'h'},
248 memset(params, 0, sizeof (*params));
251 //int this_option_optind = optind ? optind : 1;
252 int option_index = 0;
254 c = getopt_long(argc, argv, "a:b:c:d:f:h:p:u:v", long_options, &option_index);
265 params->cfg_file = optarg;
266 optlen = strlen(optarg) + 1;
267 printf("%s:%d: %s [len %ld]\n",__FUNCTION__, __LINE__, params->cfg_file, optlen);
270 params->num_vfs = atoi(optarg);
271 printf("%s:%d: %d\n",__FUNCTION__, __LINE__, params->num_vfs);
274 params->usecase_file = optarg;
275 optlen = strlen(optarg) + 1;
276 printf("%s:%d: %s [len %ld]\n",__FUNCTION__, __LINE__, params->usecase_file, optlen);
287 optlen = strlen(optarg) + 1;
288 printf("%s:%d: port %d %s [len %ld]\n",__FUNCTION__, __LINE__, port, optarg, optlen);
289 token = strtok_r(optarg, ",", &saveptr);
290 while (token != NULL) {
291 optlen = strlen(token) + 1;
292 snprintf(¶ms->vf_pcie_addr[port][vf_cnt][0], optlen, "%s", token);
293 printf("%s:%d: port %d %s [len %ld]\n",__FUNCTION__, __LINE__, port, ¶ms->vf_pcie_addr[port][vf_cnt][0], optlen);
294 token = strtok_r(NULL, ",", &saveptr);
307 app_apply_slot_cfg(RuntimeConfig *config)
310 int32_t slot_idx = 0;
313 int32_t section_idx = 0;
314 int32_t direction = 0;
318 for (slot_idx = 0; slot_idx < config->numSlots; slot_idx++) {
319 for (direction = 0; direction < XRAN_DIR_MAX; direction++) {
320 for (cc_idx = 0; cc_idx < config->numCC; cc_idx++) {
321 for (ant_idx = 0; ant_idx < ((direction == XRAN_DIR_UL) ? config->numUlAxc :config->numAxc); ant_idx++) {
322 for (section_idx = 0; section_idx < config->p_SlotPrbMap[direction][slot_idx]->nPrbElm && section_idx < XRAN_MAX_SECTIONS_PER_SLOT; section_idx++) {
323 if (config->SlotPrbCCmask[direction][slot_idx][section_idx] & (1L << cc_idx)) {
324 if (config->SlotPrbAntCMask[direction][slot_idx][section_idx] & (1L << ant_idx)) {
325 struct xran_prb_map *pRbMap = config->p_RunSlotPrbMap[direction][slot_idx][cc_idx][ant_idx];
326 pRbMap->dir = direction;
327 pRbMap->xran_port = config->o_xu_id;
329 pRbMap->cc_id = cc_idx;
330 pRbMap->ru_port_id = ant_idx;
331 pRbMap->tti_id = slot_idx;
332 pRbMap->start_sym_id = 0;
333 if (pRbMap->nPrbElm < XRAN_MAX_SECTIONS_PER_SLOT && section_idx < XRAN_MAX_SECTIONS_PER_SLOT) {
334 struct xran_prb_elm *pMapElmRun = &pRbMap->prbMap[pRbMap->nPrbElm];
335 struct xran_prb_elm *pMapElmCfg = &config->p_SlotPrbMap[direction][slot_idx]->prbMap[section_idx];
336 memcpy(pMapElmRun, pMapElmCfg, sizeof(struct xran_prb_elm));
338 rte_panic("Incorrect slot cfg\n");
350 config->RunSlotPrbMapEnabled = enable;
351 printf("[%d]config->RunSlotPrbMapEnabled %d\n",config->o_xu_id, config->RunSlotPrbMapEnabled);
357 app_parse_all_cfgs(struct sample_app_params* p_args, UsecaseConfig* p_use_cfg, RuntimeConfig* p_o_xu_cfg)
367 memset(p_use_cfg, 0, sizeof(UsecaseConfig));
369 printf("p_use_cfg error.\n");
375 RuntimeConfig* p_o_xu_cfg_loc = p_o_xu_cfg;
376 for (i = 0; i < XRAN_PORTS_NUM; i++) {
377 config_init(p_o_xu_cfg_loc);
381 printf("p_o_xu_cfg error.\n");
386 if (p_args->usecase_file) { /* use case for multiple O-RUs */
387 printf("p_args->usecase_file (%s)\n", p_args->usecase_file);
388 len = strlen(p_args->usecase_file) + 1;
390 printf("app_parse_all_cfgs: Name of p_args->usecase_file, %s is too long. Maximum is 511 characters!!\n", p_args->usecase_file);
393 strncpy(filename, p_args->usecase_file, len);
395 if (parseUsecaseFile(filename, p_use_cfg) != 0) {
396 printf("Use case config file error.\n");
399 if (p_use_cfg->oXuNum > XRAN_PORTS_NUM) {
400 printf("Use case config file error.\n");
404 /* use cmdline pcie address */
405 for (o_xu_id = 0; o_xu_id < p_use_cfg->oXuNum && o_xu_id < XRAN_PORTS_NUM; o_xu_id++) {
406 for (vf_num = 0; vf_num < XRAN_VF_MAX && p_args->num_vfs ; vf_num++) {
407 strncpy(&p_use_cfg->o_xu_pcie_bus_addr[o_xu_id][vf_num][0], &p_args->vf_pcie_addr[o_xu_id][vf_num][0], strlen(&p_args->vf_pcie_addr[o_xu_id][vf_num][0]));
410 dir = dirname(p_args->usecase_file);
411 for (o_xu_id = 0; o_xu_id < p_use_cfg->oXuNum && o_xu_id < XRAN_PORTS_NUM; o_xu_id++) {
412 memset(filename, 0, sizeof(filename));
413 printf("dir (%s)\n",dir);
414 len = strlen(dir) + 1;
416 printf("app_parse_all_cfgs: Name of directory, %s, xu_id = %d is too long. Maximum is 511 characters!!\n", dir, o_xu_id);
419 strncpy(filename, dir, len);
421 strncat(filename, "/", 1);
423 len = (sizeof(filename)) - len;
425 if (len > strlen(p_use_cfg->o_xu_cfg_file[o_xu_id])) {
426 strncat(filename, p_use_cfg->o_xu_cfg_file[o_xu_id], RTE_MIN (len, strlen(p_use_cfg->o_xu_cfg_file[o_xu_id])));
428 printf("File name error\n");
431 printf("cfg_file (%s)\n",filename);
432 printf("\n=================== O-XU %d===================\n", o_xu_id);
433 if (parseConfigFile(filename, p_o_xu_cfg) != 0) {
434 printf("Configuration file error\n");
437 p_o_xu_cfg->o_xu_id = o_xu_id;
438 if (p_o_xu_cfg->SlotNum_fileEnabled) {
439 if (parseSlotConfigFile(dir, p_o_xu_cfg) != 0) {
440 printf("parseSlotConfigFiles\n");
443 if (app_apply_slot_cfg(p_o_xu_cfg)!= 0) {
444 printf("app_apply_slot_cfg\n");
451 printf("p_args error\n");
456 printf("p_args error\n");
464 app_setup_o_xu_buffers(UsecaseConfig* p_use_cfg, RuntimeConfig* p_o_xu_cfg, struct xran_fh_init* p_xran_fh_init)
470 struct o_xu_buffers *p_iq = NULL;
472 if (p_o_xu_cfg->p_buff) {
473 p_iq = p_o_xu_cfg->p_buff;
474 printf("IQ files size is %d slots\n", p_o_xu_cfg->numSlots);
476 p_iq->iq_playback_buffer_size_dl = (p_o_xu_cfg->numSlots * N_SYM_PER_SLOT * N_SC_PER_PRB *
477 app_xran_get_num_rbs(p_o_xu_cfg->xranTech, p_o_xu_cfg->mu_number,
478 p_o_xu_cfg->nDLBandwidth, p_o_xu_cfg->nDLAbsFrePointA) *4L);
480 p_iq->iq_playback_buffer_size_ul = (p_o_xu_cfg->numSlots * N_SYM_PER_SLOT * N_SC_PER_PRB *
481 app_xran_get_num_rbs(p_o_xu_cfg->xranTech, p_o_xu_cfg->mu_number,
482 p_o_xu_cfg->nULBandwidth, p_o_xu_cfg->nULAbsFrePointA) *4L);
485 /* 10 * [14*32*273*2*2] = 4892160 bytes */
486 p_iq->iq_bfw_buffer_size_dl = (p_o_xu_cfg->numSlots * N_SYM_PER_SLOT * p_o_xu_cfg->antElmTRx *
487 app_xran_get_num_rbs(p_o_xu_cfg->xranTech, p_o_xu_cfg->mu_number,
488 p_o_xu_cfg->nDLBandwidth, p_o_xu_cfg->nDLAbsFrePointA) *4L);
490 /* 10 * [14*32*273*2*2] = 4892160 bytes */
491 p_iq->iq_bfw_buffer_size_ul = (p_o_xu_cfg->numSlots * N_SYM_PER_SLOT *
492 app_xran_get_num_rbs(p_o_xu_cfg->xranTech, p_o_xu_cfg->mu_number,
493 p_o_xu_cfg->nULBandwidth, p_o_xu_cfg->nULAbsFrePointA) *4L);
495 /* 10 * [1*273*2*2] = 349440 bytes */
496 p_iq->iq_srs_buffer_size_ul = (p_o_xu_cfg->numSlots * N_SYM_PER_SLOT * N_SC_PER_PRB *
497 app_xran_get_num_rbs(p_o_xu_cfg->xranTech, p_o_xu_cfg->mu_number,
498 p_o_xu_cfg->nULBandwidth, p_o_xu_cfg->nULAbsFrePointA)*4L);
500 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
501 p_iq->p_tx_play_buffer[i] = (int16_t*)malloc(p_iq->iq_playback_buffer_size_dl);
502 p_iq->tx_play_buffer_size[i] = (int32_t)p_iq->iq_playback_buffer_size_dl;
504 if (p_iq->p_tx_play_buffer[i] == NULL)
507 p_iq->tx_play_buffer_size[i] = sys_load_file_to_buff(p_o_xu_cfg->ant_file[i],
508 "DL IFFT IN IQ Samples in binary format",
509 (uint8_t*)p_iq->p_tx_play_buffer[i],
510 p_iq->tx_play_buffer_size[i],
512 p_iq->tx_play_buffer_position[i] = 0;
515 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->xranCat == XRAN_CATEGORY_B) {
516 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
518 p_iq->p_tx_dl_bfw_buffer[i] = (int16_t*)malloc(p_iq->iq_bfw_buffer_size_dl);
519 p_iq->tx_dl_bfw_buffer_size[i] = (int32_t)p_iq->iq_bfw_buffer_size_dl;
521 if (p_iq->p_tx_dl_bfw_buffer[i] == NULL)
524 p_iq->tx_dl_bfw_buffer_size[i] = sys_load_file_to_buff(p_o_xu_cfg->dl_bfw_file[i],
525 "DL BF weights IQ Samples in binary format",
526 (uint8_t*) p_iq->p_tx_dl_bfw_buffer[i],
527 p_iq->tx_dl_bfw_buffer_size[i],
529 p_iq->tx_dl_bfw_buffer_position[i] = 0;
533 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->xranCat == XRAN_CATEGORY_B) {
535 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
536 p_iq->p_tx_ul_bfw_buffer[i] = (int16_t*)malloc(p_iq->iq_bfw_buffer_size_ul);
537 p_iq->tx_ul_bfw_buffer_size[i] = (int32_t)p_iq->iq_bfw_buffer_size_ul;
539 if (p_iq->p_tx_ul_bfw_buffer[i] == NULL)
542 p_iq->tx_ul_bfw_buffer_size[i] = sys_load_file_to_buff(p_o_xu_cfg->ul_bfw_file[i],
543 "UL BF weights IQ Samples in binary format",
544 (uint8_t*) p_iq->p_tx_ul_bfw_buffer[i],
545 p_iq->tx_ul_bfw_buffer_size[i],
547 p_iq->tx_ul_bfw_buffer_position[i] = 0;
551 if (p_o_xu_cfg->appMode == APP_O_RU && p_o_xu_cfg->enablePrach) {
552 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
553 p_iq->p_tx_prach_play_buffer[i] = (int16_t*)malloc(PRACH_PLAYBACK_BUFFER_BYTES);
554 p_iq->tx_prach_play_buffer_size[i] = (int32_t)PRACH_PLAYBACK_BUFFER_BYTES;
556 if (p_iq->p_tx_prach_play_buffer[i] == NULL)
559 memset(p_iq->p_tx_prach_play_buffer[i], 0, PRACH_PLAYBACK_BUFFER_BYTES);
561 p_iq->tx_prach_play_buffer_size[i] = sys_load_file_to_buff(p_o_xu_cfg->prach_file[i],
562 "PRACH IQ Samples in binary format",
563 (uint8_t*) p_iq->p_tx_prach_play_buffer[i],
564 p_iq->tx_prach_play_buffer_size[i],
566 p_iq->tx_prach_play_buffer_position[i] = 0;
570 if (p_o_xu_cfg->appMode == APP_O_RU && p_o_xu_cfg->enableSrs) {
572 i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->antElmTRx);
575 p_iq->p_tx_srs_play_buffer[i] = (int16_t*)malloc(p_iq->iq_srs_buffer_size_ul);
576 p_iq->tx_srs_play_buffer_size[i] = (int32_t)p_iq->iq_srs_buffer_size_ul;
578 if (p_iq->p_tx_srs_play_buffer[i] == NULL)
581 memset(p_iq->p_tx_srs_play_buffer[i], 0, p_iq->iq_srs_buffer_size_ul);
582 p_iq->tx_srs_play_buffer_size[i] = sys_load_file_to_buff(p_o_xu_cfg->ul_srs_file[i],
583 "SRS IQ Samples in binary format",
584 (uint8_t*) p_iq->p_tx_srs_play_buffer[i],
585 p_iq->tx_srs_play_buffer_size[i],
588 p_iq->tx_srs_play_buffer_position[i] = 0;
593 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
595 p_iq->p_rx_log_buffer[i] = (int16_t*)malloc(p_iq->iq_playback_buffer_size_ul);
596 p_iq->rx_log_buffer_size[i] = (int32_t)p_iq->iq_playback_buffer_size_ul;
598 if (p_iq->p_rx_log_buffer[i] == NULL)
601 p_iq->rx_log_buffer_position[i] = 0;
603 memset(p_iq->p_rx_log_buffer[i], 0, p_iq->rx_log_buffer_size[i]);
607 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
609 p_iq->p_prach_log_buffer[i] = (int16_t*)malloc(p_o_xu_cfg->numSlots*XRAN_NUM_OF_SYMBOL_PER_SLOT*PRACH_PLAYBACK_BUFFER_BYTES);
610 p_iq->prach_log_buffer_size[i] = (int32_t)p_o_xu_cfg->numSlots*XRAN_NUM_OF_SYMBOL_PER_SLOT*PRACH_PLAYBACK_BUFFER_BYTES;
612 if (p_iq->p_prach_log_buffer[i] == NULL)
615 memset(p_iq->p_prach_log_buffer[i], 0, p_iq->prach_log_buffer_size[i]);
616 p_iq->prach_log_buffer_position[i] = 0;
620 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->enableSrs) {
622 i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->antElmTRx);
625 p_iq->p_srs_log_buffer[i] = (int16_t*)malloc(p_iq->iq_srs_buffer_size_ul);
626 p_iq->srs_log_buffer_size[i] = (int32_t)p_iq->iq_srs_buffer_size_ul;
628 if (p_iq->p_srs_log_buffer[i] == NULL)
631 memset(p_iq->p_srs_log_buffer[i], 0, p_iq->iq_srs_buffer_size_ul);
632 p_iq->srs_log_buffer_position[i] = 0;
636 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
638 snprintf(filename, sizeof(filename), "./logs/%s%d-play_ant%d.txt",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
639 sys_save_buf_to_file_txt(filename,
640 "DL IFFT IN IQ Samples in human readable format",
641 (uint8_t*) p_iq->p_tx_play_buffer[i],
642 p_iq->tx_play_buffer_size[i],
645 snprintf(filename, sizeof(filename),"./logs/%s%d-play_ant%d.bin",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
646 sys_save_buf_to_file(filename,
647 "DL IFFT IN IQ Samples in binary format",
648 (uint8_t*) p_iq->p_tx_play_buffer[i],
649 p_iq->tx_play_buffer_size[i]/sizeof(short),
653 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->xranCat == XRAN_CATEGORY_B) {
654 snprintf(filename, sizeof(filename),"./logs/%s%d-dl_bfw_ue%d.txt",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
655 sys_save_buf_to_file_txt(filename,
656 "DL Beamformig weights IQ Samples in human readable format",
657 (uint8_t*) p_iq->p_tx_dl_bfw_buffer[i],
658 p_iq->tx_dl_bfw_buffer_size[i],
661 snprintf(filename, sizeof(filename),"./logs/%s%d-dl_bfw_ue%d.bin",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"),p_o_xu_cfg->o_xu_id, i);
662 sys_save_buf_to_file(filename,
663 "DL Beamformig weightsIQ Samples in binary format",
664 (uint8_t*) p_iq->p_tx_dl_bfw_buffer[i],
665 p_iq->tx_dl_bfw_buffer_size[i]/sizeof(short),
669 snprintf(filename, sizeof(filename), "./logs/%s%d-ul_bfw_ue%d.txt",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
670 sys_save_buf_to_file_txt(filename,
671 "UL Beamformig weights IQ Samples in human readable format",
672 (uint8_t*) p_iq->p_tx_ul_bfw_buffer[i],
673 p_iq->tx_ul_bfw_buffer_size[i],
676 snprintf(filename, sizeof(filename),"./logs/%s%d-ul_bfw_ue%d.bin",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
677 sys_save_buf_to_file(filename,
678 "UL Beamformig weightsIQ Samples in binary format",
679 (uint8_t*) p_iq->p_tx_ul_bfw_buffer[i],
680 p_iq->tx_ul_bfw_buffer_size[i]/sizeof(short),
686 if (p_o_xu_cfg->appMode == APP_O_RU && p_o_xu_cfg->enableSrs && p_o_xu_cfg->xranCat == XRAN_CATEGORY_B) {
688 i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->antElmTRx);
691 snprintf(filename, sizeof(filename), "./logs/%s%d-play_srs_ant%d.txt",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
692 sys_save_buf_to_file_txt(filename,
693 "SRS IQ Samples in human readable format",
694 (uint8_t*)p_iq->p_tx_srs_play_buffer[i],
695 p_iq->tx_srs_play_buffer_size[i],
698 snprintf(filename,sizeof(filename), "./logs/%s%d-play_srs_ant%d.bin",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
699 sys_save_buf_to_file(filename,
700 "SRS IQ Samples in binary format",
701 (uint8_t*) p_iq->p_tx_srs_play_buffer[i],
702 p_iq->tx_srs_play_buffer_size[i]/sizeof(short),
707 if (p_o_xu_cfg->iqswap == 1) {
708 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
709 printf("TX: Swap I and Q to match RU format: [%d]\n",i);
713 signed short *ptr = (signed short *) p_iq->p_tx_play_buffer[i];
716 for (j = 0; j < (int32_t)(p_iq->tx_play_buffer_size[i]/sizeof(short)) ; j = j + 2) {
722 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->xranCat == XRAN_CATEGORY_B) {
723 printf("DL BFW: Swap I and Q to match RU format: [%d]\n",i);
727 signed short *ptr = (signed short *) p_iq->p_tx_dl_bfw_buffer[i];
730 for (j = 0; j < (int32_t)(p_iq->tx_dl_bfw_buffer_size[i]/sizeof(short)) ; j = j + 2) {
736 printf("UL BFW: Swap I and Q to match RU format: [%d]\n",i);
740 signed short *ptr = (signed short *) p_iq->p_tx_ul_bfw_buffer[i];
743 for (j = 0; j < (int32_t)(p_iq->tx_ul_bfw_buffer_size[i]/sizeof(short)) ; j = j + 2) {
752 if (p_o_xu_cfg->appMode == APP_O_RU) {
753 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
754 printf("PRACH: Swap I and Q to match RU format: [%d]\n",i);
758 signed short *ptr = (signed short *) p_iq-> p_tx_prach_play_buffer[i];
761 for (j = 0; j < (int32_t)(p_iq->tx_prach_play_buffer_size[i]/sizeof(short)) ; j = j + 2) {
770 if (p_o_xu_cfg->appMode == APP_O_RU) {
772 i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->antElmTRx);
774 printf("SRS: Swap I and Q to match RU format: [%d]\n",i);
778 signed short *ptr = (signed short *) p_iq->p_tx_srs_play_buffer[i];
781 for (j = 0; j < (int32_t)(p_iq->tx_srs_play_buffer_size[i]/sizeof(short)) ; j = j + 2) {
792 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
794 sprintf(filename, "./logs/swap_IQ_play_ant%d.txt", i);
795 sys_save_buf_to_file_txt(filename,
796 "DL IFFT IN IQ Samples in human readable format",
797 (uint8_t*) p_iq->p_tx_play_buffer[i],
798 p_iq->tx_play_buffer_size[i],
802 if (p_o_xu_cfg->nebyteorderswap == 1 && p_o_xu_cfg->compression == 0) {
803 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
804 printf("TX: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);
805 for (j = 0; j < p_iq->tx_play_buffer_size[i]/sizeof(short); j++) {
806 p_iq->p_tx_play_buffer[i][j] = rte_cpu_to_be_16(p_iq->p_tx_play_buffer[i][j]);
809 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->xranCat == XRAN_CATEGORY_B) {
810 printf("DL BFW: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);
811 for (j = 0; j < p_iq->tx_dl_bfw_buffer_size[i]/sizeof(short); j++) {
812 p_iq->p_tx_dl_bfw_buffer[i][j] = rte_cpu_to_be_16(p_iq->p_tx_dl_bfw_buffer[i][j]);
814 printf("UL BFW: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);
815 for (j = 0; j < p_iq->tx_ul_bfw_buffer_size[i]/sizeof(short); j++) {
816 p_iq->p_tx_ul_bfw_buffer[i][j] = rte_cpu_to_be_16(p_iq->p_tx_ul_bfw_buffer[i][j]);
821 if (p_o_xu_cfg->appMode == APP_O_RU && p_o_xu_cfg->enablePrach) {
822 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
823 printf("PRACH: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);
824 for (j = 0; j < p_iq->tx_prach_play_buffer_size[i]/sizeof(short); j++) {
825 p_iq->p_tx_prach_play_buffer[i][j] = rte_cpu_to_be_16(p_iq->p_tx_prach_play_buffer[i][j]);
830 if (p_o_xu_cfg->appMode == APP_O_RU && p_o_xu_cfg->enableSrs) {
832 i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->antElmTRx);
834 printf("SRS: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);
835 for (j = 0; j < p_iq->tx_srs_play_buffer_size[i]/sizeof(short); j++) {
836 p_iq->p_tx_srs_play_buffer[i][j] = rte_cpu_to_be_16(p_iq->p_tx_srs_play_buffer[i][j]);
844 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
846 sprintf(filename, "./logs/swap_be_play_ant%d.txt", i);
847 sys_save_buf_to_file_txt(filename,
848 "DL IFFT IN IQ Samples in human readable format",
849 (uint8_t*) p_iq->p_tx_play_buffer[i],
850 p_iq->tx_play_buffer_size[i],
860 app_dump_o_xu_buffers(UsecaseConfig* p_use_cfg, RuntimeConfig* p_o_xu_cfg)
866 struct o_xu_buffers* p_iq = NULL;
868 if (p_o_xu_cfg->p_buff) {
869 p_iq = p_o_xu_cfg->p_buff;
871 printf("Error p_o_xu_cfg->p_buff\n");
875 if (p_o_xu_cfg->iqswap == 1) {
876 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
877 printf("RX: Swap I and Q to match CPU format: [%d]\n",i);
881 signed short *ptr = (signed short *) p_iq->p_rx_log_buffer[i];
884 for (j = 0; j < (int32_t)(p_iq->rx_log_buffer_size[i]/sizeof(short)) ; j = j + 2) {
892 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->enableSrs) {
894 i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->antElmTRx);
896 printf("SRS: Swap I and Q to match CPU format: [%d]\n",i);
900 signed short *ptr = (signed short *) p_iq->p_srs_log_buffer[i];
903 for (j = 0; j < (int32_t)(p_iq->srs_log_buffer_size[i]/sizeof(short)) ; j = j + 2) {
913 if (p_o_xu_cfg->nebyteorderswap == 1 && p_o_xu_cfg->compression == 0) {
915 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
916 printf("RX: Convert S16 I and S16 Q to cpu byte order from XRAN Ant: [%d]\n",i);
917 for (j = 0; j < p_iq->rx_log_buffer_size[i]/sizeof(short); j++) {
918 p_iq->p_rx_log_buffer[i][j] = rte_be_to_cpu_16(p_iq->p_rx_log_buffer[i][j]);
922 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->enableSrs) {
924 i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->antElmTRx);
926 printf("SRS: Convert S16 I and S16 Q to cpu byte order from XRAN Ant: [%d]\n",i);
927 for (j = 0; j < p_iq->srs_log_buffer_size[i]/sizeof(short); j++) {
928 p_iq->p_srs_log_buffer[i][j] = rte_be_to_cpu_16(p_iq->p_srs_log_buffer[i][j]);
934 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
936 snprintf(filename, sizeof(filename), "./logs/%s%d-rx_log_ant%d.txt",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
937 sys_save_buf_to_file_txt(filename,
938 "UL FFT OUT IQ Samples in human readable format",
939 (uint8_t*) p_iq->p_rx_log_buffer[i],
940 p_iq->rx_log_buffer_size[i],
943 snprintf(filename, sizeof(filename), "./logs/%s%d-rx_log_ant%d.bin",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
944 sys_save_buf_to_file(filename,
945 "UL FFT OUT IQ Samples in binary format",
946 (uint8_t*) p_iq->p_rx_log_buffer[i],
947 p_iq->rx_log_buffer_size[i]/sizeof(short),
951 if (p_o_xu_cfg->appMode == APP_O_DU && p_o_xu_cfg->enableSrs) {
953 i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->antElmTRx);
955 snprintf(filename, sizeof(filename), "./logs/%s%d-srs_log_ant%d.txt",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
956 sys_save_buf_to_file_txt(filename,
957 "SRS UL FFT OUT IQ Samples in human readable format",
958 (uint8_t*)p_iq-> p_srs_log_buffer[i],
959 p_iq->srs_log_buffer_size[i],
962 snprintf(filename, sizeof(filename), "./logs/%s%d-srs_log_ant%d.bin",((p_o_xu_cfg->appMode == APP_O_DU) ? "o-du" : "o-ru"), p_o_xu_cfg->o_xu_id, i);
963 sys_save_buf_to_file(filename,
964 "SRS UL FFT OUT IQ Samples in binary format",
965 (uint8_t*) p_iq->p_srs_log_buffer[i],
966 p_iq->srs_log_buffer_size[i]/sizeof(short),
971 if (p_o_xu_cfg->enablePrach) {
972 if (p_o_xu_cfg->iqswap == 1) {
973 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
974 printf("PRACH: Swap I and Q to match CPU format: [%d]\n",i);
978 signed short *ptr = (signed short *) p_iq->p_prach_log_buffer[i];
981 for (j = 0; j < (int32_t)(p_iq->prach_log_buffer_size[i]/sizeof(short)) ; j = j + 2) {
990 if (p_o_xu_cfg->nebyteorderswap == 1 && p_o_xu_cfg->compression == 0) {
991 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
992 printf("PRACH: Convert S16 I and S16 Q to cpu byte order from XRAN Ant: [%d]\n",i);
993 for (j = 0; j < p_iq->prach_log_buffer_size[i]/sizeof(short); j++) {
994 p_iq->p_prach_log_buffer[i][j] = rte_be_to_cpu_16(p_iq->p_prach_log_buffer[i][j]);
999 for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(p_o_xu_cfg->numCC * p_o_xu_cfg->numAxc); i++) {
1001 if (p_o_xu_cfg->appMode == APP_O_DU)
1002 snprintf(filename, sizeof(filename), "./logs/%s%d%s_ant%d.txt","o-du",p_o_xu_cfg->o_xu_id,"-prach_log", i);
1004 snprintf(filename, sizeof(filename), "./logs/%s%d%s_ant%d.txt","o-ru",p_o_xu_cfg->o_xu_id,"-play_prach", i);
1005 sys_save_buf_to_file_txt(filename,
1006 "PRACH IQ Samples in human readable format",
1007 (uint8_t*) p_iq->p_prach_log_buffer[i],
1008 p_iq->prach_log_buffer_size[i],
1011 if (p_o_xu_cfg->appMode == APP_O_DU)
1012 snprintf(filename, sizeof(filename), "./logs/%s%d%s_ant%d.bin","o-du",p_o_xu_cfg->o_xu_id,"-prach_log", i);
1014 snprintf(filename, sizeof(filename), "./logs/%s%d%s_ant%d.bin","o-ru",p_o_xu_cfg->o_xu_id,"-play_prach", i);
1015 sys_save_buf_to_file(filename,
1016 "PRACH IQ Samples in binary format",
1017 (uint8_t*) p_iq->p_prach_log_buffer[i],
1018 p_iq->prach_log_buffer_size[i]/sizeof(short),
1026 app_set_main_core(UsecaseConfig* p_usecase)
1028 struct sched_param sched_param;
1031 memset(&sched_param, 0, sizeof(struct sched_param));
1032 /* set main thread affinity mask to CPU2 */
1033 sched_param.sched_priority = 99;
1036 printf("This system has %d processors configured and %d processors available.\n", get_nprocs_conf(), get_nprocs());
1038 if (p_usecase->main_core < get_nprocs_conf())
1039 CPU_SET(p_usecase->main_core, &cpuset);
1043 if (result = pthread_setaffinity_np(pthread_self(), sizeof(cpu_set_t), &cpuset))
1045 printf("pthread_setaffinity_np failed: coreId = 2, result = %d\n",result);
1047 printf("%s [CPU %2d] [PID: %6d]\n", __FUNCTION__, sched_getcpu(), getpid());
1049 if ((result = pthread_setschedparam(pthread_self(), SCHED_FIFO, &sched_param)))
1051 printf("priority is not changed: coreId = 2, result = %d\n",result);
1058 app_alloc_all_cfgs(void)
1061 RuntimeConfig* p_rt_cfg = NULL;
1064 ptr = _mm_malloc(sizeof(UsecaseConfig), 256);
1066 rte_panic("_mm_malloc: Can't allocate %lu bytes\n", sizeof(UsecaseConfig));
1069 p_usecaseConfiguration = (UsecaseConfig*)ptr;
1071 ptr = _mm_malloc(sizeof(RuntimeConfig)*XRAN_PORTS_NUM, 256);
1073 rte_panic("_mm_malloc: Can't allocate %lu bytes\n", sizeof(RuntimeConfig)*XRAN_PORTS_NUM);
1075 p_rt_cfg = (RuntimeConfig*)ptr;
1077 for (i = 0; i < XRAN_PORTS_NUM; i++) {
1078 p_startupConfiguration[i] = p_rt_cfg++;
1084 int main(int argc, char *argv[])
1088 int32_t o_xu_id = 0;
1092 struct stat st = {0};
1093 uint32_t filenameLength = strlen(argv[1]);
1094 enum xran_if_state xran_curr_if_state = XRAN_INIT;
1095 struct sample_app_params arg_params;
1097 uint64_t nTotalTime;
1099 uint32_t nCoresUsed;
1100 uint32_t nCoreUsedNum[64];
1103 app_version_print();
1104 app_timer_set_tsc_freq_from_clock();
1106 if (xran_is_synchronized() != 0)
1107 printf("Machine is not synchronized using PTP!\n");
1109 printf("Machine is synchronized using PTP!\n");
1111 if (filenameLength >= 256) {
1112 printf("Config file name input is too long, exiting!\n");
1116 if ((xret = app_alloc_all_cfgs()) < 0) {
1117 printf("app_alloc_all_cfgs failed %d\n", xret);
1121 if ((xret = app_parse_cmdline_args(argc, argv, &arg_params)) < 0) {
1122 printf("app_parse_args failed %d\n", xret);
1126 if ((xret = app_parse_all_cfgs(&arg_params, p_usecaseConfiguration, p_startupConfiguration[0])) < 0) {
1127 printf("app_parse_all_cfgs failed %d\n", xret);
1131 if ((xret = app_set_main_core(p_usecaseConfiguration)) < 0) {
1132 printf("app_set_main_core failed %d\n", xret);
1136 app_io_xran_if_alloc();
1138 /* one init for all O-XU */
1139 app_io_xran_fh_init_init(p_usecaseConfiguration, p_startupConfiguration[0], &app_io_xran_fh_init);
1141 xret = xran_init(argc, argv, &app_io_xran_fh_init, argv[0], &app_io_xran_handle);
1142 if (xret != XRAN_STATUS_SUCCESS) {
1143 printf("xran_init failed %d\n", xret);
1147 if (app_io_xran_handle == NULL)
1150 if (stat("./logs", &st) == -1) {
1151 mkdir("./logs", 0777);
1154 /** process all the O-RU|O-DU for use case */
1155 for (o_xu_id = 0; o_xu_id < p_usecaseConfiguration->oXuNum; o_xu_id++) {
1156 RuntimeConfig* p_o_xu_cfg = p_startupConfiguration[o_xu_id];
1158 app_io_xran_buffers_max_sz_set(p_o_xu_cfg);
1160 if (p_o_xu_cfg->ant_file[0] == NULL) {
1161 printf("it looks like test vector for antennas were not provided\n");
1164 if (p_o_xu_cfg->numCC > XRAN_MAX_SECTOR_NR) {
1165 printf("Number of cells %d exceeds max number supported %d!\n", p_o_xu_cfg->numCC, XRAN_MAX_SECTOR_NR);
1166 p_o_xu_cfg->numCC = XRAN_MAX_SECTOR_NR;
1169 if (p_o_xu_cfg->antElmTRx > XRAN_MAX_ANT_ARRAY_ELM_NR) {
1170 printf("Number of Antenna elements %d exceeds max number supported %d!\n", p_o_xu_cfg->antElmTRx, XRAN_MAX_ANT_ARRAY_ELM_NR);
1171 p_o_xu_cfg->antElmTRx = XRAN_MAX_ANT_ARRAY_ELM_NR;
1174 printf("Numm CC %d numAxc %d numUlAxc %d\n", p_o_xu_cfg->numCC, p_o_xu_cfg->numAxc, p_o_xu_cfg->numUlAxc);
1176 app_setup_o_xu_buffers(p_usecaseConfiguration, p_o_xu_cfg, &app_io_xran_fh_init);
1178 app_io_xran_fh_config_init(p_usecaseConfiguration, p_o_xu_cfg, &app_io_xran_fh_init, &app_io_xran_fh_config[o_xu_id]);
1180 xret = xran_open(app_io_xran_handle, &app_io_xran_fh_config[o_xu_id]);
1181 if(xret != XRAN_STATUS_SUCCESS){
1182 printf("xran_open failed %d\n", xret);
1186 if (app_io_xran_interface(o_xu_id, p_startupConfiguration[o_xu_id], p_usecaseConfiguration) != 0)
1189 app_io_xran_iq_content_init(o_xu_id, p_startupConfiguration[o_xu_id]);
1191 if ((xret = xran_reg_physide_cb(app_io_xran_handle, app_io_xran_dl_tti_call_back, NULL, 10, XRAN_CB_TTI)) != XRAN_STATUS_SUCCESS) {
1192 printf("xran_reg_physide_cb failed %d\n", xret);
1195 if ((xret = xran_reg_physide_cb(app_io_xran_handle, app_io_xran_ul_half_slot_call_back, NULL, 10, XRAN_CB_HALF_SLOT_RX)) != XRAN_STATUS_SUCCESS) {
1196 printf("xran_reg_physide_cb failed %d\n", xret);
1199 if ((xret = xran_reg_physide_cb(app_io_xran_handle, app_io_xran_ul_full_slot_call_back, NULL, 10, XRAN_CB_FULL_SLOT_RX)) != XRAN_STATUS_SUCCESS) {
1200 printf("xran_reg_physide_cb failed %d\n", xret);
1204 if ((xret = xran_reg_sym_cb(app_io_xran_handle, app_io_xran_ul_custom_sym_call_back,
1205 (void*)&cb_sym_ctx[0].cb_param,
1206 &cb_sym_ctx[0].sense_of_time,
1207 3, XRAN_CB_SYM_RX_WIN_BEGIN)) != XRAN_STATUS_SUCCESS) {
1208 printf("xran_reg_sym_cb failed %d\n", xret);
1212 if ((xret = xran_reg_sym_cb(app_io_xran_handle, app_io_xran_ul_custom_sym_call_back,
1213 (void*)&cb_sym_ctx[1].cb_param,
1214 &cb_sym_ctx[1].sense_of_time,
1215 3, XRAN_CB_SYM_RX_WIN_END)) != XRAN_STATUS_SUCCESS) {
1216 printf("xran_reg_sym_cb failed %d\n", xret);
1220 if ((xret = xran_reg_sym_cb(app_io_xran_handle, app_io_xran_ul_custom_sym_call_back,
1221 (void*)&cb_sym_ctx[2].cb_param,
1222 &cb_sym_ctx[2].sense_of_time,
1223 3, XRAN_CB_SYM_TX_WIN_BEGIN)) != XRAN_STATUS_SUCCESS) {
1224 printf("xran_reg_sym_cb failed %d\n", xret);
1228 if ((xret = xran_reg_sym_cb(app_io_xran_handle, app_io_xran_ul_custom_sym_call_back,
1229 (void*)&cb_sym_ctx[3].cb_param,
1230 &cb_sym_ctx[3].sense_of_time,
1231 3, XRAN_CB_SYM_TX_WIN_END)) != XRAN_STATUS_SUCCESS) {
1232 printf("xran_reg_sym_cb failed %d\n", xret);
1238 snprintf(filename, sizeof(filename),"mlog-%s", p_usecaseConfiguration->appMode == 0 ? "o-du" : "o-ru");
1240 /* MLogOpen(0, 32, 0, 0xFFFFFFFF, filename);*/
1242 MLogOpen(128, 7, 20000, 0, filename);
1245 puts("----------------------------------------");
1246 printf("MLog Info: virt=0x%016lx size=%d\n", MLogGetFileLocation(), MLogGetFileSize());
1247 puts("----------------------------------------");
1249 uint64_t nActiveCoreMask[MAX_BBU_POOL_CORE_MASK] = {0};
1250 uint32_t totalCC = 0;
1251 nActiveCoreMask[0] = ((1 << app_io_xran_fh_init.io_cfg.timing_core) | app_io_xran_fh_init.io_cfg.pkt_proc_core);
1252 nActiveCoreMask[1] = app_io_xran_fh_init.io_cfg.pkt_proc_core_64_127;
1254 for (o_xu_id = 0; o_xu_id < p_usecaseConfiguration->oXuNum; o_xu_id++) {
1255 RuntimeConfig* p_o_xu_cfg = p_startupConfiguration[o_xu_id];
1256 totalCC += p_o_xu_cfg->numCC;
1258 MLogAddTestCase(nActiveCoreMask, totalCC);
1260 fcntl(0, F_SETFL, fcntl(0, F_GETFL) | O_NONBLOCK);
1262 state = APP_RUNNING;
1263 printf("Start XRAN traffic\n");
1264 xran_start(app_io_xran_handle);
1267 struct xran_common_counters x_counters[XRAN_PORTS_NUM];
1272 xran_curr_if_state = xran_get_if_state();
1274 if (xran_get_common_counters(app_io_xran_handle, &x_counters[0]) == XRAN_STATUS_SUCCESS) {
1275 for (o_xu_id = 0; o_xu_id < p_usecaseConfiguration->oXuNum; o_xu_id++) {
1277 xran_get_time_stats(&nTotalTime, &nUsedTime, &nCoresUsed, nCoreUsedNum, 1);
1280 nUsedPercent = ((float)nUsedTime * 100.0) / (float)nTotalTime;
1282 mlog_times.core_total_time += nTotalTime;
1283 mlog_times.core_used_time += nUsedTime;
1286 printf("[nCoresUsed: %d] [MainCore: %d - Util: %5.2f %%]", nCoresUsed, nCoreUsedNum[0], nUsedPercent);
1287 if (nCoresUsed > 1) {
1288 printf("[Additional Cores: ");
1289 for (int nCore = 1; nCore < nCoresUsed; nCore++) {
1290 printf("%d ", nCoreUsedNum[nCore]);
1297 printf("[%s%d][rx %7ld pps %7ld kbps %7ld][tx %7ld pps %7ld kbps %7ld] [on_time %ld early %ld late %ld corrupt %ld pkt_dupl %ld Total %ld]\n",
1298 ((p_usecaseConfiguration->appMode == APP_O_DU) ? "o-du" : "o-ru"),
1300 x_counters[o_xu_id].rx_counter,
1301 x_counters[o_xu_id].rx_counter-old_rx_counter[o_xu_id],
1302 x_counters[o_xu_id].rx_bytes_per_sec*8/1000L,
1303 x_counters[o_xu_id].tx_counter,
1304 x_counters[o_xu_id].tx_counter-old_tx_counter[o_xu_id],
1305 x_counters[o_xu_id].tx_bytes_per_sec*8/1000L,
1306 x_counters[o_xu_id].Rx_on_time,
1307 x_counters[o_xu_id].Rx_early,
1308 x_counters[o_xu_id].Rx_late,
1309 x_counters[o_xu_id].Rx_corrupt,
1310 x_counters[o_xu_id].Rx_pkt_dupl,
1311 x_counters[o_xu_id].Total_msgs_rcvd);
1313 if (x_counters[o_xu_id].rx_counter > old_rx_counter[o_xu_id])
1314 old_rx_counter[o_xu_id] = x_counters[o_xu_id].rx_counter;
1315 if (x_counters[o_xu_id].tx_counter > old_tx_counter[o_xu_id])
1316 old_tx_counter[o_xu_id] = x_counters[o_xu_id].tx_counter;
1319 if(is_mlog_on == 0 && x_counters[o_xu_id].rx_counter > 0 && x_counters[o_xu_id].tx_counter > 0) {
1320 xran_set_debug_stop(p_startupConfiguration[0]->debugStop, p_startupConfiguration[0]->debugStopCount);
1321 MLogSetMask(0xFFFFFFFF);
1327 printf("error xran_get_common_counters\n");
1330 if (xran_curr_if_state == XRAN_STOPPED){
1333 if (NULL == fgets(input, 10, stdin)) {
1337 const int sel_opt = atoi(input);
1340 xran_start(app_io_xran_handle);
1341 printf("Start XRAN traffic\n");
1346 xran_stop(app_io_xran_handle);
1347 printf("Stop XRAN traffic\n");
1348 state = APP_STOPPED;
1351 puts("Wrong option passed!");
1354 if (APP_STOPPED == state)
1358 /** process all the O-RU|O-DU for use case */
1359 for (o_xu_id = 0; o_xu_id < p_usecaseConfiguration->oXuNum; o_xu_id++) {
1360 app_io_xran_iq_content_get(o_xu_id, p_startupConfiguration[o_xu_id]);
1361 /* Check for owd results */
1362 if (p_usecaseConfiguration->owdmEnable)
1366 uint64_t avgDelay =0;
1367 snprintf(filename, sizeof(filename), "./logs/%s%d-owd_results.txt", ((p_startupConfiguration[o_xu_id]->appMode == APP_O_DU)?"o-du":"o-ru"),o_xu_id);
1368 file = fopen(filename, "w");
1370 printf("can't open file %s\n",filename);
1373 if (xran_get_delay_measurements_results (app_io_xran_handle, (uint16_t) p_startupConfiguration[o_xu_id]->o_xu_id, p_usecaseConfiguration->appMode, &avgDelay))
1375 fprintf(file,"OWD Measurements failed for port %d and appMode %d \n", p_startupConfiguration[o_xu_id]->o_xu_id,p_usecaseConfiguration->appMode);
1379 fprintf(file,"OWD Measurements passed for port %d and appMode %d with AverageDelay %lu [ns]\n", p_startupConfiguration[o_xu_id]->o_xu_id,p_usecaseConfiguration->appMode, avgDelay);
1387 puts("Closing l1 app... Ending all threads...");
1389 xran_close(app_io_xran_handle);
1391 app_profile_xran_print_mlog_stats(arg_params.usecase_file);
1394 app_io_xran_if_stop();
1396 puts("Dump IQs...");
1397 for (o_xu_id = 0; o_xu_id < p_usecaseConfiguration->oXuNum; o_xu_id++) {
1398 app_dump_o_xu_buffers(p_usecaseConfiguration, p_startupConfiguration[o_xu_id]);
1401 app_io_xran_if_free();