lte-enb.c 25.9 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
/*
 * 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
 */
21 22 23 24 25 26 27 28 29 30 31

/*! \file lte-enb.c
 * \brief Top-level threads for eNodeB
 * \author R. Knopp, F. Kaltenberger, Navid Nikaein
 * \date 2012
 * \version 0.1
 * \company Eurecom
 * \email: knopp@eurecom.fr,florian.kaltenberger@eurecom.fr, navid.nikaein@eurecom.fr
 * \note
 * \warning
 */
32

33

34 35
#include "time_utils.h"

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

38 39
#include "rt_wrapper.h"

40
#include "assertions.h"
41

42 43 44 45 46 47 48 49 50 51 52

#include "PHY/types.h"

#include "PHY/defs.h"
#undef MALLOC //there are two conflicting definitions, so we better make sure we don't use it at all
//#undef FRAME_LENGTH_COMPLEX_SAMPLES //there are two conflicting definitions, so we better make sure we don't use it at all

#include "../../ARCH/COMMON/common_lib.h"

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

53
#include "PHY/LTE_TRANSPORT/if4_tools.h"
54
#include "PHY/LTE_TRANSPORT/if5_tools.h"
55

56 57 58 59 60 61 62 63 64 65 66
#include "PHY/extern.h"
#include "SCHED/extern.h"
#include "LAYER2/MAC/extern.h"

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

#include "LAYER2/MAC/defs.h"
#include "LAYER2/MAC/extern.h"
#include "LAYER2/MAC/proto.h"
#include "RRC/LITE/extern.h"
#include "PHY_INTERFACE/extern.h"
67
#include "PHY_INTERFACE/defs.h"
68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93
#ifdef SMBV
#include "PHY/TOOLS/smbv.h"
unsigned short config_frames[4] = {2,9,11,13};
#endif
#include "UTIL/LOG/log_extern.h"
#include "UTIL/OTG/otg_tx.h"
#include "UTIL/OTG/otg_externs.h"
#include "UTIL/MATH/oml.h"
#include "UTIL/LOG/vcd_signal_dumper.h"
#include "UTIL/OPT/opt.h"
#include "enb_config.h"
//#include "PHY/TOOLS/time_meas.h"

#ifndef OPENAIR2
#include "UTIL/OTG/otg_extern.h"
#endif

#if defined(ENABLE_ITTI)
# if defined(ENABLE_USE_MME)
#   include "s1ap_eNB.h"
#ifdef PDCP_USE_NETLINK
#   include "SIMULATION/ETH_TRANSPORT/proto.h"
#endif
# endif
#endif

Rohit Gupta's avatar
bugfix  
Rohit Gupta committed
94 95
#include "T.h"

96 97 98 99 100 101 102 103 104 105
//#define DEBUG_THREADS 1

//#define USRP_DEBUG 1
struct timing_info_t {
  //unsigned int frame, hw_slot, last_slot, next_slot;
  RTIME time_min, time_max, time_avg, time_last, time_now;
  //unsigned int mbox0, mbox1, mbox2, mbox_target;
  unsigned int n_samples;
} timing_info;

106 107
// Fix per CC openair rf/if device update
// extern openair0_device openair0;
108

knopp's avatar
knopp committed
109

110 111 112 113 114 115 116 117
#if defined(ENABLE_ITTI)
extern volatile int             start_eNB;
extern volatile int             start_UE;
#endif
extern volatile int                    oai_exit;

extern openair0_config_t openair0_cfg[MAX_CARDS];

Cedric Roux's avatar
Cedric Roux committed
118
extern int transmission_mode;
119

120 121
extern int oaisim_flag;

122
//pthread_t                       main_eNB_thread;
123 124 125

time_stats_t softmodem_stats_mt; // main thread
time_stats_t softmodem_stats_hw; //  hw acquisition
knopp's avatar
knopp committed
126
time_stats_t softmodem_stats_rxtx_sf; // total tx time
127
time_stats_t softmodem_stats_rx_sf; // total rx time
128 129 130 131 132 133 134 135 136

/* mutex, cond and variable to serialize phy proc TX calls
 * (this mechanism may be relaxed in the future for better
 * performances)
 */
static struct {
  pthread_mutex_t  mutex_phy_proc_tx;
  pthread_cond_t   cond_phy_proc_tx;
  volatile uint8_t phy_proc_CC_id;
137
} sync_phy_proc;
138

139 140
extern double cpuf;

141 142
void exit_fun(const char* s);

143
void init_eNB(int,int);
144
void stop_eNB(int nb_inst);
145

146
void wakeup_prach_eNB(PHY_VARS_eNB *eNB,RU_t *ru,int frame,int subframe);
147

