lte-enb.c 51.7 KB
Newer Older
1 2 3 4 5
/*
 * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The OpenAirInterface Software Alliance licenses this file to You under
6
 * the OAI Public License, Version 1.1  (the "License"); you may not use this file
7 8 9 10 11 12 13 14 15 16 17 18 19 20
 * 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
 */
ISIP CS/NCTU's avatar
ISIP CS/NCTU committed
32 33 34 35 36 37 38 39 40 41 42 43
 
/*! \function wakeup_txfh
 * \brief Implementation of creating multiple RU threads for beamforming emulation
 * \author TH Wang(Judy), TY Hsu, SY Yeh(fdragon)
 * \date 2018
 * \version 0.1
 * \company Eurecom and ISIP@NCTU
 * \email: Tsu-Han.Wang@eurecom.fr,tyhsu@cs.nctu.edu.tw,fdragon.cs96g@g2.nctu.edu.tw
 * \note
 * \warning
 */

44

Raymond Knopp's avatar
Raymond Knopp committed
45 46
#define _GNU_SOURCE
#include <pthread.h>
47

48

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

51 52
#include "rt_wrapper.h"

53
#include "assertions.h"
54

55 56 57

#include "PHY/types.h"

58 59 60 61 62
#include "PHY/INIT/phy_init.h"

#include "PHY/defs_eNB.h"
#include "SCHED/sched_eNB.h"
#include "PHY/LTE_TRANSPORT/transport_proto.h"
frtabu's avatar
frtabu committed
63
#include "nfapi/oai_integration/vendor_ext.h"
64 65 66 67 68 69 70
#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

71
#include "PHY/LTE_TRANSPORT/if4_tools.h"
72
#include "PHY/LTE_TRANSPORT/if5_tools.h"
73

74 75 76 77 78 79 80 81
#include "PHY/phy_extern.h"


#include "LAYER2/MAC/mac.h"
#include "LAYER2/MAC/mac_extern.h"
#include "LAYER2/MAC/mac_proto.h"
#include "RRC/LTE/rrc_extern.h"
#include "PHY_INTERFACE/phy_interface.h"
82
#include "common/utils/LOG/log.h"
83 84 85
#include "UTIL/OTG/otg_tx.h"
#include "UTIL/OTG/otg_externs.h"
#include "UTIL/MATH/oml.h"
86
#include "common/utils/LOG/vcd_signal_dumper.h"
87 88
#include "UTIL/OPT/opt.h"
#include "enb_config.h"
89

90 91

#ifndef OPENAIR2
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
92
  #include "UTIL/OTG/otg_extern.h"
93 94
#endif

95 96
#include "s1ap_eNB.h"
#include "SIMULATION/ETH_TRANSPORT/proto.h"
97

Rohit Gupta's avatar
Rohit Gupta committed
98 99
#include "T.h"

100 101 102 103 104 105 106 107 108 109
//#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;

110 111
// Fix per CC openair rf/if device update
// extern openair0_device openair0;
112 113 114

extern volatile int                    oai_exit;

Cedric Roux's avatar
Cedric Roux committed
115
extern int transmission_mode;
116

117 118
extern int oaisim_flag;

119 120 121
//uint16_t sf_ahead=4;
extern uint16_t sf_ahead;

122

123
//pthread_t                       main_eNB_thread;
124 125 126

time_stats_t softmodem_stats_mt; // main thread
time_stats_t softmodem_stats_hw; //  hw acquisition
127
time_stats_t softmodem_stats_rxtx_sf; // total tx time
128
time_stats_t nfapi_meas; // total tx time
129
time_stats_t softmodem_stats_rx_sf; // total rx time
130 131 132 133 134 135 136 137 138

/* 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;
139
} sync_phy_proc;
140

141 142
extern double cpuf;

143

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

147 148
int wakeup_tx(PHY_VARS_eNB *eNB ,int frame_rx,int subframe_rx,int frame_tx,int subframe_tx,uint64_t timestamp_tx);
int wakeup_txfh(PHY_VARS_eNB *eNB, L1_rxtx_proc_t *proc,int frame_tx,int subframe_tx,uint64_t timestamp_tx);
149
void wakeup_prach_eNB(PHY_VARS_eNB *eNB,RU_t *ru,int frame,int subframe);
150
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
151
  void wakeup_prach_eNB_br(PHY_VARS_eNB *eNB,RU_t *ru,int frame,int subframe);
152
#endif
153

frtabu's avatar
frtabu committed
154

155 156 157 158 159 160 161
extern void oai_subframe_ind(uint16_t sfn, uint16_t sf);
extern void add_subframe(uint16_t *frameP, uint16_t *subframeP, int offset);

//#define TICK_TO_US(ts) (ts.diff)
#define TICK_TO_US(ts) (ts.trials==0?0:ts.diff/ts.trials)


162
static inline int rxtx(PHY_VARS_eNB *eNB,L1_rxtx_proc_t *proc, char *thread_name) {
163
  int ret;
Raymond Knopp's avatar
Raymond Knopp committed
164
  start_meas(&softmodem_stats_rxtx_sf);
165

166
  //L1_rxtx_proc_t *L1_proc_tx = &eNB->proc.L1_proc_tx;
167
  // *******************************************************************
168
#if defined(PRE_SCD_THREAD)
169
  RU_t *ru = RC.ru[0];
170
#endif
171

172
  if (eNB ==NULL) {
173 174
    LOG_D(PHY,"%s:%d: rxtx invalid argument, eNB pointer is NULL",__FILE__,__LINE__);
    return -1;
175
  }
176

frtabu's avatar
frtabu committed
177
  if (NFAPI_MODE==NFAPI_MODE_PNF) {
178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193
    // I am a PNF and I need to let nFAPI know that we have a (sub)frame tick
    uint16_t frame = proc->frame_rx;
    uint16_t subframe = proc->subframe_rx;
    //add_subframe(&frame, &subframe, 4);
    //oai_subframe_ind(proc->frame_tx, proc->subframe_tx);
    //LOG_D(PHY, "oai_subframe_ind(frame:%u, subframe:%d) - NOT CALLED ********\n", frame, subframe);
    start_meas(&nfapi_meas);
    oai_subframe_ind(frame, subframe);
    stop_meas(&nfapi_meas);

    if (eNB->UL_INFO.rx_ind.rx_indication_body.number_of_pdus||
        eNB->UL_INFO.harq_ind.harq_indication_body.number_of_harqs ||
        eNB->UL_INFO.crc_ind.crc_indication_body.number_of_crcs ||
        eNB->UL_INFO.rach_ind.rach_indication_body.number_of_preambles ||
        eNB->UL_INFO.cqi_ind.number_of_cqis
       ) {
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
194 195 196 197 198 199 200 201
      LOG_D(PHY, "UL_info[rx_ind:%05d:%d harqs:%05d:%d crcs:%05d:%d preambles:%05d:%d cqis:%d] RX:%04d%d TX:%04d%d num_pdcch_symbols:%d\n",
            NFAPI_SFNSF2DEC(eNB->UL_INFO.rx_ind.sfn_sf),   eNB->UL_INFO.rx_ind.rx_indication_body.number_of_pdus,
            NFAPI_SFNSF2DEC(eNB->UL_INFO.harq_ind.sfn_sf), eNB->UL_INFO.harq_ind.harq_indication_body.number_of_harqs,
            NFAPI_SFNSF2DEC(eNB->UL_INFO.crc_ind.sfn_sf),  eNB->UL_INFO.crc_ind.crc_indication_body.number_of_crcs,
            NFAPI_SFNSF2DEC(eNB->UL_INFO.rach_ind.sfn_sf), eNB->UL_INFO.rach_ind.rach_indication_body.number_of_preambles,
            eNB->UL_INFO.cqi_ind.number_of_cqis,
            proc->frame_rx, proc->subframe_rx,
            proc->frame_tx, proc->subframe_tx, eNB->pdcch_vars[proc->subframe_tx&1].num_pdcch_symbols);
202 203 204
    }
  }

frtabu's avatar
frtabu committed
205
  if (NFAPI_MODE==NFAPI_MODE_PNF && eNB->pdcch_vars[proc->subframe_tx&1].num_pdcch_symbols == 0) {
206 207 208 209
    LOG_E(PHY, "eNB->pdcch_vars[proc->subframe_tx&1].num_pdcch_symbols == 0");
    return 0;
  }

Raymond Knopp's avatar
Raymond Knopp committed
210 211
  // ****************************************
  // Common RX procedures subframe n
Cedric Roux's avatar
Cedric Roux committed
212 213
  T(T_ENB_PHY_DL_TICK, T_INT(eNB->Mod_id), T_INT(proc->frame_tx), T_INT(proc->subframe_tx));

214
  // if this is IF5 or 3GPP_eNB
215
  if (eNB->RU_list && eNB->RU_list[0] && eNB->RU_list[0]->function < NGFI_RAU_IF4p5) {
216
    wakeup_prach_eNB(eNB,NULL,proc->frame_rx,proc->subframe_rx);
217
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
218 219 220
    wakeup_prach_eNB_br(eNB,NULL,proc->frame_rx,proc->subframe_rx);
#endif
  }
221

Wang Tsu-Han's avatar
Wang Tsu-Han committed
222 223
  release_UE_in_freeList(eNB->Mod_id);

Raymond Knopp's avatar
Raymond Knopp committed
224
  // UE-specific RX processing for subframe n
frtabu's avatar
frtabu committed
225
  if (NFAPI_MODE==NFAPI_MONOLITHIC || NFAPI_MODE==NFAPI_MODE_PNF) {
226
    phy_procedures_eNB_uespec_RX(eNB, proc);
227
  }
228

Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
229
  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_ENB_DLSCH_ULSCH_SCHEDULER, 1 );
230 231
#if defined(PRE_SCD_THREAD)

frtabu's avatar
frtabu committed
232
  if (NFAPI_MODE==NFAPI_MODE_VNF) {
233 234 235 236 237 238 239 240
    new_dlsch_ue_select_tbl_in_use = dlsch_ue_select_tbl_in_use;
    dlsch_ue_select_tbl_in_use = !dlsch_ue_select_tbl_in_use;
    // L2-emulator can work only one eNB.
    //      memcpy(&pre_scd_eNB_UE_stats,&RC.mac[ru->eNB_list[0]->Mod_id]->UE_list.eNB_UE_stats, sizeof(eNB_UE_STATS)*MAX_NUM_CCs*NUMBER_OF_UE_MAX);
    //      memcpy(&pre_scd_activeUE, &RC.mac[ru->eNB_list[0]->Mod_id]->UE_list.active, sizeof(boolean_t)*NUMBER_OF_UE_MAX);
    memcpy(&pre_scd_eNB_UE_stats,&RC.mac[0]->UE_list.eNB_UE_stats, sizeof(eNB_UE_STATS)*MAX_NUM_CCs*NUMBER_OF_UE_MAX);
    memcpy(&pre_scd_activeUE, &RC.mac[0]->UE_list.active, sizeof(boolean_t)*NUMBER_OF_UE_MAX);

241
    AssertFatal((ret= pthread_mutex_lock(&ru->proc.mutex_pre_scd))==0,"[eNB] error locking proc mutex for eNB pre scd, return %d\n",ret);
242

243
    ru->proc.instance_pre_scd++;
244

245 246 247 248
    if (ru->proc.instance_pre_scd == 0) {
      if (pthread_cond_signal(&ru->proc.cond_pre_scd) != 0) {
        LOG_E( PHY, "[eNB] ERROR pthread_cond_signal for eNB pre scd\n" );
        exit_fun( "ERROR pthread_cond_signal cond_pre_scd" );
249
      }
250 251 252
    } else {
      LOG_E( PHY, "[eNB] frame %d subframe %d rxtx busy instance_pre_scd %d\n",
             proc->frame_rx,proc->subframe_rx,ru->proc.instance_pre_scd );
253
    }
254

255 256
    AssertFatal((ret= pthread_mutex_unlock(&ru->proc.mutex_pre_scd))==0,"[eNB] error unlocking proc mutex for eNB pre scd, return %d\n",ret);

257
  }
258

259
#endif
260
  AssertFatal((ret= pthread_mutex_lock(&eNB->UL_INFO_mutex))==0,"error locking UL_INFO_mutex, return %d\n",ret);
261 262 263 264 265
  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);
266
  AssertFatal((ret= pthread_mutex_unlock(&eNB->UL_INFO_mutex))==0,"error unlocking UL_INFO_mutex, return %d\n",ret);
267

Wang Tsu-Han's avatar
Wang Tsu-Han committed
268 269
  /* this conflict resolution may be totally wrong, to be tested */
  /* CONFLICT RESOLUTION: BEGIN */
