defs.h 57.5 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 32 33 34

/*! \file PHY/defs.h
 \brief Top-level defines and structure definitions
 \author R. Knopp, F. Kaltenberger
 \date 2011
 \version 0.1
 \company Eurecom
 \email: knopp@eurecom.fr,florian.kaltenberger@eurecom.fr
 \note
 \warning
*/
#ifndef __PHY_DEFS__H__
#define __PHY_DEFS__H__

35

36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51
#define _GNU_SOURCE
#include <sched.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/ioctl.h>
#include <sys/types.h>
#include <sys/mman.h>
#include <linux/sched.h>
#include <signal.h>
#include <execinfo.h>
#include <getopt.h>
#include <sys/sysinfo.h>


52 53 54 55 56
#include <stdio.h>
#include <stdlib.h>
#include <malloc.h>
#include <string.h>
#include <math.h>
57
#include "common_lib.h"
58
#include "msc.h"
59

60 61
#include "openair2/PHY_INTERFACE/IF_Module.h"

62
//#include <complex.h>
63
#include "assertions.h"
64
#ifdef MEX
65
# define msg mexPrintf
66 67
#endif
//use msg in the real-time thread context
68
#define msg_nrt printf
69
//use msg_nrt in the non real-time context (for initialization, ...)
Cedric Roux's avatar
Cedric Roux committed
70 71 72 73 74 75
#ifndef malloc16
#  ifdef __AVX2__
#    define malloc16(x) memalign(32,x)
#  else
#    define malloc16(x) memalign(16,x)
#  endif
76
#endif
77 78 79 80 81 82
#define free16(y,x) free(y)
#define bigmalloc malloc
#define bigmalloc16 malloc16
#define openair_free(y,x) free((y))
#define PAGE_SIZE 4096

83 84
#define RX_NB_TH_MAX 2
#define RX_NB_TH 2
85

86

87 88 89 90
//! \brief Allocate \c size bytes of memory on the heap with alignment 16 and zero it afterwards.
//! If no more memory is available, this function will terminate the program with an assertion error.
static inline void* malloc16_clear( size_t size )
{
91 92 93
#ifdef __AVX2__
  void* ptr = memalign(32, size);
#else
94
  void* ptr = memalign(16, size);
95
#endif
96 97 98 99
  DevAssert(ptr);
  memset( ptr, 0, size );
  return ptr;
}
100

101 102


103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119
#define PAGE_MASK 0xfffff000
#define virt_to_phys(x) (x)

#define openair_sched_exit() exit(-1)


#define max(a,b)  ((a)>(b) ? (a) : (b))
#define min(a,b)  ((a)<(b) ? (a) : (b))


#define bzero(s,n) (memset((s),0,(n)))

#define cmax(a,b)  ((a>b) ? (a) : (b))
#define cmin(a,b)  ((a<b) ? (a) : (b))

#define cmax3(a,b,c) ((cmax(a,b)>c) ? (cmax(a,b)) : (c))

120 121 122
/// suppress compiler warning for unused arguments
#define UNUSED(x) (void)x;

123 124 125 126 127 128 129

#include "impl_defs_top.h"
#include "impl_defs_lte.h"

#include "PHY/TOOLS/time_meas.h"
#include "PHY/CODING/defs.h"
#include "PHY/TOOLS/defs.h"
130
#include "platform_types.h"
131
#define MAX_NUM_RU_PER_eNB 64 
Laurent's avatar
Laurent committed
132

133
#include "PHY/LTE_TRANSPORT/defs.h"
Raymond Knopp's avatar
 
Raymond Knopp committed
134
#include <pthread.h>
135

136
#include "targets/ARCH/COMMON/common_lib.h"
137
#include "targets/COMMON/openairinterface5g_limits.h"
138

139
#if defined(EXMIMO) || defined(OAI_USRP)
140 141 142 143
//#define NUMBER_OF_eNB_MAX 1
//#define NUMBER_OF_UE_MAX 16

//#define NUMBER_OF_CONNECTED_eNB_MAX 3
144 145
#else
#ifdef LARGE_SCALE
146 147 148
//#define NUMBER_OF_eNB_MAX 2
//#define NUMBER_OF_UE_MAX 120
//#define NUMBER_OF_CONNECTED_eNB_MAX 1 // to save some memory
149
#else
150 151 152 153
//#define NUMBER_OF_eNB_MAX 3
//#define NUMBER_OF_UE_MAX 16
//#define NUMBER_OF_RU_MAX 64
//#define NUMBER_OF_CONNECTED_eNB_MAX 1
154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171
#endif
#endif
#define NUMBER_OF_SUBBANDS_MAX 13
#define NUMBER_OF_HARQ_PID_MAX 8

#define MAX_FRAME_NUMBER 0x400



#define NUMBER_OF_RN_MAX 3
typedef enum {no_relay=1,unicast_relay_type1,unicast_relay_type2, multicast_relay} relaying_type_t;



#define MCS_COUNT 28
#define MCS_TABLE_LENGTH_MAX 64


172 173 174 175
#define NUM_DCI_MAX 32

#define NUMBER_OF_eNB_SECTORS_MAX 3

176 177
#define NB_BANDS_MAX 8

178 179 180
#define MAX_BANDS_PER_RRU 4


Laurent's avatar
Laurent committed
181 182 183
#ifdef OCP_FRAMEWORK
#include <enums.h>
#else
184
typedef enum {normal_txrx=0,rx_calib_ue=1,rx_calib_ue_med=2,rx_calib_ue_byp=3,debug_prach=4,no_L2_connect=5,calib_prach_tx=6,rx_dump_frame=7,loop_through_memory=8} runmode_t;
185

186 187 188 189 190 191 192 193
/*! \brief Extension Type */
typedef enum {
  CYCLIC_PREFIX,
  CYCLIC_SUFFIX,
  ZEROS,
  NONE
} Extension_t;
	
194
enum transmission_access_mode {
195 196 197 198 199
  NO_ACCESS=0,
  POSTPONED_ACCESS,
  CANCELED_ACCESS,
  UNKNOWN_ACCESS,
  SCHEDULED_ACCESS,
200 201
  CBA_ACCESS};

202
typedef enum  {
203
  eNodeB_3GPP=0,   // classical eNodeB function
204 205
  NGFI_RAU_IF5,    // RAU with NGFI IF5
  NGFI_RAU_IF4p5,  // RAU with NFGI IF4p5
Raymond Knopp's avatar
Raymond Knopp committed
206
  NGFI_RRU_IF5,    // NGFI_RRU (NGFI remote radio-unit,IF5)
207 208 209
  NGFI_RRU_IF4p5,  // NGFI_RRU (NGFI remote radio-unit,IF4p5)
  MBP_RRU_IF5      // Mobipass RRU
} node_function_t;
210

211
typedef enum {
212

213
  synch_to_ext_device=0,  // synch to RF or Ethernet device
214
  synch_to_other,          // synch to another source_(timer, other RU)
Cedric Roux's avatar
Cedric Roux committed
215
  synch_to_mobipass_standalone  // special case for mobipass in standalone mode
216 217
} node_timing_t;
#endif
218

219 220
typedef struct UE_SCAN_INFO_s {
  /// 10 best amplitudes (linear) for each pss signals
221
  int32_t amp[3][10];
222
  /// 10 frequency offsets (kHz) corresponding to best amplitudes, with respect do minimum DL frequency in the band
223
  int32_t freq_offset_Hz[3][10];
224 225
} UE_SCAN_INFO_t;

226 227 228 229 230 231 232 233 234 235 236 237 238 239
/// Top-level PHY Data Structure for RN
typedef struct {
  /// Module ID indicator for this instance
  uint8_t Mod_id;
  uint32_t frame;
  // phy_vars_eNB
  // phy_vars ue
  // cuurently only used to store and forward the PMCH
  uint8_t mch_avtive[10];
  uint8_t sync_area[10]; // num SF
  LTE_UE_DLSCH_t   *dlsch_rn_MCH[10];

} PHY_VARS_RN;

240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267
/// Context data structure for RX/TX portion of subframe processing
typedef struct {
  /// Component Carrier index
  uint8_t              CC_id;
  /// timestamp transmitted to HW
  openair0_timestamp timestamp_tx;
  /// subframe to act upon for transmission
  int subframe_tx;
  /// subframe to act upon for reception
  int subframe_rx;
  /// frame to act upon for transmission
  int frame_tx;
  /// frame to act upon for reception
  int frame_rx;
  /// \brief Instance count for RXn-TXnp4 processing thread.
  /// \internal This variable is protected by \ref mutex_rxtx.
  int instance_cnt_rxtx;
  /// pthread structure for RXn-TXnp4 processing thread
  pthread_t pthread_rxtx;
  /// pthread attributes for RXn-TXnp4 processing thread
  pthread_attr_t attr_rxtx;
  /// condition variable for tx processing thread
  pthread_cond_t cond_rxtx;
  /// mutex for RXn-TXnp4 processing thread
  pthread_mutex_t mutex_rxtx;
  /// scheduling parameters for RXn-TXnp4 thread
  struct sched_param sched_param_rxtx;
} eNB_rxtx_proc_t;
268 269 270 271 272 273 274 275 276 277 278 279 280

typedef struct {
  struct PHY_VARS_eNB_s *eNB;
  int UE_id;
  int harq_pid;
  int llr8_flag;
  int ret;
} td_params;

typedef struct {
  struct PHY_VARS_eNB_s *eNB;
  LTE_eNB_DLSCH_t *dlsch;
  int G;
281
  int harq_pid;
Eurecom's avatar
Eurecom committed
282 283 284 285 286 287 288 289 290 291 292 293 294 295
  int total_worker;
  int current_worker;
  /// \internal This variable is protected by \ref mutex_te.
  int instance_cnt_te;
  /// pthread attributes for parallel turbo-encoder thread
  pthread_attr_t attr_te;
  /// scheduling parameters for parallel turbo-encoder thread
  struct sched_param sched_param_te;
  /// pthread structure for parallel turbo-encoder thread
  pthread_t pthread_te;
  /// condition variable for parallel turbo-encoder thread
  pthread_cond_t cond_te;
  /// mutex for parallel turbo-encoder thread
  pthread_mutex_t mutex_te;
296 297
} te_params;

