NR UE: enable concurrent UL slot processing

This commit introduces support for concurrent UL slot processing

Key changes:
 - Increased number of UL actors from 1 to 2
 - fix several issues related to writing to global variables inside
   processSlotTX
 - Ensure in-order execution of if_module calls by utilizing the
   preexisting dynamic_barrier structure.

executables/nr-ue.c

@@ -104,7 +104,7 @@ static void *NRUE_phy_stub_standalone_pnf_task(void *arg);
 static void start_process_slot_tx(void* arg) {
   notifiedFIFO_elt_t *newTx = arg;
   nr_rxtx_thread_data_t *curMsgTx = NotifiedFifoData(newTx);
-  pushNotifiedFIFO(&curMsgTx->UE->ul_actor.fifo, newTx);
+  pushNotifiedFIFO(&curMsgTx->UE->ul_actors[curMsgTx->proc.nr_slot_tx % NUM_UL_ACTORS].fifo, newTx);
 }
 
 static size_t dump_L1_UE_meas_stats(PHY_VARS_NR_UE *ue, char *output, size_t max_len)
@@ -585,6 +585,7 @@ void processSlotTX(void *arg)
         UE->if_inst->sl_indication(&sl_indication);
         stop_meas(&UE->ue_ul_indication_stats);
       }
+      dynamic_barrier_join(rxtxD->next_barrier);
 
       if (phy_data.sl_tx_action) {
 
@@ -611,12 +612,14 @@ void processSlotTX(void *arg)
         UE->if_inst->ul_indication(&ul_indication);
         stop_meas(&UE->ue_ul_indication_stats);
       }
+      dynamic_barrier_join(rxtxD->next_barrier);
 
       phy_procedures_nrUE_TX(UE, proc, &phy_data);
     }
+  } else {
+    dynamic_barrier_join(rxtxD->next_barrier);
   }
   RU_write(rxtxD, sl_tx_action);
-  dynamic_barrier_join(rxtxD->next_barrier);
   TracyCZoneEnd(ctx);
 }
 
@@ -656,7 +659,9 @@ static int handle_sync_req_from_mac(PHY_VARS_NR_UE *UE)
     for (int i = 0; i < NUM_DL_ACTORS; i++) {
       flush_actor(UE->dl_actors + i);
     }
-    flush_actor(&UE->ul_actor);
+    for (int i = 0; i < NUM_UL_ACTORS; i++) {
+      flush_actor(UE->ul_actors + i);
+    }
 
     clean_UE_harq(UE);
     UE->is_synchronized = 0;
@@ -1186,7 +1191,6 @@ void *UE_thread(void *arg)
     curMsgTx->proc.timestamp_tx = writeTimestamp;
     curMsgTx->UE = UE;
     curMsgTx->proc.nr_slot_tx_offset = nr_slot_tx_offset;
-
     int slot = curMsgTx->proc.nr_slot_tx;
     int slot_and_frame = slot + curMsgTx->proc.frame_tx * UE->frame_parms.slots_per_frame;
     int next_tx_slot_and_frame = absolute_slot + duration_rx_to_tx + 1;

executables/nr-uesoftmodem.c

@@ -508,7 +508,9 @@ int main(int argc, char **argv)
         for (int i = 0; i < NUM_DL_ACTORS; i++) {
           init_actor(&UE[CC_id]->dl_actors[i], "DL_", -1);
         }
-        init_actor(&UE[CC_id]->ul_actor, "UL_", -1);
+        for (int i = 0; i < NUM_UL_ACTORS; i++) {
+          init_actor(&UE[CC_id]->ul_actors[i], "UL_", -1);
+        }
         init_nr_ue_vars(UE[CC_id], inst);
 
         if (UE[CC_id]->sl_mode) {
@@ -578,7 +580,9 @@ int main(int argc, char **argv)
     for (int CC_id = 0; CC_id < MAX_NUM_CCs; CC_id++) {
       PHY_VARS_NR_UE *phy_vars = PHY_vars_UE_g[0][CC_id];
       if (phy_vars) {
-        shutdown_actor(&phy_vars->ul_actor);
+        for (int i = 0; i < NUM_UL_ACTORS; i++) {
+          shutdown_actor(&phy_vars->ul_actors[i]);
+        }
         for (int i = 0; i < NUM_DL_ACTORS; i++) {
           shutdown_actor(&phy_vars->dl_actors[i]);
         }