Improved the 'non-stop' feature
This commit is contained in:
+7
-3
@@ -567,11 +567,15 @@ void *UE_thread(void *arg) {
|
||||
pushNotifiedFIFO(&txFifo, newNotifiedFIFO_elt(sizeof(nr_rxtx_thread_data_t), TX_JOB_ID,&txFifo,processSlotTX));
|
||||
}
|
||||
|
||||
|
||||
|
||||
while (!oai_exit) {
|
||||
if (UE->lost_sync) {
|
||||
abortTpool(&(get_nrUE_params()->Tpool),RX_JOB_ID);
|
||||
notifiedFIFO_elt_t *res;
|
||||
int nb = abortTpool(&(get_nrUE_params()->Tpool),RX_JOB_ID);
|
||||
nb += abortNotifiedFIFO(&nf, RX_JOB_ID);
|
||||
LOG_I(PHY,"Number of aborted slots %d\n",nb);
|
||||
for (int i=0; i<nb+1; i++)
|
||||
pushNotifiedFIFO_nothreadSafe(&freeBlocks, newNotifiedFIFO_elt(sizeof(nr_rxtx_thread_data_t), RX_JOB_ID,&nf,processSlotRX));
|
||||
nbSlotProcessing = 0;
|
||||
UE->is_synchronized = 0;
|
||||
UE->lost_sync = 0;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user