Fixed blocking bug

executables/nr-ue.c

@@ -767,6 +767,7 @@ void *UE_thread(void *arg) {
       memset(txp[i], 0, writeBlockSize);
 
     nbSlotProcessing++;
+    LOG_D(PHY,"Number of slots being processed at the moment: %d\n",nbSlotProcessing);
     pushTpool(&(get_nrUE_params()->Tpool), msgToPush);
 
   } // while !oai_exit

executables/nr-uesoftmodem.c

@@ -220,8 +220,8 @@ void init_tpools(uint8_t nun_dlsch_threads) {
     memcpy(params,"N",1);
   }
   else {
-    params = calloc(1,(RX_NB_TH*3)+1);
-    for (int i=0; i<RX_NB_TH; i++) {
+    params = calloc(1,(RX_NB_TH*NB_TH_SLOT*3)+1);
+    for (int i=0; i<RX_NB_TH*NB_TH_SLOT; i++) {
       memcpy(params+(i*3),"-1,",3);
     }
   }

openair1/PHY/defs_common.h

@@ -75,6 +75,7 @@
 
 #define RX_NB_TH_MAX 2
 #define RX_NB_TH 1
+#define NB_TH_SLOT 2
 #define RX_NB_TH_DL 14
 
 #define LTE_SLOTS_PER_SUBFRAME 2