298 299 300
typedef struct RU_proc_t_s {
  /// Pointer to associated RU descriptor
  struct RU_t_s *ru;
301 302 303 304 305 306
  /// timestamp received from HW
  openair0_timestamp timestamp_rx;
  /// timestamp to send to "slave rru"
  openair0_timestamp timestamp_tx;
  /// subframe to act upon for reception
  int subframe_rx;
307 308 309 310
  /// subframe to act upon for transmission
  int subframe_tx;
  /// subframe to act upon for reception of prach
  int subframe_prach;
311 312 313 314
#ifdef Rel14
  /// subframe to act upon for reception of prach BL/CE UEs
  int subframe_prach_br;
#endif
315 316
  /// frame to act upon for reception
  int frame_rx;
317 318
  /// frame to act upon for transmission
  int frame_tx;
319 320
  /// unwrapped frame count
  int frame_tx_unwrap;
321 322
  /// frame to act upon for reception of prach
  int frame_prach;
323 324 325 326
#ifdef Rel14
  /// frame to act upon for reception of prach
  int frame_prach_br;
#endif
327 328
  /// frame offset for slave RUs (to correct for frame asynchronism at startup)
  int frame_offset;
329 330 331
  /// \brief Instance count for FH processing thread.
  /// \internal This variable is protected by \ref mutex_FH.
  int instance_cnt_FH;
332
  int instance_cnt_FH1;
333 334
  /// \internal This variable is protected by \ref mutex_prach.
  int instance_cnt_prach;
335 336 337 338
#ifdef Rel14
  /// \internal This variable is protected by \ref mutex_prach.
  int instance_cnt_prach_br;
#endif
339 340 341 342
  /// \internal This variable is protected by \ref mutex_synch.
  int instance_cnt_synch;
  /// \internal This variable is protected by \ref mutex_eNBs.
  int instance_cnt_eNBs;
343 344 345
  /// \brief Instance count for rx processing thread.
  /// \internal This variable is protected by \ref mutex_asynch_rxtx.
  int instance_cnt_asynch_rxtx;
346 347
  /// \internal This variable is protected by \ref mutex_fep
  int instance_cnt_fep;
348
  /// \internal This variable is protected by \ref mutex_feptx
349
  int instance_cnt_feptx;
350 351
  /// This varible is protected by \ref mutex_emulatedRF
  int instance_cnt_emulateRF;
352
  /// pthread structure for RU FH processing thread
353
  pthread_t pthread_FH;
354
  pthread_t pthread_FH1;
355 356
  /// pthread structure for RU prach processing thread
  pthread_t pthread_prach;
357 358 359 360
#ifdef Rel14
  /// pthread structure for RU prach processing thread BL/CE UEs
  pthread_t pthread_prach_br;
#endif
361 362
  /// pthread struct for RU synch thread
  pthread_t pthread_synch;
363
  /// pthread struct for RU RX FEP worker thread
364
  pthread_t pthread_fep;
365
  /// pthread struct for RU TX FEP worker thread
366
  pthread_t pthread_feptx;
367 368
  /// pthread struct for emulated RF
  pthread_t pthread_emulateRF;
369 370 371 372 373 374
  /// pthread structure for asychronous RX/TX processing thread
  pthread_t pthread_asynch_rxtx;
  /// flag to indicate first RX acquisition
  int first_rx;
  /// flag to indicate first TX transmission
  int first_tx;
375
  /// pthread attributes for RU FH processing thread
376
  pthread_attr_t attr_FH;
377
  pthread_attr_t attr_FH1;
378 379
  /// pthread attributes for RU prach
  pthread_attr_t attr_prach;
380 381 382 383
#ifdef Rel14
  /// pthread attributes for RU prach BL/CE UEs
  pthread_attr_t attr_prach_br;
#endif
384 385
  /// pthread attributes for RU synch thread
  pthread_attr_t attr_synch;
386 387
  /// pthread attributes for asynchronous RX thread
  pthread_attr_t attr_asynch_rxtx;
388
  /// pthread attributes for worker fep thread
389
  pthread_attr_t attr_fep;
390 391
  /// pthread attributes for worker feptx thread
  pthread_attr_t attr_feptx;
392 393
  /// pthread attributes for emulated RF
  pthread_attr_t attr_emulateRF;
394
  /// scheduling parameters for RU FH thread
395
  struct sched_param sched_param_FH;
396
  struct sched_param sched_param_FH1;
397 398
  /// scheduling parameters for RU prach thread
  struct sched_param sched_param_prach;
399 400 401 402
#ifdef Rel14
  /// scheduling parameters for RU prach thread BL/CE UEs
  struct sched_param sched_param_prach_br;
#endif
403 404
  /// scheduling parameters for RU synch thread
  struct sched_param sched_param_synch;
405 406
  /// scheduling parameters for asynch_rxtx thread
  struct sched_param sched_param_asynch_rxtx;
407
  /// condition variable for RU FH thread
408
  pthread_cond_t cond_FH;
409
  pthread_cond_t cond_FH1;
410 411
  /// condition variable for RU prach thread
  pthread_cond_t cond_prach;
412 413 414 415
#ifdef Rel14
  /// condition variable for RU prach thread BL/CE UEs
  pthread_cond_t cond_prach_br;
#endif
416 417
  /// condition variable for RU synch thread
  pthread_cond_t cond_synch;
418 419
  /// condition variable for asynch RX/TX thread
  pthread_cond_t cond_asynch_rxtx;
420
  /// condition varible for RU RX FEP thread
421
  pthread_cond_t cond_fep;
422
  /// condition varible for RU TX FEP thread
423
  pthread_cond_t cond_feptx;
424 425
  /// condition varible for emulated RF
  pthread_cond_t cond_emulateRF;
426 427 428
  /// condition variable for eNB signal
  pthread_cond_t cond_eNBs;
  /// mutex for RU FH
429
  pthread_mutex_t mutex_FH;
430
  pthread_mutex_t mutex_FH1;
431 432
  /// mutex for RU prach
  pthread_mutex_t mutex_prach;
433 434 435 436
#ifdef Rel14
  /// mutex for RU prach BL/CE UEs
  pthread_mutex_t mutex_prach_br;
#endif
437 438 439 440
  /// mutex for RU synch
  pthread_mutex_t mutex_synch;
  /// mutex for eNB signal
  pthread_mutex_t mutex_eNBs;
441 442
  /// mutex for asynch RX/TX thread
  pthread_mutex_t mutex_asynch_rxtx;
443
  /// mutex for fep RX worker thread
444
  pthread_mutex_t mutex_fep;
445 446
  /// mutex for fep TX worker thread
  pthread_mutex_t mutex_feptx;
447 448
  /// mutex for emulated RF thread
  pthread_mutex_t mutex_emulateRF;
449 450
  /// symbol mask for IF4p5 reception per subframe
  uint32_t symbol_mask[10];
451 452 453
  /// number of slave threads
  int                  num_slaves;
  /// array of pointers to slaves
454 455
  struct RU_proc_t_s           **slave_proc;
} RU_proc_t;
456

Raymond Knopp's avatar
 
Raymond Knopp committed
457
/// Context data structure for eNB subframe processing
458
typedef struct eNB_proc_t_s {
459
  /// Component Carrier index
460
  uint8_t              CC_id;
461 462 463 464
  /// thread index
  int thread_index;
  /// timestamp received from HW
  openair0_timestamp timestamp_rx;
465 466
  /// timestamp to send to "slave rru"
  openair0_timestamp timestamp_tx;
467
  /// subframe to act upon for reception
Raymond Knopp's avatar
 
Raymond Knopp committed
468
  int subframe_rx;
469 470
  /// subframe to act upon for PRACH
  int subframe_prach;
471 472 473 474
#ifdef Rel14
  /// subframe to act upon for reception of prach BL/CE UEs
  int subframe_prach_br;
#endif
475
  /// frame to act upon for reception
Raymond Knopp's avatar
 
Raymond Knopp committed
476
  int frame_rx;
477 478
  /// frame to act upon for transmission
  int frame_tx;
479 480
  /// frame to act upon for PRACH
  int frame_prach;
481 482 483 484
#ifdef Rel14
  /// frame to act upon for PRACH BL/CE UEs
  int frame_prach_br;
#endif
485 486 487
  /// \internal This variable is protected by \ref mutex_td.
  int instance_cnt_td;
  /// \internal This variable is protected by \ref mutex_te.
488
  int instance_cnt_te[3];
489 490
  /// \internal This variable is protected by \ref mutex_prach.
  int instance_cnt_prach;
491 492 493 494
#ifdef Rel14
  /// \internal This variable is protected by \ref mutex_prach for BL/CE UEs.
  int instance_cnt_prach_br;
#endif
495 496
  // instance count for over-the-air eNB synchronization
  int instance_cnt_synch;
497 498
  /// \internal This variable is protected by \ref mutex_asynch_rxtx.
  int instance_cnt_asynch_rxtx;
Raymond Knopp's avatar
Raymond Knopp committed
499 500
  /// pthread structure for eNB single processing thread
  pthread_t pthread_single;
501 502
  /// pthread structure for asychronous RX/TX processing thread
  pthread_t pthread_asynch_rxtx;
503 504
  /// flag to indicate first RX acquisition
  int first_rx;
Raymond Knopp's avatar
Raymond Knopp committed
505 506
  /// flag to indicate first TX transmission
  int first_tx;
507 508 509
  /// pthread attributes for parallel turbo-decoder thread
  pthread_attr_t attr_td;
  /// pthread attributes for parallel turbo-encoder thread
510
  pthread_attr_t attr_te[3];
Raymond Knopp's avatar
Raymond Knopp committed
511 512
  /// pthread attributes for single eNB processing thread
  pthread_attr_t attr_single;
513 514
  /// pthread attributes for prach processing thread
  pthread_attr_t attr_prach;
515 516 517 518
#ifdef Rel14
  /// pthread attributes for prach processing thread BL/CE UEs
  pthread_attr_t attr_prach_br;
#endif
519
  /// pthread attributes for asynchronous RX thread
520
  pthread_attr_t attr_asynch_rxtx;
521 522 523
  /// scheduling parameters for parallel turbo-decoder thread
  struct sched_param sched_param_td;
  /// scheduling parameters for parallel turbo-encoder thread
524
  struct sched_param sched_param_te[3];
Raymond Knopp's avatar
Raymond Knopp committed
525 526
  /// scheduling parameters for single eNB thread
  struct sched_param sched_param_single;
527 528
  /// scheduling parameters for prach thread
  struct sched_param sched_param_prach;
529 530 531 532
#ifdef Rel14
  /// scheduling parameters for prach thread
  struct sched_param sched_param_prach_br;
#endif
533 534
  /// scheduling parameters for asynch_rxtx thread
  struct sched_param sched_param_asynch_rxtx;
535 536 537
  /// pthread structure for parallel turbo-decoder thread
  pthread_t pthread_td;
  /// pthread structure for parallel turbo-encoder thread
538
  pthread_t pthread_te[3];
539
  /// pthread structure for PRACH thread
540
  pthread_t pthread_prach;
541 542 543 544
#ifdef Rel14
  /// pthread structure for PRACH thread BL/CE UEs
  pthread_t pthread_prach_br;
#endif
545 546 547
  /// condition variable for parallel turbo-decoder thread
  pthread_cond_t cond_td;
  /// condition variable for parallel turbo-encoder thread
548
  pthread_cond_t cond_te[3];
549
  /// condition variable for PRACH processing thread;
550
  pthread_cond_t cond_prach;
551 552 553 554
#ifdef Rel14
  /// condition variable for PRACH processing thread BL/CE UEs;
  pthread_cond_t cond_prach_br;
#endif
555 556
  /// condition variable for asynch RX/TX thread
  pthread_cond_t cond_asynch_rxtx;
557 558 559
  /// mutex for parallel turbo-decoder thread
  pthread_mutex_t mutex_td;
  /// mutex for parallel turbo-encoder thread
560
  pthread_mutex_t mutex_te[3];
561
  /// mutex for PRACH thread
562
  pthread_mutex_t mutex_prach;
563 564 565 566
#ifdef Rel14
  /// mutex for PRACH thread for BL/CE UEs
  pthread_mutex_t mutex_prach_br;
#endif
567 568
  /// mutex for asynch RX/TX thread
  pthread_mutex_t mutex_asynch_rxtx;
569 570 571 572
  /// mutex for RU access to eNB processing (PDSCH/PUSCH)
  pthread_mutex_t mutex_RU;
  /// mutex for RU access to eNB processing (PRACH)
  pthread_mutex_t mutex_RU_PRACH;
573 574
  /// mutex for RU access to eNB processing (PRACH BR)
  pthread_mutex_t mutex_RU_PRACH_br;
575 576 577 578
  /// mask for RUs serving eNB (PDSCH/PUSCH)
  int RU_mask;
  /// mask for RUs serving eNB (PRACH)
  int RU_mask_prach;
579 580 581 582
#ifdef Rel14
  /// mask for RUs serving eNB (PRACH)
  int RU_mask_prach_br;
#endif
583 584 585
  /// parameters for turbo-decoding worker thread
  td_params tdp;
  /// parameters for turbo-encoding worker thread
586
  te_params tep[3];
587 588
  /// set of scheduling variables RXn-TXnp4 threads
  eNB_rxtx_proc_t proc_rxtx[2];
589
  /// stats thread pthread descriptor
590
  pthread_t process_stats_thread;
591 592
  /// for waking up tx procedure
  RU_proc_t *ru_proc;
Raymond Knopp's avatar
 
Raymond Knopp committed
593 594
} eNB_proc_t;

