From a702fd55b395a6b4be24e46c3318cdc6e51ab1e6 Mon Sep 17 00:00:00 2001
From: Sakthivel Velumani <sakthivel.velumani@eurecom.fr>
Date: Wed, 17 Mar 2021 14:58:06 +0100
Subject: [PATCH] Fixed blocking bug

---
 executables/nr-ue.c          | 1 +
 executables/nr-uesoftmodem.c | 4 ++--
 openair1/PHY/defs_common.h   | 1 +
 3 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/executables/nr-ue.c b/executables/nr-ue.c
index 092913c12e..1065396016 100644
--- a/executables/nr-ue.c
+++ b/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
diff --git a/executables/nr-uesoftmodem.c b/executables/nr-uesoftmodem.c
index 2477d4cd87..3b9b40001a 100644
--- a/executables/nr-uesoftmodem.c
+++ b/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);
     }
   }
diff --git a/openair1/PHY/defs_common.h b/openair1/PHY/defs_common.h
index c1f89f87eb..622a4ef0fd 100644
--- a/openair1/PHY/defs_common.h
+++ b/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