diff --git a/executables/nr-gnb.c b/executables/nr-gnb.c index d436828294..e4a9e4e5e6 100644 --- a/executables/nr-gnb.c +++ b/executables/nr-gnb.c @@ -475,7 +475,8 @@ void init_gNB_Tpool(int inst) { PHY_VARS_gNB *gNB; gNB = RC.gNB[inst]; gNB_L1_proc_t *proc = &gNB->proc; - + // PUSCH symbols per thread need to be calculated by how many threads we have + gNB->num_pusch_symbols_per_thread = 1; // ULSCH decoding threadpool initTpool(get_softmodem_params()->threadPoolConfig, &gNB->threadPool, cpumeas(CPUMEAS_GETSTATE)); // ULSCH decoder result FIFO diff --git a/openair1/PHY/NR_TRANSPORT/nr_ulsch_demodulation.c b/openair1/PHY/NR_TRANSPORT/nr_ulsch_demodulation.c index 309aab6256..3fa192f7cb 100644 --- a/openair1/PHY/NR_TRANSPORT/nr_ulsch_demodulation.c +++ b/openair1/PHY/NR_TRANSPORT/nr_ulsch_demodulation.c @@ -1931,7 +1931,7 @@ int nr_rx_pusch_tp(PHY_VARS_gNB *gNB, while (gNB->nbSymb > 0) { - notifiedFIFO_elt_t *req=pullTpool(&gNB->respPuschSymb, &gNB->threadPool); + notifiedFIFO_elt_t *req = pullTpool(&gNB->respPuschSymb, &gNB->threadPool); gNB->nbSymb--; delNotifiedFIFO_elt(req); }