Separating msg packing from the main S1AP class.

srsepc/hdr/mme/s1ap_mngmt_proc.h

@@ -0,0 +1,63 @@
+/**
+ *
+ * \section COPYRIGHT
+ *
+ * Copyright 2013-2017 Software Radio Systems Limited
+ *
+ * \section LICENSE
+ *
+ * This file is part of srsLTE.
+ *
+ * srsLTE is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, either version 3 of
+ * the License, or (at your option) any later version.
+ *
+ * srsLTE 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 Affero General Public License for more details.
+ *
+ * A copy of the GNU Affero General Public License can be found in
+ * the LICENSE file in the top-level directory of this distribution
+ * and at http://www.gnu.org/licenses/.
+ *
+ */
+#ifndef S1AP_MNGMT_PROC_H
+#define S1AP_MNGMT_PROC_H
+
+#include "srslte/asn1/liblte_s1ap.h"
+#include "srslte/common/common.h"
+namespace srsepc{
+
+static const uint8_t MAX_TA=255;
+static const uint8_t MAX_BPLMN=6;
+
+typedef struct{
+  bool     enb_name_present;
+  uint32_t enb_id;
+  uint8_t  enb_name[150];
+  uint16_t mcc, mnc;
+  uint32_t plmn;
+  uint8_t  nof_supported_ta;
+  uint16_t tac[MAX_TA];
+  uint8_t  nof_supported_bplmns[MAX_TA];
+  uint16_t bplmns[MAX_TA][MAX_BPLMN];
+  LIBLTE_S1AP_PAGINGDRX_ENUM drx;
+  struct   sctp_sndrcvinfo sri;
+} enb_ctx_t;
+
+class s1ap_mngmt_proc
+{
+public:
+  s1ap_mngmt_proc();
+  virtual ~s1ap_mngmt_proc();
+
+  bool unpack_s1_setup_request(LIBLTE_S1AP_MESSAGE_S1SETUPREQUEST_STRUCT *msg, enb_ctx_t* enb_ctx);
+  bool pack_s1_setup_failure(LIBLTE_S1AP_CAUSEMISC_ENUM cause, srslte::byte_buffer_t* msg);
+  bool pack_s1_setup_response(LIBLTE_S1AP_S1AP_PDU_STRUCT *pdu);
+};
+
+} //namespace srsepc
+
+#endif //S1AP_MNGMT_PROC

srsepc/src/mme/s1ap_mngmt_proc.cc