270

Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
271 272
  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_ENB_DLSCH_ULSCH_SCHEDULER, 0 );

273
  if(oai_exit) return(-1);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
274 275

  if(get_thread_parallel_conf() == PARALLEL_SINGLE_THREAD) {
Wang Tsu-Han's avatar
Wang Tsu-Han committed
276
#ifndef PHY_TX_THREAD
277
    phy_procedures_eNB_TX(eNB, proc, 1);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
278
#endif
279
  }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
280

Wang Tsu-Han's avatar
Wang Tsu-Han committed
281 282 283
  /* CONFLICT RESOLUTION: what about this release_thread call, has it to be done? if yes, where? */
  //if (release_thread(&proc->mutex_rxtx,&proc->instance_cnt_rxtx,thread_name)<0) return(-1);
  /* CONFLICT RESOLUTION: END */
Raymond Knopp's avatar
Raymond Knopp committed
284
  stop_meas( &softmodem_stats_rxtx_sf );
285

286
  LOG_D(PHY,"%s() Exit proc[rx:%d%d tx:%d%d]\n", __FUNCTION__, proc->frame_rx, proc->subframe_rx, proc->frame_tx, proc->subframe_tx);
287
  LOG_D(PHY, "rxtx:%lld nfapi:%lld tx:%lld rx:%lld prach:%lld ofdm:%lld ",
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
288 289 290 291 292 293
        softmodem_stats_rxtx_sf.p_time, nfapi_meas.p_time,
        TICK_TO_US(eNB->phy_proc_tx),
        TICK_TO_US(eNB->phy_proc_rx),
        TICK_TO_US(eNB->rx_prach),
        TICK_TO_US(eNB->ofdm_mod_stats)
       );
294 295

  LOG_D(PHY,
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
296 297 298 299 300 301 302 303
        "dlsch[enc:%lld mod:%lld scr:%lld rm:%lld t:%lld i:%lld] rx_dft:%lld ",
        TICK_TO_US(eNB->dlsch_encoding_stats),
        TICK_TO_US(eNB->dlsch_modulation_stats),
        TICK_TO_US(eNB->dlsch_scrambling_stats),
        TICK_TO_US(eNB->dlsch_rate_matching_stats),
        TICK_TO_US(eNB->dlsch_turbo_encoding_stats),
        TICK_TO_US(eNB->dlsch_interleaving_stats),
        TICK_TO_US(eNB->rx_dft_stats));
304
  LOG_D(PHY," ulsch[ch:%lld freq:%lld dec:%lld demod:%lld ru:%lld ",
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
305 306 307 308 309
        TICK_TO_US(eNB->ulsch_channel_estimation_stats),
        TICK_TO_US(eNB->ulsch_freq_offset_estimation_stats),
        TICK_TO_US(eNB->ulsch_decoding_stats),
        TICK_TO_US(eNB->ulsch_demodulation_stats),
        TICK_TO_US(eNB->ulsch_rate_unmatching_stats));
310
  LOG_D(PHY, "td:%lld dei:%lld dem:%lld llr:%lld tci:%lld ",
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
311 312 313 314 315 316 317 318 319 320 321 322 323
        TICK_TO_US(eNB->ulsch_turbo_decoding_stats),
        TICK_TO_US(eNB->ulsch_deinterleaving_stats),
        TICK_TO_US(eNB->ulsch_demultiplexing_stats),
        TICK_TO_US(eNB->ulsch_llr_stats),
        TICK_TO_US(eNB->ulsch_tc_init_stats));
  LOG_D(PHY, "tca:%lld tcb:%lld tcg:%lld tce:%lld l1:%lld l2:%lld]\n\n",
        TICK_TO_US(eNB->ulsch_tc_alpha_stats),
        TICK_TO_US(eNB->ulsch_tc_beta_stats),
        TICK_TO_US(eNB->ulsch_tc_gamma_stats),
        TICK_TO_US(eNB->ulsch_tc_ext_stats),
        TICK_TO_US(eNB->ulsch_tc_intl1_stats),
        TICK_TO_US(eNB->ulsch_tc_intl2_stats)
       );
Raymond Knopp's avatar
Raymond Knopp committed
324 325 326
  return(0);
}

327

328 329
static void *L1_thread_tx(void *param) {
  L1_proc_t *eNB_proc  = (L1_proc_t *)param;
330
  L1_rxtx_proc_t *proc = &eNB_proc->L1_proc_tx;
331 332
  PHY_VARS_eNB *eNB = RC.eNB[0][proc->CC_id];
  char thread_name[100];
Wang Tsu-Han's avatar
Wang Tsu-Han committed
333
  sprintf(thread_name,"TXnp4_%d\n",&eNB->proc.L1_proc == proc ? 0 : 1);
334
  thread_top_init(thread_name,1,470000,500000,500000);
335
  int ret;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
336

337
  //wait_sync("tx_thread");
338

339
  while (!oai_exit) {
340
    LOG_D(PHY,"Waiting for TX (IC %d)\n",proc->instance_cnt);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
341
    if (wait_on_condition(&proc->mutex,&proc->cond,&proc->instance_cnt,thread_name)<0) break;
342 343

    if (oai_exit) break;
344

Raymond Knopp's avatar
Raymond Knopp committed
345
    LOG_D(PHY,"L1_thread_tx: Running for %d.%d\n",proc->frame_tx,proc->subframe_tx);
346 347 348 349 350
    // *****************************************
    // 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)
    // *****************************************
351 352 353 354
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_SUBFRAME_NUMBER_TX1_ENB,proc->subframe_tx);
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_SUBFRAME_NUMBER_RX1_ENB,proc->subframe_rx);
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_FRAME_NUMBER_TX1_ENB,proc->frame_tx);
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_FRAME_NUMBER_RX1_ENB,proc->frame_rx);
355
    LOG_D(PHY,"L1 TX processing %d.%d\n",proc->frame_tx,proc->subframe_tx);
356
    phy_procedures_eNB_TX(eNB, proc, 1);
357
    AssertFatal((ret= pthread_mutex_lock( &proc->mutex ))==0,"error locking L1_proc_tx mutex, return %d\n",ret);
358
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_L1_PROC_TX_IC,proc->instance_cnt);
359 360 361 362 363

    int subframe_tx = proc->subframe_tx;
    int frame_tx    = proc->frame_tx;
    uint64_t timestamp_tx = proc->timestamp_tx;

364
    proc->instance_cnt = -1;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
365

366
    LOG_D(PHY,"L1 TX signaling done for %d.%d\n",proc->frame_tx,proc->subframe_tx);
367
    // the thread can now be woken up
