lte-softmodem.c 74.1 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
/*
 * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The OpenAirInterface Software Alliance licenses this file to You under
 * the OAI Public License, Version 1.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.openairinterface.org/?page_id=698
 *
 * 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.
 *-------------------------------------------------------------------------------
 * For more information about the OpenAirInterface (OAI) Software Alliance:
 *      contact@openairinterface.org
 */

22 23
/*! \file lte-enb.c
 * \brief Top-level threads for eNodeB
24
 * \author R. Knopp, F. Kaltenberger, Navid Nikaein
Raymond Knopp's avatar
 
Raymond Knopp committed
25 26 27
 * \date 2012
 * \version 0.1
 * \company Eurecom
28
 * \email: knopp@eurecom.fr,florian.kaltenberger@eurecom.fr, navid.nikaein@eurecom.fr
Raymond Knopp's avatar
 
Raymond Knopp committed
29 30 31
 * \note
 * \warning
 */
32 33

#include "lte-softmodem.h"
34

35 36
#include "T.h"

37
#include "rt_wrapper.h"
38

39
#include "../../ARCH/ETHERNET/USERSPACE/LIB/if_defs.h"
Raymond Knopp's avatar
 
Raymond Knopp committed
40

Raymond Knopp's avatar
 
Raymond Knopp committed
41
//#undef FRAME_LENGTH_COMPLEX_SAMPLES //there are two conflicting definitions, so we better make sure we don't use it at all
42 43 44 45 46 47 48 49 50

#include "PHY/vars.h"
#include "SCHED/vars.h"
#include "LAYER2/MAC/vars.h"

#include "../../SIMU/USER/init_lte.h"

#include "LAYER2/MAC/defs.h"
#include "LAYER2/MAC/vars.h"
51
#include "LAYER2/MAC/proto.h"
52 53
#include "RRC/LITE/vars.h"
#include "PHY_INTERFACE/vars.h"
54
#include "PHY_INTERFACE/defs.h"
55 56 57 58 59 60

#ifdef SMBV
#include "PHY/TOOLS/smbv.h"
unsigned short config_frames[4] = {2,9,11,13};
#endif
#include "UTIL/LOG/log_extern.h"
Navid Nikaein's avatar
Navid Nikaein committed
61
#include "UTIL/OTG/otg_tx.h"
62
#include "UTIL/OTG/otg_externs.h"
63 64
#include "UTIL/MATH/oml.h"
#include "UTIL/LOG/vcd_signal_dumper.h"
65
#include "UTIL/OPT/opt.h"
66
#include "enb_config.h"
Navid Nikaein's avatar
Navid Nikaein committed
67
//#include "PHY/TOOLS/time_meas.h"
68

Florian Kaltenberger's avatar
 
Florian Kaltenberger committed
69 70 71 72
#ifndef OPENAIR2
#include "UTIL/OTG/otg_vars.h"
#endif

73
#if defined(ENABLE_ITTI)
74 75
#include "intertask_interface_init.h"
#include "create_tasks.h"
76 77
#endif

78 79
#include "system.h"

80 81 82 83
#ifdef XFORMS
#include "PHY/TOOLS/lte_phy_scope.h"
#include "stats.h"
// current status is that every UE has a DL scope for a SINGLE eNB (eNB_id=0)
84
// at eNB 0, an UL scope for every UE
85
FD_lte_phy_scope_ue  *form_ue[NUMBER_OF_UE_MAX];
86
FD_lte_phy_scope_enb *form_enb[MAX_NUM_CCs][NUMBER_OF_UE_MAX];
87
FD_stats_form                  *form_stats=NULL,*form_stats_l2=NULL;
88
char title[255];
89
unsigned char                   scope_enb_num_ue = 2;
90
static pthread_t                forms_thread; //xforms
91 92
#endif //XFORMS

Raymond Knopp's avatar
 
Raymond Knopp committed
93 94
pthread_cond_t sync_cond;
pthread_mutex_t sync_mutex;
95
int sync_var=-1; //!< protected by mutex \ref sync_mutex.
96

97 98
uint16_t runtime_phy_rx[29][6]; // SISO [MCS 0-28][RBs 0-5 : 6, 15, 25, 50, 75, 100]
uint16_t runtime_phy_tx[29][6]; // SISO [MCS 0-28][RBs 0-5 : 6, 15, 25, 50, 75, 100]
Raymond Knopp's avatar
 
Raymond Knopp committed
99

100
#if defined(ENABLE_ITTI)
101 102
volatile int             start_eNB = 0;
volatile int             start_UE = 0;
103
#endif
Raymond Knopp's avatar
Raymond Knopp committed
104
volatile int             oai_exit = 0;
105

106
static clock_source_t clock_source = internal;
107
static int wait_for_sync = 0;
Raymond Knopp's avatar
 
Raymond Knopp committed
108

Raymond Knopp's avatar
Raymond Knopp committed
109
static char              UE_flag=0;
110
unsigned int                    mmapped_dma=0;
111
int                             single_thread_flag=1;
112

113
static char                     threequarter_fs=0;
114

115
uint32_t                 downlink_frequency[MAX_NUM_CCs][4];
116
int32_t                  uplink_frequency_offset[MAX_NUM_CCs][4];
Lionel Gauthier's avatar
Lionel Gauthier committed
117

118

119
static char                    *conf_config_file_name = NULL;
120
#if defined(ENABLE_ITTI)
121
static char                    *itti_dump_file = NULL;
Raymond Knopp's avatar
 
Raymond Knopp committed
122 123
#endif

124
int UE_scan = 1;
125
int UE_scan_carrier = 0;
126 127
runmode_t mode = normal_txrx;

128 129
FILE *input_fd=NULL;

130

131 132
#if MAX_NUM_CCs == 1
rx_gain_t                rx_gain_mode[MAX_NUM_CCs][4] = {{max_gain,max_gain,max_gain,max_gain}};
kortke's avatar
kortke committed
133 134
double tx_gain[MAX_NUM_CCs][4] = {{20,0,0,0}};
double rx_gain[MAX_NUM_CCs][4] = {{110,0,0,0}};
135 136 137 138
#else
rx_gain_t                rx_gain_mode[MAX_NUM_CCs][4] = {{max_gain,max_gain,max_gain,max_gain},{max_gain,max_gain,max_gain,max_gain}};
double tx_gain[MAX_NUM_CCs][4] = {{20,0,0,0},{20,0,0,0}};
double rx_gain[MAX_NUM_CCs][4] = {{110,0,0,0},{20,0,0,0}};
Lionel Gauthier's avatar
Lionel Gauthier committed
139
#endif
Raymond Knopp's avatar
 
Raymond Knopp committed
140

141
double rx_gain_off = 0.0;
142

Raymond Knopp's avatar
 
Raymond Knopp committed
143
double sample_rate=30.72e6;
144
double bw = 10.0e6;
145

146
static int                      tx_max_power[MAX_NUM_CCs]; /* =  {0,0}*/;
147

148 149
char   rf_config_file[1024];

Florian Kaltenberger's avatar
Florian Kaltenberger committed
150
int chain_offset=0;
151
int phy_test = 0;
152
uint8_t usim_test = 0;
Florian Kaltenberger's avatar
Florian Kaltenberger committed
153

154 155
uint8_t nb_antenna_tx = 1;
uint8_t nb_antenna_rx = 1;
156

Raymond Knopp's avatar
 
Raymond Knopp committed
157 158 159
char ref[128] = "internal";
char channels[128] = "0";

160
int                      rx_input_level_dBm;
161
static int                      online_log_messages=0;
162
#ifdef XFORMS
163
extern int                      otg_enabled;
164
static char                     do_forms=0;
165
#else
166
int                             otg_enabled;
167
#endif
Raymond Knopp's avatar
 
Raymond Knopp committed
168
//int                             number_of_cards =   1;
169

Raymond Knopp's avatar
 
Raymond Knopp committed
170
static LTE_DL_FRAME_PARMS      *frame_parms[MAX_NUM_CCs];
171
//NB-IoT
172
static NB_IoT_DL_FRAME_PARMS *frame_parms_nb_iot[MAX_NUM_CCs]; // this will be still inside the PHY_VARS of LTE
173

174 175 176
eNB_func_t node_function[MAX_NUM_CCs];
eNB_timing_t node_timing[MAX_NUM_CCs];
int16_t   node_synch_ref[MAX_NUM_CCs];
177

Florian Kaltenberger's avatar
Florian Kaltenberger committed
178
uint32_t target_dl_mcs = 28; //maximum allowed mcs
179
uint32_t target_ul_mcs = 20;
180
uint32_t timing_advance = 0;
181 182
uint8_t exit_missed_slots=1;
uint64_t num_missed_slots=0; // counter for the number of missed slots
183

184
int transmission_mode=1;
Raymond Knopp's avatar
 
Raymond Knopp committed
185

186
int16_t           glog_level         = LOG_INFO;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
187
int16_t           glog_verbosity     = LOG_MED;
188
int16_t           hw_log_level       = LOG_INFO;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
189
int16_t           hw_log_verbosity   = LOG_MED;
190
int16_t           phy_log_level      = LOG_INFO;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
191
int16_t           phy_log_verbosity  = LOG_MED;
192
int16_t           mac_log_level      = LOG_INFO;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
193
int16_t           mac_log_verbosity  = LOG_MED;
194
int16_t           rlc_log_level      = LOG_INFO;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
195
int16_t           rlc_log_verbosity  = LOG_MED;
196
int16_t           pdcp_log_level     = LOG_INFO;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
197
int16_t           pdcp_log_verbosity = LOG_MED;
Florian Kaltenberger's avatar
Florian Kaltenberger committed
198
int16_t           rrc_log_level      = LOG_INFO;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
199
int16_t           rrc_log_verbosity  = LOG_MED;
200 201 202
int16_t           opt_log_level      = LOG_INFO;
int16_t           opt_log_verbosity  = LOG_MED;

Lionel Gauthier's avatar
 
Lionel Gauthier committed
203 204 205 206 207 208
# if defined(ENABLE_USE_MME)
int16_t           gtpu_log_level     = LOG_DEBUG;
int16_t           gtpu_log_verbosity = LOG_MED;
int16_t           udp_log_level      = LOG_DEBUG;
int16_t           udp_log_verbosity  = LOG_MED;
#endif
209 210 211
#if defined (ENABLE_SECURITY)
int16_t           osa_log_level      = LOG_INFO;
int16_t           osa_log_verbosity  = LOG_MED;
212
#endif
213

214 215
char *rrh_UE_ip = "127.0.0.1";
int rrh_UE_port = 51000;
216

217 218 219 220 221
/* flag set by eNB conf file to specify if the radio head is local or remote (default option is local) */
uint8_t local_remote_radio = BBU_LOCAL_RADIO_HEAD;
/* struct for ethernet specific parameters given in eNB conf file */
eth_params_t *eth_params;

222 223 224 225
openair0_config_t openair0_cfg[MAX_CARDS];

double cpuf;

Raymond Knopp's avatar
 
Raymond Knopp committed
226
char uecap_xer[1024],uecap_xer_in=0;
227

228
int oaisim_flag=0;
229
threads_t threads= {-1,-1,-1};
Raymond Knopp's avatar
 
Raymond Knopp committed
230

Cedric Roux's avatar
Cedric Roux committed
231 232 233 234
/* see file openair2/LAYER2/MAC/main.c for why abstraction_flag is needed
 * this is very hackish - find a proper solution
 */
uint8_t abstraction_flag=0;
Raymond Knopp's avatar
 
Raymond Knopp committed
235

236 237 238 239 240
/*---------------------BMC: timespec helpers -----------------------------*/

struct timespec min_diff_time = { .tv_sec = 0, .tv_nsec = 0 };
struct timespec max_diff_time = { .tv_sec = 0, .tv_nsec = 0 };

241 242 243 244 245 246 247 248 249 250
struct timespec clock_difftime(struct timespec start, struct timespec end) {
    struct timespec temp;
    if ((end.tv_nsec-start.tv_nsec)<0) {
        temp.tv_sec = end.tv_sec-start.tv_sec-1;
        temp.tv_nsec = 1000000000+end.tv_nsec-start.tv_nsec;
    } else {
        temp.tv_sec = end.tv_sec-start.tv_sec;
        temp.tv_nsec = end.tv_nsec-start.tv_nsec;
    }
    return temp;
251 252
}

253
void print_difftimes(void) {
254
#ifdef DEBUG
255
    printf("difftimes min = %lu ns ; max = %lu ns\n", min_diff_time.tv_nsec, max_diff_time.tv_nsec);
256
#else
257
    LOG_I(HW,"difftimes min = %lu ns ; max = %lu ns\n", min_diff_time.tv_nsec, max_diff_time.tv_nsec);
258 259 260
#endif
}