knopp's avatar
knopp committed
148 149 150
static inline int rxtx(PHY_VARS_eNB *eNB,eNB_rxtx_proc_t *proc, char *thread_name) {

  start_meas(&softmodem_stats_rxtx_sf);
151

knopp's avatar
knopp committed
152 153
  // ****************************************
  // Common RX procedures subframe n
154

155
  // if this is IF5 or 3GPP_eNB
156
  if (eNB->RU_list[0]->function < NGFI_RAU_IF4p5) wakeup_prach_eNB(eNB,NULL,proc->frame_rx,proc->subframe_rx);
knopp's avatar
knopp committed
157

knopp's avatar
knopp committed
158
  // UE-specific RX processing for subframe n
159
  phy_procedures_eNB_uespec_RX(eNB, proc, no_relay );
160 161

  pthread_mutex_lock(&eNB->UL_INFO_mutex);
162 163 164 165 166
  eNB->UL_INFO.frame     = proc->frame_rx;
  eNB->UL_INFO.subframe  = proc->subframe_rx;
  eNB->UL_INFO.module_id = eNB->Mod_id;
  eNB->UL_INFO.CC_id     = eNB->CC_id;
  eNB->if_inst->UL_indication(&eNB->UL_INFO);
167
  pthread_mutex_unlock(&eNB->UL_INFO_mutex);
knopp's avatar
knopp committed
168 169 170 171 172
  // *****************************************
  // TX processing for subframe n+4
  // run PHY TX procedures the one after the other for all CCs to avoid race conditions
  // (may be relaxed in the future for performance reasons)
  // *****************************************
173
  //if (wait_CCs(proc)<0) return(-1);
knopp's avatar
knopp committed
174
  
175 176

  
knopp's avatar
knopp committed
177 178
  if (oai_exit) return(-1);
  
179
  phy_procedures_eNB_TX(eNB, proc, no_relay, NULL, 1);
knopp's avatar
knopp committed
180 181 182 183 184 185 186 187
  
  if (release_thread(&proc->mutex_rxtx,&proc->instance_cnt_rxtx,thread_name)<0) return(-1);

  stop_meas( &softmodem_stats_rxtx_sf );
  
  return(0);
}

188

189
/*!
knopp's avatar
knopp committed
190
 * \brief The RX UE-specific and TX thread of eNB.
191 192 193
 * \param param is a \ref eNB_proc_t structure which contains the info what to process.
 * \returns a pointer to an int. The storage is not on the heap and must not be freed.
 */
194

Sandeep Kumar's avatar
Sandeep Kumar committed
195 196
static void* eNB_thread_rxtx( void* param ) {

knopp's avatar
knopp committed
197
  static int eNB_thread_rxtx_status;
198

knopp's avatar
knopp committed
199
  eNB_rxtx_proc_t *proc = (eNB_rxtx_proc_t*)param;
200
  PHY_VARS_eNB *eNB = RC.eNB[0][proc->CC_id];
201

knopp's avatar
knopp committed
202 203
  char thread_name[100];

204

205
  // set default return value
knopp's avatar
knopp committed
206
  eNB_thread_rxtx_status = 0;
207 208


knopp's avatar
knopp committed
209
  sprintf(thread_name,"RXn_TXnp4_%d\n",&eNB->proc.proc_rxtx[0] == proc ? 0 : 1);
210
  thread_top_init(thread_name,1,850000L,1000000L,2000000L);
211 212

  while (!oai_exit) {
knopp's avatar
knopp committed
213
    VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_eNB_PROC_RXTX0+(proc->subframe_rx&1), 0 );
214

knopp's avatar
knopp committed
215
    if (wait_on_condition(&proc->mutex_rxtx,&proc->cond_rxtx,&proc->instance_cnt_rxtx,thread_name)<0) break;
216

knopp's avatar
knopp committed
217
    VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_eNB_PROC_RXTX0+(proc->subframe_rx&1), 1 );
218

knopp's avatar
knopp committed
219
    
220
  
221 222
    if (oai_exit) break;

223 224
    if (eNB->CC_id==0)
      if (rxtx(eNB,proc,thread_name) < 0) break;
225

knopp's avatar
knopp committed
226
  } // while !oai_exit
227

knopp's avatar
knopp committed
228
  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_eNB_PROC_RXTX0+(proc->subframe_rx&1), 0 );
229

Raymond Knopp's avatar
Raymond Knopp committed
230
  printf( "Exiting eNB thread RXn_TXnp4\n");
231

knopp's avatar
knopp committed
232 233
  eNB_thread_rxtx_status = 0;
  return &eNB_thread_rxtx_status;
234 235
}

236

237
#if defined(ENABLE_ITTI) && defined(ENABLE_USE_MME)
Sandeep Kumar's avatar
Sandeep Kumar committed
238 239 240
/* Wait for eNB application initialization to be complete (eNB registration to MME) */
static void wait_system_ready (char *message, volatile int *start_flag) {
  
241
  static char *indicator[] = {".    ", "..   ", "...  ", ".... ", ".....",
Sandeep Kumar's avatar
Sandeep Kumar committed
242
			      " ....", "  ...", "   ..", "    .", "     "};
243 244 245 246 247 248 249
  int i = 0;
  
  while ((!oai_exit) && (*start_flag == 0)) {
    LOG_N(EMU, message, indicator[i]);
    fflush(stdout);
    i = (i + 1) % (sizeof(indicator) / sizeof(indicator[0]));
    usleep(200000);
250
  }
251 252
  
  LOG_D(EMU,"\n");
253 254
}
#endif
255

knopp's avatar
knopp committed
256 257


knopp's avatar
knopp committed
258

knopp's avatar
knopp committed
259

