Started to fill in the necessary information for the create session response.

srsepc/hdr/mme/mme_gtpc.h

@@ -42,6 +42,7 @@ public:
 
   void init();
   void send_create_session_request(uint64_t imsi, struct srslte::gtpc_create_session_response *cs_resp);
+  uint64_t get_new_ctrl_teid();
 
 private:
 
@@ -53,6 +54,8 @@ private:
 
   spgw* m_spgw;
   in_addr_t m_mme_gtpc_ip;
+
+  uint64_t m_next_ctrl_teid;
 };
 
 }

srsepc/hdr/spgw/spgw.h

@@ -39,6 +39,7 @@
 #include "srslte/common/log_filter.h"
 #include "srslte/common/buffer_pool.h"
 #include "srslte/common/threads.h"
+#include "srslte/asn1/gtpc.h"
 
 namespace srsepc{
 
@@ -50,6 +51,15 @@ typedef struct {
 } spgw_args_t;
 
 
+typedef struct {
+  uint64_t imsi;
+  in_addr_t ue_ipv4;
+  struct gtpc_f_teid_ie uplink_ctrl;
+  struct gtpc_f_teid_ie uplink_user;
+  struct gtpc_f_teid_ie downlink_ctrl;
+  struct gtpc_f_teid_ie downlink_user;
+} spgw_ue_ctxr;
+
 class spgw:
   public thread
 {
@@ -60,6 +70,8 @@ public:
   void stop();
   void run_thread();
 
+  void handle_create_session_request(struct srslte::gtpc_create_session_request *cs_req, struct srslte::gtpc_create_session_response *cs_resp);
+
 private:
 
   spgw();

srsepc/src/mme/mme_gtpc.cc

@@ -34,6 +34,7 @@ mme_gtpc*          mme_gtpc::m_instance = NULL;
 boost::mutex  mme_gtpc_instance_mutex;
 
 mme_gtpc::mme_gtpc()
+  :m_next_ctrl_teid(1)
 {
 }
 
@@ -69,12 +70,20 @@ mme_gtpc::init()
   m_spgw = spgw::get_instance();
 }
 
+uint64_t
+mme_gtpc::get_new_ctrl_teid()
+{
+  return m_next_ctrl_teid++; //FIXME Use a Id pool?
+}
 void
 mme_gtpc::send_create_session_request(uint64_t imsi, struct srslte::gtpc_create_session_response *cs_resp)
 {
   struct srslte::gtpc_pdu cs_req_pdu;
   struct srslte::gtpc_create_session_request *cs_req = &cs_req_pdu.choice.create_session_request;
 
+  //Initialize GTP-C message to zero
+  bzero(&cs_req_pdu, sizeof(struct srslte::gtpc_pdu));
+
   //Setup GTP-C Header. FIXME: Length, sequence and other fields need to be added.
   cs_req_pdu.header.piggyback = false;
   cs_req_pdu.header.teid_present = true;
@@ -93,7 +102,7 @@ mme_gtpc::send_create_session_request(uint64_t imsi, struct srslte::gtpc_create_
   //Save RX Control TEID
   //create_rx_control_teid(cs_req->sender_f_teid);
 
-  //spgw->handle_create_session_request(&cs_req, cs_resp);
+  m_spgw->handle_create_session_request(cs_req, cs_resp);
   return;
 }
 } //namespace srsepc

srsepc/src/spgw/spgw.cc

@@ -35,6 +35,7 @@
 #include <linux/if_tun.h>
 #include "spgw/spgw.h"
 
+
 namespace srsepc{
 
 spgw*          spgw::m_instance = NULL;
@@ -128,61 +129,6 @@ spgw::stop()
   return;
 }
 
-void
-spgw::run_thread()
-{
-  //Mark the thread as running
-  m_running=true;
-  srslte::byte_buffer_t *msg;
-  msg = m_pool->allocate();
-
-  struct sockaddr src_addr;
-  socklen_t addrlen;
-
-  int sgi = m_sgi_if;
-
-  fd_set set;
-  //struct timeval to;
-  int max_fd = std::max(m_s1u,sgi);
-  while (m_running)
-  {
-    msg->reset();
-    FD_ZERO(&set);
-    FD_SET(m_s1u, &set);
-    FD_SET(sgi, &set);
-
-    m_spgw_log->info("Waiting for S1-U or SGi packets.\n");
-    int n = select(max_fd+1, &set, NULL, NULL, NULL);
-    if (n == -1)
-    {
-      m_spgw_log->error("Error from select\n");
-    }
-    else if (n)
-    {
-      m_spgw_log->info("Data is available now.\n");
-      if (FD_ISSET(m_s1u, &set))
-      {
-          msg->N_bytes = recvfrom(m_s1u, msg->msg, SRSLTE_MAX_BUFFER_SIZE_BYTES, 0, &src_addr, &addrlen );
-          m_spgw_log->console("Received PDU from S1-U. Bytes %d\n", msg->N_bytes);
-          m_spgw_log->debug("Received PDU from S1-U. Bytes %d\n", msg->N_bytes);
-      }
-      if (FD_ISSET(m_sgi_if, &set))
-      {
-          m_spgw_log->console("Received PDU from SGi\n");
-          msg->N_bytes = read(sgi, msg->msg, SRSLTE_MAX_BUFFER_SIZE_BYTES);
-          m_spgw_log->console("Received PDU from SGi. Bytes %d\n", msg->N_bytes);
-          m_spgw_log->debug("Received PDU from SGi. Bytes %d\n", msg->N_bytes);
-      }
-    }
-    else
-    {
-      m_spgw_log->debug("No data from select.\n");
-    }
-  }
-  m_pool->deallocate(msg);
-  return;
-}
-
 srslte::error_t
 spgw::init_sgi_if(spgw_args_t *args)
 {
@@ -283,4 +229,97 @@ spgw::init_s1u(spgw_args_t *args)
   return srslte::ERROR_NONE;
 }
 
+void
+spgw::run_thread()
+{
+  //Mark the thread as running
+  m_running=true;
+  srslte::byte_buffer_t *msg;
+  msg = m_pool->allocate();
+
+  struct sockaddr src_addr;
+  socklen_t addrlen;
+
+  int sgi = m_sgi_if;
+
+  fd_set set;
+  //struct timeval to;
+  int max_fd = std::max(m_s1u,sgi);
+  while (m_running)
+  {
+    msg->reset();
+    FD_ZERO(&set);
+    FD_SET(m_s1u, &set);
+    FD_SET(sgi, &set);
+
+    m_spgw_log->info("Waiting for S1-U or SGi packets.\n");
+    int n = select(max_fd+1, &set, NULL, NULL, NULL);
+    if (n == -1)
+    {
+      m_spgw_log->error("Error from select\n");
+    }
+    else if (n)
+    {
+      m_spgw_log->info("Data is available now.\n");
+      if (FD_ISSET(m_s1u, &set))
+      {
+          msg->N_bytes = recvfrom(m_s1u, msg->msg, SRSLTE_MAX_BUFFER_SIZE_BYTES, 0, &src_addr, &addrlen );
+          m_spgw_log->console("Received PDU from S1-U. Bytes %d\n", msg->N_bytes);
+          m_spgw_log->debug("Received PDU from S1-U. Bytes %d\n", msg->N_bytes);
+      }
+      if (FD_ISSET(m_sgi_if, &set))
+      {
+          m_spgw_log->console("Received PDU from SGi\n");
+          msg->N_bytes = read(sgi, msg->msg, SRSLTE_MAX_BUFFER_SIZE_BYTES);
+          m_spgw_log->console("Received PDU from SGi. Bytes %d\n", msg->N_bytes);
+          m_spgw_log->debug("Received PDU from SGi. Bytes %d\n", msg->N_bytes);
+      }
+    }
+    else
+    {
+      m_spgw_log->debug("No data from select.\n");
+    }
+  }
+  m_pool->deallocate(msg);
+  return;
+}
+
+
+
+
+void
+spgw::handle_create_session_request(struct srslte::gtpc_create_session_request *cs_req, struct srslte::gtpc_create_session_response *cs_resp)
+{
+  //Setup uplink control TEID
+  uint64_t spgw_uplink_ctrl_teid = get_new_ctrl_teid();
+  //Setup uplink user TEID
+  uint64_t spgw_uplink_user_teid = get_new_user_teid();
+  //Allocate UE IP
+  in_addr_t ue_ip = get_new_ue_ipv4();
+
+  //Save the UE context //TODO!!!
+
+  //Create session response message
+  //Initialize to zero\\
+  bzero(cs_resp,sizeof(struct srslte::gtpc_create_session_response));
+  //Setup Cause\\
+  cs_resp->cause = ;
+  //Setup sender F-TEID (ctrl)\\
+  cs_resp->sender_f_teid.teid_present = true;
+  cs_resp->sender_f_teid.teid = spgw_uplink_ctrl_teid;
+  cs_resp->sender_f_teid.ipv4 = m_gtpu_bind_addr;//FIXME This is not relevant, as the GTP-C is not transmitted over sockets yet.
+  //Bearer context created\\
+  cs_resp->eps_bearer_context_created.ebi = 5;
+  cs_resp->eps_bearer_context_created.cause = ;
+  cs_resp->eps_bearer_context_created.s1_u_sgw_f_teid_present=true;
+  cs_resp->eps_bearer_context_created.s1_u_sgw_f_teid.teid = spgw_uplink_user_teid;
+  //Fill in the PDA\\
+  cs_resp->pda_present = true;
+  cs_resp->pda.pdn_type = srslte::GTPC_IPV4;
+  cs_resp->ipv4_present = true;
+  cs_resp->ipv4 = ue_ip;
+  
+  return;
+}
+
 } //namespace srsepc