595 596 597

/// Context data structure for RX/TX portion of subframe processing
typedef struct {
598 599
  /// index of the current UE RX/TX proc
  int                  proc_id;
600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624
  /// Component Carrier index
  uint8_t              CC_id;
  /// timestamp transmitted to HW
  openair0_timestamp timestamp_tx;
  /// subframe to act upon for transmission
  int subframe_tx;
  /// subframe to act upon for reception
  int subframe_rx;
  /// frame to act upon for transmission
  int frame_tx;
  /// frame to act upon for reception
  int frame_rx;
  /// \brief Instance count for RXn-TXnp4 processing thread.
  /// \internal This variable is protected by \ref mutex_rxtx.
  int instance_cnt_rxtx;
  /// pthread structure for RXn-TXnp4 processing thread
  pthread_t pthread_rxtx;
  /// pthread attributes for RXn-TXnp4 processing thread
  pthread_attr_t attr_rxtx;
  /// condition variable for tx processing thread
  pthread_cond_t cond_rxtx;
  /// mutex for RXn-TXnp4 processing thread
  pthread_mutex_t mutex_rxtx;
  /// scheduling parameters for RXn-TXnp4 thread
  struct sched_param sched_param_rxtx;
625 626

  /// internal This variable is protected by ref mutex_fep_slot1.
627 628
  //int instance_cnt_slot0_dl_processing;
  int instance_cnt_slot1_dl_processing;
629
  /// pthread descriptor fep_slot1 thread
630 631
  //pthread_t pthread_slot0_dl_processing;
  pthread_t pthread_slot1_dl_processing;
632
  /// pthread attributes for fep_slot1 processing thread
633 634
 // pthread_attr_t attr_slot0_dl_processing;
  pthread_attr_t attr_slot1_dl_processing;
635
  /// condition variable for UE fep_slot1 thread;
636 637
  //pthread_cond_t cond_slot0_dl_processing;
  pthread_cond_t cond_slot1_dl_processing;
638
  /// mutex for UE synch thread
639 640
  //pthread_mutex_t mutex_slot0_dl_processing;
  pthread_mutex_t mutex_slot1_dl_processing;
641 642
  //
  uint8_t chan_est_pilot0_slot1_available;
643
  uint8_t chan_est_slot1_available;
644 645 646
  uint8_t llr_slot1_available;
  uint8_t dci_slot0_available;
  uint8_t first_symbol_available;
tct-labo4's avatar
tct-labo4 committed
647
  //uint8_t channel_level;
648 649 650
  /// scheduling parameters for fep_slot1 thread
  struct sched_param sched_param_fep_slot1;

laurent's avatar
laurent committed
651 652 653
  int sub_frame_start;
  int sub_frame_step;
  unsigned long long gotIQs;
654 655 656 657 658 659 660 661
} UE_rxtx_proc_t;

/// Context data structure for eNB subframe processing
typedef struct {
  /// Component Carrier index
  uint8_t              CC_id;
  /// Last RX timestamp
  openair0_timestamp timestamp_rx;
Raymond Knopp's avatar
Raymond Knopp committed
662 663 664 665 666 667
  /// pthread attributes for main UE thread
  pthread_attr_t attr_ue;
  /// scheduling parameters for main UE thread
  struct sched_param sched_param_ue;
  /// pthread descriptor main UE thread
  pthread_t pthread_ue;
668 669 670
  /// \brief Instance count for synch thread.
  /// \internal This variable is protected by \ref mutex_synch.
  int instance_cnt_synch;
Raymond Knopp's avatar
Raymond Knopp committed
671
  /// pthread attributes for synch processing thread
672 673 674 675 676 677 678 679 680
  pthread_attr_t attr_synch;
  /// scheduling parameters for synch thread
  struct sched_param sched_param_synch;
  /// pthread descriptor synch thread
  pthread_t pthread_synch;
  /// condition variable for UE synch thread;
  pthread_cond_t cond_synch;
  /// mutex for UE synch thread
  pthread_mutex_t mutex_synch;
681 682
  /// instance count for eNBs
  int instance_cnt_eNBs;
683
  /// set of scheduling variables RXn-TXnp4 threads
684
  UE_rxtx_proc_t proc_rxtx[RX_NB_TH];
685
} UE_proc_t;
686

687 688 689 690 691
typedef enum {
  LOCAL_RF        =0,
  REMOTE_IF5      =1,
  REMOTE_MBP_IF5  =2,
  REMOTE_IF4p5    =3,
oai's avatar
oai committed
692
  REMOTE_IF1pp    =4,
693 694
  MAX_RU_IF_TYPES =5
  //EMULATE_RF      =6
695 696 697 698 699
} RU_if_south_t;