261 262 263 264 265 266 267 268 269 270 271 272
void update_difftimes(struct timespec start, struct timespec end) {
    struct timespec diff_time = { .tv_sec = 0, .tv_nsec = 0 };
    int             changed = 0;
    diff_time = clock_difftime(start, end);
    if ((min_diff_time.tv_nsec == 0) || (diff_time.tv_nsec < min_diff_time.tv_nsec)) {
        min_diff_time.tv_nsec = diff_time.tv_nsec;
        changed = 1;
    }
    if ((max_diff_time.tv_nsec == 0) || (diff_time.tv_nsec > max_diff_time.tv_nsec)) {
        max_diff_time.tv_nsec = diff_time.tv_nsec;
        changed = 1;
    }
273
#if 1
274
    if (changed) print_difftimes();
275 276 277 278 279
#endif
}

/*------------------------------------------------------------------------*/

280 281
unsigned int build_rflocal(int txi, int txq, int rxi, int rxq) {
    return (txi + (txq<<6) + (rxi<<12) + (rxq<<18));
282
}
283 284
unsigned int build_rfdc(int dcoff_i_rxfe, int dcoff_q_rxfe) {
    return (dcoff_i_rxfe + (dcoff_q_rxfe<<8));
285 286
}

287
#if !defined(ENABLE_ITTI)
288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303
void signal_handler(int sig) {
    void *array[10];
    size_t size;

    if (sig==SIGSEGV) {
        // get void*'s for all entries on the stack
        size = backtrace(array, 10);

        // print out all the frames to stderr
        fprintf(stderr, "Error: signal %d:\n", sig);
        backtrace_symbols_fd(array, size, 2);
        exit(-1);
    } else {
        printf("trying to exit gracefully...\n");
        oai_exit = 1;
    }
304
}
305
#endif
306 307 308 309 310 311 312 313 314 315 316
#define KNRM  "\x1B[0m"
#define KRED  "\x1B[31m"
#define KGRN  "\x1B[32m"
#define KBLU  "\x1B[34m"
#define RESET "\033[0m"

void help (void) {
  printf (KGRN "Usage:\n");
  printf("  sudo -E lte-softmodem [options]\n");
  printf("  sudo -E ./lte-softmodem -O ../../../targets/PROJECTS/GENERIC-LTE-EPC/CONF/enb.band7.tm1.exmimo2.openEPC.conf -S -V -m 26 -t 16 -x 1 --ulsch-max-errors 100 -W\n\n");
  printf("Options:\n");
317
  printf("  --rf-config-file Configuration file for front-end (e.g. LMS7002M)\n");
318 319 320 321
  printf("  --ulsch-max-errors set the max ULSCH erros\n");
  printf("  --calib-ue-rx set UE RX calibration\n");
  printf("  --calib-ue-rx-med \n");
  printf("  --calib-ue-rxbyp\n");
Raymond Knopp's avatar
 
Raymond Knopp committed
322 323
  printf("  --debug-ue-prach run normal prach power ramping, but don't continue random-access\n");
  printf("  --calib-prach-tx run normal prach with maximum power, but don't continue random-access\n");
324
  printf("  --no-L2-connect bypass L2 and upper layers\n");
325
  printf("  --ue-rxgain set UE RX gain\n");
326
  printf("  --ue-rxgain-off external UE amplifier offset\n");
327
  printf("  --ue-txgain set UE TX gain\n");
Cedric Roux's avatar
Cedric Roux committed
328 329
  printf("  --ue-nb-ant-rx  set UE number of rx antennas\n");
  printf("  --ue-scan-carrier set UE to scan around carrier\n");
330
  printf("  --dlsch-demod-shift dynamic shift for LLR compuation for TM3/4 (default 0)\n");
331
  printf("  --loop-memory get softmodem (UE) to loop through memory instead of acquiring from HW\n");
332
  printf("  --mmapped-dma sets flag for improved EXMIMO UE performance\n");  
333
  printf("  --external-clock tells hardware to use an external clock reference\n");
334
  printf("  --usim-test use XOR autentication algo in case of test usim mode\n"); 
335
  printf("  --single-thread-disable. Disables single-thread mode in lte-softmodem\n"); 
336
  printf("  -A Set timing_advance\n");
337
  printf("  -C Set the downlink frequency for all component carriers\n");
338 339 340
  printf("  -d Enable soft scope and L1 and L2 stats (Xforms)\n");
  printf("  -F Calibrate the EXMIMO borad, available files: exmimo2_2arxg.lime exmimo2_2brxg.lime \n");
  printf("  -g Set the global log level, valide options: (9:trace, 8/7:debug, 6:info, 4:warn, 3:error)\n");
341
  printf("  -G Set the global log verbosity \n");
342 343 344 345 346
  printf("  -h provides this help message!\n");
  printf("  -K Generate ITTI analyzser logs (similar to wireshark logs but with more details)\n");
  printf("  -m Set the maximum downlink MCS\n");
  printf("  -O eNB configuration file (located in targets/PROJECTS/GENERIC-LTE-EPC/CONF\n");
  printf("  -q Enable processing timing measurement of lte softmodem on per subframe basis \n");
kaltenbe's avatar
kaltenbe committed
347
  printf("  -r Set the PRB, valid values: 6, 25, 50, 100  \n");    
348 349
  printf("  -S Skip the missed slots/subframes \n");    
  printf("  -t Set the maximum uplink MCS\n");
350
  printf("  -T Set hardware to TDD mode (default: FDD). Used only with -U (otherwise set in config file).\n");
351 352 353
  printf("  -U Set the lte softmodem as a UE\n");
  printf("  -W Enable L2 wireshark messages on localhost \n");
  printf("  -V Enable VCD (generated file will be located atopenair_dump_eNB.vcd, read it with target/RT/USER/eNB.gtkw\n");
354
  printf("  -x Set the transmission mode, valid options: 1 \n");
355
  printf("  -E Apply three-quarter of sampling frequency, 23.04 Msps to reduce the data rate on USB/PCIe transfers (only valid for 20 MHz)\n");
356
#if T_TRACER
357 358 359
    printf("  --T_port [port]    use given port\n");
    printf("  --T_nowait         don't wait for tracer, start immediately\n");
    printf("  --T_dont_fork      to ease debugging with gdb\n");
360
#endif
361 362
    printf(RESET);
    fflush(stdout);
363
}
364

365 366
void exit_fun(const char* s) {
    int CC_id;
Raymond Knopp's avatar
Raymond Knopp committed
367

368 369
    if (s != NULL) {
        printf("%s %s() Exiting OAI softmodem: %s\n",__FILE__, __FUNCTION__, s);
Raymond Knopp's avatar
Raymond Knopp committed
370
    }
371 372 373 374 375 376 377 378 379 380 381 382 383

    oai_exit = 1;

    for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
        if (UE_flag == 0) {
            if (PHY_vars_eNB_g[0][CC_id]->rfdevice.trx_end_func)
                PHY_vars_eNB_g[0][CC_id]->rfdevice.trx_end_func(&PHY_vars_eNB_g[0][CC_id]->rfdevice);
            if (PHY_vars_eNB_g[0][CC_id]->ifdevice.trx_end_func)
                PHY_vars_eNB_g[0][CC_id]->ifdevice.trx_end_func(&PHY_vars_eNB_g[0][CC_id]->ifdevice);
        } else {
            if (PHY_vars_UE_g[0][CC_id]->rfdevice.trx_end_func)
                PHY_vars_UE_g[0][CC_id]->rfdevice.trx_end_func(&PHY_vars_UE_g[0][CC_id]->rfdevice);
        }
Raymond Knopp's avatar
Raymond Knopp committed
384
    }
385 386

#if defined(ENABLE_ITTI)
387 388
    sleep(1); //allow lte-softmodem threads to exit first
    itti_terminate_tasks (TASK_UNKNOWN);
389
#endif
390 391 392

}

393

394
#ifdef XFORMS
395

396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418
void reset_stats(FL_OBJECT *button, long arg) {
    int i,j,k;
    PHY_VARS_eNB *phy_vars_eNB = PHY_vars_eNB_g[0][0];

    for (i=0; i<NUMBER_OF_UE_MAX; i++) {
        for (k=0; k<8; k++) { //harq_processes
            for (j=0; j<phy_vars_eNB->dlsch[i][0]->Mlimit; j++) {
                phy_vars_eNB->UE_stats[i].dlsch_NAK[k][j]=0;
                phy_vars_eNB->UE_stats[i].dlsch_ACK[k][j]=0;
                phy_vars_eNB->UE_stats[i].dlsch_trials[k][j]=0;
            }

            phy_vars_eNB->UE_stats[i].dlsch_l2_errors[k]=0;
            phy_vars_eNB->UE_stats[i].ulsch_errors[k]=0;
            phy_vars_eNB->UE_stats[i].ulsch_consecutive_errors=0;

            for (j=0; j<phy_vars_eNB->ulsch[i]->Mlimit; j++) {
                phy_vars_eNB->UE_stats[i].ulsch_decoding_attempts[k][j]=0;
                phy_vars_eNB->UE_stats[i].ulsch_decoding_attempts_last[k][j]=0;
                phy_vars_eNB->UE_stats[i].ulsch_round_errors[k][j]=0;
                phy_vars_eNB->UE_stats[i].ulsch_round_fer[k][j]=0;
            }
        }
419

420 421 422
        phy_vars_eNB->UE_stats[i].dlsch_sliding_cnt=0;
        phy_vars_eNB->UE_stats[i].dlsch_NAK_round0=0;
        phy_vars_eNB->UE_stats[i].dlsch_mcs_offset=0;
423 424 425
    }
}

426 427
static void *scope_thread(void *arg) {
    char stats_buffer[16384];
428
# ifdef ENABLE_XFORMS_WRITE_STATS
429
    FILE *UE_stats, *eNB_stats;
430
# endif
431 432 433 434
    int len = 0;
    struct sched_param sched_param;
    int UE_id, CC_id;
    int ue_cnt=0;
435

436 437
    sched_param.sched_priority = sched_get_priority_min(SCHED_FIFO)+1;
    sched_setscheduler(0, SCHED_FIFO,&sched_param);
438

439
    printf("Scope thread has priority %d\n",sched_param.sched_priority);
440

441
# ifdef ENABLE_XFORMS_WRITE_STATS
442

443 444 445 446
    if (UE_flag==1)
        UE_stats  = fopen("UE_stats.txt", "w");
    else
        eNB_stats = fopen("eNB_stats.txt", "w");
447

448
#endif
449

450 451 452 453 454 455
    while (!oai_exit) {
        if (UE_flag==1) {
            len = dump_ue_stats (PHY_vars_UE_g[0][0], &PHY_vars_UE_g[0][0]->proc.proc_rxtx[0],stats_buffer, 0, mode,rx_input_level_dBm);
            //fl_set_object_label(form_stats->stats_text, stats_buffer);
            fl_clear_browser(form_stats->stats_text);
            fl_add_browser_line(form_stats->stats_text, stats_buffer);
456

457 458 459 460
            phy_scope_UE(form_ue[0],
                         PHY_vars_UE_g[0][0],
                         0,
                         0,7);
461

462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489
        } else {
            if (PHY_vars_eNB_g[0][0]->mac_enabled==1) {
                len = dump_eNB_l2_stats (stats_buffer, 0);
                //fl_set_object_label(form_stats_l2->stats_text, stats_buffer);
                fl_clear_browser(form_stats_l2->stats_text);
                fl_add_browser_line(form_stats_l2->stats_text, stats_buffer);
            }
            len = dump_eNB_stats (PHY_vars_eNB_g[0][0], stats_buffer, 0);

            if (MAX_NUM_CCs>1)
                len += dump_eNB_stats (PHY_vars_eNB_g[0][1], &stats_buffer[len], 0);

            //fl_set_object_label(form_stats->stats_text, stats_buffer);
            fl_clear_browser(form_stats->stats_text);
            fl_add_browser_line(form_stats->stats_text, stats_buffer);

            ue_cnt=0;
            for(UE_id=0; UE_id<NUMBER_OF_UE_MAX; UE_id++) {
                for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
                    //	  if ((PHY_vars_eNB_g[0][CC_id]->dlsch[UE_id][0]->rnti>0) && (ue_cnt<scope_enb_num_ue)) {
                    if ((ue_cnt<scope_enb_num_ue)) {
                        phy_scope_eNB(form_enb[CC_id][ue_cnt],
                                      PHY_vars_eNB_g[0][CC_id],
                                      UE_id);
                        ue_cnt++;
                    }
                }
            }
490

491
        }
492

493 494 495 496
        //printf("doing forms\n");
        //usleep(100000); // 100 ms
        sleep(1);
    }
497

498
    //  printf("%s",stats_buffer);
499

500
# ifdef ENABLE_XFORMS_WRITE_STATS
501

