phy_procedures_nr_gNB.c 17 KB
Newer Older
Guy De Souza's avatar
Guy De Souza committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
/*
 * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The OpenAirInterface Software Alliance licenses this file to You under
 * the OAI Public License, Version 1.1  (the "License"); you may not use this file
 * except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.openairinterface.org/?page_id=698
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *-------------------------------------------------------------------------------
 * For more information about the OpenAirInterface (OAI) Software Alliance:
 *      contact@openairinterface.org
 */

22 23
#include "PHY/phy_extern.h"
#include "PHY/defs_gNB.h"
Guy De Souza's avatar
Guy De Souza committed
24
#include "sched_nr.h"
25
#include "PHY/NR_REFSIG/dmrs_nr.h"
Guy De Souza's avatar
Guy De Souza committed
26
#include "PHY/NR_TRANSPORT/nr_transport.h"
27
#include "PHY/NR_TRANSPORT/nr_transport_proto.h"
Guy De Souza's avatar
Guy De Souza committed
28
#include "PHY/NR_TRANSPORT/nr_dlsch.h"
29
#include "PHY/NR_TRANSPORT/nr_ulsch.h"
30
#include "PHY/NR_ESTIMATION/nr_ul_estimation.h"
31
#include "SCHED/sched_eNB.h"
32
#include "sched_nr.h"
33
#include "SCHED/sched_common_extern.h"
34 35 36
#include "nfapi/open-nFAPI/nfapi/public_inc/nfapi_interface.h"
#include "nfapi/open-nFAPI/nfapi/public_inc/nfapi_nr_interface.h"
#include "fapi_nr_l1.h"
37 38
#include "common/utils/LOG/log.h"
#include "common/utils/LOG/vcd_signal_dumper.h"
39
#include "PHY/INIT/phy_init.h"
40
#include "PHY/MODULATION/nr_modulation.h"
Guy De Souza's avatar
Guy De Souza committed
41 42 43 44 45 46 47 48
#include "T.h"

#include "assertions.h"
#include "msc.h"

#include <time.h>

#if defined(ENABLE_ITTI)
49
  #include "intertask_interface.h"
Guy De Souza's avatar
Guy De Souza committed
50 51
#endif

52 53
uint8_t SSB_Table[38]={0,2,4,6,8,10,12,14,254,254,16,18,20,22,24,26,28,30,254,254,32,34,36,38,40,42,44,46,254,254,48,50,52,54,56,58,60,62};

Guy De Souza's avatar
Guy De Souza committed
54
extern uint8_t nfapi_mode;
55

56
void nr_set_ssb_first_subcarrier(nfapi_nr_config_request_scf_t *cfg, NR_DL_FRAME_PARMS *fp) {
57 58 59 60 61 62 63

  uint8_t sco = 0;
  if (((fp->freq_range == nr_FR1) && (cfg->ssb_table.ssb_subcarrier_offset.value<24)) ||
      ((fp->freq_range == nr_FR2) && (cfg->ssb_table.ssb_subcarrier_offset.value<12)) )
    sco = cfg->ssb_table.ssb_subcarrier_offset.value;

  fp->ssb_start_subcarrier = (12 * cfg->ssb_table.ssb_offset_point_a.value + sco);
64
  LOG_D(PHY, "SSB first subcarrier %d (%d,%d)\n", fp->ssb_start_subcarrier,cfg->ssb_table.ssb_offset_point_a.value,sco);
65
}
Guy De Souza's avatar
Guy De Souza committed
66