Raymond Knopp's avatar
Raymond Knopp committed
368
    LOG_D(PHY,"L1_thread_tx: signaling completion in %d.%d\n",proc->frame_tx,proc->subframe_tx);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
369
    if (pthread_cond_signal(&proc->cond) != 0) {
370 371 372
      LOG_E( PHY, "[eNB] ERROR pthread_cond_signal for eNB TXnp4 thread\n");
      exit_fun( "ERROR pthread_cond_signal" );
    }
373

374 375
    AssertFatal((ret= pthread_mutex_unlock( &proc->mutex ))==0,"error unlocking L1_proc_tx mutex, return %d\n",ret);
    wakeup_txfh(eNB,proc,frame_tx,subframe_tx,timestamp_tx);
376 377 378 379 380
  }

  return 0;
}

381
/*!
382
 * \brief The RX UE-specific and TX thread of eNB.
383
 * \param param is a \ref L1_proc_t structure which contains the info what to process.
384 385
 * \returns a pointer to an int. The storage is not on the heap and must not be freed.
 */
386

387
static void *L1_thread( void *param ) {
388
  static int eNB_thread_rxtx_status;
389
  L1_rxtx_proc_t *proc;
390
  // Working
frtabu's avatar
frtabu committed
391
  if(NFAPI_MODE==NFAPI_MODE_VNF) {
392 393 394
    proc = (L1_rxtx_proc_t *)param;
  } else {
    L1_proc_t *eNB_proc  = (L1_proc_t *)param;
395
    proc = &eNB_proc->L1_proc;
396 397
  }

398
  PHY_VARS_eNB *eNB = RC.eNB[0][proc->CC_id];
Raymond Knopp's avatar
Raymond Knopp committed
399
  char thread_name[100];
400 401
  cpu_set_t cpuset;
  CPU_ZERO(&cpuset);
402
  // set default return value
403
  eNB_thread_rxtx_status = 0;
Wang Tsu-Han's avatar
Wang Tsu-Han committed
404
  sprintf(thread_name,"RXn_TXnp4_%d\n",&eNB->proc.L1_proc == proc ? 0 : 1);
405 406 407
  thread_top_init(thread_name,1,470000,500000,500000);
  pthread_setname_np( pthread_self(),"rxtx processing");
  LOG_I(PHY,"thread rxtx created id=%ld\n", syscall(__NR_gettid));
408 409

  while (!oai_exit) {
410
    VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_eNB_PROC_RXTX0+(proc->subframe_rx&1), 0 );
411
    T(T_ENB_MASTER_TICK, T_INT(0), T_INT(proc->frame_rx), T_INT(proc->subframe_rx));
412

413
    LOG_D(PHY,"L1RX waiting for RU RX\n");
Wang Tsu-Han's avatar
Wang Tsu-Han committed
414
    if (wait_on_condition(&proc->mutex,&proc->cond,&proc->instance_cnt,thread_name)<0) break;
415

416
    LOG_D(PHY,"L1RX starting in %d.%d\n",proc->frame_rx,proc->subframe_rx);
417
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_CPUID_ENB_THREAD_RXTX,sched_getcpu());
418
    VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_eNB_PROC_RXTX0+(proc->subframe_rx&1), 1 );
419 420 421 422
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_SUBFRAME_NUMBER_TX0_ENB,proc->subframe_tx);
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_SUBFRAME_NUMBER_RX0_ENB,proc->subframe_rx);
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_FRAME_NUMBER_TX0_ENB,proc->frame_tx);
    VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_FRAME_NUMBER_RX0_ENB,proc->frame_rx);
423

424
  
425 426
    if (oai_exit) break;

Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
427
    if (eNB->CC_id==0) {
428
      if (rxtx(eNB,proc,thread_name) < 0) break;
429 430
    }

431 432
    LOG_D(PHY,"L1 RX %d.%d done\n",proc->frame_rx,proc->subframe_rx);

433
    if(get_thread_parallel_conf() == PARALLEL_RU_L1_SPLIT)              phy_procedures_eNB_TX(eNB, proc, 1);
434 435


frtabu's avatar
frtabu committed
436
    if (NFAPI_MODE!=NFAPI_MODE_VNF) {
437 438
      if(get_thread_parallel_conf() == PARALLEL_RU_L1_TRX_SPLIT)      wakeup_tx(eNB,proc->frame_rx,proc->subframe_rx,proc->frame_tx,proc->subframe_tx,proc->timestamp_tx);
      else if(get_thread_parallel_conf() == PARALLEL_RU_L1_SPLIT)     wakeup_txfh(eNB,proc,proc->frame_tx,proc->subframe_tx,proc->timestamp_tx);
439
    }
440 441 442 443

    if (release_thread(&proc->mutex,&proc->instance_cnt,thread_name)<0) break;


Raymond Knopp's avatar
Raymond Knopp committed
444
  } // while !oai_exit
445

446
  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_eNB_PROC_RXTX0+(proc->subframe_rx&1), 0 );
447
  LOG_D(PHY, " *** Exiting eNB thread RXn_TXnp4\n");
448 449
  eNB_thread_rxtx_status = 0;
  return &eNB_thread_rxtx_status;
450 451
}

452
void eNB_top(PHY_VARS_eNB *eNB, int frame_rx, int subframe_rx, char *string,RU_t *ru) {
453 454
  L1_proc_t *proc           = &eNB->proc;
  L1_rxtx_proc_t *L1_proc = &proc->L1_proc;
Raymond Knopp's avatar
Raymond Knopp committed
455 456
  LTE_DL_FRAME_PARMS *fp = &ru->frame_parms;
  RU_proc_t *ru_proc=&ru->proc;
457 458
  proc->frame_rx    = frame_rx;
  proc->subframe_rx = subframe_rx;
Raymond Knopp's avatar
Raymond Knopp committed
459

Cedric Roux's avatar
Cedric Roux committed
460
  if (!oai_exit) {
461
    T(T_ENB_MASTER_TICK, T_INT(0), T_INT(proc->frame_rx), T_INT(proc->subframe_rx));
Wang Tsu-Han's avatar
Wang Tsu-Han committed
462 463 464 465 466
    L1_proc->timestamp_tx = ru_proc->timestamp_rx + (sf_ahead*fp->samples_per_tti);
    L1_proc->frame_rx     = ru_proc->frame_rx;
    L1_proc->subframe_rx  = ru_proc->subframe_rx;
    L1_proc->frame_tx     = (L1_proc->subframe_rx > (9-sf_ahead)) ? (L1_proc->frame_rx+1)&1023 : L1_proc->frame_rx;
    L1_proc->subframe_tx  = (L1_proc->subframe_rx + sf_ahead)%10;
Raymond Knopp's avatar
Raymond Knopp committed
467

Wang Tsu-Han's avatar
Wang Tsu-Han committed
468
    if (rxtx(eNB,L1_proc,string) < 0) LOG_E(PHY,"eNB %d CC_id %d failed during execution\n",eNB->Mod_id,eNB->CC_id);
469

Wang Tsu-Han's avatar
Wang Tsu-Han committed
470 471 472
    ru_proc->timestamp_tx = L1_proc->timestamp_tx;
    ru_proc->subframe_tx  = L1_proc->subframe_tx;
    ru_proc->frame_tx     = L1_proc->frame_tx;
473
  }
Raymond Knopp's avatar
Raymond Knopp committed
474 475
}

476 477 478
int wakeup_txfh(PHY_VARS_eNB *eNB, L1_rxtx_proc_t *proc,int frame_tx,int subframe_tx,uint64_t timestamp_tx) {

  RU_t *ru;
ISIP CS/NCTU's avatar
ISIP CS/NCTU committed
479
  RU_proc_t *ru_proc;
Raymond Knopp's avatar
Raymond Knopp committed
480
  LTE_DL_FRAME_PARMS *fp; 
481
  int waitret,ret;
482

483 484 485 486
  LOG_D(PHY,"L1 TX Waking up TX FH %d.%d (IC RU TX %d)\n",frame_tx,subframe_tx,proc->instance_cnt_RUs);

  // grab the information for the RU due to the following wait 

487
  waitret=timedwait_on_condition(&proc->mutex_RUs,&proc->cond_RUs,&proc->instance_cnt_RUs,"wakeup_txfh",1000000);
488

489 490 491 492 493 494 495 496 497 498 499 500 501 502
  AssertFatal(release_thread(&proc->mutex_RUs,&proc->instance_cnt_RUs,"wakeup_txfh")==0, "error releaseing eNB lock on RUs\n"); 

  if (waitret == ETIMEDOUT) {
     LOG_W(PHY,"Dropping TX slot (%d.%d) because FH is blocked more than 1 subframe times (1ms)\n",frame_tx,subframe_tx);

     AssertFatal((ret=pthread_mutex_lock(&eNB->proc.mutex_RU_tx))==0,"mutex_lock returns %d\n",ret);
     eNB->proc.RU_mask_tx = 0;
     AssertFatal((ret=pthread_mutex_unlock(&eNB->proc.mutex_RU_tx))==0,"mutex_unlock returns %d\n",ret);
     AssertFatal((ret=pthread_mutex_lock(&proc->mutex_RUs))==0,"mutex_lock returns %d\n",ret);
     proc->instance_cnt_RUs = 0;
     VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_FRAME_NUMBER_RX0_UE,proc->instance_cnt_RUs);
     AssertFatal((ret=pthread_mutex_unlock(&proc->mutex_RUs))==0,"mutex_unlock returns %d\n",ret);
     return(-1);
  } 
magounak's avatar
magounak committed
503