502 503 504 505 506 507 508 509 510 511 512 513
    if (UE_flag==1) {
        if (UE_stats) {
            rewind (UE_stats);
            fwrite (stats_buffer, 1, len, UE_stats);
            fclose (UE_stats);
        }
    } else {
        if (eNB_stats) {
            rewind (eNB_stats);
            fwrite (stats_buffer, 1, len, eNB_stats);
            fclose (eNB_stats);
        }
514
    }
515

516
# endif
517

518
    pthread_exit((void*)arg);
519 520 521
}
#endif

522

523

524

Raymond Knopp's avatar
 
Raymond Knopp committed
525
#if defined(ENABLE_ITTI)
526 527 528
void *l2l1_task(void *arg) {
    MessageDef *message_p = NULL;
    int         result;
Raymond Knopp's avatar
 
Raymond Knopp committed
529

530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561
    itti_set_task_real_time(TASK_L2L1);
    itti_mark_task_ready(TASK_L2L1);

    if (UE_flag == 0) {
        /* Wait for the initialize message */
        printf("Wait for the ITTI initialize message\n");
        do {
            if (message_p != NULL) {
                result = itti_free (ITTI_MSG_ORIGIN_ID(message_p), message_p);
                AssertFatal (result == EXIT_SUCCESS, "Failed to free memory (%d)!\n", result);
            }

            itti_receive_msg (TASK_L2L1, &message_p);

            switch (ITTI_MSG_ID(message_p)) {
            case INITIALIZE_MESSAGE:
                /* Start eNB thread */
                LOG_D(EMU, "L2L1 TASK received %s\n", ITTI_MSG_NAME(message_p));
                start_eNB = 1;
                break;

            case TERMINATE_MESSAGE:
                printf("received terminate message\n");
                oai_exit=1;
                itti_exit_task ();
                break;

            default:
                LOG_E(EMU, "Received unexpected message %s\n", ITTI_MSG_NAME(message_p));
                break;
            }
        } while (ITTI_MSG_ID(message_p) != INITIALIZE_MESSAGE);
562

563 564
        result = itti_free (ITTI_MSG_ORIGIN_ID(message_p), message_p);
        AssertFatal (result == EXIT_SUCCESS, "Failed to free memory (%d)!\n", result);
Raymond Knopp's avatar
 
Raymond Knopp committed
565 566
    }

567 568 569
    do {
        // Wait for a message
        itti_receive_msg (TASK_L2L1, &message_p);
Raymond Knopp's avatar
 
Raymond Knopp committed
570

571 572 573 574 575
        switch (ITTI_MSG_ID(message_p)) {
        case TERMINATE_MESSAGE:
            oai_exit=1;
            itti_exit_task ();
            break;
Raymond Knopp's avatar
 
Raymond Knopp committed
576

577 578 579
        case ACTIVATE_MESSAGE:
            start_UE = 1;
            break;
Raymond Knopp's avatar
 
Raymond Knopp committed
580

581 582 583
        case DEACTIVATE_MESSAGE:
            start_UE = 0;
            break;
584

585 586 587
        case MESSAGE_TEST:
            LOG_I(EMU, "Received %s\n", ITTI_MSG_NAME(message_p));
            break;
Raymond Knopp's avatar
 
Raymond Knopp committed
588

589 590 591 592
        default:
            LOG_E(EMU, "Received unexpected message %s\n", ITTI_MSG_NAME(message_p));
            break;
        }
Raymond Knopp's avatar
 
Raymond Knopp committed
593

594 595 596
        result = itti_free (ITTI_MSG_ORIGIN_ID(message_p), message_p);
        AssertFatal (result == EXIT_SUCCESS, "Failed to free memory (%d)!\n", result);
    } while(!oai_exit);
597

598
    return NULL;
599 600 601
}
#endif

Raymond Knopp's avatar
 
Raymond Knopp committed
602 603


604 605 606 607 608 609

static void get_options (int argc, char **argv) {
    int c;
    //  char                          line[1000];
    //  int                           l;
    int k,i;//,j,k;
610
#if defined(OAI_USRP) || defined(CPRIGW)
611
    int clock_src;
Raymond Knopp's avatar
 
Raymond Knopp committed
612
#endif
613
    int CC_id;
Raymond Knopp's avatar
 
Raymond Knopp committed
614

615

616
  const Enb_properties_array_t *enb_properties;
617

618 619 620 621 622 623 624 625 626 627 628 629 630
    enum long_option_e {
        LONG_OPTION_START = 0x100, /* Start after regular single char options */
        LONG_OPTION_RF_CONFIG_FILE,
        LONG_OPTION_ULSCH_MAX_CONSECUTIVE_ERRORS,
        LONG_OPTION_CALIB_UE_RX,
        LONG_OPTION_CALIB_UE_RX_MED,
        LONG_OPTION_CALIB_UE_RX_BYP,
        LONG_OPTION_DEBUG_UE_PRACH,
        LONG_OPTION_NO_L2_CONNECT,
        LONG_OPTION_CALIB_PRACH_TX,
        LONG_OPTION_RXGAIN,
        LONG_OPTION_RXGAINOFF,
        LONG_OPTION_TXGAIN,
631 632
	LONG_OPTION_NBRXANT,
	LONG_OPTION_NBTXANT,
633 634 635 636 637 638 639 640 641 642 643 644 645
        LONG_OPTION_SCANCARRIER,
        LONG_OPTION_MAXPOWER,
        LONG_OPTION_DUMP_FRAME,
        LONG_OPTION_LOOPMEMORY,
        LONG_OPTION_PHYTEST,
        LONG_OPTION_USIMTEST,
        LONG_OPTION_MMAPPED_DMA,
        LONG_OPTION_EXTERNAL_CLOCK,
        LONG_OPTION_WAIT_FOR_SYNC,
        LONG_OPTION_SINGLE_THREAD_DISABLE,
        LONG_OPTION_THREADIQ,
        LONG_OPTION_THREADODDSUBFRAME,
        LONG_OPTION_THREADEVENSUBFRAME,
646
        LONG_OPTION_DEMOD_SHIFT,
647
#if T_TRACER
648 649 650
        LONG_OPTION_T_PORT,
        LONG_OPTION_T_NOWAIT,
        LONG_OPTION_T_DONT_FORK,
651
#endif
652

653 654 655 656 657 658 659 660 661 662 663 664 665 666
    };

    static const struct option long_options[] = {
        {"rf-config-file",required_argument,  NULL, LONG_OPTION_RF_CONFIG_FILE},
        {"ulsch-max-errors",required_argument,  NULL, LONG_OPTION_ULSCH_MAX_CONSECUTIVE_ERRORS},
        {"calib-ue-rx",     required_argument,  NULL, LONG_OPTION_CALIB_UE_RX},
        {"calib-ue-rx-med", required_argument,  NULL, LONG_OPTION_CALIB_UE_RX_MED},
        {"calib-ue-rx-byp", required_argument,  NULL, LONG_OPTION_CALIB_UE_RX_BYP},
        {"debug-ue-prach",  no_argument,        NULL, LONG_OPTION_DEBUG_UE_PRACH},
        {"no-L2-connect",   no_argument,        NULL, LONG_OPTION_NO_L2_CONNECT},
        {"calib-prach-tx",   no_argument,        NULL, LONG_OPTION_CALIB_PRACH_TX},
        {"ue-rxgain",   required_argument,  NULL, LONG_OPTION_RXGAIN},
        {"ue-rxgain-off",   required_argument,  NULL, LONG_OPTION_RXGAINOFF},
        {"ue-txgain",   required_argument,  NULL, LONG_OPTION_TXGAIN},
667 668
     	{"ue-nb-ant-rx", required_argument,  NULL, LONG_OPTION_NBRXANT},
	    {"ue-nb-ant-tx", required_argument,  NULL, LONG_OPTION_NBTXANT},
669 670 671 672 673 674 675 676 677 678 679 680 681
        {"ue-scan-carrier",   no_argument,  NULL, LONG_OPTION_SCANCARRIER},
        {"ue-max-power",   required_argument,  NULL, LONG_OPTION_MAXPOWER},
        {"ue-dump-frame", no_argument, NULL, LONG_OPTION_DUMP_FRAME},
        {"loop-memory", required_argument, NULL, LONG_OPTION_LOOPMEMORY},
        {"phy-test", no_argument, NULL, LONG_OPTION_PHYTEST},
        {"usim-test", no_argument, NULL, LONG_OPTION_USIMTEST},
        {"mmapped-dma", no_argument, NULL, LONG_OPTION_MMAPPED_DMA},
        {"external-clock", no_argument, NULL, LONG_OPTION_EXTERNAL_CLOCK},
        {"wait-for-sync", no_argument, NULL, LONG_OPTION_WAIT_FOR_SYNC},
        {"single-thread-disable", no_argument, NULL, LONG_OPTION_SINGLE_THREAD_DISABLE},
        {"threadIQ",  required_argument, NULL, LONG_OPTION_THREADIQ},
        {"threadOddSubframe",  required_argument, NULL, LONG_OPTION_THREADODDSUBFRAME},
        {"threadEvenSubframe",  required_argument, NULL, LONG_OPTION_THREADEVENSUBFRAME},
682
        {"dlsch-demod-shift", required_argument,  NULL, LONG_OPTION_DEMOD_SHIFT},
683
#if T_TRACER
684 685 686
        {"T_port",                 required_argument, 0, LONG_OPTION_T_PORT},
        {"T_nowait",               no_argument,       0, LONG_OPTION_T_NOWAIT},
        {"T_dont_fork",            no_argument,       0, LONG_OPTION_T_DONT_FORK},
687
#endif
688 689 690
    {NULL, 0, NULL, 0}
  };

691
  while ((c = getopt_long (argc, argv, "A:a:C:dEK:g:F:G:hqO:m:SUVRM:r:P:Ws:t:Tx:",long_options,NULL)) != -1) {
692
    switch (c) {
693
    case LONG_OPTION_RF_CONFIG_FILE:
694 695 696 697 698 699
      if ((strcmp("null", optarg) == 0) || (strcmp("NULL", optarg) == 0)) {
	printf("no configuration filename is provided\n");
      }
      else if (strlen(optarg)<=1024){
	strcpy(rf_config_file,optarg);
      }else {
700 701
	printf("Configuration filename is too long\n");
	exit(-1);   
702 703
      }
      break;
704 705 706 707
    case LONG_OPTION_MAXPOWER:
      tx_max_power[0]=atoi(optarg);
      for (CC_id=1;CC_id<MAX_NUM_CCs;CC_id++)
	tx_max_power[CC_id]=tx_max_power[0];
708
      break;
709 710 711 712
    case LONG_OPTION_ULSCH_MAX_CONSECUTIVE_ERRORS:
      ULSCH_max_consecutive_errors = atoi(optarg);
      printf("Set ULSCH_max_consecutive_errors = %d\n",ULSCH_max_consecutive_errors);
      break;
713

714 715 716 717 718
    case LONG_OPTION_CALIB_UE_RX:
      mode = rx_calib_ue;
      rx_input_level_dBm = atoi(optarg);
      printf("Running with UE calibration on (LNA max), input level %d dBm\n",rx_input_level_dBm);
      break;
719

720 721 722 723
    case LONG_OPTION_CALIB_UE_RX_MED:
      mode = rx_calib_ue_med;
      rx_input_level_dBm = atoi(optarg);
      printf("Running with UE calibration on (LNA med), input level %d dBm\n",rx_input_level_dBm);
Raymond Knopp's avatar
 
Raymond Knopp committed
724
      break;
725

726 727 728 729 730
    case LONG_OPTION_CALIB_UE_RX_BYP:
      mode = rx_calib_ue_byp;
      rx_input_level_dBm = atoi(optarg);
      printf("Running with UE calibration on (LNA byp), input level %d dBm\n",rx_input_level_dBm);
      break;
731

732 733 734
    case LONG_OPTION_DEBUG_UE_PRACH:
      mode = debug_prach;
      break;
735

736 737 738
    case LONG_OPTION_NO_L2_CONNECT:
      mode = no_L2_connect;
      break;
739

Raymond Knopp's avatar
 
Raymond Knopp committed
740 741
    case LONG_OPTION_CALIB_PRACH_TX:
      mode = calib_prach_tx;
Rohit Gupta's avatar
Rohit Gupta committed
742
      printf("Setting mode to calib_prach_tx (%d)\n",mode);
Raymond Knopp's avatar
 
Raymond Knopp committed
743 744
      break;

745
    case LONG_OPTION_RXGAIN:
746 747
      for (i=0; i<4; i++)
        rx_gain[0][i] = atof(optarg);
748

749
      break;
750

751 752 753 754
    case LONG_OPTION_RXGAINOFF:
      rx_gain_off = atof(optarg);
      break;

755 756 757
    case LONG_OPTION_TXGAIN:
      for (i=0; i<4; i++)
        tx_gain[0][i] = atof(optarg);
758

759
      break;
760 761 762 763 764 765
    case LONG_OPTION_NBRXANT:
    	nb_antenna_rx = atof(optarg);
    	break;
    case LONG_OPTION_NBTXANT:
    	nb_antenna_tx = atof(optarg);
    	break;
766 767 768 769 770
    case LONG_OPTION_SCANCARRIER:
      UE_scan_carrier=1;

      break;

771 772 773 774 775 776
    case LONG_OPTION_LOOPMEMORY:
      mode=loop_through_memory;
      input_fd = fopen(optarg,"r");
      AssertFatal(input_fd != NULL,"Please provide an input file\n");
      break;

777 778 779 780
    case LONG_OPTION_DUMP_FRAME:
      mode = rx_dump_frame;
      break;
      
781 782 783
    case LONG_OPTION_PHYTEST:
      phy_test = 1;
      break;
784

785 786 787
    case LONG_OPTION_USIMTEST:
        usim_test = 1;
      break;
788 789 790
    case LONG_OPTION_MMAPPED_DMA:
      mmapped_dma = 1;
      break;
Raymond Knopp's avatar
Raymond Knopp committed
791

792 793
    case LONG_OPTION_SINGLE_THREAD_DISABLE:
      single_thread_flag = 0;
Raymond Knopp's avatar
Raymond Knopp committed
794
      break;
795 796 797 798 799

    case LONG_OPTION_EXTERNAL_CLOCK:
      clock_source = external;
      break;

800 801 802 803
    case LONG_OPTION_WAIT_FOR_SYNC:
      wait_for_sync = 1;
      break;

804 805 806 807 808 809 810 811 812
    case LONG_OPTION_THREADIQ:
       threads.iq=atoi(optarg);
       break;
    case LONG_OPTION_THREADODDSUBFRAME:
       threads.odd=atoi(optarg);
       break;
    case LONG_OPTION_THREADEVENSUBFRAME:
       threads.even=atoi(optarg);
       break;
813 814
    case LONG_OPTION_DEMOD_SHIFT: {
        extern int16_t dlsch_demod_shift;
815 816
        dlsch_demod_shift = atof(optarg);
        break;
817
    }
818
#if T_TRACER
819 820 821 822 823 824
        case LONG_OPTION_T_PORT: {
            extern int T_port;
            if (optarg == NULL) abort();  /* should not happen */
            T_port = atoi(optarg);
            break;
        }
825

826 827 828 829 830
        case LONG_OPTION_T_NOWAIT: {
            extern int T_wait;
            T_wait = 0;
            break;
        }
831

832 833 834 835 836
        case LONG_OPTION_T_DONT_FORK: {
            extern int T_dont_fork;
            T_dont_fork = 1;
            break;
        }
837 838
#endif

839 840 841
        case 'A':
            timing_advance = atoi (optarg);
            break;
842

843 844 845 846 847 848 849 850
        case 'C':
            for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
                downlink_frequency[CC_id][0] = atof(optarg); // Use float to avoid issue with frequency over 2^31.
                downlink_frequency[CC_id][1] = downlink_frequency[CC_id][0];
                downlink_frequency[CC_id][2] = downlink_frequency[CC_id][0];
                downlink_frequency[CC_id][3] = downlink_frequency[CC_id][0];
                printf("Downlink for CC_id %d frequency set to %u\n", CC_id, downlink_frequency[CC_id][0]);
            }
851

852
            UE_scan=0;
853

854
            break;
855

856 857 858
        case 'a':
            chain_offset = atoi(optarg);
            break;
Florian Kaltenberger's avatar
Florian Kaltenberger committed
859

860
        case 'd':
861
#ifdef XFORMS
862 863
            do_forms=1;
            printf("Running with XFORMS!\n");
Raymond Knopp's avatar
 
Raymond Knopp committed
864
#endif
865
            break;
866

867 868 869
        case 'E':
            threequarter_fs=1;
            break;
870

871
        case 'K':
872
#if defined(ENABLE_ITTI)
873
            itti_dump_file = strdup(optarg);
874
#else
875
            printf("-K option is disabled when ENABLE_ITTI is not defined\n");
Raymond Knopp's avatar
 
Raymond Knopp committed
876
#endif
877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974
            break;

        case 'O':
            conf_config_file_name = optarg;
            break;

        case 'U':
            UE_flag = 1;
            break;

        case 'm':
            target_dl_mcs = atoi (optarg);
            break;

        case 't':
            target_ul_mcs = atoi (optarg);
            break;

        case 'W':
            opt_enabled=1;
            opt_type = OPT_WIRESHARK;
            strncpy(in_ip, "127.0.0.1", sizeof(in_ip));
            in_ip[sizeof(in_ip) - 1] = 0; // terminate string
            printf("Enabling OPT for wireshark for local interface");
            /*
            if (optarg == NULL){
            in_ip[0] =NULL;
            printf("Enabling OPT for wireshark for local interface");
            } else {
            strncpy(in_ip, optarg, sizeof(in_ip));
            in_ip[sizeof(in_ip) - 1] = 0; // terminate string
            printf("Enabling OPT for wireshark with %s \n",in_ip);
            }
                 */
            break;

        case 'P':
            opt_type = OPT_PCAP;
            opt_enabled=1;

            if (optarg == NULL) {
                strncpy(in_path, "/tmp/oai_opt.pcap", sizeof(in_path));
                in_path[sizeof(in_path) - 1] = 0; // terminate string
                printf("Enabling OPT for PCAP with the following path /tmp/oai_opt.pcap");
            } else {
                strncpy(in_path, optarg, sizeof(in_path));
                in_path[sizeof(in_path) - 1] = 0; // terminate string
                printf("Enabling OPT for PCAP  with the following file %s \n",in_path);
            }

            break;

        case 'V':
            ouput_vcd = 1;
            break;

        case  'q':
            opp_enabled = 1;
            break;

        case  'R' :
            online_log_messages =1;
            break;

        case 'r':
            UE_scan = 0;

            for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
                switch(atoi(optarg)) {
                case 6:
                    frame_parms[CC_id]->N_RB_DL=6;
                    frame_parms[CC_id]->N_RB_UL=6;
                    break;

                case 25:
                    frame_parms[CC_id]->N_RB_DL=25;
                    frame_parms[CC_id]->N_RB_UL=25;
                    break;

                case 50:
                    frame_parms[CC_id]->N_RB_DL=50;
                    frame_parms[CC_id]->N_RB_UL=50;
                    break;

                case 100:
                    frame_parms[CC_id]->N_RB_DL=100;
                    frame_parms[CC_id]->N_RB_UL=100;
                    break;

                default:
                    printf("Unknown N_RB_DL %d, switching to 25\n",atoi(optarg));
                    break;
                }
            }

            break;

        case 's':
975
#if defined(OAI_USRP) || defined(CPRIGW)
Raymond Knopp's avatar
 
Raymond Knopp committed
976

977
            clock_src = atoi(optarg);
978

979 980 981 982 983 984 985
            if (clock_src == 0) {
                //  char ref[128] = "internal";
                //strncpy(uhd_ref, ref, strlen(ref)+1);
            } else if (clock_src == 1) {
                //char ref[128] = "external";
                //strncpy(uhd_ref, ref, strlen(ref)+1);
            }
986

Raymond Knopp's avatar
 
Raymond Knopp committed
987
#else
988
            printf("Note: -s not defined for ExpressMIMO2\n");
Raymond Knopp's avatar
 
Raymond Knopp committed
989
#endif
990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028
            break;

        case 'S':
            exit_missed_slots=0;
            printf("Skip exit for missed slots\n");
            break;

        case 'g':
            glog_level=atoi(optarg); // value between 1 - 9
            break;

        case 'F':
            break;

        case 'G':
            glog_verbosity=atoi(optarg);// value from 0, 0x5, 0x15, 0x35, 0x75
            break;

        case 'x':
            printf("Transmission mode should be set in config file now\n");
            exit(-1);
            /*
            transmission_mode = atoi(optarg);

            if (transmission_mode > 7) {
              printf("Transmission mode %d not supported for the moment\n",transmission_mode);
              exit(-1);
            }
            */
            break;

        case 'T':
            for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++)
                frame_parms[CC_id]->frame_type = TDD;
            break;

        case 'h':
            help ();
            exit (-1);
