diff --git a/common/utils/threadPool/thread-pool.c b/common/utils/threadPool/thread-pool.c
index a17495c91fd896ff4bcfffbfc89c48362afd49d3..b45a8fa7227141ec611b90423a8ef651f00da9cd 100644
--- a/common/utils/threadPool/thread-pool.c
+++ b/common/utils/threadPool/thread-pool.c
@@ -117,8 +117,9 @@ void initTpool(char *params,tpool_t *pool, bool performanceMeas) {
pool->allthreads->pool=pool;
//Configure the thread scheduler policy for Linux
// set the thread name for debugging
- sprintf(myThread->name,"Tpool_%d",myThread->coreID);
- threadCreate(&pool->allthreads->threadID, one_thread, (void *)pool->allthreads, Tpool, myThread->name, myThread->coreID, OAI_PRIORITY_RT);
+ sprintf(pool->allthreads->name,"Tpool_%d",pool->allthreads->coreID);
+ threadCreate(&pool->allthreads->threadID, one_thread, (void *)pool->allthreads,
+ pool->allthreads->name, pool->allthreads->coreID, OAI_PRIORITY_RT);
pool->nbThreads++;
}
diff --git a/executables/nr-gnb.c b/executables/nr-gnb.c
index c76fae828eff780157c48f056f5cbf4e7615bde7..c0571f2bc5e2eed5603d7555b3a94e195e91c9aa 100644
--- a/executables/nr-gnb.c
+++ b/executables/nr-gnb.c
@@ -272,7 +272,6 @@ static void *gNB_L1_thread_tx(void *param) {
//PHY_VARS_gNB *gNB = RC.gNB[0][proc->CC_id];
char thread_name[100];
sprintf(thread_name,"TXnp4_%d\n",&gNB->proc.L1_proc == proc ? 0 : 1);
- //thread_top_init(thread_name,1,470000,500000,500000);
//wait_sync("tx_thread");
@@ -327,7 +326,6 @@ static void *gNB_L1_thread( void *param ) {
// set default return value
gNB_thread_rxtx_status = 0;
sprintf(thread_name,"RXn_TXnp4_%d",&gNB->proc.L1_proc == proc ? 0 : 1);
- //thread_top_init(thread_name,1,850000L,1000000L,2000000L);
while (!oai_exit) {
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_gNB_PROC_RXTX0, 0 );
@@ -651,7 +649,6 @@ static void* gNB_thread_prach( void* param ) {
// set default return value
gNB_thread_prach_status = 0;
- thread_top_init("gNB_thread_prach",1,500000L,1000000L,20000000L);
while (!oai_exit) {
diff --git a/executables/nr-ru.c b/executables/nr-ru.c
index f76cada501dd31e36e2203146ad682317a964bc7..f64a92f5c2e6076f8acc5ac0f7f1259b101172ac 100644
--- a/executables/nr-ru.c
+++ b/executables/nr-ru.c
@@ -777,7 +777,6 @@ static void *ru_thread_asynch_rxtx( void *param ) {
RU_t *ru = (RU_t *)param;
RU_proc_t *proc = &ru->proc;
int subframe=0, frame=0;
- thread_top_init("ru_thread_asynch_rxtx",1,870000L,1000000L,1000000L);
// wait for top-level synchronization and do one acquisition to get timestamp for setting frame/subframe
wait_sync("ru_thread_asynch_rxtx");
// wait for top-level synchronization and do one acquisition to get timestamp for setting frame/subframe
@@ -825,7 +824,6 @@ static void *ru_thread_prach( void *param ) {
RU_proc_t *proc = (RU_proc_t *)&ru->proc;
// set default return value
ru_thread_prach_status = 0;
- thread_top_init("ru_thread_prach",1,500000L,1000000L,20000000L);
while (RC.ru_mask>0) {
usleep(1e6);
@@ -1211,7 +1209,6 @@ static void *ru_thread_tx( void *param ) {
int i = 0;
cpu_set_t cpuset;
CPU_ZERO(&cpuset);
- thread_top_init("ru_thread_tx",1,400000,500000,500000);
//CPU_SET(5, &cpuset);
//pthread_setaffinity_np(pthread_self(), sizeof(cpu_set_t), &cpuset);
//wait_sync("ru_thread_tx");
@@ -1324,7 +1321,6 @@ static void *ru_thread( void *param ) {
ru_thread_status = 0;
// set default return value
sprintf(threadname,"ru_thread %d",ru->idx);
- thread_top_init(threadname,0,870000,1000000,1000000);
LOG_I(PHY,"Starting RU %d (%s,%s),\n",ru->idx,NB_functions[ru->function],NB_timing[ru->if_timing]);
if(emulate_rf) {
@@ -1507,7 +1503,6 @@ void *ru_thread_synch(void *arg) {
static int ru_thread_synch_status;
- thread_top_init("ru_thread_synch",0,5000000,10000000,10000000);
wait_sync("ru_thread_synch");
@@ -1633,7 +1628,7 @@ void init_RU_proc(RU_t *ru) {
pthread_cond_init( &proc->cond_asynch_rxtx, NULL);
pthread_cond_init( &proc->cond_synch,NULL);
pthread_cond_init( &proc->cond_gNBs, NULL);
- threadCreate( &proc->pthread_FH, ru_thread, (void *)ru, "thread_FH", -1, OAI_PRIORITY_RT );
+ threadCreate( &proc->pthread_FH, ru_thread, (void *)ru, "thread_FH", -1, OAI_PRIORITY_RT_MAX );
if (get_thread_parallel_conf() == PARALLEL_RU_L1_SPLIT || get_thread_parallel_conf() == PARALLEL_RU_L1_TRX_SPLIT)
threadCreate( &proc->pthread_FH1, ru_thread_tx, (void *)ru, "thread_FH1", -1, OAI_PRIORITY_RT );
diff --git a/executables/nr-softmodem.c b/executables/nr-softmodem.c
index 00620febd71bf261352bcedb6521568c03b52769..f45ae385fa03989118115ee893a918ead8cc932c 100644
--- a/executables/nr-softmodem.c
+++ b/executables/nr-softmodem.c
@@ -1065,7 +1065,6 @@ int main( int argc, char **argv ) {
} // UE_id
threadCreate(&forms_thread, scope_thread, NULL, "scope", -1, OAI_PRIORITY_RT_LOW);
-
printf("Scope thread created, ret=%d\n",ret);
}
diff --git a/executables/nr-ue.c b/executables/nr-ue.c
index 6629d5155a8eb48d2af422e0d9319090386d752b..8b5d4eaed256d584009c3a6e022889d264745fcd 100644
--- a/executables/nr-ue.c
+++ b/executables/nr-ue.c
@@ -760,7 +760,7 @@ void init_UE(int nb_inst) {
mac_inst->initial_bwp_ul.N_RB = UE->frame_parms.N_RB_UL;
mac_inst->initial_bwp_ul.cyclic_prefix = UE->frame_parms.Ncp;
LOG_I(PHY,"Intializing UE Threads for instance %d (%p,%p)...\n",inst,PHY_vars_UE_g[inst],PHY_vars_UE_g[inst][0]);
- threadCreate(&threads[inst], UE_thread, (void *)UE), "UEthread", -1, OAI_PRIORITY_RT);
+ threadCreate(&threads[inst], UE_thread, (void *)UE, "UEthread", -1, OAI_PRIORITY_RT_MAX);
}
printf("UE threads created by %ld\n", gettid());
diff --git a/openair1/SCHED/ru_procedures.c b/openair1/SCHED/ru_procedures.c
index f30f09859cbd665dbe6296deb59a2a5d61f8d92a..cb892489f152f2ecfa7b2c43831017ab73225f41 100644
--- a/openair1/SCHED/ru_procedures.c
+++ b/openair1/SCHED/ru_procedures.c
@@ -44,6 +44,7 @@
#include "assertions.h"
+#include "common/utils/system.h"
#include "msc.h"
#include <time.h>
@@ -483,7 +484,7 @@ void init_feptx_thread(RU_t *ru,pthread_attr_t *attr_feptx) {
pthread_mutex_init( &proc->mutex_feptx, NULL);
pthread_cond_init( &proc->cond_feptx, NULL);
- pthread_create(&proc->pthread_feptx, attr_feptx, feptx_thread, (void*)ru);
+ threadCreate(&proc->pthread_feptx, feptx_thread, (void*)ru, "feptx", -1, OAI_PRIORITY_RT);
}
@@ -497,7 +498,7 @@ void init_fep_thread(RU_t *ru,pthread_attr_t *attr_fep) {
pthread_mutex_init( &proc->mutex_fep, NULL);
pthread_cond_init( &proc->cond_fep, NULL);
- pthread_create(&proc->pthread_fep, attr_fep, fep_thread, (void*)ru);
+ threadCreate(&proc->pthread_fep, fep_thread, (void*)ru, "fep", -1, OAI_PRIORITY_RT);
}
diff --git a/openair1/SCHED_NR/nr_ru_procedures.c b/openair1/SCHED_NR/nr_ru_procedures.c
index a0f12a7287c4498c93527acd9e370e27cfbc56c7..d0b9d3ee480c5f3ef788f4a3938bb7bcc6d9066d 100644
--- a/openair1/SCHED_NR/nr_ru_procedures.c
+++ b/openair1/SCHED_NR/nr_ru_procedures.c
@@ -180,7 +180,6 @@ static void *nr_feptx_thread(void *param) {
RU_t *ru = (RU_t *)param;
RU_proc_t *proc = &ru->proc;
- thread_top_init("nr_feptx_thread",0,870000,1000000,1000000);
while (!oai_exit) {
diff --git a/openair3/SCTP/sctp_eNB_task.c b/openair3/SCTP/sctp_eNB_task.c
index e7265d66d6485c25e74f5cf128e0a89e932001f8..60f233bc4a736cfcd97efdf5d21bf1420af1237b 100644
--- a/openair3/SCTP/sctp_eNB_task.c
+++ b/openair3/SCTP/sctp_eNB_task.c
@@ -40,6 +40,7 @@
#include <arpa/inet.h>
#include "assertions.h"
+#include "common/utils/system.h"
#include "queue.h"
#include "intertask_interface.h"
diff --git a/targets/ARCH/USRP/USERSPACE/LIB/usrp_lib.cpp b/targets/ARCH/USRP/USERSPACE/LIB/usrp_lib.cpp
index ab23d52b3a282b6aa89a12a58844702cb38c9131..8a012b39de5da4c9813ed8f0d731a42d5a820f20 100644
--- a/targets/ARCH/USRP/USERSPACE/LIB/usrp_lib.cpp
+++ b/targets/ARCH/USRP/USERSPACE/LIB/usrp_lib.cpp
@@ -299,6 +299,7 @@ static int trx_usrp_start(openair0_device *device) {
if (u_sf_mode != 2) { // not replay mode
#endif
+ uhd::set_thread_priority_safe(1.0);
usrp_state_t *s = (usrp_state_t *)device->priv;
// setup GPIO for TDD, GPIO(4) = ATR_RX
//set data direction register (DDR) to output
@@ -1038,7 +1039,6 @@ extern "C" {
<< use_mmap << std::endl;
} else {
#endif
- uhd::set_thread_priority_safe(1.0);
usrp_state_t *s = (usrp_state_t *)calloc(sizeof(usrp_state_t),1);
if (openair0_cfg[0].clock_source==gpsdo)