504
  for(int ru_id=0; ru_id<eNB->num_RU; ru_id++){
505 506 507
    ru      = eNB->RU_list[ru_id];
    ru_proc = &ru->proc;
    fp = &ru->frame_parms;
Raymond Knopp's avatar
Raymond Knopp committed
508 509 510
    if (((fp->frame_type == TDD) && (subframe_select(fp,proc->subframe_tx)==SF_UL))||
        (eNB->RU_list[ru_id]->state == RU_SYNC)||
        (eNB->RU_list[ru_id]->wait_cnt>0)){
511
       AssertFatal((pthread_mutex_lock(&proc->mutex_RUs))==0, "mutex_lock returns %d\n",ret);
Raymond Knopp's avatar
Raymond Knopp committed
512
       proc->instance_cnt_RUs = 0;
513
       AssertFatal((pthread_mutex_unlock(&proc->mutex_RUs))==0, "mutex_unlock returns %d\n",ret);
Raymond Knopp's avatar
Raymond Knopp committed
514 515
       continue;//hacking only works when all RU_tx works on the same subframe #TODO: adding mask stuff
    }
516

517 518
    AssertFatal((ret = pthread_mutex_lock(&ru_proc->mutex_eNBs))==0,"ERROR pthread_mutex_lock failed on mutex_eNBs L1_thread_tx with ret=%d\n",ret);

Wang Tsu-Han's avatar
Wang Tsu-Han committed
519
    if (ru_proc->instance_cnt_eNBs == 0) {
520 521 522 523 524 525
      LOG_E(PHY,"Frame %d, subframe %d: TX FH thread busy, dropping Frame %d, subframe %d\n", ru_proc->frame_tx, ru_proc->subframe_tx, proc->frame_rx, proc->subframe_rx);
      AssertFatal((ret=pthread_mutex_lock(&eNB->proc.mutex_RU_tx))==0,"mutex_lock returns %d\n",ret);
      eNB->proc.RU_mask_tx = 0;
      AssertFatal((ret=pthread_mutex_unlock(&eNB->proc.mutex_RU_tx))==0,"mutex_unlock returns %d\n",ret);
      AssertFatal((ret=pthread_mutex_unlock( &ru_proc->mutex_eNBs ))==0,"mutex_unlock return %d\n",ret);
      return(-1);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
526
    }
527

528
    ru_proc->instance_cnt_eNBs = 0;
529 530 531
    ru_proc->timestamp_tx = timestamp_tx;
    ru_proc->subframe_tx  = subframe_tx;
    ru_proc->frame_tx     = frame_tx;
532

533
    LOG_D(PHY,"L1 TX Waking up TX FH (2) %d.%d\n",frame_tx,subframe_tx);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
534
    // the thread can now be woken up
535 536 537
    AssertFatal(pthread_cond_signal(&ru_proc->cond_eNBs) == 0,
               "[eNB] ERROR pthread_cond_signal for eNB TXnp4 thread\n");
    AssertFatal((ret=pthread_mutex_unlock(&ru_proc->mutex_eNBs))==0,"mutex_unlock returned %d\n",ret);
538
  }
539
  return(0);
Raymond Knopp's avatar
Raymond Knopp committed
540 541
}

542 543 544 545 546 547
int wakeup_tx(PHY_VARS_eNB *eNB, int frame_rx,int subframe_rx,int frame_tx,int subframe_tx,uint64_t timestamp_tx) {

  L1_rxtx_proc_t *L1_proc = &eNB->proc.L1_proc;
  L1_rxtx_proc_t *L1_proc_tx = &eNB->proc.L1_proc_tx;

  int ret;
548

Raymond Knopp's avatar
Raymond Knopp committed
549
  LOG_D(PHY,"ENTERED wakeup_tx (IC %d)\n",L1_proc_tx->instance_cnt);
550
  
551
  AssertFatal((ret = pthread_mutex_lock(&L1_proc_tx->mutex))==0,"mutex_lock returns %d\n",ret);
552

553 554
  LOG_D(PHY,"L1 RX %d.%d Waiting to wake up L1 TX %d.%d (IC L1TX %d)\n",L1_proc->frame_rx,L1_proc->subframe_rx,L1_proc->frame_tx,L1_proc->subframe_tx,L1_proc_tx->instance_cnt);

555
  while(L1_proc_tx->instance_cnt == 0) {
556
    pthread_cond_wait(&L1_proc_tx->cond,&L1_proc_tx->mutex);
557 558
  }

559
  LOG_D(PHY,"L1 RX Got signal that TX %d.%d is done\n",L1_proc_tx->frame_tx,L1_proc_tx->subframe_tx);
560
  VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_L1_PROC_TX_IC,L1_proc_tx->instance_cnt);
561
  L1_proc_tx->instance_cnt = 0;
562
  VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_L1_PROC_TX_IC,L1_proc_tx->instance_cnt);
563 564 565 566 567
  L1_proc_tx->subframe_rx   = subframe_rx;
  L1_proc_tx->frame_rx      = frame_rx;
  L1_proc_tx->subframe_tx   = subframe_tx;
  L1_proc_tx->frame_tx      = frame_tx;
  L1_proc_tx->timestamp_tx  = timestamp_tx;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
568

569
  // the thread can now be woken up
570
  LOG_D(PHY,"L1 RX Waking up L1 TX %d.%d\n",L1_proc->frame_tx,L1_proc->subframe_tx);
571
  AssertFatal(pthread_cond_signal(&L1_proc_tx->cond) == 0, "ERROR pthread_cond_signal for eNB L1 thread tx\n");
572

573
  AssertFatal((ret=pthread_mutex_unlock(&L1_proc_tx->mutex))==0,"mutex_unlock returns %d\n",ret);
574 575
  return(0);
}
Raymond Knopp's avatar
Raymond Knopp committed
576

577
int wakeup_rxtx(PHY_VARS_eNB *eNB,RU_t *ru) {
578
  L1_proc_t *proc=&eNB->proc;
579
  RU_proc_t *ru_proc=&ru->proc;
580
  L1_rxtx_proc_t *L1_proc=&proc->L1_proc;
581
  LTE_DL_FRAME_PARMS *fp = &eNB->frame_parms;
582
  int ret;
583

584
  LOG_D(PHY,"ENTERED wakeup_rxtx, %d.%d\n",ru_proc->frame_rx,ru_proc->subframe_rx);
585

586 587 588
  // wake up TX for subframe n+sl_ahead
  // lock the TX mutex and make sure the thread is ready
  AssertFatal((ret=pthread_mutex_lock(&L1_proc->mutex)) == 0,"mutex_lock returns %d\n", ret);
589

590 591 592 593
  if (L1_proc->instance_cnt == 0) { // L1_thread is busy so abort the subframe
   AssertFatal((ret=pthread_mutex_unlock( &L1_proc->mutex))==0,"mutex_unlock return %d\n",ret);
   LOG_W(PHY,"L1_thread isn't ready in %d.%d, aborting RX processing\n",ru_proc->frame_rx,ru_proc->subframe_rx); 
   return(0);
594
  }
595
 
596

Wang Tsu-Han's avatar
Wang Tsu-Han committed
597
  ++L1_proc->instance_cnt;
598 599
  // 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
600
  // transmitted timestamp of the next TX slot (first).
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
601
  // The last (TS_rx mod samples_per_frame) was n*samples_per_tti,
602 603
  // we want to generate subframe (n+sf_ahead), so TS_tx = TX_rx+sf_ahead*samples_per_tti,
  // and proc->subframe_tx = proc->subframe_rx+sf_ahead
604 605 606 607 608
  L1_proc->timestamp_tx = ru_proc->timestamp_rx + (sf_ahead*fp->samples_per_tti);
  L1_proc->frame_rx     = ru_proc->frame_rx;
  L1_proc->subframe_rx  = ru_proc->subframe_rx;
  L1_proc->frame_tx     = (L1_proc->subframe_rx > (9-sf_ahead)) ? (L1_proc->frame_rx+1)&1023 : L1_proc->frame_rx;
  L1_proc->subframe_tx  = (L1_proc->subframe_rx + sf_ahead)%10;
609

610
  LOG_D(PHY,"wakeup_rxtx: L1_proc->subframe_rx %d, L1_proc->subframe_tx %d, RU %d\n",L1_proc->subframe_rx,L1_proc->subframe_tx,ru->idx);
611

612 613 614 615
  VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_FRAME_NUMBER_WAKEUP_RXTX_RX_RU+ru->idx, L1_proc->frame_rx);
  VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_SUBFRAME_NUMBER_WAKEUP_RXTX_RX_RU+ru->idx, L1_proc->subframe_rx);
  VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_FRAME_NUMBER_WAKEUP_RXTX_TX_RU+ru->idx, L1_proc->frame_tx);
  VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME(VCD_SIGNAL_DUMPER_VARIABLES_SUBFRAME_NUMBER_WAKEUP_RXTX_TX_RU+ru->idx, L1_proc->subframe_tx);
magounak's avatar
magounak committed
616

617
  // the thread can now be woken up
618 619 620 621
  if (pthread_cond_signal(&L1_proc->cond) != 0) {
    LOG_E( PHY, "[eNB] ERROR pthread_cond_signal for eNB RXn-TXnp4 thread\n");
    exit_fun( "ERROR pthread_cond_signal" );
    return(-1);
622
  }
623 624 625

  AssertFatal((ret=pthread_mutex_unlock( &L1_proc->mutex))==0,"mutex_unlock return %d\n",ret);

626 627 628
  return(0);
}