260
void eNB_top(PHY_VARS_eNB *eNB, int frame_rx, int subframe_rx, char *string) {
261

262

263 264
  eNB_proc_t *proc           = &eNB->proc;
  eNB_rxtx_proc_t *proc_rxtx = &proc->proc_rxtx[0];
265

266 267


knopp's avatar
knopp committed
268

269 270
  proc->frame_rx    = frame_rx;
  proc->subframe_rx = subframe_rx;
271
  
272 273
  if (!oai_exit) {

knopp's avatar
knopp committed
274

knopp's avatar
knopp committed
275 276
    LOG_D(PHY,"eNB_top in %p (proc %p, CC_id %d), frame %d, subframe %d, instance_cnt_prach %d\n",
	  pthread_self(), proc, eNB->CC_id, proc->frame_rx,proc->subframe_rx,proc->instance_cnt_prach);
277
 
knopp's avatar
knopp committed
278 279


280
    T(T_ENB_MASTER_TICK, T_INT(0), T_INT(proc->frame_rx), T_INT(proc->subframe_rx));
knopp's avatar
knopp committed
281

282 283 284 285 286 287
    proc_rxtx->subframe_rx = proc->subframe_rx;
    proc_rxtx->frame_rx    = proc->frame_rx;
    proc_rxtx->subframe_tx = (proc->subframe_rx+4)%10;
    proc_rxtx->frame_tx    = (proc->subframe_rx>5) ? (1+proc->frame_rx)&1023 : proc->frame_rx;
    proc->frame_tx         = proc_rxtx->frame_tx;
    proc_rxtx->timestamp_tx = proc->timestamp_tx;
knopp's avatar
knopp committed
288

289
    if (rxtx(eNB,proc_rxtx,string) < 0) LOG_E(PHY,"eNB %d CC_id %d failed during execution\n",eNB->Mod_id,eNB->CC_id);
knopp's avatar
knopp committed
290 291
    LOG_D(PHY,"eNB_top out %p (proc %p, CC_id %d), frame %d, subframe %d, instance_cnt_prach %d\n",
	  pthread_self(), proc, eNB->CC_id, proc->frame_rx,proc->subframe_rx,proc->instance_cnt_prach);
292
  }
knopp's avatar
knopp committed
293 294 295 296
  
}


297 298 299 300 301 302 303
int wakeup_rxtx(PHY_VARS_eNB *eNB,RU_t *ru) {

  eNB_proc_t *proc=&eNB->proc;

  eNB_rxtx_proc_t *proc_rxtx=&proc->proc_rxtx[proc->frame_rx&1];

  LTE_DL_FRAME_PARMS *fp = &eNB->frame_parms;
304 305 306 307

  int i;
  struct timespec wait;
  
308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328
  pthread_mutex_lock(&proc->mutex_RU);
  for (i=0;i<eNB->num_RU;i++) {
    if (ru == eNB->RU_list[i]) {
      if ((proc->RU_mask&(1<<i)) > 0)
	LOG_E(PHY,"eNB %d frame %d, subframe %d : previous information from RU %d (num_RU %d,mask %x) has not been served yet!\n",
	      eNB->Mod_id,proc->frame_rx,proc->subframe_rx,ru->idx,eNB->num_RU,proc->RU_mask);
      proc->RU_mask |= (1<<i);
    }
  }
  if (proc->RU_mask != (1<<eNB->num_RU)-1) {  // not all RUs have provided their information so return
    pthread_mutex_unlock(&proc->mutex_RU);
    return(0);
  }
  else { // all RUs have provided their information so continue on and wakeup eNB processing
    proc->RU_mask = 0;
    pthread_mutex_unlock(&proc->mutex_RU);
  }




329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355
  wait.tv_sec=0;
  wait.tv_nsec=5000000L;

  /* accept some delay in processing - up to 5ms */
  for (i = 0; i < 10 && proc_rxtx->instance_cnt_rxtx == 0; i++) {
    LOG_W( PHY,"[eNB] Frame %d, eNB RXn-TXnp4 thread busy!! (cnt_rxtx %i)\n", proc_rxtx->frame_tx, proc_rxtx->instance_cnt_rxtx);
    usleep(500);
  }
  if (proc_rxtx->instance_cnt_rxtx == 0) {
    exit_fun( "TX thread busy" );
    return(-1);
  }

  // wake up TX for subframe n+4
  // lock the TX mutex and make sure the thread is ready
  if (pthread_mutex_timedlock(&proc_rxtx->mutex_rxtx,&wait) != 0) {
    LOG_E( PHY, "[eNB] ERROR pthread_mutex_lock for eNB RXTX thread %d (IC %d)\n", proc_rxtx->subframe_rx&1,proc_rxtx->instance_cnt_rxtx );
    exit_fun( "error locking mutex_rxtx" );
    return(-1);
  }
  
  ++proc_rxtx->instance_cnt_rxtx;
  
  // We have just received and processed the common part of a subframe, say n. 
  // TS_rx is the last received timestamp (start of 1st slot), TS_tx is the desired 
  // transmitted timestamp of the next TX slot (first).
  // The last (TS_rx mod samples_per_frame) was n*samples_per_tti, 
knopp's avatar
knopp committed
356 357
  // we want to generate subframe (n+4), so TS_tx = TX_rx+4*samples_per_tti,
  // and proc->subframe_tx = proc->subframe_rx+4
358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375
  proc_rxtx->timestamp_tx = proc->timestamp_rx + (4*fp->samples_per_tti);
  proc_rxtx->frame_rx     = proc->frame_rx;
  proc_rxtx->subframe_rx  = proc->subframe_rx;
  proc_rxtx->frame_tx     = (proc_rxtx->subframe_rx > 5) ? (proc_rxtx->frame_rx+1)&1023 : proc_rxtx->frame_rx;
  proc_rxtx->subframe_tx  = (proc_rxtx->subframe_rx + 4)%10;
  
  // the thread can now be woken up
  if (pthread_cond_signal(&proc_rxtx->cond_rxtx) != 0) {
    LOG_E( PHY, "[eNB] ERROR pthread_cond_signal for eNB RXn-TXnp4 thread\n");
    exit_fun( "ERROR pthread_cond_signal" );
    return(-1);
  }
  
  pthread_mutex_unlock( &proc_rxtx->mutex_rxtx );

  return(0);
}