typedef struct RU_t_s{
  /// index of this ru
  uint32_t idx;
700 701
 /// Pointer to configuration file
  char *rf_config_file;
702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778
  /// southbound interface
  RU_if_south_t if_south;
  /// timing
  node_timing_t if_timing;
  /// function
  node_function_t function;
  /// Ethernet parameters for fronthaul interface
  eth_params_t eth_params;
  /// flag to indicate the RU is in synch with a master reference
  int in_synch;
  /// timing offset
  int rx_offset;        
  /// flag to indicate the RU is a slave to another source
  int is_slave;
  /// Total gain of receive chain
  uint32_t             rx_total_gain_dB;
  /// number of bands that this device can support
  int num_bands;
  /// band list
  int band[MAX_BANDS_PER_RRU];
  /// number of RX paths on device
  int nb_rx;
  /// number of TX paths on device
  int nb_tx;
  /// maximum PDSCH RS EPRE
  int max_pdschReferenceSignalPower;
  /// maximum RX gain
  int max_rxgain;
  /// Attenuation of RX paths on device
  int att_rx;
  /// Attenuation of TX paths on device
  int att_tx;
  /// flag to indicate precoding operation in RU
  int do_precoding;
  /// Frame parameters
  LTE_DL_FRAME_PARMS frame_parms;
  ///timing offset used in TDD
  int              N_TA_offset; 
  /// RF device descriptor
  openair0_device rfdevice;
  /// HW configuration
  openair0_config_t openair0_cfg;
  /// Number of eNBs using this RU
  int num_eNB;
  /// list of eNBs using this RU
  struct PHY_VARS_eNB_s *eNB_list[NUMBER_OF_eNB_MAX];
  /// Mapping of antenna ports to RF chain index
  openair0_rf_map      rf_map;
  /// IF device descriptor
  openair0_device ifdevice;
  /// Pointer for ifdevice buffer struct
  if_buffer_t ifbuffer;
  /// if prach processing is to be performed in RU
  int                  do_prach;
  /// function pointer to synchronous RX fronthaul function (RRU,3GPP_eNB)
  void                 (*fh_south_in)(struct RU_t_s *ru,int *frame, int *subframe);
  /// function pointer to synchronous TX fronthaul function
  void                 (*fh_south_out)(struct RU_t_s *ru);
  /// function pointer to synchronous RX fronthaul function (RRU)
  void                 (*fh_north_in)(struct RU_t_s *ru,int *frame, int *subframe);
  /// function pointer to synchronous RX fronthaul function (RRU)
  void                 (*fh_north_out)(struct RU_t_s *ru);
  /// function pointer to asynchronous fronthaul interface
  void                 (*fh_north_asynch_in)(struct RU_t_s *ru,int *frame, int *subframe);
  /// function pointer to asynchronous fronthaul interface
  void                 (*fh_south_asynch_in)(struct RU_t_s *ru,int *frame, int *subframe);
  /// function pointer to initialization function for radio interface
  int                  (*start_rf)(struct RU_t_s *ru);
  /// function pointer to initialization function for radio interface
  int                  (*start_if)(struct RU_t_s *ru,struct PHY_VARS_eNB_s *eNB);
  /// function pointer to RX front-end processing routine (DFTs/prefix removal or NULL)
  void                 (*feprx)(struct RU_t_s *ru);
  /// function pointer to TX front-end processing routine (IDFTs and prefix removal or NULL)
  void                 (*feptx_ofdm)(struct RU_t_s *ru);
  /// function pointer to TX front-end processing routine (PRECODING)
  void                 (*feptx_prec)(struct RU_t_s *ru);
  /// function pointer to wakeup routine in lte-enb.
Raymond Knopp's avatar
Raymond Knopp committed
779
  int (*wakeup_rxtx)(struct PHY_VARS_eNB_s *eNB, struct RU_t_s *ru);
780
  /// function pointer to wakeup routine in lte-enb.
Raymond Knopp's avatar
Raymond Knopp committed
781
  void (*wakeup_prach_eNB)(struct PHY_VARS_eNB_s *eNB,struct RU_t_s *ru,int frame,int subframe);
782
  /// function pointer to wakeup routine in lte-enb.
Raymond Knopp's avatar
Raymond Knopp committed
783
  void (*wakeup_prach_eNB_br)(struct PHY_VARS_eNB_s *eNB,struct RU_t_s *ru,int frame,int subframe);
784
  /// function pointer to eNB entry routine
785
  void (*eNB_top)(struct PHY_VARS_eNB_s *eNB, int frame_rx, int subframe_rx, char *string,struct RU_t_s *ru);
786 787
  /// Timing statistics
  time_stats_t ofdm_demod_stats;
788 789
  /// Timing statistics (TX)
  time_stats_t ofdm_mod_stats;
790 791 792 793 794 795 796 797
  /// Timing wait statistics
  time_stats_t ofdm_demod_wait_stats;
  /// Timing wakeup statistics
  time_stats_t ofdm_demod_wakeup_stats;
  /// Timing wait statistics (TX)
  time_stats_t ofdm_mod_wait_stats;
  /// Timing wakeup statistics (TX)
  time_stats_t ofdm_mod_wakeup_stats;
798 799 800
  /// RX and TX buffers for precoder output
  RU_COMMON            common;
  /// beamforming weight vectors per eNB
Raymond Knopp's avatar
Raymond Knopp committed
801
  int32_t **beam_weights[NUMBER_OF_eNB_MAX+1][15];
802 803 804

  /// received frequency-domain signal for PRACH (IF4p5 RRU) 
  int16_t              **prach_rxsigF;
805 806
  /// received frequency-domain signal for PRACH BR (IF4p5 RRU) 
  int16_t              **prach_rxsigF_br[4];
807 808 809 810 811 812
  /// sequence number for IF5
  uint8_t seqno;
  /// initial timestamp used as an offset make first real timestamp 0
  openair0_timestamp   ts_offset;
  /// process scheduling variables
  RU_proc_t            proc;
813 814
  /// stats thread pthread descriptor
  pthread_t            ru_stats_thread;
815 816 817 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 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 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
} RU_t;


typedef struct {
  //unsigned int   rx_power[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];     //! estimated received signal power (linear)
  //unsigned short rx_power_dB[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];  //! estimated received signal power (dB)
  //unsigned short rx_avg_power_dB[NUMBER_OF_CONNECTED_eNB_MAX];              //! estimated avg received signal power (dB)

  // RRC measurements
  uint32_t rssi;
  int n_adj_cells;
  unsigned int adj_cell_id[6];
  uint32_t rsrq[7];
  uint32_t rsrp[7];
  float rsrp_filtered[7]; // after layer 3 filtering
  float rsrq_filtered[7];
  // common measurements
  //! estimated noise power (linear)
  unsigned int   n0_power[NB_ANTENNAS_RX];
  //! estimated noise power (dB)
  unsigned short n0_power_dB[NB_ANTENNAS_RX];
  //! total estimated noise power (linear)
  unsigned int   n0_power_tot;
  //! total estimated noise power (dB)
  unsigned short n0_power_tot_dB;
  //! average estimated noise power (linear)
  unsigned int   n0_power_avg;
  //! average estimated noise power (dB)
  unsigned short n0_power_avg_dB;
  //! total estimated noise power (dBm)
  short n0_power_tot_dBm;

  // UE measurements
  //! estimated received spatial signal power (linear)
  int            rx_spatial_power[NUMBER_OF_CONNECTED_eNB_MAX][2][2];
  //! estimated received spatial signal power (dB)
  unsigned short rx_spatial_power_dB[NUMBER_OF_CONNECTED_eNB_MAX][2][2];

  /// estimated received signal power (sum over all TX antennas)
  //int            wideband_cqi[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];
  int            rx_power[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];
  /// estimated received signal power (sum over all TX antennas)
  //int            wideband_cqi_dB[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];
  unsigned short rx_power_dB[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];

  /// estimated received signal power (sum over all TX/RX antennas)
  int            rx_power_tot[NUMBER_OF_CONNECTED_eNB_MAX]; //NEW
  /// estimated received signal power (sum over all TX/RX antennas)
  unsigned short rx_power_tot_dB[NUMBER_OF_CONNECTED_eNB_MAX]; //NEW

  //! estimated received signal power (sum of all TX/RX antennas, time average)
  int            rx_power_avg[NUMBER_OF_CONNECTED_eNB_MAX];
  //! estimated received signal power (sum of all TX/RX antennas, time average, in dB)
  unsigned short rx_power_avg_dB[NUMBER_OF_CONNECTED_eNB_MAX];

  /// SINR (sum of all TX/RX antennas, in dB)
  int            wideband_cqi_tot[NUMBER_OF_CONNECTED_eNB_MAX];
  /// SINR (sum of all TX/RX antennas, time average, in dB)
  int            wideband_cqi_avg[NUMBER_OF_CONNECTED_eNB_MAX];

  //! estimated rssi (dBm)
  short          rx_rssi_dBm[NUMBER_OF_CONNECTED_eNB_MAX];
  //! estimated correlation (wideband linear) between spatial channels (computed in dlsch_demodulation)
  int            rx_correlation[NUMBER_OF_CONNECTED_eNB_MAX][2];
  //! estimated correlation (wideband dB) between spatial channels (computed in dlsch_demodulation)
  int            rx_correlation_dB[NUMBER_OF_CONNECTED_eNB_MAX][2];

  /// Wideband CQI (sum of all RX antennas, in dB, for precoded transmission modes (3,4,5,6), up to 4 spatial streams)
  int            precoded_cqi_dB[NUMBER_OF_CONNECTED_eNB_MAX+1][4];
  /// Subband CQI per RX antenna (= SINR)
  int            subband_cqi[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX][NUMBER_OF_SUBBANDS_MAX];
  /// Total Subband CQI  (= SINR)
  int            subband_cqi_tot[NUMBER_OF_CONNECTED_eNB_MAX][NUMBER_OF_SUBBANDS_MAX];
  /// Subband CQI in dB (= SINR dB)
  int            subband_cqi_dB[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX][NUMBER_OF_SUBBANDS_MAX];
  /// Total Subband CQI
  int            subband_cqi_tot_dB[NUMBER_OF_CONNECTED_eNB_MAX][NUMBER_OF_SUBBANDS_MAX];
  /// Wideband PMI for each RX antenna
  int            wideband_pmi_re[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];
  /// Wideband PMI for each RX antenna
  int            wideband_pmi_im[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];
  ///Subband PMI for each RX antenna
  int            subband_pmi_re[NUMBER_OF_CONNECTED_eNB_MAX][NUMBER_OF_SUBBANDS_MAX][NB_ANTENNAS_RX];
  ///Subband PMI for each RX antenna
  int            subband_pmi_im[NUMBER_OF_CONNECTED_eNB_MAX][NUMBER_OF_SUBBANDS_MAX][NB_ANTENNAS_RX];
  /// chosen RX antennas (1=Rx antenna 1, 2=Rx antenna 2, 3=both Rx antennas)
  unsigned char           selected_rx_antennas[NUMBER_OF_CONNECTED_eNB_MAX][NUMBER_OF_SUBBANDS_MAX];
  /// Wideband Rank indication
  unsigned char  rank[NUMBER_OF_CONNECTED_eNB_MAX];
  /// Number of RX Antennas
  unsigned char  nb_antennas_rx;
  /// DLSCH error counter
  // short          dlsch_errors;

} PHY_MEASUREMENTS;

typedef struct {
  //unsigned int   rx_power[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];     //! estimated received signal power (linear)
  //unsigned short rx_power_dB[NUMBER_OF_CONNECTED_eNB_MAX][NB_ANTENNAS_RX];  //! estimated received signal power (dB)
  //unsigned short rx_avg_power_dB[NUMBER_OF_CONNECTED_eNB_MAX];              //! estimated avg received signal power (dB)

  // common measurements
  //! estimated noise power (linear)
  unsigned int   n0_power[MAX_NUM_RU_PER_eNB];
  //! estimated noise power (dB)
  unsigned short n0_power_dB[MAX_NUM_RU_PER_eNB];
  //! total estimated noise power (linear)
  unsigned int   n0_power_tot;
  //! estimated avg noise power (dB)
  unsigned short n0_power_tot_dB;
  //! estimated avg noise power (dB)
  short n0_power_tot_dBm;
  //! estimated avg noise power per RB per RX ant (lin)
  unsigned short n0_subband_power[MAX_NUM_RU_PER_eNB][100];
  //! estimated avg noise power per RB per RX ant (dB)
  unsigned short n0_subband_power_dB[MAX_NUM_RU_PER_eNB][100];
  //! estimated avg noise power per RB (dB)
  short n0_subband_power_tot_dB[100];
  //! estimated avg noise power per RB (dBm)
  short n0_subband_power_tot_dBm[100];
  // eNB measurements (per user)
  //! estimated received spatial signal power (linear)
  unsigned int   rx_spatial_power[NUMBER_OF_UE_MAX][2][2];
  //! estimated received spatial signal power (dB)
  unsigned short rx_spatial_power_dB[NUMBER_OF_UE_MAX][2][2];
  //! estimated rssi (dBm)
  short          rx_rssi_dBm[NUMBER_OF_UE_MAX];
  //! estimated correlation (wideband linear) between spatial channels (computed in dlsch_demodulation)
  int            rx_correlation[NUMBER_OF_UE_MAX][2];
  //! estimated correlation (wideband dB) between spatial channels (computed in dlsch_demodulation)
  int            rx_correlation_dB[NUMBER_OF_UE_MAX][2];

  /// Wideband CQI (= SINR)
  int            wideband_cqi[NUMBER_OF_UE_MAX][MAX_NUM_RU_PER_eNB];
  /// Wideband CQI in dB (= SINR dB)
  int            wideband_cqi_dB[NUMBER_OF_UE_MAX][MAX_NUM_RU_PER_eNB];
  /// Wideband CQI (sum of all RX antennas, in dB)
  char           wideband_cqi_tot[NUMBER_OF_UE_MAX];
  /// Subband CQI per RX antenna and RB (= SINR)
  int            subband_cqi[NUMBER_OF_UE_MAX][MAX_NUM_RU_PER_eNB][100];
  /// Total Subband CQI and RB (= SINR)
  int            subband_cqi_tot[NUMBER_OF_UE_MAX][100];
  /// Subband CQI in dB and RB (= SINR dB)
  int            subband_cqi_dB[NUMBER_OF_UE_MAX][MAX_NUM_RU_PER_eNB][100];
  /// Total Subband CQI and RB
  int            subband_cqi_tot_dB[NUMBER_OF_UE_MAX][100];

} PHY_MEASUREMENTS_eNB;