629
void wakeup_prach_eNB(PHY_VARS_eNB *eNB,RU_t *ru,int frame,int subframe) {
630
  L1_proc_t *proc = &eNB->proc;
631
  LTE_DL_FRAME_PARMS *fp=&eNB->frame_parms;
632
  int i,ret;
633

634
  if (ru!=NULL) {
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
635

636
    AssertFatal((ret=pthread_mutex_lock(&proc->mutex_RU_PRACH))==0,"mutex_lock return %d\n",ret);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
637
    for (i=0; i<eNB->num_RU; i++) {
638 639 640 641 642 643
    	if (ru == eNB->RU_list[i] && eNB->RU_list[i]->wait_cnt == 0) {
        	LOG_D(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);
		proc->RU_mask_prach |= (1<<i);
        } else if (eNB->RU_list[i]->state == RU_SYNC || eNB->RU_list[i]->wait_cnt > 0) {
	        proc->RU_mask_prach |= (1<<i);
      	}
644
    }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
645

646
    if (proc->RU_mask_prach != (1<<eNB->num_RU)-1) {  // not all RUs have provided their information so return
647
      AssertFatal((ret=pthread_mutex_unlock(&proc->mutex_RU_PRACH))==0,"mutex_unlock return %d\n",ret);
Raymond Knopp's avatar
Raymond Knopp committed
648
      return;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
649
    } else { // all RUs have provided their information so continue on and wakeup eNB processing
650
      proc->RU_mask_prach = 0;
651
      AssertFatal((ret=pthread_mutex_unlock(&proc->mutex_RU_PRACH))==0,"mutex_unlock return %d\n",ret);
652 653
    }
  }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
654

655
  // check if we have to detect PRACH first
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
656
  if (is_prach_subframe(fp,frame,subframe)>0) {
657
    LOG_D(PHY,"Triggering prach processing, frame %d, subframe %d\n",frame,subframe);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
658

659
    if (proc->instance_cnt_prach == 0) {
660
      LOG_W(PHY,"[eNB] Frame %d Subframe %d, dropping PRACH\n", frame,subframe);
661 662
      return;
    }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
663

664
    // wake up thread for PRACH RX
665
    AssertFatal((ret=pthread_mutex_lock(&proc->mutex_prach))==0,"[eNB] ERROR pthread_mutex_lock for eNB PRACH thread %d (IC %d)\n", proc->thread_index, proc->instance_cnt_prach);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
666

667 668
    ++proc->instance_cnt_prach;
    // set timing for prach thread
669 670
    proc->frame_prach = frame;
    proc->subframe_prach = subframe;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
671

672 673 674 675 676 677
    // 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;
    }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
678

679
    AssertFatal((ret=pthread_mutex_unlock( &proc->mutex_prach))==0,"mutex_unlock return %d\n",ret);
680 681 682
  }
}

683
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
684
void wakeup_prach_eNB_br(PHY_VARS_eNB *eNB,RU_t *ru,int frame,int subframe) {
685
  L1_proc_t *proc = &eNB->proc;
686
  LTE_DL_FRAME_PARMS *fp=&eNB->frame_parms;
687
  int i,ret;
688 689

  if (ru!=NULL) {
690
    AssertFatal((ret=pthread_mutex_lock(&proc->mutex_RU_PRACH_br))==0,"mutex_lock return %d\n",ret);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
691 692

    for (i=0; i<eNB->num_RU; i++) {
693
      if (ru == eNB->RU_list[i]) {
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
694 695 696 697 698
        LOG_D(PHY,"frame %d, subframe %d: RU %d for eNB %d signals PRACH BR (mask %x, num_RU %d)\n",frame,subframe,i,eNB->Mod_id,proc->RU_mask_prach_br,eNB->num_RU);

        if ((proc->RU_mask_prach_br&(1<<i)) > 0)
          LOG_E(PHY,"eNB %d frame %d, subframe %d : previous information (PRACH BR) from RU %d (num_RU %d, mask %x) has not been served yet!\n",
                eNB->Mod_id,frame,subframe,ru->idx,eNB->num_RU,proc->RU_mask_prach_br);
699

Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
700
        proc->RU_mask_prach_br |= (1<<i);
701 702
      }
    }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
703

704
    if (proc->RU_mask_prach_br != (1<<eNB->num_RU)-1) {  // not all RUs have provided their information so return
705
      AssertFatal((ret=pthread_mutex_unlock(&proc->mutex_RU_PRACH_br))==0,"mutex_unlock return %d\n",ret);
Raymond Knopp's avatar
Raymond Knopp committed
706
      return;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
707
    } else { // all RUs have provided their information so continue on and wakeup eNB processing
708
      proc->RU_mask_prach_br = 0;
709
      AssertFatal((ret=pthread_mutex_unlock(&proc->mutex_RU_PRACH_br))==0,"mutex_unlock return %d\n",ret);
710 711
    }
  }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
712

713
  // check if we have to detect PRACH first
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
714
  if (is_prach_subframe(fp,frame,subframe)>0) {
715
    LOG_D(PHY,"Triggering prach br processing, frame %d, subframe %d\n",frame,subframe);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
716

717 718 719 720
    if (proc->instance_cnt_prach_br == 0) {
      LOG_W(PHY,"[eNB] Frame %d Subframe %d, dropping PRACH BR\n", frame,subframe);
      return;
    }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
721

722
    // wake up thread for PRACH RX
723
    AssertFatal((ret=pthread_mutex_lock(&proc->mutex_prach_br))==0,"[eNB] ERROR pthread_mutex_lock for eNB PRACH thread %d (IC %d)\n", proc->thread_index, proc->instance_cnt_prach_br);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
724

725 726 727 728
    ++proc->instance_cnt_prach_br;
    // set timing for prach thread
    proc->frame_prach_br = frame;
    proc->subframe_prach_br = subframe;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
729

730 731 732 733 734 735
    // the thread can now be woken up
    if (pthread_cond_signal(&proc->cond_prach_br) != 0) {
      LOG_E( PHY, "[eNB] ERROR pthread_cond_signal for eNB PRACH BR thread %d\n", proc->thread_index);
      exit_fun( "ERROR pthread_cond_signal" );
      return;
    }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
736

737
    AssertFatal((ret=pthread_mutex_unlock( &proc->mutex_prach_br))==0,"mutex_unlock return %d\n",ret);
738 739 740 741
  }
}
#endif

Wang Tsu-Han's avatar
Wang Tsu-Han committed
742

743 744
/*!
 * \brief The prach receive thread of eNB.
745
 * \param param is a \ref L1_proc_t structure which contains the info what to process.
746 747
 * \returns a pointer to an int. The storage is not on the heap and must not be freed.
 */
748
static void *eNB_thread_prach( void *param ) {
749
  static int eNB_thread_prach_status;
750
  PHY_VARS_eNB *eNB= (PHY_VARS_eNB *)param;
751
  L1_proc_t *proc = &eNB->proc;
752 753
  // set default return value
  eNB_thread_prach_status = 0;
754
  thread_top_init("eNB_thread_prach",1,500000,1000000,20000000);
755

756
  //wait_sync("eNB_thread_prach");
757

758
  while (!oai_exit) {
Raymond Knopp's avatar
Raymond Knopp committed
759
    if (wait_on_condition(&proc->mutex_prach,&proc->cond_prach,&proc->instance_cnt_prach,"eNB_prach_thread") < 0) break;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
760

761
    if (oai_exit) break;
762 763

    LOG_D(PHY,"Running eNB prach procedures\n");
764
    prach_procedures(eNB
765
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
766
                     ,0
767
#endif
768
                    );
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
769

Raymond Knopp's avatar
Raymond Knopp committed
770
    if (release_thread(&proc->mutex_prach,&proc->instance_cnt_prach,"eNB_prach_thread") < 0) break;
771
  }
772

773
  LOG_I(PHY, "Exiting eNB thread PRACH\n");
774 775
  eNB_thread_prach_status = 0;
  return &eNB_thread_prach_status;
776 777
}

778
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
779 780
/*!
 * \brief The prach receive thread of eNB for BL/CE UEs.
781
 * \param param is a \ref L1_proc_t structure which contains the info what to process.
782 783
 * \returns a pointer to an int. The storage is not on the heap and must not be freed.
 */
784
static void *eNB_thread_prach_br( void *param ) {
785 786
  static int eNB_thread_prach_status;
  PHY_VARS_eNB *eNB= (PHY_VARS_eNB *)param;
787
  L1_proc_t *proc = &eNB->proc;
788 789
  // set default return value
  eNB_thread_prach_status = 0;
790
  thread_top_init("eNB_thread_prach_br",1,500000,1000000,20000000);
791 792 793

  while (!oai_exit) {
    if (wait_on_condition(&proc->mutex_prach_br,&proc->cond_prach_br,&proc->instance_cnt_prach_br,"eNB_prach_thread_br") < 0) break;
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
794

795
    if (oai_exit) break;
796 797 798

    LOG_D(PHY,"Running eNB prach procedures for BL/CE UEs\n");
    prach_procedures(eNB,1);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
799

800 801 802 803 804 805 806 807 808
    if (release_thread(&proc->mutex_prach_br,&proc->instance_cnt_prach_br,"eNB_prach_thread_br") < 0) break;
  }

  LOG_I(PHY, "Exiting eNB thread PRACH BR\n");
  eNB_thread_prach_status = 0;
  return &eNB_thread_prach_status;
}

#endif
Raymond Knopp's avatar
Raymond Knopp committed
809

Raymond Knopp's avatar
Raymond Knopp committed
810

811

Wang Tsu-Han's avatar
Wang Tsu-Han committed
812
extern void init_td_thread(PHY_VARS_eNB *);
Eurecom's avatar
Eurecom committed
813
extern void init_te_thread(PHY_VARS_eNB *);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
814 815
extern void kill_td_thread(PHY_VARS_eNB *);
extern void kill_te_thread(PHY_VARS_eNB *);
816