1029

1030 1031 1032 1033
        default:
            help ();
            exit (-1);
            break;
1034
        }
1035
    }
1036

1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097
    if (UE_flag == 0)
        AssertFatal(conf_config_file_name != NULL,"Please provide a configuration file\n");

    if ((UE_flag == 0) && (conf_config_file_name != NULL)) {
        int i,j;

        NB_eNB_INST = 1;

        /* Read eNB configuration file */
        enb_properties = enb_config_init(conf_config_file_name);

        AssertFatal (NB_eNB_INST <= enb_properties->number,
                     "Number of eNB is greater than eNB defined in configuration file %s (%d/%d)!",
                     conf_config_file_name, NB_eNB_INST, enb_properties->number);

        /* Update some simulation parameters */
        for (i=0; i < enb_properties->number; i++) {
            AssertFatal (MAX_NUM_CCs == enb_properties->properties[i]->nb_cc,
                         "lte-softmodem compiled with MAX_NUM_CCs=%d, but only %d CCs configured for eNB %d!",
                         MAX_NUM_CCs, enb_properties->properties[i]->nb_cc, i);
            eth_params = (eth_params_t*)malloc(enb_properties->properties[i]->nb_rrh_gw * sizeof(eth_params_t));
            memset(eth_params, 0, enb_properties->properties[i]->nb_rrh_gw * sizeof(eth_params_t));

            for (j=0; j<enb_properties->properties[i]->nb_rrh_gw; j++) {

                if (enb_properties->properties[i]->rrh_gw_config[j].active == 1 ) {
                    local_remote_radio = BBU_REMOTE_RADIO_HEAD;
                    (eth_params+j)->local_if_name             = enb_properties->properties[i]->rrh_gw_config[j].rrh_gw_if_name;
                    (eth_params+j)->my_addr                   = enb_properties->properties[i]->rrh_gw_config[j].local_address;
                    (eth_params+j)->my_port                   = enb_properties->properties[i]->rrh_gw_config[j].local_port;
                    (eth_params+j)->remote_addr               = enb_properties->properties[i]->rrh_gw_config[j].remote_address;
                    (eth_params+j)->remote_port               = enb_properties->properties[i]->rrh_gw_config[j].remote_port;

                    if (enb_properties->properties[i]->rrh_gw_config[j].raw == 1) {
                        (eth_params+j)->transp_preference       = ETH_RAW_MODE;
                    } else if (enb_properties->properties[i]->rrh_gw_config[j].rawif4p5 == 1) {
                        (eth_params+j)->transp_preference       = ETH_RAW_IF4p5_MODE;
                    } else if (enb_properties->properties[i]->rrh_gw_config[j].udpif4p5 == 1) {
                        (eth_params+j)->transp_preference       = ETH_UDP_IF4p5_MODE;
                    } else if (enb_properties->properties[i]->rrh_gw_config[j].rawif5_mobipass == 1) {
                        (eth_params+j)->transp_preference       = ETH_RAW_IF5_MOBIPASS;
                    } else {
                        (eth_params+j)->transp_preference       = ETH_UDP_MODE;
                    }

                    (eth_params+j)->iq_txshift                = enb_properties->properties[i]->rrh_gw_config[j].iq_txshift;
                    (eth_params+j)->tx_sample_advance         = enb_properties->properties[i]->rrh_gw_config[j].tx_sample_advance;
                    (eth_params+j)->tx_scheduling_advance     = enb_properties->properties[i]->rrh_gw_config[j].tx_scheduling_advance;
                    if (enb_properties->properties[i]->rrh_gw_config[j].exmimo == 1) {
                        (eth_params+j)->rf_preference          = EXMIMO_DEV;
                    } else if (enb_properties->properties[i]->rrh_gw_config[j].usrp_b200 == 1) {
                        (eth_params+j)->rf_preference          = USRP_B200_DEV;
                    } else if (enb_properties->properties[i]->rrh_gw_config[j].usrp_x300 == 1) {
                        (eth_params+j)->rf_preference          = USRP_X300_DEV;
                    } else if (enb_properties->properties[i]->rrh_gw_config[j].bladerf == 1) {
                        (eth_params+j)->rf_preference          = BLADERF_DEV;
                    } else if (enb_properties->properties[i]->rrh_gw_config[j].lmssdr == 1) {
                        //(eth_params+j)->rf_preference          = LMSSDR_DEV;
                    } else {
                        (eth_params+j)->rf_preference          = 0;
                    }
1098
                    (eth_params+j)->if_compress               = enb_properties->properties[i]->rrh_gw_config[j].if_compress;
1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166
                } else {
                    local_remote_radio = BBU_LOCAL_RADIO_HEAD;
                }

            }

            for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {


                node_function[CC_id]  = enb_properties->properties[i]->cc_node_function[CC_id];
                node_timing[CC_id]    = enb_properties->properties[i]->cc_node_timing[CC_id];
                node_synch_ref[CC_id] = enb_properties->properties[i]->cc_node_synch_ref[CC_id];

                frame_parms[CC_id]->frame_type =       enb_properties->properties[i]->frame_type[CC_id];
                frame_parms[CC_id]->tdd_config =       enb_properties->properties[i]->tdd_config[CC_id];
                frame_parms[CC_id]->tdd_config_S =     enb_properties->properties[i]->tdd_config_s[CC_id];
                frame_parms[CC_id]->Ncp =              enb_properties->properties[i]->prefix_type[CC_id];

                //for (j=0; j < enb_properties->properties[i]->nb_cc; j++ ){
                frame_parms[CC_id]->Nid_cell            =  enb_properties->properties[i]->Nid_cell[CC_id];
                frame_parms[CC_id]->N_RB_DL             =  enb_properties->properties[i]->N_RB_DL[CC_id];
                frame_parms[CC_id]->N_RB_UL             =  enb_properties->properties[i]->N_RB_DL[CC_id];
                frame_parms[CC_id]->nb_antennas_tx      =  enb_properties->properties[i]->nb_antennas_tx[CC_id];
                frame_parms[CC_id]->nb_antenna_ports_eNB  =  enb_properties->properties[i]->nb_antenna_ports[CC_id];
                frame_parms[CC_id]->nb_antennas_rx      =  enb_properties->properties[i]->nb_antennas_rx[CC_id];

                frame_parms[CC_id]->prach_config_common.prach_ConfigInfo.prach_ConfigIndex = enb_properties->properties[i]->prach_config_index[CC_id];
                frame_parms[CC_id]->prach_config_common.prach_ConfigInfo.prach_FreqOffset  = enb_properties->properties[i]->prach_freq_offset[CC_id];

                frame_parms[CC_id]->mode1_flag         = (frame_parms[CC_id]->nb_antenna_ports_eNB == 1) ? 1 : 0;
                frame_parms[CC_id]->threequarter_fs    = threequarter_fs;

                //} // j
            }


            init_all_otg(0);
            g_otg->seed = 0;
            init_seeds(g_otg->seed);

            for (k=0; k<enb_properties->properties[i]->num_otg_elements; k++) {
                j=enb_properties->properties[i]->otg_ue_id[k]; // ue_id
                g_otg->application_idx[i][j] = 1;
                //g_otg->packet_gen_type=SUBSTRACT_STRING;
                g_otg->background[i][j][0] =enb_properties->properties[i]->otg_bg_traffic[k];
                g_otg->application_type[i][j][0] =enb_properties->properties[i]->otg_app_type[k];// BCBR; //MCBR, BCBR

                printf("[OTG] configuring traffic type %d for  eNB %d UE %d (Background traffic is %s)\n",
                       g_otg->application_type[i][j][0], i, j,(g_otg->background[i][j][0]==1)?"Enabled":"Disabled");
            }

            init_predef_traffic(enb_properties->properties[i]->num_otg_elements, 1);


            glog_level                     = enb_properties->properties[i]->glog_level;
            glog_verbosity                 = enb_properties->properties[i]->glog_verbosity;
            hw_log_level                   = enb_properties->properties[i]->hw_log_level;
            hw_log_verbosity               = enb_properties->properties[i]->hw_log_verbosity ;
            phy_log_level                  = enb_properties->properties[i]->phy_log_level;
            phy_log_verbosity              = enb_properties->properties[i]->phy_log_verbosity;
            mac_log_level                  = enb_properties->properties[i]->mac_log_level;
            mac_log_verbosity              = enb_properties->properties[i]->mac_log_verbosity;
            rlc_log_level                  = enb_properties->properties[i]->rlc_log_level;
            rlc_log_verbosity              = enb_properties->properties[i]->rlc_log_verbosity;
            pdcp_log_level                 = enb_properties->properties[i]->pdcp_log_level;
            pdcp_log_verbosity             = enb_properties->properties[i]->pdcp_log_verbosity;
            rrc_log_level                  = enb_properties->properties[i]->rrc_log_level;
            rrc_log_verbosity              = enb_properties->properties[i]->rrc_log_verbosity;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
1167
# if defined(ENABLE_USE_MME)
1168 1169 1170 1171
            gtpu_log_level                 = enb_properties->properties[i]->gtpu_log_level;
            gtpu_log_verbosity             = enb_properties->properties[i]->gtpu_log_verbosity;
            udp_log_level                  = enb_properties->properties[i]->udp_log_level;
            udp_log_verbosity              = enb_properties->properties[i]->udp_log_verbosity;
Lionel Gauthier's avatar
 
Lionel Gauthier committed
1172
#endif
1173
#if defined (ENABLE_SECURITY)
1174 1175
            osa_log_level                  = enb_properties->properties[i]->osa_log_level;
            osa_log_verbosity              = enb_properties->properties[i]->osa_log_verbosity;
1176
#endif
Florian Kaltenberger's avatar
Florian Kaltenberger committed
1177

1178 1179 1180 1181 1182 1183 1184 1185
            // adjust the log
            for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
                for (k = 0 ; k < 4; k++) {
                    downlink_frequency[CC_id][k]      =       enb_properties->properties[i]->downlink_frequency[CC_id];
                    uplink_frequency_offset[CC_id][k] =  enb_properties->properties[i]->uplink_frequency_offset[CC_id];
                    rx_gain[CC_id][k]                 =  (double)enb_properties->properties[i]->rx_gain[CC_id];
                    tx_gain[CC_id][k]                 =  (double)enb_properties->properties[i]->tx_gain[CC_id];
                }
1186

1187 1188 1189
                printf("Downlink frequency/ uplink offset of CC_id %d set to %ju/%d\n", CC_id,
                       enb_properties->properties[i]->downlink_frequency[CC_id],
                       enb_properties->properties[i]->uplink_frequency_offset[CC_id]);
1190

1191 1192
            } // CC_id
        }// i
