Commit b900880d authored by Cedric Roux's avatar Cedric Roux

- handle TERMINATE_MESSAGE in EPC layers

git-svn-id: http://svn.eurecom.fr/openair4G/trunk@4547 818b1a75-f10b-46b9-bf7c-635c3b92a50f
parent 60dc6519
...@@ -449,6 +449,9 @@ static void *gtpv1u_thread(void *args) ...@@ -449,6 +449,9 @@ static void *gtpv1u_thread(void *args)
free(data_req_p->buffer); free(data_req_p->buffer);
} }
break; break;
case TERMINATE_MESSAGE: {
itti_exit_task();
} break;
case TIMER_HAS_EXPIRED: case TIMER_HAS_EXPIRED:
nwGtpv1uProcessTimeout(&received_message_p->ittiMsg.timer_has_expired.arg); nwGtpv1uProcessTimeout(&received_message_p->ittiMsg.timer_has_expired.arg);
break; break;
......
...@@ -79,6 +79,9 @@ next_message: ...@@ -79,6 +79,9 @@ next_message:
itti_send_msg_to_task(TASK_MME_APP, INSTANCE_DEFAULT, message_p); itti_send_msg_to_task(TASK_MME_APP, INSTANCE_DEFAULT, message_p);
} break; } break;
case TERMINATE_MESSAGE: {
itti_exit_task();
} break;
default: { default: {
NAS_DEBUG("Unkwnon message ID %d:%s\n", NAS_DEBUG("Unkwnon message ID %d:%s\n",
ITTI_MSG_ID(received_message_p), ITTI_MSG_ID(received_message_p),
......
...@@ -144,6 +144,9 @@ void *s1ap_mme_thread(void *args) ...@@ -144,6 +144,9 @@ void *s1ap_mme_thread(void *args)
case TIMER_HAS_EXPIRED: { case TIMER_HAS_EXPIRED: {
s1ap_handle_timer_expiry(&received_message_p->ittiMsg.timer_has_expired); s1ap_handle_timer_expiry(&received_message_p->ittiMsg.timer_has_expired);
} break; } break;
case TERMINATE_MESSAGE: {
itti_exit_task();
} break;
default: { default: {
S1AP_DEBUG("Unkwnon message ID %d:%s\n", S1AP_DEBUG("Unkwnon message ID %d:%s\n",
ITTI_MSG_ID(received_message_p), ITTI_MSG_NAME(received_message_p)); ITTI_MSG_ID(received_message_p), ITTI_MSG_NAME(received_message_p));
......
...@@ -86,6 +86,9 @@ void *s6a_thread(void *args) ...@@ -86,6 +86,9 @@ void *s6a_thread(void *args)
case S6A_AUTH_INFO_REQ: { case S6A_AUTH_INFO_REQ: {
s6a_generate_authentication_info_req(&received_message_p->ittiMsg.s6a_auth_info_req); s6a_generate_authentication_info_req(&received_message_p->ittiMsg.s6a_auth_info_req);
} break; } break;
case TERMINATE_MESSAGE: {
itti_exit_task();
} break;
default: { default: {
S6A_DEBUG("Unkwnon message ID %d:%s\n", S6A_DEBUG("Unkwnon message ID %d:%s\n",
ITTI_MSG_ID(received_message_p), ITTI_MSG_NAME(received_message_p)); ITTI_MSG_ID(received_message_p), ITTI_MSG_NAME(received_message_p));
......
...@@ -612,8 +612,11 @@ static void *sctp_intertask_interface(void *args_p) ...@@ -612,8 +612,11 @@ static void *sctp_intertask_interface(void *args_p)
} }
} break; } break;
case MESSAGE_TEST: { case MESSAGE_TEST: {
int i = 10000; // int i = 10000;
while(i--); // while(i--);
} break;
case TERMINATE_MESSAGE: {
itti_exit_task();
} break; } break;
default: { default: {
SCTP_DEBUG("Unkwnon message ID %d:%s\n", SCTP_DEBUG("Unkwnon message ID %d:%s\n",
......
...@@ -16,6 +16,7 @@ static char fw_2_print_buffer[FW_2_PRINT_BUFFER_LEN]; ...@@ -16,6 +16,7 @@ static char fw_2_print_buffer[FW_2_PRINT_BUFFER_LEN];
void sgi_print_hex_octets(unsigned char* dataP, unsigned long sizeP) void sgi_print_hex_octets(unsigned char* dataP, unsigned long sizeP)
//----------------------------------------------------------------------------- //-----------------------------------------------------------------------------
{ {
return;
unsigned long octet_index = 0; unsigned long octet_index = 0;
unsigned long buffer_marker = 0; unsigned long buffer_marker = 0;
unsigned char aindex; unsigned char aindex;
......
...@@ -90,6 +90,10 @@ static void *sgw_lite_intertask_interface(void *args_p) ...@@ -90,6 +90,10 @@ static void *sgw_lite_intertask_interface(void *args_p)
sgw_lite_handle_sgi_endpoint_updated(&received_message_p->ittiMsg.sgiUpdateEndpointResp); sgw_lite_handle_sgi_endpoint_updated(&received_message_p->ittiMsg.sgiUpdateEndpointResp);
} break; } break;
case TERMINATE_MESSAGE: {
itti_exit_task();
} break;
default: { default: {
SPGW_APP_DEBUG("Unkwnon message ID %d:%s\n", SPGW_APP_DEBUG("Unkwnon message ID %d:%s\n",
ITTI_MSG_ID(received_message_p), ITTI_MSG_NAME(received_message_p)); ITTI_MSG_ID(received_message_p), ITTI_MSG_NAME(received_message_p));
......
...@@ -256,6 +256,9 @@ static void *udp_intertask_interface(void *args_p) ...@@ -256,6 +256,9 @@ static void *udp_intertask_interface(void *args_p)
"(%d:%s)\n", errno, strerror(errno)); "(%d:%s)\n", errno, strerror(errno));
} }
} break; } break;
case TERMINATE_MESSAGE: {
itti_exit_task();
} break;
case MESSAGE_TEST: { case MESSAGE_TEST: {
} break; } break;
default: { default: {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment