lte-softmodem.c 49.6 KB
Newer Older
1 2 3 4 5
/*
 * 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
6
 * the OAI Public License, Version 1.1  (the "License"); you may not use this file
7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
 * 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
knopp's avatar
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
knopp's avatar
knopp committed
29 30 31
 * \note
 * \warning
 */
32

33

Cedric Roux's avatar
Cedric Roux committed
34 35 36
#define _GNU_SOURCE             /* See feature_test_macros(7) */
#include <sched.h>

37

38 39
#include "T.h"

40
#include "rt_wrapper.h"
41

42

43 44
#undef MALLOC //there are two conflicting definitions, so we better make sure we don't use it at all

45
#include "assertions.h"
46
#include "msc.h"
47 48

#include "PHY/types.h"
49

50
#include "PHY/defs.h"
51
#include "common/ran_context.h"
52
#include "common/config/config_userapi.h"
oai's avatar
oai committed
53
#include "common/utils/load_module_shlib.h"
54
#undef MALLOC //there are two conflicting definitions, so we better make sure we don't use it at all
knopp's avatar
knopp committed
55
//#undef FRAME_LENGTH_COMPLEX_SAMPLES //there are two conflicting definitions, so we better make sure we don't use it at all
56

knopp's avatar
knopp committed
57
#include "../../ARCH/COMMON/common_lib.h"
58
#include "../../ARCH/ETHERNET/USERSPACE/LIB/if_defs.h"
knopp's avatar
knopp committed
59

knopp's avatar
knopp committed
60
//#undef FRAME_LENGTH_COMPLEX_SAMPLES //there are two conflicting definitions, so we better make sure we don't use it at all
61 62 63 64 65 66 67 68 69

#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"
70
#include "LAYER2/MAC/proto.h"
71 72 73 74 75 76 77 78
#include "RRC/LITE/vars.h"
#include "PHY_INTERFACE/vars.h"

#ifdef SMBV
#include "PHY/TOOLS/smbv.h"
unsigned short config_frames[4] = {2,9,11,13};
#endif
#include "UTIL/LOG/log_extern.h"
nikaeinn's avatar
nikaeinn committed
79
#include "UTIL/OTG/otg_tx.h"
80
#include "UTIL/OTG/otg_externs.h"
81 82
#include "UTIL/MATH/oml.h"
#include "UTIL/LOG/vcd_signal_dumper.h"
83
#include "UTIL/OPT/opt.h"
84
#include "enb_config.h"
nikaeinn's avatar
nikaeinn committed
85
//#include "PHY/TOOLS/time_meas.h"
86

Florian Kaltenberger's avatar
Florian Kaltenberger committed
87 88 89 90
#ifndef OPENAIR2
#include "UTIL/OTG/otg_vars.h"
#endif

91
#if defined(ENABLE_ITTI)
92 93
#include "intertask_interface_init.h"
#include "create_tasks.h"
94 95
#endif

96 97
#include "system.h"

98 99 100
#ifdef XFORMS
#include "PHY/TOOLS/lte_phy_scope.h"
#include "stats.h"
101
#endif
102
#include "lte-softmodem.h"
103

104

105
#ifdef XFORMS
106
// current status is that every UE has a DL scope for a SINGLE eNB (eNB_id=0)
107
// at eNB 0, an UL scope for every UE
108
FD_lte_phy_scope_ue  *form_ue[NUMBER_OF_UE_MAX];
109
FD_lte_phy_scope_enb *form_enb[MAX_NUM_CCs][NUMBER_OF_UE_MAX];
110
FD_stats_form                  *form_stats=NULL,*form_stats_l2=NULL;
111
char title[255];
112
unsigned char                   scope_enb_num_ue = 2;
113
static pthread_t                forms_thread; //xforms
114 115
#endif //XFORMS

knopp's avatar
knopp committed
116 117
pthread_cond_t sync_cond;
pthread_mutex_t sync_mutex;
118
int sync_var=-1; //!< protected by mutex \ref sync_mutex.
119

120 121
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]
knopp's avatar
knopp committed
122

123
#if defined(ENABLE_ITTI)
124 125
volatile int             start_eNB = 0;
volatile int             start_UE = 0;
126
#endif
knopp's avatar
knopp committed
127
volatile int             oai_exit = 0;
128

129
static clock_source_t clock_source = internal;
130
static int wait_for_sync = 0;
knopp's avatar
knopp committed
131

knopp's avatar
knopp committed
132
static char              UE_flag=0;
133
unsigned int                    mmapped_dma=0;
134
int                             single_thread_flag=1;
135

136
static char                     threequarter_fs=0;
137

138
uint32_t                 downlink_frequency[MAX_NUM_CCs][4];
139
int32_t                  uplink_frequency_offset[MAX_NUM_CCs][4];
gauthier's avatar
gauthier committed
140

141

142

143
#if defined(ENABLE_ITTI)
144
static char                    *itti_dump_file = NULL;
knopp's avatar
knopp committed
145 146
#endif

147
int UE_scan = 1;
148
int UE_scan_carrier = 0;
149 150
runmode_t mode = normal_txrx;

151 152
FILE *input_fd=NULL;

153

154 155
#if MAX_NUM_CCs == 1
rx_gain_t                rx_gain_mode[MAX_NUM_CCs][4] = {{max_gain,max_gain,max_gain,max_gain}};
156 157
double tx_gain[MAX_NUM_CCs][4] = {{20,0,0,0}};
double rx_gain[MAX_NUM_CCs][4] = {{110,0,0,0}};
158 159 160 161
#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}};
gauthier's avatar
gauthier committed
162
#endif
knopp's avatar
knopp committed
163

164
double rx_gain_off = 0.0;
165

knopp's avatar
knopp committed
166
double sample_rate=30.72e6;
167
double bw = 10.0e6;
168

169
static int                      tx_max_power[MAX_NUM_CCs]; /* =  {0,0}*/;
170

171 172
char   rf_config_file[1024];

Florian Kaltenberger's avatar
Florian Kaltenberger committed
173
int chain_offset=0;
174
int phy_test = 0;
175
uint8_t usim_test = 0;
Florian Kaltenberger's avatar
Florian Kaltenberger committed
176

177 178 179
uint8_t dci_Format = 0;
uint8_t agregation_Level =0xFF;

180 181
uint8_t nb_antenna_tx = 1;
uint8_t nb_antenna_rx = 1;
182

knopp's avatar
knopp committed
183 184 185
char ref[128] = "internal";
char channels[128] = "0";

186
int                      rx_input_level_dBm;
187

188
#ifdef XFORMS
189
extern int                      otg_enabled;
190
static char                     do_forms=0;
191
#else
192
int                             otg_enabled;
193
#endif
knopp's avatar
knopp committed
194
//int                             number_of_cards =   1;
195

196 197

static LTE_DL_FRAME_PARMS      *frame_parms[MAX_NUM_CCs];
Florian Kaltenberger's avatar
Florian Kaltenberger committed
198
uint32_t target_dl_mcs = 28; //maximum allowed mcs
199
uint32_t target_ul_mcs = 20;
200
uint32_t timing_advance = 0;
201 202
uint8_t exit_missed_slots=1;
uint64_t num_missed_slots=0; // counter for the number of missed slots
203

204

205 206
extern void reset_opp_meas(void);
extern void print_opp_meas(void);
207

208
int transmission_mode=1;
knopp's avatar
knopp committed
209

210

211

212 213 214
/* struct for ethernet specific parameters given in eNB conf file */
eth_params_t *eth_params;

215 216 217 218
openair0_config_t openair0_cfg[MAX_CARDS];

double cpuf;

219 220
extern char uecap_xer[1024];
char uecap_xer_in=0;
221

222
int oaisim_flag=0;
223
threads_t threads= {-1,-1,-1,-1,-1,-1,-1};
knopp's avatar
knopp committed
224

Cedric Roux's avatar
Cedric Roux committed
225 226 227 228
/* 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;
knopp's avatar
knopp committed
229

230 231
/* forward declarations */
void set_default_frame_parms(LTE_DL_FRAME_PARMS *frame_parms[MAX_NUM_CCs]);
232
/* override the enb configuration parameters */
233
static void reconfigure_enb_params(int enb_id);
234

235 236 237 238 239
/*---------------------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 };

240
struct timespec clock_difftime(struct timespec start, struct timespec end) {
241 242 243 244 245 246 247 248 249
  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;
250 251
}

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

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

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

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

286
#if !defined(ENABLE_ITTI)
287
void signal_handler(int sig) {
288 289 290 291 292 293
  void *array[10];
  size_t size;

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

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

311

Raymond Knopp's avatar
Raymond Knopp committed
312

313 314
void exit_fun(const char* s)
{
Raymond Knopp's avatar
Raymond Knopp committed
315
  int CC_id;
316
  int ru_id;
Raymond Knopp's avatar
Raymond Knopp committed
317

318
  if (s != NULL) {
319
    printf("%s %s() Exiting OAI softmodem: %s\n",__FILE__, __FUNCTION__, s);
320 321 322
  }

  oai_exit = 1;
323 324 325 326 327 328 329 330 331 332

  if (UE_flag==0) {
    for (ru_id=0; ru_id<RC.nb_RU;ru_id++) {
      if (RC.ru[ru_id]->rfdevice.trx_end_func)
	RC.ru[ru_id]->rfdevice.trx_end_func(&RC.ru[ru_id]->rfdevice);
      if (RC.ru[ru_id]->ifdevice.trx_end_func)
	RC.ru[ru_id]->ifdevice.trx_end_func(&RC.ru[ru_id]->ifdevice);  
    }
  }

Raymond Knopp's avatar
Raymond Knopp committed
333
  for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
334 335 336 337

    oai_exit = 1;

    for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
338 339 340 341 342
      if (UE_flag == 0) {
      } 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);
      }
knopp's avatar
knopp committed
343
    }
344 345

#if defined(ENABLE_ITTI)
346 347
    sleep(1); //allow lte-softmodem threads to exit first
    itti_terminate_tasks (TASK_UNKNOWN);
348
#endif
349

350
  }
351

352
}
353

354
#ifdef XFORMS
355

356

357 358
void reset_stats(FL_OBJECT *button, long arg)
{
359
  int i,j,k;
360
  PHY_VARS_eNB *phy_vars_eNB = RC.eNB[0][0];
361 362 363

  for (i=0; i<NUMBER_OF_UE_MAX; i++) {
    for (k=0; k<8; k++) { //harq_processes
364
      for (j=0; j<phy_vars_eNB->dlsch[i][0]->Mlimit; j++) {
365 366 367
	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;
368
      }
369

370 371 372
      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;
373 374


375 376 377
      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;
378 379 380 381
    }
  }
}

382
static void *scope_thread(void *arg) {
knopp's avatar
knopp committed
383
  char stats_buffer[16384];
384
# ifdef ENABLE_XFORMS_WRITE_STATS
knopp's avatar
knopp committed
385
  FILE *UE_stats, *eNB_stats;
386
# endif
knopp's avatar
knopp committed
387
  struct sched_param sched_param;
388
  int UE_id, CC_id;
389
  int ue_cnt=0;
390

391
  sched_param.sched_priority = sched_get_priority_min(SCHED_FIFO)+1;
knopp's avatar
knopp committed
392
  sched_setscheduler(0, SCHED_FIFO,&sched_param);
393

knopp's avatar
knopp committed
394
  printf("Scope thread has priority %d\n",sched_param.sched_priority);
395

396
# ifdef ENABLE_XFORMS_WRITE_STATS
397 398

  if (UE_flag==1)
knopp's avatar
knopp committed
399
    UE_stats  = fopen("UE_stats.txt", "w");
400
  else
knopp's avatar
knopp committed
401
    eNB_stats = fopen("eNB_stats.txt", "w");
402

403
#endif
404

knopp's avatar
knopp committed
405 406
  while (!oai_exit) {
    if (UE_flag==1) {
407
      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);
knopp's avatar
knopp committed
408 409 410
      //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);
411

412
      phy_scope_UE(form_ue[0],
413 414 415 416
		   PHY_vars_UE_g[0][0],
		   0,
		   0,7);

417

knopp's avatar
knopp committed
418
    } else {
419
      /*
420
	if (RC.eNB[0][0]->mac_enabled==1) {
421 422 423 424
	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);
425 426
	}
	len = dump_eNB_stats (RC.eNB[0][0], stats_buffer, 0);
427

428 429
	if (MAX_NUM_CCs>1)
	len += dump_eNB_stats (RC.eNB[0][1], &stats_buffer[len], 0);
430

431 432 433
	//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);
434
      */