1193

1194 1195
        //this is needed for phy-test option
        transmission_mode = enb_properties->properties[0]->ue_TransmissionMode[0]+1;
1196

1197 1198
    } else if (UE_flag == 1) {
        if (conf_config_file_name != NULL) {
1199

1200 1201 1202 1203 1204
            // Here the configuration file is the XER encoded UE capabilities
            // Read it in and store in asn1c data structures
            strcpy(uecap_xer,conf_config_file_name);
            uecap_xer_in=1;
        }
1205
    }
Raymond Knopp's avatar
 
Raymond Knopp committed
1206
}
1207

1208 1209 1210
#if T_TRACER
int T_wait = 1;       /* by default we wait for the tracer */
int T_port = 2021;    /* default port to listen to to wait for the tracer */
1211
int T_dont_fork = 0;  /* default is to fork, see 'T_init' to understand */
1212 1213
#endif

1214
void set_default_frame_parms(LTE_DL_FRAME_PARMS *frame_parms[MAX_NUM_CCs]);
1215
void A(LTE_DL_FRAME_PARMS *frame_parms[MAX_NUM_CCs]) {
Raymond Knopp's avatar
Raymond Knopp committed
1216

1217
    int CC_id;
Raymond Knopp's avatar
Raymond Knopp committed
1218

1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255
    for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
        frame_parms[CC_id] = (LTE_DL_FRAME_PARMS*) malloc(sizeof(LTE_DL_FRAME_PARMS));
        /* Set some default values that may be overwritten while reading options */
        frame_parms[CC_id]->frame_type          = FDD;
        frame_parms[CC_id]->tdd_config          = 3;
        frame_parms[CC_id]->tdd_config_S        = 0;
        frame_parms[CC_id]->N_RB_DL             = 100;
        frame_parms[CC_id]->N_RB_UL             = 100;
        frame_parms[CC_id]->Ncp                 = NORMAL;
        frame_parms[CC_id]->Ncp_UL              = NORMAL;
        frame_parms[CC_id]->Nid_cell            = 0;
        frame_parms[CC_id]->num_MBSFN_config    = 0;
        frame_parms[CC_id]->nb_antenna_ports_eNB  = 1;
        frame_parms[CC_id]->nb_antennas_tx      = 1;
        frame_parms[CC_id]->nb_antennas_rx      = 1;

        frame_parms[CC_id]->nushift             = 0;

        frame_parms[CC_id]->phich_config_common.phich_resource = oneSixth;
        frame_parms[CC_id]->phich_config_common.phich_duration = normal;
        // UL RS Config
        frame_parms[CC_id]->pusch_config_common.ul_ReferenceSignalsPUSCH.cyclicShift = 0;//n_DMRS1 set to 0
        frame_parms[CC_id]->pusch_config_common.ul_ReferenceSignalsPUSCH.groupHoppingEnabled = 0;
        frame_parms[CC_id]->pusch_config_common.ul_ReferenceSignalsPUSCH.sequenceHoppingEnabled = 0;
        frame_parms[CC_id]->pusch_config_common.ul_ReferenceSignalsPUSCH.groupAssignmentPUSCH = 0;

        frame_parms[CC_id]->prach_config_common.rootSequenceIndex=22;
        frame_parms[CC_id]->prach_config_common.prach_ConfigInfo.zeroCorrelationZoneConfig=1;
        frame_parms[CC_id]->prach_config_common.prach_ConfigInfo.prach_ConfigIndex=0;
        frame_parms[CC_id]->prach_config_common.prach_ConfigInfo.highSpeedFlag=0;
        frame_parms[CC_id]->prach_config_common.prach_ConfigInfo.prach_FreqOffset=0;

        downlink_frequency[CC_id][0] = 2680000000; // Use float to avoid issue with frequency over 2^31.
        downlink_frequency[CC_id][1] = downlink_frequency[CC_id][0];
        downlink_frequency[CC_id][2] = downlink_frequency[CC_id][0];
        downlink_frequency[CC_id][3] = downlink_frequency[CC_id][0];
        //printf("Downlink for CC_id %d frequency set to %u\n", CC_id, downlink_frequency[CC_id][0]);
Raymond Knopp's avatar
Raymond Knopp committed
1256

1257
    }
Raymond Knopp's avatar
Raymond Knopp committed
1258 1259 1260

}

1261
//NB_IoT-------------------------------------------------
1262 1263
void set_default_frame_parms_NB_IoT(NB_IoT_DL_FRAME_PARMS *frame_parms[MAX_NUM_CCs]);
void set_default_frame_parms_NB_IoT(NB_IoT_DL_FRAME_PARMS *frame_parms[MAX_NUM_CCs]) {
1264 1265 1266 1267

    int CC_id;

    for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
1268
        frame_parms[CC_id] = (NB_IoT_DL_FRAME_PARMS*) malloc(sizeof(NB_IoT_DL_FRAME_PARMS));
1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306
        /* Set some default values that may be overwritten while reading options */

        //XXX check if there are other parameters to be set

        frame_parms[CC_id]->Ncp                 = NORMAL;
        frame_parms[CC_id]->Ncp_UL              = NORMAL;
        frame_parms[CC_id]->Nid_cell            = 0;
        frame_parms[CC_id]->nb_antenna_ports_eNB  = 1;
        frame_parms[CC_id]->nb_antennas_tx      = 1;
        frame_parms[CC_id]->nb_antennas_rx      = 1;

        frame_parms[CC_id]->nushift             = 0;

        // UL RS Config
        frame_parms[CC_id]->npusch_config_common.ul_ReferenceSignalsNPUSCH.groupHoppingEnabled = 0;
        frame_parms[CC_id]->npusch_config_common.ul_ReferenceSignalsNPUSCH.groupAssignmentNPUSCH = 0;


        frame_parms[CC_id]->nprach_config_common.nprach_CP_Length
		//frame_parms[CC_id]->nprach_config_common.nprach_ParametersList.list.array[CC_id]
		//frame_parms[CC_id]->nprach_config_common.rsrp_ThresholdsPrachInfoList


		//already initialized in the set_default_frame_parms function for LTE

//        downlink_frequency[CC_id][0] = 2680000000; // Use float to avoid issue with frequency over 2^31.
//        downlink_frequency[CC_id][1] = downlink_frequency[CC_id][0];
//        downlink_frequency[CC_id][2] = downlink_frequency[CC_id][0];
//        downlink_frequency[CC_id][3] = downlink_frequency[CC_id][0];
//        //printf("Downlink for CC_id %d frequency set to %u\n", CC_id, downlink_frequency[CC_id][0]);

    }

}




1307 1308
void init_openair0(void);

