remove unused global queues, dead code

openair1/SIMULATION/LTE_PHY/dlsim.c

@@ -1263,9 +1263,7 @@ int main(int argc, char **argv) {
 
   L1_rxtx_proc_t *proc_eNB = &eNB->proc.L1_proc;
   proc_eNB->threadPool = (tpool_t *)malloc(sizeof(tpool_t));
-  proc_eNB->respDecode=(notifiedFIFO_t*) malloc(sizeof(notifiedFIFO_t));
   initTpool("n", proc_eNB->threadPool, true);
-  initNotifiedFIFO(proc_eNB->respDecode);
 
   proc_eNB->frame_tx=0;
 

openair1/SIMULATION/LTE_PHY/ulsim.c

@@ -795,9 +795,7 @@ int main(int argc, char **argv) {
   proc_rxtx_ue->subframe_tx = proc_rxtx->subframe_rx;
   proc_rxtx_ue->subframe_rx = (proc_rxtx->subframe_tx+6)%10;
   proc_rxtx->threadPool = (tpool_t *)malloc(sizeof(tpool_t));
-  proc_rxtx->respDecode=(notifiedFIFO_t*) malloc(sizeof(notifiedFIFO_t));
   initTpool("n", proc_rxtx->threadPool, true);
-  initNotifiedFIFO(proc_rxtx->respDecode);
 
   printf("Init UL hopping UE\n");
   init_ul_hopping(&UE->frame_parms);

openair1/SIMULATION/NR_PHY/dlsim.c

@@ -965,12 +965,9 @@ int main(int argc, char **argv)
   //NR_COMMON_channels_t *cc = RC.nrmac[0]->common_channels;
   int ret = 1;
   initNamedTpool(gNBthreads, &gNB->threadPool, true, "gNB-tpool");
-  initNotifiedFIFO(&gNB->L1_tx_free);
-  initNotifiedFIFO(&gNB->L1_tx_filled);
   initNotifiedFIFO(&gNB->L1_tx_out);
   // we create 2 threads for L1 tx processing
-  notifiedFIFO_elt_t *msgL1Tx = newNotifiedFIFO_elt(sizeof(processingData_L1tx_t),0,&gNB->L1_tx_free,processSlotTX);
-  processingData_L1tx_t *msgDataTx = (processingData_L1tx_t *)NotifiedFifoData(msgL1Tx);
+  processingData_L1tx_t *msgDataTx = malloc(sizeof(processingData_L1tx_t));
   init_DLSCH_struct(gNB, msgDataTx);
   msgDataTx->slot = slot;
   msgDataTx->frame = frame;
@@ -1091,7 +1088,6 @@ int main(int argc, char **argv)
         Sched_INFO->frame = frame;
         Sched_INFO->slot = slot;
         Sched_INFO->UL_dci_req.numPdus = 0;
-        pushNotifiedFIFO(&gNB->L1_tx_free,msgL1Tx);
         nr_schedule_response(Sched_INFO);
 
         /* PTRS values for DLSIM calculations   */

openair1/SIMULATION/NR_PHY/ulschsim.c

@@ -391,7 +391,6 @@ int main(int argc, char **argv)
   //gNB_config = &gNB->gNB_config;
 
   initTpool("n", &gNB->threadPool, true);
-  initNotifiedFIFO(&gNB->respDecode);
   frame_parms = &gNB->frame_parms; //to be initialized I suppose (maybe not necessary for PBCH)
   frame_parms->N_RB_DL = N_RB_DL;
   frame_parms->N_RB_UL = N_RB_UL;

openair1/SIMULATION/NR_PHY/ulsim.c

@@ -727,14 +727,7 @@ int main(int argc, char *argv[])
   else
     initNamedTpool(gNBthreads, &gNB->threadPool, true, "gNB-tpool");
 
-  initNotifiedFIFO(&gNB->respDecode);
-
-  initNotifiedFIFO(&gNB->respPuschSymb);
-  initNotifiedFIFO(&gNB->L1_tx_free);
-  initNotifiedFIFO(&gNB->L1_tx_filled);
-  initNotifiedFIFO(&gNB->L1_tx_out);
-  notifiedFIFO_elt_t *msgL1Tx = newNotifiedFIFO_elt(sizeof(processingData_L1tx_t), 0, &gNB->L1_tx_free, NULL);
-  processingData_L1tx_t *msgDataTx = (processingData_L1tx_t *)NotifiedFifoData(msgL1Tx);
+  processingData_L1tx_t *msgDataTx = malloc(sizeof(processingData_L1tx_t));
   msgDataTx->slot = -1;
   gNB->msgDataTx = msgDataTx;
   //gNB_config = &gNB->gNB_config;
@@ -1299,7 +1292,6 @@ int main(int argc, char *argv[])
         UE_proc.gNB_id = 0;
 
         // prepare ULSCH/PUSCH reception
-        pushNotifiedFIFO(&gNB->L1_tx_free, msgL1Tx); // to unblock the process in the beginning
         nr_schedule_response(Sched_INFO);
 
         // --------- setting parameters for UE --------