435 436
      ue_cnt=0;
      for(UE_id=0; UE_id<NUMBER_OF_UE_MAX; UE_id++) {
437
	for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
438
	  //	  if ((RC.eNB[0][CC_id]->dlsch[UE_id][0]->rnti>0) && (ue_cnt<scope_enb_num_ue)) {
439
	  if ((ue_cnt<scope_enb_num_ue)) {
gauthier's avatar
gauthier committed
440
	    phy_scope_eNB(form_enb[CC_id][ue_cnt],
441
			  RC.eNB[0][CC_id],
442 443 444
			  UE_id);
	    ue_cnt++;
	  }
445
	}
knopp's avatar
knopp committed
446
      }
447

448
    }
449
	
knopp's avatar
knopp committed
450
    //printf("doing forms\n");
Florian Kaltenberger's avatar
Florian Kaltenberger committed
451 452
    //usleep(100000); // 100 ms
    sleep(1);
knopp's avatar
knopp committed
453
  }
454

455
  //  printf("%s",stats_buffer);
456

457
# ifdef ENABLE_XFORMS_WRITE_STATS
458

459 460 461 462 463 464
  if (UE_flag==1) {
    if (UE_stats) {
      rewind (UE_stats);
      fwrite (stats_buffer, 1, len, UE_stats);
      fclose (UE_stats);
    }
465
  } else {
466 467 468 469 470 471
    if (eNB_stats) {
      rewind (eNB_stats);
      fwrite (stats_buffer, 1, len, eNB_stats);
      fclose (eNB_stats);
    }
  }
472

473
# endif
474

knopp's avatar
knopp committed
475
  pthread_exit((void*)arg);
476 477 478
}
#endif

479

480

481