@@ -0,0 +1,184 @@
+/**
+ *
+ * \section COPYRIGHT
+ *
+ * Copyright 2013-2017 Software Radio Systems Limited
+ *
+ * \section LICENSE
+ *
+ * This file is part of srsLTE.
+ *
+ * srsLTE is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, either version 3 of
+ * the License, or (at your option) any later version.
+ *
+ * srsLTE 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 Affero General Public License for more details.
+ *
+ * A copy of the GNU Affero General Public License can be found in
+ * the LICENSE file in the top-level directory of this distribution
+ * and at http://www.gnu.org/licenses/.
+ *
+ */
+
+//#include "srslte/upper/s1ap_common.h"
+#include "srslte/common/bcd_helpers.h"
+#include "mme/s1ap.h"
+#include "mme/s1ap_mngmt_proc.h"
+
+namespace srsepc{
+
+s1ap_mngmt_proc::s1ap_mngmt_proc()
+{
+}
+
+s1ap_mngmt_proc::~s1ap_mngmt_proc()
+{
+}
+
+bool 
+s1ap_mngmt_proc::unpack_s1_setup_request(LIBLTE_S1AP_MESSAGE_S1SETUPREQUEST_STRUCT *msg, enb_ctx_t* enb_ctx)
+{
+  
+  uint8_t enb_id_bits[32];
+  uint32_t plmn = 0;  
+  uint16_t tac, bplmn;
+
+  uint32_t tmp32=0;
+  //eNB Name
+  enb_ctx->enb_name_present=msg->eNBname_present;
+  if(msg->eNBname_present)
+  {
+    bzero(enb_ctx->enb_name,sizeof(enb_ctx->enb_name));
+    memcpy(enb_ctx->enb_name,&msg->eNBname.buffer,msg->eNBname.n_octets);
+  }
+  //eNB Id
+  bzero(enb_id_bits,sizeof(enb_id_bits));
+  memcpy(&enb_id_bits[32-LIBLTE_S1AP_MACROENB_ID_BIT_STRING_LEN], msg->Global_ENB_ID.eNB_ID.choice.macroENB_ID.buffer, LIBLTE_S1AP_MACROENB_ID_BIT_STRING_LEN);
+  liblte_pack(enb_id_bits, 32, (uint8_t*) &tmp32);
+  enb_ctx->enb_id=ntohl(tmp32);
+  
+  //PLMN Id
+  ((uint8_t*)&plmn)[1] = msg->Global_ENB_ID.pLMNidentity.buffer[0];
+  ((uint8_t*)&plmn)[2] = msg->Global_ENB_ID.pLMNidentity.buffer[1];
+  ((uint8_t*)&plmn)[3] = msg->Global_ENB_ID.pLMNidentity.buffer[2];
+
+  enb_ctx->plmn = ntohl(plmn);
+  srslte::s1ap_plmn_to_mccmnc(enb_ctx->plmn, &enb_ctx->mcc, &enb_ctx->mnc);
+
+  //SupportedTAs
+  enb_ctx->nof_supported_ta=msg->SupportedTAs.len;
+  for(uint16_t i=0; i<msg->SupportedTAs.len; i++)
+  {
+    //TAC
+    ((uint8_t*)&enb_ctx->tac[i])[0] = msg->SupportedTAs.buffer[i].tAC.buffer[0];
+    ((uint8_t*)&enb_ctx->tac[i])[1] = msg->SupportedTAs.buffer[i].tAC.buffer[1];
+    enb_ctx->tac[i]=ntohs(enb_ctx->tac[i]);
+    enb_ctx->nof_supported_bplmns[i]=msg->SupportedTAs.buffer[i].broadcastPLMNs.len;
+    for (uint16_t j=0; j<msg->SupportedTAs.buffer[i].broadcastPLMNs.len; j++)
+    {
+      //BPLMNs
+      ((uint8_t*)&enb_ctx->bplmns[i][j])[1] = msg->SupportedTAs.buffer[i].broadcastPLMNs.buffer[j].buffer[0];
+      ((uint8_t*)&enb_ctx->bplmns[i][j])[2] = msg->SupportedTAs.buffer[i].broadcastPLMNs.buffer[j].buffer[1];
+      ((uint8_t*)&enb_ctx->bplmns[i][j])[3] = msg->SupportedTAs.buffer[i].broadcastPLMNs.buffer[j].buffer[2];
+
+      enb_ctx->bplmns[i][j] = ntohl(enb_ctx->bplmns[i][j]);
+    }
+  }
+
+  //Default Paging DRX
+  enb_ctx->drx = msg->DefaultPagingDRX.e;
+
+  return true;
+}
+
+bool
+s1ap_mngmt_proc::pack_s1_setup_failure(LIBLTE_S1AP_CAUSEMISC_ENUM cause, srslte::byte_buffer_t *msg)
+{
+  LIBLTE_S1AP_S1AP_PDU_STRUCT pdu;
+  bzero(&pdu, sizeof(LIBLTE_S1AP_S1AP_PDU_STRUCT));
+
+  pdu.choice_type = LIBLTE_S1AP_S1AP_PDU_CHOICE_UNSUCCESSFULOUTCOME;
+
+  LIBLTE_S1AP_UNSUCCESSFULOUTCOME_STRUCT *unsucc = &pdu.choice.unsuccessfulOutcome;
+  unsucc->procedureCode = LIBLTE_S1AP_PROC_ID_S1SETUP;
+  unsucc->criticality = LIBLTE_S1AP_CRITICALITY_REJECT;
+  unsucc->choice_type = LIBLTE_S1AP_UNSUCCESSFULOUTCOME_CHOICE_S1SETUPFAILURE;
+ 
+  LIBLTE_S1AP_MESSAGE_S1SETUPFAILURE_STRUCT* s1_fail=(LIBLTE_S1AP_MESSAGE_S1SETUPFAILURE_STRUCT*)&unsucc->choice;
+
+  s1_fail->TimeToWait_present=false;
+  s1_fail->CriticalityDiagnostics_present=false;
+  s1_fail->Cause.ext=false;
+  s1_fail->Cause.choice_type = LIBLTE_S1AP_CAUSE_CHOICE_MISC;
+  s1_fail->Cause.choice.misc.ext=false;
+  s1_fail->Cause.choice.misc.e=cause;
+  
+  liblte_s1ap_pack_s1ap_pdu(&pdu, (LIBLTE_BYTE_MSG_STRUCT*)msg);
+  return true;
+ }
+
+
+bool
+s1ap_mngmt_proc::pack_s1_setup_response(LIBLTE_S1AP_S1AP_PDU_STRUCT *pdu)
+{
+/*
+  srslte::byte_buffer_t       msg;
+  //LIBLTE_S1AP_S1AP_PDU_STRUCT pdu;
+  bzero(pdu, sizeof(LIBLTE_S1AP_S1AP_PDU_STRUCT));
+
+  pdu->choice_type = LIBLTE_S1AP_S1AP_PDU_CHOICE_SUCCESSFULOUTCOME;
+
+  LIBLTE_S1AP_SUCCESSFULOUTCOME_STRUCT *succ = &pdu->choice.successfulOutcome;
+  succ->procedureCode = LIBLTE_S1AP_PROC_ID_S1SETUP;
+  succ->criticality = LIBLTE_S1AP_CRITICALITY_IGNORE;
+  succ->choice_type = LIBLTE_S1AP_SUCCESSFULOUTCOME_CHOICE_S1SETUPRESPONSE;
+ 
+  LIBLTE_S1AP_MESSAGE_S1SETUPRESPONSE_STRUCT* s1_resp=(LIBLTE_S1AP_MESSAGE_S1SETUPRESPONSE_STRUCT*)&succ->choice;
+
+  s1_resp->ext=false;
+  
+  //MME Name
+  s1_resp->MMEname_present=true;
+  s1_resp->MMEname.ext=false;
+  s1_resp->MMEname.n_octets=m_mme_name.length();
+  memcpy(s1_resp->MMEname.buffer,m_mme_name.c_str(),m_mme_name.length());
+
+  //Served GUMEIs
+  s1_resp->ServedGUMMEIs.len=1;//TODO Only one served GUMMEI supported
+  LIBLTE_S1AP_SERVEDGUMMEISITEM_STRUCT *serv_gummei = &s1_resp->ServedGUMMEIs.buffer[0];
+
+  serv_gummei->ext=false;
+  //serv_gummei->iE_Extensions=false;
+
+  uint32_t plmn=0;
+  srslte::s1ap_mccmnc_to_plmn(m_mcc, m_mnc, &plmn);
+  plmn=htonl(plmn);
+  serv_gummei->servedPLMNs.len = 1; //Only one PLMN supported
+  serv_gummei->servedPLMNs.buffer[0].buffer[0]=((uint8_t*)&plmn)[1];
+  serv_gummei->servedPLMNs.buffer[0].buffer[1]=((uint8_t*)&plmn)[2];
+  serv_gummei->servedPLMNs.buffer[0].buffer[2]=((uint8_t*)&plmn)[3];
+
+  serv_gummei->servedGroupIDs.len=1; //LIBLTE_S1AP_SERVEDGROUPIDS_STRUCT
+  uint16_t tmp=htons(m_mme_group);
+  serv_gummei->servedGroupIDs.buffer[0].buffer[0]=((uint8_t*)&tmp)[0];
+  serv_gummei->servedGroupIDs.buffer[0].buffer[1]=((uint8_t*)&tmp)[1];
+ 
+  serv_gummei->servedMMECs.len=1; //Only one MMEC served
+  serv_gummei->servedMMECs.buffer[0].buffer[0]=m_mme_code;
+
+  //Relative MME Capacity
+  s1_resp->RelativeMMECapacity.RelativeMMECapacity=255;
+
+  //Relay Unsupported
+  s1_resp->MMERelaySupportIndicator_present=false;
+    
+  liblte_s1ap_pack_s1ap_pdu(pdu, (LIBLTE_BYTE_MSG_STRUCT*)&msg);
+*/  
+ return true;
+}
+
+} //namespace srsepc