67
void nr_common_signal_procedures (PHY_VARS_gNB *gNB,int frame, int slot) {
68

Guy De Souza's avatar
Guy De Souza committed
69
  NR_DL_FRAME_PARMS *fp=&gNB->frame_parms;
70
  nfapi_nr_config_request_scf_t *cfg = &gNB->gNB_config;
Guy De Souza's avatar
Guy De Souza committed
71
  int **txdataF = gNB->common_vars.txdataF;
72
  uint8_t ssb_index, n_hf;
73
  uint16_t ssb_start_symbol, rel_slot;
74
  int txdataF_offset = (slot%2)*fp->samples_per_slot_wCP;
75 76
  uint16_t slots_per_hf = (fp->slots_per_frame)>>1;

77
  n_hf = fp->half_frame_bit;
78 79

  // if SSB periodicity is 5ms, they are transmitted in both half frames
80
  if ( cfg->ssb_table.ssb_period.value == 0) {
81
    if (slot<slots_per_hf)
82 83 84 85 86
      n_hf=0;
    else
      n_hf=1;
  }

87
  // to set a effective slot number in the half frame where the SSB is supposed to be
88
  rel_slot = (n_hf)? (slot-slots_per_hf) : slot; 
89

90
  LOG_D(PHY,"common_signal_procedures: frame %d, slot %d\n",frame,slot);
Guy De Souza's avatar
Guy De Souza committed
91

92
  if(rel_slot<38 && rel_slot>=0)  { // there is no SSB beyond slot 37
93

94
    for (int i=0; i<2; i++)  {  // max two SSB per frame
95
      
96 97
      ssb_index = i + SSB_Table[rel_slot]; // computing the ssb_index

98
      if ((ssb_index<64) && ((fp->L_ssb >> (63-ssb_index)) & 0x01))  { // generating the ssb only if the bit of L_ssb at current ssb index is 1
99 100 101 102 103
        fp->ssb_index = ssb_index;
        int ssb_start_symbol_abs = nr_get_ssb_start_symbol(fp); // computing the starting symbol for current ssb
	ssb_start_symbol = ssb_start_symbol_abs % fp->symbols_per_slot;  // start symbol wrt slot

	nr_set_ssb_first_subcarrier(cfg, fp);  // setting the first subcarrier
104
	
105 106 107
	LOG_D(PHY,"SS TX: frame %d, slot %d, start_symbol %d\n",frame,slot, ssb_start_symbol);
	nr_generate_pss(gNB->d_pss, &txdataF[0][txdataF_offset], AMP, ssb_start_symbol, cfg, fp);
	nr_generate_sss(gNB->d_sss, &txdataF[0][txdataF_offset], AMP, ssb_start_symbol, cfg, fp);
108
	
109 110 111 112
        if (cfg->carrier_config.num_tx_ant.value <= 4)
	  nr_generate_pbch_dmrs(gNB->nr_gold_pbch_dmrs[n_hf][ssb_index&7],&txdataF[0][txdataF_offset], AMP, ssb_start_symbol, cfg, fp);
        else
	  nr_generate_pbch_dmrs(gNB->nr_gold_pbch_dmrs[0][ssb_index&7],&txdataF[0][txdataF_offset], AMP, ssb_start_symbol, cfg, fp);
113
	
114 115 116 117 118 119 120 121
	nr_generate_pbch(&gNB->pbch,
	                 &gNB->ssb_pdu,
	                 gNB->nr_pbch_interleaver,
			 &txdataF[0][txdataF_offset],
			 AMP,
			 ssb_start_symbol,
			 n_hf, frame, cfg, fp);

122 123
      }
    }
124
  }
Guy De Souza's avatar
Guy De Souza committed
125 126 127
}

void phy_procedures_gNB_TX(PHY_VARS_gNB *gNB,
128
                           int frame,int slot,
129
                           int do_meas) {
Guy De Souza's avatar
Guy De Souza committed
130 131
  int aa;
  NR_DL_FRAME_PARMS *fp=&gNB->frame_parms;
132
  nfapi_nr_config_request_scf_t *cfg = &gNB->gNB_config;
Guy De Souza's avatar
Guy De Souza committed
133
  int offset = gNB->CC_id;
134
  uint8_t ssb_frame_periodicity = 1;  // every how many frames SSB are generated
135
  int txdataF_offset = (slot%2)*fp->samples_per_slot_wCP;
136

137 138 139
  
  
  if (cfg->ssb_table.ssb_period.value > 1) 
140
    ssb_frame_periodicity = 1 <<(cfg->ssb_table.ssb_period.value -1) ; 
Guy De Souza's avatar
Guy De Souza committed
141

Rakesh's avatar
Rakesh committed
142
  if ((cfg->cell_config.frame_duplex_type.value == TDD) &&
143
      (nr_slot_select(cfg,frame,slot) == NR_UPLINK_SLOT)) return;
Guy De Souza's avatar
Guy De Souza committed
144

145
  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_PROCEDURES_ENB_TX+offset,1);