knopp's avatar
knopp committed
482
#if defined(ENABLE_ITTI)
483
void *l2l1_task(void *arg) {
knopp's avatar
knopp committed
484 485 486 487 488
  MessageDef *message_p = NULL;
  int         result;

  itti_set_task_real_time(TASK_L2L1);
  itti_mark_task_ready(TASK_L2L1);
489

knopp's avatar
knopp committed
490 491
  if (UE_flag == 0) {
    /* Wait for the initialize message */
492
    printf("Wait for the ITTI initialize message\n");
493
    do {
knopp's avatar
knopp committed
494
      if (message_p != NULL) {
495 496
	result = itti_free (ITTI_MSG_ORIGIN_ID(message_p), message_p);
	AssertFatal (result == EXIT_SUCCESS, "Failed to free memory (%d)!\n", result);
knopp's avatar
knopp committed
497
      }
498

499 500 501
      itti_receive_msg (TASK_L2L1, &message_p);

      switch (ITTI_MSG_ID(message_p)) {
knopp's avatar
knopp committed
502
      case INITIALIZE_MESSAGE:
503 504 505 506
	/* Start eNB thread */
	LOG_D(EMU, "L2L1 TASK received %s\n", ITTI_MSG_NAME(message_p));
	start_eNB = 1;
	break;
knopp's avatar
knopp committed
507 508

      case TERMINATE_MESSAGE:
509 510
	printf("received terminate message\n");
	oai_exit=1;
511
        start_eNB = 0;
512 513
	itti_exit_task ();
	break;
knopp's avatar
knopp committed
514 515

      default:
516 517
	LOG_E(EMU, "Received unexpected message %s\n", ITTI_MSG_NAME(message_p));
	break;
518
      }
knopp's avatar
knopp committed
519
    } while (ITTI_MSG_ID(message_p) != INITIALIZE_MESSAGE);
520

knopp's avatar
knopp committed
521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541
    result = itti_free (ITTI_MSG_ORIGIN_ID(message_p), message_p);
    AssertFatal (result == EXIT_SUCCESS, "Failed to free memory (%d)!\n", result);
  }

  do {
    // Wait for a message
    itti_receive_msg (TASK_L2L1, &message_p);

    switch (ITTI_MSG_ID(message_p)) {
    case TERMINATE_MESSAGE:
      oai_exit=1;
      itti_exit_task ();
      break;

    case ACTIVATE_MESSAGE:
      start_UE = 1;
      break;

    case DEACTIVATE_MESSAGE:
      start_UE = 0;
      break;
542

knopp's avatar
knopp committed
543 544 545 546 547 548 549 550 551 552 553
    case MESSAGE_TEST:
      LOG_I(EMU, "Received %s\n", ITTI_MSG_NAME(message_p));
      break;

    default:
      LOG_E(EMU, "Received unexpected message %s\n", ITTI_MSG_NAME(message_p));
      break;
    }

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

knopp's avatar
knopp committed
556
  return NULL;
557 558 559
}
#endif

560

561 562 563 564 565
static void get_options(void) {
  int CC_id;
  int tddflag;
  char *loopfile=NULL;
  int dumpframe;
566 567
  uint32_t online_log_messages;
  uint32_t glog_level, glog_verbosity;
oai's avatar
oai committed
568
  uint32_t start_telnetsrv;
569

570
  paramdef_t cmdline_params[] =CMDLINE_PARAMS_DESC ;
571
  paramdef_t cmdline_logparams[] =CMDLINE_LOGPARAMS_DESC ;
572 573 574 575 576 577 578 579 580 581 582 583 584

  config_process_cmdline( cmdline_params,sizeof(cmdline_params)/sizeof(paramdef_t),NULL); 

  if (strlen(in_path) > 0) {
      opt_type = OPT_PCAP;
      opt_enabled=1;
      printf("Enabling OPT for PCAP  with the following file %s \n",in_path);
  }
  if (strlen(in_ip) > 0) {
      opt_enabled=1;
      opt_type = OPT_WIRESHARK;
      printf("Enabling OPT for wireshark for local interface");
  }
585 586 587 588 589 590 591 592

  config_process_cmdline( cmdline_logparams,sizeof(cmdline_logparams)/sizeof(paramdef_t),NULL);
  if(config_isparamset(cmdline_logparams,CMDLINE_ONLINELOG_IDX)) {
      set_glog_onlinelog(online_log_messages);
  }
  if(config_isparamset(cmdline_logparams,CMDLINE_GLOGLEVEL_IDX)) {
      set_glog(glog_level, -1);
  }
593
  if(config_isparamset(cmdline_logparams,CMDLINE_GLOGVERBO_IDX)) {
594 595
      set_glog(-1, glog_verbosity);
  }
oai's avatar
oai committed
596
  if (start_telnetsrv) {
597
     load_module_shlib("telnetsrv",NULL,0);
oai's avatar
oai committed
598 599
  }

600
  
601
  if (UE_flag > 0) {
oai's avatar
oai committed
602
     uint8_t n_rb_dl;
603 604
     paramdef_t cmdline_uemodeparams[] =CMDLINE_UEMODEPARAMS_DESC;
     paramdef_t cmdline_ueparams[] =CMDLINE_UEPARAMS_DESC;
oai's avatar
oai committed
605

Florian Kaltenberger's avatar
Florian Kaltenberger committed
606
     set_default_frame_parms(frame_parms);
oai's avatar
oai committed
607

608 609 610 611 612 613 614 615
     config_process_cmdline( cmdline_uemodeparams,sizeof(cmdline_uemodeparams)/sizeof(paramdef_t),NULL);
     config_process_cmdline( cmdline_ueparams,sizeof(cmdline_ueparams)/sizeof(paramdef_t),NULL);
      if (loopfile != NULL) {
  	  printf("Input file for hardware emulation: %s",loopfile);
  	  mode=loop_through_memory;
  	  input_fd = fopen(loopfile,"r");
  	  AssertFatal(input_fd != NULL,"Please provide a valid input file\n");
      }
oai's avatar
oai committed
616

617 618 619
      if ( (cmdline_uemodeparams[CMDLINE_CALIBUERX_IDX].paramflags &  PARAMFLAG_PARAMSET) != 0) mode = rx_calib_ue;
      if ( (cmdline_uemodeparams[CMDLINE_CALIBUERXMED_IDX].paramflags &  PARAMFLAG_PARAMSET) != 0) mode = rx_calib_ue_med;
      if ( (cmdline_uemodeparams[CMDLINE_CALIBUERXBYP_IDX].paramflags &  PARAMFLAG_PARAMSET) != 0) mode = rx_calib_ue_byp;
620 621 622
      if ( (cmdline_uemodeparams[CMDLINE_DEBUGUEPRACH_IDX].paramflags &  PARAMFLAG_PARAMSET) != 0) mode = debug_prach;
      if ( (cmdline_uemodeparams[CMDLINE_NOL2CONNECT_IDX].paramflags &  PARAMFLAG_PARAMSET) != 0)  mode = no_L2_connect;
      if ( (cmdline_uemodeparams[CMDLINE_CALIBPRACHTX_IDX].paramflags &  PARAMFLAG_PARAMSET) != 0) mode = calib_prach_tx; 
623 624 625
      if (dumpframe  > 0)  mode = rx_dump_frame;
      
      if ( downlink_frequency[0][0] > 0) {
Florian Kaltenberger's avatar
Florian Kaltenberger committed
626 627 628 629 630
	printf("Downlink frequency set to %u\n", downlink_frequency[0][0]);
	for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
	  frame_parms[CC_id]->dl_CarrierFreq = downlink_frequency[0][0];
	}
	UE_scan=0;
631 632
      } 

oai's avatar
oai committed
633 634 635 636
      if (tddflag > 0) {
         for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) 
	     frame_parms[CC_id]->frame_type = TDD;
      }
Florian Kaltenberger's avatar
Florian Kaltenberger committed
637

638
      if (n_rb_dl !=0) {
Florian Kaltenberger's avatar
Florian Kaltenberger committed
639
	printf("NB_RB set to %d\n",n_rb_dl);
640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660
	if ( n_rb_dl < 6 ) {
	  n_rb_dl = 6;
	  printf ( "%i: Invalid number of ressource blocks, adjusted to 6\n",n_rb_dl);
	}
	if ( n_rb_dl > 100 ) {
	  n_rb_dl = 100;
	  printf ( "%i: Invalid number of ressource blocks, adjusted to 100\n",n_rb_dl);
	}
	if ( n_rb_dl > 50 && n_rb_dl < 100 ) {
	  n_rb_dl = 50;
	  printf ( "%i: Invalid number of ressource blocks, adjusted to 50\n",n_rb_dl);
	}
	if ( n_rb_dl > 25 && n_rb_dl < 50 ) {
	  n_rb_dl = 25;
	  printf ( "%i: Invalid number of ressource blocks, adjusted to 25\n",n_rb_dl);
	}
	UE_scan = 0;
	for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
	  frame_parms[CC_id]->N_RB_DL=n_rb_dl;
	  frame_parms[CC_id]->N_RB_UL=n_rb_dl;
	}
661 662
      }