Raymond Knopp's avatar
Raymond Knopp committed
1309 1310
void init_openair0() {

1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346
    int card;
    int i;

    for (card=0; card<MAX_CARDS; card++) {

        openair0_cfg[card].mmapped_dma=mmapped_dma;
        openair0_cfg[card].configFilename = NULL;

        if(frame_parms[0]->N_RB_DL == 100) {
            if (frame_parms[0]->threequarter_fs) {
                openair0_cfg[card].sample_rate=23.04e6;
                openair0_cfg[card].samples_per_frame = 230400;
                openair0_cfg[card].tx_bw = 10e6;
                openair0_cfg[card].rx_bw = 10e6;
            } else {
                openair0_cfg[card].sample_rate=30.72e6;
                openair0_cfg[card].samples_per_frame = 307200;
                openair0_cfg[card].tx_bw = 10e6;
                openair0_cfg[card].rx_bw = 10e6;
            }
        } else if(frame_parms[0]->N_RB_DL == 50) {
            openair0_cfg[card].sample_rate=15.36e6;
            openair0_cfg[card].samples_per_frame = 153600;
            openair0_cfg[card].tx_bw = 5e6;
            openair0_cfg[card].rx_bw = 5e6;
        } else if (frame_parms[0]->N_RB_DL == 25) {
            openair0_cfg[card].sample_rate=7.68e6;
            openair0_cfg[card].samples_per_frame = 76800;
            openair0_cfg[card].tx_bw = 2.5e6;
            openair0_cfg[card].rx_bw = 2.5e6;
        } else if (frame_parms[0]->N_RB_DL == 6) {
            openair0_cfg[card].sample_rate=1.92e6;
            openair0_cfg[card].samples_per_frame = 19200;
            openair0_cfg[card].tx_bw = 1.5e6;
            openair0_cfg[card].rx_bw = 1.5e6;
        }
Raymond Knopp's avatar
Raymond Knopp committed
1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357




    if (frame_parms[0]->frame_type==TDD)
      openair0_cfg[card].duplex_mode = duplex_mode_TDD;
    else //FDD
      openair0_cfg[card].duplex_mode = duplex_mode_FDD;

    
    if (local_remote_radio == BBU_REMOTE_RADIO_HEAD) {      
1358 1359 1360 1361
      openair0_cfg[card].remote_addr    = (eth_params+card)->remote_addr;
      openair0_cfg[card].remote_port    = (eth_params+card)->remote_port;
      openair0_cfg[card].my_addr        = (eth_params+card)->my_addr;
      openair0_cfg[card].my_port        = (eth_params+card)->my_port;    
Raymond Knopp's avatar
Raymond Knopp committed
1362 1363 1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 1375
    } 
    
    printf("HW: Configuring card %d, nb_antennas_tx/rx %d/%d\n",card,
           ((UE_flag==0) ? PHY_vars_eNB_g[0][0]->frame_parms.nb_antennas_tx : PHY_vars_UE_g[0][0]->frame_parms.nb_antennas_tx),
           ((UE_flag==0) ? PHY_vars_eNB_g[0][0]->frame_parms.nb_antennas_rx : PHY_vars_UE_g[0][0]->frame_parms.nb_antennas_rx));
    openair0_cfg[card].Mod_id = 0;

    if (UE_flag) {
      printf("ETHERNET: Configuring UE ETH for %s:%d\n",rrh_UE_ip,rrh_UE_port);
      openair0_cfg[card].remote_addr   = &rrh_UE_ip[0];
      openair0_cfg[card].remote_port = rrh_UE_port;
    } 

    openair0_cfg[card].num_rb_dl=frame_parms[0]->N_RB_DL;
1376

1377
    openair0_cfg[card].clock_source = clock_source;
1378

1379
    openair0_cfg[card].tx_num_channels=min(2,((UE_flag==0) ? PHY_vars_eNB_g[0][0]->frame_parms.nb_antennas_tx : PHY_vars_UE_g[0][0]->frame_parms.nb_antennas_rx));
Raymond Knopp's avatar
Raymond Knopp committed
1380
    openair0_cfg[card].rx_num_channels=min(2,((UE_flag==0) ? PHY_vars_eNB_g[0][0]->frame_parms.nb_antennas_rx : PHY_vars_UE_g[0][0]->frame_parms.nb_antennas_rx));
1381

Raymond Knopp's avatar
Raymond Knopp committed
1382
    for (i=0; i<4; i++) {
Florian Kaltenberger's avatar
Florian Kaltenberger committed
1383

Raymond Knopp's avatar
Raymond Knopp committed
1384 1385 1386 1387
      if (i<openair0_cfg[card].tx_num_channels)
	openair0_cfg[card].tx_freq[i] = (UE_flag==0) ? downlink_frequency[0][i] : downlink_frequency[0][i]+uplink_frequency_offset[0][i];
      else
	openair0_cfg[card].tx_freq[i]=0.0;
1388

Raymond Knopp's avatar
Raymond Knopp committed
1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399
      if (i<openair0_cfg[card].rx_num_channels)
	openair0_cfg[card].rx_freq[i] = (UE_flag==0) ? downlink_frequency[0][i] + uplink_frequency_offset[0][i] : downlink_frequency[0][i];
      else
	openair0_cfg[card].rx_freq[i]=0.0;

      openair0_cfg[card].autocal[i] = 1;
      openair0_cfg[card].tx_gain[i] = tx_gain[0][i];
      if (UE_flag == 0) {
	openair0_cfg[card].rx_gain[i] = PHY_vars_eNB_g[0][0]->rx_total_gain_dB;
      }
      else {
1400
	openair0_cfg[card].rx_gain[i] = PHY_vars_UE_g[0][0]->rx_total_gain_dB - rx_gain_off;
Raymond Knopp's avatar
Raymond Knopp committed
1401 1402
      }

1403
      openair0_cfg[card].configFilename = rf_config_file;
1404 1405 1406 1407 1408
      printf("Card %d, channel %d, Setting tx_gain %f, rx_gain %f, tx_freq %f, rx_freq %f\n",
             card,i, openair0_cfg[card].tx_gain[i],
             openair0_cfg[card].rx_gain[i],
             openair0_cfg[card].tx_freq[i],
             openair0_cfg[card].rx_freq[i]);
1409
    }
Raymond Knopp's avatar
 
Raymond Knopp committed
1410
  }
Raymond Knopp's avatar
 
Raymond Knopp committed
1411
}
1412

1413 1414
int main( int argc, char **argv ) {
    int i,j,k,aa,re;
1415
#if defined (XFORMS)
1416
    void *status;
1417
#endif
1418

1419 1420 1421
    int CC_id;
    uint8_t  abstraction_flag=0;
    uint8_t beta_ACK=0,beta_RI=0,beta_CQI=2;
1422

Raymond Knopp's avatar
 
Raymond Knopp committed
1423
#if defined (XFORMS)
1424
    int ret;
1425
#endif
1426

1427 1428
    start_background_system();

1429
#ifdef DEBUG_CONSOLE
1430 1431
    setvbuf(stdout, NULL, _IONBF, 0);
    setvbuf(stderr, NULL, _IONBF, 0);
1432 1433
#endif

1434
    PHY_VARS_UE *UE[MAX_NUM_CCs];
1435

1436 1437
    mode = normal_txrx;
    memset(&openair0_cfg[0],0,sizeof(openair0_config_t)*MAX_CARDS);
1438

1439
    memset(tx_max_power,0,sizeof(int)*MAX_NUM_CCs);
gabrielC's avatar
gabrielC committed
1440

1441
    set_latency_target();
1442

1443 1444
    // set default parameters
    set_default_frame_parms(frame_parms);
1445
#ifdef NB_IOT
1446
    set_default_frame_parms_NB_IoT(frame_parms_nb_iot);
1447
#endif
1448

1449

1450 1451
    // initialize logging
    logInit();
1452

1453 1454
    // get options and fill parameters from configuration file
    get_options (argc, argv); //Command-line options, enb_properties
1455

Raymond Knopp's avatar
Raymond Knopp committed
1456 1457 1458 1459




1460
#if T_TRACER
1461
    T_init(T_port, T_wait, T_dont_fork);
1462 1463
#endif

1464 1465
    // initialize the log (see log.h for details)
    set_glog(glog_level, glog_verbosity);
Raymond Knopp's avatar
 
Raymond Knopp committed
1466

1467 1468
    //randominit (0);
    set_taus_seed (0);
1469

1470 1471 1472 1473 1474 1475
    if (UE_flag==1) {
        printf("configuring for UE\n");

        set_comp_log(HW,      LOG_DEBUG,  LOG_HIGH, 1);
        set_comp_log(PHY,     LOG_DEBUG,   LOG_HIGH, 1);
        set_comp_log(MAC,     LOG_INFO,   LOG_HIGH, 1);
1476
        set_comp_log(RLC,     LOG_INFO,   LOG_HIGH | FLAG_THREAD, 1);
1477 1478 1479
        set_comp_log(PDCP,    LOG_INFO,   LOG_HIGH, 1);
        set_comp_log(OTG,     LOG_INFO,   LOG_HIGH, 1);
        set_comp_log(RRC,     LOG_INFO,   LOG_HIGH, 1);
1480
#if defined(ENABLE_ITTI)
1481
        set_comp_log(EMU,     LOG_INFO,   LOG_MED, 1);
1482
# if defined(ENABLE_USE_MME)
1483
        set_comp_log(NAS,     LOG_INFO,   LOG_HIGH, 1);
1484 1485
# endif
#endif
1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496
    } else {
        printf("configuring for eNB\n");

        set_comp_log(HW,      hw_log_level, hw_log_verbosity, 1);
        set_comp_log(PHY,     phy_log_level,   phy_log_verbosity, 1);
        if (opt_enabled == 1 )
            set_comp_log(OPT,   opt_log_level,      opt_log_verbosity, 1);
        set_comp_log(MAC,     mac_log_level,  mac_log_verbosity, 1);
        set_comp_log(RLC,     rlc_log_level,   rlc_log_verbosity, 1);
        set_comp_log(PDCP,    pdcp_log_level,  pdcp_log_verbosity, 1);
        set_comp_log(RRC,     rrc_log_level,  rrc_log_verbosity, 1);
1497
#if defined(ENABLE_ITTI)
1498
        set_comp_log(EMU,     LOG_INFO,   LOG_MED, 1);
1499
# if defined(ENABLE_USE_MME)
1500 1501 1502 1503
        set_comp_log(UDP_,    udp_log_level,   udp_log_verbosity, 1);
        set_comp_log(GTPU,    gtpu_log_level,   gtpu_log_verbosity, 1);
        set_comp_log(S1AP,    LOG_DEBUG,   LOG_HIGH, 1);
        set_comp_log(SCTP,    LOG_INFO,   LOG_HIGH, 1);
1504
# endif
1505
#if defined(ENABLE_SECURITY)
1506
        set_comp_log(OSA,    osa_log_level,   osa_log_verbosity, 1);
1507
#endif
1508
#endif
1509
#ifdef LOCALIZATION
1510 1511
        set_comp_log(LOCALIZE, LOG_DEBUG, LOG_LOW, 1);
        set_component_filelog(LOCALIZE);
1512
#endif
1513 1514
        set_comp_log(ENB_APP, LOG_INFO, LOG_HIGH, 1);
        set_comp_log(OTG,     LOG_INFO,   LOG_HIGH, 1);
1515

1516 1517 1518 1519
        if (online_log_messages == 1) {
            set_component_filelog(RRC);
            set_component_filelog(PDCP);
        }
Raymond Knopp's avatar
 
Raymond Knopp committed
1520
    }
1521

1522 1523 1524 1525 1526 1527
    if (ouput_vcd) {
        if (UE_flag==1)
            VCD_SIGNAL_DUMPER_INIT("/tmp/openair_dump_UE.vcd");
        else
            VCD_SIGNAL_DUMPER_INIT("/tmp/openair_dump_eNB.vcd");
    }
1528

1529 1530 1531 1532
    if (opp_enabled ==1) {
        reset_opp_meas();
    }
    cpuf=get_cpu_freq_GHz();
1533

1534
#if defined(ENABLE_ITTI)
1535

1536 1537 1538 1539 1540
    if (UE_flag == 1) {
        log_set_instance_type (LOG_INSTANCE_UE);
    } else {
        log_set_instance_type (LOG_INSTANCE_ENB);
    }
1541

1542
    itti_init(TASK_MAX, THREAD_MAX, MESSAGES_ID_MAX, tasks_info, messages_info, messages_definition_xml, itti_dump_file);
1543

1544 1545
    // initialize mscgen log after ITTI
    MSC_INIT(MSC_E_UTRAN, THREAD_MAX+TASK_MAX);
1546
#endif
1547

1548 1549
    if (opt_type != OPT_NONE) {
        radio_type_t radio_type;
1550

1551 1552 1553 1554
        if (frame_parms[0]->frame_type == FDD)
            radio_type = RADIO_TYPE_FDD;
        else
            radio_type = RADIO_TYPE_TDD;
1555

1556 1557 1558
        if (init_opt(in_path, in_ip, NULL, radio_type) == -1)
            LOG_E(OPT,"failed to run OPT \n");
    }
1559

1560
#ifdef PDCP_USE_NETLINK
1561
    netlink_init();
1562
#if defined(PDCP_USE_NETLINK_QUEUES)
1563
    pdcp_netlink_init();
1564
#endif
1565 1566
#endif

1567
#if !defined(ENABLE_ITTI)
1568 1569 1570
    // to make a graceful exit when ctrl-c is pressed
    signal(SIGSEGV, signal_handler);
    signal(SIGINT, signal_handler);
1571
#endif
1572

1573

1574
    check_clock();
Raymond Knopp's avatar
 
Raymond Knopp committed
1575

1576 1577 1578 1579 1580 1581
#ifndef PACKAGE_VERSION
#  define PACKAGE_VERSION "UNKNOWN-EXPERIMENTAL"
#endif

  LOG_I(HW, "Version: %s\n", PACKAGE_VERSION);

Raymond Knopp's avatar
 
Raymond Knopp committed
1582
  // init the parameters
1583 1584
  for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {

Raymond Knopp's avatar
Raymond Knopp committed
1585
    if (UE_flag==1) {
1586 1587
      frame_parms[CC_id]->nb_antennas_tx     = nb_antenna_tx;
      frame_parms[CC_id]->nb_antennas_rx     = nb_antenna_rx;
1588
      frame_parms[CC_id]->nb_antenna_ports_eNB = 1; //initial value overwritten by initial sync later
1589 1590

      LOG_I(PHY,"Set nb_rx_antenna %d , nb_tx_antenna %d \n",frame_parms[CC_id]->nb_antennas_rx, frame_parms[CC_id]->nb_antennas_tx);
1591

1592
#ifdef NB_IOT
1593 1594 1595 1596 1597 1598 1599
      frame_parms_nb_iot[CC_id]->nb_antennas_tx     = nb_antenna_tx;
      frame_parms_nb_iot[CC_id]->nb_antennas_rx     = nb_antenna_rx;
      frame_parms_nb_iot[CC_id]->nb_antenna_ports_eNB = 1; //initial value overwritten by initial sync later

      LOG_I(PHY,"[NB-IoT] Set nb_rx_antenna %d , nb_tx_antenna %d \n",frame_parms_nb_iot[CC_id]->nb_antennas_rx, frame_parms_nb_iot[CC_id]->nb_antennas_tx);

#endif
1600 1601
    }

1602 1603

    //XXXX we need to modify it for NB-IoT????
1604 1605
    init_ul_hopping(frame_parms[CC_id]);
    init_frame_parms(frame_parms[CC_id],1);
1606 1607
    //   phy_init_top(frame_parms[CC_id]);
    phy_init_lte_top(frame_parms[CC_id]);
Raymond Knopp's avatar
 
Raymond Knopp committed
1608 1609 1610
  }


1611 1612

    for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
1613
        //init prach for openair1 test
1614

1615 1616
        // prach_fmt = get_prach_fmt(frame_parms->prach_config_common.prach_ConfigInfo.prach_ConfigIndex, frame_parms->frame_type);
        // N_ZC = (prach_fmt <4)?839:139;
Raymond Knopp's avatar
 
Raymond Knopp committed
1617
    }
