-/******************************************************************************
-*
-* 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.
-*
-*******************************************************************************/
-
-
-#define _GNU_SOURCE
-#include <unistd.h>
-#include <sys/syscall.h>
-#include <sched.h>
-#include <assert.h>
-#include <err.h>
-#include <libgen.h>
-#include <sys/time.h>
-#include <time.h>
-#include <unistd.h>
-#include <stdio.h>
-#include <fcntl.h>
-#include <pthread.h>
-#include <sys/stat.h>
-#include <unistd.h>
-
-
-#include "common.h"
-#include "config.h"
-#include "xran_mlog_lnx.h"
-
-#include "xran_fh_o_du.h"
-#include "xran_cp_api.h"
-#include "xran_sync_api.h"
-#include "xran_mlog_task_id.h"
-
-#define MAX_BBU_POOL_CORE_MASK (4)
-
-
-#define SW_FPGA_TOTAL_BUFFER_LEN 4*1024*1024*1024
-#define SW_FPGA_SEGMENT_BUFFER_LEN 1*1024*1024*1024
-#define SW_FPGA_FH_TOTAL_BUFFER_LEN 1*1024*1024*1024
-#define FPGA_TO_SW_PRACH_RX_BUFFER_LEN (8192)
-
-#define NSEC_PER_SEC 1000000000
-
-#define MAX_PKT_BURST (448+4) // 4x14x8
-#define N_MAX_BUFFER_SEGMENT MAX_PKT_BURST
-
-#define MAIN_PRIORITY 98
-#define NUM_OF_SUBFRAME_PER_FRAME (10)
-
-enum app_state state;
-
-uint64_t tick_per_usec;
-static volatile uint64_t timer_last_irq_tick = 0;
-static uint64_t tsc_resolution_hz = 0;
-
-RuntimeConfig startupConfiguration = {0};
-
-/* buffers size */
-uint32_t nFpgaToSW_FTH_RxBufferLen;
-uint32_t nFpgaToSW_PRACH_RxBufferLen;
-uint32_t nSW_ToFpga_FTH_TxBufferLen;
-
-static struct xran_fh_init xranInit;
-void * xranHandle = NULL;
-
-struct xran_fh_config xranConf;
-struct xran_fh_config *pXranConf = NULL;
-
-typedef struct
-{
- uint32_t phaseFlag :1;
- uint32_t NRARFCN :22;
- uint32_t SULFreShift :1;
- uint32_t SULFlag :1;
- uint32_t rsv :7;
-}FPGAPhaseCompCfg;
-
-typedef struct XranLibConfig
-{
- uint32_t nDriverCoreId;
- uint32_t nTimingAdvance;
- uint32_t nFhConfig;
- uint32_t nFhBufIntFlag;
- uint32_t nSectorNum;
- uint32_t nNrOfSlotInSf;
- uint32_t nNrofSfInFrame;
- void * pFthInstanceHandles;
-}XranLibConfigStruct;
-typedef enum {
- XRANFTHTX_OUT = 0,
- XRANFTHTX_PRB_MAP_OUT,
- XRANFTHRX_IN,
- XRANFTHRX_PRB_MAP_IN,
- XRANFTHRACH_IN,
- MAX_SW_XRAN_INTERFACE_NUM
-}SWXRANInterfaceTypeEnum;
-
-/*
- * manage one cell's all Ethernet frames for one DL or UL LTE subframe
- */
-typedef struct {
- /* -1-this subframe is not used in current frame format
- 0-this subframe can be transmitted, i.e., data is ready
- 1-this subframe is waiting transmission, i.e., data is not ready
- 10 - DL transmission missing deadline. When FE needs this subframe data but bValid is still 1,
- set bValid to 10.
- */
- int32_t bValid ; // when UL rx, it is subframe index.
- int32_t nSegToBeGen;
- int32_t nSegGenerated; // how many date segment are generated by DL LTE processing or received from FE
- // -1 means that DL packet to be transmitted is not ready in BS
- int32_t nSegTransferred; // number of data segments has been transmitted or received
- struct rte_mbuf *pData[N_MAX_BUFFER_SEGMENT]; // point to DPDK allocated memory pool
- struct xran_buffer_list sBufferList;
-} BbuIoBufCtrlStruct;
-
-typedef struct {
- uint64_t nCoreMask;
- int16_t cpuSocketId;
- uint8_t nDriverCoreId;
- uint8_t nFHCoreId;
-
- struct rte_mempool *bbuio_buf_pool;
-
- /* io struct */
- BbuIoBufCtrlStruct sFrontHaulTxBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];
- BbuIoBufCtrlStruct sFrontHaulTxPrbMapBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];
- BbuIoBufCtrlStruct sFrontHaulRxBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];
- BbuIoBufCtrlStruct sFrontHaulRxPrbMapBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];
- BbuIoBufCtrlStruct sFHPrachRxBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];
-
- /* buffers lists */
- struct xran_flat_buffer sFrontHaulTxBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_NUM_OF_SYMBOL_PER_SLOT];
- struct xran_flat_buffer sFrontHaulTxPrbMapBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];
- struct xran_flat_buffer sFrontHaulRxBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_NUM_OF_SYMBOL_PER_SLOT];
- struct xran_flat_buffer sFrontHaulRxPrbMapBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];
- struct xran_flat_buffer sFHPrachRxBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_NUM_OF_SYMBOL_PER_SLOT];
-
- void* nInstanceHandle[XRAN_PORTS_NUM][XRAN_MAX_SECTOR_NR]; // instance per sector
- uint32_t nBufPoolIndex[XRAN_MAX_SECTOR_NR][MAX_SW_XRAN_INTERFACE_NUM]; // every api owns unique buffer pool
- uint16_t nInstanceNum;
-
- uint64_t nTscTiming[XRAN_N_FE_BUF_LEN]; // records the TSC when a timing packet is received.
-} BbuXranIoIfStruct;
-
-static BbuXranIoIfStruct gsXranIoIf;
-static XranLibConfigStruct *gpXranLibConfig = NULL;
-
-extern long rx_counter;
-extern long tx_counter;
-
-#define CPU_HZ tick_per_usec //us
-
-/* Application User space functions */
-void xran_fh_rx_callback(void *pCallbackTag, int32_t status);
-void xran_fh_rx_prach_callback(void *pCallbackTag, int32_t status);
-
-static BbuXranIoIfStruct *xran_get_ctx(void)
-{
- return &gsXranIoIf;
-}
-
-static void print_menu()
-{
- puts("+---------------------------------------+");
- puts("| Press 1 to start 5G NR XRAN traffic |");
- puts("| Press 2 reserved for future use |");
- puts("| Press 3 to quit |");
- puts("+---------------------------------------+");
-}
-
-static int32_t get_xran_sfidx(uint8_t nNrOfSlotInSf)
-{
- int32_t nSfIdx = -1;
- uint32_t nFrameIdx;
- uint32_t nSubframeIdx;
- uint32_t nSlotIdx;
- uint64_t nSecond;
-
- uint32_t nXranTime = xran_get_slot_idx(&nFrameIdx, &nSubframeIdx, &nSlotIdx, &nSecond);
- nSfIdx = nFrameIdx*NUM_OF_SUBFRAME_PER_FRAME*nNrOfSlotInSf
- + nSubframeIdx*nNrOfSlotInSf
- + nSlotIdx;
-#if 0
- printf("\nxranTime is %d, return is %d, radio frame is %d, subframe is %d slot is %d tsc is %llu us",
- nXranTime,
- nSfIdx,
- nFrameIdx,
- nSubframeIdx,
- nSlotIdx,
- __rdtsc()/CPU_HZ);
-#endif
-
- return nSfIdx;
-}
-
-void xran_fh_rx_callback(void *pCallbackTag, xran_status_t status)
-{
- uint64_t t1 = MLogTick();
- uint32_t mlogVar[10];
- uint32_t mlogVarCnt = 0;
- uint8_t Numerlogy = xranConf.frame_conf.nNumerology;
- uint8_t nNrOfSlotInSf = 1<<Numerlogy;
- int32_t sfIdx = get_xran_sfidx(nNrOfSlotInSf);
-
- mlogVar[mlogVarCnt++] = 0xCCCCCCCC;
- mlogVar[mlogVarCnt++] = status >> 16; /* tti */
- mlogVar[mlogVarCnt++] = status & 0xFF; /* sym */
- mlogVar[mlogVarCnt++] = (uint32_t)sfIdx;
- MLogAddVariables(mlogVarCnt, mlogVar, MLogTick());
- rte_pause();
-
- MLogTask(PID_GNB_SYM_CB, t1, MLogTick());
- return;
-}
-
-void xran_fh_rx_prach_callback(void *pCallbackTag, xran_status_t status)
-{
- uint64_t t1 = MLogTick();
- uint32_t mlogVar[10];
- uint32_t mlogVarCnt = 0;
-
- mlogVar[mlogVarCnt++] = 0xDDDDDDDD;
- mlogVar[mlogVarCnt++] = status >> 16; /* tti */
- mlogVar[mlogVarCnt++] = status & 0xFF; /* sym */
- MLogAddVariables(mlogVarCnt, mlogVar, MLogTick());
- rte_pause();
-
- MLogTask(PID_GNB_PRACH_CB, t1, MLogTick());
-}
-
-//-------------------------------------------------------------------------------------------
-/** @ingroup group_nbiot_source_auxlib_timer
- *
- * @param void
- *
- * @return Ticks
- *
- * @description
- * This function reads the rtdsc clock and returns the current value in there.
- *
-**/
-//-------------------------------------------------------------------------------------------
-unsigned long timer_get_ticks(void)
-{
- unsigned long ret;
- union
- {
- unsigned long tsc_64;
- struct
- {
- uint32_t lo_32;
- uint32_t hi_32;
- };
- } tsc;
-
- __asm volatile("rdtsc" :
- "=a" (tsc.lo_32),
- "=d" (tsc.hi_32));
-
- ret = ((unsigned long)tsc.tsc_64);
- return ret;
-}
-
-//-------------------------------------------------------------------------------------------
-/** @ingroup group_lte_source_auxlib_timer
- *
- * @param void
- *
- * @return 0 if SUCCESS
- *
- * @description
- * This function gets the clock speed of the core and figures out number of ticks per usec.
- * It is used by l1app and testmac applications to initialize the mlog utility
- *
-**/
-//-------------------------------------------------------------------------------------------
-int timer_set_tsc_freq_from_clock(void)
-{
-#define NS_PER_SEC 1E9
- struct timespec sleeptime = {.tv_nsec = 5E8 }; /* 1/2 second */
- struct timespec t_start, t_end;
- uint64_t tsc_resolution_hz = 0;
-
- if (clock_gettime(CLOCK_MONOTONIC_RAW, &t_start) == 0)
- {
- unsigned long ns, end, start = timer_get_ticks();
- nanosleep(&sleeptime,NULL);
- clock_gettime(CLOCK_MONOTONIC_RAW, &t_end);
- end = timer_get_ticks();
- ns = ((t_end.tv_sec - t_start.tv_sec) * NS_PER_SEC);
- ns += (t_end.tv_nsec - t_start.tv_nsec);
-
- double secs = (double)ns/NS_PER_SEC;
- tsc_resolution_hz = (unsigned long)((end - start)/secs);
-
- tick_per_usec = (tsc_resolution_hz / 1000000);
- printf("System clock (rdtsc) resolution %lu [Hz]\n", tsc_resolution_hz);
- printf("Ticks per us %lu\n", tick_per_usec);
- return 0;
- }
-
- return -1;
-}
-
-int physide_dl_tti_call_back(void * param)
-{
- uint64_t t1 = MLogTick();
- rte_pause();
- MLogTask(PID_GNB_PROC_TIMING, t1, MLogTick());
- return 0;
-}
-
-int physide_ul_half_slot_call_back(void * param)
-{
- uint64_t t1 = MLogTick();
- rte_pause();
- MLogTask(PID_GNB_PROC_TIMING, t1, MLogTick());
- return 0;
-}
-
-int physide_ul_full_slot_call_back(void * param)
-{
- uint64_t t1 = MLogTick();
- rte_pause();
- MLogTask(PID_GNB_PROC_TIMING, t1, MLogTick());
- return 0;
-}
-
-int32_t init_xran(void)
-{
- BbuXranIoIfStruct *psBbuIo = xran_get_ctx();
- xran_status_t status;
- int32_t nSectorIndex[XRAN_MAX_SECTOR_NR];
- int32_t nSectorNum;
- int32_t i, j, k, z;
-
- void *ptr;
- void *mb;
- uint32_t *u32dptr;
- uint16_t *u16dptr;
- uint8_t *u8dptr;
-
- SWXRANInterfaceTypeEnum eInterfaceType;
-
- XranLibConfigStruct *ptrLibConfig;
-
- struct xran_buffer_list *pFthTxBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];
- struct xran_buffer_list *pFthTxPrbMapBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];
- struct xran_buffer_list *pFthRxBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];
- struct xran_buffer_list *pFthRxPrbMapBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];
- struct xran_buffer_list *pFthRxRachBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];
-
- for (nSectorNum = 0; nSectorNum < XRAN_MAX_SECTOR_NR; nSectorNum++)
- {
- nSectorIndex[nSectorNum] = nSectorNum;
- }
-
- nSectorNum = numCCPorts;
- printf ("XRAN front haul xran_mm_init \n");
- status = xran_mm_init (xranHandle, (uint64_t) SW_FPGA_FH_TOTAL_BUFFER_LEN, SW_FPGA_SEGMENT_BUFFER_LEN);
- if (status != XRAN_STATUS_SUCCESS)
- {
- printf ("Failed at XRAN front haul xran_mm_init \n");
- exit(-1);
- }
-
- psBbuIo->nInstanceNum = numCCPorts;
-
- for (k = 0; k < XRAN_PORTS_NUM; k++) {
- status = xran_sector_get_instances (xranHandle, psBbuIo->nInstanceNum,&psBbuIo->nInstanceHandle[k][0]);
- if (status != XRAN_STATUS_SUCCESS)
- {
- printf ("get sector instance failed %d for XRAN nInstanceNum %d\n",k, psBbuIo->nInstanceNum);
- exit(-1);
- }
- for (i = 0; i < psBbuIo->nInstanceNum; i++){
- printf("%s [%d]: CC %d handle %p\n", __FUNCTION__, k, i, psBbuIo->nInstanceHandle[0][i]);
- }
- }
-
- printf("Sucess xran_mm_init \n");
- gpXranLibConfig = (XranLibConfigStruct*)malloc(sizeof(XranLibConfigStruct));
- ptrLibConfig = gpXranLibConfig;
- if (ptrLibConfig)
- {
- #if 0
- ptrLibConfig->nDriverCoreId = psBbuIo->nDriverCoreId;
- ptrLibConfig->pFecInstanceHandles = &(psBbuIo->nInstanceHandle[FPGA_FEC][0]);
- ptrLibConfig->pFthInstanceHandles = &(psBbuIo->nInstanceHandle[FPGA_FRONTHAUL][0]);
- ptrLibConfig->nTimingAdvance = psFPGAInitPara->nTimeAdvance;
- ptrLibConfig->nFhConfig = psFPGAInitPara->nEthPorts;
- ptrLibConfig->nFhBufIntFlag = 0; //need init fronthaul buffer, then set to 1.
- ptrLibConfig->nNrofSfInFrame = NUM_OF_SUBFRAME_PER_FRAME;
- ptrLibConfig->nNrOfSlotInSf = pConfigParams->nNumOfSlotPerSubframe;
- if (pConfigParams->nNumerology < 3)
- {
- ptrLibConfig->nSectorNum = psFPGAInitPara->nSecNum;
- }
- #endif
- }
- else
- {
- printf ("could not allocate ptrLibConfig in init_xran\n");
- exit(-1);
- }
-
- printf("nSectorNum %d\n", nSectorNum);
-
- /* Init Memory */
- for(i = 0; i<nSectorNum; i++)
- {
- eInterfaceType = XRANFTHTX_OUT;
- printf("nSectorIndex[%d] = %d\n",i, nSectorIndex[i]);
- status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],
- XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, nSW_ToFpga_FTH_TxBufferLen);
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_init , status %d\n", status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
- for(j = 0; j < XRAN_N_FE_BUF_LEN; j++)
- {
- for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].bValid = 0;
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].nSegGenerated = -1;
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].nSegTransferred = 0;
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_NUM_OF_SYMBOL_PER_SLOT;
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFrontHaulTxBuffers[j][i][z][0];
-
- for(k = 0; k < XRAN_NUM_OF_SYMBOL_PER_SLOT; k++)
- {
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nElementLenInBytes = nSW_ToFpga_FTH_TxBufferLen; // 14 symbols 3200bytes/symbol
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nNumberOfElements = 1;
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nOffsetInBytes = 0;
- status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i], psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_allocate_buffer , status %d\n",status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pData = (uint8_t *)ptr;
- psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pCtrl = (void *)mb;
-
- if(ptr){
- u32dptr = (uint32_t*)(ptr);
- uint8_t *ptr_temp = (uint8_t *)ptr;
- memset(u32dptr, 0xCC, nSW_ToFpga_FTH_TxBufferLen);
- ptr_temp[0] = j; // TTI
- ptr_temp[1] = i; // Sec
- ptr_temp[2] = z; // Ant
- ptr_temp[3] = k; // sym
- }
- }
- }
- }
-
- /* C-plane DL */
- eInterfaceType = XRANFTHTX_PRB_MAP_OUT;
- printf("nSectorIndex[%d] = %d\n",i, nSectorIndex[i]);
- status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],
- XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, sizeof(struct xran_prb_map));
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_init , status %d\n", status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
- for(j = 0; j < XRAN_N_FE_BUF_LEN; j++)
- {
- for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].bValid = 0;
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].nSegGenerated = -1;
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].nSegTransferred = 0;
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_NUM_OF_SYMBOL_PER_SLOT;
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFrontHaulTxPrbMapBuffers[j][i][z];
-
- {
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nElementLenInBytes = sizeof(struct xran_prb_map);
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nNumberOfElements = 1;
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nOffsetInBytes = 0;
- status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i], psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_allocate_buffer , status %d\n",status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->pData = (uint8_t *)ptr;
- psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->pCtrl = (void *)mb;
-
- if(ptr){
- u32dptr = (uint32_t*)(ptr);
- uint8_t *ptr_temp = (uint8_t *)ptr;
- memset(u32dptr, 0xCC, sizeof(struct xran_prb_map));
- ptr_temp[0] = j; // TTI
- ptr_temp[1] = i; // Sec
- ptr_temp[2] = z; // Ant
- ptr_temp[3] = k; // sym
- }
- }
- }
- }
- }
-
- for(i = 0; i<nSectorNum; i++)
- {
- eInterfaceType = XRANFTHRX_IN;
- status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType], XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, nSW_ToFpga_FTH_TxBufferLen);
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_init, status %d\n", status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
-
- for(j = 0;j < XRAN_N_FE_BUF_LEN; j++)
- {
- for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].bValid = 0;
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].nSegGenerated = -1;
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].nSegTransferred = 0;
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_NUM_OF_SYMBOL_PER_SLOT;
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFrontHaulRxBuffers[j][i][z][0];
- for(k = 0; k< XRAN_NUM_OF_SYMBOL_PER_SLOT; k++)
- {
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nElementLenInBytes = nFpgaToSW_FTH_RxBufferLen; // 1 symbols 3200bytes
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nNumberOfElements = 1;
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nOffsetInBytes = 0;
- status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i],psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_allocate_buffer , status %d\n",status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pData = (uint8_t *)ptr;
- psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pCtrl = (void *) mb;
- if(ptr){
- u32dptr = (uint32_t*)(ptr);
- uint8_t *ptr_temp = (uint8_t *)ptr;
- memset(u32dptr, 0xCC, nFpgaToSW_FTH_RxBufferLen);
- ptr_temp[0] = j; // TTI
- ptr_temp[1] = i; // Sec
- ptr_temp[2] = z; // Ant
- ptr_temp[3] = k; // sym
- }
- }
- }
- }
-
- /* C-plane */
- eInterfaceType = XRANFTHRX_PRB_MAP_IN;
- status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],
- XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, sizeof(struct xran_prb_map));
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_init, status %d\n", status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
-
- for(j = 0;j < XRAN_N_FE_BUF_LEN; j++)
- {
- for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].bValid = 0;
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].nSegGenerated = -1;
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].nSegTransferred = 0;
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_NUM_OF_SYMBOL_PER_SLOT;
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFrontHaulRxPrbMapBuffers[j][i][z];
- {
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nElementLenInBytes = sizeof(struct xran_prb_map);
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nNumberOfElements = 1;
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nOffsetInBytes = 0;
- status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i],psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_allocate_buffer , status %d\n",status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->pData = (uint8_t *)ptr;
- psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->pCtrl = (void *)mb;
- if(ptr){
- u32dptr = (uint32_t*)(ptr);
- uint8_t *ptr_temp = (uint8_t *)ptr;
- memset(u32dptr, 0xCC, sizeof(struct xran_prb_map));
- ptr_temp[0] = j; // TTI
- ptr_temp[1] = i; // Sec
- ptr_temp[2] = z; // Ant
- ptr_temp[3] = k; // sym
- }
- }
- }
- }
- }
-
- // add prach rx buffer
- for(i = 0; i<nSectorNum; i++)
- {
- eInterfaceType = XRANFTHRACH_IN;
- status = xran_bm_init(psBbuIo->nInstanceHandle[0][i],&psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, FPGA_TO_SW_PRACH_RX_BUFFER_LEN);
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_init, status %d\n", status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
- for(j = 0;j < XRAN_N_FE_BUF_LEN; j++)
- {
- for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].bValid = 0;
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].nSegGenerated = -1;
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].nSegTransferred = 0;
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_MAX_ANTENNA_NR; // ant number.
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFHPrachRxBuffers[j][i][z][0];
- for(k = 0; k< XRAN_NUM_OF_SYMBOL_PER_SLOT; k++)
- {
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nElementLenInBytes = FPGA_TO_SW_PRACH_RX_BUFFER_LEN;
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nNumberOfElements = 1;
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nOffsetInBytes = 0;
- status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i],psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_bm_allocate_buffer, status %d\n",status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pData = (uint8_t *)ptr;
- psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pCtrl = (void *)mb;
- if(ptr){
- u32dptr = (uint32_t*)(ptr);
- memset(u32dptr, 0xCC, FPGA_TO_SW_PRACH_RX_BUFFER_LEN);
- }
- }
- }
- }
- }
-
- for(i=0; i<nSectorNum; i++)
- {
- for(j=0; j<XRAN_N_FE_BUF_LEN; j++)
- {
- for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){
- pFthTxBuffer[i][z][j] = &(psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList);
- pFthTxPrbMapBuffer[i][z][j] = &(psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList);
- pFthRxBuffer[i][z][j] = &(psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList);
- pFthRxPrbMapBuffer[i][z][j] = &(psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList);
- pFthRxRachBuffer[i][z][j] = &(psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList);
- }
- }
- }
-
- if(NULL != psBbuIo->nInstanceHandle[0])
- {
- for (i = 0; i<nSectorNum; i++)
- {
- xran_5g_fronthault_config (psBbuIo->nInstanceHandle[0][i],
- pFthTxBuffer[i],
- pFthTxPrbMapBuffer[i],
- pFthRxBuffer[i],
- pFthRxPrbMapBuffer[i],
- xran_fh_rx_callback, &pFthRxBuffer[i][0]);
- }
-
- // add prach callback here
- for (i = 0; i<nSectorNum; i++)
- {
- xran_5g_prach_req(psBbuIo->nInstanceHandle[0][i], pFthRxRachBuffer[i],
- xran_fh_rx_prach_callback,&pFthRxRachBuffer[i][0]);
- }
- ptrLibConfig->nFhBufIntFlag = 1;
- }
-
- return status;
-}
-
-int init_xran_iq_content(void)
-{
- BbuXranIoIfStruct *psBbuIo = xran_get_ctx();
- xran_status_t status;
- int32_t nSectorIndex[XRAN_MAX_SECTOR_NR];
- int32_t nSectorNum;
- int32_t cc_id, ant_id, sym_id, tti;
- int32_t flowId;
-
- uint8_t frame_id = 0;
- uint8_t subframe_id = 0;
- uint8_t slot_id = 0;
- uint8_t sym = 0;
-
- void *ptr;
- uint32_t *u32dptr;
- uint16_t *u16dptr;
- uint8_t *u8dptr;
-
- char *pos = NULL;
- struct xran_prb_map *pRbMap = NULL;
-
- for (nSectorNum = 0; nSectorNum < XRAN_MAX_SECTOR_NR; nSectorNum++)
- {
- nSectorIndex[nSectorNum] = nSectorNum;
- }
- nSectorNum = numCCPorts;
- printf ("init_xran_iq_content\n");
-
- /* Init Memory */
- for(cc_id = 0; cc_id <nSectorNum; cc_id++)
- {
- for(tti = 0; tti < XRAN_N_FE_BUF_LEN; tti ++) {
- for(ant_id = 0; ant_id < XRAN_MAX_ANTENNA_NR; ant_id++){
- for(sym_id = 0; sym_id < XRAN_NUM_OF_SYMBOL_PER_SLOT; sym_id++) {
-
- flowId = XRAN_MAX_ANTENNA_NR*cc_id + ant_id;
-
- if(p_tx_play_buffer[flowId]){
- pos = ((char*)p_tx_play_buffer[flowId]) + tx_play_buffer_position[flowId];
- ptr = psBbuIo->sFrontHaulTxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;
-
- if(ptr && pos){
- u32dptr = (uint32_t*)(ptr);
- rte_memcpy(u32dptr, pos, pXranConf->nDLRBs*N_SC_PER_PRB*4);
-#ifdef DEBUG_XRAN_BUFFERS
- uint8_t *ptr_temp = (uint8_t *)ptr;
- ptr_temp[0] = tti; // TTI
- ptr_temp[1] = cc_id; // Sec
- ptr_temp[2] = ant_id; // Ant
- ptr_temp[3] = sym_id; // sym
-#endif
- } else {
- exit(-1);
- printf("ptr ==NULL\n");
- }
-
- /* c-plane DL */
- pRbMap = (struct xran_prb_map *) psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers->pData;
- if(pRbMap){
- pRbMap->dir = XRAN_DIR_DL;
- pRbMap->xran_port = 0;
- pRbMap->band_id = 0;
- pRbMap->cc_id = cc_id;
- pRbMap->ru_port_id = ant_id;
- pRbMap->tti_id = tti;
- pRbMap->start_sym_id = 0;
- pRbMap->nPrbElm = 1;
- pRbMap->prbMap[0].nRBStart = 0;
- pRbMap->prbMap[0].nRBSize = pXranConf->nDLRBs;
- pRbMap->prbMap[0].nBeamIndex = 0;
- pRbMap->prbMap[0].compMethod = XRAN_COMPMETHOD_NONE;
- }else{
- printf("DL pRbMap ==NULL\n");
- exit(-1);
- }
-
- /* c-plane UL */
- pRbMap = (struct xran_prb_map *) psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers->pData;
- if(pRbMap){
- pRbMap->dir = XRAN_DIR_UL;
- pRbMap->xran_port = 0;
- pRbMap->band_id = 0;
- pRbMap->cc_id = cc_id;
- pRbMap->ru_port_id = ant_id;
- pRbMap->tti_id = tti;
- pRbMap->start_sym_id = 0;
- pRbMap->nPrbElm = 1;
- pRbMap->prbMap[0].nRBStart = 0;
- pRbMap->prbMap[0].nRBSize = pXranConf->nULRBs;
- pRbMap->prbMap[0].nBeamIndex = 0;
- pRbMap->prbMap[0].compMethod = XRAN_COMPMETHOD_NONE;
- }else {
- printf("UL: pRbMap ==NULL\n");
- exit(-1);
- }
-
- tx_play_buffer_position[flowId] += pXranConf->nDLRBs*N_SC_PER_PRB*4;
-
- if(tx_play_buffer_position[flowId] >= tx_play_buffer_size[flowId])
- tx_play_buffer_position[flowId] = 0;
- } else {
- //printf("flowId %d\n", flowId);
- }
- }
- }
-
- /* prach TX for RU only */
- if(startupConfiguration.appMode == APP_O_RU && startupConfiguration.enablePrach){
- for(ant_id = 0; ant_id < XRAN_MAX_ANTENNA_NR; ant_id++){
- for(sym_id = 0; sym_id < 1; sym_id++) {
- flowId = XRAN_MAX_ANTENNA_NR*cc_id + ant_id;
-
- if(p_tx_prach_play_buffer[flowId]){
- /* (0-79 slots) 10ms of IQs */
- pos = ((char*)p_tx_prach_play_buffer[flowId]);
-
- ptr = psBbuIo->sFHPrachRxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;
-
- if(ptr && pos){
- u32dptr = (uint32_t*)(ptr);
- rte_memcpy(u32dptr, pos, PRACH_PLAYBACK_BUFFER_BYTES);
-#ifdef DEBUG_XRAN_BUFFERS
- uint8_t *ptr_temp = (uint8_t *)ptr;
- ptr_temp[0] = tti; // TTI
- ptr_temp[1] = cc_id; // Sec
- ptr_temp[2] = ant_id; // Ant
- ptr_temp[3] = sym_id; // sym
-#endif
- } else {
- exit(-1);
- printf("ptr ==NULL\n");
- }
- } else {
- //printf("flowId %d\n", flowId);
- }
- }
- }
- }
- }
- }
-
- return 0;
-}
-
-void stop_xran(void)
-{
- xran_status_t status = 0;
- SWXRANInterfaceTypeEnum eInterfaceType;
-
- free(gpXranLibConfig);
- gpXranLibConfig = NULL;
-
- status += xran_mm_destroy(xranHandle)*2;
-
- if(XRAN_STATUS_SUCCESS != status)
- {
- printf("Failed at xran_mm_destroy, status %d\n",status);
- iAssert(status == XRAN_STATUS_SUCCESS);
- }
-}
-
-int get_xran_iq_content(void)
-{
- BbuXranIoIfStruct *psBbuIo = xran_get_ctx();
- xran_status_t status;
- int32_t nSectorIndex[XRAN_MAX_SECTOR_NR];
- int32_t nSectorNum;
- int32_t cc_id, ant_id, sym_id, tti;
- int32_t flowId;
-
- uint8_t frame_id = 0;
- uint8_t subframe_id = 0;
- uint8_t slot_id = 0;
- uint8_t sym = 0;
-
- void *ptr;
- uint32_t *u32dptr;
- uint16_t *u16dptr;
- uint8_t *u8dptr;
-
- char *pos = NULL;
-
- for (nSectorNum = 0; nSectorNum < XRAN_MAX_SECTOR_NR; nSectorNum++)
- {
- nSectorIndex[nSectorNum] = nSectorNum;
- }
- nSectorNum = numCCPorts;
- printf ("get_xran_iq_content\n");
-
- /* Init Memory */
- for(cc_id = 0; cc_id <nSectorNum; cc_id++)
- {
- for(tti = 0; tti < XRAN_N_FE_BUF_LEN; tti++) {
- for(ant_id = 0; ant_id < XRAN_MAX_ANTENNA_NR; ant_id++){
- for(sym_id = 0; sym_id < XRAN_NUM_OF_SYMBOL_PER_SLOT; sym_id++) {
- flowId = XRAN_MAX_ANTENNA_NR * cc_id + ant_id;
- if(p_rx_log_buffer[flowId]){
- /* (0-79 slots) 10ms of IQs */
- pos = ((char*)p_rx_log_buffer[flowId]) + rx_log_buffer_position[flowId];
- ptr = psBbuIo->sFrontHaulRxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;
- if(ptr){
- u32dptr = (uint32_t*)(ptr);
- rte_memcpy(pos, u32dptr, pXranConf->nULRBs*N_SC_PER_PRB*4);
-#ifdef DEBUG_XRAN_BUFFERS
- if (pos[0] != tti||
- pos[1] != cc_id ||
- pos[2] != ant_id ||
- pos[3] != sym_id){
- printf("[flowId %d] %d %d %d %d\n", flowId, pos[0], pos[1], pos[2], pos[3]);
- }
-#endif
- }else
- printf("ptr ==NULL\n");
-
- rx_log_buffer_position[flowId] += pXranConf->nULRBs*N_SC_PER_PRB*4;
-
- if(rx_log_buffer_position[flowId] >= rx_log_buffer_size[flowId])
- rx_log_buffer_position[flowId] = 0;
- } else {
- //printf("flowId %d\n", flowId);
- }
- }
-
- /* prach RX for O-DU only */
- if(startupConfiguration.appMode == APP_O_DU){
- flowId = XRAN_MAX_ANTENNA_NR * cc_id + ant_id;
- sym_id = 0;
-
- if(p_prach_log_buffer[flowId]){
- /* (0-79 slots) 10ms of IQs */
- pos = ((char*)p_prach_log_buffer[flowId]) + prach_log_buffer_position[flowId];
- ptr = psBbuIo->sFHPrachRxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;
- if(ptr){
- u32dptr = (uint32_t*)(ptr);
- rte_memcpy(pos, u32dptr, PRACH_PLAYBACK_BUFFER_BYTES);
-#ifdef DEBUG_XRAN_BUFFERS
- if (pos[0] != tti||
- pos[1] != cc_id ||
- pos[2] != ant_id ||
- pos[3] != sym_id){
- printf("[flowId %d] %d %d %d %d\n", flowId, pos[0], pos[1], pos[2], pos[3]);
- }
-#endif
- }else
- printf("ptr ==NULL\n");
-
- prach_log_buffer_position[flowId] += PRACH_PLAYBACK_BUFFER_BYTES;
-
- if(prach_log_buffer_position[flowId] >= prach_log_buffer_size[flowId])
- prach_log_buffer_position[flowId] = 0;
- } else {
- //printf("flowId %d\n", flowId);
- }
- }
-
- }
- }
- }
-
- return 0;
-}
-
-void version_print(void)
-{
- char sysversion[100];
- char *compilation_date = __DATE__;
- char *compilation_time = __TIME__;
-
- uint32_t nLen;
- uint32_t i;
-
- snprintf(sysversion, 99, "Version: %s", VERSIONX);
- nLen = strlen(sysversion);
-
- printf("\n\n");
- printf("===========================================================================================================\n");
- printf("SAMPLE-APP VERSION\n");
- printf("===========================================================================================================\n");
-
- printf("%s\n", sysversion);
- printf("build-date: %s\n", compilation_date);
- printf("build-time: %s\n", compilation_time);
-}
-
-int main(int argc, char *argv[])
-{
- int i;
- int j, len;
- int lcore_id = 0;
- char filename[64];
- uint32_t nCenterFreq;
- int32_t xret = 0;
- struct stat st = {0};
- uint32_t filenameLength = strlen(argv[1]);
- char *pCheckName1 = NULL, *pCheckName2 = NULL;
- enum xran_if_state xran_curr_if_state = XRAN_INIT;
-
- if (argc == 3)
- errx(2, "Need two argument - the PCI address of the network port");
- if (filenameLength >= 64)
- {
- printf("Config file name input is too long, exiting!\n");
- exit(-1);
- }
-
- version_print();
-
- //add for Klocworks
- len = strlen(argv[1]) + 1;
- if (len > (sizeof(filename) - 10))
- len = (sizeof(filename) - 10);
- strncpy(filename, argv[1], (sizeof(filename) - 10));
- filename[len] = '\0';
-
- pCheckName1 = strstr(filename, "config_file_o_du.dat");
- pCheckName2 = strstr(filename, "config_file_o_ru.dat");
- if ((pCheckName1 == NULL) && (pCheckName2 == NULL))
- {
- printf("config file name %s is not valid!\n", filename);
- exit(-1);
- }
-
- if (xran_is_synchronized() != 0)
- printf("Machine is not synchronized using PTP!\n");
- else
- printf("Machine is synchronized using PTP!\n");
-
- memset(&startupConfiguration, 0, sizeof(RuntimeConfig));
-
- if (parseConfigFile(filename, (RuntimeConfig*)&startupConfiguration) != 0) {
- printf("Configuration file error.\n");
- return 0;
- }
-
- if(startupConfiguration.ant_file[0] == NULL){
- printf("it looks like test vector for antennas were not provided\n");
- exit(-1);
- }
- if (startupConfiguration.numCC > XRAN_MAX_SECTOR_NR)
- {
- printf("Number of cells %d exceeds max number supported %d!\n", startupConfiguration.numCC, XRAN_MAX_SECTOR_NR);
- startupConfiguration.numCC = XRAN_MAX_SECTOR_NR;
-
- }
- numCCPorts = startupConfiguration.numCC;
- num_eAxc = startupConfiguration.numAxc;
-
- printf("numCCPorts %d num_eAxc%d\n", numCCPorts, num_eAxc);
-
- if (startupConfiguration.mu_number <= 1){
- nFpgaToSW_FTH_RxBufferLen = 13168; /* 273*12*4 + 64*/
- nFpgaToSW_PRACH_RxBufferLen = 8192;
- nSW_ToFpga_FTH_TxBufferLen = 13168; /* 273*12*4 + 64*/
- } else if (startupConfiguration.mu_number == 3){
- nFpgaToSW_FTH_RxBufferLen = 3328;
- nFpgaToSW_PRACH_RxBufferLen = 8192;
- nSW_ToFpga_FTH_TxBufferLen = 3328;
- } else {
- printf("given numerology is not supported %d\n", startupConfiguration.mu_number);
- exit(-1);
- }
-
- memset(&xranInit, 0, sizeof(struct xran_fh_init));
-
- if(startupConfiguration.appMode == APP_O_DU) {
- printf("set O-DU\n");
- xranInit.io_cfg.id = 0;//ID_LLS_CU;
- xranInit.io_cfg.core = 4+1;
- xranInit.io_cfg.system_core = 0;
- xranInit.io_cfg.pkt_proc_core = 4+2;
- xranInit.io_cfg.pkt_aux_core = 0; /* do not start*/
- xranInit.io_cfg.timing_core = 4+3;
- } else {
- printf("set O-DU\n");
- xranInit.io_cfg.id = 1; /* ID_LLS_CU;*/
- xranInit.io_cfg.core = 1;
- xranInit.io_cfg.system_core = 0;
- xranInit.io_cfg.pkt_proc_core = 2;
- xranInit.io_cfg.pkt_aux_core = 0; /* do not start */
- xranInit.io_cfg.timing_core = 3;
- }
-
- xranInit.io_cfg.bbdev_mode = XRAN_BBDEV_NOT_USED;
-
- xranInit.eAxCId_conf.mask_cuPortId = 0xf000;
- xranInit.eAxCId_conf.mask_bandSectorId = 0x0f00;
- xranInit.eAxCId_conf.mask_ccId = 0x00f0;
- xranInit.eAxCId_conf.mask_ruPortId = 0x000f;
- xranInit.eAxCId_conf.bit_cuPortId = 12;
- xranInit.eAxCId_conf.bit_bandSectorId = 8;
- xranInit.eAxCId_conf.bit_ccId = 4;
- xranInit.eAxCId_conf.bit_ruPortId = 0;
-
- xranInit.io_cfg.dpdk_dev[XRAN_UP_VF] = argv[2];
- xranInit.io_cfg.dpdk_dev[XRAN_CP_VF] = argv[3];
- xranInit.mtu = startupConfiguration.mtu;
-
- xranInit.p_o_du_addr = (int8_t*)&startupConfiguration.o_du_addr;
- xranInit.p_o_ru_addr = (int8_t*)&startupConfiguration.o_ru_addr;
- xranInit.filePrefix = "wls";
- xranInit.xranCat = XRAN_CATRGORY_A;
-
- xranInit.Tadv_cp_dl = startupConfiguration.Tadv_cp_dl;
- xranInit.T2a_min_cp_dl = startupConfiguration.T2a_min_cp_dl;
- xranInit.T2a_max_cp_dl = startupConfiguration.T2a_max_cp_dl;
- xranInit.T2a_min_cp_ul = startupConfiguration.T2a_min_cp_ul;
- xranInit.T2a_max_cp_ul = startupConfiguration.T2a_max_cp_ul;
- xranInit.T2a_min_up = startupConfiguration.T2a_min_up;
- xranInit.T2a_max_up = startupConfiguration.T2a_max_up;
- xranInit.Ta3_min = startupConfiguration.Ta3_min;
- xranInit.Ta3_max = startupConfiguration.Ta3_max;
- xranInit.T1a_min_cp_dl = startupConfiguration.T1a_min_cp_dl;
- xranInit.T1a_max_cp_dl = startupConfiguration.T1a_max_cp_dl;
- xranInit.T1a_min_cp_ul = startupConfiguration.T1a_min_cp_ul;
- xranInit.T1a_max_cp_ul = startupConfiguration.T1a_max_cp_ul;
- xranInit.T1a_min_up = startupConfiguration.T1a_min_up;
- xranInit.T1a_max_up = startupConfiguration.T1a_max_up;
- xranInit.Ta4_min = startupConfiguration.Ta4_min;
- xranInit.Ta4_max = startupConfiguration.Ta4_max;
-
- xranInit.enableCP = startupConfiguration.enableCP;
- xranInit.prachEnable = startupConfiguration.enablePrach;
- xranInit.debugStop = startupConfiguration.debugStop;
- xranInit.debugStopCount = startupConfiguration.debugStopCount;
- xranInit.DynamicSectionEna = startupConfiguration.DynamicSectionEna;
- xranInit.io_cfg.bbdev_mode = XRAN_BBDEV_NOT_USED; //startupConfiguration.bbdevMode;
-
- xranInit.cp_vlan_tag = startupConfiguration.cp_vlan_tag;
- xranInit.up_vlan_tag = startupConfiguration.up_vlan_tag;
-
- printf("IQ files size is %d slots\n", startupConfiguration.numSlots);
-
- iq_playback_buffer_size_dl = (startupConfiguration.numSlots * N_SYM_PER_SLOT * N_SC_PER_PRB *
- app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nDLBandwidth, startupConfiguration.nDLAbsFrePointA)
- *4L);
-
- iq_playback_buffer_size_ul = (startupConfiguration.numSlots * N_SYM_PER_SLOT * N_SC_PER_PRB *
- app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nULBandwidth, startupConfiguration.nULAbsFrePointA)
- *4L);
-
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
-
- p_tx_play_buffer[i] = (int16_t*)malloc(iq_playback_buffer_size_dl);
- tx_play_buffer_size[i] = (int32_t)iq_playback_buffer_size_dl;
-
- if (p_tx_play_buffer[i] == NULL)
- exit(-1);
-
- tx_play_buffer_size[i] = sys_load_file_to_buff(startupConfiguration.ant_file[i],
- "DL IFFT IN IQ Samples in binary format",
- (uint8_t*) p_tx_play_buffer[i],
- tx_play_buffer_size[i],
- 1);
- tx_play_buffer_position[i] = 0;
- }
-
- if (startupConfiguration.appMode == APP_O_RU && startupConfiguration.enablePrach){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- p_tx_prach_play_buffer[i] = (int16_t*)malloc(PRACH_PLAYBACK_BUFFER_BYTES);
- tx_prach_play_buffer_size[i] = (int32_t)PRACH_PLAYBACK_BUFFER_BYTES;
-
- if (p_tx_prach_play_buffer[i] == NULL)
- exit(-1);
-
- tx_prach_play_buffer_size[i] = sys_load_file_to_buff(startupConfiguration.prach_file[i],
- "PRACH IQ Samples in binary format",
- (uint8_t*) p_tx_prach_play_buffer[i],
- tx_prach_play_buffer_size[i],
- 1);
- tx_prach_play_buffer_position[i] = 0;
- }
- }
- /* log of ul */
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
-
- p_rx_log_buffer[i] = (int16_t*)malloc(iq_playback_buffer_size_ul);
- rx_log_buffer_size[i] = (int32_t)iq_playback_buffer_size_ul;
-
- if (p_rx_log_buffer[i] == NULL)
- exit(-1);
-
- rx_log_buffer_position[i] = 0;
-
- memset(p_rx_log_buffer[i], 0, rx_log_buffer_size[i]);
- }
-
- /* log of Prach */
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
-
- p_prach_log_buffer[i] = (int16_t*)malloc(startupConfiguration.numSlots*PRACH_PLAYBACK_BUFFER_BYTES);
- prach_log_buffer_size[i] = (int32_t)startupConfiguration.numSlots*PRACH_PLAYBACK_BUFFER_BYTES;
-
- if (p_prach_log_buffer[i] == NULL)
- exit(-1);
-
- memset(p_prach_log_buffer[i], 0, prach_log_buffer_size[i]);
- prach_log_buffer_position[i] = 0;
- }
-
- if (stat("./logs", &st) == -1) {
- mkdir("./logs", 0777);
- }
-
- for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
-
- sprintf(filename, "./logs/%s-play_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);
- sys_save_buf_to_file_txt(filename,
- "DL IFFT IN IQ Samples in human readable format",
- (uint8_t*) p_tx_play_buffer[i],
- tx_play_buffer_size[i],
- 1);
-
- sprintf(filename, "./logs/%s-play_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);
- sys_save_buf_to_file(filename,
- "DL IFFT IN IQ Samples in binary format",
- (uint8_t*) p_tx_play_buffer[i],
- tx_play_buffer_size[i]/sizeof(short),
- sizeof(short));
-
- if (startupConfiguration.appMode == APP_O_RU && startupConfiguration.enablePrach){
- sprintf(filename, "./logs/%s-play_prach_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);
- sys_save_buf_to_file_txt(filename,
- "DL IFFT IN IQ Samples in human readable format",
- (uint8_t*) p_tx_prach_play_buffer[i],
- tx_prach_play_buffer_size[i],
- 1);
-
- sprintf(filename, "./logs/%s-play_prach_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);
- sys_save_buf_to_file(filename,
- "DL IFFT IN IQ Samples in binary format",
- (uint8_t*) p_tx_prach_play_buffer[i],
- tx_prach_play_buffer_size[i]/sizeof(short),
- sizeof(short));
- }
- }
- if (startupConfiguration.iqswap == 1){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- printf("TX: Swap I and Q to match RU format: [%d]\n",i);
- {
- /* swap I and Q */
- int32_t j;
- signed short *ptr = (signed short *) p_tx_play_buffer[i];
- signed short temp;
-
- for (j = 0; j < (int32_t)(tx_play_buffer_size[i]/sizeof(short)) ; j = j + 2){
- temp = ptr[j];
- ptr[j] = ptr[j + 1];
- ptr[j + 1] = temp;
- }
- }
- }
- if (startupConfiguration.appMode == APP_O_RU){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- printf("PRACH: Swap I and Q to match RU format: [%d]\n",i);
- {
- /* swap I and Q */
- int32_t j;
- signed short *ptr = (signed short *) p_tx_prach_play_buffer[i];
- signed short temp;
-
- for (j = 0; j < (int32_t)(tx_prach_play_buffer_size[i]/sizeof(short)) ; j = j + 2){
- temp = ptr[j];
- ptr[j] = ptr[j + 1];
- ptr[j + 1] = temp;
- }
- }
- }
- }
-
- }
-
-#if 0
- for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
-
- sprintf(filename, "./logs/swap_IQ_play_ant%d.txt", i);
- sys_save_buf_to_file_txt(filename,
- "DL IFFT IN IQ Samples in human readable format",
- (uint8_t*) p_tx_play_buffer[i],
- tx_play_buffer_size[i],
- 1);
- }
-#endif
- if (startupConfiguration.nebyteorderswap == 1){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- printf("TX: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);
- for (j = 0; j < tx_play_buffer_size[i]/sizeof(short); j++){
- p_tx_play_buffer[i][j] = rte_cpu_to_be_16(p_tx_play_buffer[i][j]);
- }
- }
-
- if (startupConfiguration.appMode == APP_O_RU){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- printf("PRACH: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);
- for (j = 0; j < tx_prach_play_buffer_size[i]/sizeof(short); j++){
- p_tx_prach_play_buffer[i][j] = rte_cpu_to_be_16(p_tx_prach_play_buffer[i][j]);
- }
- }
- }
- }
-
-#if 0
- for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
-
- sprintf(filename, "./logs/swap_be_play_ant%d.txt", i);
- sys_save_buf_to_file_txt(filename,
- "DL IFFT IN IQ Samples in human readable format",
- (uint8_t*) p_tx_play_buffer[i],
- tx_play_buffer_size[i],
- 1);
- }
-#endif
-
-
- timer_set_tsc_freq_from_clock();
- xret = xran_init(argc, argv, &xranInit, argv[0], &xranHandle);
- if(xret != XRAN_STATUS_SUCCESS){
- printf("xran_init failed %d\n", xret);
- exit(-1);
- }
-
- if(xranHandle == NULL)
- exit(1);
-
- memset(&xranConf, 0, sizeof(struct xran_fh_config));
- pXranConf = &xranConf;
-
- pXranConf->sector_id = 0;
- pXranConf->nCC = numCCPorts;
- pXranConf->neAxc = num_eAxc;
-
- pXranConf->frame_conf.nFrameDuplexType = startupConfiguration.nFrameDuplexType;
- pXranConf->frame_conf.nNumerology = startupConfiguration.mu_number;
- pXranConf->frame_conf.nTddPeriod = startupConfiguration.nTddPeriod;
-
- for (i = 0; i < startupConfiguration.nTddPeriod; i++){
- pXranConf->frame_conf.sSlotConfig[i] = startupConfiguration.sSlotConfig[i];
- }
-
- pXranConf->prach_conf.nPrachSubcSpacing = startupConfiguration.mu_number;
- pXranConf->prach_conf.nPrachFreqStart = 0;
- pXranConf->prach_conf.nPrachFilterIdx = XRAN_FILTERINDEX_PRACH_ABC;
- pXranConf->prach_conf.nPrachConfIdx = startupConfiguration.prachConfigIndex;
- pXranConf->prach_conf.nPrachFreqOffset = -792;
-
- pXranConf->ru_conf.iqWidth = 16;
- pXranConf->ru_conf.compMeth = XRAN_COMPMETHOD_NONE;
- pXranConf->ru_conf.fftSize = 0;
- while (startupConfiguration.nULFftSize >>= 1)
- ++pXranConf->ru_conf.fftSize;
-
- pXranConf->ru_conf.byteOrder = (startupConfiguration.nebyteorderswap == 1) ? XRAN_NE_BE_BYTE_ORDER : XRAN_CPU_LE_BYTE_ORDER ;
- pXranConf->ru_conf.iqOrder = (startupConfiguration.iqswap == 1) ? XRAN_Q_I_ORDER : XRAN_I_Q_ORDER;
-
- printf("FFT Order %d\n", pXranConf->ru_conf.fftSize);
-
- pXranConf->nDLRBs = app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nDLBandwidth, startupConfiguration.nDLAbsFrePointA);
- pXranConf->nULRBs = app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nULBandwidth, startupConfiguration.nULAbsFrePointA);
-
- nCenterFreq = startupConfiguration.nDLAbsFrePointA + (((pXranConf->nDLRBs * N_SC_PER_PRB) / 2) * app_xran_get_scs(startupConfiguration.mu_number));
- pXranConf->nDLCenterFreqARFCN = app_xran_cal_nrarfcn(nCenterFreq);
- printf("DL center freq %d DL NR-ARFCN %d\n", nCenterFreq, pXranConf->nDLCenterFreqARFCN);
-
- nCenterFreq = startupConfiguration.nULAbsFrePointA + (((pXranConf->nULRBs * N_SC_PER_PRB) / 2) * app_xran_get_scs(startupConfiguration.mu_number));
- pXranConf->nULCenterFreqARFCN = app_xran_cal_nrarfcn(nCenterFreq);
- printf("UL center freq %d UL NR-ARFCN %d\n", nCenterFreq, pXranConf->nULCenterFreqARFCN);
-
- pXranConf->bbdev_dec = NULL;
- pXranConf->bbdev_enc = NULL;
-
- if(init_xran() != 0)
- exit(-1);
-
- xran_reg_physide_cb(xranHandle, physide_dl_tti_call_back, NULL, 10, XRAN_CB_TTI);
- xran_reg_physide_cb(xranHandle, physide_ul_half_slot_call_back, NULL, 10, XRAN_CB_HALF_SLOT_RX);
- xran_reg_physide_cb(xranHandle, physide_ul_full_slot_call_back, NULL, 10, XRAN_CB_FULL_SLOT_RX);
-
- init_xran_iq_content();
-
- xret = xran_open(xranHandle, pXranConf);
-
- if(xret != XRAN_STATUS_SUCCESS){
- printf("xran_open failed %d\n", xret);
- exit(-1);
- }
-
- sprintf(filename, "mlog-%s", startupConfiguration.appMode == 0 ? "o-du" : "o-ru");
-
-// MLogOpen(0, 32, 0, 0xFFFFFFFF, filename);
-
- MLogOpen(256, 3, 20000, 0xFFFFFFFF, filename);
-
- puts("----------------------------------------");
- printf("MLog Info: virt=0x%016lx size=%d\n", MLogGetFileLocation(), MLogGetFileSize());
- puts("----------------------------------------");
-
-
- uint64_t nActiveCoreMask[MAX_BBU_POOL_CORE_MASK] = {0};
- nActiveCoreMask[0] = 1 << xranInit.io_cfg.timing_core;
- uint32_t numCarriers = startupConfiguration.numCC;
-
- MLogAddTestCase(nActiveCoreMask, numCarriers);
-
- fcntl(0, F_SETFL, fcntl(0, F_GETFL) | O_NONBLOCK);
-
- state = APP_RUNNING;
- printf("Start XRAN traffic\n");
- xran_start(xranHandle);
- sleep(3);
- print_menu();
- for (;;) {
- struct xran_common_counters x_counters;
- char input[10];
- sleep(1);
- xran_curr_if_state = xran_get_if_state();
- if(xran_get_common_counters(xranHandle, &x_counters) == XRAN_STATUS_SUCCESS) {
- printf("rx %ld tx %ld [on_time %ld early %ld late %ld corrupt %ld pkt_dupl %ld Total %ld\n", rx_counter, tx_counter,
- x_counters.Rx_on_time,
- x_counters.Rx_early,
- x_counters.Rx_late,
- x_counters.Rx_corrupt,
- x_counters.Rx_pkt_dupl,
- x_counters.Total_msgs_rcvd);
- } else {
- printf("error xran_get_common_counters\n");
- }
-
- if (xran_curr_if_state == XRAN_STOPPED){
- break;
- }
- if (NULL == fgets(input, 10, stdin)) {
- continue;
- }
-
- const int sel_opt = atoi(input);
- switch (sel_opt) {
- case 1:
- xran_start(xranHandle);
- printf("Start XRAN traffic\n");
- break;
- case 2:
- break;
- case 3:
- xran_stop(xranHandle);
- printf("Stop XRAN traffic\n");
- state = APP_STOPPED;
- break;
- default:
- puts("Wrong option passed!");
- break;
- }
- if (APP_STOPPED == state)
- break;
- }
-
- get_xran_iq_content();
-
- puts("Closing l1 app... Ending all threads...");
- xran_close(xranHandle);
- MLogPrint(NULL);
-
- stop_xran();
- puts("Dump IQs...");
-
- if (startupConfiguration.iqswap == 1){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- printf("RX: Swap I and Q to match CPU format: [%d]\n",i);
- {
- /* swap I and Q */
- int32_t j;
- signed short *ptr = (signed short *) p_rx_log_buffer[i];
- signed short temp;
-
- for (j = 0; j < (int32_t)(rx_log_buffer_size[i]/sizeof(short)) ; j = j + 2){
- temp = ptr[j];
- ptr[j] = ptr[j + 1];
- ptr[j + 1] = temp;
- }
- }
- }
- }
-
- if (startupConfiguration.nebyteorderswap == 1){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- printf("RX: Convert S16 I and S16 Q to cpu byte order from XRAN Ant: [%d]\n",i);
- for (j = 0; j < rx_log_buffer_size[i]/sizeof(short); j++){
- p_rx_log_buffer[i][j] = rte_be_to_cpu_16(p_rx_log_buffer[i][j]);
- }
- }
- }
-
- for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
-
- sprintf(filename, "./logs/%s-rx_log_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);
- sys_save_buf_to_file_txt(filename,
- "UL FFT OUT IQ Samples in human readable format",
- (uint8_t*) p_rx_log_buffer[i],
- rx_log_buffer_size[i],
- 1);
-
- sprintf(filename, "./logs/%s-rx_log_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);
- sys_save_buf_to_file(filename,
- "UL FFT OUT IQ Samples in binary format",
- (uint8_t*) p_rx_log_buffer[i],
- rx_log_buffer_size[i]/sizeof(short),
- sizeof(short));
- }
-
- if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.enablePrach){
- if (startupConfiguration.iqswap == 1){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- printf("PRACH: Swap I and Q to match CPU format: [%d]\n",i);
- {
- /* swap I and Q */
- int32_t j;
- signed short *ptr = (signed short *) p_prach_log_buffer[i];
- signed short temp;
-
- for (j = 0; j < (int32_t)(prach_log_buffer_size[i]/sizeof(short)) ; j = j + 2){
- temp = ptr[j];
- ptr[j] = ptr[j + 1];
- ptr[j + 1] = temp;
- }
- }
- }
- }
-
-
- if (startupConfiguration.nebyteorderswap == 1){
- for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
- printf("PRACH: Convert S16 I and S16 Q to cpu byte order from XRAN Ant: [%d]\n",i);
- for (j = 0; j < prach_log_buffer_size[i]/sizeof(short); j++){
- p_prach_log_buffer[i][j] = rte_be_to_cpu_16(p_prach_log_buffer[i][j]);
- }
- }
- }
-
-
- for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {
-
- sprintf(filename, "./logs/%s-prach_log_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);
- sys_save_buf_to_file_txt(filename,
- "PRACH FFT OUT IQ Samples in human readable format",
- (uint8_t*) p_prach_log_buffer[i],
- prach_log_buffer_size[i],
- 1);
-
- sprintf(filename, "./logs/%s-prach_log_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);
- sys_save_buf_to_file(filename,
- "PRACH FFT OUT IQ Samples in binary format",
- (uint8_t*) p_prach_log_buffer[i],
- prach_log_buffer_size[i]/sizeof(short),
- sizeof(short));
- }
- }
-
- return 0;
-}
+/******************************************************************************\r
+*\r
+* Copyright (c) 2019 Intel.\r
+*\r
+* Licensed under the Apache License, Version 2.0 (the "License");\r
+* you may not use this file except in compliance with the License.\r
+* You may obtain a copy of the License at\r
+*\r
+* http://www.apache.org/licenses/LICENSE-2.0\r
+*\r
+* Unless required by applicable law or agreed to in writing, software\r
+* distributed under the License is distributed on an "AS IS" BASIS,\r
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+* See the License for the specific language governing permissions and\r
+* limitations under the License.\r
+*\r
+*******************************************************************************/\r
+\r
+#define _GNU_SOURCE\r
+#include <unistd.h>\r
+#include <sys/syscall.h>\r
+#include <sched.h>\r
+#include <assert.h>\r
+#include <err.h>\r
+#include <libgen.h>\r
+#include <sys/time.h>\r
+#include <time.h>\r
+#include <unistd.h>\r
+#include <stdio.h>\r
+#include <fcntl.h>\r
+#include <pthread.h>\r
+#include <sys/stat.h>\r
+#include <unistd.h>\r
+\r
+#include "common.h"\r
+#include "config.h"\r
+#include "xran_mlog_lnx.h"\r
+\r
+#include "xran_fh_o_du.h"\r
+#include "xran_compression.h"\r
+#include "xran_cp_api.h"\r
+#include "xran_sync_api.h"\r
+#include "xran_mlog_task_id.h"\r
+\r
+#define MAX_BBU_POOL_CORE_MASK (4)\r
+\r
+\r
+#define SW_FPGA_TOTAL_BUFFER_LEN 4*1024*1024*1024\r
+#define SW_FPGA_SEGMENT_BUFFER_LEN 1*1024*1024*1024\r
+#define SW_FPGA_FH_TOTAL_BUFFER_LEN 1*1024*1024*1024\r
+#define FPGA_TO_SW_PRACH_RX_BUFFER_LEN (8192)\r
+\r
+#define NSEC_PER_SEC 1000000000\r
+\r
+#define MAX_PKT_BURST (448+4) // 4x14x8\r
+#define N_MAX_BUFFER_SEGMENT MAX_PKT_BURST\r
+\r
+#define MAIN_PRIORITY 98\r
+#define NUM_OF_SUBFRAME_PER_FRAME (10)\r
+\r
+enum app_state state;\r
+\r
+uint64_t tick_per_usec;\r
+static volatile uint64_t timer_last_irq_tick = 0;\r
+static uint64_t tsc_resolution_hz = 0;\r
+\r
+RuntimeConfig startupConfiguration = {0};\r
+\r
+/* buffers size */\r
+uint32_t nFpgaToSW_FTH_RxBufferLen;\r
+uint32_t nFpgaToSW_PRACH_RxBufferLen;\r
+uint32_t nSW_ToFpga_FTH_TxBufferLen;\r
+\r
+static struct xran_fh_init xranInit;\r
+void * xranHandle = NULL;\r
+\r
+struct xran_fh_config xranConf;\r
+struct xran_fh_config *pXranConf = NULL;\r
+\r
+typedef struct\r
+{\r
+ uint32_t phaseFlag :1;\r
+ uint32_t NRARFCN :22;\r
+ uint32_t SULFreShift :1;\r
+ uint32_t SULFlag :1;\r
+ uint32_t rsv :7;\r
+}FPGAPhaseCompCfg;\r
+\r
+typedef struct XranLibConfig\r
+{\r
+ uint32_t nDriverCoreId;\r
+ uint32_t nTimingAdvance;\r
+ uint32_t nFhConfig;\r
+ uint32_t nFhBufIntFlag;\r
+ uint32_t nSectorNum;\r
+ uint32_t nNrOfSlotInSf;\r
+ uint32_t nNrofSfInFrame;\r
+ void * pFthInstanceHandles;\r
+}XranLibConfigStruct;\r
+typedef enum {\r
+ XRANFTHTX_OUT = 0,\r
+ XRANFTHTX_PRB_MAP_OUT,\r
+ XRANFTHTX_SEC_DESC_OUT,\r
+ XRANFTHRX_IN,\r
+ XRANFTHRX_PRB_MAP_IN,\r
+ XRANFTHTX_SEC_DESC_IN,\r
+ XRANFTHRACH_IN,\r
+ XRANSRS_IN,\r
+ MAX_SW_XRAN_INTERFACE_NUM\r
+}SWXRANInterfaceTypeEnum;\r
+\r
+/*\r
+ * manage one cell's all Ethernet frames for one DL or UL LTE subframe\r
+ */\r
+typedef struct {\r
+ /* -1-this subframe is not used in current frame format\r
+ 0-this subframe can be transmitted, i.e., data is ready\r
+ 1-this subframe is waiting transmission, i.e., data is not ready\r
+ 10 - DL transmission missing deadline. When FE needs this subframe data but bValid is still 1,\r
+ set bValid to 10.\r
+ */\r
+ int32_t bValid ; // when UL rx, it is subframe index.\r
+ int32_t nSegToBeGen;\r
+ int32_t nSegGenerated; // how many date segment are generated by DL LTE processing or received from FE\r
+ // -1 means that DL packet to be transmitted is not ready in BS\r
+ int32_t nSegTransferred; // number of data segments has been transmitted or received\r
+ struct rte_mbuf *pData[N_MAX_BUFFER_SEGMENT]; // point to DPDK allocated memory pool\r
+ struct xran_buffer_list sBufferList;\r
+} BbuIoBufCtrlStruct;\r
+\r
+typedef struct {\r
+ uint64_t nCoreMask;\r
+ int16_t cpuSocketId;\r
+ uint8_t nDriverCoreId;\r
+ uint8_t nFHCoreId;\r
+\r
+ struct rte_mempool *bbuio_buf_pool;\r
+\r
+ /* io struct */\r
+ BbuIoBufCtrlStruct sFrontHaulTxBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];\r
+ BbuIoBufCtrlStruct sFrontHaulTxPrbMapBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];\r
+ BbuIoBufCtrlStruct sFrontHaulRxBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];\r
+ BbuIoBufCtrlStruct sFrontHaulRxPrbMapBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];\r
+ BbuIoBufCtrlStruct sFHPrachRxBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];\r
+\r
+ /* Cat B */\r
+ BbuIoBufCtrlStruct sFHSrsRxBbuIoBufCtrl[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANT_ARRAY_ELM_NR];\r
+\r
+ /* buffers lists */\r
+ struct xran_flat_buffer sFrontHaulTxBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_NUM_OF_SYMBOL_PER_SLOT];\r
+ struct xran_flat_buffer sFrontHaulTxPrbMapBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];\r
+ struct xran_flat_buffer sFrontHaulRxBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_NUM_OF_SYMBOL_PER_SLOT];\r
+ struct xran_flat_buffer sFrontHaulRxPrbMapBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR];\r
+ struct xran_flat_buffer sFHPrachRxBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_NUM_OF_SYMBOL_PER_SLOT];\r
+\r
+ /* Cat B SRS buffers */\r
+ struct xran_flat_buffer sFHSrsRxBuffers[XRAN_N_FE_BUF_LEN][XRAN_MAX_SECTOR_NR][XRAN_MAX_ANT_ARRAY_ELM_NR][XRAN_MAX_NUM_OF_SRS_SYMBOL_PER_SLOT];\r
+\r
+ void* nInstanceHandle[XRAN_PORTS_NUM][XRAN_MAX_SECTOR_NR]; // instance per sector\r
+ uint32_t nBufPoolIndex[XRAN_MAX_SECTOR_NR][MAX_SW_XRAN_INTERFACE_NUM]; // every api owns unique buffer pool\r
+ uint16_t nInstanceNum;\r
+\r
+ uint64_t nTscTiming[XRAN_N_FE_BUF_LEN]; // records the TSC when a timing packet is received.\r
+} BbuXranIoIfStruct;\r
+\r
+static BbuXranIoIfStruct gsXranIoIf;\r
+static XranLibConfigStruct *gpXranLibConfig = NULL;\r
+\r
+extern long rx_counter;\r
+extern long tx_counter;\r
+extern long tx_bytes_counter;\r
+extern long rx_bytes_counter;\r
+extern long tx_bytes_per_sec;\r
+extern long rx_bytes_per_sec;\r
+long old_rx_counter = 0;\r
+long old_tx_counter = 0;\r
+\r
+\r
+\r
+#define CPU_HZ tick_per_usec //us\r
+\r
+/* Application User space functions */\r
+void xran_fh_rx_callback(void *pCallbackTag, int32_t status);\r
+void xran_fh_rx_prach_callback(void *pCallbackTag, int32_t status);\r
+\r
+static BbuXranIoIfStruct *xran_get_ctx(void)\r
+{\r
+ return &gsXranIoIf;\r
+}\r
+\r
+static void print_menu()\r
+{\r
+ puts("+---------------------------------------+");\r
+ puts("| Press 1 to start 5G NR XRAN traffic |");\r
+ puts("| Press 2 reserved for future use |");\r
+ puts("| Press 3 to quit |");\r
+ puts("+---------------------------------------+");\r
+}\r
+\r
+static int32_t get_xran_sfidx(uint8_t nNrOfSlotInSf)\r
+{\r
+ int32_t nSfIdx = -1;\r
+ uint32_t nFrameIdx;\r
+ uint32_t nSubframeIdx;\r
+ uint32_t nSlotIdx;\r
+ uint64_t nSecond;\r
+\r
+ uint32_t nXranTime = xran_get_slot_idx(&nFrameIdx, &nSubframeIdx, &nSlotIdx, &nSecond);\r
+ nSfIdx = nFrameIdx*NUM_OF_SUBFRAME_PER_FRAME*nNrOfSlotInSf\r
+ + nSubframeIdx*nNrOfSlotInSf\r
+ + nSlotIdx;\r
+#if 0\r
+ printf("\nxranTime is %d, return is %d, radio frame is %d, subframe is %d slot is %d tsc is %llu us",\r
+ nXranTime,\r
+ nSfIdx,\r
+ nFrameIdx,\r
+ nSubframeIdx,\r
+ nSlotIdx,\r
+ __rdtsc()/CPU_HZ);\r
+#endif\r
+\r
+ return nSfIdx;\r
+}\r
+\r
+void xran_fh_rx_callback(void *pCallbackTag, xran_status_t status)\r
+{\r
+ uint64_t t1 = MLogTick();\r
+ uint32_t mlogVar[10];\r
+ uint32_t mlogVarCnt = 0;\r
+ uint8_t Numerlogy = xranConf.frame_conf.nNumerology;\r
+ uint8_t nNrOfSlotInSf = 1<<Numerlogy;\r
+ int32_t sfIdx = get_xran_sfidx(nNrOfSlotInSf);\r
+\r
+ mlogVar[mlogVarCnt++] = 0xCCCCCCCC;\r
+ mlogVar[mlogVarCnt++] = status >> 16; /* tti */\r
+ mlogVar[mlogVarCnt++] = status & 0xFF; /* sym */\r
+ mlogVar[mlogVarCnt++] = (uint32_t)sfIdx;\r
+ MLogAddVariables(mlogVarCnt, mlogVar, MLogTick());\r
+ rte_pause();\r
+\r
+ MLogTask(PID_GNB_SYM_CB, t1, MLogTick());\r
+ return;\r
+}\r
+\r
+void xran_fh_rx_prach_callback(void *pCallbackTag, xran_status_t status)\r
+{\r
+ uint64_t t1 = MLogTick();\r
+ uint32_t mlogVar[10];\r
+ uint32_t mlogVarCnt = 0;\r
+\r
+ mlogVar[mlogVarCnt++] = 0xDDDDDDDD;\r
+ mlogVar[mlogVarCnt++] = status >> 16; /* tti */\r
+ mlogVar[mlogVarCnt++] = status & 0xFF; /* sym */\r
+ MLogAddVariables(mlogVarCnt, mlogVar, MLogTick());\r
+ rte_pause();\r
+\r
+ MLogTask(PID_GNB_PRACH_CB, t1, MLogTick());\r
+}\r
+\r
+void xran_fh_rx_srs_callback(void *pCallbackTag, xran_status_t status)\r
+{\r
+ uint64_t t1 = MLogTick();\r
+ uint32_t mlogVar[10];\r
+ uint32_t mlogVarCnt = 0;\r
+\r
+ mlogVar[mlogVarCnt++] = 0xCCCCCCCC;\r
+ mlogVar[mlogVarCnt++] = status >> 16; /* tti */\r
+ mlogVar[mlogVarCnt++] = status & 0xFF; /* sym */\r
+ MLogAddVariables(mlogVarCnt, mlogVar, MLogTick());\r
+ rte_pause();\r
+\r
+ MLogTask(PID_GNB_SRS_CB, t1, MLogTick());\r
+}\r
+\r
+\r
+//-------------------------------------------------------------------------------------------\r
+/** @ingroup group_nbiot_source_auxlib_timer\r
+ *\r
+ * @param void\r
+ *\r
+ * @return Ticks\r
+ *\r
+ * @description\r
+ * This function reads the rtdsc clock and returns the current value in there.\r
+ *\r
+**/\r
+//-------------------------------------------------------------------------------------------\r
+unsigned long timer_get_ticks(void)\r
+{\r
+ unsigned long ret;\r
+ union\r
+ {\r
+ unsigned long tsc_64;\r
+ struct\r
+ {\r
+ uint32_t lo_32;\r
+ uint32_t hi_32;\r
+ };\r
+ } tsc;\r
+\r
+ __asm volatile("rdtsc" :\r
+ "=a" (tsc.lo_32),\r
+ "=d" (tsc.hi_32));\r
+\r
+ ret = ((unsigned long)tsc.tsc_64);\r
+ return ret;\r
+}\r
+\r
+//-------------------------------------------------------------------------------------------\r
+/** @ingroup group_lte_source_auxlib_timer\r
+ *\r
+ * @param void\r
+ *\r
+ * @return 0 if SUCCESS\r
+ *\r
+ * @description\r
+ * This function gets the clock speed of the core and figures out number of ticks per usec.\r
+ * It is used by l1app and testmac applications to initialize the mlog utility\r
+ *\r
+**/\r
+//-------------------------------------------------------------------------------------------\r
+int timer_set_tsc_freq_from_clock(void)\r
+{\r
+#define NS_PER_SEC 1E9\r
+ struct timespec sleeptime = {.tv_nsec = 5E8 }; /* 1/2 second */\r
+ struct timespec t_start, t_end;\r
+ uint64_t tsc_resolution_hz = 0;\r
+\r
+ if (clock_gettime(CLOCK_MONOTONIC_RAW, &t_start) == 0)\r
+ {\r
+ unsigned long ns, end, start = timer_get_ticks();\r
+ nanosleep(&sleeptime,NULL);\r
+ clock_gettime(CLOCK_MONOTONIC_RAW, &t_end);\r
+ end = timer_get_ticks();\r
+ ns = ((t_end.tv_sec - t_start.tv_sec) * NS_PER_SEC);\r
+ ns += (t_end.tv_nsec - t_start.tv_nsec);\r
+\r
+ double secs = (double)ns/NS_PER_SEC;\r
+ tsc_resolution_hz = (unsigned long)((end - start)/secs);\r
+\r
+ tick_per_usec = (tsc_resolution_hz / 1000000);\r
+ printf("System clock (rdtsc) resolution %lu [Hz]\n", tsc_resolution_hz);\r
+ printf("Ticks per us %lu\n", tick_per_usec);\r
+ return 0;\r
+ }\r
+\r
+ return -1;\r
+}\r
+\r
+int physide_dl_tti_call_back(void * param)\r
+{\r
+ uint64_t t1 = MLogTick();\r
+ rte_pause();\r
+ MLogTask(PID_GNB_PROC_TIMING, t1, MLogTick());\r
+ return 0;\r
+}\r
+\r
+int physide_ul_half_slot_call_back(void * param)\r
+{\r
+ uint64_t t1 = MLogTick();\r
+ rte_pause();\r
+ MLogTask(PID_GNB_PROC_TIMING, t1, MLogTick());\r
+ return 0;\r
+}\r
+\r
+int physide_ul_full_slot_call_back(void * param)\r
+{\r
+ uint64_t t1 = MLogTick();\r
+ rte_pause();\r
+ MLogTask(PID_GNB_PROC_TIMING, t1, MLogTick());\r
+ return 0;\r
+}\r
+\r
+int32_t init_xran(void)\r
+{\r
+ BbuXranIoIfStruct *psBbuIo = xran_get_ctx();\r
+ xran_status_t status;\r
+ int32_t nSectorIndex[XRAN_MAX_SECTOR_NR];\r
+ int32_t nSectorNum;\r
+ int32_t i, j, k, z;\r
+\r
+ void *ptr;\r
+ void *mb;\r
+ uint32_t *u32dptr;\r
+ uint16_t *u16dptr;\r
+ uint8_t *u8dptr;\r
+\r
+ SWXRANInterfaceTypeEnum eInterfaceType;\r
+\r
+ XranLibConfigStruct *ptrLibConfig;\r
+\r
+ struct xran_buffer_list *pFthTxBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];\r
+ struct xran_buffer_list *pFthTxPrbMapBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];\r
+ struct xran_buffer_list *pFthRxBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];\r
+ struct xran_buffer_list *pFthRxPrbMapBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];\r
+ struct xran_buffer_list *pFthRxRachBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANTENNA_NR][XRAN_N_FE_BUF_LEN];\r
+ struct xran_buffer_list *pFthRxSrsBuffer[XRAN_MAX_SECTOR_NR][XRAN_MAX_ANT_ARRAY_ELM_NR][XRAN_N_FE_BUF_LEN];\r
+\r
+ for (nSectorNum = 0; nSectorNum < XRAN_MAX_SECTOR_NR; nSectorNum++)\r
+ {\r
+ nSectorIndex[nSectorNum] = nSectorNum;\r
+ }\r
+\r
+ nSectorNum = numCCPorts;\r
+ printf ("XRAN front haul xran_mm_init \n");\r
+ status = xran_mm_init (xranHandle, (uint64_t) SW_FPGA_FH_TOTAL_BUFFER_LEN, SW_FPGA_SEGMENT_BUFFER_LEN);\r
+ if (status != XRAN_STATUS_SUCCESS)\r
+ {\r
+ printf ("Failed at XRAN front haul xran_mm_init \n");\r
+ exit(-1);\r
+ }\r
+\r
+ psBbuIo->nInstanceNum = numCCPorts;\r
+\r
+ for (k = 0; k < XRAN_PORTS_NUM; k++) {\r
+ status = xran_sector_get_instances (xranHandle, psBbuIo->nInstanceNum,&psBbuIo->nInstanceHandle[k][0]);\r
+ if (status != XRAN_STATUS_SUCCESS)\r
+ {\r
+ printf ("get sector instance failed %d for XRAN nInstanceNum %d\n",k, psBbuIo->nInstanceNum);\r
+ exit(-1);\r
+ }\r
+ for (i = 0; i < psBbuIo->nInstanceNum; i++){\r
+ printf("%s [%d]: CC %d handle %p\n", __FUNCTION__, k, i, psBbuIo->nInstanceHandle[0][i]);\r
+ }\r
+ }\r
+\r
+ printf("Sucess xran_mm_init \n");\r
+ gpXranLibConfig = (XranLibConfigStruct*)malloc(sizeof(XranLibConfigStruct));\r
+ ptrLibConfig = gpXranLibConfig;\r
+ if (ptrLibConfig)\r
+ {\r
+ #if 0\r
+ ptrLibConfig->nDriverCoreId = psBbuIo->nDriverCoreId;\r
+ ptrLibConfig->pFecInstanceHandles = &(psBbuIo->nInstanceHandle[FPGA_FEC][0]);\r
+ ptrLibConfig->pFthInstanceHandles = &(psBbuIo->nInstanceHandle[FPGA_FRONTHAUL][0]);\r
+ ptrLibConfig->nTimingAdvance = psFPGAInitPara->nTimeAdvance;\r
+ ptrLibConfig->nFhConfig = psFPGAInitPara->nEthPorts;\r
+ ptrLibConfig->nFhBufIntFlag = 0; //need init fronthaul buffer, then set to 1.\r
+ ptrLibConfig->nNrofSfInFrame = NUM_OF_SUBFRAME_PER_FRAME;\r
+ ptrLibConfig->nNrOfSlotInSf = pConfigParams->nNumOfSlotPerSubframe;\r
+ if (pConfigParams->nNumerology < 3)\r
+ {\r
+ ptrLibConfig->nSectorNum = psFPGAInitPara->nSecNum;\r
+ }\r
+ #endif\r
+ }\r
+ else\r
+ {\r
+ printf ("could not allocate ptrLibConfig in init_xran\n");\r
+ exit(-1);\r
+ }\r
+\r
+ printf("nSectorNum %d\n", nSectorNum);\r
+\r
+ /* Init Memory */\r
+ for(i = 0; i<nSectorNum; i++)\r
+ {\r
+ eInterfaceType = XRANFTHTX_OUT;\r
+ printf("nSectorIndex[%d] = %d\n",i, nSectorIndex[i]);\r
+ status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],\r
+ XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, nSW_ToFpga_FTH_TxBufferLen);\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_init , status %d\n", status);\r
+ }\r
+ for(j = 0; j < XRAN_N_FE_BUF_LEN; j++)\r
+ {\r
+ for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].bValid = 0;\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].nSegGenerated = -1;\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].nSegTransferred = 0;\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_NUM_OF_SYMBOL_PER_SLOT;\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFrontHaulTxBuffers[j][i][z][0];\r
+\r
+ for(k = 0; k < XRAN_NUM_OF_SYMBOL_PER_SLOT; k++)\r
+ {\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nElementLenInBytes = nSW_ToFpga_FTH_TxBufferLen; // 14 symbols 3200bytes/symbol\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nNumberOfElements = 1;\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nOffsetInBytes = 0;\r
+ status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i], psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);\r
+ if(XRAN_STATUS_SUCCESS != status){\r
+ rte_panic("Failed at xran_bm_allocate_buffer , status %d\n",status);\r
+ }\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pData = (uint8_t *)ptr;\r
+ psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pCtrl = (void *)mb;\r
+\r
+ if(ptr){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ uint8_t *ptr_temp = (uint8_t *)ptr;\r
+ memset(u32dptr, 0x0, nSW_ToFpga_FTH_TxBufferLen);\r
+ // ptr_temp[0] = j; // TTI\r
+ // ptr_temp[1] = i; // Sec\r
+ // ptr_temp[2] = z; // Ant\r
+ // ptr_temp[3] = k; // sym\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ /* C-plane DL */\r
+ eInterfaceType = XRANFTHTX_SEC_DESC_OUT;\r
+ status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],\r
+ XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT*XRAN_MAX_SECTIONS_PER_SYM, sizeof(struct xran_section_desc));\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_init , status %d\n", status);\r
+ }\r
+\r
+ eInterfaceType = XRANFTHTX_PRB_MAP_OUT;\r
+ status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],\r
+ XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, sizeof(struct xran_prb_map));\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_init , status %d\n", status);\r
+ }\r
+\r
+ for(j = 0; j < XRAN_N_FE_BUF_LEN; j++)\r
+ {\r
+ for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].bValid = 0;\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].nSegGenerated = -1;\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].nSegTransferred = 0;\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_NUM_OF_SYMBOL_PER_SLOT;\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFrontHaulTxPrbMapBuffers[j][i][z];\r
+\r
+ {\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nElementLenInBytes = sizeof(struct xran_prb_map);\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nNumberOfElements = 1;\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nOffsetInBytes = 0;\r
+ status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i], psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_allocate_buffer , status %d\n",status);\r
+ }\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->pData = (uint8_t *)ptr;\r
+ psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->pCtrl = (void *)mb;\r
+\r
+ if(ptr){\r
+ void *sd_ptr;\r
+ void *sd_mb;\r
+ int elm_id;\r
+ struct xran_prb_map * p_rb_map = (struct xran_prb_map *)ptr;\r
+ if (startupConfiguration.appMode == APP_O_DU)\r
+ memcpy(ptr, &startupConfiguration.PrbMapDl, sizeof(struct xran_prb_map));\r
+ else\r
+ memcpy(ptr, &startupConfiguration.PrbMapUl, sizeof(struct xran_prb_map));\r
+\r
+ for (elm_id = 0; elm_id < p_rb_map->nPrbElm; elm_id++){\r
+ struct xran_prb_elm *pPrbElem = &p_rb_map->prbMap[elm_id];\r
+ for(k = 0; k < XRAN_NUM_OF_SYMBOL_PER_SLOT; k++){\r
+ status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i], psBbuIo->nBufPoolIndex[nSectorIndex[i]][XRANFTHTX_SEC_DESC_OUT],&sd_ptr, &sd_mb);\r
+ if(XRAN_STATUS_SUCCESS != status){\r
+ rte_panic("SD Failed at xran_bm_allocate_buffer , status %d\n",status);\r
+ }\r
+ pPrbElem->p_sec_desc[k] = sd_ptr;\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ for(i = 0; i<nSectorNum; i++)\r
+ {\r
+ eInterfaceType = XRANFTHRX_IN;\r
+ status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType], XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, nSW_ToFpga_FTH_TxBufferLen);\r
+ if(XRAN_STATUS_SUCCESS != status)\r
+ {\r
+ printf("Failed at xran_bm_init, status %d\n", status);\r
+ iAssert(status == XRAN_STATUS_SUCCESS);\r
+ }\r
+\r
+ for(j = 0;j < XRAN_N_FE_BUF_LEN; j++)\r
+ {\r
+ for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].bValid = 0;\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].nSegGenerated = -1;\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].nSegTransferred = 0;\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_NUM_OF_SYMBOL_PER_SLOT;\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFrontHaulRxBuffers[j][i][z][0];\r
+ for(k = 0; k< XRAN_NUM_OF_SYMBOL_PER_SLOT; k++)\r
+ {\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nElementLenInBytes = nFpgaToSW_FTH_RxBufferLen; // 1 symbols 3200bytes\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nNumberOfElements = 1;\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nOffsetInBytes = 0;\r
+ status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i],psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_allocate_buffer , status %d\n",status);\r
+ }\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pData = (uint8_t *)ptr;\r
+ psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pCtrl = (void *) mb;\r
+ if(ptr){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ uint8_t *ptr_temp = (uint8_t *)ptr;\r
+ memset(u32dptr, 0x0, nFpgaToSW_FTH_RxBufferLen);\r
+ // ptr_temp[0] = j; // TTI\r
+ // ptr_temp[1] = i; // Sec\r
+ // ptr_temp[2] = z; // Ant\r
+ // ptr_temp[3] = k; // sym\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ /* C-plane */\r
+ eInterfaceType = XRANFTHTX_SEC_DESC_IN;\r
+ status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],\r
+ XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT*XRAN_MAX_SECTIONS_PER_SYM, sizeof(struct xran_section_desc));\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_init , status %d\n", status);\r
+ }\r
+ eInterfaceType = XRANFTHRX_PRB_MAP_IN;\r
+ status = xran_bm_init(psBbuIo->nInstanceHandle[0][i], &psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],\r
+ XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, sizeof(struct xran_prb_map));\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_init, status %d\n", status);\r
+ }\r
+\r
+ for(j = 0;j < XRAN_N_FE_BUF_LEN; j++) {\r
+ for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].bValid = 0;\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].nSegGenerated = -1;\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].nSegTransferred = 0;\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_NUM_OF_SYMBOL_PER_SLOT;\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFrontHaulRxPrbMapBuffers[j][i][z];\r
+ {\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nElementLenInBytes = sizeof(struct xran_prb_map);\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nNumberOfElements = 1;\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->nOffsetInBytes = 0;\r
+ status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i],psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_allocate_buffer , status %d\n",status);\r
+ }\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->pData = (uint8_t *)ptr;\r
+ psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList.pBuffers->pCtrl = (void *)mb;\r
+ if(ptr){\r
+ void *sd_ptr;\r
+ void *sd_mb;\r
+ int elm_id;\r
+ struct xran_prb_map * p_rb_map = (struct xran_prb_map *)ptr;\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU)\r
+ memcpy(ptr, &startupConfiguration.PrbMapUl, sizeof(struct xran_prb_map));\r
+ else\r
+ memcpy(ptr, &startupConfiguration.PrbMapDl, sizeof(struct xran_prb_map));\r
+\r
+ for (elm_id = 0; elm_id < p_rb_map->nPrbElm; elm_id++){\r
+ struct xran_prb_elm *pPrbElem = &p_rb_map->prbMap[elm_id];\r
+ for(k = 0; k < XRAN_NUM_OF_SYMBOL_PER_SLOT; k++){\r
+ status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i], psBbuIo->nBufPoolIndex[nSectorIndex[i]][XRANFTHTX_SEC_DESC_IN],&sd_ptr, &sd_mb);\r
+ if(XRAN_STATUS_SUCCESS != status){\r
+ rte_panic("SD Failed at xran_bm_allocate_buffer , status %d\n",status);\r
+ }\r
+ pPrbElem->p_sec_desc[k] = sd_ptr;\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+\r
+ // add prach rx buffer\r
+ for(i = 0; i<nSectorNum; i++)\r
+ {\r
+ eInterfaceType = XRANFTHRACH_IN;\r
+ status = xran_bm_init(psBbuIo->nInstanceHandle[0][i],&psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],XRAN_N_FE_BUF_LEN*XRAN_MAX_ANTENNA_NR*XRAN_NUM_OF_SYMBOL_PER_SLOT, FPGA_TO_SW_PRACH_RX_BUFFER_LEN);\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_init, status %d\n", status);\r
+ }\r
+ for(j = 0;j < XRAN_N_FE_BUF_LEN; j++)\r
+ {\r
+ for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].bValid = 0;\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].nSegGenerated = -1;\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].nSegTransferred = 0;\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_MAX_ANTENNA_NR; // ant number.\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFHPrachRxBuffers[j][i][z][0];\r
+ for(k = 0; k< XRAN_NUM_OF_SYMBOL_PER_SLOT; k++)\r
+ {\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nElementLenInBytes = FPGA_TO_SW_PRACH_RX_BUFFER_LEN;\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nNumberOfElements = 1;\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nOffsetInBytes = 0;\r
+ status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i],psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_allocate_buffer, status %d\n",status);\r
+ }\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pData = (uint8_t *)ptr;\r
+ psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pCtrl = (void *)mb;\r
+ if(ptr){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ memset(u32dptr, 0x0, FPGA_TO_SW_PRACH_RX_BUFFER_LEN);\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ /* add SRS rx buffer */\r
+ for(i = 0; i<nSectorNum; i++)\r
+ {\r
+ eInterfaceType = XRANSRS_IN;\r
+ status = xran_bm_init(psBbuIo->nInstanceHandle[0][i],&psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],\r
+ XRAN_N_FE_BUF_LEN*XRAN_MAX_ANT_ARRAY_ELM_NR*XRAN_MAX_NUM_OF_SRS_SYMBOL_PER_SLOT, nSW_ToFpga_FTH_TxBufferLen);\r
+\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_init, status %d\n", status);\r
+ }\r
+ for(j = 0; j < XRAN_N_FE_BUF_LEN; j++)\r
+ {\r
+ for(z = 0; z < XRAN_MAX_ANT_ARRAY_ELM_NR; z++){\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].bValid = 0;\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].nSegGenerated = -1;\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].nSegToBeGen = -1;\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].nSegTransferred = 0;\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].sBufferList.nNumBuffers = XRAN_MAX_ANT_ARRAY_ELM_NR; /* ant number */\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers = &psBbuIo->sFHSrsRxBuffers[j][i][z][0];\r
+ for(k = 0; k < XRAN_MAX_NUM_OF_SRS_SYMBOL_PER_SLOT; k++)\r
+ {\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nElementLenInBytes = nSW_ToFpga_FTH_TxBufferLen;\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nNumberOfElements = 1;\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].nOffsetInBytes = 0;\r
+ status = xran_bm_allocate_buffer(psBbuIo->nInstanceHandle[0][i],psBbuIo->nBufPoolIndex[nSectorIndex[i]][eInterfaceType],&ptr, &mb);\r
+ if(XRAN_STATUS_SUCCESS != status) {\r
+ rte_panic("Failed at xran_bm_allocate_buffer, status %d\n",status);\r
+ }\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pData = (uint8_t *)ptr;\r
+ psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].sBufferList.pBuffers[k].pCtrl = (void *)mb;\r
+ if(ptr){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ memset(u32dptr, 0x0, nSW_ToFpga_FTH_TxBufferLen);\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+\r
+ for(i=0; i<nSectorNum; i++)\r
+ {\r
+ for(j=0; j<XRAN_N_FE_BUF_LEN; j++)\r
+ {\r
+ for(z = 0; z < XRAN_MAX_ANTENNA_NR; z++){\r
+ pFthTxBuffer[i][z][j] = &(psBbuIo->sFrontHaulTxBbuIoBufCtrl[j][i][z].sBufferList);\r
+ pFthTxPrbMapBuffer[i][z][j] = &(psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[j][i][z].sBufferList);\r
+ pFthRxBuffer[i][z][j] = &(psBbuIo->sFrontHaulRxBbuIoBufCtrl[j][i][z].sBufferList);\r
+ pFthRxPrbMapBuffer[i][z][j] = &(psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[j][i][z].sBufferList);\r
+ pFthRxRachBuffer[i][z][j] = &(psBbuIo->sFHPrachRxBbuIoBufCtrl[j][i][z].sBufferList);\r
+ }\r
+\r
+ for(z = 0; z < XRAN_MAX_ANT_ARRAY_ELM_NR; z++){\r
+ pFthRxSrsBuffer[i][z][j] = &(psBbuIo->sFHSrsRxBbuIoBufCtrl[j][i][z].sBufferList);\r
+ }\r
+ }\r
+ }\r
+\r
+ if(NULL != psBbuIo->nInstanceHandle[0])\r
+ {\r
+ /* add pusch callback */\r
+ for (i = 0; i<nSectorNum; i++)\r
+ {\r
+ xran_5g_fronthault_config (psBbuIo->nInstanceHandle[0][i],\r
+ pFthTxBuffer[i],\r
+ pFthTxPrbMapBuffer[i],\r
+ pFthRxBuffer[i],\r
+ pFthRxPrbMapBuffer[i],\r
+ xran_fh_rx_callback, &pFthRxBuffer[i][0]);\r
+ }\r
+\r
+ /* add prach callback here */\r
+ for (i = 0; i<nSectorNum; i++)\r
+ {\r
+ xran_5g_prach_req(psBbuIo->nInstanceHandle[0][i], pFthRxRachBuffer[i],\r
+ xran_fh_rx_prach_callback,&pFthRxRachBuffer[i][0]);\r
+ }\r
+\r
+ /* add SRS callback here */\r
+ for (i = 0; i<nSectorNum; i++) {\r
+ xran_5g_srs_req(psBbuIo->nInstanceHandle[0][i], pFthRxSrsBuffer[i],\r
+ xran_fh_rx_srs_callback,&pFthRxSrsBuffer[i][0]);\r
+ }\r
+\r
+ ptrLibConfig->nFhBufIntFlag = 1;\r
+ }\r
+\r
+ return status;\r
+}\r
+\r
+int init_xran_iq_content(void)\r
+{\r
+ BbuXranIoIfStruct *psBbuIo = xran_get_ctx();\r
+ xran_status_t status;\r
+ int32_t nSectorIndex[XRAN_MAX_SECTOR_NR];\r
+ int32_t nSectorNum;\r
+ int32_t cc_id, ant_id, sym_id, tti;\r
+ int32_t flowId;\r
+\r
+ uint8_t frame_id = 0;\r
+ uint8_t subframe_id = 0;\r
+ uint8_t slot_id = 0;\r
+ uint8_t sym = 0;\r
+\r
+ void *ptr;\r
+ uint32_t *u32dptr;\r
+ uint16_t *u16dptr;\r
+ uint8_t *u8dptr;\r
+\r
+ char *pos = NULL;\r
+ struct xran_prb_map *pRbMap = NULL;\r
+\r
+ for (nSectorNum = 0; nSectorNum < XRAN_MAX_SECTOR_NR; nSectorNum++)\r
+ {\r
+ nSectorIndex[nSectorNum] = nSectorNum;\r
+ }\r
+ nSectorNum = numCCPorts;\r
+ printf ("init_xran_iq_content\n");\r
+\r
+ /* Init Memory */\r
+ for(cc_id = 0; cc_id <nSectorNum; cc_id++)\r
+ {\r
+ for(tti = 0; tti < XRAN_N_FE_BUF_LEN; tti ++) {\r
+ for(ant_id = 0; ant_id < XRAN_MAX_ANTENNA_NR; ant_id++){\r
+ for(sym_id = 0; sym_id < XRAN_NUM_OF_SYMBOL_PER_SLOT; sym_id++) {\r
+\r
+ flowId = XRAN_MAX_ANTENNA_NR*cc_id + ant_id;\r
+ if(p_tx_play_buffer[flowId]){\r
+ /* c-plane DL */\r
+ pRbMap = (struct xran_prb_map *) psBbuIo->sFrontHaulTxPrbMapBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers->pData;\r
+ if(pRbMap){\r
+ if (xranInit.DynamicSectionEna == 0){\r
+ pRbMap->dir = XRAN_DIR_DL;\r
+ pRbMap->xran_port = 0;\r
+ pRbMap->band_id = 0;\r
+ pRbMap->cc_id = cc_id;\r
+ pRbMap->ru_port_id = ant_id;\r
+ pRbMap->tti_id = tti;\r
+ pRbMap->start_sym_id = 0;\r
+ pRbMap->nPrbElm = 1;\r
+ pRbMap->prbMap[0].nStartSymb = 0;\r
+ pRbMap->prbMap[0].numSymb = 14;\r
+ pRbMap->prbMap[0].nRBStart = 0;\r
+ pRbMap->prbMap[0].nRBSize = pXranConf->nDLRBs;\r
+ pRbMap->prbMap[0].nBeamIndex = 0;\r
+ pRbMap->prbMap[0].compMethod = XRAN_COMPMETHOD_NONE;\r
+ pRbMap->prbMap[0].iqWidth = 16;\r
+ } else if(pXranConf->ru_conf.xranCat == XRAN_CATEGORY_B\r
+ && startupConfiguration.appMode == APP_O_DU\r
+ && sym_id == 0){ /* BF Ws are per slot */\r
+ int idxElm = 0;\r
+ char* dl_bfw_pos = ((char*)p_tx_dl_bfw_buffer[flowId]) + tx_dl_bfw_buffer_position[flowId];\r
+ struct xran_prb_elm* p_pRbMapElm = NULL;\r
+ for (idxElm = 0; idxElm < pRbMap->nPrbElm; idxElm++){\r
+ p_pRbMapElm = &pRbMap->prbMap[idxElm];\r
+ p_pRbMapElm->bf_weight.nAntElmTRx = pXranConf->nAntElmTRx;\r
+ if(p_pRbMapElm->BeamFormingType == XRAN_BEAM_WEIGHT && p_pRbMapElm->bf_weight_update){\r
+ int16_t ext_len = 9600;\r
+ int16_t ext_sec_total = 0;\r
+ int8_t * ext_buf =(int8_t*) xran_malloc(ext_len);\r
+ int idRb = 0;\r
+ int16_t *ptr = NULL;\r
+ int i;\r
+ if (ext_buf){\r
+ ext_buf += (RTE_PKTMBUF_HEADROOM +\r
+ sizeof (struct xran_ecpri_hdr) +\r
+ sizeof(struct xran_cp_radioapp_section1));\r
+\r
+ ext_len -= (RTE_PKTMBUF_HEADROOM +\r
+ sizeof (struct xran_ecpri_hdr) +\r
+ sizeof(struct xran_cp_radioapp_section1));\r
+ ext_sec_total = xran_cp_populate_section_ext_1((int8_t *)ext_buf,\r
+ ext_len,\r
+ (int16_t *) (dl_bfw_pos + (p_pRbMapElm->nRBStart*pXranConf->nAntElmTRx)*4),\r
+ p_pRbMapElm->nRBSize,\r
+ pXranConf->nAntElmTRx,\r
+ p_pRbMapElm->iqWidth, p_pRbMapElm->compMethod);\r
+ if(ext_sec_total > 0){\r
+ p_pRbMapElm->bf_weight.p_ext_section = ext_buf;\r
+ p_pRbMapElm->bf_weight.ext_section_sz = ext_sec_total;\r
+ }else {\r
+ rte_panic("xran_cp_populate_section_ext_1 return error [%d]\n", ext_sec_total);\r
+ }\r
+ } else {\r
+ rte_panic("xran_malloc return NULL\n");\r
+ }\r
+ }\r
+ }\r
+ }\r
+ } else {\r
+ printf("DL pRbMap ==NULL\n");\r
+ exit(-1);\r
+ }\r
+\r
+ pos = ((char*)p_tx_play_buffer[flowId]) + tx_play_buffer_position[flowId];\r
+ ptr = psBbuIo->sFrontHaulTxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;\r
+\r
+ if(ptr && pos){\r
+ int idxElm = 0;\r
+ u8dptr = (uint8_t*)ptr;\r
+ int16_t payload_len = 0;\r
+\r
+ uint8_t *dst = (uint8_t *)u8dptr;\r
+ uint8_t *src = (uint8_t *)pos;\r
+ struct xran_prb_elm* p_prbMapElm = &pRbMap->prbMap[idxElm];\r
+ dst = xran_add_hdr_offset(dst, p_prbMapElm->compMethod);\r
+ for (idxElm = 0; idxElm < pRbMap->nPrbElm; idxElm++) {\r
+ struct xran_section_desc *p_sec_desc = NULL;\r
+ p_prbMapElm = &pRbMap->prbMap[idxElm];\r
+ p_sec_desc = p_prbMapElm->p_sec_desc[sym_id];\r
+\r
+ if(p_sec_desc == NULL){\r
+ printf ("p_sec_desc == NULL\n");\r
+ exit(-1);\r
+ }\r
+ src = (uint8_t *)(pos + p_prbMapElm->nRBStart*N_SC_PER_PRB*4L);\r
+\r
+ if(p_prbMapElm->compMethod == XRAN_COMPMETHOD_NONE) {\r
+ payload_len = p_prbMapElm->nRBSize*N_SC_PER_PRB*4L;\r
+ rte_memcpy(dst, src, payload_len);\r
+\r
+ } else if (p_prbMapElm->compMethod == XRAN_COMPMETHOD_BLKFLOAT) {\r
+ struct xranlib_compress_request bfp_com_req;\r
+ struct xranlib_compress_response bfp_com_rsp;\r
+\r
+ memset(&bfp_com_req, 0, sizeof(struct xranlib_compress_request));\r
+ memset(&bfp_com_rsp, 0, sizeof(struct xranlib_compress_response));\r
+\r
+ bfp_com_req.data_in = (int16_t*)src;\r
+ bfp_com_req.numRBs = p_prbMapElm->nRBSize;\r
+ bfp_com_req.len = p_prbMapElm->nRBSize*N_SC_PER_PRB*4L;\r
+ bfp_com_req.compMethod = p_prbMapElm->compMethod;\r
+ bfp_com_req.iqWidth = p_prbMapElm->iqWidth;\r
+\r
+ bfp_com_rsp.data_out = (int8_t*)dst;\r
+ bfp_com_rsp.len = 0;\r
+\r
+ if(xranlib_compress_avx512(&bfp_com_req, &bfp_com_rsp) < 0){\r
+ printf ("compression failed [%d]\n",\r
+ p_prbMapElm->compMethod);\r
+ exit(-1);\r
+ } else {\r
+ payload_len = bfp_com_rsp.len;\r
+ }\r
+ }else {\r
+ printf ("p_prbMapElm->compMethod == %d is not supported\n",\r
+ p_prbMapElm->compMethod);\r
+ exit(-1);\r
+ }\r
+\r
+ /* update RB map for given element */\r
+ p_sec_desc->iq_buffer_offset = RTE_PTR_DIFF(dst, u8dptr);\r
+ p_sec_desc->iq_buffer_len = payload_len;\r
+\r
+ /* add headroom for ORAN headers between IQs for chunk of RBs*/\r
+ dst += payload_len;\r
+ dst = xran_add_hdr_offset(dst, p_prbMapElm->compMethod);\r
+ }\r
+ } else {\r
+ exit(-1);\r
+ printf("ptr ==NULL\n");\r
+ }\r
+\r
+\r
+ /* c-plane UL */\r
+ pRbMap = (struct xran_prb_map *) psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers->pData;\r
+ if(pRbMap){\r
+ if (xranInit.DynamicSectionEna == 0){\r
+ pRbMap->dir = XRAN_DIR_UL;\r
+ pRbMap->xran_port = 0;\r
+ pRbMap->band_id = 0;\r
+ pRbMap->cc_id = cc_id;\r
+ pRbMap->ru_port_id = ant_id;\r
+ pRbMap->tti_id = tti;\r
+ pRbMap->start_sym_id = 0;\r
+ pRbMap->nPrbElm = 1;\r
+ pRbMap->prbMap[0].nRBStart = 0;\r
+ pRbMap->prbMap[0].nRBSize = pXranConf->nULRBs;\r
+ pRbMap->prbMap[0].nStartSymb = 0;\r
+ pRbMap->prbMap[0].numSymb = 14;\r
+ pRbMap->prbMap[0].p_sec_desc[sym_id]->iq_buffer_offset = 0;\r
+ pRbMap->prbMap[0].p_sec_desc[sym_id]->iq_buffer_len = pXranConf->nULRBs *4L;\r
+ pRbMap->prbMap[0].nBeamIndex = 0;\r
+ pRbMap->prbMap[0].compMethod = XRAN_COMPMETHOD_NONE;\r
+ } else if(pXranConf->ru_conf.xranCat == XRAN_CATEGORY_B\r
+ && startupConfiguration.appMode == APP_O_DU\r
+ && sym_id == 0){\r
+ int idxElm = 0;\r
+ char * ul_bfw_pos = ((char*)p_tx_ul_bfw_buffer[flowId]) + tx_ul_bfw_buffer_position[flowId];\r
+ struct xran_prb_elm* p_pRbMapElm = NULL;\r
+\r
+ for (idxElm = 0; idxElm < pRbMap->nPrbElm; idxElm++){\r
+ p_pRbMapElm = &pRbMap->prbMap[idxElm];\r
+ p_pRbMapElm->bf_weight.nAntElmTRx = pXranConf->nAntElmTRx;\r
+ if(p_pRbMapElm->BeamFormingType == XRAN_BEAM_WEIGHT && p_pRbMapElm->bf_weight_update){\r
+ int16_t ext_len = 9600;\r
+ int16_t ext_sec_total = 0;\r
+ int8_t * ext_buf =(int8_t*) xran_malloc(ext_len);\r
+ int idRb = 0;\r
+ int16_t *ptr = NULL;\r
+ int i;\r
+ if (ext_buf){\r
+ ext_buf += (RTE_PKTMBUF_HEADROOM +\r
+ sizeof (struct xran_ecpri_hdr) +\r
+ sizeof(struct xran_cp_radioapp_section1));\r
+\r
+ ext_len -= (RTE_PKTMBUF_HEADROOM +\r
+ sizeof (struct xran_ecpri_hdr) +\r
+ sizeof(struct xran_cp_radioapp_section1));\r
+ ptr = (int16_t*)(ul_bfw_pos +(p_pRbMapElm->nRBStart*pXranConf->nAntElmTRx)*4);\r
+ ext_sec_total = xran_cp_populate_section_ext_1((int8_t *)ext_buf,\r
+ ext_len,\r
+ (int16_t *) (ul_bfw_pos + (p_pRbMapElm->nRBStart*pXranConf->nAntElmTRx)*4),\r
+ p_pRbMapElm->nRBSize,\r
+ pXranConf->nAntElmTRx,\r
+ p_pRbMapElm->iqWidth, p_pRbMapElm->compMethod);\r
+ if(ext_sec_total > 0){\r
+ p_pRbMapElm->bf_weight.p_ext_section = ext_buf;\r
+ p_pRbMapElm->bf_weight.ext_section_sz = ext_sec_total;\r
+ }else {\r
+ rte_panic("xran_cp_populate_section_ext_1 return error [%d]\n", ext_sec_total);\r
+ }\r
+ } else {\r
+ rte_panic("xran_malloc return NULL\n");\r
+ }\r
+ }\r
+ }\r
+ }\r
+ } else {\r
+ printf("DL pRbMap ==NULL\n");\r
+ exit(-1);\r
+ }\r
+\r
+ tx_play_buffer_position[flowId] += pXranConf->nDLRBs*N_SC_PER_PRB*4;\r
+\r
+ if(tx_play_buffer_position[flowId] >= tx_play_buffer_size[flowId])\r
+ tx_play_buffer_position[flowId] = 0;\r
+\r
+ if(pXranConf->ru_conf.xranCat == XRAN_CATEGORY_B\r
+ && startupConfiguration.appMode == APP_O_DU\r
+ && sym_id == 0) {\r
+ tx_dl_bfw_buffer_position[flowId] += (pXranConf->nDLRBs*pXranConf->nAntElmTRx)*4;\r
+ if(tx_dl_bfw_buffer_position[flowId] >= tx_dl_bfw_buffer_size[flowId])\r
+ tx_dl_bfw_buffer_position[flowId] = 0;\r
+\r
+ tx_ul_bfw_buffer_position[flowId] += (pXranConf->nULRBs*pXranConf->nAntElmTRx)*4;\r
+ if(tx_ul_bfw_buffer_position[flowId] >= tx_ul_bfw_buffer_size[flowId])\r
+ tx_ul_bfw_buffer_position[flowId] = 0;\r
+ }\r
+ } else {\r
+ //printf("flowId %d\n", flowId);\r
+ }\r
+ }\r
+ }\r
+\r
+ /* prach TX for RU only */\r
+ if(startupConfiguration.appMode == APP_O_RU && startupConfiguration.enablePrach){\r
+ for(ant_id = 0; ant_id < XRAN_MAX_ANTENNA_NR; ant_id++){\r
+ for(sym_id = 0; sym_id < XRAN_NUM_OF_SYMBOL_PER_SLOT; sym_id++) {\r
+ flowId = XRAN_MAX_ANTENNA_NR*cc_id + ant_id;\r
+\r
+ if(p_tx_prach_play_buffer[flowId]){\r
+ pos = ((char*)p_tx_prach_play_buffer[flowId]);\r
+\r
+ ptr = psBbuIo->sFHPrachRxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;\r
+\r
+ if(ptr && pos){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ /* duplicate full PRACH (repetition * occassions ) in every symbol */\r
+ memset(u32dptr,0 , PRACH_PLAYBACK_BUFFER_BYTES);\r
+ rte_memcpy(u32dptr, pos, RTE_MIN(PRACH_PLAYBACK_BUFFER_BYTES, tx_prach_play_buffer_size[flowId]));\r
+ } else {\r
+ exit(-1);\r
+ printf("ptr ==NULL\n");\r
+ }\r
+ } else {\r
+ //printf("flowId %d\n", flowId);\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ /* SRS TX for RU only */\r
+ if(startupConfiguration.appMode == APP_O_RU && startupConfiguration.enableSrs){\r
+ for(ant_id = 0; ant_id < XRAN_MAX_ANT_ARRAY_ELM_NR; ant_id++){\r
+ for(sym_id = 0; sym_id < XRAN_MAX_NUM_OF_SRS_SYMBOL_PER_SLOT; sym_id++) {\r
+ flowId = XRAN_MAX_ANT_ARRAY_ELM_NR*cc_id + ant_id;\r
+\r
+ if(p_tx_srs_play_buffer[flowId]){\r
+ pos = ((char*)p_tx_srs_play_buffer[flowId]) + tx_srs_play_buffer_position[flowId];\r
+ ptr = psBbuIo->sFHSrsRxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;\r
+\r
+ if(startupConfiguration.srsSymMask & (1 << sym_id) ){\r
+ if(ptr && pos){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ memset(u32dptr,0 , pXranConf->nULRBs*N_SC_PER_PRB*4);\r
+ rte_memcpy(u32dptr, pos, pXranConf->nULRBs*N_SC_PER_PRB*4);\r
+ } else {\r
+ exit(-1);\r
+ printf("ptr ==NULL\n");\r
+ }\r
+ }\r
+\r
+ tx_srs_play_buffer_position[flowId] += pXranConf->nULRBs*N_SC_PER_PRB*4;\r
+\r
+ if(tx_srs_play_buffer_position[flowId] >= tx_srs_play_buffer_size[flowId])\r
+ tx_srs_play_buffer_position[flowId] = 0;\r
+ } else {\r
+ //printf("flowId %d\n", flowId);\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ return 0;\r
+}\r
+\r
+void stop_xran(void)\r
+{\r
+ xran_status_t status = 0;\r
+ SWXRANInterfaceTypeEnum eInterfaceType;\r
+\r
+ free(gpXranLibConfig);\r
+ gpXranLibConfig = NULL;\r
+\r
+ status += xran_mm_destroy(xranHandle)*2;\r
+\r
+ if(XRAN_STATUS_SUCCESS != status)\r
+ {\r
+ printf("Failed at xran_mm_destroy, status %d\n",status);\r
+ iAssert(status == XRAN_STATUS_SUCCESS);\r
+ }\r
+}\r
+\r
+int get_xran_iq_content(void)\r
+{\r
+ BbuXranIoIfStruct *psBbuIo = xran_get_ctx();\r
+ xran_status_t status;\r
+ int32_t nSectorIndex[XRAN_MAX_SECTOR_NR];\r
+ int32_t nSectorNum;\r
+ int32_t cc_id, ant_id, sym_id, tti;\r
+ int32_t flowId;\r
+\r
+ uint8_t frame_id = 0;\r
+ uint8_t subframe_id = 0;\r
+ uint8_t slot_id = 0;\r
+ uint8_t sym = 0;\r
+\r
+ void *ptr;\r
+ uint32_t *u32dptr;\r
+ uint16_t *u16dptr;\r
+ uint8_t *u8dptr;\r
+\r
+ char *pos = NULL;\r
+\r
+ for (nSectorNum = 0; nSectorNum < XRAN_MAX_SECTOR_NR; nSectorNum++)\r
+ {\r
+ nSectorIndex[nSectorNum] = nSectorNum;\r
+ }\r
+ nSectorNum = numCCPorts;\r
+ printf ("get_xran_iq_content\n");\r
+\r
+ /* Init Memory */\r
+ for(cc_id = 0; cc_id <nSectorNum; cc_id++)\r
+ {\r
+ for(tti = 0; tti < XRAN_N_FE_BUF_LEN; tti++) {\r
+ for(ant_id = 0; ant_id < XRAN_MAX_ANTENNA_NR; ant_id++){\r
+ int32_t idxElm = 0;\r
+ struct xran_prb_map *pRbMap = NULL;\r
+ struct xran_prb_elm *pRbElm = NULL;\r
+ struct xran_section_desc *p_sec_desc = NULL;\r
+ pRbMap = (struct xran_prb_map *) psBbuIo->sFrontHaulRxPrbMapBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers->pData;\r
+ if(pRbMap == NULL)\r
+ exit(-1);\r
+ flowId = XRAN_MAX_ANTENNA_NR * cc_id + ant_id;\r
+ for(sym_id = 0; sym_id < XRAN_NUM_OF_SYMBOL_PER_SLOT; sym_id++) {\r
+ pRbElm = &pRbMap->prbMap[0];\r
+ if(pRbMap->nPrbElm == 1){\r
+ if(p_rx_log_buffer[flowId]) {\r
+ pos = ((char*)p_rx_log_buffer[flowId]) + rx_log_buffer_position[flowId];\r
+ ptr = psBbuIo->sFrontHaulRxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;\r
+ if(ptr){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ char* my_ptr =(char *)ptr;\r
+ rte_memcpy(pos + pRbElm->nRBStart*N_SC_PER_PRB*4L , u32dptr, pRbElm->nRBSize*N_SC_PER_PRB*4L);\r
+ }else {\r
+ printf("[%d][%d][%d][%d]ptr ==NULL\n",tti,cc_id,ant_id, sym_id);\r
+ }\r
+ }\r
+ } else {\r
+ for(idxElm = 0; idxElm < pRbMap->nPrbElm; idxElm++ ) {\r
+ pRbElm = &pRbMap->prbMap[idxElm];\r
+ p_sec_desc = pRbElm->p_sec_desc[sym_id];\r
+ if(p_rx_log_buffer[flowId] && p_sec_desc){\r
+ if(sym_id >= pRbElm->nStartSymb && sym_id < pRbElm->nStartSymb + pRbElm->numSymb){\r
+ pos = ((char*)p_rx_log_buffer[flowId]) + rx_log_buffer_position[flowId];\r
+ ptr = p_sec_desc->pData;\r
+ if(ptr){\r
+ int32_t payload_len = 0;\r
+ u32dptr = (uint32_t*)(ptr);\r
+ if (pRbElm->compMethod != XRAN_COMPMETHOD_NONE){\r
+ struct xranlib_decompress_request bfp_decom_req;\r
+ struct xranlib_decompress_response bfp_decom_rsp;\r
+\r
+ memset(&bfp_decom_req, 0, sizeof(struct xranlib_decompress_request));\r
+ memset(&bfp_decom_rsp, 0, sizeof(struct xranlib_decompress_response));\r
+\r
+ bfp_decom_req.data_in = (int8_t *)u32dptr;\r
+ bfp_decom_req.numRBs = pRbElm->nRBSize;\r
+ bfp_decom_req.len = (3* pRbElm->iqWidth + 1)*pRbElm->nRBSize;\r
+ bfp_decom_req.compMethod = pRbElm->compMethod;\r
+ bfp_decom_req.iqWidth = pRbElm->iqWidth;\r
+\r
+ bfp_decom_rsp.data_out = (int16_t *)(pos + pRbElm->nRBStart*N_SC_PER_PRB*4);\r
+ bfp_decom_rsp.len = 0;\r
+\r
+ if(xranlib_decompress_avx512(&bfp_decom_req, &bfp_decom_rsp) < 0){\r
+ printf ("compression failed [%d]\n",\r
+ pRbElm->compMethod);\r
+ exit(-1);\r
+ } else {\r
+ payload_len = bfp_decom_rsp.len;\r
+ }\r
+ } else {\r
+ rte_memcpy(pos + pRbElm->nRBStart*N_SC_PER_PRB*4 , u32dptr, pRbElm->nRBSize*N_SC_PER_PRB*4);\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+ rx_log_buffer_position[flowId] += pXranConf->nULRBs*N_SC_PER_PRB*4;\r
+\r
+ if(rx_log_buffer_position[flowId] >= rx_log_buffer_size[flowId])\r
+ rx_log_buffer_position[flowId] = 0;\r
+ }\r
+\r
+ /* prach RX for O-DU only */\r
+ if(startupConfiguration.appMode == APP_O_DU) {\r
+ flowId = XRAN_MAX_ANTENNA_NR * cc_id + ant_id;\r
+ for(sym_id = 0; sym_id < XRAN_NUM_OF_SYMBOL_PER_SLOT; sym_id++){\r
+ if(p_prach_log_buffer[flowId]){\r
+ /* (0-79 slots) 10ms of IQs */\r
+ pos = ((char*)p_prach_log_buffer[flowId]) + prach_log_buffer_position[flowId];\r
+ ptr = psBbuIo->sFHPrachRxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData; //8192 144\r
+ if(ptr){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ rte_memcpy(pos, u32dptr, PRACH_PLAYBACK_BUFFER_BYTES);\r
+ }else\r
+ printf("ptr ==NULL\n");\r
+\r
+ prach_log_buffer_position[flowId] += PRACH_PLAYBACK_BUFFER_BYTES;\r
+\r
+ if(prach_log_buffer_position[flowId] >= prach_log_buffer_size[flowId])\r
+ prach_log_buffer_position[flowId] = 0;\r
+ } else {\r
+ //printf("flowId %d\n", flowId);\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ /* SRS RX for O-DU only */\r
+ if(startupConfiguration.appMode == APP_O_DU) {\r
+ for(ant_id = 0; ant_id < XRAN_MAX_ANT_ARRAY_ELM_NR; ant_id++){\r
+ flowId = XRAN_MAX_ANT_ARRAY_ELM_NR*cc_id + ant_id;\r
+ for(sym_id = 0; sym_id < XRAN_MAX_NUM_OF_SRS_SYMBOL_PER_SLOT; sym_id++){\r
+ if(p_srs_log_buffer[flowId]){\r
+ pos = ((char*)p_srs_log_buffer[flowId]) + srs_log_buffer_position[flowId];\r
+ ptr = psBbuIo->sFHSrsRxBbuIoBufCtrl[tti][cc_id][ant_id].sBufferList.pBuffers[sym_id].pData;\r
+ if(ptr){\r
+ u32dptr = (uint32_t*)(ptr);\r
+ rte_memcpy(pos, u32dptr, pXranConf->nULRBs*N_SC_PER_PRB*4);\r
+ }else\r
+ printf("ptr ==NULL\n");\r
+\r
+ srs_log_buffer_position[flowId] += pXranConf->nULRBs*N_SC_PER_PRB*4;\r
+\r
+ if(srs_log_buffer_position[flowId] >= srs_log_buffer_size[flowId])\r
+ srs_log_buffer_position[flowId] = 0;\r
+ } else {\r
+ //printf("flowId %d\n", flowId);\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ return 0;\r
+}\r
+\r
+void version_print(void)\r
+{\r
+ char sysversion[100];\r
+ char *compilation_date = __DATE__;\r
+ char *compilation_time = __TIME__;\r
+\r
+ uint32_t nLen;\r
+ uint32_t i;\r
+\r
+ snprintf(sysversion, 99, "Version: %s", VERSIONX);\r
+ nLen = strlen(sysversion);\r
+\r
+ printf("\n\n");\r
+ printf("===========================================================================================================\n");\r
+ printf("SAMPLE-APP VERSION\n");\r
+ printf("===========================================================================================================\n");\r
+\r
+ printf("%s\n", sysversion);\r
+ printf("build-date: %s\n", compilation_date);\r
+ printf("build-time: %s\n", compilation_time);\r
+}\r
+\r
+int main(int argc, char *argv[])\r
+{\r
+ int i;\r
+ int j, len;\r
+ int lcore_id = 0;\r
+ char filename[256];\r
+ char prefix_name[256];\r
+ uint32_t nCenterFreq;\r
+ int32_t xret = 0;\r
+ struct stat st = {0};\r
+ uint32_t filenameLength = strlen(argv[1]);\r
+ char *pCheckName1 = NULL, *pCheckName2 = NULL;\r
+ enum xran_if_state xran_curr_if_state = XRAN_INIT;\r
+\r
+ uint64_t nMask = (uint64_t)1;\r
+ uint16_t nCoreUsage[4*64+1];\r
+ uint16_t nCoreId[4*64];\r
+ float nTotal = 0.0;\r
+ uint64_t nTotalTime;\r
+ uint64_t nUsedTime;\r
+ uint32_t nCoreUsed;\r
+ float nUsedPercent;\r
+\r
+\r
+ if (argc == 3)\r
+ errx(2, "Need two argument - the PCI address of the network port");\r
+ if (filenameLength >= 256)\r
+ {\r
+ printf("Config file name input is too long, exiting!\n");\r
+ exit(-1);\r
+ }\r
+\r
+ version_print();\r
+\r
+ //add for Klocworks\r
+ len = strlen(argv[1]) + 1;\r
+ if (len > (sizeof(filename) - 10))\r
+ len = (sizeof(filename) - 10);\r
+ strncpy(filename, argv[1], (sizeof(filename) - 10));\r
+ filename[len] = '\0';\r
+\r
+ if (xran_is_synchronized() != 0)\r
+ printf("Machine is not synchronized using PTP!\n");\r
+ else\r
+ printf("Machine is synchronized using PTP!\n");\r
+\r
+ memset(&startupConfiguration, 0, sizeof(RuntimeConfig));\r
+\r
+ if (parseConfigFile(filename, (RuntimeConfig*)&startupConfiguration) != 0) {\r
+ printf("Configuration file error.\n");\r
+ return -1;\r
+ }\r
+\r
+ if(startupConfiguration.ant_file[0] == NULL){\r
+ printf("it looks like test vector for antennas were not provided\n");\r
+ exit(-1);\r
+ }\r
+\r
+ if (startupConfiguration.numCC > XRAN_MAX_SECTOR_NR) {\r
+ printf("Number of cells %d exceeds max number supported %d!\n", startupConfiguration.numCC, XRAN_MAX_SECTOR_NR);\r
+ startupConfiguration.numCC = XRAN_MAX_SECTOR_NR;\r
+\r
+ }\r
+ if (startupConfiguration.antElmTRx > XRAN_MAX_ANT_ARRAY_ELM_NR) {\r
+ printf("Number of Antenna elements %d exceeds max number supported %d!\n", startupConfiguration.antElmTRx, XRAN_MAX_ANT_ARRAY_ELM_NR);\r
+ startupConfiguration.antElmTRx = XRAN_MAX_ANT_ARRAY_ELM_NR;\r
+ }\r
+\r
+ numCCPorts = startupConfiguration.numCC;\r
+ num_eAxc = startupConfiguration.numAxc;\r
+\r
+ printf("numCCPorts %d num_eAxc%d\n", numCCPorts, num_eAxc);\r
+\r
+ if (startupConfiguration.mu_number <= 1){\r
+ nFpgaToSW_FTH_RxBufferLen = 13168; /* 273*12*4 + 64*/\r
+ nFpgaToSW_PRACH_RxBufferLen = 8192;\r
+ nSW_ToFpga_FTH_TxBufferLen = 13168 + /* 273*12*4 + 64* + ETH AND ORAN HDRs */\r
+ XRAN_MAX_SECTIONS_PER_SYM* (RTE_PKTMBUF_HEADROOM + sizeof(struct ether_hdr) +\r
+ sizeof(struct xran_ecpri_hdr) +\r
+ sizeof(struct radio_app_common_hdr) +\r
+ sizeof(struct data_section_hdr));\r
+ } else if (startupConfiguration.mu_number == 3){\r
+ nFpgaToSW_FTH_RxBufferLen = 3328;\r
+ nFpgaToSW_PRACH_RxBufferLen = 8192;\r
+ nSW_ToFpga_FTH_TxBufferLen = 3328 +\r
+ XRAN_MAX_SECTIONS_PER_SYM * (RTE_PKTMBUF_HEADROOM + sizeof(struct ether_hdr) +\r
+ sizeof(struct xran_ecpri_hdr) +\r
+ sizeof(struct radio_app_common_hdr) +\r
+ sizeof(struct data_section_hdr));\r
+ } else {\r
+ printf("given numerology is not supported %d\n", startupConfiguration.mu_number);\r
+ exit(-1);\r
+ }\r
+ printf("nSW_ToFpga_FTH_TxBufferLen %d\n", nSW_ToFpga_FTH_TxBufferLen);\r
+\r
+ memset(&xranInit, 0, sizeof(struct xran_fh_init));\r
+\r
+ if(startupConfiguration.appMode == APP_O_DU) {\r
+ printf("set O-DU\n");\r
+ xranInit.io_cfg.id = 0;/* O-DU */\r
+ xranInit.io_cfg.core = startupConfiguration.io_core;\r
+ xranInit.io_cfg.system_core = startupConfiguration.system_core;\r
+ xranInit.io_cfg.pkt_proc_core = startupConfiguration.pkt_proc_core;\r
+ xranInit.io_cfg.pkt_aux_core = startupConfiguration.pkt_aux_core; /* do not start*/\r
+ xranInit.io_cfg.timing_core = startupConfiguration.timing_core;\r
+ } else {\r
+ printf("set O-RU\n");\r
+ xranInit.io_cfg.id = 1; /* O-RU*/\r
+ xranInit.io_cfg.core = startupConfiguration.io_core;\r
+ xranInit.io_cfg.system_core = startupConfiguration.system_core;\r
+ xranInit.io_cfg.pkt_proc_core = startupConfiguration.pkt_proc_core;\r
+ xranInit.io_cfg.pkt_aux_core = startupConfiguration.pkt_aux_core; /* do not start*/\r
+ xranInit.io_cfg.timing_core = startupConfiguration.timing_core;\r
+ }\r
+\r
+ cpu_set_t cpuset;\r
+ pthread_t thread;\r
+\r
+ thread = pthread_self();\r
+ CPU_ZERO(&cpuset);\r
+ CPU_SET(xranInit.io_cfg.system_core,&cpuset);\r
+ pthread_setaffinity_np(thread, sizeof(cpu_set_t), &cpuset);\r
+/* if (s != 0)\r
+ handle_error_en(s, "pthread_setaffinity_np");\r
+*/\r
+\r
+ xranInit.io_cfg.bbdev_mode = XRAN_BBDEV_NOT_USED;\r
+\r
+ if(startupConfiguration.xranCat == XRAN_CATEGORY_A){\r
+ xranInit.eAxCId_conf.mask_cuPortId = 0xf000;\r
+ xranInit.eAxCId_conf.mask_bandSectorId = 0x0f00;\r
+ xranInit.eAxCId_conf.mask_ccId = 0x00f0;\r
+ xranInit.eAxCId_conf.mask_ruPortId = 0x000f;\r
+ xranInit.eAxCId_conf.bit_cuPortId = 12;\r
+ xranInit.eAxCId_conf.bit_bandSectorId = 8;\r
+ xranInit.eAxCId_conf.bit_ccId = 4;\r
+ xranInit.eAxCId_conf.bit_ruPortId = 0;\r
+ } else {\r
+ xranInit.eAxCId_conf.mask_cuPortId = 0xf000;\r
+ xranInit.eAxCId_conf.mask_bandSectorId = 0x0c00;\r
+ xranInit.eAxCId_conf.mask_ccId = 0x0300;\r
+ xranInit.eAxCId_conf.mask_ruPortId = 0x00ff; /* more than [0-127] eAxC */\r
+ xranInit.eAxCId_conf.bit_cuPortId = 12;\r
+ xranInit.eAxCId_conf.bit_bandSectorId = 10;\r
+ xranInit.eAxCId_conf.bit_ccId = 8;\r
+ xranInit.eAxCId_conf.bit_ruPortId = 0;\r
+ }\r
+\r
+ xranInit.io_cfg.dpdk_dev[XRAN_UP_VF] = argv[2];\r
+ xranInit.io_cfg.dpdk_dev[XRAN_CP_VF] = argv[3];\r
+ xranInit.mtu = startupConfiguration.mtu;\r
+\r
+ xranInit.p_o_du_addr = (int8_t *)&startupConfiguration.o_du_addr;\r
+ xranInit.p_o_ru_addr = (int8_t *)&startupConfiguration.o_ru_addr;\r
+\r
+ snprintf(prefix_name, sizeof(prefix_name), "wls_%d",startupConfiguration.instance_id);\r
+ xranInit.filePrefix = prefix_name;\r
+\r
+ xranInit.totalBfWeights = startupConfiguration.totalBfWeights;\r
+\r
+ xranInit.Tadv_cp_dl = startupConfiguration.Tadv_cp_dl;\r
+ xranInit.T2a_min_cp_dl = startupConfiguration.T2a_min_cp_dl;\r
+ xranInit.T2a_max_cp_dl = startupConfiguration.T2a_max_cp_dl;\r
+ xranInit.T2a_min_cp_ul = startupConfiguration.T2a_min_cp_ul;\r
+ xranInit.T2a_max_cp_ul = startupConfiguration.T2a_max_cp_ul;\r
+ xranInit.T2a_min_up = startupConfiguration.T2a_min_up;\r
+ xranInit.T2a_max_up = startupConfiguration.T2a_max_up;\r
+ xranInit.Ta3_min = startupConfiguration.Ta3_min;\r
+ xranInit.Ta3_max = startupConfiguration.Ta3_max;\r
+ xranInit.T1a_min_cp_dl = startupConfiguration.T1a_min_cp_dl;\r
+ xranInit.T1a_max_cp_dl = startupConfiguration.T1a_max_cp_dl;\r
+ xranInit.T1a_min_cp_ul = startupConfiguration.T1a_min_cp_ul;\r
+ xranInit.T1a_max_cp_ul = startupConfiguration.T1a_max_cp_ul;\r
+ xranInit.T1a_min_up = startupConfiguration.T1a_min_up;\r
+ xranInit.T1a_max_up = startupConfiguration.T1a_max_up;\r
+ xranInit.Ta4_min = startupConfiguration.Ta4_min;\r
+ xranInit.Ta4_max = startupConfiguration.Ta4_max;\r
+\r
+ xranInit.enableCP = startupConfiguration.enableCP;\r
+ xranInit.prachEnable = startupConfiguration.enablePrach;\r
+ xranInit.srsEnable = startupConfiguration.enableSrs;\r
+ xranInit.debugStop = startupConfiguration.debugStop;\r
+ xranInit.debugStopCount = startupConfiguration.debugStopCount;\r
+ xranInit.DynamicSectionEna = startupConfiguration.DynamicSectionEna;\r
+ xranInit.io_cfg.bbdev_mode = XRAN_BBDEV_NOT_USED;\r
+ xranInit.GPS_Alpha = startupConfiguration.GPS_Alpha;\r
+ xranInit.GPS_Beta = startupConfiguration.GPS_Beta;\r
+\r
+ xranInit.cp_vlan_tag = startupConfiguration.cp_vlan_tag;\r
+ xranInit.up_vlan_tag = startupConfiguration.up_vlan_tag;\r
+\r
+ printf("IQ files size is %d slots\n", startupConfiguration.numSlots);\r
+\r
+ iq_playback_buffer_size_dl = (startupConfiguration.numSlots * N_SYM_PER_SLOT * N_SC_PER_PRB *\r
+ app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nDLBandwidth, startupConfiguration.nDLAbsFrePointA)\r
+ *4L);\r
+\r
+ iq_playback_buffer_size_ul = (startupConfiguration.numSlots * N_SYM_PER_SLOT * N_SC_PER_PRB *\r
+ app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nULBandwidth, startupConfiguration.nULAbsFrePointA)\r
+ *4L);\r
+\r
+\r
+ /* 10 * [14*32*273*2*2] = 4892160 bytes */\r
+ iq_bfw_buffer_size_dl = (startupConfiguration.numSlots * N_SYM_PER_SLOT * startupConfiguration.antElmTRx *\r
+ app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nDLBandwidth, startupConfiguration.nDLAbsFrePointA)\r
+ *4L);\r
+\r
+ /* 10 * [14*32*273*2*2] = 4892160 bytes */\r
+ iq_bfw_buffer_size_ul = (startupConfiguration.numSlots * N_SYM_PER_SLOT *\r
+ app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nULBandwidth, startupConfiguration.nULAbsFrePointA)\r
+ *4L);\r
+\r
+ /* 10 * [1*273*2*2] = 349440 bytes */\r
+ iq_srs_buffer_size_ul = (startupConfiguration.numSlots * N_SYM_PER_SLOT * N_SC_PER_PRB *\r
+ app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nULBandwidth, startupConfiguration.nULAbsFrePointA)\r
+ *4L);\r
+\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ p_tx_play_buffer[i] = (int16_t*)malloc(iq_playback_buffer_size_dl);\r
+ tx_play_buffer_size[i] = (int32_t)iq_playback_buffer_size_dl;\r
+\r
+ if (p_tx_play_buffer[i] == NULL)\r
+ exit(-1);\r
+\r
+ tx_play_buffer_size[i] = sys_load_file_to_buff(startupConfiguration.ant_file[i],\r
+ "DL IFFT IN IQ Samples in binary format",\r
+ (uint8_t*) p_tx_play_buffer[i],\r
+ tx_play_buffer_size[i],\r
+ 1);\r
+ tx_play_buffer_position[i] = 0;\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.xranCat == XRAN_CATEGORY_B){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+\r
+ p_tx_dl_bfw_buffer[i] = (int16_t*)malloc(iq_bfw_buffer_size_dl);\r
+ tx_dl_bfw_buffer_size[i] = (int32_t)iq_bfw_buffer_size_dl;\r
+\r
+ if (p_tx_dl_bfw_buffer[i] == NULL)\r
+ exit(-1);\r
+\r
+ tx_dl_bfw_buffer_size[i] = sys_load_file_to_buff(startupConfiguration.dl_bfw_file[i],\r
+ "DL BF weights IQ Samples in binary format",\r
+ (uint8_t*) p_tx_dl_bfw_buffer[i],\r
+ tx_dl_bfw_buffer_size[i],\r
+ 1);\r
+ tx_dl_bfw_buffer_position[i] = 0;\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.xranCat == XRAN_CATEGORY_B){\r
+\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ p_tx_ul_bfw_buffer[i] = (int16_t*)malloc(iq_bfw_buffer_size_ul);\r
+ tx_ul_bfw_buffer_size[i] = (int32_t)iq_bfw_buffer_size_ul;\r
+\r
+ if (p_tx_ul_bfw_buffer[i] == NULL)\r
+ exit(-1);\r
+\r
+ tx_ul_bfw_buffer_size[i] = sys_load_file_to_buff(startupConfiguration.ul_bfw_file[i],\r
+ "UL BF weights IQ Samples in binary format",\r
+ (uint8_t*) p_tx_ul_bfw_buffer[i],\r
+ tx_ul_bfw_buffer_size[i],\r
+ 1);\r
+ tx_ul_bfw_buffer_position[i] = 0;\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_RU && startupConfiguration.enablePrach){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ p_tx_prach_play_buffer[i] = (int16_t*)malloc(PRACH_PLAYBACK_BUFFER_BYTES);\r
+ tx_prach_play_buffer_size[i] = (int32_t)PRACH_PLAYBACK_BUFFER_BYTES;\r
+\r
+ if (p_tx_prach_play_buffer[i] == NULL)\r
+ exit(-1);\r
+\r
+ memset(p_tx_prach_play_buffer[i], 0, PRACH_PLAYBACK_BUFFER_BYTES);\r
+\r
+ tx_prach_play_buffer_size[i] = sys_load_file_to_buff(startupConfiguration.prach_file[i],\r
+ "PRACH IQ Samples in binary format",\r
+ (uint8_t*) p_tx_prach_play_buffer[i],\r
+ tx_prach_play_buffer_size[i],\r
+ 1);\r
+ tx_prach_play_buffer_position[i] = 0;\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_RU && startupConfiguration.enableSrs){\r
+ for(i = 0;\r
+ i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(numCCPorts * startupConfiguration.antElmTRx);\r
+ i++) {\r
+\r
+ p_tx_srs_play_buffer[i] = (int16_t*)malloc(iq_srs_buffer_size_ul);\r
+ tx_srs_play_buffer_size[i] = (int32_t)iq_srs_buffer_size_ul;\r
+\r
+ if (p_tx_srs_play_buffer[i] == NULL)\r
+ exit(-1);\r
+\r
+ memset(p_tx_srs_play_buffer[i], 0, iq_srs_buffer_size_ul);\r
+ tx_prach_play_buffer_size[i] = sys_load_file_to_buff(startupConfiguration.ul_srs_file[i],\r
+ "SRS IQ Samples in binary format",\r
+ (uint8_t*) p_tx_srs_play_buffer[i],\r
+ tx_srs_play_buffer_size[i],\r
+ 1);\r
+\r
+ tx_srs_play_buffer_position[i] = 0;\r
+ }\r
+ }\r
+\r
+ /* log of ul */\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+\r
+ p_rx_log_buffer[i] = (int16_t*)malloc(iq_playback_buffer_size_ul);\r
+ rx_log_buffer_size[i] = (int32_t)iq_playback_buffer_size_ul;\r
+\r
+ if (p_rx_log_buffer[i] == NULL)\r
+ exit(-1);\r
+\r
+ rx_log_buffer_position[i] = 0;\r
+\r
+ memset(p_rx_log_buffer[i], 0, rx_log_buffer_size[i]);\r
+ }\r
+\r
+ /* log of prach */\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+\r
+ p_prach_log_buffer[i] = (int16_t*)malloc(startupConfiguration.numSlots*XRAN_NUM_OF_SYMBOL_PER_SLOT*PRACH_PLAYBACK_BUFFER_BYTES);\r
+ prach_log_buffer_size[i] = (int32_t)startupConfiguration.numSlots*XRAN_NUM_OF_SYMBOL_PER_SLOT*PRACH_PLAYBACK_BUFFER_BYTES;\r
+\r
+ if (p_prach_log_buffer[i] == NULL)\r
+ exit(-1);\r
+\r
+ memset(p_prach_log_buffer[i], 0, prach_log_buffer_size[i]);\r
+ prach_log_buffer_position[i] = 0;\r
+ }\r
+\r
+ /* log of SRS */\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.enableSrs){\r
+ for(i = 0;\r
+ i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(numCCPorts * startupConfiguration.antElmTRx);\r
+ i++) {\r
+\r
+ p_srs_log_buffer[i] = (int16_t*)malloc(iq_srs_buffer_size_ul);\r
+ srs_log_buffer_size[i] = (int32_t)iq_srs_buffer_size_ul;\r
+\r
+ if (p_srs_log_buffer[i] == NULL)\r
+ exit(-1);\r
+\r
+ memset(p_srs_log_buffer[i], 0, iq_srs_buffer_size_ul);\r
+ srs_log_buffer_position[i] = 0;\r
+ }\r
+ }\r
+\r
+ if (stat("./logs", &st) == -1) {\r
+ mkdir("./logs", 0777);\r
+ }\r
+\r
+ for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-play_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "DL IFFT IN IQ Samples in human readable format",\r
+ (uint8_t*) p_tx_play_buffer[i],\r
+ tx_play_buffer_size[i],\r
+ 1);\r
+\r
+ snprintf(filename, sizeof(filename),"./logs/%s-play_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file(filename,\r
+ "DL IFFT IN IQ Samples in binary format",\r
+ (uint8_t*) p_tx_play_buffer[i],\r
+ tx_play_buffer_size[i]/sizeof(short),\r
+ sizeof(short));\r
+\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.xranCat == XRAN_CATEGORY_B){\r
+ snprintf(filename, sizeof(filename),"./logs/%s-dl_bfw_ue%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "DL Beamformig weights IQ Samples in human readable format",\r
+ (uint8_t*) p_tx_dl_bfw_buffer[i],\r
+ tx_dl_bfw_buffer_size[i],\r
+ 1);\r
+\r
+ snprintf(filename, sizeof(filename),"./logs/%s-dl_bfw_ue%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file(filename,\r
+ "DL Beamformig weightsIQ Samples in binary format",\r
+ (uint8_t*) p_tx_dl_bfw_buffer[i],\r
+ tx_dl_bfw_buffer_size[i]/sizeof(short),\r
+ sizeof(short));\r
+\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-ul_bfw_ue%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "UL Beamformig weights IQ Samples in human readable format",\r
+ (uint8_t*) p_tx_ul_bfw_buffer[i],\r
+ tx_ul_bfw_buffer_size[i],\r
+ 1);\r
+\r
+ snprintf(filename, sizeof(filename),"./logs/%s-ul_bfw_ue%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file(filename,\r
+ "UL Beamformig weightsIQ Samples in binary format",\r
+ (uint8_t*) p_tx_ul_bfw_buffer[i],\r
+ tx_ul_bfw_buffer_size[i]/sizeof(short),\r
+ sizeof(short));\r
+\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_RU && startupConfiguration.enablePrach){\r
+ snprintf(filename, sizeof(filename), "./logs/%s-play_prach_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "PRACH IQ Samples in human readable format",\r
+ (uint8_t*) p_tx_prach_play_buffer[i],\r
+ tx_prach_play_buffer_size[i],\r
+ 1);\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-play_prach_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file(filename,\r
+ "PRACH IQ Samples in binary format",\r
+ (uint8_t*) p_tx_prach_play_buffer[i],\r
+ tx_prach_play_buffer_size[i]/sizeof(short),\r
+ sizeof(short));\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_RU && startupConfiguration.enableSrs && startupConfiguration.xranCat == XRAN_CATEGORY_B){\r
+ for(i = 0;\r
+ i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(numCCPorts * startupConfiguration.antElmTRx);\r
+ i++) {\r
+\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-play_srs_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "SRS IQ Samples in human readable format",\r
+ (uint8_t*) p_tx_srs_play_buffer[i],\r
+ tx_srs_play_buffer_size[i],\r
+ 1);\r
+\r
+ snprintf(filename,sizeof(filename), "./logs/%s-play_srs_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file(filename,\r
+ "SRS IQ Samples in binary format",\r
+ (uint8_t*) p_tx_srs_play_buffer[i],\r
+ tx_srs_play_buffer_size[i]/sizeof(short),\r
+ sizeof(short));\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.iqswap == 1){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ printf("TX: Swap I and Q to match RU format: [%d]\n",i);\r
+ {\r
+ /* swap I and Q */\r
+ int32_t j;\r
+ signed short *ptr = (signed short *) p_tx_play_buffer[i];\r
+ signed short temp;\r
+\r
+ for (j = 0; j < (int32_t)(tx_play_buffer_size[i]/sizeof(short)) ; j = j + 2){\r
+ temp = ptr[j];\r
+ ptr[j] = ptr[j + 1];\r
+ ptr[j + 1] = temp;\r
+ }\r
+ }\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.xranCat == XRAN_CATEGORY_B){\r
+ printf("DL BFW: Swap I and Q to match RU format: [%d]\n",i);\r
+ {\r
+ /* swap I and Q */\r
+ int32_t j;\r
+ signed short *ptr = (signed short *) p_tx_dl_bfw_buffer[i];\r
+ signed short temp;\r
+\r
+ for (j = 0; j < (int32_t)(tx_dl_bfw_buffer_size[i]/sizeof(short)) ; j = j + 2){\r
+ temp = ptr[j];\r
+ ptr[j] = ptr[j + 1];\r
+ ptr[j + 1] = temp;\r
+ }\r
+ }\r
+ printf("UL BFW: Swap I and Q to match RU format: [%d]\n",i);\r
+ {\r
+ /* swap I and Q */\r
+ int32_t j;\r
+ signed short *ptr = (signed short *) p_tx_ul_bfw_buffer[i];\r
+ signed short temp;\r
+\r
+ for (j = 0; j < (int32_t)(tx_ul_bfw_buffer_size[i]/sizeof(short)) ; j = j + 2){\r
+ temp = ptr[j];\r
+ ptr[j] = ptr[j + 1];\r
+ ptr[j + 1] = temp;\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_RU){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ printf("PRACH: Swap I and Q to match RU format: [%d]\n",i);\r
+ {\r
+ /* swap I and Q */\r
+ int32_t j;\r
+ signed short *ptr = (signed short *) p_tx_prach_play_buffer[i];\r
+ signed short temp;\r
+\r
+ for (j = 0; j < (int32_t)(tx_prach_play_buffer_size[i]/sizeof(short)) ; j = j + 2){\r
+ temp = ptr[j];\r
+ ptr[j] = ptr[j + 1];\r
+ ptr[j + 1] = temp;\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_RU){\r
+ for(i = 0;\r
+ i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(numCCPorts * startupConfiguration.antElmTRx);\r
+ i++) {\r
+ printf("SRS: Swap I and Q to match RU format: [%d]\n",i);\r
+ {\r
+ /* swap I and Q */\r
+ int32_t j;\r
+ signed short *ptr = (signed short *) p_tx_srs_play_buffer[i];\r
+ signed short temp;\r
+\r
+ for (j = 0; j < (int32_t)(tx_srs_play_buffer_size[i]/sizeof(short)) ; j = j + 2){\r
+ temp = ptr[j];\r
+ ptr[j] = ptr[j + 1];\r
+ ptr[j + 1] = temp;\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+#if 0\r
+ for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+\r
+ sprintf(filename, "./logs/swap_IQ_play_ant%d.txt", i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "DL IFFT IN IQ Samples in human readable format",\r
+ (uint8_t*) p_tx_play_buffer[i],\r
+ tx_play_buffer_size[i],\r
+ 1);\r
+ }\r
+#endif\r
+ if (startupConfiguration.nebyteorderswap == 1 && startupConfiguration.compression == 0){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ printf("TX: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);\r
+ for (j = 0; j < tx_play_buffer_size[i]/sizeof(short); j++){\r
+ p_tx_play_buffer[i][j] = rte_cpu_to_be_16(p_tx_play_buffer[i][j]);\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.xranCat == XRAN_CATEGORY_B){\r
+ printf("DL BFW: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);\r
+ for (j = 0; j < tx_dl_bfw_buffer_size[i]/sizeof(short); j++){\r
+ p_tx_dl_bfw_buffer[i][j] = rte_cpu_to_be_16(p_tx_dl_bfw_buffer[i][j]);\r
+ }\r
+ printf("UL BFW: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);\r
+ for (j = 0; j < tx_ul_bfw_buffer_size[i]/sizeof(short); j++){\r
+ p_tx_ul_bfw_buffer[i][j] = rte_cpu_to_be_16(p_tx_ul_bfw_buffer[i][j]);\r
+ }\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_RU && startupConfiguration.enablePrach){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ printf("PRACH: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);\r
+ for (j = 0; j < tx_prach_play_buffer_size[i]/sizeof(short); j++){\r
+ p_tx_prach_play_buffer[i][j] = rte_cpu_to_be_16(p_tx_prach_play_buffer[i][j]);\r
+ }\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_RU && startupConfiguration.enableSrs){\r
+ for(i = 0;\r
+ i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(numCCPorts * startupConfiguration.antElmTRx);\r
+ i++) {\r
+ printf("SRS: Convert S16 I and S16 Q to network byte order for XRAN Ant: [%d]\n",i);\r
+ for (j = 0; j < tx_srs_play_buffer_size[i]/sizeof(short); j++){\r
+ p_tx_srs_play_buffer[i][j] = rte_cpu_to_be_16(p_tx_srs_play_buffer[i][j]);\r
+ }\r
+ }\r
+ }\r
+\r
+ }\r
+\r
+#if 0\r
+ for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+\r
+ sprintf(filename, "./logs/swap_be_play_ant%d.txt", i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "DL IFFT IN IQ Samples in human readable format",\r
+ (uint8_t*) p_tx_play_buffer[i],\r
+ tx_play_buffer_size[i],\r
+ 1);\r
+ }\r
+#endif\r
+\r
+ memset(&xranConf, 0, sizeof(struct xran_fh_config));\r
+ pXranConf = &xranConf;\r
+\r
+ pXranConf->nDLRBs = app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nDLBandwidth, startupConfiguration.nDLAbsFrePointA);\r
+ pXranConf->nULRBs = app_xran_get_num_rbs(startupConfiguration.mu_number, startupConfiguration.nULBandwidth, startupConfiguration.nULAbsFrePointA);\r
+\r
+ if(startupConfiguration.DynamicSectionEna == 0){\r
+ struct xran_prb_map* pRbMap;\r
+\r
+ pRbMap = &startupConfiguration.PrbMapDl;\r
+\r
+ pRbMap->dir = XRAN_DIR_DL;\r
+ pRbMap->xran_port = 0;\r
+ pRbMap->band_id = 0;\r
+ pRbMap->cc_id = 0;\r
+ pRbMap->ru_port_id = 0;\r
+ pRbMap->tti_id = 0;\r
+ pRbMap->start_sym_id = 0;\r
+ pRbMap->nPrbElm = 1;\r
+ pRbMap->prbMap[0].nStartSymb = 0;\r
+ pRbMap->prbMap[0].numSymb = 14;\r
+ pRbMap->prbMap[0].nRBStart = 0;\r
+ pRbMap->prbMap[0].nRBSize = pXranConf->nDLRBs;\r
+ pRbMap->prbMap[0].nBeamIndex = 0;\r
+ pRbMap->prbMap[0].compMethod = XRAN_COMPMETHOD_NONE;\r
+ pRbMap->prbMap[0].iqWidth = 16;\r
+\r
+ pRbMap = &startupConfiguration.PrbMapUl;\r
+ pRbMap->dir = XRAN_DIR_UL;\r
+ pRbMap->xran_port = 0;\r
+ pRbMap->band_id = 0;\r
+ pRbMap->cc_id = 0;\r
+ pRbMap->ru_port_id = 0;\r
+ pRbMap->tti_id = 0;\r
+ pRbMap->start_sym_id = 0;\r
+ pRbMap->nPrbElm = 1;\r
+ pRbMap->prbMap[0].nStartSymb = 0;\r
+ pRbMap->prbMap[0].numSymb = 14;\r
+ pRbMap->prbMap[0].nRBStart = 0;\r
+ pRbMap->prbMap[0].nRBSize = pXranConf->nULRBs;\r
+ pRbMap->prbMap[0].nBeamIndex = 0;\r
+ pRbMap->prbMap[0].compMethod = XRAN_COMPMETHOD_NONE;\r
+ pRbMap->prbMap[0].iqWidth = 16;\r
+ }\r
+\r
+ timer_set_tsc_freq_from_clock();\r
+ xret = xran_init(argc, argv, &xranInit, argv[0], &xranHandle);\r
+ if(xret != XRAN_STATUS_SUCCESS){\r
+ printf("xran_init failed %d\n", xret);\r
+ exit(-1);\r
+ }\r
+\r
+ if(xranHandle == NULL)\r
+ exit(1);\r
+\r
+\r
+ pXranConf->sector_id = 0;\r
+ pXranConf->nCC = numCCPorts;\r
+ pXranConf->neAxc = num_eAxc;\r
+ pXranConf->neAxcUl = startupConfiguration.numUlAxc;\r
+ pXranConf->nAntElmTRx = startupConfiguration.antElmTRx;\r
+\r
+ pXranConf->frame_conf.nFrameDuplexType = startupConfiguration.nFrameDuplexType;\r
+ pXranConf->frame_conf.nNumerology = startupConfiguration.mu_number;\r
+ pXranConf->frame_conf.nTddPeriod = startupConfiguration.nTddPeriod;\r
+\r
+ for (i = 0; i < startupConfiguration.nTddPeriod; i++){\r
+ pXranConf->frame_conf.sSlotConfig[i] = startupConfiguration.sSlotConfig[i];\r
+ }\r
+\r
+ pXranConf->prach_conf.nPrachSubcSpacing = startupConfiguration.mu_number;\r
+ pXranConf->prach_conf.nPrachFreqStart = 0;\r
+ pXranConf->prach_conf.nPrachFilterIdx = XRAN_FILTERINDEX_PRACH_ABC;\r
+ pXranConf->prach_conf.nPrachConfIdx = startupConfiguration.prachConfigIndex;\r
+ pXranConf->prach_conf.nPrachFreqOffset = -792;\r
+\r
+ pXranConf->srs_conf.symbMask = startupConfiguration.srsSymMask;\r
+ pXranConf->srs_conf.eAxC_offset = 2 * startupConfiguration.numAxc; /* PUSCH, PRACH, SRS */\r
+\r
+ pXranConf->ru_conf.xranCat = startupConfiguration.xranCat;\r
+ pXranConf->ru_conf.iqWidth = startupConfiguration.PrbMapDl.prbMap[0].iqWidth;\r
+\r
+ if (startupConfiguration.compression == 0)\r
+ pXranConf->ru_conf.compMeth = XRAN_COMPMETHOD_NONE;\r
+ else\r
+ pXranConf->ru_conf.compMeth = XRAN_COMPMETHOD_BLKFLOAT;\r
+\r
+ pXranConf->ru_conf.fftSize = 0;\r
+ while (startupConfiguration.nULFftSize >>= 1)\r
+ ++pXranConf->ru_conf.fftSize;\r
+\r
+ pXranConf->ru_conf.byteOrder = (startupConfiguration.nebyteorderswap == 1) ? XRAN_NE_BE_BYTE_ORDER : XRAN_CPU_LE_BYTE_ORDER ;\r
+ pXranConf->ru_conf.iqOrder = (startupConfiguration.iqswap == 1) ? XRAN_Q_I_ORDER : XRAN_I_Q_ORDER;\r
+\r
+ printf("FFT Order %d\n", pXranConf->ru_conf.fftSize);\r
+\r
+ nCenterFreq = startupConfiguration.nDLAbsFrePointA + (((pXranConf->nDLRBs * N_SC_PER_PRB) / 2) * app_xran_get_scs(startupConfiguration.mu_number));\r
+ pXranConf->nDLCenterFreqARFCN = app_xran_cal_nrarfcn(nCenterFreq);\r
+ printf("DL center freq %d DL NR-ARFCN %d\n", nCenterFreq, pXranConf->nDLCenterFreqARFCN);\r
+\r
+ nCenterFreq = startupConfiguration.nULAbsFrePointA + (((pXranConf->nULRBs * N_SC_PER_PRB) / 2) * app_xran_get_scs(startupConfiguration.mu_number));\r
+ pXranConf->nULCenterFreqARFCN = app_xran_cal_nrarfcn(nCenterFreq);\r
+ printf("UL center freq %d UL NR-ARFCN %d\n", nCenterFreq, pXranConf->nULCenterFreqARFCN);\r
+\r
+ pXranConf->bbdev_dec = NULL;\r
+ pXranConf->bbdev_enc = NULL;\r
+\r
+ pXranConf->log_level = 1;\r
+\r
+ if(startupConfiguration.maxFrameId)\r
+ pXranConf->ru_conf.xran_max_frame = startupConfiguration.maxFrameId;\r
+\r
+ if(init_xran() != 0)\r
+ exit(-1);\r
+\r
+ xran_reg_physide_cb(xranHandle, physide_dl_tti_call_back, NULL, 10, XRAN_CB_TTI);\r
+ xran_reg_physide_cb(xranHandle, physide_ul_half_slot_call_back, NULL, 10, XRAN_CB_HALF_SLOT_RX);\r
+ xran_reg_physide_cb(xranHandle, physide_ul_full_slot_call_back, NULL, 10, XRAN_CB_FULL_SLOT_RX);\r
+\r
+ init_xran_iq_content();\r
+\r
+ xret = xran_open(xranHandle, pXranConf);\r
+\r
+ if(xret != XRAN_STATUS_SUCCESS){\r
+ printf("xran_open failed %d\n", xret);\r
+ exit(-1);\r
+ }\r
+\r
+ snprintf(filename, sizeof(filename),"mlog-%s", startupConfiguration.appMode == 0 ? "o-du" : "o-ru");\r
+\r
+ /* MLogOpen(0, 32, 0, 0xFFFFFFFF, filename);*/\r
+\r
+ MLogOpen(256, 3, 20000, 0, filename);\r
+ MLogSetMask(0);\r
+\r
+ puts("----------------------------------------");\r
+ printf("MLog Info: virt=0x%016lx size=%d\n", MLogGetFileLocation(), MLogGetFileSize());\r
+ puts("----------------------------------------");\r
+\r
+\r
+ uint64_t nActiveCoreMask[MAX_BBU_POOL_CORE_MASK] = {0};\r
+ nActiveCoreMask[0] = 1 << xranInit.io_cfg.timing_core;\r
+ uint32_t numCarriers = startupConfiguration.numCC;\r
+\r
+ MLogAddTestCase(nActiveCoreMask, numCarriers);\r
+\r
+ fcntl(0, F_SETFL, fcntl(0, F_GETFL) | O_NONBLOCK);\r
+\r
+ state = APP_RUNNING;\r
+ printf("Start XRAN traffic\n");\r
+ xran_start(xranHandle);\r
+ sleep(3);\r
+ print_menu();\r
+ for (;;) {\r
+ struct xran_common_counters x_counters;\r
+ char input[10];\r
+ sleep(1);\r
+ xran_curr_if_state = xran_get_if_state();\r
+ if(xran_get_common_counters(xranHandle, &x_counters) == XRAN_STATUS_SUCCESS) {\r
+\r
+ xran_get_time_stats(&nTotalTime, &nUsedTime, &nCoreUsed, 1);\r
+ nUsedPercent = ((float)nUsedTime * 100.0) / (float)nTotalTime;\r
+\r
+ printf("[%s][rx %ld pps %ld kbps %ld][tx %ld pps %ld kbps %ld] [on_time %ld early %ld late %ld corrupt %ld pkt_dupl %ld Total %ld] IO Util: %5.2f %%\n",\r
+ ((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"),\r
+ rx_counter,\r
+ rx_counter-old_rx_counter,\r
+ rx_bytes_per_sec*8/1000L,\r
+ tx_counter,\r
+ tx_counter-old_tx_counter,\r
+ tx_bytes_per_sec*8/1000L,\r
+ x_counters.Rx_on_time,\r
+ x_counters.Rx_early,\r
+ x_counters.Rx_late,\r
+ x_counters.Rx_corrupt,\r
+ x_counters.Rx_pkt_dupl,\r
+ x_counters.Total_msgs_rcvd,\r
+ nUsedPercent);\r
+\r
+ if(rx_counter > old_rx_counter)\r
+ old_rx_counter = rx_counter;\r
+ if(tx_counter > old_tx_counter)\r
+ old_tx_counter = tx_counter;\r
+\r
+ if(rx_counter > 0 && tx_counter > 0)\r
+ MLogSetMask(0xFFFFFFFF);\r
+ } else {\r
+ printf("error xran_get_common_counters\n");\r
+ }\r
+\r
+ if (xran_curr_if_state == XRAN_STOPPED){\r
+ break;\r
+ }\r
+ if (NULL == fgets(input, 10, stdin)) {\r
+ continue;\r
+ }\r
+\r
+ const int sel_opt = atoi(input);\r
+ switch (sel_opt) {\r
+ case 1:\r
+ xran_start(xranHandle);\r
+ printf("Start XRAN traffic\n");\r
+ break;\r
+ case 2:\r
+ break;\r
+ case 3:\r
+ xran_stop(xranHandle);\r
+ printf("Stop XRAN traffic\n");\r
+ state = APP_STOPPED;\r
+ break;\r
+ default:\r
+ puts("Wrong option passed!");\r
+ break;\r
+ }\r
+ if (APP_STOPPED == state)\r
+ break;\r
+ }\r
+\r
+ get_xran_iq_content();\r
+\r
+ puts("Closing l1 app... Ending all threads...");\r
+ xran_close(xranHandle);\r
+ MLogPrint(NULL);\r
+\r
+ stop_xran();\r
+ puts("Dump IQs...");\r
+\r
+ if (startupConfiguration.iqswap == 1){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ printf("RX: Swap I and Q to match CPU format: [%d]\n",i);\r
+ {\r
+ /* swap I and Q */\r
+ int32_t j;\r
+ signed short *ptr = (signed short *) p_rx_log_buffer[i];\r
+ signed short temp;\r
+\r
+ for (j = 0; j < (int32_t)(rx_log_buffer_size[i]/sizeof(short)) ; j = j + 2){\r
+ temp = ptr[j];\r
+ ptr[j] = ptr[j + 1];\r
+ ptr[j + 1] = temp;\r
+ }\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.enableSrs){\r
+ for(i = 0;\r
+ i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(numCCPorts * startupConfiguration.antElmTRx);\r
+ i++) {\r
+ printf("SRS: Swap I and Q to match CPU format: [%d]\n",i);\r
+ {\r
+ /* swap I and Q */\r
+ int32_t j;\r
+ signed short *ptr = (signed short *) p_srs_log_buffer[i];\r
+ signed short temp;\r
+\r
+ for (j = 0; j < (int32_t)(srs_log_buffer_size[i]/sizeof(short)) ; j = j + 2){\r
+ temp = ptr[j];\r
+ ptr[j] = ptr[j + 1];\r
+ ptr[j + 1] = temp;\r
+ }\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.nebyteorderswap == 1 && startupConfiguration.compression == 0) {\r
+\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ printf("RX: Convert S16 I and S16 Q to cpu byte order from XRAN Ant: [%d]\n",i);\r
+ for (j = 0; j < rx_log_buffer_size[i]/sizeof(short); j++){\r
+ p_rx_log_buffer[i][j] = rte_be_to_cpu_16(p_rx_log_buffer[i][j]);\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.enableSrs){\r
+ for(i = 0;\r
+ i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(numCCPorts * startupConfiguration.antElmTRx);\r
+ i++) {\r
+ printf("SRS: Convert S16 I and S16 Q to cpu byte order from XRAN Ant: [%d]\n",i);\r
+ for (j = 0; j < srs_log_buffer_size[i]/sizeof(short); j++){\r
+ p_srs_log_buffer[i][j] = rte_be_to_cpu_16(p_srs_log_buffer[i][j]);\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+ for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-rx_log_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "UL FFT OUT IQ Samples in human readable format",\r
+ (uint8_t*) p_rx_log_buffer[i],\r
+ rx_log_buffer_size[i],\r
+ 1);\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-rx_log_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file(filename,\r
+ "UL FFT OUT IQ Samples in binary format",\r
+ (uint8_t*) p_rx_log_buffer[i],\r
+ rx_log_buffer_size[i]/sizeof(short),\r
+ sizeof(short));\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.enableSrs){\r
+ for(i = 0;\r
+ i < MAX_ANT_CARRIER_SUPPORTED_CAT_B && i < (uint32_t)(numCCPorts * startupConfiguration.antElmTRx);\r
+ i++) {\r
+ snprintf(filename, sizeof(filename), "./logs/%s-srs_log_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "SRS UL FFT OUT IQ Samples in human readable format",\r
+ (uint8_t*) p_srs_log_buffer[i],\r
+ srs_log_buffer_size[i],\r
+ 1);\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-srs_log_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file(filename,\r
+ "SRS UL FFT OUT IQ Samples in binary format",\r
+ (uint8_t*) p_srs_log_buffer[i],\r
+ srs_log_buffer_size[i]/sizeof(short),\r
+ sizeof(short));\r
+ }\r
+ }\r
+\r
+ if (startupConfiguration.appMode == APP_O_DU && startupConfiguration.enablePrach){\r
+ if (startupConfiguration.iqswap == 1){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ printf("PRACH: Swap I and Q to match CPU format: [%d]\n",i);\r
+ {\r
+ /* swap I and Q */\r
+ int32_t j;\r
+ signed short *ptr = (signed short *) p_prach_log_buffer[i];\r
+ signed short temp;\r
+\r
+ for (j = 0; j < (int32_t)(prach_log_buffer_size[i]/sizeof(short)) ; j = j + 2){\r
+ temp = ptr[j];\r
+ ptr[j] = ptr[j + 1];\r
+ ptr[j + 1] = temp;\r
+ }\r
+ }\r
+ }\r
+ }\r
+\r
+\r
+ if (startupConfiguration.nebyteorderswap == 1 && startupConfiguration.compression == 0){\r
+ for(i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+ printf("PRACH: Convert S16 I and S16 Q to cpu byte order from XRAN Ant: [%d]\n",i);\r
+ for (j = 0; j < prach_log_buffer_size[i]/sizeof(short); j++){\r
+ p_prach_log_buffer[i][j] = rte_be_to_cpu_16(p_prach_log_buffer[i][j]);\r
+ }\r
+ }\r
+ }\r
+\r
+\r
+ for (i = 0; i < MAX_ANT_CARRIER_SUPPORTED && i < (uint32_t)(numCCPorts * num_eAxc); i++) {\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-prach_log_ant%d.txt",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file_txt(filename,\r
+ "PRACH FFT OUT IQ Samples in human readable format",\r
+ (uint8_t*) p_prach_log_buffer[i],\r
+ prach_log_buffer_size[i],\r
+ 1);\r
+\r
+ snprintf(filename, sizeof(filename), "./logs/%s-prach_log_ant%d.bin",((startupConfiguration.appMode == APP_O_DU) ? "o-du" : "o-ru"), i);\r
+ sys_save_buf_to_file(filename,\r
+ "PRACH FFT OUT IQ Samples in binary format",\r
+ (uint8_t*) p_prach_log_buffer[i],\r
+ prach_log_buffer_size[i]/sizeof(short),\r
+ sizeof(short));\r
+ }\r
+ }\r
+\r
+ return 0;\r
+}\r
Code Review / o-du / phy.git / blobdiff