663 664 665 666
      for (CC_id=0;CC_id<MAX_NUM_CCs;CC_id++) {
	tx_max_power[CC_id]=tx_max_power[0];
	rx_gain[0][CC_id] = rx_gain[0][0];
	tx_gain[0][CC_id] = tx_gain[0][0];
667 668
      }
  } /* UE_flag > 0 */
669

670 671 672 673 674
#if T_TRACER
  paramdef_t cmdline_ttraceparams[] =CMDLINE_TTRACEPARAMS_DESC ;
  config_process_cmdline( cmdline_ttraceparams,sizeof(cmdline_ttraceparams)/sizeof(paramdef_t),NULL);   
#endif

675 676 677 678
  if ( !(CONFIG_ISFLAGSET(CONFIG_ABORT)) ) {
    if (UE_flag == 0) {
      memset((void*)&RC,0,sizeof(RC));
      /* Read RC configuration file */
679
      RCConfig();
680 681
      NB_eNB_INST = RC.nb_inst;
      NB_RU	  = RC.nb_RU;
682
      printf("Configuration: nb_rrc_inst %d, nb_L1_inst %d, nb_ru %d\n",NB_eNB_INST,RC.nb_L1_inst,NB_RU);
683
    }
684
  } else if (UE_flag == 1 && (!(CONFIG_ISFLAGSET(CONFIG_NOOOPT))) ) {
685 686
    // Here the configuration file is the XER encoded UE capabilities
    // Read it in and store in asn1c data structures
Florian Kaltenberger's avatar
Florian Kaltenberger committed
687 688
    sprintf(uecap_xer,"%stargets/PROJECTS/GENERIC-LTE-EPC/CONF/UE_config.xml",getenv("OPENAIR_HOME"));
    printf("%s\n",uecap_xer);
689 690
    uecap_xer_in=1;
  } /* UE with config file  */
691 692 693
}


694 695 696 697 698 699
static void reconfigure_enb_params(int enb_id)
{
  int CC_id, k;
  const Enb_properties_array_t *enb_properties=enb_config_get();

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

701 702 703
    node_function[CC_id]  = enb_properties->properties[enb_id]->cc_node_function[CC_id];
    node_timing[CC_id]    = enb_properties->properties[enb_id]->cc_node_timing[CC_id];
    node_synch_ref[CC_id] = enb_properties->properties[enb_id]->cc_node_synch_ref[CC_id];
704

705 706 707 708
    frame_parms[CC_id]->frame_type   = enb_properties->properties[enb_id]->frame_type[CC_id];
    frame_parms[CC_id]->tdd_config   = enb_properties->properties[enb_id]->tdd_config[CC_id];
    frame_parms[CC_id]->tdd_config_S = enb_properties->properties[enb_id]->tdd_config_s[CC_id];
    frame_parms[CC_id]->Ncp          = enb_properties->properties[enb_id]->prefix_type[CC_id];
709

710 711 712 713 714 715 716
                //for (j=0; j < enb_properties->properties[i]->nb_cc; j++ ){
    frame_parms[CC_id]->Nid_cell             = enb_properties->properties[enb_id]->Nid_cell[CC_id];
    frame_parms[CC_id]->N_RB_DL              = enb_properties->properties[enb_id]->N_RB_DL[CC_id];
    frame_parms[CC_id]->N_RB_UL              = enb_properties->properties[enb_id]->N_RB_DL[CC_id];
    frame_parms[CC_id]->nb_antennas_tx       = enb_properties->properties[enb_id]->nb_antennas_tx[CC_id];
    frame_parms[CC_id]->nb_antenna_ports_eNB = enb_properties->properties[enb_id]->nb_antenna_ports[CC_id];
    frame_parms[CC_id]->nb_antennas_rx       = enb_properties->properties[enb_id]->nb_antennas_rx[CC_id];
717

718 719
    frame_parms[CC_id]->prach_config_common.prach_ConfigInfo.prach_ConfigIndex = enb_properties->properties[enb_id]->prach_config_index[CC_id];
    frame_parms[CC_id]->prach_config_common.prach_ConfigInfo.prach_FreqOffset  = enb_properties->properties[enb_id]->prach_freq_offset[CC_id];
720

721 722 723 724 725 726 727 728 729
    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;

    for (k = 0 ; k < 4; k++) {
      downlink_frequency[CC_id][k]      =  enb_properties->properties[enb_id]->downlink_frequency[CC_id];
      uplink_frequency_offset[CC_id][k] =  enb_properties->properties[enb_id]->uplink_frequency_offset[CC_id];
      rx_gain[CC_id][k]                 =  (double)enb_properties->properties[enb_id]->rx_gain[CC_id];
      tx_gain[CC_id][k]                 =  (double)enb_properties->properties[enb_id]->tx_gain[CC_id];
    }
730

731 732 733
    printf("Downlink frequency/ uplink offset of CC_id %d set to %ju/%d\n", CC_id,
           enb_properties->properties[enb_id]->downlink_frequency[CC_id],
           enb_properties->properties[enb_id]->uplink_frequency_offset[CC_id]);
734

735 736 737 738 739 740 741
    init_ul_hopping(frame_parms[CC_id]);
    init_frame_parms(frame_parms[CC_id],1);
    //   phy_init_top(frame_parms[CC_id]);
    phy_init_lte_top(frame_parms[CC_id]);
  } // CC_id
}