146

147
  if (do_meas==1) start_meas(&gNB->phy_proc_tx);
Guy De Souza's avatar
Guy De Souza committed
148 149

  // clear the transmit data array for the current subframe
Raymond Knopp's avatar
Raymond Knopp committed
150
  for (aa=0; aa<cfg->carrier_config.num_tx_ant.value; aa++) {
151
    memset(&gNB->common_vars.txdataF[aa][txdataF_offset],0,fp->samples_per_slot_wCP*sizeof(int32_t));
Guy De Souza's avatar
Guy De Souza committed
152 153
  }

WANG Tsu-Han's avatar
WANG Tsu-Han committed
154
  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_ENB_COMMON_TX,1);
155
  if (nfapi_mode == 0 || nfapi_mode == 1) { 
156
    if ((!(frame%ssb_frame_periodicity)))  // generate SSB only for given frames according to SSB periodicity
157
      nr_common_signal_procedures(gNB,frame, slot);
158
  }
WANG Tsu-Han's avatar
WANG Tsu-Han committed
159
  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_ENB_COMMON_TX,0);
160

161

162 163 164 165 166
  if (gNB->pdcch_pdu || gNB->ul_dci_pdu) {
    LOG_D(PHY, "[gNB %d] Frame %d slot %d Calling nr_generate_dci_top (number of UL/DL DCI %d/%d)\n",
	  gNB->Mod_id, frame, slot,
	  gNB->ul_dci_pdu==NULL?0:gNB->ul_dci_pdu->pdcch_pdu.pdcch_pdu_rel15.numDlDci,
	  gNB->pdcch_pdu==NULL?0:gNB->pdcch_pdu->pdcch_pdu_rel15.numDlDci);
167
  
168
    VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_ENB_PDCCH_TX,1);
169

170 171 172 173 174 175 176 177
    nr_generate_dci_top(gNB->pdcch_pdu,
			gNB->ul_dci_pdu,
			gNB->nr_gold_pdcch_dmrs[slot],
			&gNB->common_vars.txdataF[0][txdataF_offset],
			AMP, *fp);
  
    VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_ENB_PDCCH_TX,0);
  }
178 179 180
 
  LOG_D(PHY, "PDSCH generation started (%d)\n", gNB->num_pdsch_rnti);
  for (int i=0; i<gNB->num_pdsch_rnti; i++) {
181 182 183 184
    VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_GENERATE_DLSCH,1);
    nr_generate_pdsch(gNB->dlsch[i][0],
		      gNB->nr_gold_pdsch_dmrs[slot],
		      gNB->common_vars.txdataF,
185
		      AMP, frame, slot, fp, 0,
186 187
		      &gNB->dlsch_encoding_stats,
		      &gNB->dlsch_scrambling_stats,
188 189 190 191 192 193 194 195
		      &gNB->dlsch_modulation_stats,
		      &gNB->tinput,
		      &gNB->tprep,
		      &gNB->tparity,
		      &gNB->toutput,
		      &gNB->dlsch_rate_matching_stats,
		      &gNB->dlsch_interleaving_stats,
		      &gNB->dlsch_segmentation_stats);
196
    VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_GENERATE_DLSCH,0);
197
  }
198

199
  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_PROCEDURES_ENB_TX+offset,0);
Guy De Souza's avatar
Guy De Souza committed
200
}
201 202


203

204
/*
205

206 207
  if ((cfg->subframe_config.duplex_mode.value == TDD) && 
      ((nr_slot_select(fp,frame,slot)&NR_DOWNLINK_SLOT)==SF_DL)) return;
208 209 210 211 212

  //  VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_PROCEDURES_ENB_RX,1);


  if (do_prach_rx(fp,frame,slot)) L1_nr_prach_procedures(gNB,frame,slot/fp->slots_per_subframe);
213 214
*/

