acouzens
/
open5gs
1
0
Fork 1
Code Issues Pull Requests 1 Projects Releases Wiki Activity

Attach Reject is implemented

This commit is contained in:
Sukchan Lee 2017-08-11 12:05:01 +09:00
parent dbbf7de908
commit 2951f3dbb8
9 changed files with 163 additions and 69 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/mme/emm_build.c
View File

@ -24,6 +24,7 @@ status_t emm_build_attach_accept(
d_assert(mme_ue, return CORE_ERROR, "Null param");
d_assert(mme_ue->enb_ue, return CORE_ERROR, "Null param");
d_assert(esmbuf, return CORE_ERROR, "Null param");
memset(&message, 0, sizeof(message));
message.h.security_header_type =
@ -76,3 +77,33 @@ status_t emm_build_attach_accept(
return CORE_OK;
}
status_t emm_build_attach_reject(
pkbuf_t **emmbuf, nas_emm_cause_t emm_cause, pkbuf_t *esmbuf)
{
nas_message_t message;
nas_attach_reject_t *attach_reject = &message.emm.attach_reject;
memset(&message, 0, sizeof(message));
message.emm.h.protocol_discriminator = NAS_PROTOCOL_DISCRIMINATOR_EMM;
message.emm.h.message_type = NAS_ATTACH_REJECT;
attach_reject->emm_cause = emm_cause;
if (esmbuf)
{
attach_reject->presencemask |=
NAS_ATTACH_REJECT_ESM_MESSAGE_CONTAINER_PRESENT;
attach_reject->esm_message_container.data = esmbuf->payload;
attach_reject->esm_message_container.len = esmbuf->len;
}
d_assert(nas_plain_encode(emmbuf, &message) == CORE_OK && *emmbuf,,);
if (esmbuf)
{
pkbuf_free(esmbuf);
}
return CORE_OK;
}

2
src/mme/emm_build.h
View File

@ -9,6 +9,8 @@ extern "C" {
CORE_DECLARE(status_t) emm_build_attach_accept(
pkbuf_t **emmbuf, mme_ue_t *mme_ue, pkbuf_t *esmbuf);
CORE_DECLARE(status_t) emm_build_attach_reject(
pkbuf_t **emmbuf, nas_emm_cause_t emm_cause, pkbuf_t *esmbuf);
#ifdef __cplusplus
}

43
src/mme/emm_handler.c
View File

@ -174,7 +174,7 @@ void emm_handle_attach_accept(mme_sess_t *sess)
d_assert(bearer, return, "Null param");
rv = esm_build_activate_default_bearer_context(&esmbuf, bearer);
d_assert(rv == CORE_OK && esmbuf, return, "bearer build error");
d_assert(rv == CORE_OK && esmbuf, return, "esm build error");
d_trace(3, "[NAS] Activate default bearer context request : "
"EMM <-- ESM[%d]\n", bearer->ebi);
@ -251,6 +251,45 @@ void emm_handle_attach_complete(
d_assert(nas_send_to_downlink_nas_transport(mme_ue, emmbuf) == CORE_OK,,);
}
void emm_handle_attach_reject(mme_ue_t *mme_ue)
{
status_t rv;
pkbuf_t *esmbuf = NULL, *emmbuf = NULL;
nas_message_t *message = NULL;
d_assert(mme_ue, return, "Null param");
message = &mme_ue->last_esm_message;
if (message)
{
switch(message->esm.h.message_type)
{
case NAS_PDN_CONNECTIVITY_REQUEST:
{
c_uint8_t pti = message->esm.h.procedure_transaction_identity;
rv = esm_build_pdn_connectivity_reject(&esmbuf, pti,
ESM_CAUSE_PROTOCOL_ERROR_UNSPECIFIED);
d_assert(rv == CORE_OK && esmbuf, return, "esm build error");
d_trace(3, "[NAS] PDN Connectivity reject : "
"EMM <-- ESM[%d]\n", pti);
break;
}
default:
{
d_warn("Not implemented(type:%d)", message->esm.h.message_type);
break;
}
}
}
rv = emm_build_attach_reject(&emmbuf,
EMM_CAUSE_EPS_SERVICES_AND_NON_EPS_SERVICES_NOT_ALLOWED, esmbuf);
d_assert(rv == CORE_OK && emmbuf,
pkbuf_free(esmbuf); return, "emm build error");
d_trace(3, "[NAS] Attach reject : UE[%s] <-- EMM\n", mme_ue->imsi_bcd);
d_assert(nas_send_to_downlink_nas_transport(mme_ue, emmbuf) == CORE_OK,,);
}
void emm_handle_identity_request(mme_ue_t *mme_ue)
{
pkbuf_t *emmbuf = NULL;
@ -463,7 +502,7 @@ void emm_handle_detach_request(
break;
}
if (MME_SESSION_WAS_CREATED(mme_ue))
if (MME_UE_HAVE_SESSION(mme_ue))
{
emm_handle_s11_delete_session_request(mme_ue);
}

1
src/mme/emm_handler.h
View File

@ -14,6 +14,7 @@ CORE_DECLARE(void) emm_handle_attach_request(
CORE_DECLARE(void) emm_handle_attach_accept(mme_sess_t *sess);
CORE_DECLARE(void) emm_handle_attach_complete(
mme_ue_t *mme_ue, nas_attach_complete_t *attach_complete);
CORE_DECLARE(void) emm_handle_attach_reject(mme_ue_t *mme_ue);
CORE_DECLARE(void) emm_handle_identity_request(mme_ue_t *mme_ue);
CORE_DECLARE(void) emm_handle_identity_response(

124
src/mme/emm_sm.c
View File

@ -47,68 +47,6 @@ void emm_state_operational(fsm_t *s, event_t *e)
{
break;
}
case MME_EVT_EMM_UE_FROM_S6A:
{
index_t index = event_get_param1(e);
mme_ue_t *mme_ue = NULL;
d_assert(index, return, "Null param");
mme_ue = mme_ue_find(index);
d_assert(mme_ue, return, "Null param");
switch(event_get_param2(e))
{
case S6A_CMD_AUTHENTICATION_INFORMATION:
{
c_uint32_t result_code = event_get_param3(e);
if (result_code != ER_DIAMETER_SUCCESS)
{
/* TODO */
/* Send Attach Reject */
return;
}
emm_handle_authentication_request(mme_ue);
break;
}
case S6A_CMD_UPDATE_LOCATION:
{
mme_sess_t *sess = NULL;
mme_bearer_t *bearer = NULL;
c_uint32_t result_code = event_get_param3(e);
if (result_code != ER_DIAMETER_SUCCESS)
{
/* TODO */
return;
}
sess = mme_sess_find_by_last_esm_message(mme_ue);
d_assert(sess, return, "Null param");
bearer = mme_default_bearer_in_sess(sess);
d_assert(bearer, return, "Null param");
if (MME_SESSION_HAVE_APN(sess))
{
if (MME_SESSION_IS_VALID(sess))
{
emm_handle_attach_accept(sess);
}
else
{
mme_s11_handle_create_session_request(bearer);
}
}
else
{
esm_handle_information_request(sess);
}
break;
}
}
break;
}
case MME_EVT_EMM_UE_MSG:
{
index_t index = event_get_param1(e);
@ -195,7 +133,7 @@ void emm_state_operational(fsm_t *s, event_t *e)
}
else
{
if (MME_SESSION_WAS_CREATED(mme_ue))
if (MME_UE_HAVE_SESSION(mme_ue))
{
emm_handle_s11_delete_session_request(mme_ue);
}
@ -288,7 +226,67 @@ void emm_state_operational(fsm_t *s, event_t *e)
break;
}
case MME_EVT_EMM_UE_FROM_S6A:
{
index_t index = event_get_param1(e);
mme_ue_t *mme_ue = NULL;
d_assert(index, return, "Null param");
mme_ue = mme_ue_find(index);
d_assert(mme_ue, return, "Null param");
switch(event_get_param2(e))
{
case S6A_CMD_AUTHENTICATION_INFORMATION:
{
c_uint32_t result_code = event_get_param3(e);
if (result_code != ER_DIAMETER_SUCCESS)
{
emm_handle_attach_reject(mme_ue);
return;
}
emm_handle_authentication_request(mme_ue);
break;
}
case S6A_CMD_UPDATE_LOCATION:
{
mme_sess_t *sess = NULL;
mme_bearer_t *bearer = NULL;
c_uint32_t result_code = event_get_param3(e);
if (result_code != ER_DIAMETER_SUCCESS)
{
/* TODO */
return;
}
sess = mme_sess_find_by_last_esm_message(mme_ue);
d_assert(sess, return, "Null param");
bearer = mme_default_bearer_in_sess(sess);
d_assert(bearer, return, "Null param");
if (MME_SESSION_HAVE_APN(sess))
{
if (MME_SESSION_IS_VALID(sess))
{
emm_handle_attach_accept(sess);
}
else
{
mme_s11_handle_create_session_request(bearer);
}
}
else
{
esm_handle_information_request(sess);
}
break;
}
}
break;
}
default:
{
d_error("Unknown event %s", mme_event_get_name(e));

20
src/mme/esm_build.c
View File

@ -7,6 +7,26 @@
#include "nas_security.h"
#include "esm_build.h"
status_t esm_build_pdn_connectivity_reject(
pkbuf_t **pkbuf, c_uint8_t pti, nas_esm_cause_t esm_cause)
{
nas_message_t message;
nas_pdn_connectivity_reject_t *pdn_connectivity_reject =
&message.esm.pdn_connectivity_reject;
memset(&message, 0, sizeof(message));
message.esm.h.eps_bearer_identity = 0;
message.esm.h.protocol_discriminator = NAS_PROTOCOL_DISCRIMINATOR_ESM;
message.esm.h.procedure_transaction_identity = pti;
message.esm.h.message_type = NAS_PDN_CONNECTIVITY_REJECT;
pdn_connectivity_reject->esm_cause = esm_cause;
d_assert(nas_plain_encode(pkbuf, &message) == CORE_OK && *pkbuf,,);
return CORE_OK;
}
status_t esm_build_information_request(pkbuf_t **pkbuf, mme_bearer_t *bearer)
{
nas_message_t message;

7
src/mme/esm_build.h
View File

@ -7,8 +7,11 @@
extern "C" {
#endif /* __cplusplus */
CORE_DECLARE(status_t) esm_build_information_request(
pkbuf_t **pkbuf, mme_bearer_t *bearer);
CORE_DECLARE(status_t) esm_build_pdn_connectivity_reject(pkbuf_t **pkbuf,
c_uint8_t pti, nas_esm_cause_t esm_cause);
CORE_DECLARE(status_t) esm_build_information_request(pkbuf_t **pkbuf,
mme_bearer_t *bearer);
CORE_DECLARE(status_t) esm_build_activate_default_bearer_context(
pkbuf_t **pkbuf, mme_bearer_t *bearer);

2
src/mme/esm_sm.c
View File

@ -102,7 +102,7 @@ void esm_state_operational(fsm_t *s, event_t *e)
}
else
{
if (MME_SESSION_WAS_CREATED(mme_ue))
if (MME_UE_HAVE_SESSION(mme_ue))
{
emm_handle_s11_delete_session_request(mme_ue);
}

2
src/mme/mme_context.h
View File

@ -254,7 +254,7 @@ typedef struct _mme_sess_t {
(((sess)->sgw_s11_teid) && \
((sess)->sgw_s11_addr))
#define MME_SESSION_WAS_CREATED(mme) \
#define MME_UE_HAVE_SESSION(mme) \
((mme) && (mme_sess_first(mme_ue)) && \
(MME_SESSION_IS_VALID(mme_sess_first(mme_ue))))