742
#if T_TRACER
743
int T_nowait = 0;     /* by default we wait for the tracer */
744
int T_port = 2021;    /* default port to listen to to wait for the tracer */
745
int T_dont_fork = 0;  /* default is to fork, see 'T_init' to understand */
746 747
#endif

748

749

knopp's avatar
knopp committed
750
void set_default_frame_parms(LTE_DL_FRAME_PARMS *frame_parms[MAX_NUM_CCs]) {
knopp's avatar
knopp committed
751 752 753 754 755 756 757 758 759 760 761 762 763 764 765

  int CC_id;

  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;
766
    frame_parms[CC_id]->nb_antenna_ports_eNB  = 1;
knopp's avatar
knopp committed
767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785
    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;

786 787 788 789
//    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];
knopp's avatar
knopp committed
790
    //printf("Downlink for CC_id %d frequency set to %u\n", CC_id, downlink_frequency[CC_id][0]);
791
    frame_parms[CC_id]->dl_CarrierFreq=downlink_frequency[CC_id][0];
oai's avatar
oai committed
792

knopp's avatar
knopp committed
793 794 795 796
  }

}

knopp's avatar
knopp committed
797 798
void init_openair0(void);

knopp's avatar
knopp committed
799 800 801 802 803 804 805 806 807 808 809 810 811
void init_openair0() {

  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;
812
	openair0_cfg[card].samples_per_frame = 230400;
knopp's avatar
knopp committed
813 814
	openair0_cfg[card].tx_bw = 10e6;
	openair0_cfg[card].rx_bw = 10e6;
815
      } else {
knopp's avatar
knopp committed
816
	openair0_cfg[card].sample_rate=30.72e6;
817
	openair0_cfg[card].samples_per_frame = 307200;
knopp's avatar
knopp committed
818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846
	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;
    }




    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;

    printf("HW: Configuring card %d, nb_antennas_tx/rx %d/%d\n",card,
847 848
	   ((UE_flag==0) ? RC.eNB[0][0]->frame_parms.nb_antennas_tx : PHY_vars_UE_g[0][0]->frame_parms.nb_antennas_tx),
	   ((UE_flag==0) ? RC.eNB[0][0]->frame_parms.nb_antennas_rx : PHY_vars_UE_g[0][0]->frame_parms.nb_antennas_rx));
knopp's avatar
knopp committed
849 850 851
    openair0_cfg[card].Mod_id = 0;

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

853
    openair0_cfg[card].clock_source = clock_source;
854

855

856 857
    openair0_cfg[card].tx_num_channels=min(2,((UE_flag==0) ? RC.eNB[0][0]->frame_parms.nb_antennas_tx : PHY_vars_UE_g[0][0]->frame_parms.nb_antennas_tx));
    openair0_cfg[card].rx_num_channels=min(2,((UE_flag==0) ? RC.eNB[0][0]->frame_parms.nb_antennas_rx : PHY_vars_UE_g[0][0]->frame_parms.nb_antennas_rx));
858

knopp's avatar
knopp committed
859
    for (i=0; i<4; i++) {
860

knopp's avatar
knopp committed
861 862 863 864
      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;
865

knopp's avatar
knopp committed
866 867 868 869 870 871 872 873
      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) {
874
	openair0_cfg[card].rx_gain[i] = RC.eNB[0][0]->rx_total_gain_dB;
knopp's avatar
knopp committed
875 876
      }
      else {
877
	openair0_cfg[card].rx_gain[i] = PHY_vars_UE_g[0][0]->rx_total_gain_dB - rx_gain_off;
knopp's avatar
knopp committed
878 879
      }

880
      openair0_cfg[card].configFilename = rf_config_file;