817 818
static void *process_stats_thread(void *param) {
  PHY_VARS_eNB     *eNB      = (PHY_VARS_eNB *)param;
819
  wait_sync("process_stats_thread");
820 821

  while (!oai_exit) {
Wang Tsu-Han's avatar
Wang Tsu-Han committed
822
    sleep(1);
823 824

    if (opp_enabled == 1) {
825 826
      if ( eNB->ulsch_decoding_stats.trials>0)
        print_meas(&eNB->ulsch_decoding_stats,"ulsch_decoding",NULL,NULL);
827

828
      if (eNB->dlsch_encoding_stats.trials >0) {
829 830 831 832 833 834 835 836 837 838 839
        print_meas(&eNB->dlsch_turbo_encoding_preperation_stats,"dlsch_coding_crc",NULL,NULL);
        print_meas(&eNB->dlsch_turbo_encoding_segmentation_stats,"dlsch_segmentation",NULL,NULL);
        print_meas(&eNB->dlsch_encoding_stats,"dlsch_encoding",NULL,NULL);
        print_meas(&eNB->dlsch_turbo_encoding_signal_stats,"coding_signal",NULL,NULL);
        print_meas(&eNB->dlsch_turbo_encoding_main_stats,"coding_main",NULL,NULL);
        print_meas(&eNB->dlsch_turbo_encoding_stats,"turbo_encoding",NULL,NULL);
        print_meas(&eNB->dlsch_interleaving_stats,"turbo_interleaving",NULL,NULL);
        print_meas(&eNB->dlsch_rate_matching_stats,"turbo_rate_matching",NULL,NULL);
        print_meas(&eNB->dlsch_turbo_encoding_waiting_stats,"coding_wait",NULL,NULL);
        print_meas(&eNB->dlsch_turbo_encoding_wakeup_stats0,"coding_worker_0",NULL,NULL);
        print_meas(&eNB->dlsch_turbo_encoding_wakeup_stats1,"coding_worker_1",NULL,NULL);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
840
      }
841

842 843
      print_meas(&eNB->dlsch_modulation_stats,"dlsch_modulation",NULL,NULL);
    }
844
  }
845

846 847 848
  return(NULL);
}

849

850
void init_eNB_proc(int inst) {
851
  /*int i=0;*/
852
  int CC_id;
853
  PHY_VARS_eNB *eNB;
854 855
  L1_proc_t *proc;
  L1_rxtx_proc_t *L1_proc, *L1_proc_tx;
Raymond Knopp's avatar
Raymond Knopp committed
856
  pthread_attr_t *attr0=NULL,*attr1=NULL,*attr_prach=NULL;
857
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
858 859
  pthread_attr_t *attr_prach_br=NULL;
#endif
860 861
  LOG_I(PHY,"%s(inst:%d) RC.nb_CC[inst]:%d \n",__FUNCTION__,inst,RC.nb_CC[inst]);

862
  for (CC_id=0; CC_id<RC.nb_CC[inst]; CC_id++) {
863
    eNB = RC.eNB[inst][CC_id];
laurent's avatar
laurent committed
864
#ifndef OCP_FRAMEWORK
865
    LOG_I(PHY,"Initializing eNB processes instance:%d CC_id %d \n",inst,CC_id);
laurent's avatar
laurent committed
866
#endif
867
    proc = &eNB->proc;
Wang Tsu-Han's avatar
Wang Tsu-Han committed
868 869 870 871
    L1_proc                        = &proc->L1_proc;
    L1_proc_tx                     = &proc->L1_proc_tx;
    L1_proc->instance_cnt          = -1;
    L1_proc_tx->instance_cnt       = -1;
872 873
    L1_proc->instance_cnt_RUs      = 0;
    L1_proc_tx->instance_cnt_RUs   = 0;
874
    proc->instance_cnt_prach       = -1;
875
    proc->instance_cnt_asynch_rxtx = -1;
Eurecom's avatar
Eurecom committed
876
    proc->instance_cnt_synch       = -1;
877
    proc->CC_id                    = CC_id;
Wang Tsu-Han's avatar
Wang Tsu-Han committed
878 879
    proc->first_rx                 =1;
    proc->first_tx                 =1;
magounak's avatar
magounak committed
880
    proc->RU_mask_tx               = 0; // (1<<eNB->num_RU)-1;
881
    memset((void*)proc->RU_mask,0,10*sizeof(proc->RU_mask[0]));
Wang Tsu-Han's avatar
Wang Tsu-Han committed
882
    proc->RU_mask_prach            =0;
883
    pthread_mutex_init( &eNB->UL_INFO_mutex, NULL);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
884 885 886 887
    pthread_mutex_init( &L1_proc->mutex, NULL);
    pthread_mutex_init( &L1_proc_tx->mutex, NULL);
    pthread_cond_init( &L1_proc->cond, NULL);
    pthread_cond_init( &L1_proc_tx->cond, NULL);
888 889 890 891
    pthread_mutex_init( &L1_proc->mutex_RUs, NULL);
    pthread_mutex_init( &L1_proc_tx->mutex_RUs, NULL);
    pthread_cond_init( &L1_proc->cond_RUs, NULL);
    pthread_cond_init( &L1_proc_tx->cond_RUs, NULL);
Raymond Knopp's avatar
Raymond Knopp committed
892 893
    pthread_mutex_init( &proc->mutex_prach, NULL);
    pthread_mutex_init( &proc->mutex_asynch_rxtx, NULL);
894
    pthread_mutex_init( &proc->mutex_RU,NULL);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
895
    pthread_mutex_init( &proc->mutex_RU_tx,NULL);
896
    pthread_mutex_init( &proc->mutex_RU_PRACH,NULL);
897
    pthread_cond_init( &proc->cond_prach, NULL);
898
    pthread_cond_init( &proc->cond_asynch_rxtx, NULL);
899 900
    pthread_attr_init( &proc->attr_prach);
    pthread_attr_init( &proc->attr_asynch_rxtx);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
901 902
    pthread_attr_init( &L1_proc->attr);
    pthread_attr_init( &L1_proc_tx->attr);
903
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
904 905 906 907 908 909 910
    proc->instance_cnt_prach_br    = -1;
    proc->RU_mask_prach_br=0;
    pthread_mutex_init( &proc->mutex_prach_br, NULL);
    pthread_mutex_init( &proc->mutex_RU_PRACH_br,NULL);
    pthread_cond_init( &proc->cond_prach_br, NULL);
    pthread_attr_init( &proc->attr_prach_br);
#endif
911
#ifndef DEADLINE_SCHEDULER
Wang Tsu-Han's avatar
Wang Tsu-Han committed
912 913
    attr0       = &L1_proc->attr;
    attr1       = &L1_proc_tx->attr;
Raymond Knopp's avatar
Raymond Knopp committed
914
    attr_prach  = &proc->attr_prach;
915
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
916 917
    attr_prach_br  = &proc->attr_prach_br;
#endif
Raymond Knopp's avatar
Raymond Knopp committed
918
    //    attr_td     = &proc->attr_td;
919
    //    attr_te     = &proc->attr_te;
Raymond Knopp's avatar
Raymond Knopp committed
920
#endif
Wang Tsu-Han's avatar
Wang Tsu-Han committed
921

922
    if(get_thread_worker_conf() == WORKER_ENABLE) {
923
      init_te_thread(eNB);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
924
      init_td_thread(eNB);
925
    }
926

927 928
    LOG_I(PHY,"eNB->single_thread_flag:%d\n", eNB->single_thread_flag);

frtabu's avatar
frtabu committed
929
    if ((get_thread_parallel_conf() == PARALLEL_RU_L1_SPLIT || get_thread_parallel_conf() == PARALLEL_RU_L1_TRX_SPLIT) && NFAPI_MODE!=NFAPI_MODE_VNF) {
Wang Tsu-Han's avatar
Wang Tsu-Han committed
930 931
      pthread_create( &L1_proc->pthread, attr0, L1_thread, proc );
      pthread_create( &L1_proc_tx->pthread, attr1, L1_thread_tx, proc);
frtabu's avatar
frtabu committed
932
    } else if (NFAPI_MODE==NFAPI_MODE_VNF) { // this is neccesary in VNF or L2 FAPI simulator.
933 934 935
      // Original Code from Fujitsu w/ old structure/field name
      //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] );
936 937
      pthread_create( &L1_proc->pthread, attr0, L1_thread, L1_proc );
      pthread_create( &L1_proc_tx->pthread, attr1, L1_thread, L1_proc_tx);
938
    }
939

940
    pthread_create( &proc->pthread_prach, attr_prach, eNB_thread_prach, eNB );
941
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
942 943
    pthread_create( &proc->pthread_prach_br, attr_prach_br, eNB_thread_prach_br, eNB );
#endif
944
    AssertFatal(proc->instance_cnt_prach == -1,"instance_cnt_prach = %d\n",proc->instance_cnt_prach);
945

946
    if (opp_enabled == 1) pthread_create(&proc->process_stats_thread,NULL,process_stats_thread,(void *)eNB);
947
  }
948

949
  //for multiple CCs: setup master and slaves
950
  /*
951 952
     for (CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
     eNB = PHY_vars_eNB_g[inst][CC_id];
953

954 955
     if (eNB->node_timing == synch_to_ext_device) { //master
     eNB->proc.num_slaves = MAX_NUM_CCs-1;
956
     eNB->proc.slave_proc = (L1_proc_t**)malloc(eNB->proc.num_slaves*sizeof(L1_proc_t*));
957

958 959 960 961 962 963 964
     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);
     }
     }
     }
  */
965 966 967 968
  /* 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;
969 970
}

971

972

973 974 975
/*!
 * \brief Terminate eNB TX and RX threads.
 */
976
void kill_eNB_proc(int inst) {
977
  int *status;
978
  PHY_VARS_eNB *eNB;
979 980
  L1_proc_t *proc;
  L1_rxtx_proc_t *L1_proc, *L1_proc_tx;
981
  int ret;
982

983
  for (int CC_id=0; CC_id<MAX_NUM_CCs; CC_id++) {
984
    eNB=RC.eNB[inst][CC_id];
Wang Tsu-Han's avatar
Wang Tsu-Han committed
985 986 987
    proc        = &eNB->proc;
    L1_proc     = &proc->L1_proc;
    L1_proc_tx  = &proc->L1_proc_tx;
988

989
    if(get_thread_worker_conf() == WORKER_ENABLE) {
990 991 992
      kill_td_thread(eNB);
      kill_te_thread(eNB);
    }
Wang Tsu-Han's avatar
Wang Tsu-Han committed
993

994
    LOG_I(PHY, "Killing TX CC_id %d inst %d\n", CC_id, inst );
Wang Tsu-Han's avatar
Wang Tsu-Han committed
995

frtabu's avatar
frtabu committed
996
    if ((get_thread_parallel_conf() == PARALLEL_RU_L1_SPLIT || get_thread_parallel_conf() == PARALLEL_RU_L1_TRX_SPLIT) && NFAPI_MODE!=NFAPI_MODE_VNF) {
997
      AssertFatal((ret=pthread_mutex_lock(&L1_proc->mutex))==0,"mutex_lock return %d\n",ret);
998 999
      L1_proc->instance_cnt = 0;
      pthread_cond_signal(&L1_proc->cond);
1000 1001
      AssertFatal((ret=pthread_mutex_unlock(&L1_proc->mutex))==0,"mutex_unlock return %d\n",ret);
      AssertFatal((ret=pthread_mutex_lock(&L1_proc_tx->mutex))==0,"mutex_lock return %d\n",ret);
1002 1003
      L1_proc_tx->instance_cnt = 0;
      pthread_cond_signal(&L1_proc_tx->cond);
1004
      AssertFatal((ret=pthread_mutex_unlock(&L1_proc_tx->mutex))==0,"muex_unlock return %d\n",ret);
1005
    }
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1006

1007
    AssertFatal((ret=pthread_mutex_lock(&proc->mutex_prach))==0,"mutex_lock return %d\n",ret);
Raymond Knopp's avatar
Raymond Knopp committed
1008 1009
    proc->instance_cnt_prach = 0;
    pthread_cond_signal( &proc->cond_prach );
1010
    AssertFatal((ret=pthread_mutex_unlock(&proc->mutex_prach))==0,"mutex_unlock return %d\n",ret);
1011
    pthread_cond_signal( &proc->cond_asynch_rxtx );
1012
    pthread_cond_broadcast(&sync_phy_proc.cond_phy_proc_tx);
1013
    LOG_D(PHY, "joining pthread_prach\n");
1014
    pthread_join( proc->pthread_prach, (void **)&status );
1015
    LOG_I(PHY, "Destroying prach mutex/cond\n");
1016
    pthread_mutex_destroy( &proc->mutex_prach);
1017
    pthread_cond_destroy( &proc->cond_prach );
1018
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
1019
    proc->instance_cnt_prach_br = 0;
1020
    pthread_cond_signal( &proc->cond_prach_br );
1021
    pthread_join( proc->pthread_prach_br, (void **)&status );
1022
    pthread_mutex_destroy( &proc->mutex_prach_br);
1023
    pthread_cond_destroy( &proc->cond_prach_br );
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1024
#endif
1025
    LOG_I(PHY, "Destroying UL_INFO mutex\n");
1026
    pthread_mutex_destroy(&eNB->UL_INFO_mutex);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1027

frtabu's avatar
frtabu committed
1028
    if ((get_thread_parallel_conf() == PARALLEL_RU_L1_SPLIT || get_thread_parallel_conf() == PARALLEL_RU_L1_TRX_SPLIT) && NFAPI_MODE!=NFAPI_MODE_VNF) {
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1029
      LOG_I(PHY, "Joining L1_proc mutex/cond\n");
1030
      pthread_join( L1_proc->pthread, (void **)&status );
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1031
      LOG_I(PHY, "Joining L1_proc_tx mutex/cond\n");
1032
      pthread_join( L1_proc_tx->pthread, (void **)&status );
1033
    }
1034

Wang Tsu-Han's avatar
Wang Tsu-Han committed
1035 1036 1037
    LOG_I(PHY, "Destroying L1_proc mutex/cond\n");
    pthread_mutex_destroy( &L1_proc->mutex );
    pthread_cond_destroy( &L1_proc->cond );
1038 1039
    pthread_mutex_destroy( &L1_proc->mutex_RUs );
    pthread_cond_destroy( &L1_proc->cond_RUs );
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1040 1041 1042
    LOG_I(PHY, "Destroying L1_proc_tx mutex/cond\n");
    pthread_mutex_destroy( &L1_proc_tx->mutex );
    pthread_cond_destroy( &L1_proc_tx->cond );
1043 1044
    pthread_mutex_destroy( &L1_proc_tx->mutex_RUs );
    pthread_cond_destroy( &L1_proc_tx->cond_RUs );
Robert Schmidt's avatar
Robert Schmidt committed
1045 1046
    pthread_attr_destroy(&proc->attr_prach);
    pthread_attr_destroy(&proc->attr_asynch_rxtx);
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1047 1048
    pthread_attr_destroy(&L1_proc->attr);
    pthread_attr_destroy(&L1_proc_tx->attr);
1049
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
Robert Schmidt's avatar
Robert Schmidt committed
1050 1051 1052
    pthread_mutex_destroy(&proc->mutex_RU_PRACH_br);
    pthread_attr_destroy(&proc->attr_prach_br);
#endif
1053
  }
1054 1055
}

1056

1057 1058 1059 1060 1061 1062


void reset_opp_meas(void) {
  int sfn;
  reset_meas(&softmodem_stats_mt);
  reset_meas(&softmodem_stats_hw);
1063

1064
  for (sfn=0; sfn < 10; sfn++) {
1065
    reset_meas(&softmodem_stats_rxtx_sf);
1066
    reset_meas(&softmodem_stats_rx_sf);
1067 1068 1069
  }
}

1070

1071 1072 1073 1074
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);
1075

