Calculate throughput & Initial static TBS

openair2/LAYER2/NR_MAC_gNB/gNB_scheduler_ulsch.c

@@ -529,6 +529,8 @@ int8_t select_ul_harq_pid(NR_UE_sched_ctrl_t *sched_ctrl) {
   return -1;
 }
 
+float ul_thr_ue[MAX_MOBILES_PER_GNB];
+
 void pf_ul(module_id_t module_id,
            frame_t frame,
            sub_frame_t slot,
@@ -551,6 +553,11 @@ void pf_ul(module_id_t module_id,
     const uint16_t bwpSize = NRRIV2BW(sched_ctrl->active_ubwp->bwp_Common->genericParameters.locationAndBandwidth,275);
 
     /* Calculate throughput */
+    const float a = 0.0005f; // corresponds to 200ms window
+    const uint32_t b = UE_info->mac_stats[UE_id].ulsch_current_bytes;
+    ul_thr_ue[UE_id] = (1 - a) * ul_thr_ue[UE_id] + a * b;
+    LOG_D(MAC,"%4d.%2d %s() static TBS %d, ul_thr_ue[%d] %f\n",
+          frame, slot, __func__, b, UE_id, ul_thr_ue[UE_id]);
 
     /* RETRANSMISSION: Check retransmission */
 
@@ -752,6 +759,9 @@ void nr_schedule_ulsch(module_id_t module_id,
     if (sched_pusch->rbSize <= 0)
       continue;
 
+    /* subframe == 6, sched_pusch->rbSize > 0, initial static TBS size */
+    UE_info->mac_stats[UE_id].ulsch_current_bytes = 0;
+
     uint16_t rnti = UE_info->rnti[UE_id];
 
     int8_t harq_id = select_ul_harq_pid(sched_ctrl);