881
      printf("Card %d, channel %d, Setting tx_gain %f, rx_gain %f, tx_freq %f, rx_freq %f\n",
882 883 884 885
	     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]);
886
    }
knopp's avatar
knopp committed
887
  }
knopp's avatar
knopp committed
888
}
889

890
void wait_RUs(void) {
891 892 893 894 895 896 897 898 899 900 901 902 903 904 905

  LOG_I(PHY,"Waiting for RUs to be configured ...\n");

  // wait for all RUs to be configured over fronthaul
  pthread_mutex_lock(&RC.ru_mutex);



  while (RC.ru_mask>0) {
    pthread_cond_wait(&RC.ru_cond,&RC.ru_mutex);
  }

  LOG_I(PHY,"RUs configured\n");
}

906
void wait_eNBs(void) {
907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924

  int i,j;
  int waiting=1;


  while (waiting==1) {
    printf("Waiting for eNB L1 instances to all get configured ... sleeping 500ms (nb_L1_inst %d)\n",RC.nb_L1_inst);
    usleep(500000);
    waiting=0;
    for (i=0;i<RC.nb_L1_inst;i++)
      for (j=0;j<RC.nb_L1_CC[i];j++)
	if (RC.eNB[i][j]->configured==0) {
	  waiting=1;
	  break;
	}
  }
  printf("eNB L1 are configured\n");
}
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 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989
void fill_PHY_vars_eNB_g(uint8_t abstraction_flag, uint8_t beta_ACK, uint8_t beta_RI, uint8_t beta_CQI)
{
  int CC_id, i, j, k, re;
  for (CC_id = 0; CC_id < MAX_NUM_CCs; CC_id++) {
    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);
    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;
      }
    }

    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;
    }
  }
}

990 991 992
#if defined(ENABLE_ITTI) && defined(FLEXRAN_AGENT_SB_IF)
/*
 * helper function to terminate a certain ITTI task
993
 */
994
void terminate_task(task_id_t task_id, mid_t mod_id)
995
{
996 997 998 999 1000 1001 1002 1003 1004 1005 1006
  LOG_I(ENB_APP, "sending TERMINATE_MESSAGE to task %s (%d)\n", itti_get_task_name(task_id), task_id);
  MessageDef *msg;
  msg = itti_alloc_new_message (ENB_APP, TERMINATE_MESSAGE);
  itti_send_msg_to_task (task_id, ENB_MODULE_ID_TO_INSTANCE(mod_id), msg);
}

int stop_L1L2(int enb_id)
{
  int CC_id;

  LOG_W(ENB_APP, "stopping lte-softmodem\n");
1007
  oai_exit = 1;
1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025

  /* stop trx devices */
  for(CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
    if (PHY_vars_eNB_g[0][CC_id]->rfdevice.trx_stop_func) {
        LOG_I(ENB_APP, "stopping PHY_vars_eNB_g[0][%d]->rfdevice (via trx_stop_func())\n", CC_id);
        PHY_vars_eNB_g[0][CC_id]->rfdevice.trx_stop_func(&PHY_vars_eNB_g[0][CC_id]->rfdevice);
    }
    if (PHY_vars_eNB_g[0][CC_id]->ifdevice.trx_stop_func) {
        LOG_I(ENB_APP, "stopping PHY_vars_eNB_g[0][%d]->ifdevice (via trx_stop_func())\n", CC_id);
        PHY_vars_eNB_g[0][CC_id]->ifdevice.trx_stop_func(&PHY_vars_eNB_g[0][CC_id]->ifdevice);
    }
  }

  /* these tasks need to pick up new configuration */
  terminate_task(TASK_RRC_ENB, enb_id);
  terminate_task(TASK_L2L1, enb_id);
  LOG_W(ENB_APP, "calling kill_eNB_proc() for instance %d\n", enb_id);
  kill_eNB_proc(enb_id);
1026
  oai_exit = 0;
1027 1028 1029 1030 1031 1032 1033 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
  return 0;
}

/*
 * Restart the lte-softmodem.
 * This function checks whether we are in ENB_NORMAL_OPERATION (defined by
 * FlexRAN). If yes, first stop L1/L2/L3, then resume.
 */
int restart_L1L2(int enb_id)
{
  int i, aa, CC_id;
  /* needed for fill_PHY_vars_eNB_g(), defined locally in main();
   * abstraction flag is needed too, but defined both globally and in main () */
  uint8_t beta_ACK = 0, beta_RI = 0, beta_CQI = 2;
  /* needed for macphy_init() */
  int eMBMS_active = 0;

  LOG_W(ENB_APP, "restarting lte-softmodem\n");

  /* block threads */
  sync_var = -1;

  reconfigure_enb_params(enb_id);     /* set frame parameters from configuration */

  /* PHY_vars_eNB_g will be filled by init_lte_eNB(), so free and
   * let the data structure be filled again */
  for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
    free(PHY_vars_eNB_g[0][CC_id]);
    fill_PHY_vars_eNB_g(abstraction_flag, beta_ACK, beta_RI, beta_CQI);
  }

  dump_frame_parms(frame_parms[0]);
  init_openair0();

  /* give MAC interface current cell information, the rest is the same.
   * For more info, check l2_init(). Then, initialize it (cf. line 1904). */
  mac_xface->frame_parms = frame_parms[0];
  mac_xface->macphy_init(eMBMS_active,(uecap_xer_in==1)?uecap_xer:NULL,0,0);

  LOG_I(ENB_APP, "attempting to create ITTI tasks\n");
  if (itti_create_task (TASK_RRC_ENB, rrc_enb_task, NULL) < 0) {
    LOG_E(RRC, "Create task for RRC eNB failed\n");
    return -1;
  } else {
    LOG_I(RRC, "Re-created task for RRC eNB successfully\n");
  }
  if (itti_create_task (TASK_L2L1, l2l1_task, NULL) < 0) {
    LOG_E(PDCP, "Create task for L2L1 failed\n");
    return -1;
  } else {
    LOG_I(PDCP, "Re-created task for L2L1 successfully\n");
  }

  /* TODO XForms here */