1076
  for (sfn=0; sfn < 10; sfn++) {
1077
    print_meas(&softmodem_stats_rxtx_sf,"[eNB][total_phy_proc_rxtx]",NULL, NULL);
1078
    print_meas(&softmodem_stats_rx_sf,"[eNB][total_phy_proc_rx]",NULL,NULL);
1079 1080
  }
}
1081

1082
void free_transport(PHY_VARS_eNB *eNB) {
1083 1084 1085 1086
  int i;
  int j;

  for (i=0; i<NUMBER_OF_UE_MAX; i++) {
1087
    LOG_D(PHY, "Freeing Transport Channel Buffers for DLSCH, UE %d\n",i);
1088 1089 1090

    for (j=0; j<2; j++) free_eNB_dlsch(eNB->dlsch[i][j]);

1091
    LOG_D(PHY, "Freeing Transport Channel Buffer for ULSCH, UE %d\n",i);
1092 1093
    free_eNB_ulsch(eNB->ulsch[1+i]);
  }
1094

1095 1096 1097
  free_eNB_ulsch(eNB->ulsch[0]);
}

1098 1099 1100 1101
void init_transport(PHY_VARS_eNB *eNB) {
  int i;
  int j;
  LTE_DL_FRAME_PARMS *fp = &eNB->frame_parms;
Cedric Roux's avatar
Cedric Roux committed
1102
  LOG_I(PHY, "Initialise transport\n");
1103

1104
  for (i=0; i<NUMBER_OF_UE_MAX; i++) {
Wang Tsu-Han's avatar
Wang Tsu-Han committed
1105
    LOG_D(PHY,"Allocating Transport Channel Buffers for DLSCH, UE %d\n",i);
1106

1107 1108
    for (j=0; j<2; j++) {
      eNB->dlsch[i][j] = new_eNB_dlsch(1,8,NSOFT,fp->N_RB_DL,0,fp);
1109

1110
      if (!eNB->dlsch[i][j]) {
1111
        LOG_E(PHY,"Can't get eNB dlsch structures for UE %d \n", i);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
1112
        exit(-1);
1113
      } else {
1114 1115
        eNB->dlsch[i][j]->rnti=0;
        LOG_D(PHY,"dlsch[%d][%d] => %p rnti:%d\n",i,j,eNB->dlsch[i][j], eNB->dlsch[i][j]->rnti);
1116 1117
      }
    }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
1118

Wang Tsu-Han's avatar
Wang Tsu-Han committed
1119
    LOG_D(PHY,"Allocating Transport Channel Buffer for ULSCH, UE %d\n",i);
1120
    eNB->ulsch[1+i] = new_eNB_ulsch(MAX_TURBO_ITERATIONS,fp->N_RB_UL, 0);
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
1121

1122 1123
    if (!eNB->ulsch[1+i]) {
      LOG_E(PHY,"Can't get eNB ulsch structures\n");
1124 1125
      exit(-1);
    }
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
1126

1127 1128 1129
    // 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;
1130
  }
1131

1132 1133
  // ULSCH for RA
  eNB->ulsch[0] = new_eNB_ulsch(MAX_TURBO_ITERATIONS, fp->N_RB_UL, 0);
1134

1135 1136 1137 1138
  if (!eNB->ulsch[0]) {
    LOG_E(PHY,"Can't get eNB ulsch structures\n");
    exit(-1);
  }
1139

1140 1141 1142 1143 1144 1145 1146
  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;
1147

1148 1149
  for(i=0; i<NUMBER_OF_UE_MAX; i++)
    eNB->mu_mimo_mode[i].dl_pow_off = 2;
1150

1151 1152 1153 1154 1155
  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;
1156
}
Raymond Knopp's avatar
Raymond Knopp committed
1157 1158

