Trying a fix for realtime issue

executables/nr-gnb.c

@@ -128,6 +128,7 @@ void tx_func(void *param) {
   syncMsg->ru = gNB->RU_list[0];
   res->key = slot_tx;
   pushTpool(gNB->threadPool, res);
+  gNB->memclr_mac(gNB->Mod_id, gNB->CC_id);
 }
 
 void rx_func(void *param) {
@@ -493,6 +494,7 @@ void init_gNB(int single_thread_flag,int wait_for_sync) {
     LOG_I(PHY,"Registering with MAC interface module (after %p)\n",gNB->if_inst);
     gNB->if_inst->NR_Schedule_response   = nr_schedule_response;
     gNB->if_inst->NR_PHY_config_req      = nr_phy_config_request;
+    gNB->memclr_mac = memclr_mac;
     memset((void *)&gNB->UL_INFO,0,sizeof(gNB->UL_INFO));
     LOG_I(PHY,"Setting indication lists\n");
 

openair1/PHY/defs_gNB.h

@@ -695,6 +695,7 @@ typedef struct PHY_VARS_gNB_s {
   NR_IF_Module_t       *if_inst;
   NR_UL_IND_t          UL_INFO;
   pthread_mutex_t      UL_INFO_mutex;
+  void (*memclr_mac)(int Mod_id, int CC_id);
 
   /// NFAPI RX ULSCH information
   nfapi_nr_rx_data_pdu_t  rx_pdu_list[MAX_UL_PDUS_PER_SLOT];

openair2/NR_PHY_INTERFACE/NR_IF_Module.c

@@ -267,3 +267,9 @@ NR_IF_Module_t *NR_IF_Module_init(int Mod_id) {
 
   return nr_if_inst[Mod_id];
 }
+
+void memclr_mac(int Mod_id, int CC_id) {
+
+  nfapi_nr_dl_tti_request_pdu_t *dl_tti_pdu_list = &RC.nrmac[Mod_id]->DL_req[CC_id].dl_tti_request_body.dl_tti_pdu_list[0];
+  memset(dl_tti_pdu_list, 0, sizeof(nfapi_nr_dl_tti_request_pdu_t)*NFAPI_NR_MAX_DL_TTI_PDUS);
+}

openair2/NR_PHY_INTERFACE/NR_IF_Module.h

@@ -120,6 +120,8 @@ typedef struct NR_IF_Module_s {
 /*Initial */
 NR_IF_Module_t *NR_IF_Module_init(int Mod_id);
 
+void memclr_mac(int Mod_id, int CC_id);
+
 void NR_IF_Module_kill(int Mod_id);
 
 void NR_UL_indication(NR_UL_IND_t *UL_INFO);