1081

1082 1083 1084 1085 1086
  printf("Initializing eNB threads\n");
  init_eNB(node_function, node_timing, 1, eth_params, single_thread_flag, wait_for_sync);
  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;
1087
  }
1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107

  mlockall(MCL_CURRENT | MCL_FUTURE);

  printf("Setting eNB buffer to all-RX\n");
  // 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;
  }

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

  pthread_mutex_lock(&sync_mutex);
  sync_var=0;
  pthread_cond_broadcast(&sync_cond);
  pthread_mutex_unlock(&sync_mutex);

  return 0;
1108
}
1109
#endif
1110

1111 1112
int main( int argc, char **argv )
{
1113
  int i;
1114
#if defined (XFORMS)
knopp's avatar
knopp committed
1115
  void *status;
1116
#endif
1117

knopp's avatar
knopp committed
1118
  int CC_id;
1119
  int ru_id;
knopp's avatar
knopp committed
1120
  uint8_t  abstraction_flag=0;
knopp's avatar
knopp committed
1121
  uint8_t beta_ACK=0,beta_RI=0,beta_CQI=2;
1122

knopp's avatar
knopp committed
1123
#if defined (XFORMS)
1124 1125
  int ret;
#endif
1126

1127
  start_background_system();
1128 1129 1130 1131
  if ( load_configmodule(argc,argv) == NULL) {
    exit_fun("[SOFTMODEM] Error, configuration module init failed\n");
  } 
      
1132 1133 1134 1135 1136
#ifdef DEBUG_CONSOLE
  setvbuf(stdout, NULL, _IONBF, 0);
  setvbuf(stderr, NULL, _IONBF, 0);
#endif

1137 1138 1139
  PHY_VARS_UE *UE[MAX_NUM_CCs];

  mode = normal_txrx;
1140
  memset(&openair0_cfg[0],0,sizeof(openair0_config_t)*MAX_CARDS);
1141

1142
  memset(tx_max_power,0,sizeof(int)*MAX_NUM_CCs);
1143

knopp's avatar
knopp committed
1144
  set_latency_target();
1145 1146


knopp's avatar
knopp committed
1147
  // set default parameters
Florian Kaltenberger's avatar
Florian Kaltenberger committed
1148
  //if (UE_flag == 1) set_default_frame_parms(frame_parms);
1149

1150
  logInit();
knopp's avatar
knopp committed
1151

1152
  printf("Reading in command-line options\n");
1153

1154
  get_options (); 
1155
  if (CONFIG_ISFLAGSET(CONFIG_ABORT) && UE_flag == 0) {
1156 1157
      fprintf(stderr,"Getting configuration failed\n");
      exit(-1);
1158
  }
knopp's avatar
knopp committed
1159 1160


1161
#if T_TRACER
1162
  T_init(T_port, 1-T_nowait, T_dont_fork);
1163 1164
#endif

1165

1166

1167 1168
  //randominit (0);
  set_taus_seed (0);
knopp's avatar
knopp committed
1169

1170 1171
  if (UE_flag==1) {
    printf("configuring for UE\n");
1172

1173
    set_comp_log(HW,      LOG_DEBUG,  LOG_HIGH, 1);
Florian Kaltenberger's avatar
Florian Kaltenberger committed
1174
    set_comp_log(PHY,     LOG_INFO,   LOG_HIGH, 1);
1175
    set_comp_log(MAC,     LOG_INFO,   LOG_HIGH, 1);
1176
    set_comp_log(RLC,     LOG_INFO,   LOG_HIGH | FLAG_THREAD, 1);
1177 1178 1179
    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);
1180
#if defined(ENABLE_ITTI)
1181
    set_comp_log(EMU,     LOG_INFO,   LOG_MED, 1);
1182
# if defined(ENABLE_USE_MME)
1183
    set_comp_log(NAS,     LOG_INFO,   LOG_HIGH, 1);
1184 1185
# endif
#endif
1186

1187
  } else {
1188
    printf("configuring for RAU/RRU\n");
1189

1190
  }
1191

knopp's avatar
knopp committed
1192 1193
  if (ouput_vcd) {
    if (UE_flag==1)
gauthier's avatar
gauthier committed
1194
      VCD_SIGNAL_DUMPER_INIT("/tmp/openair_dump_UE.vcd");
knopp's avatar
knopp committed
1195
    else
gauthier's avatar
gauthier committed
1196
      VCD_SIGNAL_DUMPER_INIT("/tmp/openair_dump_eNB.vcd");
knopp's avatar
knopp committed
1197
  }
1198

1199
  if (opp_enabled ==1) {
1200
    reset_opp_meas();
1201 1202
  }
  cpuf=get_cpu_freq_GHz();
1203

1204
#if defined(ENABLE_ITTI)
1205

knopp's avatar
knopp committed
1206 1207
  if (UE_flag == 1) {
    log_set_instance_type (LOG_INSTANCE_UE);
1208