Raymond Knopp's avatar
Raymond Knopp committed
215
void nr_ulsch_procedures(PHY_VARS_gNB *gNB, int frame_rx, int slot_rx, int ULSCH_id, uint8_t harq_pid)
216 217
{
  NR_DL_FRAME_PARMS                    *frame_parms           = &gNB->frame_parms;
218
  nfapi_nr_ul_config_ulsch_pdu         *rel15_ul              = &gNB->ulsch[ULSCH_id][0]->harq_processes[harq_pid]->ulsch_pdu;
219 220
  nfapi_nr_ul_config_ulsch_pdu_rel15_t *nfapi_ulsch_pdu_rel15 = &rel15_ul->ulsch_pdu_rel15;
  
221
  uint8_t ret;
222 223
  uint8_t l, number_dmrs_symbols = 0;
  uint8_t mapping_type;
224 225
  uint32_t G;
  int Nid_cell = 0; // [hna] shouldn't be a local variable (should be signaled)
226
  uint16_t start_symbol, number_symbols, nb_re_dmrs;
227

228 229
  mapping_type = gNB->pusch_config.pusch_TimeDomainResourceAllocation[0]->mappingType;

230 231 232 233
  start_symbol = nfapi_ulsch_pdu_rel15->start_symbol;
  number_symbols = nfapi_ulsch_pdu_rel15->number_symbols;

  for (l = start_symbol; l < start_symbol + number_symbols; l++)
234 235 236 237 238 239
      number_dmrs_symbols += is_dmrs_symbol(l,
                                            0,
                                            0,
                                            0,
                                            0,
                                            0,
240
                                            number_symbols,
241 242 243 244
                                            &gNB->dmrs_UplinkConfig,
                                            mapping_type,
                                            frame_parms->ofdm_symbol_size);

245
  nb_re_dmrs = ((gNB->dmrs_UplinkConfig.pusch_dmrs_type == pusch_dmrs_type1)?6:4)*number_dmrs_symbols;
246

247
  G = nr_get_G(nfapi_ulsch_pdu_rel15->number_rbs,
248
               number_symbols,
249
               nb_re_dmrs,
yilmazt's avatar
yilmazt committed
250 251 252
               nfapi_ulsch_pdu_rel15->length_dmrs,
               nfapi_ulsch_pdu_rel15->Qm,
               nfapi_ulsch_pdu_rel15->n_layers);
253

254

255 256 257 258
  //----------------------------------------------------------
  //------------------- ULSCH unscrambling -------------------
  //----------------------------------------------------------

Raymond Knopp's avatar
Raymond Knopp committed
259
  nr_ulsch_unscrambling(gNB->pusch_vars[ULSCH_id]->llr,
yilmazt's avatar
yilmazt committed
260 261 262 263
                        G,
                        0,
                        Nid_cell,
                        rel15_ul->rnti);
264 265 266 267 268

  //----------------------------------------------------------
  //--------------------- ULSCH decoding ---------------------
  //----------------------------------------------------------

269
  ret = nr_ulsch_decoding(gNB,
Raymond Knopp's avatar
Raymond Knopp committed
270 271
                    ULSCH_id,
                    gNB->pusch_vars[ULSCH_id]->llr,
yilmazt's avatar
yilmazt committed
272
                    frame_parms,
273
                    frame_rx,
274
                    number_symbols,
275
                    nb_re_dmrs,
276
                    slot_rx,
yilmazt's avatar
yilmazt committed
277 278
                    harq_pid,
                    0);
279
        
280
  if (ret > gNB->ulsch[ULSCH_id][0]->max_ldpc_iterations)
281
    LOG_I(PHY, "ULSCH %d in error\n",ULSCH_id);
282
  else
283
    LOG_I(PHY, "ULSCH %d received ok\n",ULSCH_id);
284 285 286 287

}


