nr-ip-over-LTE: Small fixes, now IP traffic is received at the IP interface of...

nr-ip-over-LTE: Small fixes, now IP traffic is received at the IP interface of the UE but there are many packet losses and occasionally there are duplicate ping requests received, leading to UE crashing

openair1/PHY/NR_UE_TRANSPORT/nr_dlsch_decoding.c

@@ -666,7 +666,7 @@ uint32_t nr_dlsch_decoding(PHY_VARS_NR_UE *phy_vars_ue,
                 }*/
 #endif
            if (frame%100 == 0){
-              LOG_I (PHY, "Printing 100 first payload bytes:");
+              LOG_I (PHY, "Printing 100 first payload bytes at frame: %d ", frame);
               for (int i = 0; i <10 ; i++){ //Kr_bytes
             	  LOG_I(PHY, "[%d] : %x ", i, harq_process->b[i]);
               }

openair1/SCHED_NR_UE/phy_procedures_nr_ue.c

@@ -3796,6 +3796,8 @@ void nr_ue_dlsch_procedures(PHY_VARS_NR_UE *ue,
       LOG_D(PHY," ------ end ldpc decoder for AbsSubframe %d.%d ------  \n", frame_rx, nr_tti_rx);
 
       LOG_I(PHY, "harq_pid: %d, TBS expected dlsch0: %d, TBS expected dlsch1: %d  \n",harq_pid, dlsch0->harq_processes[harq_pid]->TBS, dlsch1->harq_processes[harq_pid]->TBS);
+      
+      if(ret<dlsch0->max_ldpc_iterations+1){
       // fill dl_indication message
       dl_indication.module_id = ue->Mod_id;
       dl_indication.cc_id = ue->CC_id;
@@ -3818,6 +3820,7 @@ void nr_ue_dlsch_procedures(PHY_VARS_NR_UE *ue,
       //  send to mac
       if (ue->if_inst && ue->if_inst->dl_indication)
       ue->if_inst->dl_indication(&dl_indication);
+      }
     }
 
 

openair2/LAYER2/NR_MAC_UE/nr_ue_procedures.c

@@ -2395,7 +2395,7 @@ nr_ue_send_sdu(module_id_t module_idP,
 #if defined(ENABLE_MAC_PAYLOAD_DEBUG)
 		LOG_I(MAC, "Printing MAC PDU contents \n");
 		int j;
-		for (j = 0; j < rx_lengths[i]; j++)
+		for (j = 0; j < 10; j++) //rx_lengths[i]
 			LOG_I(MAC, "%x.", (unsigned char) payload_ptr[j]);
 		LOG_I(MAC, "\n");
 #endif

openair2/LAYER2/NR_MAC_gNB/gNB_scheduler_phytest.c

@@ -370,7 +370,7 @@ void nr_schedule_uss_dlsch_phytest(module_id_t   module_idP,
                                              );
 
     	    if (rlc_status.bytes_in_buffer > 0) {
-    	      LOG_I(MAC,
+    	      LOG_D(MAC,
     		    "[eNB %d][USER-PLANE DEFAULT DRB] Frame %d : DTCH->DLSCH, Requesting %d bytes from RLC (lcid %d total hdr len %d), TBS: %d \n \n",
     		    module_idP, frameP,
                       TBS - ta_len - header_length_total - sdu_length_total - 3,
@@ -388,7 +388,7 @@ void nr_schedule_uss_dlsch_phytest(module_id_t   module_idP,
 
 
 
-    	      LOG_I(MAC,
+    	      LOG_D(MAC,
     		    "[eNB %d][USER-PLANE DEFAULT DRB] Got %d bytes for DTCH %d \n",
     		    module_idP, sdu_lengths[num_sdus], lcid);
 
@@ -437,7 +437,7 @@ void nr_schedule_uss_dlsch_phytest(module_id_t   module_idP,
     	        		ta_update,    // timing advance
     	        		NULL,    // contention res id
     	        		padding, post_padding);
-    	LOG_I(MAC, "Offset bits: %d \n", offset);
+    	LOG_D(MAC, "Offset bits: %d \n", offset);
 
     	// Probably there should be other actions done before that
     	// cycle through SDUs and place in dlsch_buffer
@@ -457,8 +457,8 @@ void nr_schedule_uss_dlsch_phytest(module_id_t   module_idP,
 
     	memcpy(nr_mac->UE_list.DLSCH_pdu[CC_id][0][0].payload[0],DLSCH_pdu.payload[0],TBS_bytes);
 
-    	LOG_I(MAC, "Printing first 100 payload bytes at the gNB side, Frame: %d, slot: %d : \n", frameP, slotP);
-    	  for(int i = 0; i < 100; i++) { // TBS_bytes dlsch_pdu_rel15->transport_block_size/8 6784/8
+    	LOG_I(MAC, "Printing first 10 payload bytes at the gNB side, Frame: %d, slot: %d, , TBS size: %d \n \n", frameP, slotP, TBS_bytes);
+    	  for(int i = 0; i < 10; i++) { // TBS_bytes dlsch_pdu_rel15->transport_block_size/8 6784/8
     	  	  LOG_I(MAC, "%x. ", ((uint8_t *)nr_mac->UE_list.DLSCH_pdu[CC_id][0][0].payload[0])[i]);
     	  }
 
@@ -481,12 +481,12 @@ void nr_schedule_uss_dlsch_phytest(module_id_t   module_idP,
 		  // HOT FIX for all zero pdu problem
 		  // ------------------------------------------------------------------------------------------------
 		  
-		  for(int i = 0; i < 100; i++) { //TBS_bytes
+		  for(int i = 0; i < TBS_bytes; i++) { //
 		  	  ((uint8_t *)nr_mac->UE_list.DLSCH_pdu[CC_id][0][0].payload[0])[i] = (unsigned char) rand();
 		  	  //LOG_I(MAC, "%x. ", ((uint8_t *)nr_mac->UE_list.DLSCH_pdu[CC_id][0][0].payload[0])[i]);
 		    }
                   if (frameP%100 == 0){
-		      LOG_I(MAC, "Printing payload bytes at the gNB side, Frame: %d, slot: %d : \n", frameP, slotP);
+		      LOG_I(MAC, "Printing first 10 payload bytes at the gNB side, Frame: %d, slot: %d, TBS size: %d \n", frameP, slotP, TBS_bytes);
   		      for(int i = 0; i < 10; i++) {
 			  LOG_I(MAC, "%x. ", ((uint8_t *)nr_mac->UE_list.DLSCH_pdu[CC_id][0][0].payload[0])[i]);
   		      }

openair2/LAYER2/PDCP_v10.1.0/pdcp_fifo.c

@@ -174,9 +174,9 @@ int pdcp_fifo_read_input_sdus_fromtun (const protocol_ctxt_t *const  ctxt_pP) {
           ctxt.module_id, ctxt.rnti, ctxt.enb_flag);
 
     if (h_rc == HASH_TABLE_OK) {
-      LOG_I(PDCP, "[FRAME %5u][UE][NETLINK][IP->PDCP] INST %d: Received socket with length %d on Rab %d \n",
+      LOG_D(PDCP, "[FRAME %5u][UE][NETLINK][IP->PDCP] INST %d: Received socket with length %d on Rab %d \n",
             ctxt.frame, ctxt.instance, len, rab_id);
-      LOG_I(PDCP, "[FRAME %5u][UE][IP][INSTANCE %u][RB %u][--- PDCP_DATA_REQ / %d Bytes --->][PDCP][MOD %u][UE %04x][RB %u]\n",
+      LOG_D(PDCP, "[FRAME %5u][UE][IP][INSTANCE %u][RB %u][--- PDCP_DATA_REQ / %d Bytes --->][PDCP][MOD %u][UE %04x][RB %u]\n",
             ctxt.frame, ctxt.instance, rab_id, len, ctxt.module_id,
             ctxt.rnti, rab_id);
       MSC_LOG_RX_MESSAGE((ctxt_pP->enb_flag == ENB_FLAG_YES) ? MSC_PDCP_ENB:MSC_PDCP_UE,