feat(ldpc-offload-xdma): enabled task manager in nr-softmodem + enabled decoding timer for FPGA

common/utils/thread_pool/task_manager.h

 #ifndef TASK_MANAGER_WORKING_STEALING_H
 #define TASK_MANAGER_WORKING_STEALING_H 
 
-//#define TASK_MANAGER
+#define TASK_MANAGER
 //#define FIBONACCI
 //#define OMP_TP 1
 

executables/nr-gnb.c

@@ -541,6 +541,10 @@ void init_eNB_afterRU(void) {
      */
     //init_precoding_weights(RC.gNB[inst]);
     init_gNB_Tpool(inst);
+#ifdef TASK_MANAGER
+    init_task_manager(&gNB->man, gNB->threadPool.nbThreads);
+#endif
+
   }
 
 }

openair1/PHY/NR_TRANSPORT/nr_ulsch_decoding.c

@@ -67,7 +67,7 @@
 #include <omp.h>
 
 #include "PHY/CODING/nrLDPC_decoder_offload_xdma/nrLDPC_decoder_offload_xdma.h" // XDMA header file
-#define NUM_THREADS_PREPARE 5
+#define NUM_THREADS_PREPARE 8
 
 static inline
 int64_t time_now_us(void)
@@ -1041,11 +1041,11 @@ uint32_t nr_ulsch_decoding(PHY_VARS_gNB *phy_vars_gNB,
     //==================================================================
     // Xilinx FPGA LDPC decoding function -> nrLDPC_decoder_FPGA_PYM()
     //==================================================================
-    //start_meas(&phy_vars_gNB->ulsch_ldpc_fpga_time_stats);
+    start_meas(&phy_vars_gNB->ulsch_ldpc_decoding_stats);
     nrLDPC_decoder_FPGA_PYM((int8_t *)&multi_indata[0], (int8_t *)&multi_outdata[0], dec_conf);
     // printf("Xilinx FPGA -> CB = %d\n", harq_process->C);
     // nrLDPC_decoder_FPGA_PYM((int8_t *)&temp_multi_indata[0], (int8_t *)&multi_outdata[0], dec_conf);
-    //stop_meas(&phy_vars_gNB->ulsch_ldpc_fpga_time_stats);
+    stop_meas(&phy_vars_gNB->ulsch_ldpc_decoding_stats);
 
     for (r = 0; r < harq_process->C; r++) {
       // -----------------------------------------------------------------------------------------------

openair1/SIMULATION/NR_PHY/ulsim.c

@@ -1662,9 +1662,9 @@ int main(int argc, char *argv[])
       printStatIndent2(&UE->ulsch_ldpc_encoding_stats,"ULSCH LDPC encoder time");
       printStatIndent2(&UE->ulsch_rate_matching_stats,"ULSCH rate-matching time");
       printStatIndent2(&UE->ulsch_interleaving_stats,"ULSCH interleaving time");
-      //printStatIndent2(&gNB->ulsch_deinterleaving_stats,"ULSCH deinterleaving");
-      //printStatIndent2(&gNB->ulsch_rate_unmatching_stats,"ULSCH rate matching rx");
-      //printStatIndent2(&gNB->ulsch_ldpc_decoding_stats,"ULSCH ldpc decoding");
+      printStatIndent2(&gNB->ulsch_deinterleaving_stats,"ULSCH deinterleaving");
+      printStatIndent2(&gNB->ulsch_rate_unmatching_stats,"ULSCH rate matching rx");
+      printStatIndent2(&gNB->ulsch_ldpc_decoding_stats,"ULSCH ldpc decoding");
       printStatIndent(&gNB->rx_srs_stats,"RX SRS time");
       printStatIndent2(&gNB->generate_srs_stats,"Generate SRS sequence time");
       printStatIndent2(&gNB->get_srs_signal_stats,"Get SRS signal time");