288
void nr_fill_rx_indication(PHY_VARS_gNB *gNB, int frame, int slot_rx, int ULSCH_id, uint8_t harq_pid)
289 290 291 292 293
{
  // --------------------
  // [hna] TO BE CLEANED
  // --------------------

294
  nfapi_rx_indication_pdu_t *pdu;
295 296 297
  int timing_advance_update;
  int sync_pos;

cig's avatar
cig committed
298
  uint16_t mu = gNB->frame_parms.numerology_index;
299 300 301 302 303
  // pthread_mutex_lock(&gNB->UL_INFO_mutex);

  // gNB->UL_INFO.rx_ind.sfn_sf                    = frame<<4| slot_rx;
  // gNB->UL_INFO.rx_ind.rx_indication_body.tl.tag = NFAPI_RX_INDICATION_BODY_TAG;

304
  pdu = &gNB->UL_INFO.rx_ind.rx_indication_body.rx_pdu_list[gNB->UL_INFO.rx_ind.rx_indication_body.number_of_pdus];
305 306 307 308 309 310 311 312

  // pdu->rx_ue_information.handle          = gNB->ulsch[UE_id+1][0]->handle;
  // pdu->rx_ue_information.tl.tag          = NFAPI_RX_UE_INFORMATION_TAG;
  // pdu->rx_ue_information.rnti            = gNB->ulsch[UE_id+1][0]->rnti;
  // pdu->rx_indication_rel8.tl.tag         = NFAPI_RX_INDICATION_REL8_TAG;
  // pdu->rx_indication_rel8.length         = gNB->ulsch[UE_id+1][0]->harq_processes[harq_pid]->TBS>>3;
  // pdu->rx_indication_rel8.offset         = 1;   // DJP - I dont understand - but broken unless 1 ????  0;  // filled in at the end of the UL_INFO formation

cig's avatar
cig committed
313 314
  pdu->data                              = gNB->ulsch[ULSCH_id+1][0]->harq_processes[harq_pid]->b;
  sync_pos                               = nr_est_timing_advance_pusch(gNB, ULSCH_id); // estimate timing advance for MAC
315
  timing_advance_update                  = sync_pos * (1 << mu);                    // scale by the used scs numerology
316

317
  // scale the 16 factor in N_TA calculation in 38.213 section 4.2 according to the used FFT size
318 319 320
  switch (gNB->frame_parms.N_RB_DL) {
    case 106: timing_advance_update /= 16; break;
    case 217: timing_advance_update /= 32; break;
321
    case 245: timing_advance_update /= 32; break;
Florian Kaltenberger's avatar
Florian Kaltenberger committed
322
    case 273: timing_advance_update /= 32; break;
cig's avatar
cig committed
323
    case 66:  timing_advance_update /= 12; break;
324 325 326 327 328 329 330 331 332
    default: abort();
  }

  // put timing advance command in 0..63 range
  timing_advance_update += 31;

  if (timing_advance_update < 0)  timing_advance_update = 0;
  if (timing_advance_update > 63) timing_advance_update = 63;

333
  LOG_D(PHY, "Estimated timing advance PUSCH is  = %d, timing_advance_update is %d \n", sync_pos,timing_advance_update);
334 335

  pdu->rx_indication_rel8.timing_advance = timing_advance_update;
336 337 338 339 340 341 342 343 344 345 346 347

  // estimate UL_CQI for MAC (from antenna port 0 only)
  // int SNRtimes10 = dB_fixed_times10(gNB->pusch_vars[UE_id]->ulsch_power[0]) - 300;//(10*gNB->measurements.n0_power_dB[0]);

  // if      (SNRtimes10 < -640) pdu->rx_indication_rel8.ul_cqi=0;
  // else if (SNRtimes10 >  635) pdu->rx_indication_rel8.ul_cqi=255;
  // else                        pdu->rx_indication_rel8.ul_cqi=(640+SNRtimes10)/5;

  // LOG_D(PHY,"[PUSCH %d] Frame %d Subframe %d Filling RX_indication with SNR %d (%d), timing_advance %d (update %d)\n",
  // harq_pid,frame,slot_rx,SNRtimes10,pdu->rx_indication_rel8.ul_cqi,pdu->rx_indication_rel8.timing_advance,
  // timing_advance_update);

348
  gNB->UL_INFO.rx_ind.rx_indication_body.number_of_pdus++;
349 350 351 352 353
  // gNB->UL_INFO.rx_ind.sfn_sf = frame<<4 | slot_rx;

  // pthread_mutex_unlock(&gNB->UL_INFO_mutex);
}

