Skip to content

O
OpenXG-RAN
Commit 2e1dfb5b authored by Robert Schmidt's avatar Robert Schmidt
Browse files
Options

place oai_exit test after wait_on_condition() in threads

parent c56b5af0
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
targets/RT/USER/lte-enb.c
View file @ 2e1dfb5b
...@@ -783,10 +783,10 @@ static void* eNB_thread_prach( void* param ) { ...@@ -783,10 +783,10 @@ static void* eNB_thread_prach( void* param ) {
while (!oai_exit) { while (!oai_exit) {
if (oai_exit) break;
if (wait_on_condition(&proc->mutex_prach,&proc->cond_prach,&proc->instance_cnt_prach,"eNB_prach_thread") < 0) break; if (wait_on_condition(&proc->mutex_prach,&proc->cond_prach,&proc->instance_cnt_prach,"eNB_prach_thread") < 0) break;
if (oai_exit) break;
LOG_D(PHY,"Running eNB prach procedures\n"); LOG_D(PHY,"Running eNB prach procedures\n");
prach_procedures(eNB prach_procedures(eNB
...@@ -824,10 +824,10 @@ static void* eNB_thread_prach_br( void* param ) { ...@@ -824,10 +824,10 @@ static void* eNB_thread_prach_br( void* param ) {
while (!oai_exit) { while (!oai_exit) {
if (oai_exit) break;
if (wait_on_condition(&proc->mutex_prach_br,&proc->cond_prach_br,&proc->instance_cnt_prach_br,"eNB_prach_thread_br") < 0) break; if (wait_on_condition(&proc->mutex_prach_br,&proc->cond_prach_br,&proc->instance_cnt_prach_br,"eNB_prach_thread_br") < 0) break;
if (oai_exit) break;
LOG_D(PHY,"Running eNB prach procedures for BL/CE UEs\n"); LOG_D(PHY,"Running eNB prach procedures for BL/CE UEs\n");
prach_procedures(eNB,1); prach_procedures(eNB,1);
......
targets/RT/USER/lte-ru.c
View file @ 2e1dfb5b
...@@ -1080,8 +1080,8 @@ static void* ru_thread_prach( void* param ) { ...@@ -1080,8 +1080,8 @@ static void* ru_thread_prach( void* param ) {
while (!oai_exit) { while (!oai_exit) {
if (oai_exit) break;
if (wait_on_condition(&proc->mutex_prach,&proc->cond_prach,&proc->instance_cnt_prach,"ru_prach_thread") < 0) break; if (wait_on_condition(&proc->mutex_prach,&proc->cond_prach,&proc->instance_cnt_prach,"ru_prach_thread") < 0) break;
if (oai_exit) break;
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_RU_PRACH_RX, 1 ); VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME( VCD_SIGNAL_DUMPER_FUNCTIONS_PHY_RU_PRACH_RX, 1 );
if (ru->eNB_list[0]){ if (ru->eNB_list[0]){
prach_procedures( prach_procedures(
...@@ -1130,8 +1130,8 @@ static void* ru_thread_prach_br( void* param ) { ...@@ -1130,8 +1130,8 @@ static void* ru_thread_prach_br( void* param ) {
while (!oai_exit) { while (!oai_exit) {
if (oai_exit) break;
if (wait_on_condition(&proc->mutex_prach_br,&proc->cond_prach_br,&proc->instance_cnt_prach_br,"ru_prach_thread_br") < 0) break; if (wait_on_condition(&proc->mutex_prach_br,&proc->cond_prach_br,&proc->instance_cnt_prach_br,"ru_prach_thread_br") < 0) break;
if (oai_exit) break;
rx_prach(NULL, rx_prach(NULL,
ru, ru,
NULL, NULL,
......
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