PentHertz
/
srsLTE
mirror of https://github.com/PentHertz/srsLTE.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Continuing to change functions to ctx_mngmnt_proc

This commit is contained in:
Pedro Alvarez 2017-12-26 15:59:57 +00:00
parent c5b1b7edc3
commit 9e72fbce43
2 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
srsepc/hdr/mme/s1ap_ctx_mngmt_proc.h
View File

@ -31,6 +31,7 @@
#include "mme/s1ap_common.h" #include "mme/s1ap_common.h"
#include "srslte/common/log_filter.h" #include "srslte/common/log_filter.h"
#include "mme/mme_gtpc.h" #include "mme/mme_gtpc.h"
#include "srslte/common/buffer_pool.h"
namespace srsepc{ namespace srsepc{
@ -55,11 +56,13 @@ private:
virtual ~s1ap_ctx_mngmt_proc(); virtual ~s1ap_ctx_mngmt_proc();
s1ap* m_s1ap; s1ap* m_s1ap;
s1ap_nas_transport* m_s1ap_nas_transport;
srslte::log_filter *m_s1ap_log; srslte::log_filter *m_s1ap_log;
s1ap_args_t m_s1ap_args; s1ap_args_t m_s1ap_args;
mme_gtpc* m_mme_gtpc; mme_gtpc* m_mme_gtpc;
srslte::byte_buffer_pool *m_pool;
}; };
} //namespace srsepc } //namespace srsepc

13
srsepc/src/mme/s1ap_ctx_mngmt_proc.cc
View File

@ -28,6 +28,8 @@
#include "srslte/common/bcd_helpers.h" #include "srslte/common/bcd_helpers.h"
#include "mme/s1ap.h" #include "mme/s1ap.h"
#include "mme/s1ap_ctx_mngmt_proc.h" #include "mme/s1ap_ctx_mngmt_proc.h"
#include "srslte/common/liblte_security.h"
namespace srsepc{ namespace srsepc{
@ -70,12 +72,14 @@ s1ap_ctx_mngmt_proc::init(void)
m_mme_gtpc = mme_gtpc::get_instance(); m_mme_gtpc = mme_gtpc::get_instance();
m_s1ap_log = m_s1ap->m_s1ap_log; m_s1ap_log = m_s1ap->m_s1ap_log;
m_s1ap_args = m_s1ap->m_s1ap_args; m_s1ap_args = m_s1ap->m_s1ap_args;
m_pool = srslte::byte_buffer_pool::get_instance();
m_s1ap_nas_transport = s1ap_nas_transport::get_instance();
} }
bool bool
s1ap_ctx_mngmt_proc::send_initial_context_setup_request(uint32_t mme_ue_s1ap_id, struct srslte::gtpc_create_session_response *cs_resp, struct srslte::gtpc_f_teid_ie sgw_ctrl_fteid) s1ap_ctx_mngmt_proc::send_initial_context_setup_request(uint32_t mme_ue_s1ap_id, struct srslte::gtpc_create_session_response *cs_resp, struct srslte::gtpc_f_teid_ie sgw_ctrl_fteid)
{ {
ue_ctx_t *ue_ctx; int s1mme = m_s1ap->get_s1_mme();
//Prepare reply PDU //Prepare reply PDU
LIBLTE_S1AP_S1AP_PDU_STRUCT pdu; LIBLTE_S1AP_S1AP_PDU_STRUCT pdu;
@ -94,13 +98,12 @@ s1ap_ctx_mngmt_proc::send_initial_context_setup_request(uint32_t mme_ue_s1ap_id,
m_s1ap_log->info("Preparing to send Initial Context Setup request\n"); m_s1ap_log->info("Preparing to send Initial Context Setup request\n");
//Find UE Context //Find UE Context
std::map<uint32_t, ue_ctx_t*>::iterator ue_ctx_it = m_active_ues.find(mme_ue_s1ap_id); ue_ctx_t *ue_ctx = m_s1ap->find_ue_ctx(mme_ue_s1ap_id);
if(ue_ctx_it == m_active_ues.end()) if(ue_ctx == NULL)
{ {
m_s1ap_log->error("Could not find UE to send Setup Context Request. MME S1AP Id: %d", mme_ue_s1ap_id); m_s1ap_log->error("Could not find UE to send Setup Context Request. MME S1AP Id: %d", mme_ue_s1ap_id);
return false; return false;
} }
ue_ctx = ue_ctx_it->second;
//Add MME and eNB S1AP Ids //Add MME and eNB S1AP Ids
in_ctxt_req->MME_UE_S1AP_ID.MME_UE_S1AP_ID = ue_ctx->mme_ue_s1ap_id; in_ctxt_req->MME_UE_S1AP_ID.MME_UE_S1AP_ID = ue_ctx->mme_ue_s1ap_id;
@ -184,7 +187,7 @@ s1ap_ctx_mngmt_proc::send_initial_context_setup_request(uint32_t mme_ue_s1ap_id,
return false; return false;
} }
//Send Reply to eNB //Send Reply to eNB
ssize_t n_sent = sctp_send(m_s1mme,reply_buffer->msg, reply_buffer->N_bytes, &ue_ctx->enb_sri, 0); ssize_t n_sent = sctp_send(s1mme,reply_buffer->msg, reply_buffer->N_bytes, &ue_ctx->enb_sri, 0);
if(n_sent == -1) if(n_sent == -1)
{ {
m_s1ap_log->error("Failed to send Initial Context Setup Request\n"); m_s1ap_log->error("Failed to send Initial Context Setup Request\n");