Commit 0a0a90fc authored by Hongzhi's avatar Hongzhi

adding one more rx thread

parent 799f12f0
...@@ -1224,8 +1224,8 @@ if (harq_process->C>1) { // wakeup worker if more than 1 segment ...@@ -1224,8 +1224,8 @@ if (harq_process->C>1) { // wakeup worker if more than 1 segment
} else } else
{ {
LOG_E( PHY, "[SCHED][UE %d] UE dlsch td thread busy (IC %d)!!\n", phy_vars_ue->Mod_id, proc->instance_cnt_dlsch_td); LOG_E( PHY, "[SCHED][UE %d] UE dlsch td thread busy (IC %d)!!\n", phy_vars_ue->Mod_id, proc->instance_cnt_dlsch_td);
if (proc->instance_cnt_dlsch_td > 2) if (proc->instance_cnt_dlsch_td > 4)
exit_fun("instance_cnt_dlsch_td > 2"); exit_fun("instance_cnt_dlsch_td > 4");
} }
//AssertFatal(pthread_cond_signal(&proc->cond_slot1_dl_processing) ==0 ,""); //AssertFatal(pthread_cond_signal(&proc->cond_slot1_dl_processing) ==0 ,"");
AssertFatal(pthread_mutex_unlock(&proc->mutex_dlsch_td) ==0,""); AssertFatal(pthread_mutex_unlock(&proc->mutex_dlsch_td) ==0,"");
...@@ -1257,8 +1257,8 @@ if (harq_process->C>1) { // wakeup worker if more than 1 segment ...@@ -1257,8 +1257,8 @@ if (harq_process->C>1) { // wakeup worker if more than 1 segment
} else } else
{ {
LOG_E( PHY, "[SCHED][UE %d] UE dlsch td thread 1 busy (IC %d)!!\n", phy_vars_ue->Mod_id, proc->instance_cnt_dlsch_td1); LOG_E( PHY, "[SCHED][UE %d] UE dlsch td thread 1 busy (IC %d)!!\n", phy_vars_ue->Mod_id, proc->instance_cnt_dlsch_td1);
if (proc->instance_cnt_dlsch_td1 > 2) if (proc->instance_cnt_dlsch_td1 > 4)
exit_fun("instance_cnt_dlsch_td1 > 2"); exit_fun("instance_cnt_dlsch_td1 > 4");
} }
AssertFatal(pthread_mutex_unlock(&proc->mutex_dlsch_td1) ==0,""); AssertFatal(pthread_mutex_unlock(&proc->mutex_dlsch_td1) ==0,"");
...@@ -2580,7 +2580,7 @@ uint32_t dlsch_decoding_2thread0(void *arg) ...@@ -2580,7 +2580,7 @@ uint32_t dlsch_decoding_2thread0(void *arg)
#endif #endif
#ifdef UE_DLSCH_PARALLELISATION #ifdef UE_DLSCH_PARALLELISATION
#define FIFO_PRIORITY 38 #define FIFO_PRIORITY 39
uint32_t dlsch_decoding_2thread1(void *arg) uint32_t dlsch_decoding_2thread1(void *arg)
{ {
static __thread int UE_dlsch_td_retval1; static __thread int UE_dlsch_td_retval1;
......
...@@ -73,8 +73,8 @@ ...@@ -73,8 +73,8 @@
#define openair_free(y,x) free((y)) #define openair_free(y,x) free((y))
#define PAGE_SIZE 4096 #define PAGE_SIZE 4096
#define RX_NB_TH_MAX 3 #define RX_NB_TH_MAX 4
#define RX_NB_TH 3 #define RX_NB_TH 4
//#ifdef SHRLIBDEV //#ifdef SHRLIBDEV
......
...@@ -37,8 +37,8 @@ ...@@ -37,8 +37,8 @@
#include "types.h" #include "types.h"
//#include "defs.h" //#include "defs.h"
#define RX_NB_TH_MAX 3 #define RX_NB_TH_MAX 4
#define RX_NB_TH 3 #define RX_NB_TH 4
#define LTE_SLOTS_PER_SUBFRAME 2 #define LTE_SLOTS_PER_SUBFRAME 2
......
...@@ -3477,7 +3477,7 @@ int ue_pdcch_procedures(uint8_t eNB_id,PHY_VARS_UE *ue,UE_rxtx_proc_t *proc,uint ...@@ -3477,7 +3477,7 @@ int ue_pdcch_procedures(uint8_t eNB_id,PHY_VARS_UE *ue,UE_rxtx_proc_t *proc,uint
else { else {
#ifdef DEBUG_PHY_PROC #ifdef DEBUG_PHY_PROC
LOG_I(PHY,"[UE %d] frame %d, nr_tti_rx %d: received DCI %d with RNTI=%x (C-RNTI:%x, CBA_RNTI %x) and format %d!\n",ue->Mod_id,frame_rx,nr_tti_rx,i,dci_alloc_rx[i].rnti, LOG_D(PHY,"[UE %d] frame %d, nr_tti_rx %d: received DCI %d with RNTI=%x (C-RNTI:%x, CBA_RNTI %x) and format %d!\n",ue->Mod_id,frame_rx,nr_tti_rx,i,dci_alloc_rx[i].rnti,
ue->pdcch_vars[ue->current_thread_id[nr_tti_rx]][eNB_id]->crnti, ue->pdcch_vars[ue->current_thread_id[nr_tti_rx]][eNB_id]->crnti,
ue->ulsch[eNB_id]->cba_rnti[0], ue->ulsch[eNB_id]->cba_rnti[0],
dci_alloc_rx[i].format); dci_alloc_rx[i].format);
......
...@@ -897,7 +897,7 @@ void *UE_thread(void *arg) { ...@@ -897,7 +897,7 @@ void *UE_thread(void *arg) {
g_ue_rx_thread_busy++; g_ue_rx_thread_busy++;
#endif #endif
LOG_E( PHY, "[SCHED][UE %d] !! UE RX thread busy (IC %d)!!\n", UE->Mod_id, proc->instance_cnt_rxtx); LOG_E( PHY, "[SCHED][UE %d] !! UE RX thread busy (IC %d)!!\n", UE->Mod_id, proc->instance_cnt_rxtx);
if (proc->instance_cnt_rxtx > 2) if (proc->instance_cnt_rxtx > 4)
{ {
char exit_fun_string[256]; char exit_fun_string[256];
sprintf(exit_fun_string,"[SCHED][UE %d] !!! UE instance_cnt_rxtx > 2 (IC %d) (Proc %d)!!", sprintf(exit_fun_string,"[SCHED][UE %d] !!! UE instance_cnt_rxtx > 2 (IC %d) (Proc %d)!!",
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment