Add pseudo-code in pf_dl()

openair2/LAYER2/NR_MAC_gNB/gNB_scheduler_dlsch.c

@@ -506,10 +506,22 @@ void pf_dl(module_id_t module_id,
            int max_num_ue) {
 
     const int UE_id = 0;
-  const int CC_id = 0;
+    NR_UE_sched_ctrl_t *sched_ctrl = &UE_info->UE_sched_ctrl[UE_id];
+    const int current_harq_pid = sched_ctrl->current_harq_pid;
+    NR_UE_harq_t *harq = &sched_ctrl->harq_processes[current_harq_pid];
+    NR_UE_ret_info_t *retInfo = &sched_ctrl->retInfo[current_harq_pid];
+    const uint16_t bwpSize = NRRIV2BW(sched_ctrl->active_bwp->bwp_Common->genericParameters.locationAndBandwidth, 275);
+    int rbStart = NRRIV2PRBOFFSET(sched_ctrl->active_bwp->bwp_Common->genericParameters.locationAndBandwidth, 275);
 
+    /* Loop UE_info->list to check retransmission */
+    for (int UE_id = UE_info->list.head; UE_id >= 0; UE_id = UE_info->list.next[UE_id]) {
       NR_UE_sched_ctrl_t *sched_ctrl = &UE_info->UE_sched_ctrl[UE_id];
       const uint16_t rnti = UE_info->rnti[UE_id];
+      /* Calculate Throughput */
+
+
+      /* retransmission */
+      if (harq->round != 0) {
 
         /* Find a free CCE */
         const int target_ss = NR_SearchSpace__searchSpaceType_PR_ue_Specific;
@@ -546,14 +558,7 @@ void pf_dl(module_id_t module_id,
 
         AssertFatal(sched_ctrl->pucch_sched_idx >= 0, "no uplink slot for PUCCH found!\n");
 
-  uint8_t *vrb_map = RC.nrmac[module_id]->common_channels[CC_id].vrb_map;
-  const int current_harq_pid = sched_ctrl->current_harq_pid;
-  NR_UE_harq_t *harq = &sched_ctrl->harq_processes[current_harq_pid];
-  NR_UE_ret_info_t *retInfo = &sched_ctrl->retInfo[current_harq_pid];
-  const uint16_t bwpSize = NRRIV2BW(sched_ctrl->active_bwp->bwp_Common->genericParameters.locationAndBandwidth, 275);
-  int rbStart = NRRIV2PRBOFFSET(sched_ctrl->active_bwp->bwp_Common->genericParameters.locationAndBandwidth, 275);
-
-  if (harq->round != 0) { /* retransmission */
+        /* Allocate retransmission */
         sched_ctrl->time_domain_allocation = retInfo->time_domain_allocation;
 
         /* ensure that there is a free place for RB allocation */
@@ -582,6 +587,57 @@ void pf_dl(module_id_t module_id,
         sched_ctrl->mcs = retInfo->mcs;
         sched_ctrl->numDmrsCdmGrpsNoData = retInfo->numDmrsCdmGrpsNoData;
       } else {
+       /* Check DL buffer */
+
+       /* Calculate coeff */
+
+       /* Create UE_sched list for transmission*/
+
+      }
+    }
+
+    /* Loop UE_sched to find max coeff and allocate transmission */
+    //while(n_rb_sched > 0 && UE_sched.head >= 0){
+    if (harq->round == 0) { // temp
+
+      /* Find max coeff from UE_sched*/
+
+      /* Find a free CCE */
+      const int target_ss = NR_SearchSpace__searchSpaceType_PR_ue_Specific;
+      sched_ctrl->search_space = get_searchspace(sched_ctrl->active_bwp, target_ss);
+      uint8_t nr_of_candidates;
+      find_aggregation_candidates(&sched_ctrl->aggregation_level,
+                                  &nr_of_candidates,
+                                  sched_ctrl->search_space);
+      sched_ctrl->coreset = get_coreset(sched_ctrl->active_bwp, sched_ctrl->search_space, 1 /* dedicated */);
+      int cid = sched_ctrl->coreset->controlResourceSetId;
+      const uint16_t Y = UE_info->Y[UE_id][cid][slot];
+      const int m = UE_info->num_pdcch_cand[UE_id][cid];
+      sched_ctrl->cce_index = allocate_nr_CCEs(RC.nrmac[module_id],
+                                               sched_ctrl->active_bwp,
+                                               sched_ctrl->coreset,
+                                               sched_ctrl->aggregation_level,
+                                               Y,
+                                               m,
+                                               nr_of_candidates);
+      if (sched_ctrl->cce_index < 0) {
+          LOG_E(MAC, "%s(): could not find CCE for UE %d\n", __func__, UE_id);
+          return;
+      }
+      UE_info->num_pdcch_cand[UE_id][cid]++;
+
+      /* Find PUCCH occasion */
+      nr_acknack_scheduling(module_id,
+                            UE_id,
+                            frame,
+                            slot,
+                            num_slots_per_tdd,
+                            &sched_ctrl->pucch_sched_idx,
+                            &sched_ctrl->pucch_occ_idx);
+
+      AssertFatal(sched_ctrl->pucch_sched_idx >= 0, "no uplink slot for PUCCH found!\n");
+
+      /* Allocate transmission */
       // Time-domain allocation
       sched_ctrl->time_domain_allocation = 2;
 
@@ -615,13 +671,15 @@ void pf_dl(module_id_t module_id,
       } while (rbStart + rbSize < bwpSize && rballoc_mask[rbStart + rbSize] && TBS < sched_ctrl->num_total_bytes);
       sched_ctrl->rbSize = rbSize;
       sched_ctrl->rbStart = rbStart;
-  }
+      n_rb_sched -= sched_ctrl->rbSize;
 
       /* mark the corresponding RBs as used */
       for (int rb = 0; rb < sched_ctrl->rbSize; rb++) {
-    vrb_map[rb + sched_ctrl->rbStart] = 1;
+          //vrb_map[rb + sched_ctrl->rbStart] = 1;
           rballoc_mask[rb + sched_ctrl->rbStart] = 0;
       }
+    }
+
 }
 
 void nr_simple_dlsch_preprocessor(module_id_t module_id,