1618

1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658
    if (UE_flag==1) {
        NB_UE_INST=1;
        NB_INST=1;

        PHY_vars_UE_g = malloc(sizeof(PHY_VARS_UE**));
        PHY_vars_UE_g[0] = malloc(sizeof(PHY_VARS_UE*)*MAX_NUM_CCs);

        for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {

            PHY_vars_UE_g[0][CC_id] = init_lte_UE(frame_parms[CC_id], 0,abstraction_flag);
            UE[CC_id] = PHY_vars_UE_g[0][CC_id];
            printf("PHY_vars_UE_g[0][%d] = %p\n",CC_id,UE[CC_id]);

            if (phy_test==1)
                UE[CC_id]->mac_enabled = 0;
            else
                UE[CC_id]->mac_enabled = 1;

            if (UE[CC_id]->mac_enabled == 0) {  //set default UL parameters for testing mode
                for (i=0; i<NUMBER_OF_CONNECTED_eNB_MAX; i++) {
                    UE[CC_id]->pusch_config_dedicated[i].betaOffset_ACK_Index = beta_ACK;
                    UE[CC_id]->pusch_config_dedicated[i].betaOffset_RI_Index  = beta_RI;
                    UE[CC_id]->pusch_config_dedicated[i].betaOffset_CQI_Index = beta_CQI;

                    UE[CC_id]->scheduling_request_config[i].sr_PUCCH_ResourceIndex = 0;
                    UE[CC_id]->scheduling_request_config[i].sr_ConfigIndex = 7+(0%3);
                    UE[CC_id]->scheduling_request_config[i].dsr_TransMax = sr_n4;
                }
            }

            UE[CC_id]->UE_scan = UE_scan;
            UE[CC_id]->UE_scan_carrier = UE_scan_carrier;
            UE[CC_id]->mode    = mode;
            printf("UE[%d]->mode = %d\n",CC_id,mode);

            compute_prach_seq(&UE[CC_id]->frame_parms.prach_config_common,
                              UE[CC_id]->frame_parms.frame_type,
                              UE[CC_id]->X_u);

            if (UE[CC_id]->mac_enabled == 1)
hbilel's avatar
hbilel committed
1659 1660 1661 1662
            {
                UE[CC_id]->pdcch_vars[0][0]->crnti = 0x1234;
                UE[CC_id]->pdcch_vars[1][0]->crnti = 0x1234;
            }
1663
            else
hbilel's avatar
hbilel committed
1664 1665 1666 1667
            {
                UE[CC_id]->pdcch_vars[0][0]->crnti = 0x1235;
                UE[CC_id]->pdcch_vars[1][0]->crnti = 0x1235;
            }
1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678 1679 1680 1681

            UE[CC_id]->rx_total_gain_dB =  (int)rx_gain[CC_id][0] + rx_gain_off;
            UE[CC_id]->tx_power_max_dBm = tx_max_power[CC_id];

            if (frame_parms[CC_id]->frame_type==FDD) {
                UE[CC_id]->N_TA_offset = 0;
            } else {
                if (frame_parms[CC_id]->N_RB_DL == 100)
                    UE[CC_id]->N_TA_offset = 624;
                else if (frame_parms[CC_id]->N_RB_DL == 50)
                    UE[CC_id]->N_TA_offset = 624/2;
                else if (frame_parms[CC_id]->N_RB_DL == 25)
                    UE[CC_id]->N_TA_offset = 624/4;
            }
1682

1683
        }
1684

1685 1686 1687
        //  printf("tx_max_power = %d -> amp %d\n",tx_max_power,get_tx_amp(tx_max_poHwer,tx_max_power));
    } else {
        //this is eNB
1688
        PHY_vars_eNB_g = malloc(sizeof(PHY_VARS_eNB**)); //global PHY_vars --> is a matrix
1689 1690 1691
        PHY_vars_eNB_g[0] = malloc(sizeof(PHY_VARS_eNB*));

        for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
1692
        	//we initialiaze DL/UL buffer and HARQ (inside the LTE_eNB_DLSCH)
1693

1694
            PHY_vars_eNB_g[0][CC_id] = init_lte_eNB(frame_parms[CC_id],0,frame_parms[CC_id]->Nid_cell,node_function[CC_id],abstraction_flag);
1695 1696
            //this is a complementary function for just initialize manage NB_ioT stuff inside the PHY_Vars
#ifdef NB_IOT
1697
            //init_lte_eNB_NB(PHY_vars_eNB_g[0][CC_id],frame_parms_nb_iot[CC_id], 0, frame_parms_nb_iot[CC_id]->Nid_cell,node_function[CC_id],abstraction_flag);
1698 1699
#endif

1700 1701 1702 1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727 1728 1729 1730
            PHY_vars_eNB_g[0][CC_id]->ue_dl_rb_alloc=0x1fff;
            PHY_vars_eNB_g[0][CC_id]->target_ue_dl_mcs=target_dl_mcs;
            PHY_vars_eNB_g[0][CC_id]->ue_ul_nb_rb=6;
            PHY_vars_eNB_g[0][CC_id]->target_ue_ul_mcs=target_ul_mcs;
            // initialization for phy-test
            for (k=0; k<NUMBER_OF_UE_MAX; k++) {
                PHY_vars_eNB_g[0][CC_id]->transmission_mode[k] = transmission_mode;
                if (transmission_mode==7)
                    lte_gold_ue_spec_port5(PHY_vars_eNB_g[0][CC_id]->lte_gold_uespec_port5_table[k],frame_parms[CC_id]->Nid_cell,0x1235+k);
            }
            if ((transmission_mode==1) || (transmission_mode==7)) {
                for (j=0; j<frame_parms[CC_id]->nb_antennas_tx; j++)
                    for (re=0; re<frame_parms[CC_id]->ofdm_symbol_size; re++)
                        PHY_vars_eNB_g[0][CC_id]->common_vars.beam_weights[0][0][j][re] = 0x00007fff/frame_parms[CC_id]->nb_antennas_tx;
            }

            if (phy_test==1) PHY_vars_eNB_g[0][CC_id]->mac_enabled = 0;
            else PHY_vars_eNB_g[0][CC_id]->mac_enabled = 1;

            if (PHY_vars_eNB_g[0][CC_id]->mac_enabled == 0) { //set default parameters for testing mode
                for (i=0; i<NUMBER_OF_UE_MAX; i++) {
                    PHY_vars_eNB_g[0][CC_id]->pusch_config_dedicated[i].betaOffset_ACK_Index = beta_ACK;
                    PHY_vars_eNB_g[0][CC_id]->pusch_config_dedicated[i].betaOffset_RI_Index  = beta_RI;
                    PHY_vars_eNB_g[0][CC_id]->pusch_config_dedicated[i].betaOffset_CQI_Index = beta_CQI;

                    PHY_vars_eNB_g[0][CC_id]->scheduling_request_config[i].sr_PUCCH_ResourceIndex = i;
                    PHY_vars_eNB_g[0][CC_id]->scheduling_request_config[i].sr_ConfigIndex = 7+(i%3);
                    PHY_vars_eNB_g[0][CC_id]->scheduling_request_config[i].dsr_TransMax = sr_n4;
                }
            }

1731
            //TODO: this is different for NB-IoT
1732 1733 1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744 1745 1746 1747 1748
            compute_prach_seq(&PHY_vars_eNB_g[0][CC_id]->frame_parms.prach_config_common,
                              PHY_vars_eNB_g[0][CC_id]->frame_parms.frame_type,
                              PHY_vars_eNB_g[0][CC_id]->X_u);


            PHY_vars_eNB_g[0][CC_id]->rx_total_gain_dB = (int)rx_gain[CC_id][0];

            if (frame_parms[CC_id]->frame_type==FDD) {
                PHY_vars_eNB_g[0][CC_id]->N_TA_offset = 0;
            } else {
                if (frame_parms[CC_id]->N_RB_DL == 100)
                    PHY_vars_eNB_g[0][CC_id]->N_TA_offset = 624;
                else if (frame_parms[CC_id]->N_RB_DL == 50)
                    PHY_vars_eNB_g[0][CC_id]->N_TA_offset = 624/2;
                else if (frame_parms[CC_id]->N_RB_DL == 25)
                    PHY_vars_eNB_g[0][CC_id]->N_TA_offset = 624/4;
            }
1749

1750
        }
1751

1752

1753 1754
        NB_eNB_INST=1;
        NB_INST=1;
1755 1756

    }
1757

1758 1759
    fill_modeled_runtime_table(runtime_phy_rx,runtime_phy_tx);
    cpuf=get_cpu_freq_GHz();
1760

1761

1762
    dump_frame_parms(frame_parms[0]);
1763

1764
    init_openair0();
Raymond Knopp's avatar
Raymond Knopp committed
1765 1766


1767

laurent's avatar
laurent committed
1768
#ifndef DEADLINE_SCHEDULER
1769

1770 1771 1772 1773 1774 1775
    /* Currently we set affinity for UHD to CPU 0 for eNB/UE and only if number of CPUS >2 */

    cpu_set_t cpuset;
    int s;
    char cpu_affinity[1024];
    CPU_ZERO(&cpuset);
1776
#ifdef CPU_AFFINITY
1777 1778 1779 1780 1781 1782 1783 1784
    if (get_nprocs() > 2) {
        CPU_SET(0, &cpuset);
        s = pthread_setaffinity_np(pthread_self(), sizeof(cpu_set_t), &cpuset);
        if (s != 0) {
            perror( "pthread_setaffinity_np");
            exit_fun("Error setting processor affinity");
        }
        LOG_I(HW, "Setting the affinity of main function to CPU 0, for device library to use CPU 0 only!\n");
1785
    }
1786
#endif
1787

1788 1789 1790 1791 1792
    /* Check the actual affinity mask assigned to the thread */
    s = pthread_getaffinity_np(pthread_self(), sizeof(cpu_set_t), &cpuset);
    if (s != 0) {
        perror( "pthread_getaffinity_np");
        exit_fun("Error getting processor affinity ");
1793
    }