376
void wakeup_prach_eNB(PHY_VARS_eNB *eNB,RU_t *ru,int frame,int subframe) {
knopp's avatar
knopp committed
377 378 379

  eNB_proc_t *proc = &eNB->proc;
  LTE_DL_FRAME_PARMS *fp=&eNB->frame_parms;
380
  int i;
knopp's avatar
knopp committed
381

382 383 384 385
  if (ru!=NULL) {
    pthread_mutex_lock(&proc->mutex_RU_PRACH);
    for (i=0;i<eNB->num_RU;i++) {
      if (ru == eNB->RU_list[i]) {
386
	LOG_I(PHY,"frame %d, subframe %d: RU %d for eNB %d signals PRACH (mask %x, num_RU %d)\n",frame,subframe,i,eNB->Mod_id,proc->RU_mask_prach,eNB->num_RU);
387 388
	if ((proc->RU_mask_prach&(1<<i)) > 0)
	  LOG_E(PHY,"eNB %d frame %d, subframe %d : previous information (PRACH) from RU %d (num_RU %d, mask %x) has not been served yet!\n",
389
		eNB->Mod_id,frame,subframe,ru->idx,eNB->num_RU,proc->RU_mask_prach);
390 391 392 393 394 395 396 397 398 399 400 401 402
	proc->RU_mask_prach |= (1<<i);
      }
    }
    if (proc->RU_mask_prach != (1<<eNB->num_RU)-1) {  // not all RUs have provided their information so return
      pthread_mutex_unlock(&proc->mutex_RU_PRACH);
      return(0);
    }
    else { // all RUs have provided their information so continue on and wakeup eNB processing
      proc->RU_mask_prach = 0;
      pthread_mutex_unlock(&proc->mutex_RU_PRACH);
    }
  }
    
knopp's avatar
knopp committed
403
  // check if we have to detect PRACH first
404
  if (is_prach_subframe(fp,frame,subframe)>0) { 
405
    LOG_D(PHY,"Triggering prach processing, frame %d, subframe %d\n",frame,subframe);
knopp's avatar
knopp committed
406
    if (proc->instance_cnt_prach == 0) {
407
      LOG_W(PHY,"[eNB] Frame %d Subframe %d, dropping PRACH\n", frame,subframe);
knopp's avatar
knopp committed
408 409 410 411 412 413 414 415 416 417 418 419
      return;
    }
    
    // wake up thread for PRACH RX
    if (pthread_mutex_lock(&proc->mutex_prach) != 0) {
      LOG_E( PHY, "[eNB] ERROR pthread_mutex_lock for eNB PRACH thread %d (IC %d)\n", proc->thread_index, proc->instance_cnt_prach);
      exit_fun( "error locking mutex_prach" );
      return;
    }
    
    ++proc->instance_cnt_prach;
    // set timing for prach thread
420 421
    proc->frame_prach = frame;
    proc->subframe_prach = subframe;
knopp's avatar
knopp committed
422 423 424 425 426 427 428 429 430 431 432 433 434
    
    // the thread can now be woken up
    if (pthread_cond_signal(&proc->cond_prach) != 0) {
      LOG_E( PHY, "[eNB] ERROR pthread_cond_signal for eNB PRACH thread %d\n", proc->thread_index);
      exit_fun( "ERROR pthread_cond_signal" );
      return;
    }
    
    pthread_mutex_unlock( &proc->mutex_prach );
  }

}

435 436 437 438 439
/*!
 * \brief The prach receive thread of eNB.
 * \param param is a \ref eNB_proc_t structure which contains the info what to process.
 * \returns a pointer to an int. The storage is not on the heap and must not be freed.
 */
Sandeep Kumar's avatar
Sandeep Kumar committed
440
static void* eNB_thread_prach( void* param ) {
441 442
  static int eNB_thread_prach_status;

443 444 445

  PHY_VARS_eNB *eNB= (PHY_VARS_eNB *)param;
  eNB_proc_t *proc = &eNB->proc;
Raymond Knopp's avatar
Raymond Knopp committed
446

447 448 449
  // set default return value
  eNB_thread_prach_status = 0;

450
  thread_top_init("eNB_thread_prach",1,500000L,1000000L,20000000L);
451

Sandeep Kumar's avatar
Sandeep Kumar committed
452 453 454
  while (!oai_exit) {
    
    if (oai_exit) break;
knopp's avatar
knopp committed
455
    
Sandeep Kumar's avatar
Sandeep Kumar committed
456

knopp's avatar
knopp committed
457
    if (wait_on_condition(&proc->mutex_prach,&proc->cond_prach,&proc->instance_cnt_prach,"eNB_prach_thread") < 0) break;
knopp's avatar
knopp committed
458 459

    LOG_D(PHY,"Running eNB prach procedures\n");
460
    prach_procedures(eNB);
461
    
knopp's avatar
knopp committed
462
    if (release_thread(&proc->mutex_prach,&proc->instance_cnt_prach,"eNB_prach_thread") < 0) break;
Sandeep Kumar's avatar
Sandeep Kumar committed
463
  }
464

knopp's avatar
knopp committed
465
  LOG_I(PHY, "Exiting eNB thread PRACH\n");
Raymond Knopp's avatar
Raymond Knopp committed
466

467 468
  eNB_thread_prach_status = 0;
  return &eNB_thread_prach_status;
469 470
}

