Added agent support for remote scheduler

cmake_targets/CMakeLists.txt

@@ -1099,6 +1099,7 @@ set (MAC_SRC
   ${MAC_DIR}/config.c
   ${MAC_DIR}/eNB_agent_scheduler_dlsch_ue.c
   ${MAC_DIR}/eNB_agent_scheduler_dataplane.c
+  ${MAC_DIR}/eNB_agent_scheduler_dlsch_ue_remote.c
  )
 
 set (ENB_APP_SRC
@@ -1113,7 +1114,7 @@ add_library(L2
   ${OPENAIR2_DIR}/RRC/L2_INTERFACE/openair_rrc_L2_interface.c)
 
 #Test for adding a shared library
-add_library(alt_sched SHARED ${MAC_DIR}/eNB_agent_scheduler_dlsch_ue_alt.c)
+#add_library(alt_sched SHARED ${MAC_DIR}/eNB_agent_scheduler_dlsch_ue_alt.c)
 
 # L3 Libs
 ##########################

openair2/ENB_APP/enb_agent.c

@@ -277,6 +277,11 @@ int enb_agent_start(mid_t mod_id, const Enb_properties_array_t* enb_properties){
   
   enb_agent_init_timer();
 
+  /*
+   * Initialize the mac agent
+   */
+  enb_agent_init_mac_agent(mod_id);
+  
   /* 
    * start the enb agent task for tx and interaction with the underlying network function
    */ 

openair2/ENB_APP/enb_agent_handler.c

@@ -55,7 +55,7 @@ enb_agent_message_decoded_callback agent_messages_callback[][3] = {
   {0, 0, 0}, /*PROTOCOL__PROGRAN_MESSAGE__MSG_UE_CONFIG_REPLY_MSG*/
   {enb_agent_lc_config_reply, 0, 0}, /*PROTOCOL__PROGRAN_MESSAGE__MSG_LC_CONFIG_REQUEST_MSG*/
   {0, 0, 0}, /*PROTOCOL__PROGRAN_MESSAGE__MSG_LC_CONFIG_REPLY_MSG*/
-  {0, 0, 0}, /*PROTOCOL__PROGRAN_MESSAGE__MSG_DL_MAC_CONFIG_MSG*/
+  {enb_agent_mac_handle_dl_mac_config, 0, 0}, /*PROTOCOL__PROGRAN_MESSAGE__MSG_DL_MAC_CONFIG_MSG*/
   {0, 0, 0}, /*PROTOCOL__PROGRAN_MESSAGE__MSG_UE_STATE_CHANGE_MSG*/
   {enb_agent_control_delegation, 0, 0}, /*PROTOCOL__PROGRAN_MESSAGE__MSG_CONTROL_DELEGATION_MSG*/
 
@@ -116,10 +116,9 @@ Protocol__ProgranMessage* enb_agent_handle_message (mid_t mod_id,
   err_code = ((*agent_messages_callback[decoded_message->msg_case-1][decoded_message->msg_dir-1])(mod_id, (void *) decoded_message, &reply_message));
   if ( err_code < 0 ){
     goto error;
-  }
-  
+  } else if (err_code == 1) { //If err_code > 1, we do not want to dispose the message yet
     protocol__progran_message__free_unpacked(decoded_message, NULL);
-
+  }
   return reply_message;
   
 error:

openair2/ENB_APP/enb_agent_mac.c

@@ -42,6 +42,8 @@
 #include "LAYER2/MAC/proto.h"
 #include "LAYER2/MAC/enb_agent_mac_proto.h"
 
+#include "liblfds700.h"
+
 #include "log.h"
 
 
@@ -51,6 +53,13 @@ unsigned int mac_agent_registered[NUM_MAX_ENB];
 /*Array containing the Agent-MAC interfaces*/
 AGENT_MAC_xface *agent_mac_xface[NUM_MAX_ENB];
 
+/* Ringbuffer related structs used for maintaining the dl mac config messages */
+//message_queue_t *dl_mac_config_queue;
+struct lfds700_misc_prng_state ps[NUM_MAX_ENB];
+struct lfds700_ringbuffer_element *dl_mac_config_array[NUM_MAX_ENB];
+struct lfds700_ringbuffer_state ringbuffer_state[NUM_MAX_ENB];
+
+
 int enb_agent_mac_handle_stats(mid_t mod_id, const void *params, Protocol__ProgranMessage **msg){
 
   // TODO: Must deal with sanitization of input
@@ -1154,6 +1163,56 @@ int enb_agent_mac_destroy_dl_config(Protocol__ProgranMessage *msg) {
   return -1;
 }
 
+void enb_agent_get_pending_dl_mac_config(mid_t mod_id, Protocol__ProgranMessage **msg) {
+
+  struct lfds700_misc_prng_state ls;
+  
+  LFDS700_MISC_MAKE_VALID_ON_CURRENT_LOGICAL_CORE_INITS_COMPLETED_BEFORE_NOW_ON_ANY_OTHER_LOGICAL_CORE;
+  lfds700_misc_prng_init(&ls);
+  
+  if (lfds700_ringbuffer_read(&ringbuffer_state[mod_id], NULL, (void **) msg, &ls) == 0) {
+    *msg = NULL;
+  }
+}
+
+int enb_agent_mac_handle_dl_mac_config(mid_t mod_id, const void *params, Protocol__ProgranMessage **msg) {
+
+  struct lfds700_misc_prng_state ls;
+  enum lfds700_misc_flag overwrite_occurred_flag;
+  Protocol__ProgranMessage *overwritten_dl_config;
+   
+  LFDS700_MISC_MAKE_VALID_ON_CURRENT_LOGICAL_CORE_INITS_COMPLETED_BEFORE_NOW_ON_ANY_OTHER_LOGICAL_CORE;
+  lfds700_misc_prng_init(&ls);
+  
+  lfds700_ringbuffer_write( &ringbuffer_state[mod_id],
+			    NULL,
+			    (void *) params,
+			    &overwrite_occurred_flag,
+			    NULL,
+			    (void **)&overwritten_dl_config,
+			    &ls);
+
+  if (overwrite_occurred_flag == LFDS700_MISC_FLAG_RAISED) {
+    // Delete unmanaged dl_config
+    enb_agent_mac_destroy_dl_config(overwritten_dl_config);
+  }
+  *msg = NULL;
+  return 2;
+
+ error:
+  *msg = NULL;
+  return -1;
+}
+
+void enb_agent_init_mac_agent(mid_t mod_id) {
+  lfds700_misc_library_init_valid_on_current_logical_core();
+  lfds700_misc_prng_init(&ps[mod_id]);
+  int num_elements = RINGBUFFER_SIZE + 1;
+  //Allow RINGBUFFER_SIZE messages to be stored in the ringbuffer at any time
+  dl_mac_config_array[mod_id] = malloc( sizeof(struct lfds700_ringbuffer_element) *  num_elements);
+  lfds700_ringbuffer_init_valid_on_current_logical_core( &ringbuffer_state[mod_id], dl_mac_config_array[mod_id], num_elements, &ps[mod_id], NULL );
+}
+
 /***********************************************
  * eNB agent - technology mac API implementation
  ***********************************************/
@@ -1284,6 +1343,7 @@ int enb_agent_register_mac_xface(mid_t mod_id, AGENT_MAC_xface *xface) {
   xface->enb_agent_send_sf_trigger = enb_agent_send_sf_trigger;
   xface->enb_agent_send_update_mac_stats = enb_agent_send_update_mac_stats;
   xface->enb_agent_schedule_ue_spec = schedule_ue_spec_default;
+  xface->enb_agent_get_pending_dl_mac_config = enb_agent_get_pending_dl_mac_config;
   xface->enb_agent_notify_ue_state_change = enb_agent_ue_state_change;
 
   mac_agent_registered[mod_id] = 1;
@@ -1299,6 +1359,8 @@ int enb_agent_unregister_mac_xface(mid_t mod_id, AGENT_MAC_xface *xface) {
   xface->enb_agent_send_sf_trigger = NULL;
   xface->enb_agent_send_update_mac_stats = NULL;
   xface->enb_agent_schedule_ue_spec = NULL;
+  xface->enb_agent_get_pending_dl_mac_config = NULL;
+  xface->enb_agent_notify_ue_state_change = NULL;
 
   mac_agent_registered[mod_id] = 0;
   agent_mac_xface[mod_id] = NULL;

openair2/ENB_APP/enb_agent_mac.h

@@ -76,6 +76,9 @@ typedef struct stats_request_config_s{
   report_config_t *config;
 } stats_request_config_t;
 
+/* Initialization function for the agent structures etc */
+void enb_agent_init_mac_agent(mid_t mod_id);
+
 int enb_agent_mac_handle_stats(mid_t mod_id, const void *params, Protocol__ProgranMessage **msg);
 
 int enb_agent_mac_stats_request(mid_t mod_id, xid_t xid, const stats_request_config_t *report_config, Protocol__ProgranMessage **msg);
@@ -98,6 +101,8 @@ int enb_agent_mac_create_empty_dl_config(mid_t mod_id, Protocol__ProgranMessage
 
 int enb_agent_mac_destroy_dl_config(Protocol__ProgranMessage *msg);
 
+int enb_agent_mac_handle_dl_mac_config(mid_t mod_id, const void *params, Protocol__ProgranMessage **msg);
+
 
 /**********************************
  * eNB agent - technology mac API
@@ -113,6 +118,9 @@ void enb_agent_send_sf_trigger(mid_t mod_id);
 /// based on the stats request configuration
 void enb_agent_send_update_mac_stats(mid_t mod_id);
 
+/// Provide to the scheduler a pending dl_mac_config message
+void enb_agent_get_pending_dl_mac_config(mid_t mod_id, Protocol__ProgranMessage **msg);
+
 /*Register technology specific interface callbacks*/
 int enb_agent_register_mac_xface(mid_t mod_id, AGENT_MAC_xface *xface);
 

openair2/ENB_APP/enb_agent_mac_defs.h

@@ -42,6 +42,8 @@
 #include "progran.pb-c.h"
 #include "header.pb-c.h"
 
+#define RINGBUFFER_SIZE 100
+
 /* ENB AGENT-MAC Interface */
 typedef struct {
   //msg_context_t *agent_ctxt;
@@ -56,11 +58,15 @@ typedef struct {
   /// based on the stats request configuration
   void (*enb_agent_send_update_mac_stats)(mid_t mod_id);
 
+  /// Provide to the scheduler a pending dl_mac_config message
+  void (*enb_agent_get_pending_dl_mac_config)(mid_t mod_id,
+					      Protocol__ProgranMessage **msg);
+  
   /// Run the UE DL scheduler and fill the Protocol__ProgranMessage. Assumes that
   /// dl_info is already initialized as prp_dl_mac_config and fills the
   /// prp_dl_data part of it
   void (*enb_agent_schedule_ue_spec)(mid_t mod_id, uint32_t frame, uint32_t subframe,
-				     int *mbsfn_flag, Protocol__ProgranMessage *dl_info);
+				     int *mbsfn_flag, Protocol__ProgranMessage **dl_info);
 
 
   /// Notify the controller for a state change of a particular UE, by sending the proper

openair2/LAYER2/MAC/eNB_agent_scheduler_dataplane.c

@@ -69,7 +69,7 @@ void apply_dl_scheduling_decisions(mid_t mod_id,
 				   uint32_t frame,
 				   uint32_t subframe,
 				   int *mbsfn_flag,
-				   Protocol__ProgranMessage *dl_scheduling_info) {
+				   const Protocol__ProgranMessage *dl_scheduling_info) {
 
   Protocol__PrpDlMacConfig *mac_config = dl_scheduling_info->dl_mac_config_msg;
 

openair2/LAYER2/MAC/eNB_agent_scheduler_dlsch_ue.c

@@ -64,6 +64,7 @@
 
 #include "header.pb-c.h"
 #include "progran.pb-c.h"
+#include "enb_agent_mac.h"
 
 #include "SIMULATION/TOOLS/defs.h" // for taus
 
@@ -80,7 +81,7 @@ schedule_ue_spec_default(
   uint32_t      frame,
   uint32_t      subframe,
   int           *mbsfn_flag,
-  Protocol__ProgranMessage *dl_info
+  Protocol__ProgranMessage **dl_info
 )
 //------------------------------------------------------------------------------
 {
@@ -126,6 +127,7 @@ schedule_ue_spec_default(
   uint8_t ue_has_transmission = 0;
   uint32_t ndi;
   
+  enb_agent_mac_create_empty_dl_config(mod_id, dl_info);
   
   if (UE_list->head==-1) {
     return;
@@ -763,10 +765,10 @@ schedule_ue_spec_default(
    } // CC_id loop
 
    // Add all the dl_data elements to the progran message
-   dl_info->dl_mac_config_msg->n_dl_ue_data = num_ues_added;
-   dl_info->dl_mac_config_msg->dl_ue_data = (Protocol__PrpDlData **) malloc(sizeof(Protocol__PrpDlData *) * num_ues_added);
+   (*dl_info)->dl_mac_config_msg->n_dl_ue_data = num_ues_added;
+   (*dl_info)->dl_mac_config_msg->dl_ue_data = (Protocol__PrpDlData **) malloc(sizeof(Protocol__PrpDlData *) * num_ues_added);
    for (i = 0; i < num_ues_added; i++) {
-     dl_info->dl_mac_config_msg->dl_ue_data[i] = dl_data[i];
+     (*dl_info)->dl_mac_config_msg->dl_ue_data[i] = dl_data[i];
    }
    
    stop_meas(&eNB->schedule_dlsch);

openair2/LAYER2/MAC/eNB_agent_scheduler_dlsch_ue_remote.c

+/*******************************************************************************
+    OpenAirInterface
+    Copyright(c) 1999 - 2014 Eurecom
+
+    OpenAirInterface is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+
+    OpenAirInterface is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with OpenAirInterface.The full GNU General Public License is
+    included in this distribution in the file called "COPYING". If not,
+    see <http://www.gnu.org/licenses/>.
+
+  Contact Information
+  OpenAirInterface Admin: openair_admin@eurecom.fr
+  OpenAirInterface Tech : openair_tech@eurecom.fr
+  OpenAirInterface Dev  : openair4g-devel@lists.eurecom.fr
+
+  Address      : Eurecom, Campus SophiaTech, 450 Route des Chappes, CS 50193 - 06904 Biot Sophia Antipolis cedex, FRANCE
+
+*******************************************************************************/
+
+/*! \file eNB_agent_scheduler_dlsch_ue_remote.c
+ * \brief procedures related to remote scheduling in the DLSCH transport channel
+ * \author Xenofon Foukas
+ * \date 2016
+ * \email: x.foukas@sms.ed.ac.uk
+ * \version 0.1
+ * @ingroup _mac
+
+ */
+
+#include "eNB_agent_scheduler_dlsch_ue_remote.h"
+
+struct DlMacConfigHead queue_head;
+
+int queue_initialized = 0;
+
+void schedule_ue_spec_remote(mid_t mod_id, uint32_t frame, uint32_t subframe,
+			     int *mbsfn_flag, Protocol__ProgranMessage **dl_info) {
+
+  if (queue_initialized) {
+    TAILQ_INIT(&queue_head);
+    queue_initialized = 1;
+  }
+
+  dl_mac_config_element_t *dl_config_elem;
+
+  int diff;
+  
+  // First we check to see if we have a scheduling decision for this sfn_sf already in our queue
+  while(queue_head.tqh_first != NULL) {
+    dl_config_elem = queue_head.tqh_first;
+    diff = get_sf_difference(mod_id, dl_config_elem->dl_info->dl_mac_config_msg->sfn_sf);
+    // Check if this decision is for now, for a later or a previous subframe
+    if ( diff == 0) { // Now
+      TAILQ_REMOVE(&queue_head, queue_head.tqh_first, configs);
+      *dl_info = dl_config_elem->dl_info;
+      free(dl_config_elem);
+      return;
+    } else if (diff < 0) { //previous subframe , delete message and free memory
+      TAILQ_REMOVE(&queue_head, queue_head.tqh_first, configs);
+      enb_agent_mac_destroy_dl_config(dl_config_elem->dl_info);
+      free(dl_config_elem);
+    } else { // next subframe, nothing to do now
+      enb_agent_create_empty_dl_config(mod_id, dl_info);
+      return;
+    }
+  }
+
+  //Done with the local cache. Now we need to check if something new arrived
+  enb_agent_get_pending_dl_mac_config(mod_id, dl_info);
+  while (*dl_info != NULL) {
+
+    diff = get_sf_difference(mod_id, (*dl_info)->dl_mac_config_msg->sfn_sf);
+    if (diff == 0) { // Got a command for this sfn_sf
+      return;
+    } else if (diff < 0) {
+      enb_agent_mac_destroy_dl_config(*dl_info);
+    } else { // Intended for future subframe. Store it in local cache
+      dl_mac_config_element_t *e = malloc(sizeof(dl_mac_config_element_t));
+      TAILQ_INSERT_TAIL(&queue_head, e, configs);
+      enb_agent_create_empty_dl_config(mod_id, dl_info);
+      // No need to look for another. Messages arrive ordered
+      return;
+    }
+    enb_agent_get_pending_dl_mac_config(mod_id, dl_info);
+  }
+  
+  // We found no pending command, so we will simply pass an empty one
+  enb_agent_create_empty_dl_config(mod_id, dl_info);
+}
+
+int get_sf_difference(mid_t mod_id, uint16_t sfn_sf) {
+  int diff_in_subframes;
+  
+  uint16_t current_frame = get_current_system_frame_num(mod_id);
+  uint16_t current_subframe = get_current_subframe(mod_id);
+  uint16_t current_sfn_sf = get_sfn_sf(mod_id);
+  
+  if (sfn_sf == current_sfn_sf) {
+    return 0;
+  }
+  
+  uint16_t frame_mask = !((1<<4) - 1);
+  uint16_t frame = (sfn_sf & frame_mask) >> 4;
+  
+  uint16_t sf_mask = !(((1<<12) - 1) << 4);
+  uint16_t subframe = (sfn_sf & sf_mask);
+  
+  if (frame == current_frame) {
+    return subframe - current_subframe;
+  } else if (frame > current_frame) {
+    diff_in_subframes = 9 - current_subframe;
+    diff_in_subframes += subframe;
+    diff_in_subframes += (frame-2) * 10;
+    if (diff_in_subframes > SCHED_AHEAD_SUBFRAMES) {
+      return -1;
+    } else {
+      return 1;
+    }
+  } else { //frame < current_frame
+    diff_in_subframes = 9 - current_subframe;
+    diff_in_subframes += subframe;
+    if (frame > 0) {
+      diff_in_subframes += (frame - 1) * 10;
+    }
+    diff_in_subframes += (1023 - current_frame) * 10;
+    if (diff_in_subframes > SCHED_AHEAD_SUBFRAMES) {
+      return -1;
+    } else {
+      return 1;
+    }
+  }
+}

openair2/LAYER2/MAC/eNB_agent_scheduler_dlsch_ue_remote.h

+/*******************************************************************************
+    OpenAirInterface
+    Copyright(c) 1999 - 2014 Eurecom
+
+    OpenAirInterface is free software: you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+
+    OpenAirInterface is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with OpenAirInterface.The full GNU General Public License is
+    included in this distribution in the file called "COPYING". If not,
+    see <http://www.gnu.org/licenses/>.
+
+  Contact Information
+  OpenAirInterface Admin: openair_admin@eurecom.fr
+  OpenAirInterface Tech : openair_tech@eurecom.fr
+  OpenAirInterface Dev  : openair4g-devel@lists.eurecom.fr
+
+  Address      : Eurecom, Campus SophiaTech, 450 Route des Chappes, CS 50193 - 06904 Biot Sophia Antipolis cedex, FRANCE
+
+*******************************************************************************/
+
+/*! \file eNB_agent_scheduler_dlsch_ue_remote.h
+ * \brief Local stub for remote scheduler used by the controller
+ * \author Xenofon Foukas
+ * \date 2016
+ * \email: x.foukas@sms.ed.ac.uk
+ * \version 0.1
+ * @ingroup _mac
+
+ */
+
+#ifndef __LAYER2_MAC_ENB_AGENT_SCHEDULER_DLSCH_UE_REMOTE_H__
+#define __LAYER2_MAC_ENB_AGENT_SCHEDULER_DLSCH_UE_REMOTE_H___
+
+#include "progran.pb-c.h"
+#include "header.pb-c.h"
+
+#include "ENB_APP/enb_agent_defs.h"
+#include "enb_agent_mac.h"
+
+#include <sys/queue.h>
+
+// Maximum value of schedule ahead of time
+// Required to identify if a dl_command is for the future or not
+#define SCHED_AHEAD_SUBFRAMES 10
+
+typedef struct dl_mac_config_element_s {
+  Protocol__ProgranMessage *dl_info;
+  TAILQ_ENTRY(dl_mac_config_element_s) configs;
+} dl_mac_config_element_t;
+
+TAILQ_HEAD(DlMacConfigHead, dl_mac_config_element_s);
+
+/*
+ * Default scheduler used by the eNB agent
+ */
+void schedule_ue_spec_remote(mid_t mod_id, uint32_t frame, uint32_t subframe,
+			     int *mbsfn_flag, Protocol__ProgranMessage **dl_info);
+
+
+// Find the difference in subframes from the given subframe
+// negative for older value
+// 0 for equal
+// positive for future value
+// Based on  
+int get_sf_difference(mid_t mod_id, uint16_t sfn_sf);
+
+#endif

openair2/LAYER2/MAC/enb_agent_mac_proto.h

@@ -48,14 +48,13 @@
  * Default scheduler used by the eNB agent
  */
 void schedule_ue_spec_default(mid_t mod_id, uint32_t frame, uint32_t subframe,
-				     int *mbsfn_flag, Protocol__ProgranMessage *dl_info);
-
+				     int *mbsfn_flag, Protocol__ProgranMessage **dl_info);
 
 /*
  * Data plane function for applying the DL decisions of the scheduler
  */
 void apply_dl_scheduling_decisions(mid_t mod_id, uint32_t frame, uint32_t subframe, int *mbsfn_flag,
-				Protocol__ProgranMessage *dl_scheduling_info);
+				const Protocol__ProgranMessage *dl_scheduling_info);
 
 /*
  * Data plane function for applying the UE specific DL decisions of the scheduler