cmake_targets/CMakeLists.txt

@@ -1123,6 +1123,7 @@ set(L2_SRC
   ${RRC_DIR}/L2_interface.c
   )
 set (MAC_SRC
+  ${PHY_INTERFACE_DIR}/phy_stub_UE.c
   ${PHY_INTERFACE_DIR}/IF_Module.c
   ${MAC_DIR}/main.c
   ${MAC_DIR}/ue_procedures.c

openair1/PHY/INIT/defs.h

@@ -356,6 +356,8 @@ void phy_cleanup(void);
 
 void phy_config_request(PHY_Config_t *phy_config);
 
+void phy_config_request_ue(UE_PHY_Config_t* UE_config_INFO);
+
 int init_frame_parms(LTE_DL_FRAME_PARMS *frame_parms,uint8_t osf);
 void dump_frame_parms(LTE_DL_FRAME_PARMS *frame_parms);
 

openair1/PHY/INIT/lte_init.c

@@ -59,7 +59,6 @@ int l1_north_init_eNB() {
 }
 
 
-
 void phy_config_request(PHY_Config_t *phy_config) {
 
   uint8_t Mod_id              = phy_config->Mod_id;
@@ -255,6 +254,18 @@ void phy_config_request(PHY_Config_t *phy_config) {
   LOG_I(PHY,"eNB %d/%d configured\n",Mod_id,CC_id);
 }
 
+
+/* Panos: New function of the UE MAC interface: This function
+should copy the values assigned to the interface parameters
+(within MAC/config.c) to the PHY frame configuration. It should be called at the end of
+config::rrc_mac_config_request_ue()*/
+
+void phy_config_request_ue (UE_PHY_Config_t* UE_config_INFO)
+{
+
+}
+
+
 void phy_config_sib1_ue(uint8_t Mod_id,int CC_id,
                         uint8_t eNB_id,
                         TDD_Config_t *tdd_Config,

openair1/PHY/defs.h

@@ -58,6 +58,7 @@
 #include "msc.h"
 
 #include "openair2/PHY_INTERFACE/IF_Module.h"
+#include "openair2/PHY_INTERFACE/IF_Module_UE.h"
 
 //#include <complex.h>
 #include "assertions.h"
@@ -1281,6 +1282,12 @@ typedef struct {
   /// N0 (used for abstraction)
   double N0;
 
+  /// Panos: Pointer to IF_Module_UE instance of the UE.
+  IF_Module_UE_t *if_inst_ue;
+
+  /// Panos: Pointer to DL.indication structure of the UE.
+  UE_DL_IND_t UE_DL_INFO;
+
   /// PDSCH Varaibles
   PDSCH_CONFIG_DEDICATED pdsch_config_dedicated[NUMBER_OF_CONNECTED_eNB_MAX];
 

openair1/SCHED/phy_procedures_lte_ue.c

@@ -503,6 +503,7 @@ void ue_compute_srs_occasion(PHY_VARS_UE *ue,UE_rxtx_proc_t *proc,uint8_t eNB_id
                   {
                       int Mod_id = ue->Mod_id;
                       int CC_id = ue->CC_id;
+                      // Panos: Substitute call to ue_get_SR() with the filled ue_SR_config->SR_payload (0, or 1).
                       SR_payload = ue_get_SR(Mod_id,
 					     CC_id,
 					     frame_tx,
@@ -1338,6 +1339,8 @@ void ue_prach_procedures(PHY_VARS_UE *ue,UE_rxtx_proc_t *proc,uint8_t eNB_id,uin
     // ask L2 for RACH transport
     if ((mode != rx_calib_ue) && (mode != rx_calib_ue_med) && (mode != rx_calib_ue_byp) && (mode != no_L2_connect) ) {
       LOG_D(PHY,"Getting PRACH resources\n");
+      // Panos: Substitute the call to ue_get_rach with ue->prach_resources[eNB_id] = UE_MAC_interface::ue_rach_config, assuming that
+      // ue_get_rach() will have been called from the MAC layer.
       ue->prach_resources[eNB_id] = ue_get_rach(ue->Mod_id,
 						ue->CC_id,
 						frame_tx,
@@ -1416,6 +1419,7 @@ void ue_prach_procedures(PHY_VARS_UE *ue,UE_rxtx_proc_t *proc,uint8_t eNB_id,uin
   }
   
   if (ue->mac_enabled==1){
+	  // Panos: Substitute with fill_Tx_indication(ue->Mod_id, ue->CC_id, frame_tx, eNB_id, UE_MAC_Tx_IND_Msg1_TYPE)
     Msg1_transmitted(ue->Mod_id,
 		     ue->CC_id,
 		     frame_tx,
@@ -1684,6 +1688,7 @@ void ue_ulsch_uespec_procedures(PHY_VARS_UE *ue,UE_rxtx_proc_t *proc,uint8_t eNB
       
       if (ue->mac_enabled == 1) {
 	// signal MAC that Msg3 was sent
+    // Substitute call to this function by call to fill_Tx_indication (UE_MAC_Tx_IND_Msg3_TYPE)
 	Msg3_transmitted(Mod_id,
 			 CC_id,
 			 frame_tx,
@@ -1699,6 +1704,10 @@ void ue_ulsch_uespec_procedures(PHY_VARS_UE *ue,UE_rxtx_proc_t *proc,uint8_t eNB
 	if (ue->ulsch[eNB_id]->harq_processes[harq_pid]->round==0) {
 	  //if (ue->ulsch[eNB_id]->harq_processes[harq_pid]->calibration_flag == 0) {
 	  access_mode=SCHEDULED_ACCESS;
+
+	  // Panos: Remove the call to ue_get_sdu here and use
+	  // the corresponding Tx.request PDU, instead of ulsch_input_buffer, below.
+
 	  ue_get_sdu(Mod_id,
 		     CC_id,
 		     frame_tx,
@@ -2536,6 +2545,8 @@ void ue_pbch_procedures(uint8_t eNB_id,PHY_VARS_UE *ue,UE_rxtx_proc_t *proc, uin
     frame_tx += pbch_phase;
 
     if (ue->mac_enabled==1) {
+      // Panos:Substitute this call with fill_bch_indication(sync=1)
+
       dl_phy_sync_success(ue->Mod_id,frame_rx,eNB_id,
 			  ue->UE_mode[eNB_id]==NOT_SYNCHED ? 1 : 0);
     }
@@ -2617,7 +2628,11 @@ void ue_pbch_procedures(uint8_t eNB_id,PHY_VARS_UE *ue,UE_rxtx_proc_t *proc, uin
 
     ue->pbch_vars[eNB_id]->pdu_errors_conseq++;
     ue->pbch_vars[eNB_id]->pdu_errors++;
-    if (ue->mac_enabled == 1) rrc_out_of_sync_ind(ue->Mod_id,frame_rx,eNB_id);
+    if (ue->mac_enabled == 1) {
+    	// Panos: Substitute call to rrc_out_of_sync_ind() with fill_bch_incication(sync=0).
+
+    	rrc_out_of_sync_ind(ue->Mod_id,frame_rx,eNB_id);
+    }
     else AssertFatal(ue->pbch_vars[eNB_id]->pdu_errors_conseq<100,
 		     "More that 100 consecutive PBCH errors! Exiting!\n");
   }
@@ -2637,6 +2652,55 @@ void ue_pbch_procedures(uint8_t eNB_id,PHY_VARS_UE *ue,UE_rxtx_proc_t *proc, uin
   VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_UE_PBCH_PROCEDURES, VCD_FUNCTION_OUT);
 }
 
+// Panos: New function supporting the MAC interface
+void fill_bch_indication(module_id_t   module_idP,
+		frame_t frameP,
+		unsigned char eNB_index,
+		uint8_t first_sync,
+		uint8_t sync)
+{
+
+}
+
+// Panos: New function supporting the MAC interface
+void fill_dlsch_indication(module_id_t module_idP,
+	    uint8_t CC_id,
+	    frame_t frameP,
+        sub_frame_t subframeP,
+	    uint8_t* sdu,
+	    uint16_t sdu_len,
+	    uint8_t eNB_index)
+{
+
+}
+
+// Panos: New function supporting the MAC interface
+void fill_dlsch_rar_indication(module_id_t module_idP,
+		  int CC_id,
+		  frame_t frameP,
+		  rnti_t ra_rnti,
+		  uint8_t* dlsch_buffer,
+		  rnti_t* t_crnti,
+		  uint8_t preamble_index,
+		  uint8_t* selected_rar_buffer)
+{
+
+}
+
+// PANOS: New function supporting the MAC interface
+
+void fill_Tx_indication(module_id_t module_idP,uint8_t CC_id,frame_t frameP, uint8_t eNB_id, uint8_t Tx_ind_type)
+{
+	switch (Tx_ind_type)
+	{
+	case UE_MAC_Tx_IND_Msg1_TYPE:
+		break;
+	case UE_MAC_Tx_IND_Msg3_TYPE:
+		break;
+	}
+}
+
+
 int ue_pdcch_procedures(uint8_t eNB_id,PHY_VARS_UE *ue,UE_rxtx_proc_t *proc,uint8_t abstraction_flag)
 {
 
@@ -3217,6 +3281,7 @@ void process_rar(PHY_VARS_UE *ue, UE_rxtx_proc_t *proc, int eNB_id, runmode_t mo
 	    subframe_rx,
 	    ue->prach_resources[eNB_id]->ra_PreambleIndex);
       
+      // Panos: Substitute call to ue_process_rar() with call to fill_dlsch_rar_indication()
       timing_advance = ue_process_rar(ue->Mod_id,
 				      ue->CC_id,
 				      frame_rx,
@@ -3507,6 +3572,7 @@ void ue_dlsch_procedures(PHY_VARS_UE *ue,
       if (ue->mac_enabled == 1) {
 	switch (pdsch) {
 	case PDSCH:
+		// Panos: Substitute call to ue_send_sdu() with call to fill_dlsch_indication()
 	  ue_send_sdu(ue->Mod_id,
 		      CC_id,
 		      frame_rx,
@@ -3516,6 +3582,7 @@ void ue_dlsch_procedures(PHY_VARS_UE *ue,
 		      eNB_id);
 	  break;
 	case SI_PDSCH:
+		// Panos: Substitute call with call to fill_dlsch_indication()
 	  ue_decode_si(ue->Mod_id,
 		       CC_id,
 		       frame_rx,
@@ -3524,7 +3591,8 @@ void ue_dlsch_procedures(PHY_VARS_UE *ue,
 		       ue->dlsch_SI[eNB_id]->harq_processes[0]->TBS>>3);
 	  break;
 	case P_PDSCH:
-	  ue_decode_p(ue->Mod_id,
+		// Panos: Substitute call with call to fill_dlsch_indication()
+		ue_decode_p(ue->Mod_id,
 		      CC_id,
 		      frame_rx,
 		      eNB_id,
@@ -3532,6 +3600,7 @@ void ue_dlsch_procedures(PHY_VARS_UE *ue,
 		      ue->dlsch_SI[eNB_id]->harq_processes[0]->TBS>>3);
 	  break;
 	case RA_PDSCH:
+		// Panos: Substitute with call to fill_dlsch_rar_indication()
 	  process_rar(ue,proc,eNB_id,mode,abstraction_flag);
 	  break;
 	case PDSCH1:

openair2/LAYER2/MAC/config.c

@@ -264,6 +264,7 @@ void config_sib1(int Mod_idP,
   
 }
 
+
 int power_off_dB[6] = {78,118,140,170,188,200};
 
 void config_sib2(int Mod_idP, 
@@ -414,6 +415,10 @@ void config_sib2(int Mod_idP,
 
 }
 
+
+
+
+
 void config_dedicated(int Mod_idP, 
 		      int CC_idP, 
 		      uint16_t rnti, 
@@ -671,6 +676,47 @@ int rrc_mac_config_req_eNB(module_id_t                      Mod_idP,
   return(0);			   
 
 }
+
+// P: New function supporting the MAC interface
+void config_sib1_ue()
+{
+
+}
+
+// P: New function supporting the MAC interface
+void config_sib2_ue()
+{
+
+}
+
+// P: New function supporting the MAC interface
+void config_meas_ue()
+{
+
+}
+
+// P: New function supporting the MAC interface
+// to substitute call to phy_config_afterHO_ue().
+void config_afterHO_ue()
+{
+
+}
+
+// P: New function supporting the MAC interface
+void config_sib13_ue()
+{
+
+}
+
+
+// P: New function supporting the MAC interface
+void config_dedicated_ue()
+{
+
+}
+
+
+
 int
 rrc_mac_config_req_ue(
   module_id_t                      Mod_idP,
@@ -1021,6 +1067,9 @@ rrc_mac_config_req_ue(
 #endif
   VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_RRC_MAC_CONFIG, VCD_FUNCTION_OUT);
 
+  // Panos: Call to the phy_config_request_ue() function of the interface to copy the UE_PHY_Config_t interface
+  // configuration to the PHY common and dedicated configuration originating from RRC.
+
   return(0);
 }
 

openair2/LAYER2/MAC/defs.h

@@ -235,6 +235,33 @@ typedef struct {
   uint8_t R:2;
 } __attribute__((__packed__))SCH_SUBHEADER_FIXED;
 
+
+// Panos:
+/*!\brief  MAC subheader long  with 24bit DST field */
+typedef struct {
+	uint8_t   V:4; //Version number: Possible values "0001", "0010", "0011" based on TS36.321 section 6.2.3.
+	uint32_t  SRC:24; //Prose UE source ID. Size 24 bits.
+	uint32_t  DST:24; //Prose UE destination ID. Size 16 or 24 bits.
+	uint8_t   LCID:5;
+	uint8_t   L:7;	// Length field indicating the size of the corresponding SDU in byes. Not sure about the size of this field (7).
+	uint8_t	  F:1;
+	uint8_t	  E:1;
+	uint8_t	  R:1;
+}__attribute__((__packed__))SLSCH_SUBHEADER_24_Bit_DST;
+
+/*!\brief  MAC subheader long  with 16bit DST field */
+typedef struct {
+	uint8_t   V:4; //Version number: Possible values "0001", "0010", "0011" based on TS36.321 section 6.2.3.
+	uint32_t  SRC:24; //Prose UE source ID. Size 24 bits.
+	uint32_t  DST:16; //Prose UE destination ID. Size 16 or 24 bits.
+	uint8_t   LCID:5;
+	uint8_t   L:7;	// Length field indicating the size of the corresponding SDU in byes. Not sure about the size of this field (7).
+	uint8_t	  F:1;
+	uint8_t	  E:1;
+	uint8_t	  R:1;
+}__attribute__((__packed__))SLSCH_SUBHEADER_16_Bit_DST;
+
+
 /*!\brief  mac control element: short buffer status report for a specific logical channel group ID*/
 typedef struct {
   uint8_t Buffer_size:6;  // octet 1 LSB
@@ -250,6 +277,30 @@ typedef struct {
   uint8_t Buffer_size0:6;
 } __attribute__((__packed__))BSR_LONG;
 
+// Panos:
+/*!\brief  mac control element: sidelink buffer status report */
+typedef struct {
+	uint8_t DST_1:4;
+	uint8_t LCGID_1: 2;
+	uint8_t Buffer_size_1:6;
+	uint8_t DST_2:4;
+	uint8_t LCGID_2: 2;
+	uint8_t Buffer_size_2:6;
+}__attribute__((__packed__))SL_BSR;
+
+/*!\brief  mac control element: truncated sidelink buffer status report */
+typedef struct {
+	uint8_t DST:4;
+	uint8_t LCGID: 2;
+	uint8_t Buffer_size:6;
+	uint8_t R1:1;
+	uint8_t R2:1;
+	uint8_t R3:1;
+	uint8_t R4:1;
+}__attribute__((__packed__))SL_BSR_Truncated;
+
+
+
 #define BSR_LONG_SIZE  (sizeof(BSR_LONG))
 /*!\brief  mac control element: timing advance  */
 typedef struct {
@@ -1162,6 +1213,17 @@ typedef struct {
   MeasGapConfig_t  *measGapConfig;
   /// Pointers to LogicalChannelConfig indexed by LogicalChannelIdentity. Note NULL means LCHAN is inactive.
   LogicalChannelConfig_t *logicalChannelConfig[MAX_NUM_LCID];
+
+  /// Panos: Pointer to IF_Module_UE instance of the UE
+  IF_Module_UE_t *if_inst_ue;
+  /// Panos: UE_MAC interface: Config request structure.
+  UE_PHY_Config_t UE_config;
+  /// Panos: UE_MAC interface: UL Config Request Structure
+  UE_MAC_ul_config_request_t UL_req_ue[MAX_NUM_CCs];
+  /// Panos: UE_MAC interface: UL Transmission request structure.
+  UE_MAC_tx_request_t UL_TX_req[MAX_NUM_CCs];
+
+
   /// Scheduling Information
   UE_SCHEDULING_INFO scheduling_info;
   /// Outgoing CCCH pdu for PHY

openair2/LAYER2/MAC/ue_procedures.c

@@ -1781,6 +1781,8 @@ for (lcid=DCCH; (lcid < MAX_NUM_LCID) && (is_all_lcid_processed == FALSE) ; lcid
   VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_UE_GET_SDU, VCD_FUNCTION_OUT);
   stop_meas(&UE_mac_inst[module_idP].tx_ulsch_sdu);
   
+  // Panos: Tx_request should be filled from the ulsch_buffer here.
+
   if (opt_enabled) {
     trace_pdu(0, ulsch_buffer, buflen, module_idP, 3, UE_mac_inst[module_idP].crnti, UE_mac_inst[module_idP].txFrame, UE_mac_inst[module_idP].txSubframe, 0, 0);
     LOG_D(OPT,"[UE %d][ULSCH] Frame %d subframe %d trace pdu for rnti %x  with size %d\n",

openair2/PHY_INTERFACE/IF_Module_UE.c

+#include "openair1/PHY/defs.h"
+#include "openair2/PHY_INTERFACE/IF_Module_UE.h"
+#include "openair2/PHY_INTERFACE/UE_MAC_interface.h"
+#include "openair1/PHY/extern.h"
+#include "LAYER2/MAC/extern.h"
+#include "LAYER2/MAC/proto.h"
+#include "common/ran_context.h"
+
+IF_Module_UE_t *if_inst_ue;
+
+
+
+void handle_bch(UE_DL_IND_t *UE_DL_INFO)
+{
+
+}
+
+
+void handle_dlsch(UE_DL_IND_t *UE_DL_INFO)
+{
+	int i;
+	UE_MAC_dlsch_indication_pdu_t *dlsch_pdu_ind;
+
+	for (i=0; i<UE_DL_INFO->UE_DLSCH_ind.number_of_pdus; i++)
+	{
+		dlsch_pdu_ind = UE_DL_INFO->UE_DLSCH_ind.dlsch_ind_list[i];
+		switch (dlsch_pdu_ind->pdu_type) {
+
+		case UE_MAC_DL_IND_PDSCH_PDU_TYPE:
+				// Call ue_send_sdu()
+			break;
+
+		case UE_MAC_DL_IND_SI_PDSCH_PDU_TYPE:
+				// Call ue_decode_si()
+			break;
+
+		case UE_MAC_DL_IND_P_PDSCH_PDU_TYPE:
+				// Call ue_decode_p()
+			break;
+
+		case UE_MAC_DL_IND_DLSCH_RAR_PDU_TYPE:
+			   // Call ue_process_rar()
+			break;
+		}
+	}
+
+}
+
+
+void UE_DL_indication(UE_DL_IND_t *UE_DL_INFO)
+{
+
+    /*Call handle functions to forward PDUs or control indications to the upper layers.
+	handle_bch(UE_DL_INFO);
+	handle_dlsch (UE_DL_INFO);
+
+	Trigger ue_scheduler() ?
+	*/
+}
+
+/* Indicate the Txon of Msg1 or Msg3 to the MAC layer of the transmitter side and trigger associated
+ * MAC layer operations */
+
+void UE_Tx_indication(UE_Tx_IND_t *UE_Tx_INFO)
+{
+	switch (UE_Tx_INFO->ind_type) {
+
+	case UE_MAC_Tx_IND_Msg1_TYPE:
+		//Call Msg1_transmitted()
+	break;
+
+	case UE_MAC_Tx_IND_Msg3_TYPE:
+		//Call Msg3_transmitted()
+	break;
+	}
+}
+
+/// Panos: Not sure about the implementation of this function.
+IF_Module_UE_t *IF_Module_ue_init(int Mod_id){
+
+  AssertFatal(Mod_id<MAX_MODULES,"Asking for Module %d > %d\n",Mod_id,MAX_IF_MODULES);
+
+  if (if_inst_ue[Mod_id]==NULL) {
+    if_inst_ue[Mod_id] = (IF_Module_t*)malloc(sizeof(IF_Module_t));
+    memset((void*)if_inst_ue[Mod_id],0,sizeof(IF_Module_t));
+
+    //if_inst_ue[Mod_id]->CC_mask=0;
+    if_inst_ue[Mod_id]->UE_DL_indication = UE_DL_indication;
+    if_inst_ue[Mod_id]->UE_Tx_indication = UE_Tx_indication;
+
+    // Panos: Have to check about this.
+    /*AssertFatal(pthread_mutex_init(&if_inst_ue[Mod_id]->if_mutex,NULL)==0,
+		"allocation of if_inst[%d]->if_mutex fails\n",Mod_id);*/
+  }
+  return if_inst[Mod_id];
+}
+
+

openair2/PHY_INTERFACE/IF_Module_UE.h

+
+/*This is the interface module between PHY
+*Provided the FAPI style interface structures for P7.
+*
+*
+*
+*//*
+ * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The OpenAirInterface Software Alliance licenses this file to You under
+ * the OAI Public License, Version 1.0  (the "License"); you may not use this file
+ * except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.openairinterface.org/?page_id=698
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *-------------------------------------------------------------------------------
+ * For more information about the OpenAirInterface (OAI) Software Alliance:
+ *      contact@openairinterface.org
+ */
+
+/*! \file openair2/PHY_INTERFACE/IF_Module.h
+* \brief data structures for PHY/MAC interface modules
+* \author EURECOM/NTUST
+* \date 2017
+* \version 0.1
+* \company Eurecom
+* \email: raymond.knopp@eurecom.fr
+* \note
+* \warning
+*/
+#ifndef __IF_MODULE_UE__H__
+#define __IF_MODULE_UE__H__
+
+
+#include <stdint.h>
+#include "openair1/PHY/LTE_TRANSPORT/defs.h"
+#include "UE_MAC_interface.h"
+
+#define MAX_NUM_DL_PDU 100
+#define MAX_NUM_UL_PDU 100
+#define MAX_NUM_HI_DCI0_PDU 100
+#define MAX_NUM_TX_REQUEST_PDU 100
+
+#define MAX_NUM_HARQ_IND 100
+#define MAX_NUM_CRC_IND 100
+#define MAX_NUM_SR_IND 100
+#define MAX_NUM_CQI_IND 100
+#define MAX_NUM_RACH_IND 100
+#define MAX_NUM_SRS_IND 100
+
+typedef struct{
+  /// Module ID
+  module_id_t module_id;
+  /// CC ID
+  int CC_id;
+  // / frame
+  frame_t frame;
+  /// subframe
+  sub_frame_t subframe;
+
+  /// harq ACKs indication list
+  //UE_MAC_hi_indication_body_t UE_hi_ind;
+
+  /// crc indication list
+  //UE_MAC_crc_indication_body_t UE_crc_ind;
+
+  /// RX BCH indication
+  UE_MAC_BCH_indication_body_t UE_BCH_ind;
+
+  /// RX DLSCH indication
+  UE_MAC_DLSCH_indication_body_t UE_DLSCH_ind;
+
+} UE_DL_IND_t;
+
+
+typedef struct{
+	/// Module ID
+	module_id_t module_id;
+	/// CC ID
+	int CC_id;
+	/// frame
+	frame_t frame;
+	/// subframe
+	sub_frame_t subframe;
+	/// Txon Indication type (Msg1 or Msg3)
+	uint8_t ind_type;
+}UE_Tx_IND_t;
+
+
+typedef struct{
+	/// Module ID
+	module_id_t module_id;
+	/// CC ID
+	int CC_id;
+	/// frame
+	frame_t frame;
+	/// subframe
+	sub_frame_t subframe;
+	/// Sidelink Control Information indication
+	ue_sci_indication_body_t UE_SCI_ind;
+    /// RX SLSCH indication
+	ue_SLSCH_indication_body_t UE_SLSCH_ind;
+	/// RX SLDCH indication
+	ue_SLDCH_indication_body_t UE_SLDCH_ind;
+	/// RX SLBCH indication
+	ue_SLBCH_indication_body_t UE_SLBCH_ind;
+
+} UE_SL_IND_t;
+
+// Downlink subframe P7
+
+
+typedef struct{
+  /// Module ID
+  module_id_t module_id; 
+  /// CC ID
+  uint8_t CC_id;
+  /// frame
+  frame_t frame;
+  /// subframe
+  sub_frame_t subframe;
+  /// UE_Mode to be filled only after
+  UE_MODE_t UE_mode[NUMBER_OF_CONNECTED_eNB_MAX];
+  /// MAC IFace UL Config Request
+  UE_MAC_ul_config_request_t *UE_UL_req;
+  /// MAC IFace SL Transmission Config Request
+  UE_MAC_sl_config_request_Tx_t *SL_Tx_req;
+  /// MAC IFace SL Reception Config Request
+  UE_MAC_sl_config_request_Rx_t *SL_Rx_req;
+  /// Pointers to UL SDUs
+  UE_MAC_tx_request_t *UE_TX_req;
+  /// Pointers to SL SDUs
+  UE_MAC_sl_tx_request_t *TX_SL_req;
+}UE_Sched_Rsp_t;
+
+typedef struct {
+    uint8_t Mod_id;
+    int CC_id;
+    UE_PHY_config_common_request_t *cfg_common;
+    UE_PHY_config_dedicated_request_t *cfg_dedicated;
+}UE_PHY_Config_t;
+
+typedef struct IF_Module_UE_s{
+//define the function pointer
+  void (*UE_DL_indication)(UE_DL_IND_t *UE_DL_INFO);
+  void (*UE_SL_indication)(UE_SL_IND_t *UE_SL_INFO);
+  void (*UE_Tx_indication)(UE_Tx_IND_t *UE_Tx_INFO);
+  void (*UE_sched_response)(UE_Sched_Rsp_t *UE_Sched_INFO);
+  void (*UE_config_req)(UE_PHY_Config_t* UE_config_INFO);
+//P: Perhaps an additional separate function for dedicated PHY configuration is needed.
+  //uint32_t CC_mask_ue;
+  uint16_t current_frame;
+  uint8_t current_subframe;
+  pthread_mutex_t if_mutex;
+}IF_Module_UE_t;
+
+
+IF_Module_UE_t *IF_Module_UE_init(int Mod_id);
+void IF_Module_UE_kill(int Mod_id);
+
+
+void UE_DL_indication(UE_DL_IND_t *UE_DL_INFO);
+
+
+void UE_Tx_indication(UE_Tx_IND_t *UE_Tx_INFO);
+
+
+/*Interface for Downlink, transmitting the DLSCH SDU, DCI SDU*/
+void UE_schedule_response(UE_Sched_Rsp_t *UE_Sched_INFO);
+
+#endif
+

openair2/PHY_INTERFACE/UE_MAC_interface.h

+
+/*This is the interface module between PHY
+*Provided the FAPI style interface structures for P7.
+*
+*
+*
+*//*
+ * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The OpenAirInterface Software Alliance licenses this file to You under
+ * the OAI Public License, Version 1.0  (the "License"); you may not use this file
+ * except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.openairinterface.org/?page_id=698
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *-------------------------------------------------------------------------------
+ * For more information about the OpenAirInterface (OAI) Software Alliance:
+ *      contact@openairinterface.org
+ */
+
+/*! \file openair2/PHY_INTERFACE/IF_Module.h
+* \brief data structures for PHY/MAC interface modules
+* \author EURECOM/NTUST
+* \date 2017
+* \version 0.1
+* \company Eurecom
+* \email: raymond.knopp@eurecom.fr
+* \note
+* \warning
+*/
+#ifndef __UE_MAC_INTERFACE__H__
+#define __UE_MAC_INTERFACE__H__
+
+#include "nfapi_interface.h"
+#include "openair1/PHY/impl_defs_lte.h"
+#include "targets/COMMON/openairinterface5g_limits.h"
+
+
+
+#define MAX_NUM_DL_PDU 100
+#define MAX_NUM_UL_PDU 100
+#define MAX_NUM_HI_DCI0_PDU 100
+#define MAX_NUM_TX_REQUEST_PDU 100
+
+#define MAX_NUM_HARQ_IND 100
+#define MAX_NUM_CRC_IND 100
+#define MAX_NUM_SR_IND 100
+#define MAX_NUM_CQI_IND 100
+#define MAX_NUM_RACH_IND 100
+#define MAX_NUM_SRS_IND 100
+
+
+// UE_MAC enums
+typedef enum {
+	UE_MAC_DL_IND_PDSCH_PDU_TYPE =0,
+	UE_MAC_DL_IND_SI_PDSCH_PDU_TYPE,
+	UE_MAC_DL_IND_P_PDSCH_PDU_TYPE,
+	UE_MAC_DL_IND_DLSCH_RAR_PDU_TYPE
+} UE_MAC_dl_ind_pdu_type_e;
+
+// UE_MAC enums
+typedef enum {
+	UE_MAC_Tx_IND_Msg1_TYPE =0,
+	UE_MAC_Tx_IND_Msg3_TYPE
+} UE_MAC_Tx_ind_type_e;
+
+
+
+// *** UE_UL_Config.request related structures
+
+
+typedef struct{
+	//module_id_t module_idP;
+	//int CC_id;
+	//frame_t frameP;
+	uint8_t eNB_id;
+	//uint16_t rnti;
+	//sub_frame_t subframe_tx;
+	uint32_t SR_payload; //0 or 1
+}UE_MAC_ul_config_SR;
+
+
+
+typedef struct{
+	//module_id_t module_idP;
+	//int CC_id;
+	//frame_t frameP;
+	uint8_t eNB_indexP;
+	//sub_frame_t subframeP;
+
+	uint8_t ra_RACH_MaskIndex;
+	int8_t ra_PREAMBLE_RECEIVED_TARGET_POWER;
+	uint8_t ra_TDD_map_index;
+	uint16_t ra_RNTI;
+	uint8_t *Msg3;
+}UE_MAC_ul_config_rach;
+
+typedef struct {
+	union {
+		UE_MAC_ul_config_rach			ue_rach_config;
+		//UE_MAC_ul_config_ULSCH     		ue_ULSCH_pdu;
+		UE_MAC_ul_config_SR     		ue_SR_config;
+	};
+} UE_MAC_ul_config_request_list;
+
+typedef struct {
+	nfapi_tl_t tl;
+	uint16_t length_list;
+	UE_MAC_ul_config_request_list* ue_ul_config_list;
+} UE_MAC_ul_config_request_body_t;
+
+typedef struct {
+	//nfapi_p7_message_header_t header;
+	uint16_t sfn_sf;
+	UE_MAC_ul_config_request_body_t ue_ul_config_request_body; //nfapi_dl_config_request_body_t
+} UE_MAC_ul_config_request_t;
+
+
+
+
+
+
+
+
+
+// *** UE_Tx.request related structures
+
+typedef struct {
+	uint16_t pdu_length;
+	uint16_t pdu_index;
+	uint8_t num_segments;
+	struct {
+		uint32_t segment_length;
+		uint8_t* segment_data;
+	} segments[NFAPI_TX_MAX_SEGMENTS];
+} UE_MAC_tx_request_pdu_t;
+
+
+typedef struct {
+	nfapi_tl_t tl;
+	uint16_t number_of_pdus;
+	UE_MAC_tx_request_pdu_t* ue_tx_pdu_list;
+} UE_MAC_tx_request_body_t;
+
+
+typedef struct {
+	//nfapi_p7_message_header_t header;
+	uint16_t sfn_sf;
+	UE_MAC_tx_request_body_t ue_tx_request_body;
+} UE_MAC_tx_request_t;
+
+
+typedef struct{
+
+
+}UE_MAC_sl_config_request_Tx_t;
+
+typedef struct{
+
+
+}UE_MAC_sl_config_request_Rx_t;
+
+
+typedef struct{
+
+
+}UE_MAC_sl_tx_request_t;
+
+
+
+
+
+
+// *** UE_DL.indication related structures
+
+typedef struct{
+	unsigned char eNB_index;
+	uint8_t       first_sync; //boolean 0 or 1
+	uint8_t       sync; // boolean 0 or 1 to indicate whether rrc_out_of_sync_ind() or dl_phy_sync_success()
+						// should be called from the handler function of the interface respectively.
+}UE_MAC_bch_indication_pdu_t;
+
+
+typedef struct{
+	nfapi_tl_t tl;
+	UE_MAC_bch_indication_pdu_t* bch_ind_list;
+}UE_MAC_BCH_indication_body_t;
+
+
+// Panos: Corresponding to inputs of MAC functions: ue_send_sdu(), ue_decode_si(), ue_decode_p().
+typedef struct{
+	uint8_t* 	data;
+	uint16_t 	data_len;
+}UE_MAC_dlsch_pdu;
+
+
+// Panos: Corresponding to inputs of MAC function: process_rar().
+typedef struct{
+	rnti_t 		ra_rnti;
+	uint8_t* 	rar_input_buffer; // Originating from PHY
+	rnti_t* 	t_crnti;
+	uint8_t 	preamble_index;
+	uint8_t* 	rar_output_buffer; //should be returned to PHY: dlsch0->harq_processes[0]->b
+}UE_MAC_dlsch_rar_pdu;
+
+
+typedef struct{
+	uint8_t pdu_type;
+	uint8_t eNB_index;
+	union{
+		UE_MAC_dlsch_pdu 	 dlsch_pdu_ind;
+		UE_MAC_dlsch_rar_pdu dlsch_rar_pdu_ind;
+	};
+}UE_MAC_dlsch_indication_pdu_t;
+
+
+typedef struct{
+	nfapi_tl_t tl;
+	uint16_t number_of_pdus;
+	UE_MAC_dlsch_indication_pdu_t* dlsch_ind_list;
+}UE_MAC_DLSCH_indication_body_t;
+
+
+
+
+
+
+// *** UE_SL.indication related structures
+
+typedef struct{
+
+}ue_sci_indication_body_t;
+
+
+typedef struct{
+
+}ue_SLSCH_indication_body_t;
+
+
+typedef struct{
+
+}ue_SLDCH_indication_body_t;
+
+typedef struct{
+
+}ue_SLBCH_indication_body_t;
+
+
+// *** UE_Config_common.request related structures
+
+typedef struct {
+	uint8_t subframeAssignment;
+	uint8_t specialSubframePatterns;
+}UE_PHY_tdd_frame_structure_t;
+
+
+typedef struct {
+	uint16_t rootSequenceIndex;
+	uint8_t prach_Config_enabled;
+	uint8_t prach_ConfigIndex;
+	uint8_t highSpeedFlag;
+	uint8_t zeroCorrelationZoneConfig;
+	uint8_t prach_FreqOffset;
+}UE_PHY_prach_config_t;
+
+typedef struct {
+	uint8_t deltaPUCCH_Shift;
+	uint8_t nRB_CQI;
+	uint8_t nCS_AN;
+	uint16_t n1PUCCH_AN;
+}UE_PHY_pucch_config_t;
+
+
+typedef struct {
+	int8_t referenceSignalPower;
+	uint8_t p_b;
+}UE_PHY_pdsch_config_t;
+
+
+typedef struct {
+	uint8_t n_SB;
+	PUSCH_HOPPING_t hoppingMode;
+	uint8_t pusch_HoppingOffset;
+	uint8_t enable64QAM;
+	uint8_t groupHoppingEnabled;
+	uint8_t groupAssignmentPUSCH;
+	uint8_t sequenceHoppingEnabled;
+	uint8_t cyclicShift;
+}UE_PHY_pusch_config_t;
+
+
+typedef struct{
+	uint8_t enabled_flag;
+	uint8_t srs_BandwidthConfig;
+	uint8_t srs_SubframeConfig;
+	uint8_t ackNackSRS_SimultaneousTransmission;
+	uint8_t srs_MaxUpPts;
+}UE_PHY_SRS_config_t;
+
+typedef struct{
+	int8_t p0_NominalPUSCH;
+	PUSCH_alpha_t alpha;
+	int8_t p0_NominalPUCCH;
+	int8_t deltaPreambleMsg3;
+	long deltaF_PUCCH_Format1;
+	long deltaF_PUCCH_Format1b;
+	long deltaF_PUCCH_Format2;
+	long deltaF_PUCCH_Format2a;
+	long deltaF_PUCCH_Format2b;
+}UE_PHY_UL_power_control_config_t;
+
+
+typedef struct{
+	uint8_t maxHARQ_Msg3Tx;
+}UE_PHY_HARQ_Msg3_config_t;
+
+typedef struct{
+	uint8_t nb_antennas_tx;
+}UE_PHY_antenna_config_t;
+
+typedef struct{
+	PHICH_RESOURCE_t phich_resource;
+	PHICH_DURATION_t phich_duration;
+}UE_PHY_phich_config_t;
+
+
+typedef struct {
+	UE_PHY_tdd_frame_structure_t ue_tdd_frame_structure_config;
+	UE_PHY_prach_config_t ue_prach_config;
+	UE_PHY_pucch_config_t ue_pucch_config;
+	UE_PHY_pdsch_config_t ue_pdsch_config;
+	UE_PHY_pusch_config_t ue_pusch_config;
+	UE_PHY_SRS_config_t   ue_srs_config;
+	UE_PHY_UL_power_control_config_t ue_ul_pow_cntl_config;
+	UE_PHY_HARQ_Msg3_config_t ue_harq_msg3_config;
+	/* Where can we find the types and values of the configuration for the PCH?
+	UE_MAC_pusch_config_t ue_pch_config
+	radioResourceConfigCommon->pcch_Config.defaultPagingCycle, radioResourceConfigCommon->pcch_Config.nB*/
+	UE_PHY_antenna_config_t ue_ant_config;
+	UE_PHY_phich_config_t ue_phich_config;
+	/* MBSFN?*/
+}UE_PHY_config_common_request_t;
+
+
+
+
+
+
+
+// *** UE_Config_dedicated. request related structures
+
+typedef struct{
+	PA_t p_a;
+}UE_PHY_pdsch_config_dedicated_t;
+
+
+typedef struct{
+	uint8_t ackNackRepetition;
+	ANFBmode_t tdd_AckNackFeedbackMode;
+	//ACKNAKREP_t repetitionFactor;
+	//uint16_t n1PUCCH_AN_Rep;
+}UE_PHY_pucch_config_dedicated_t;
+
+
+typedef struct{
+	uint16_t betaOffset_ACK_Index;
+	uint16_t betaOffset_RI_Index;
+	uint16_t betaOffset_CQI_Index;
+}UE_PHY_pusch_config_dedicated_t;
+
+
+typedef struct{
+	int8_t p0_UE_PUSCH;
+	uint8_t deltaMCS_Enabled;
+	uint8_t accumulationEnabled;
+	int8_t p0_UE_PUCCH;
+	int8_t pSRS_Offset;
+	uint8_t filterCoefficient;
+}UE_PHY_ul_power_control_config_dedicated_t;
+
+
+typedef struct{
+	uint16_t sr_PUCCH_ResourceIndex;
+	uint8_t sr_ConfigIndex;
+	DSR_TRANSMAX_t dsr_TransMax;
+}UE_PHY_SR_config_dedicated_t;
+
+
+typedef struct{
+	uint8_t srsConfigDedicatedSetup;
+	uint8_t duration;
+	uint8_t cyclicShift;
+	uint8_t freqDomainPosition;
+	uint8_t srs_Bandwidth;
+	uint16_t srs_ConfigIndex;
+	uint8_t srs_HoppingBandwidth;
+	uint8_t transmissionComb;
+	//uint8_t srsCellSubframe;
+	//uint8_t srsUeSubframe;
+}UE_PHY_srs_ul_config_dedicated_t;
+
+
+typedef struct{
+	CQI_REPORTMODEAPERIODIC cqi_ReportModeAperiodic;
+	CQI_REPORTPERIODIC CQI_ReportPeriodic;
+	//int8_t nomPDSCH_RS_EPRE_Offset;
+}UE_PHY_cqi_report_config_dedicated_t;
+
+
+
+typedef struct{
+	uint8_t transmission_mode [NUMBER_OF_CONNECTED_eNB_MAX];
+	UE_PHY_pdsch_config_dedicated_t ue_pdsch_config;
+	UE_PHY_pucch_config_dedicated_t ue_pucch_config;
+	UE_PHY_pusch_config_dedicated_t ue_pusch_config;
+	UE_PHY_ul_power_control_config_dedicated_t ue_ul_pow_cntrl_config;
+	UE_PHY_SR_config_dedicated_t	ue_SR_config;
+	UE_PHY_srs_ul_config_dedicated_t ue_srs_ul_config;
+	UE_PHY_cqi_report_config_dedicated_t ue_cqi_report_config;
+}UE_PHY_config_dedicated_request_t;
+
+#endif
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+/*
+typedef struct {
+	nfapi_p4_p5_message_header_t header;
+	uint8_t num_tlv;
+	nfapi_subframe_config_t subframe_config;
+	nfapi_rf_config_t rf_config;
+	nfapi_phich_config_t phich_config;
+	nfapi_sch_config_t sch_config;
+	nfapi_prach_config_t prach_config;
+	nfapi_pusch_config_t pusch_config;
+	nfapi_pucch_config_t pucch_config;
+	nfapi_srs_config_t srs_config;
+	nfapi_uplink_reference_signal_config_t uplink_reference_signal_config;
+	nfapi_laa_config_t laa_config;
+	nfapi_emtc_config_t emtc_config;
+	nfapi_tdd_frame_structure_t tdd_frame_structure_config;
+	nfapi_l23_config_t l23_config;
+	nfapi_nb_iot_config_t nb_iot_config;
+
+	// addition nfapi tlvs as per table 2-16 in idle or configure
+	nfapi_nfapi_t nfapi_config;
+
+	nfapi_vendor_extension_tlv_t vendor_extension;
+} nfapi_config_request_t;
+
+
+
+
+
+typedef struct {
+	nfapi_tl_t tl;
+	uint8_t dci_format;
+	uint8_t cce_index;
+	uint8_t aggregation_level;
+	uint16_t rnti;
+	uint8_t resource_block_start;
+	uint8_t number_of_resource_block;
+	uint8_t mcs_1;
+	uint8_t cyclic_shift_2_for_drms;
+	uint8_t frequency_hopping_enabled_flag;
+	uint8_t frequency_hopping_bits;
+	uint8_t new_data_indication_1;
+	uint8_t ue_tx_antenna_seleciton;
+	uint8_t tpc;
+	uint8_t cqi_csi_request;
+	uint8_t ul_index;
+	uint8_t dl_assignment_index;
+	uint32_t tpc_bitmap;
+	uint16_t transmission_power;
+} nfapi_hi_dci0_dci_pdu_rel8_t;
+
+*/

openair2/PHY_INTERFACE/phy_stub_UE.c

+
+//#include "openair1/PHY/defs.h"
+//#include "openair2/PHY_INTERFACE/IF_Module.h"
+//#include "openair1/PHY/extern.h"
+#include "LAYER2/MAC/extern.h"
+//#include "LAYER2/MAC/proto.h"
+//#include "common/ran_context.h"
+#include "openair2/PHY_INTERFACE/phy_stub_UE.h"
+
+
+void handle_nfapi_UE_Rx(uint8_t Mod_id, Sched_Rsp_t *Sched_INFO, int eNB_id){
+	// copy data from eNB L2 interface to UE L2 interface
+
+	int 					   CC_id	   = Sched_INFO->CC_id;
+	nfapi_dl_config_request_t *DL_req      = Sched_INFO->DL_req;
+	nfapi_tx_request_t        *Tx_req      = Sched_INFO->TX_req;
+	frame_t                   frame        = Sched_INFO->frame;
+	sub_frame_t               subframe     = Sched_INFO->subframe;
+
+	uint8_t number_dl_pdu             = DL_req->dl_config_request_body.number_pdu;
+	nfapi_dl_config_request_pdu_t *dl_config_pdu;
+	nfapi_dl_config_request_pdu_t *dl_config_pdu_tmp;
+	int i = 0;
+
+	for (i=0; i<number_dl_pdu; i++)
+	{
+		dl_config_pdu = &DL_req->dl_config_request_body.dl_config_pdu_list[i];
+		switch (dl_config_pdu->pdu_type) {
+		case NFAPI_DL_CONFIG_BCH_PDU_TYPE:
+			// BCH case
+			// Last parameter is 1 if first time synchronization and zero otherwise. Not sure which value to put
+			// for our case.
+			dl_phy_sync_success(Mod_id,frame,eNB_id, 0);
+			break;
+
+		case NFAPI_DL_CONFIG_DCI_DL_PDU_TYPE:
+			if (dl_config_pdu->dci_dl_pdu.dci_dl_pdu_rel8.rnti_type == 1) {
+				// C-RNTI (Normal DLSCH case)
+				dl_config_pdu_tmp = &DL_req->dl_config_request_body.dl_config_pdu_list[i+1];
+				if (dl_config_pdu_tmp->pdu_type == NFAPI_DL_CONFIG_DLSCH_PDU_TYPE){
+					ue_send_sdu(Mod_id, CC_id, frame, subframe,
+							Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_data,
+							Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_length,
+							eNB_id);
+					i++;
+				}
+				else {
+					LOG_E(MAC,"[UE %d] CCid %d Frame %d, subframe %d : Cannot extract DLSCH PDU from NFAPI\n",Mod_id, CC_id,frame,subframe);
+				}
+			}
+			else if (dl_config_pdu->dci_dl_pdu.dci_dl_pdu_rel8.rnti_type == 2) {
+				dl_config_pdu_tmp = &DL_req->dl_config_request_body.dl_config_pdu_list[i+1];
+				if(dl_config_pdu_tmp->pdu_type == NFAPI_DL_CONFIG_DLSCH_PDU_TYPE && dl_config_pdu->dci_dl_pdu.dci_dl_pdu_rel8.rnti == 0xFFFF){
+					//pdu = Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_data;
+					// Question about eNB_index here. How do we obtain it?
+					ue_decode_si(Mod_id, CC_id, frame, eNB_id,
+							Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_data,
+							Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_length);
+					i++;
+				}
+				else if(dl_config_pdu_tmp->pdu_type == NFAPI_DL_CONFIG_DLSCH_PDU_TYPE && dl_config_pdu->dci_dl_pdu.dci_dl_pdu_rel8.rnti == 0xFFFE){
+					// P_RNTI case
+					//pdu = Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_data;
+					// Question about eNB_index here. How do we obtain it?
+					ue_decode_p(Mod_id, CC_id, frame, eNB_id,
+							Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_data,
+							Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_length);
+					i++;
+				}
+				else if(dl_config_pdu_tmp->pdu_type == NFAPI_DL_CONFIG_DLSCH_PDU_TYPE) {
+					// RA-RNTI case
+					// ue_process_rar should be called but the problem is that this function currently uses PHY_VARS_UE
+					// elements.
+
+					// C-RNTI parameter not actually used. Provided only to comply with existing function definition.
+					// Not sure about parameters to fill the preamble index. Originally it comes from PHY.
+					const rnti_t c_rnti;
+					ue_process_rar(Mod_id, CC_id, frame,
+							dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.rnti, //RA-RNTI
+							Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_data,
+							c_rnti,
+							UE_mac_inst[Mod_id].RA_prach_resources.ra_PreambleIndex,
+							Tx_req->tx_request_body.tx_pdu_list[dl_config_pdu_tmp->dlsch_pdu.dlsch_pdu_rel8.pdu_index].segments[0].segment_data);
+				}
+				else {
+					LOG_E(MAC,"[UE %d] CCid %d Frame %d, subframe %d : Cannot extract DLSCH PDU from NFAPI\n",Mod_id, CC_id,frame,subframe);
+				}
+
+			}
+			break;
+		}
+
+	}
+
+
+}
+

openair2/PHY_INTERFACE/phy_stub_UE.h

+/*
+ * phy_stub_UE.h
+ *
+ *  Created on: Sep 14, 2017
+ *      Author: montre
+ */
+
+
+#ifndef __PHY_STUB_UE__H__
+#define __PHY_STUB_UE__H__
+
+#include <stdint.h>
+#include "openair2/PHY_INTERFACE/IF_Module.h"
+//#include "openair1/PHY/LTE_TRANSPORT/defs.h"
+//#include "openair1/PHY/defs.h"
+//#include "openair1/PHY/LTE_TRANSPORT/defs.h"
+
+
+// Panos: This function should return all the sched_response config messages which concern a specific UE. Inside this
+// function we should somehow make the translation of config message's rnti to Mod_ID.
+Sched_Rsp_t get_nfapi_sched_response(uint8_t Mod_id);
+
+// This function will be processing DL_config and Tx.requests and trigger all the MAC Rx related calls at the UE side,
+// namely:ue_send_sdu(), or ue_decode_si(), or ue_decode_p(), or ue_process_rar() based on the rnti type.
+void handle_nfapi_UE_Rx(uint8_t Mod_id, Sched_Rsp_t *Sched_INFO, int eNB_id);
+
+// This function will be processing UL and HI_DCI0 config requests to trigger all the MAC Tx related calls
+// at the UE side, namely: ue_get_SR(), ue_get_rach(), ue_get_sdu() based on the pdu configuration type.
+// The output of these calls will be put to an UL_IND_t structure which will then be the input to
+// send_nfapi_UL_indications().
+UL_IND_t generate_nfapi_UL_indications(Sched_Rsp_t sched_response);
+
+// This function should pass the UL indication messages to the eNB side through the socket interface.
+void send_nfapi_UL_indications(UL_IND_t UL_INFO);
+
+
+#endif /* PHY_STUB_UE_H_ */

targets/RT/USER/lte-enb.c

@@ -163,6 +163,7 @@ static inline int rxtx(PHY_VARS_eNB *eNB,eNB_rxtx_proc_t *proc, char *thread_nam
 #endif
   }
   // UE-specific RX processing for subframe n
+  // Panos: Substitute with call to get_nfapi_indications() from the socket.
   phy_procedures_eNB_uespec_RX(eNB, proc, no_relay );
 
   pthread_mutex_lock(&eNB->UL_INFO_mutex);
@@ -183,6 +184,7 @@ static inline int rxtx(PHY_VARS_eNB *eNB,eNB_rxtx_proc_t *proc, char *thread_nam
   
   if (oai_exit) return(-1);
   
+  // Panos: Substitute with call to send_nfapi_sched_response() to the UE through the socket.
   phy_procedures_eNB_TX(eNB, proc, no_relay, NULL, 1);
   
   if (release_thread(&proc->mutex_rxtx,&proc->instance_cnt_rxtx,thread_name)<0) return(-1);

targets/RT/USER/lte-ue.c

@@ -569,6 +569,10 @@ static void *UE_thread_rxn_txnp4(void *arg) {
     PHY_VARS_UE    *UE   = rtd->UE;
     int ret;
 
+    // Panos: Call (Sched_Rsp_t) get_nfapi_sched_response(UE->Mod_ID) to get all
+    //sched_response config messages which concern the specific UE. Inside this
+    //function we should somehow make the translation of rnti to Mod_ID.
+
     proc->instance_cnt_rxtx=-1;
     proc->subframe_rx=proc->sub_frame_start;
 
@@ -624,6 +628,7 @@ static void *UE_thread_rxn_txnp4(void *arg) {
                        (sf_type==SF_UL? "SF_UL" :
                         (sf_type==SF_S ? "SF_S"  : "UNKNOWN_SF_TYPE"))));
             }
+            // Panos: Substitute with call to handle_nfapi_UE_Rx(Sched_Resp).
             phy_procedures_UE_RX( UE, proc, 0, 0, UE->mode, no_relay, NULL );
         }
 
@@ -666,8 +671,11 @@ static void *UE_thread_rxn_txnp4(void *arg) {
 
         if ((subframe_select( &UE->frame_parms, proc->subframe_tx) == SF_UL) ||
 	    (UE->frame_parms.frame_type == FDD) )
-            if (UE->mode != loop_through_memory)
-                phy_procedures_UE_TX(UE,proc,0,0,UE->mode,no_relay);
+            if (UE->mode != loop_through_memory){
+            	// Panos: Substitute with call to generate_nfapi_UL_indications and then send_nfapi_UL_indications()
+            	phy_procedures_UE_TX(UE,proc,0,0,UE->mode,no_relay);
+            }
+