knopp's avatar
knopp committed
471

knopp's avatar
knopp committed
472

473
extern void init_fep_thread(PHY_VARS_eNB *, pthread_attr_t *);
knopp's avatar
knopp committed
474 475
extern void init_td_thread(PHY_VARS_eNB *, pthread_attr_t *);
extern void init_te_thread(PHY_VARS_eNB *, pthread_attr_t *);
476

477
void init_eNB_proc(int inst) {
Sandeep Kumar's avatar
Sandeep Kumar committed
478
  
Rohit Gupta's avatar
Rohit Gupta committed
479
  int i=0;
480
  int CC_id;
481 482
  PHY_VARS_eNB *eNB;
  eNB_proc_t *proc;
knopp's avatar
knopp committed
483
  eNB_rxtx_proc_t *proc_rxtx;
484
  pthread_attr_t *attr0=NULL,*attr1=NULL,*attr_FH=NULL,*attr_prach=NULL,*attr_asynch=NULL,*attr_single=NULL,*attr_fep=NULL,*attr_td=NULL,*attr_te=NULL,*attr_synch=NULL;
knopp's avatar
knopp committed
485

knopp's avatar
knopp committed
486
  for (CC_id=0; CC_id<RC.nb_CC[inst]; CC_id++) {
487
    eNB = RC.eNB[inst][CC_id];
laurent's avatar
small2  
laurent committed
488
#ifndef OCP_FRAMEWORK
489
    LOG_I(PHY,"Initializing eNB processes %d CC_id %d \n",inst,CC_id);
laurent's avatar
small2  
laurent committed
490
#endif
491
    proc = &eNB->proc;
knopp's avatar
knopp committed
492

493
    proc_rxtx                      = proc->proc_rxtx;
494 495
    proc_rxtx[0].instance_cnt_rxtx = -1;
    proc_rxtx[1].instance_cnt_rxtx = -1;
496
    proc->instance_cnt_prach       = -1;
497
    proc->instance_cnt_asynch_rxtx = -1;
498
    proc->CC_id                    = CC_id;    
499

knopp's avatar
knopp committed
500 501
    proc->first_rx=1;
    proc->first_tx=1;
502 503
    proc->RU_mask=0;
    proc->RU_mask_prach=0;
knopp's avatar
knopp committed
504

505
    pthread_mutex_init( &eNB->UL_INFO_mutex, NULL);
506 507 508 509
    pthread_mutex_init( &proc_rxtx[0].mutex_rxtx, NULL);
    pthread_mutex_init( &proc_rxtx[1].mutex_rxtx, NULL);
    pthread_cond_init( &proc_rxtx[0].cond_rxtx, NULL);
    pthread_cond_init( &proc_rxtx[1].cond_rxtx, NULL);
knopp's avatar
knopp committed
510 511 512

    pthread_mutex_init( &proc->mutex_prach, NULL);
    pthread_mutex_init( &proc->mutex_asynch_rxtx, NULL);
513 514
    pthread_mutex_init( &proc->mutex_RU,NULL);
    pthread_mutex_init( &proc->mutex_RU_PRACH,NULL);
knopp's avatar
knopp committed
515

516
    pthread_cond_init( &proc->cond_prach, NULL);
517
    pthread_cond_init( &proc->cond_asynch_rxtx, NULL);
518 519 520 521

    pthread_attr_init( &proc->attr_prach);
    pthread_attr_init( &proc->attr_asynch_rxtx);
    pthread_attr_init( &proc->attr_single);
522 523
    pthread_attr_init( &proc->attr_td);
    pthread_attr_init( &proc->attr_te);
524 525
    pthread_attr_init( &proc_rxtx[0].attr_rxtx);
    pthread_attr_init( &proc_rxtx[1].attr_rxtx);
526
#ifndef DEADLINE_SCHEDULER
knopp's avatar
knopp committed
527 528 529 530 531
    attr0       = &proc_rxtx[0].attr_rxtx;
    attr1       = &proc_rxtx[1].attr_rxtx;
    attr_prach  = &proc->attr_prach;
    attr_asynch = &proc->attr_asynch_rxtx;
    attr_single = &proc->attr_single;
532 533
    attr_td     = &proc->attr_td;
    attr_te     = &proc->attr_te; 
knopp's avatar
knopp committed
534 535
#endif

536 537 538 539
    if (eNB->single_thread_flag==0) {
      pthread_create( &proc_rxtx[0].pthread_rxtx, attr0, eNB_thread_rxtx, &proc_rxtx[0] );
      pthread_create( &proc_rxtx[1].pthread_rxtx, attr1, eNB_thread_rxtx, &proc_rxtx[1] );
    }
540
    pthread_create( &proc->pthread_prach, attr_prach, eNB_thread_prach, eNB );
knopp's avatar
knopp committed
541

542
    char name[16];
543 544 545 546 547 548
    if (eNB->single_thread_flag==0) {
      snprintf( name, sizeof(name), "RXTX0 %d", i );
      pthread_setname_np( proc_rxtx[0].pthread_rxtx, name );
      snprintf( name, sizeof(name), "RXTX1 %d", i );
      pthread_setname_np( proc_rxtx[1].pthread_rxtx, name );
    }
knopp's avatar
knopp committed
549 550 551

    AssertFatal(proc->instance_cnt_prach == -1,"instance_cnt_prach = %d\n",proc->instance_cnt_prach);

552
    
553
  }
554

555
  //for multiple CCs: setup master and slaves
556 557 558
  /* 
     for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
     eNB = PHY_vars_eNB_g[inst][CC_id];
559

560 561 562
     if (eNB->node_timing == synch_to_ext_device) { //master
     eNB->proc.num_slaves = MAX_NUM_CCs-1;
     eNB->proc.slave_proc = (eNB_proc_t**)malloc(eNB->proc.num_slaves*sizeof(eNB_proc_t*));
563

564 565 566 567 568 569 570
     for (i=0; i< eNB->proc.num_slaves; i++) {
     if (i < CC_id)  eNB->proc.slave_proc[i] = &(PHY_vars_eNB_g[inst][i]->proc);
     if (i >= CC_id)  eNB->proc.slave_proc[i] = &(PHY_vars_eNB_g[inst][i+1]->proc);
     }
     }
     }
  */
571

572 573 574 575
  /* setup PHY proc TX sync mechanism */
  pthread_mutex_init(&sync_phy_proc.mutex_phy_proc_tx, NULL);
  pthread_cond_init(&sync_phy_proc.cond_phy_proc_tx, NULL);
  sync_phy_proc.phy_proc_CC_id = 0;
576 577
}