void init_eNB_afterRU(void) {
1159 1160
  int inst,CC_id,ru_id,i,aa;
  PHY_VARS_eNB *eNB;
1161
  LOG_I(PHY,"%s() RC.nb_inst:%d\n", __FUNCTION__, RC.nb_inst);
1162

1163
  for (inst=0; inst<RC.nb_inst; inst++) {
1164 1165
    LOG_I(PHY,"RC.nb_CC[inst]:%d\n", RC.nb_CC[inst]);

1166
    for (CC_id=0; CC_id<RC.nb_CC[inst]; CC_id++) {
1167
      LOG_I(PHY,"RC.nb_CC[inst:%d][CC_id:%d]:%p\n", inst, CC_id, RC.eNB[inst][CC_id]);
1168 1169
      eNB                                  =  RC.eNB[inst][CC_id];
      phy_init_lte_eNB(eNB,0,0);
1170

1171
      // map antennas and PRACH signals to eNB RX
1172
      if (0) AssertFatal(eNB->num_RU>0,"Number of RU attached to eNB %d is zero\n",eNB->Mod_id);
1173

1174
      LOG_I(PHY,"Mapping RX ports from %d RUs to eNB %d\n",eNB->num_RU,eNB->Mod_id);
1175
      eNB->frame_parms.nb_antennas_rx       = 0;
Cedric Roux's avatar
Cedric Roux committed
1176
      LOG_I(PHY,"Overwriting eNB->prach_vars.rxsigF[0]:%p\n", eNB->prach_vars.rxsigF[0]);
1177
      eNB->prach_vars.rxsigF[0] = (int16_t **)malloc16(64*sizeof(int16_t *));
1178
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
1179

1180
      for (int ce_level=0; ce_level<4; ce_level++) {
Cedric Roux's avatar
Cedric Roux committed
1181
        LOG_I(PHY,"Overwriting eNB->prach_vars_br.rxsigF.rxsigF[0]:%p\n", eNB->prach_vars_br.rxsigF[ce_level]);
1182
        eNB->prach_vars_br.rxsigF[ce_level] = (int16_t **)malloc16(64*sizeof(int16_t *));
1183 1184
      }

Raymond Knopp's avatar
Raymond Knopp committed
1185
#endif
1186 1187
      LOG_I(PHY,"eNB->num_RU:%d\n", eNB->num_RU);

1188 1189 1190 1191 1192 1193 1194 1195
      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;
        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);
1196

1197 1198 1199
        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[0][aa]    =  eNB->RU_list[ru_id]->prach_rxsigF[i];
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
1200
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
1201

1202 1203
          for (int ce_level=0; ce_level<4; ce_level++)
            eNB->prach_vars_br.rxsigF[ce_level][aa] = eNB->RU_list[ru_id]->prach_rxsigF_br[ce_level][i];
1204

Raymond Knopp's avatar
Raymond Knopp committed
1205
#endif
1206
          eNB->common_vars.rxdataF[aa]     =  eNB->RU_list[ru_id]->common.rxdataF[i];
Louis Adrien Dufrene's avatar
Louis Adrien Dufrene committed
1207
        }
1208
      }
1209

Cedric Roux's avatar
Cedric Roux committed
1210 1211 1212 1213
      /* TODO: review this code, there is something wrong.
       * In monolithic mode, we come here with nb_antennas_rx == 0
       * (not tested in other modes).
       */
1214
      if (eNB->frame_parms.nb_antennas_rx < 1) {
1215 1216
        LOG_I(PHY, "%s() ************* DJP ***** eNB->frame_parms.nb_antennas_rx:%d - GOING TO HARD CODE TO 1", __FUNCTION__, eNB->frame_parms.nb_antennas_rx);
        eNB->frame_parms.nb_antennas_rx = 1;
1217
      } else {
Cedric Roux's avatar
Cedric Roux committed
1218
        //LOG_I(PHY," Delete code\n");
1219 1220
      }

1221
      if (eNB->frame_parms.nb_antennas_tx < 1) {
1222 1223
        LOG_I(PHY, "%s() ************* DJP ***** eNB->frame_parms.nb_antennas_tx:%d - GOING TO HARD CODE TO 1", __FUNCTION__, eNB->frame_parms.nb_antennas_tx);
        eNB->frame_parms.nb_antennas_tx = 1;
1224
      } else {
Cedric Roux's avatar
Cedric Roux committed
1225
        //LOG_I(PHY," Delete code\n");
1226 1227
      }

1228
      AssertFatal(eNB->frame_parms.nb_antennas_rx >0,
1229
                  "inst %d, CC_id %d : nb_antennas_rx %d\n",inst,CC_id,eNB->frame_parms.nb_antennas_rx);
1230
      LOG_I(PHY,"inst %d, CC_id %d : nb_antennas_rx %d\n",inst,CC_id,eNB->frame_parms.nb_antennas_rx);
1231
      init_transport(eNB);
Raymond Knopp's avatar
Raymond Knopp committed
1232
      //init_precoding_weights(RC.eNB[inst][CC_id]);
1233
    }
1234

1235 1236
    init_eNB_proc(inst);
  }
1237

1238
  for (ru_id=0; ru_id<RC.nb_RU; ru_id++) {
1239
    AssertFatal(RC.ru[ru_id]!=NULL,"ru_id %d is null\n",ru_id);
1240 1241
    RC.ru[ru_id]->wakeup_rxtx         = wakeup_rxtx;
    RC.ru[ru_id]->wakeup_prach_eNB    = wakeup_prach_eNB;
1242
#if (LTE_RRC_VERSION >= MAKE_VERSION(14, 0, 0))
1243
    RC.ru[ru_id]->wakeup_prach_eNB_br = wakeup_prach_eNB_br;
1244
#endif
1245
    RC.ru[ru_id]->eNB_top             = eNB_top;
1246 1247
  }
}
1248

1249
void init_eNB(int single_thread_flag,int wait_for_sync) {
1250
  int CC_id;
1251
  int inst;
1252
  PHY_VARS_eNB *eNB;
1253 1254
  LOG_I(PHY,"[lte-softmodem.c] eNB structure about to allocated RC.nb_L1_inst:%d RC.nb_L1_CC[0]:%d\n",RC.nb_L1_inst,RC.nb_L1_CC[0]);

1255
  if (RC.eNB == NULL) RC.eNB = (PHY_VARS_eNB ** *) malloc(RC.nb_L1_inst*sizeof(PHY_VARS_eNB **));
Raymond Knopp's avatar
Raymond Knopp committed
1256

1257
  LOG_I(PHY,"[lte-softmodem.c] eNB structure RC.eNB allocated\n");
1258

1259 1260
  for (inst=0; inst<RC.nb_L1_inst; inst++) {
    if (RC.eNB[inst] == NULL) RC.eNB[inst] = (PHY_VARS_eNB **) malloc(RC.nb_CC[inst]*sizeof(PHY_VARS_eNB *));
1261

1262 1263
    for (CC_id=0; CC_id<RC.nb_L1_CC[inst]; CC_id++) {
      if (RC.eNB[inst][CC_id] == NULL) RC.eNB[inst][CC_id] = (PHY_VARS_eNB *) malloc(sizeof(PHY_VARS_eNB));
1264

1265 1266 1267
      eNB                     = RC.eNB[inst][CC_id];
      eNB->abstraction_flag   = 0;
      eNB->single_thread_flag = single_thread_flag;
1268
      LOG_I(PHY,"Initializing eNB %d CC_id %d single_thread_flag:%d\n",inst,CC_id,single_thread_flag);
laurent's avatar
laurent committed
1269
#ifndef OCP_FRAMEWORK
1270
      LOG_I(PHY,"Initializing eNB %d CC_id %d\n",inst,CC_id);
laurent's avatar
laurent committed
1271
#endif
1272
      LOG_I(PHY,"Registering with MAC interface module\n");
1273 1274 1275
      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;
1276 1277
      memset((void *)&eNB->UL_INFO,0,sizeof(eNB->UL_INFO));
      memset((void *)&eNB->Sched_INFO,0,sizeof(eNB->Sched_INFO));
1278
      LOG_I(PHY,"Setting indication lists\n");
1279 1280 1281 1282
      eNB->UL_INFO.rx_ind.rx_indication_body.rx_pdu_list   = eNB->rx_pdu_list;
      eNB->UL_INFO.crc_ind.crc_indication_body.crc_pdu_list = eNB->crc_pdu_list;
      eNB->UL_INFO.sr_ind.sr_indication_body.sr_pdu_list = eNB->sr_pdu_list;
      eNB->UL_INFO.harq_ind.harq_indication_body.harq_pdu_list = eNB->harq_pdu_list;
1283 1284
      eNB->UL_INFO.cqi_ind.cqi_pdu_list = eNB->cqi_pdu_list;
      eNB->UL_INFO.cqi_ind.cqi_raw_pdu_list = eNB->cqi_raw_pdu_list;
1285
      eNB->prach_energy_counter = 0;
1286
    }
1287
  }
1288

1289

1290
  LOG_I(PHY,"[lte-softmodem.c] eNB structure allocated\n");
1291
  
1292 1293


1294 1295 1296
}


1297
void stop_eNB(int nb_inst) {
1298
  for (int inst=0; inst<nb_inst; inst++) {
1299
    LOG_I(PHY,"Killing eNB %d processing threads\n",inst);
1300 1301
    kill_eNB_proc(inst);
  }
1302
}