965
/// Top-level PHY Data Structure for eNB
966
typedef struct PHY_VARS_eNB_s {
967
  /// Module ID indicator for this instance
Raymond Knopp's avatar
 
Raymond Knopp committed
968 969
  module_id_t          Mod_id;
  uint8_t              CC_id;
970
  uint8_t              configured;
971
  eNB_proc_t           proc;
Raymond Knopp's avatar
Raymond Knopp committed
972
  int                  single_thread_flag;
973
  int                  abstraction_flag;
974 975
  int                  num_RU;
  RU_t                 *RU_list[MAX_NUM_RU_PER_eNB];
976 977 978 979
  /// Ethernet parameters for northbound midhaul interface
  eth_params_t         eth_params_n;
  /// Ethernet parameters for fronthaul interface
  eth_params_t         eth_params;
980
  int                  rx_total_gain_dB;
981
  int                  (*td)(struct PHY_VARS_eNB_s *eNB,int UE_id,int harq_pid,int llr8_flag);
982
  int                  (*te)(struct PHY_VARS_eNB_s *,uint8_t *,uint8_t,LTE_eNB_DLSCH_t *,int,uint8_t,time_stats_t *,time_stats_t *,time_stats_t *,time_stats_t *,time_stats_t *,time_stats_t *,time_stats_t *);
983
  int                  (*start_if)(struct RU_t_s *ru,struct PHY_VARS_eNB_s *eNB);
Raymond Knopp's avatar
 
Raymond Knopp committed
984
  uint8_t              local_flag;
985
  LTE_DL_FRAME_PARMS   frame_parms;
986 987 988
  PHY_MEASUREMENTS_eNB measurements;
  IF_Module_t          *if_inst;
  UL_IND_t             UL_INFO;
989
  pthread_mutex_t      UL_INFO_mutex;
990
  /// NFAPI RX ULSCH information
991
  nfapi_rx_indication_pdu_t  rx_pdu_list[NFAPI_RX_IND_MAX_PDU];
992
  /// NFAPI RX ULSCH CRC information
993
  nfapi_crc_indication_pdu_t crc_pdu_list[NFAPI_CRC_IND_MAX_PDU];
994 995 996 997 998 999 1000 1001
  /// NFAPI HARQ information
  nfapi_harq_indication_pdu_t harq_pdu_list[NFAPI_HARQ_IND_MAX_PDU];
  /// NFAPI SR information
  nfapi_sr_indication_pdu_t sr_pdu_list[NFAPI_SR_IND_MAX_PDU];
  /// NFAPI CQI information
  nfapi_cqi_indication_pdu_t cqi_pdu_list[NFAPI_CQI_IND_MAX_PDU];
  /// NFAPI CQI information (raw component)
  nfapi_cqi_indication_raw_pdu_t cqi_raw_pdu_list[NFAPI_CQI_IND_MAX_PDU];
1002 1003 1004 1005 1006 1007
  /// NFAPI PRACH information
  nfapi_preamble_pdu_t preamble_list[MAX_NUM_RX_PRACH_PREAMBLES];
#ifdef Rel14
  /// NFAPI PRACH information BL/CE UEs
  nfapi_preamble_pdu_t preamble_list_br[MAX_NUM_RX_PRACH_PREAMBLES];
#endif
1008 1009
  Sched_Rsp_t          Sched_INFO;
  LTE_eNB_PDCCH        pdcch_vars[2];
1010
  LTE_eNB_PHICH        phich_vars[2];
1011
#ifdef Rel14
1012 1013
  LTE_eNB_EPDCCH       epdcch_vars[2];
  LTE_eNB_MPDCCH       mpdcch_vars[2];
1014 1015
  LTE_eNB_PRACH        prach_vars_br;
#endif
1016
  LTE_eNB_COMMON       common_vars;
1017
  LTE_eNB_UCI          uci_vars[NUMBER_OF_UE_MAX];
1018 1019 1020 1021 1022 1023
  LTE_eNB_SRS          srs_vars[NUMBER_OF_UE_MAX];
  LTE_eNB_PBCH         pbch;
  LTE_eNB_PUSCH       *pusch_vars[NUMBER_OF_UE_MAX];
  LTE_eNB_PRACH        prach_vars;
  LTE_eNB_DLSCH_t     *dlsch[NUMBER_OF_UE_MAX][2];   // Nusers times two spatial streams
  LTE_eNB_ULSCH_t     *ulsch[NUMBER_OF_UE_MAX+1];      // Nusers + number of RA
1024
  LTE_eNB_DLSCH_t     *dlsch_SI,*dlsch_ra,*dlsch_p;
1025 1026 1027
  LTE_eNB_DLSCH_t     *dlsch_MCH;
  LTE_eNB_UE_stats     UE_stats[NUMBER_OF_UE_MAX];
  LTE_eNB_UE_stats    *UE_stats_ptr[NUMBER_OF_UE_MAX];
1028 1029

  /// cell-specific reference symbols
Raymond Knopp's avatar
 
Raymond Knopp committed
1030 1031
  uint32_t         lte_gold_table[20][2][14];

1032
  /// UE-specific reference symbols (p=5), TM 7
1033
  uint32_t         lte_gold_uespec_port5_table[NUMBER_OF_UE_MAX][20][38];
1034

Raymond Knopp's avatar
 
Raymond Knopp committed
1035 1036
  /// UE-specific reference symbols (p=7...14), TM 8/9/10
  uint32_t         lte_gold_uespec_table[2][20][2][21];
1037

1038
  /// mbsfn reference symbols
Raymond Knopp's avatar
 
Raymond Knopp committed
1039
  uint32_t         lte_gold_mbsfn_table[10][3][42];
1040

1041
  uint32_t X_u[64][839];
1042 1043 1044
#ifdef Rel14
  uint32_t X_u_br[4][64][839];
#endif
1045
  uint8_t pbch_configured;
1046
  uint8_t pbch_pdu[4]; //PBCH_PDU_SIZE
1047 1048 1049
  char eNB_generate_rar;

  /// Indicator set to 0 after first SR
1050
  uint8_t first_sr[NUMBER_OF_UE_MAX];
1051

1052
  uint32_t max_peak_val;
1053 1054
  int max_eNB_id, max_sync_pos;

1055 1056
  /// \brief sinr for all subcarriers of the current link (used only for abstraction).
  /// first index: ? [0..N_RB_DL*12[
1057 1058
  double *sinr_dB;

1059
  /// N0 (used for abstraction)
1060 1061 1062 1063 1064
  double N0;

  unsigned char first_run_timing_advance[NUMBER_OF_UE_MAX];
  unsigned char first_run_I0_measurements;

1065
  
1066 1067 1068 1069 1070 1071 1072 1073 1074
  unsigned char    is_secondary_eNB; // primary by default
  unsigned char    is_init_sync;     /// Flag to tell if initial synchronization is performed. This affects how often the secondary eNB will listen to the PSS from the primary system.
  unsigned char    has_valid_precoder; /// Flag to tell if secondary eNB has channel estimates to create NULL-beams from, and this B/F vector is created.
  unsigned char    PeNB_id;          /// id of Primary eNB

  /// hold the precoder for NULL beam to the primary user
  int              **dl_precoder_SeNB[3];
  char             log2_maxp; /// holds the maximum channel/precoder coefficient

1075
  /// if ==0 enables phy only test mode
1076 1077
  int mac_enabled;

1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100


  // PDSCH Varaibles
  PDSCH_CONFIG_DEDICATED pdsch_config_dedicated[NUMBER_OF_UE_MAX];

  // PUSCH Varaibles
  PUSCH_CONFIG_DEDICATED pusch_config_dedicated[NUMBER_OF_UE_MAX];

  // PUCCH variables
  PUCCH_CONFIG_DEDICATED pucch_config_dedicated[NUMBER_OF_UE_MAX];

  // UL-POWER-Control
  UL_POWER_CONTROL_DEDICATED ul_power_control_dedicated[NUMBER_OF_UE_MAX];

  // TPC
  TPC_PDCCH_CONFIG tpc_pdcch_config_pucch[NUMBER_OF_UE_MAX];
  TPC_PDCCH_CONFIG tpc_pdcch_config_pusch[NUMBER_OF_UE_MAX];

  // CQI reporting
  CQI_REPORT_CONFIG cqi_report_config[NUMBER_OF_UE_MAX];

  // SRS Variables
  SOUNDINGRS_UL_CONFIG_DEDICATED soundingrs_ul_config_dedicated[NUMBER_OF_UE_MAX];
1101
  uint8_t ncs_cell[20][7];
1102 1103 1104 1105 1106

  // Scheduling Request Config
  SCHEDULING_REQUEST_CONFIG scheduling_request_config[NUMBER_OF_UE_MAX];

  // Transmission mode per UE
1107
  uint8_t transmission_mode[NUMBER_OF_UE_MAX];
1108 1109 1110

  /// cba_last successful reception for each group, used for collision detection
  uint8_t cba_last_reception[4];
1111

1112 1113 1114
  // Pointers for active physicalConfigDedicated to be applied in current subframe
  struct PhysicalConfigDedicated *physicalConfigDedicated[NUMBER_OF_UE_MAX];

1115

1116 1117
  uint32_t rb_mask_ul[4];

1118 1119 1120 1121
  /// Information regarding TM5
  MU_MIMO_mode mu_mimo_mode[NUMBER_OF_UE_MAX];


1122 1123 1124 1125 1126 1127 1128 1129 1130
  /// target_ue_dl_mcs : only for debug purposes
  uint32_t target_ue_dl_mcs;
  /// target_ue_ul_mcs : only for debug purposes
  uint32_t target_ue_ul_mcs;
  /// target_ue_dl_rballoc : only for debug purposes
  uint32_t ue_dl_rb_alloc;
  /// target ul PRBs : only for debug
  uint32_t ue_ul_nb_rb;

1131
  ///check for Total Transmissions
Raymond Knopp's avatar
 
Raymond Knopp committed
1132
  uint32_t check_for_total_transmissions;
1133 1134

  ///check for MU-MIMO Transmissions
Raymond Knopp's avatar
 
Raymond Knopp committed
1135
  uint32_t check_for_MUMIMO_transmissions;
1136 1137

  ///check for SU-MIMO Transmissions
Raymond Knopp's avatar
 
Raymond Knopp committed
1138
  uint32_t check_for_SUMIMO_transmissions;
1139 1140

  ///check for FULL MU-MIMO Transmissions
Raymond Knopp's avatar
 
Raymond Knopp committed
1141
  uint32_t  FULL_MUMIMO_transmissions;
1142 1143

  /// Counter for total bitrate, bits and throughput in downlink
Raymond Knopp's avatar
 
Raymond Knopp committed
1144 1145 1146
  uint32_t total_dlsch_bitrate;
  uint32_t total_transmitted_bits;
  uint32_t total_system_throughput;
1147

1148
  int hw_timing_advance;
1149

1150 1151 1152 1153
  time_stats_t phy_proc;
  time_stats_t phy_proc_tx;
  time_stats_t phy_proc_rx;
  time_stats_t rx_prach;
1154

1155 1156 1157
  time_stats_t ofdm_mod_stats;
  time_stats_t dlsch_encoding_stats;
  time_stats_t dlsch_modulation_stats;
1158
  time_stats_t dlsch_scrambling_stats;
1159
  time_stats_t dlsch_rate_matching_stats;
1160 1161
  time_stats_t dlsch_turbo_encoding_preperation_stats;
  time_stats_t dlsch_turbo_encoding_segmentation_stats;
1162
  time_stats_t dlsch_turbo_encoding_stats;
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1163
  time_stats_t dlsch_turbo_encoding_waiting_stats;
1164
  time_stats_t dlsch_turbo_encoding_signal_stats;
1165
  time_stats_t dlsch_turbo_encoding_main_stats;
1166 1167
  time_stats_t dlsch_turbo_encoding_wakeup_stats0;
  time_stats_t dlsch_turbo_encoding_wakeup_stats1;
1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186
  time_stats_t dlsch_interleaving_stats;

  time_stats_t rx_dft_stats;
  time_stats_t ulsch_channel_estimation_stats;
  time_stats_t ulsch_freq_offset_estimation_stats;
  time_stats_t ulsch_decoding_stats;
  time_stats_t ulsch_demodulation_stats;
  time_stats_t ulsch_rate_unmatching_stats;
  time_stats_t ulsch_turbo_decoding_stats;
  time_stats_t ulsch_deinterleaving_stats;
  time_stats_t ulsch_demultiplexing_stats;
  time_stats_t ulsch_llr_stats;
  time_stats_t ulsch_tc_init_stats;
  time_stats_t ulsch_tc_alpha_stats;
  time_stats_t ulsch_tc_beta_stats;
  time_stats_t ulsch_tc_gamma_stats;
  time_stats_t ulsch_tc_ext_stats;
  time_stats_t ulsch_tc_intl1_stats;
  time_stats_t ulsch_tc_intl2_stats;
1187

1188 1189 1190
#ifdef LOCALIZATION
  /// time state for localization
  time_stats_t localization_stats;
1191
#endif
1192

1193 1194
  int32_t pucch1_stats_cnt[NUMBER_OF_UE_MAX][10];
  int32_t pucch1_stats[NUMBER_OF_UE_MAX][10*1024];
1195
  int32_t pucch1_stats_thres[NUMBER_OF_UE_MAX][10*1024];
1196
  int32_t pucch1ab_stats_cnt[NUMBER_OF_UE_MAX][10];
1197
  int32_t pucch1ab_stats[NUMBER_OF_UE_MAX][2*10*1024];
1198 1199 1200 1201 1202
  int32_t pusch_stats_rb[NUMBER_OF_UE_MAX][10240];
  int32_t pusch_stats_round[NUMBER_OF_UE_MAX][10240];
  int32_t pusch_stats_mcs[NUMBER_OF_UE_MAX][10240];
  int32_t pusch_stats_bsr[NUMBER_OF_UE_MAX][10240];
  int32_t pusch_stats_BO[NUMBER_OF_UE_MAX][10240];
1203 1204 1205
} PHY_VARS_eNB;