578

579

580 581 582
/*!
 * \brief Terminate eNB TX and RX threads.
 */
583
void kill_eNB_proc(int inst) {
Sandeep Kumar's avatar
Sandeep Kumar committed
584

585
  int *status;
586 587
  PHY_VARS_eNB *eNB;
  eNB_proc_t *proc;
knopp's avatar
knopp committed
588
  eNB_rxtx_proc_t *proc_rxtx;
589
  for (int CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
590
    eNB=RC.eNB[inst][CC_id];
591 592
    
    proc = &eNB->proc;
knopp's avatar
knopp committed
593
    proc_rxtx = &proc->proc_rxtx[0];
594
    
knopp's avatar
knopp committed
595 596

    LOG_I(PHY, "Killing TX CC_id %d inst %d\n", CC_id, inst );
597
    
knopp's avatar
knopp committed
598 599
    proc_rxtx[0].instance_cnt_rxtx = 0; // FIXME data race!
    proc_rxtx[1].instance_cnt_rxtx = 0; // FIXME data race!
Raymond Knopp's avatar
Raymond Knopp committed
600
    proc->instance_cnt_prach = 0;
knopp's avatar
knopp committed
601
    pthread_cond_signal( &proc_rxtx[0].cond_rxtx );    
Raymond Knopp's avatar
Raymond Knopp committed
602 603
    pthread_cond_signal( &proc_rxtx[1].cond_rxtx );
    pthread_cond_signal( &proc->cond_prach );
604
    pthread_cond_broadcast(&sync_phy_proc.cond_phy_proc_tx);
605 606 607
    pthread_join( proc->pthread_prach, (void**)&status );    
    pthread_mutex_destroy( &proc->mutex_prach );
    pthread_cond_destroy( &proc->cond_prach );         
608
    pthread_mutex_destroy(&eNB->UL_INFO_mutex);
609
    int i;
Raymond Knopp's avatar
Raymond Knopp committed
610
    for (i=0;i<2;i++) {
knopp's avatar
knopp committed
611 612 613 614
      pthread_join( proc_rxtx[i].pthread_rxtx, (void**)&status );
      pthread_mutex_destroy( &proc_rxtx[i].mutex_rxtx );
      pthread_cond_destroy( &proc_rxtx[i].cond_rxtx );
    }
615
  }
616 617
}

618

619 620 621


void reset_opp_meas(void) {
Sandeep Kumar's avatar
Sandeep Kumar committed
622

623 624 625 626 627
  int sfn;
  reset_meas(&softmodem_stats_mt);
  reset_meas(&softmodem_stats_hw);
  
  for (sfn=0; sfn < 10; sfn++) {
knopp's avatar
knopp committed
628
    reset_meas(&softmodem_stats_rxtx_sf);
629
    reset_meas(&softmodem_stats_rx_sf);
630 631 632
  }
}

Sandeep Kumar's avatar
Sandeep Kumar committed
633

634 635 636 637 638 639 640
void print_opp_meas(void) {

  int sfn=0;
  print_meas(&softmodem_stats_mt, "Main ENB Thread", NULL, NULL);
  print_meas(&softmodem_stats_hw, "HW Acquisation", NULL, NULL);
  
  for (sfn=0; sfn < 10; sfn++) {
knopp's avatar
knopp committed
641
    print_meas(&softmodem_stats_rxtx_sf,"[eNB][total_phy_proc_rxtx]",NULL, NULL);
642
    print_meas(&softmodem_stats_rx_sf,"[eNB][total_phy_proc_rx]",NULL,NULL);
643 644
  }
}
645