1794 1795 1796 1797 1798 1799 1800
    memset(cpu_affinity, 0 , sizeof(cpu_affinity));
    for (int j = 0; j < CPU_SETSIZE; j++) {
        if (CPU_ISSET(j, &cpuset)) {
            char temp[1024];
            sprintf(temp, " CPU_%d ", j);
            strcat(cpu_affinity, temp);
        }
1801
    }
1802
    LOG_I(HW, "CPU Affinity of main() function is... %s\n", cpu_affinity);
1803
#endif
1804

1805
    openair0_cfg[0].log_level = glog_level;
1806 1807


Raymond Knopp's avatar
Raymond Knopp committed
1808

1809 1810 1811

    int eMBMS_active=0;
    if (node_function[0] <= NGFI_RAU_IF4p5) { // don't initialize L2 for RRU
1812

1813 1814
        // MP, Nick: Initialization of IF module for NB-IoT should be here
#ifdef NB_IOT
1815 1816
        	if_inst = malloc(sizeof(IF_Module_t));
        	LOG_I(PHY,"Allocate IF-Module for NB-IoT\n");
1817
#endif
1818 1819
        //---------------------------

1820
        LOG_I(PHY,"Intializing L2\n");
1821

1822 1823 1824 1825
        mac_xface = malloc(sizeof(MAC_xface));
        l2_init(frame_parms[0],eMBMS_active,(uecap_xer_in==1)?uecap_xer:NULL,
                0,// cba_group_active
                0); // HO flag
1826

1827 1828
//initialize L2 for NB-IoT stuff (complementary to legacy OAI initialization)
#ifdef NB_IOT
1829
        l2_init_eNB_NB_IoT();
1830 1831 1832
#endif


1833 1834 1835 1836
        mac_xface->macphy_exit = &exit_fun;
    } else if (node_function[0] == NGFI_RRU_IF4p5) { // Initialize PRACH in this case

    }
Raymond Knopp's avatar
Raymond Knopp committed
1837 1838


1839

winckel's avatar
winckel committed
1840
#if defined(ENABLE_ITTI)
1841

1842
    if ((UE_flag == 1)||
1843
	((node_function[0]<NGFI_RAU_IF4p5)&&(phy_test==0)))
1844 1845 1846 1847 1848
        // don't create if node doesn't connect to RRC/S1/GTP
        if (create_tasks(UE_flag ? 0 : 1, UE_flag ? 1 : 0) < 0) {
            printf("cannot create ITTI tasks\n");
            exit(-1); // need a softer mode
        }
1849

1850
    printf("ITTI tasks created\n");
winckel's avatar
winckel committed
1851
#endif
Florian Kaltenberger's avatar
 
Florian Kaltenberger committed
1852

1853 1854 1855 1856 1857 1858 1859 1860
    if (phy_test==0) {
        if (UE_flag==1) {
            printf("Filling UE band info\n");
            fill_ue_band_info();
            mac_xface->dl_phy_sync_success (0, 0, 0, 1);
        } else if (node_function[0]>NGFI_RRU_IF4p5)
            mac_xface->mrbch_phy_sync_failure (0, 0, 0);
    }
Raymond Knopp's avatar
 
Raymond Knopp committed
1861

1862

1863

1864
    mlockall(MCL_CURRENT | MCL_FUTURE);
1865

1866 1867
    pthread_cond_init(&sync_cond,NULL);
    pthread_mutex_init(&sync_mutex, NULL);
1868 1869

#ifdef XFORMS
1870 1871 1872 1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914
    int UE_id;

    if (do_forms==1) {
        fl_initialize (&argc, argv, NULL, 0, 0);

        if (UE_flag==0) {
            form_stats_l2 = create_form_stats_form();
            fl_show_form (form_stats_l2->stats_form, FL_PLACE_HOTSPOT, FL_FULLBORDER, "l2 stats");
            form_stats = create_form_stats_form();
            fl_show_form (form_stats->stats_form, FL_PLACE_HOTSPOT, FL_FULLBORDER, "stats");

            for(UE_id=0; UE_id<scope_enb_num_ue; UE_id++) {
                for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
                    form_enb[CC_id][UE_id] = create_lte_phy_scope_enb();
                    sprintf (title, "LTE UL SCOPE eNB for CC_id %d, UE %d",CC_id,UE_id);
                    fl_show_form (form_enb[CC_id][UE_id]->lte_phy_scope_enb, FL_PLACE_HOTSPOT, FL_FULLBORDER, title);

                    if (otg_enabled) {
                        fl_set_button(form_enb[CC_id][UE_id]->button_0,1);
                        fl_set_object_label(form_enb[CC_id][UE_id]->button_0,"DL Traffic ON");
                    } else {
                        fl_set_button(form_enb[CC_id][UE_id]->button_0,0);
                        fl_set_object_label(form_enb[CC_id][UE_id]->button_0,"DL Traffic OFF");
                    }
                } // CC_id
            } // UE_id
        } else {
            form_stats = create_form_stats_form();
            fl_show_form (form_stats->stats_form, FL_PLACE_HOTSPOT, FL_FULLBORDER, "stats");
            UE_id = 0;
            form_ue[UE_id] = create_lte_phy_scope_ue();
            sprintf (title, "LTE DL SCOPE UE");
            fl_show_form (form_ue[UE_id]->lte_phy_scope_ue, FL_PLACE_HOTSPOT, FL_FULLBORDER, title);

            /*
            if (openair_daq_vars.use_ia_receiver) {
                   fl_set_button(form_ue[UE_id]->button_0,1);
                   fl_set_object_label(form_ue[UE_id]->button_0, "IA Receiver ON");
            } else {
                   fl_set_button(form_ue[UE_id]->button_0,0);
                   fl_set_object_label(form_ue[UE_id]->button_0, "IA Receiver OFF");
            }*/
            fl_set_button(form_ue[UE_id]->button_0,0);
            fl_set_object_label(form_ue[UE_id]->button_0, "IA Receiver OFF");
        }
Raymond Knopp's avatar
 
Raymond Knopp committed
1915

1916
        ret = pthread_create(&forms_thread, NULL, scope_thread, NULL);
1917

1918 1919
        if (ret == 0)
            pthread_setname_np( forms_thread, "xforms" );
1920

1921 1922
        printf("Scope thread created, ret=%d\n",ret);
    }
1923

1924 1925
#endif

1926
    rt_sleep_ns(10*100000000ULL);
1927

Raymond Knopp's avatar
 
Raymond Knopp committed
1928

1929

1930 1931 1932 1933
    // start the main thread
    if (UE_flag == 1) {
        init_UE(1);
        number_of_cards = 1;
1934

1935 1936 1937 1938 1939
        for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
            PHY_vars_UE_g[0][CC_id]->rf_map.card=0;
            PHY_vars_UE_g[0][CC_id]->rf_map.chain=CC_id+chain_offset;
        }
    } else {
Nick Ho's avatar
Nick Ho committed
1940

1941
#ifdef NB_IOT
Nick Ho's avatar
Nick Ho committed
1942
        printf("Initializing IF Module in PHY layer\n");
1943
        //register function
Nick Ho's avatar
Nick Ho committed
1944
        IF_Module_init_L1();
1945
#endif
Nick Ho's avatar
Nick Ho committed
1946

1947 1948 1949 1950 1951 1952 1953 1954 1955
        printf("Initializing eNB threads\n");
        init_eNB(node_function,node_timing,1,eth_params,single_thread_flag,wait_for_sync);

        number_of_cards = 1;

        for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
            PHY_vars_eNB_g[0][CC_id]->rf_map.card=0;
            PHY_vars_eNB_g[0][CC_id]->rf_map.chain=CC_id+chain_offset;
        }
Raymond Knopp's avatar
 
Raymond Knopp committed
1956
    }
1957

1958 1959 1960 1961
    // connect the TX/RX buffers
    if (UE_flag==1) {

        for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
1962 1963


1964
#ifdef OAI_USRP
1965
            UE[CC_id]->hw_timing_advance = timing_advance;
1966
#else
1967
            UE[CC_id]->hw_timing_advance = 160;
1968
#endif
1969 1970 1971 1972 1973
        }
        if (setup_ue_buffers(UE,&openair0_cfg[0])!=0) {
            printf("Error setting up eNB buffer\n");
            exit(-1);
        }
1974 1975 1976



1977 1978 1979 1980 1981 1982 1983 1984 1985 1986
        if (input_fd) {
            printf("Reading in from file to antenna buffer %d\n",0);
            if (fread(UE[0]->common_vars.rxdata[0],
                      sizeof(int32_t),
                      frame_parms[0]->samples_per_tti*10,
                      input_fd) != frame_parms[0]->samples_per_tti*10)
                printf("error reading from file\n");
        }
        //p_exmimo_config->framing.tdd_config = TXRXSWITCH_TESTRX;
    } else {
1987

Raymond Knopp's avatar
 
Raymond Knopp committed
1988

1989

1990

1991

1992
        printf("Setting eNB buffer to all-RX\n");
navid's avatar
navid committed
1993

1994 1995 1996 1997 1998 1999 2000
        // Set LSBs for antenna switch (ExpressMIMO)
        for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
            PHY_vars_eNB_g[0][CC_id]->hw_timing_advance = 0;
            for (i=0; i<frame_parms[CC_id]->samples_per_tti*10; i++)
                for (aa=0; aa<frame_parms[CC_id]->nb_antennas_tx; aa++)
                    PHY_vars_eNB_g[0][CC_id]->common_vars.txdata[0][aa][i] = 0x00010001;
        }
2001
    }
2002
    sleep(3);
2003

2004

2005
    printf("Sending sync to all threads\n");
2006

2007 2008 2009 2010
    pthread_mutex_lock(&sync_mutex);
    sync_var=0;
    pthread_cond_broadcast(&sync_cond);
    pthread_mutex_unlock(&sync_mutex);
2011

2012 2013 2014
    // wait for end of program
    printf("TYPE <CTRL-C> TO TERMINATE\n");
    //getchar();
2015 2016

#if defined(ENABLE_ITTI)
2017 2018 2019
    printf("Entering ITTI signals handler\n");
    itti_wait_tasks_end();
    oai_exit=1;
2020
#else
2021

2022 2023
    while (oai_exit==0)
        rt_sleep_ns(100000000ULL);
2024

2025
#endif
2026

2027
    // stop threads
2028
#ifdef XFORMS
2029
    printf("waiting for XFORMS thread\n");
2030

2031 2032 2033 2034
    if (do_forms==1) {
        pthread_join(forms_thread,&status);
        fl_hide_form(form_stats->stats_form);
        fl_free_form(form_stats->stats_form);
2035

2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049
        if (UE_flag==1) {
            fl_hide_form(form_ue[0]->lte_phy_scope_ue);
            fl_free_form(form_ue[0]->lte_phy_scope_ue);
        } else {
            fl_hide_form(form_stats_l2->stats_form);
            fl_free_form(form_stats_l2->stats_form);

            for(UE_id=0; UE_id<scope_enb_num_ue; UE_id++) {
                for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
                    fl_hide_form(form_enb[CC_id][UE_id]->lte_phy_scope_enb);
                    fl_free_form(form_enb[CC_id][UE_id]->lte_phy_scope_enb);
                }
            }
        }
Raymond Knopp's avatar
 
Raymond Knopp committed
2050
    }
2051

2052 2053
#endif

2054
    printf("stopping MODEM threads\n");
2055

2056 2057 2058 2059 2060
    // cleanup
    if (UE_flag == 1) {
    } else {
        stop_eNB(1);
    }
2061

2062

2063 2064
    pthread_cond_destroy(&sync_cond);
    pthread_mutex_destroy(&sync_mutex);
2065

2066

2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077
    // *** Handle per CC_id openair0
    if (UE_flag==1) {
        if (PHY_vars_UE_g[0][0]->rfdevice.trx_end_func)
            PHY_vars_UE_g[0][0]->rfdevice.trx_end_func(&PHY_vars_UE_g[0][0]->rfdevice);
    } else {
        for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
            if (PHY_vars_eNB_g[0][CC_id]->rfdevice.trx_end_func)
                PHY_vars_eNB_g[0][CC_id]->rfdevice.trx_end_func(&PHY_vars_eNB_g[0][CC_id]->rfdevice);
            if (PHY_vars_eNB_g[0][CC_id]->ifdevice.trx_end_func)
                PHY_vars_eNB_g[0][CC_id]->ifdevice.trx_end_func(&PHY_vars_eNB_g[0][CC_id]->ifdevice);
        }
Raymond Knopp's avatar
Raymond Knopp committed
2078
    }
2079 2080
    if (ouput_vcd)
        VCD_SIGNAL_DUMPER_CLOSE();
2081

2082 2083
    if (opt_enabled == 1)
        terminate_opt();
2084

2085
    logClean();
2086

2087
    return 0;
Raymond Knopp's avatar
 
Raymond Knopp committed
2088
}