#define debug_msg if (((mac_xface->frame%100) == 0) || (mac_xface->frame < 50)) msg
1206

1207 1208
/// Top-level PHY Data Structure for UE
typedef struct {
Raymond Knopp's avatar
 
Raymond Knopp committed
1209
  /// \brief Module ID indicator for this instance
1210
  uint8_t Mod_id;
Raymond Knopp's avatar
 
Raymond Knopp committed
1211
  /// \brief Component carrier ID for this PHY instance
Raymond Knopp's avatar
 
Raymond Knopp committed
1212
  uint8_t CC_id;
1213 1214
  /// \brief Mapping of CC_id antennas to cards
  openair0_rf_map      rf_map;
Raymond Knopp's avatar
 
Raymond Knopp committed
1215 1216 1217 1218 1219
  //uint8_t local_flag;
  /// \brief Indicator of current run mode of UE (normal_txrx, rx_calib_ue, no_L2_connect, debug_prach)
  runmode_t mode;
  /// \brief Indicator that UE should perform band scanning
  int UE_scan;
1220 1221
  /// \brief Indicator that UE should perform coarse scanning around carrier
  int UE_scan_carrier;
Raymond Knopp's avatar
 
Raymond Knopp committed
1222
  /// \brief Indicator that UE is synchronized to an eNB
1223
  int is_synchronized;
1224 1225
  /// Data structure for UE process scheduling
  UE_proc_t proc;
1226 1227
  /// Flag to indicate the UE shouldn't do timing correction at all
  int no_timing_correction;
Raymond Knopp's avatar
 
Raymond Knopp committed
1228
  /// \brief Total gain of the TX chain (16-bit baseband I/Q to antenna)
Raymond Knopp's avatar
 
Raymond Knopp committed
1229
  uint32_t tx_total_gain_dB;
Raymond Knopp's avatar
 
Raymond Knopp committed
1230
  /// \brief Total gain of the RX chain (antenna to baseband I/Q) This is a function of rx_gain_mode (and the corresponding gain) and the rx_gain of the card.
1231
  uint32_t rx_total_gain_dB;
Raymond Knopp's avatar
 
Raymond Knopp committed
1232
  /// \brief Total gains with maximum RF gain stage (ExpressMIMO2/Lime)
Raymond Knopp's avatar
 
Raymond Knopp committed
1233
  uint32_t rx_gain_max[4];
Raymond Knopp's avatar
 
Raymond Knopp committed
1234
  /// \brief Total gains with medium RF gain stage (ExpressMIMO2/Lime)
Raymond Knopp's avatar
 
Raymond Knopp committed
1235
  uint32_t rx_gain_med[4];
Raymond Knopp's avatar
 
Raymond Knopp committed
1236
  /// \brief Total gains with bypassed RF gain stage (ExpressMIMO2/Lime)
Raymond Knopp's avatar
 
Raymond Knopp committed
1237
  uint32_t rx_gain_byp[4];
Raymond Knopp's avatar
 
Raymond Knopp committed
1238
  /// \brief Current transmit power
1239
  int16_t tx_power_dBm[10];
Raymond Knopp's avatar
 
Raymond Knopp committed
1240
  /// \brief Total number of REs in current transmission
1241
  int tx_total_RE[10];
Raymond Knopp's avatar
 
Raymond Knopp committed
1242
  /// \brief Maximum transmit power
1243
  int8_t tx_power_max_dBm;
Raymond Knopp's avatar
 
Raymond Knopp committed
1244
  /// \brief Number of eNB seen by UE
1245
  uint8_t n_connected_eNB;
Raymond Knopp's avatar
 
Raymond Knopp committed
1246
  /// \brief indicator that Handover procedure has been initiated
1247
  uint8_t ho_initiated;
Raymond Knopp's avatar
 
Raymond Knopp committed
1248
  /// \brief indicator that Handover procedure has been triggered
1249
  uint8_t ho_triggered;
1250
  /// \brief Measurement variables.
1251 1252
  PHY_MEASUREMENTS measurements;
  LTE_DL_FRAME_PARMS  frame_parms;
1253
  /// \brief Frame parame before ho used to recover if ho fails.
1254 1255 1256
  LTE_DL_FRAME_PARMS  frame_parms_before_ho;
  LTE_UE_COMMON    common_vars;

1257 1258 1259
  // point to the current rxTx thread index
  uint8_t current_thread_id[10];

1260
  LTE_UE_PDSCH     *pdsch_vars[RX_NB_TH_MAX][NUMBER_OF_CONNECTED_eNB_MAX+1]; // two RxTx Threads
1261 1262 1263
  LTE_UE_PDSCH_FLP *pdsch_vars_flp[NUMBER_OF_CONNECTED_eNB_MAX+1];
  LTE_UE_PDSCH     *pdsch_vars_SI[NUMBER_OF_CONNECTED_eNB_MAX+1];
  LTE_UE_PDSCH     *pdsch_vars_ra[NUMBER_OF_CONNECTED_eNB_MAX+1];
1264
  LTE_UE_PDSCH     *pdsch_vars_p[NUMBER_OF_CONNECTED_eNB_MAX+1];
1265 1266
  LTE_UE_PDSCH     *pdsch_vars_MCH[NUMBER_OF_CONNECTED_eNB_MAX];
  LTE_UE_PBCH      *pbch_vars[NUMBER_OF_CONNECTED_eNB_MAX];
1267
  LTE_UE_PDCCH     *pdcch_vars[RX_NB_TH_MAX][NUMBER_OF_CONNECTED_eNB_MAX];
1268
  LTE_UE_PRACH     *prach_vars[NUMBER_OF_CONNECTED_eNB_MAX];
1269
  LTE_UE_DLSCH_t   *dlsch[RX_NB_TH_MAX][NUMBER_OF_CONNECTED_eNB_MAX][2]; // two RxTx Threads
1270
  LTE_UE_ULSCH_t   *ulsch[NUMBER_OF_CONNECTED_eNB_MAX];
1271 1272 1273
  LTE_UE_DLSCH_t   *dlsch_SI[NUMBER_OF_CONNECTED_eNB_MAX];
  LTE_UE_DLSCH_t   *dlsch_ra[NUMBER_OF_CONNECTED_eNB_MAX];
  LTE_UE_DLSCH_t   *dlsch_p[NUMBER_OF_CONNECTED_eNB_MAX];
1274
  LTE_UE_DLSCH_t   *dlsch_MCH[NUMBER_OF_CONNECTED_eNB_MAX];
Raymond Knopp's avatar
Raymond Knopp committed
1275 1276 1277
  // This is for SIC in the UE, to store the reencoded data
  LTE_eNB_DLSCH_t  *dlsch_eNB[NUMBER_OF_CONNECTED_eNB_MAX];

1278 1279 1280 1281 1282
  //Paging parameters
  uint32_t              IMSImod1024;
  uint32_t              PF;
  uint32_t              PO;

1283
  // For abstraction-purposes only
1284 1285 1286
  uint8_t               sr[10];
  uint8_t               pucch_sel[10];
  uint8_t               pucch_payload[22];
1287 1288 1289

  UE_MODE_t        UE_mode[NUMBER_OF_CONNECTED_eNB_MAX];
  /// cell-specific reference symbols
Raymond Knopp's avatar
 
Raymond Knopp committed
1290 1291
  uint32_t lte_gold_table[7][20][2][14];

1292
  /// UE-specific reference symbols (p=5), TM 7
1293
  uint32_t lte_gold_uespec_port5_table[20][38];
1294

Raymond Knopp's avatar
 
Raymond Knopp committed
1295
  /// ue-specific reference symbols
1296
  uint32_t lte_gold_uespec_table[2][20][2][21];
1297

Raymond Knopp's avatar
 
Raymond Knopp committed
1298 1299
  /// mbsfn reference symbols
  uint32_t lte_gold_mbsfn_table[10][3][42];
1300

1301
  uint32_t X_u[64][839];
1302

1303
  uint32_t high_speed_flag;
Raymond Knopp's avatar
 
Raymond Knopp committed
1304
  uint32_t perfect_ce;
1305
  int16_t ch_est_alpha;
1306 1307
  int generate_ul_signal[NUMBER_OF_CONNECTED_eNB_MAX];

1308
  UE_SCAN_INFO_t scan_info[NB_BANDS_MAX];
1309

1310 1311
  char ulsch_no_allocation_counter[NUMBER_OF_CONNECTED_eNB_MAX];

1312 1313


1314 1315 1316
  unsigned char ulsch_Msg3_active[NUMBER_OF_CONNECTED_eNB_MAX];
  uint32_t  ulsch_Msg3_frame[NUMBER_OF_CONNECTED_eNB_MAX];
  unsigned char ulsch_Msg3_subframe[NUMBER_OF_CONNECTED_eNB_MAX];
1317 1318
  PRACH_RESOURCES_t *prach_resources[NUMBER_OF_CONNECTED_eNB_MAX];
  int turbo_iterations, turbo_cntl_iterations;
1319 1320
  /// \brief ?.
  /// - first index: eNB [0..NUMBER_OF_CONNECTED_eNB_MAX[ (hard coded)
Raymond Knopp's avatar
 
Raymond Knopp committed
1321
  uint32_t total_TBS[NUMBER_OF_CONNECTED_eNB_MAX];
1322 1323
  /// \brief ?.
  /// - first index: eNB [0..NUMBER_OF_CONNECTED_eNB_MAX[ (hard coded)
Raymond Knopp's avatar
 
Raymond Knopp committed
1324
  uint32_t total_TBS_last[NUMBER_OF_CONNECTED_eNB_MAX];
1325 1326
  /// \brief ?.
  /// - first index: eNB [0..NUMBER_OF_CONNECTED_eNB_MAX[ (hard coded)
Raymond Knopp's avatar
 
Raymond Knopp committed
1327
  uint32_t bitrate[NUMBER_OF_CONNECTED_eNB_MAX];
1328 1329
  /// \brief ?.
  /// - first index: eNB [0..NUMBER_OF_CONNECTED_eNB_MAX[ (hard coded)
Raymond Knopp's avatar
 
Raymond Knopp committed
1330
  uint32_t total_received_bits[NUMBER_OF_CONNECTED_eNB_MAX];
1331 1332 1333 1334 1335 1336 1337 1338 1339
  int dlsch_errors[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_errors_last[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_received[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_received_last[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_fer[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_SI_received[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_SI_errors[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_ra_received[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_ra_errors[NUMBER_OF_CONNECTED_eNB_MAX];
1340 1341
  int dlsch_p_received[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_p_errors[NUMBER_OF_CONNECTED_eNB_MAX];
1342 1343 1344 1345 1346 1347 1348 1349
  int dlsch_mch_received_sf[MAX_MBSFN_AREA][NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_mch_received[NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_mcch_received[MAX_MBSFN_AREA][NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_mtch_received[MAX_MBSFN_AREA][NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_mcch_errors[MAX_MBSFN_AREA][NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_mtch_errors[MAX_MBSFN_AREA][NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_mcch_trials[MAX_MBSFN_AREA][NUMBER_OF_CONNECTED_eNB_MAX];
  int dlsch_mtch_trials[MAX_MBSFN_AREA][NUMBER_OF_CONNECTED_eNB_MAX];
1350 1351
  int current_dlsch_cqi[NUMBER_OF_CONNECTED_eNB_MAX];
  unsigned char first_run_timing_advance[NUMBER_OF_CONNECTED_eNB_MAX];
1352 1353 1354 1355
  uint8_t               generate_prach;
  uint8_t               prach_cnt;
  uint8_t               prach_PreambleIndex;
  //  uint8_t               prach_timer;
1356 1357
  uint8_t               decode_SIB;
  uint8_t               decode_MIB;
1358
  int              rx_offset; /// Timing offset
1359
  int              rx_offset_diff; /// Timing adjustment for ofdm symbol0 on HW USRP
1360
  int              time_sync_cell;
1361
  int              timing_advance; ///timing advance signalled from eNB
1362
  int              hw_timing_advance;
1363
  int              N_TA_offset; ///timing offset used in TDD
1364
  /// Flag to tell if UE is secondary user (cognitive mode)
1365
  unsigned char    is_secondary_ue;
1366
  /// Flag to tell if secondary eNB has channel estimates to create NULL-beams from.
1367
  unsigned char    has_valid_precoder;
1368 1369 1370
  /// hold the precoder for NULL beam to the primary eNB
  int              **ul_precoder_S_UE;
  /// holds the maximum channel/precoder coefficient
1371
  char             log2_maxp;
1372

1373 1374 1375
  /// if ==0 enables phy only test mode
  int mac_enabled;

1376
  /// Flag to initialize averaging of PHY measurements
1377
  int init_averaging;
1378

1379 1380
  /// \brief sinr for all subcarriers of the current link (used only for abstraction).
  /// - first index: ? [0..12*N_RB_DL[
1381
  double *sinr_dB;
1382

1383 1384
  /// \brief sinr for all subcarriers of first symbol for the CQI Calculation.
  /// - first index: ? [0..12*N_RB_DL[
1385 1386
  double *sinr_CQI_dB;

1387 1388 1389
  /// sinr_effective used for CQI calulcation
  double sinr_eff;

1390 1391
  /// N0 (used for abstraction)
  double N0;
1392

1393 1394 1395 1396 1397
  /// PDSCH Varaibles
  PDSCH_CONFIG_DEDICATED pdsch_config_dedicated[NUMBER_OF_CONNECTED_eNB_MAX];

  /// PUSCH Varaibles
  PUSCH_CONFIG_DEDICATED pusch_config_dedicated[NUMBER_OF_CONNECTED_eNB_MAX];
1398

1399 1400 1401 1402 1403 1404 1405
  /// PUSCH contention-based access vars
  PUSCH_CA_CONFIG_DEDICATED  pusch_ca_config_dedicated[NUMBER_OF_eNB_MAX]; // lola

  /// PUCCH variables

  PUCCH_CONFIG_DEDICATED pucch_config_dedicated[NUMBER_OF_CONNECTED_eNB_MAX];

1406
  uint8_t ncs_cell[20][7];
1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424

  /// UL-POWER-Control
  UL_POWER_CONTROL_DEDICATED ul_power_control_dedicated[NUMBER_OF_CONNECTED_eNB_MAX];

  /// TPC
  TPC_PDCCH_CONFIG tpc_pdcch_config_pucch[NUMBER_OF_CONNECTED_eNB_MAX];
  TPC_PDCCH_CONFIG tpc_pdcch_config_pusch[NUMBER_OF_CONNECTED_eNB_MAX];

  /// CQI reporting
  CQI_REPORT_CONFIG cqi_report_config[NUMBER_OF_CONNECTED_eNB_MAX];

  /// SRS Variables
  SOUNDINGRS_UL_CONFIG_DEDICATED soundingrs_ul_config_dedicated[NUMBER_OF_CONNECTED_eNB_MAX];

  /// Scheduling Request Config
  SCHEDULING_REQUEST_CONFIG scheduling_request_config[NUMBER_OF_CONNECTED_eNB_MAX];

  /// Transmission mode per eNB
1425
  uint8_t transmission_mode[NUMBER_OF_CONNECTED_eNB_MAX];
1426

1427
  time_stats_t phy_proc[RX_NB_TH];
1428
  time_stats_t phy_proc_tx;
1429
  time_stats_t phy_proc_rx[RX_NB_TH];
1430

1431 1432
  uint32_t use_ia_receiver;

1433 1434 1435 1436 1437 1438 1439 1440 1441
  time_stats_t ofdm_mod_stats;
  time_stats_t ulsch_encoding_stats;
  time_stats_t ulsch_modulation_stats;
  time_stats_t ulsch_segmentation_stats;
  time_stats_t ulsch_rate_matching_stats;
  time_stats_t ulsch_turbo_encoding_stats;
  time_stats_t ulsch_interleaving_stats;
  time_stats_t ulsch_multiplexing_stats;

hbilel's avatar
hbilel committed
1442
  time_stats_t generic_stat;
1443
  time_stats_t generic_stat_bis[RX_NB_TH][LTE_SLOTS_PER_SUBFRAME];
1444 1445 1446 1447 1448 1449
  time_stats_t ue_front_end_stat[RX_NB_TH];
  time_stats_t ue_front_end_per_slot_stat[RX_NB_TH][LTE_SLOTS_PER_SUBFRAME];
  time_stats_t pdcch_procedures_stat[RX_NB_TH];
  time_stats_t pdsch_procedures_stat[RX_NB_TH];
  time_stats_t pdsch_procedures_per_slot_stat[RX_NB_TH][LTE_SLOTS_PER_SUBFRAME];
  time_stats_t dlsch_procedures_stat[RX_NB_TH];
hbilel's avatar
hbilel committed
1450

1451
  time_stats_t ofdm_demod_stats;
1452
  time_stats_t dlsch_rx_pdcch_stats;
1453 1454 1455
  time_stats_t rx_dft_stats;
  time_stats_t dlsch_channel_estimation_stats;
  time_stats_t dlsch_freq_offset_estimation_stats;
1456
  time_stats_t dlsch_decoding_stats[2];
1457 1458 1459 1460 1461
  time_stats_t dlsch_demodulation_stats;
  time_stats_t dlsch_rate_unmatching_stats;
  time_stats_t dlsch_turbo_decoding_stats;
  time_stats_t dlsch_deinterleaving_stats;
  time_stats_t dlsch_llr_stats;
tct-labo4's avatar
tct-labo4 committed
1462
  time_stats_t dlsch_llr_stats_parallelization[RX_NB_TH][LTE_SLOTS_PER_SUBFRAME];
1463
  time_stats_t dlsch_unscrambling_stats;
Raymond Knopp's avatar
Raymond Knopp committed
1464 1465 1466
  time_stats_t dlsch_rate_matching_stats;
  time_stats_t dlsch_turbo_encoding_stats;
  time_stats_t dlsch_interleaving_stats;
1467 1468 1469 1470 1471 1472 1473
  time_stats_t dlsch_tc_init_stats;
  time_stats_t dlsch_tc_alpha_stats;
  time_stats_t dlsch_tc_beta_stats;
  time_stats_t dlsch_tc_gamma_stats;
  time_stats_t dlsch_tc_ext_stats;
  time_stats_t dlsch_tc_intl1_stats;
  time_stats_t dlsch_tc_intl2_stats;
1474
  time_stats_t tx_prach;
1475

Raymond Knopp's avatar
Raymond Knopp committed
1476 1477 1478
  /// RF and Interface devices per CC

  openair0_device rfdevice; 
1479 1480
} PHY_VARS_UE;

1481 1482 1483 1484 1485 1486 1487
/* this structure is used to pass both UE phy vars and
 * proc to the function UE_thread_rxn_txnp4
 */
struct rx_tx_thread_data {
  PHY_VARS_UE    *UE;
  UE_rxtx_proc_t *proc;
};
1488

1489 1490
void exit_fun(const char* s);

1491 1492 1493 1494 1495
#include "UTIL/LOG/log_extern.h"
extern pthread_cond_t sync_cond;
extern pthread_mutex_t sync_mutex;
extern int sync_var;

1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543
#define MAX_RRU_CONFIG_SIZE 1024
typedef enum {
  RAU_tick=0,
  RRU_capabilities=1,
  RRU_config=2,
  RRU_MSG_max_num=3
} rru_config_msg_type_t;

typedef struct RRU_CONFIG_msg_s {
  rru_config_msg_type_t type;
  ssize_t len;
  uint8_t msg[MAX_RRU_CONFIG_SIZE];
} RRU_CONFIG_msg_t;

typedef enum {
  OAI_IF5_only      =0,
  OAI_IF4p5_only    =1,
  OAI_IF5_and_IF4p5 =2,
  MBP_IF5           =3,
  MAX_FH_FMTs       =4
} FH_fmt_options_t;

#define MAX_BANDS_PER_RRU 4

typedef struct RRU_capabilities_s {
  /// Fronthaul format
  FH_fmt_options_t FH_fmt;
  /// number of EUTRA bands (<=4) supported by RRU
  uint8_t          num_bands;
  /// EUTRA band list supported by RRU
  uint8_t          band_list[MAX_BANDS_PER_RRU];
  /// Number of concurrent bands (component carriers)
  uint8_t          num_concurrent_bands;
  /// Maximum TX EPRE of each band
  int8_t           max_pdschReferenceSignalPower[MAX_BANDS_PER_RRU];
  /// Maximum RX gain of each band
  uint8_t          max_rxgain[MAX_BANDS_PER_RRU];
  /// Number of RX ports of each band
  uint8_t          nb_rx[MAX_BANDS_PER_RRU];
  /// Number of TX ports of each band
  uint8_t          nb_tx[MAX_BANDS_PER_RRU]; 
  /// max DL bandwidth (1,6,15,25,50,75,100)
  uint8_t          N_RB_DL[MAX_BANDS_PER_RRU];
  /// max UL bandwidth (1,6,15,25,50,75,100)
  uint8_t          N_RB_UL[MAX_BANDS_PER_RRU];
} RRU_capabilities_t;

typedef struct RRU_config_s {
1544

1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568
  /// Fronthaul format
  RU_if_south_t FH_fmt;
  /// number of EUTRA bands (<=4) configured in RRU
  uint8_t num_bands;
  /// EUTRA band list configured in RRU
  uint8_t band_list[MAX_BANDS_PER_RRU];
  /// TX frequency
  uint32_t tx_freq[MAX_BANDS_PER_RRU];
  /// RX frequency
  uint32_t rx_freq[MAX_BANDS_PER_RRU];
  /// TX attenation w.r.t. max
  uint8_t att_tx[MAX_BANDS_PER_RRU];
  /// RX attenuation w.r.t. max
  uint8_t att_rx[MAX_BANDS_PER_RRU];
  /// DL bandwidth
  uint8_t N_RB_DL[MAX_BANDS_PER_RRU];
  /// UL bandwidth
  uint8_t N_RB_UL[MAX_BANDS_PER_RRU];
  /// 3/4 sampling rate
  uint8_t threequarter_fs[MAX_BANDS_PER_RRU];
  /// prach_FreqOffset for IF4p5
  int prach_FreqOffset[MAX_BANDS_PER_RRU];
  /// prach_ConfigIndex for IF4p5
  int prach_ConfigIndex[MAX_BANDS_PER_RRU];
1569 1570 1571 1572 1573 1574 1575
#ifdef Rel14
  int emtc_prach_CElevel_enable[MAX_BANDS_PER_RRU][4];
  /// emtc_prach_FreqOffset for IF4p5 per CE Level
  int emtc_prach_FreqOffset[MAX_BANDS_PER_RRU][4];
  /// emtc_prach_ConfigIndex for IF4p5 per CE Level
  int emtc_prach_ConfigIndex[MAX_BANDS_PER_RRU][4];
#endif
1576
} RRU_config_t;
1577 1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592


static inline void wait_sync(char *thread_name) {

  printf( "waiting for sync (%s)\n",thread_name);
  pthread_mutex_lock( &sync_mutex );
  
  while (sync_var<0)
    pthread_cond_wait( &sync_cond, &sync_mutex );
  
  pthread_mutex_unlock(&sync_mutex);
  
  printf( "got sync (%s)\n", thread_name);

}

1593
static inline int wait_on_condition(pthread_mutex_t *mutex,pthread_cond_t *cond,int *instance_cnt,char *name) {
1594 1595 1596 1597 1598
  if (pthread_mutex_lock(mutex) != 0) {
    LOG_E( PHY, "[SCHED][eNB] error locking mutex for %s\n",name);
    exit_fun("nothing to add");
    return(-1);
  }
1599

1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613
  while (*instance_cnt < 0) {
    // most of the time the thread is waiting here
    // proc->instance_cnt_rxtx is -1
    pthread_cond_wait(cond,mutex); // this unlocks mutex_rxtx while waiting and then locks it again
  }

  if (pthread_mutex_unlock(mutex) != 0) {
    LOG_E(PHY,"[SCHED][eNB] error unlocking mutex for %s\n",name);
    exit_fun("nothing to add");
    return(-1);
  }
  return(0);
}

1614
static inline int wait_on_busy_condition(pthread_mutex_t *mutex,pthread_cond_t *cond,int *instance_cnt,char *name) {
1615 1616 1617 1618 1619 1620

  if (pthread_mutex_lock(mutex) != 0) {
    LOG_E( PHY, "[SCHED][eNB] error locking mutex for %s\n",name);
    exit_fun("nothing to add");
    return(-1);
  }
1621

1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634 1635
  while (*instance_cnt == 0) {
    // most of the time the thread will skip this
    // waits only if proc->instance_cnt_rxtx is 0
    pthread_cond_wait(cond,mutex); // this unlocks mutex_rxtx while waiting and then locks it again
  }

  if (pthread_mutex_unlock(mutex) != 0) {
    LOG_E(PHY,"[SCHED][eNB] error unlocking mutex for %s\n",name);
    exit_fun("nothing to add");
    return(-1);
  }
  return(0);
}

1636
static inline int release_thread(pthread_mutex_t *mutex,int *instance_cnt,char *name) {
1637 1638 1639 1640 1641 1642

  if (pthread_mutex_lock(mutex) != 0) {
    LOG_E( PHY, "[SCHED][eNB] error locking mutex for %s\n",name);
    exit_fun("nothing to add");
    return(-1);
  }
1643

1644
  *instance_cnt=*instance_cnt-1;
1645

1646 1647 1648 1649 1650 1651 1652
  if (pthread_mutex_unlock(mutex) != 0) {
    LOG_E( PHY, "[SCHED][eNB] error unlocking mutex for %s\n",name);
    exit_fun("nothing to add");
    return(-1);
  }
  return(0);
}
1653

1654 1655 1656 1657 1658 1659 1660 1661 1662

#include "PHY/INIT/defs.h"
#include "PHY/LTE_REFSIG/defs.h"
#include "PHY/MODULATION/defs.h"
#include "PHY/LTE_TRANSPORT/proto.h"
#include "PHY/LTE_ESTIMATION/defs.h"

#include "SIMULATION/ETH_TRANSPORT/defs.h"
#endif //  __PHY_DEFS__H__