646
void init_transport(PHY_VARS_eNB *eNB) {
647

648 649 650
  int i;
  int j;
  LTE_DL_FRAME_PARMS *fp = &eNB->frame_parms;
knopp's avatar
knopp committed
651

652 653 654 655 656 657
  for (i=0; i<NUMBER_OF_UE_MAX; i++) {
    LOG_I(PHY,"Allocating Transport Channel Buffers for DLSCH, UE %d\n",i);
    for (j=0; j<2; j++) {
      eNB->dlsch[i][j] = new_eNB_dlsch(1,8,NSOFT,fp->N_RB_DL,0,fp);
      if (!eNB->dlsch[i][j]) {
	LOG_E(PHY,"Can't get eNB dlsch structures for UE %d \n", i);
knopp's avatar
knopp committed
658
	exit(-1);
659 660 661
      } else {
	LOG_D(PHY,"dlsch[%d][%d] => %p\n",i,j,eNB->dlsch[i][j]);
	eNB->dlsch[i][j]->rnti=0;
knopp's avatar
knopp committed
662 663
      }
    }
664 665 666 667 668 669
    
    LOG_I(PHY,"Allocating Transport Channel Buffer for ULSCH, UE %d\n",i);
    eNB->ulsch[1+i] = new_eNB_ulsch(MAX_TURBO_ITERATIONS,fp->N_RB_UL, 0);
    
    if (!eNB->ulsch[1+i]) {
      LOG_E(PHY,"Can't get eNB ulsch structures\n");
knopp's avatar
knopp committed
670 671
      exit(-1);
    }
672 673 674 675
    
    // this is the transmission mode for the signalling channels
    // this will be overwritten with the real transmission mode by the RRC once the UE is connected
    eNB->transmission_mode[i] = fp->nb_antenna_ports_eNB==1 ? 1 : 2;
knopp's avatar
knopp committed
676
  }
677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692
  // ULSCH for RA
  eNB->ulsch[0] = new_eNB_ulsch(MAX_TURBO_ITERATIONS, fp->N_RB_UL, 0);
  
  if (!eNB->ulsch[0]) {
    LOG_E(PHY,"Can't get eNB ulsch structures\n");
    exit(-1);
  }
  eNB->dlsch_SI  = new_eNB_dlsch(1,8,NSOFT,fp->N_RB_DL, 0, fp);
  LOG_D(PHY,"eNB %d.%d : SI %p\n",eNB->Mod_id,eNB->CC_id,eNB->dlsch_SI);
  eNB->dlsch_ra  = new_eNB_dlsch(1,8,NSOFT,fp->N_RB_DL, 0, fp);
  LOG_D(PHY,"eNB %d.%d : RA %p\n",eNB->Mod_id,eNB->CC_id,eNB->dlsch_ra);
  eNB->dlsch_MCH = new_eNB_dlsch(1,8,NSOFT,fp->N_RB_DL, 0, fp);
  LOG_D(PHY,"eNB %d.%d : MCH %p\n",eNB->Mod_id,eNB->CC_id,eNB->dlsch_MCH);
  
  
  eNB->rx_total_gain_dB=130;
knopp's avatar
knopp committed
693
  
694 695 696 697 698 699 700 701 702 703 704 705 706 707 708
  for(i=0; i<NUMBER_OF_UE_MAX; i++)
    eNB->mu_mimo_mode[i].dl_pow_off = 2;
  
  eNB->check_for_total_transmissions = 0;
  
  eNB->check_for_MUMIMO_transmissions = 0;
  
  eNB->FULL_MUMIMO_transmissions = 0;
  
  eNB->check_for_SUMIMO_transmissions = 0;
  
  fp->pucch_config_common.deltaPUCCH_Shift = 1;
    
} 
void init_eNB_afterRU() {
knopp's avatar
knopp committed
709

710 711
  int inst,CC_id,ru_id,i,aa;
  PHY_VARS_eNB *eNB;
712 713


714 715 716 717 718 719 720
  for (inst=0;inst<RC.nb_inst;inst++) {
    for (CC_id=0;CC_id<RC.nb_CC[inst];CC_id++) {
      eNB                                  =  RC.eNB[inst][CC_id];
      phy_init_lte_eNB(eNB,0,0);
      // map antennas and PRACH signals to eNB RX
      AssertFatal(eNB->num_RU>0,"Number of RU attached to eNB %d is zero\n",eNB->Mod_id);
      LOG_I(PHY,"Mapping RX ports from %d RUs to eNB %d\n",eNB->num_RU,eNB->Mod_id);
721
      eNB->frame_parms.nb_antennas_rx       = 0;
722 723
      for (ru_id=0,aa=0;ru_id<eNB->num_RU;ru_id++) {
	eNB->frame_parms.nb_antennas_rx    += eNB->RU_list[ru_id]->nb_rx;
724 725 726 727 728 729 730 731 732

	AssertFatal(eNB->RU_list[ru_id]->common.rxdataF!=NULL,
		    "RU %d : common.rxdataF is NULL\n",
		    eNB->RU_list[ru_id]->idx);

	AssertFatal(eNB->RU_list[ru_id]->prach_rxsigF!=NULL,
		    "RU %d : prach_rxsigF is NULL\n",
		    eNB->RU_list[ru_id]->idx);

733 734 735 736 737 738
	for (i=0;i<eNB->RU_list[ru_id]->nb_rx;aa++,i++) { 
	  LOG_I(PHY,"Attaching RU %d antenna %d to eNB antenna %d\n",eNB->RU_list[ru_id]->idx,i,aa);
	  eNB->prach_vars.rxsigF[aa]       =  eNB->RU_list[ru_id]->prach_rxsigF[i];
	  eNB->common_vars.rxdataF[aa]     =  eNB->RU_list[ru_id]->common.rxdataF[i];
	}
      }
739 740 741
      AssertFatal(eNB->frame_parms.nb_antennas_rx >0,
		  "inst %d, CC_id %d : nb_antennas_rx %d\n",inst,CC_id,eNB->frame_parms.nb_antennas_rx);
      LOG_I(PHY,"inst %d, CC_id %d : nb_antennas_rx %d\n",inst,CC_id,eNB->frame_parms.nb_antennas_rx);
742 743 744 745 746 747 748 749 750 751 752 753

      AssertFatal(eNB->frame_parms.nb_antennas_rx <= sizeof(eNB->prach_vars.prach_ifft) / sizeof(eNB->prach_vars.prach_ifft[0]),
		  "nb_antennas_rx too large");
      for (i=0; i<eNB->frame_parms.nb_antennas_rx; i++) {
	eNB->prach_vars.prach_ifft[i] = (int16_t*)malloc16_clear(1024*2*sizeof(int16_t));
	LOG_D(PHY,"[INIT] prach_vars->prach_ifft[%d] = %p\n",i,eNB->prach_vars.prach_ifft[i]);
      }
      init_transport(eNB);
      init_precoding_weights(RC.eNB[inst][CC_id]);
    }
    init_eNB_proc(inst);
  }
knopp's avatar
knopp committed
754

755
  for (ru_id=0;ru_id<RC.nb_RU;ru_id++) {
756 757

    AssertFatal(RC.ru[ru_id]!=NULL,"ru_id %d is null\n",ru_id);
758
    
759 760 761
    RC.ru[ru_id]->wakeup_rxtx      = wakeup_rxtx;
    RC.ru[ru_id]->wakeup_prach_eNB = wakeup_prach_eNB;
    RC.ru[ru_id]->eNB_top          = eNB_top;
762 763 764
  }
}
void init_eNB(int single_thread_flag,int wait_for_sync) {
765
  
766
  int CC_id;
767
  int inst;
768
  PHY_VARS_eNB *eNB;
knopp's avatar
knopp committed
769

770 771
  if (RC.eNB == NULL) RC.eNB = (PHY_VARS_eNB***) malloc(RC.nb_L1_inst*sizeof(PHY_VARS_eNB **));
  for (inst=0;inst<RC.nb_L1_inst;inst++) {
knopp's avatar
knopp committed
772
    if (RC.eNB[inst] == NULL) RC.eNB[inst] = (PHY_VARS_eNB**) malloc(RC.nb_CC[inst]*sizeof(PHY_VARS_eNB *));
773
    for (CC_id=0;CC_id<RC.nb_L1_CC[inst];CC_id++) {
774 775
      if (RC.eNB[inst][CC_id] == NULL) RC.eNB[inst][CC_id] = (PHY_VARS_eNB*) malloc(sizeof(PHY_VARS_eNB));
      eNB                     = RC.eNB[inst][CC_id]; 
776
      eNB->abstraction_flag   = 0;
knopp's avatar
knopp committed
777
      eNB->single_thread_flag = single_thread_flag;
778

779

laurent's avatar
small2  
laurent committed
780
#ifndef OCP_FRAMEWORK
781
      LOG_I(PHY,"Initializing eNB %d CC_id %d\n",inst,CC_id);
laurent's avatar
small2  
laurent committed
782
#endif
knopp's avatar
knopp committed
783 784


785 786
      eNB->td                   = ulsch_decoding_data;//(single_thread_flag==1) ? ulsch_decoding_data_2thread : ulsch_decoding_data;
      eNB->te                   = dlsch_encoding;//(single_thread_flag==1) ? dlsch_encoding_2threads : dlsch_encoding;
787

788
      
789
      LOG_I(PHY,"Registering with MAC interface module\n");
790 791 792 793 794 795 796 797
      AssertFatal((eNB->if_inst         = IF_Module_init(inst))!=NULL,"Cannot register interface");
      eNB->if_inst->schedule_response   = schedule_response;
      eNB->if_inst->PHY_config_req      = phy_config_request;
      memset((void*)&eNB->UL_INFO,0,sizeof(eNB->UL_INFO));
      memset((void*)&eNB->Sched_INFO,0,sizeof(eNB->Sched_INFO));
      LOG_I(PHY,"Setting indication lists\n");
      eNB->UL_INFO.rx_ind.rx_pdu_list   = eNB->rx_pdu_list;
      eNB->UL_INFO.crc_ind.crc_pdu_list = eNB->crc_pdu_list;
knopp's avatar
knopp committed
798 799
    }

800
  }
801

802

803
  LOG_I(PHY,"[lte-softmodem.c] eNB structure allocated\n");
804
  
805 806


807 808 809
}


810
void stop_eNB(int nb_inst) {
811

812
  for (int inst=0;inst<nb_inst;inst++) {
knopp's avatar
knopp committed
813
    LOG_I(PHY,"Killing eNB %d processing threads\n",inst);
814 815
    kill_eNB_proc(inst);
  }
816
}