354 355
void nr_fill_crc_indication (PHY_VARS_gNB *gNB, int frame, int slot_rx, int UE_id, uint8_t crc_flag){
  // pthread_mutex_lock(&gNB->UL_INFO_mutex);
356
  // nfapi_crc_indication_pdu_t *pdu = &gNB->UL_INFO.crc_ind.crc_indication_body.crc_pdu_list[gNB->UL_INFO.crc_ind.crc_indication_body.number_of_crcs];
357 358 359 360 361 362 363 364 365 366 367 368 369
  // gNB->UL_INFO.crc_ind.sfn_sf                         = frame<<4 | subframe;
  // gNB->UL_INFO.crc_ind.header.message_id              = NFAPI_CRC_INDICATION;
  // gNB->UL_INFO.crc_ind.crc_indication_body.tl.tag     = NFAPI_CRC_INDICATION_BODY_TAG;
  // pdu->instance_length = 0;     // don't know what to do with this
  // //  pdu->rx_ue_information.handle                       = handle;
  // pdu->rx_ue_information.tl.tag                       = NFAPI_RX_UE_INFORMATION_TAG;
  // pdu->rx_ue_information.rnti                         = gNB->ulsch[UE_id]->rnti;
  // pdu->crc_indication_rel8.tl.tag                     = NFAPI_CRC_INDICATION_REL8_TAG;
  // pdu->crc_indication_rel8.crc_flag                   = crc_flag;
  gNB->UL_INFO.crc_ind.crc_indication_body.number_of_crcs++;
  //LOG_D(PHY, "%s() rnti:%04x crcs:%d crc_flag:%d\n", __FUNCTION__, pdu->rx_ue_information.rnti, gNB->UL_INFO.crc_ind.crc_indication_body.number_of_crcs, crc_flag);
  // pthread_mutex_unlock(&gNB->UL_INFO_mutex);
}
370

371
void phy_procedures_gNB_common_RX(PHY_VARS_gNB *gNB, int frame_rx, int slot_rx) {
372 373

  uint8_t symbol;
374
  unsigned char aa;
375 376

  for(symbol = 0; symbol < NR_SYMBOLS_PER_SLOT; symbol++) {
377 378 379 380 381 382
    // nr_slot_fep_ul(gNB, symbol, proc->slot_rx, 0, 0);
    for (aa = 0; aa < gNB->frame_parms.nb_antennas_rx; aa++) {
      nr_slot_fep_ul(&gNB->frame_parms,
                     gNB->common_vars.rxdata[aa],
                     gNB->common_vars.rxdataF[aa],
                     symbol,
383
                     slot_rx,
384 385 386
                     0,
                     0);
    }
387
  }
388 389 390

}

391
void phy_procedures_gNB_uespec_RX(PHY_VARS_gNB *gNB, int frame_rx, int slot_rx) {
392

393
  LOG_D(PHY,"phy_procedures_gNB_uespec_RX frame %d, slot %d\n",frame_rx,slot_rx);
394

395 396
  for (int ULSCH_id=0;ULSCH_id<NUMBER_OF_NR_ULSCH_MAX;ULSCH_id++) {
    NR_gNB_ULSCH_t *ulsch = gNB->ulsch[ULSCH_id];
397

398 399 400 401
    if (ulsch->rnti > 0) {
      uint8_t harq_pid = ulsch->harq_process_id[slot_rx];
      uint8_t symbol_start = ulsch->harq_processes[harq_pid]->ulsch_pdu.ulsch_pdu_rel15.start_symbol;
      uint8_t symbol_end = symbol_start + ulsch->harq_processes[harq_pid]->ulsch_pdu.ulsch_pdu_rel15.number_symbols;
cig's avatar
cig committed
402
      
403 404 405 406 407 408 409 410
      for(uint8_t symbol = symbol_start; symbol < symbol_end; symbol++) {
	nr_rx_pusch(gNB, ULSCH_id, frame_rx, slot_rx, symbol, harq_pid);
      }
      //LOG_M("rxdataF_comp.m","rxF_comp",gNB->pusch_vars[0]->rxdataF_comp[0],6900,1,1);
      //LOG_M("rxdataF_ext.m","rxF_ext",gNB->pusch_vars[0]->rxdataF_ext[0],6900,1,1);
      nr_ulsch_procedures(gNB, frame_rx, slot_rx, ULSCH_id, harq_pid);
      nr_fill_rx_indication(gNB, frame_rx, slot_rx, ULSCH_id, harq_pid);  // indicate SDU to MAC
      nr_fill_crc_indication(gNB, frame_rx, slot_rx, ULSCH_id, 0);
411 412
    }
  }
413
}