From 03d76e8d432eccabb2b57da4ac58f9fcf6a5030a Mon Sep 17 00:00:00 2001
From: winckel <winckel@eurecom.fr>
Date: Wed, 4 Dec 2013 09:54:27 +0000
Subject: [PATCH] Created files for eNB application.
git-svn-id: http://svn.eurecom.fr/openair4G/trunk@4579 818b1a75-f10b-46b9-bf7c-635c3b92a50f
---
openair2/ENB_APP/Makefile.inc | 6 +
openair2/ENB_APP/enb_app.c | 209 ++++++++++++++++++++++++++++++++++
openair2/ENB_APP/enb_app.h | 36 ++++++
3 files changed, 251 insertions(+)
create mode 100644 openair2/ENB_APP/Makefile.inc
create mode 100644 openair2/ENB_APP/enb_app.c
create mode 100644 openair2/ENB_APP/enb_app.h
diff --git a/openair2/ENB_APP/Makefile.inc b/openair2/ENB_APP/Makefile.inc
new file mode 100644
index 0000000000..4b79c096f5
--- /dev/null
+++ b/openair2/ENB_APP/Makefile.inc
@@ -0,0 +1,6 @@
+ENB_APP_DIR = $(OPENAIR2_TOP)/ENB_APP
+
+ENB_APP_OBJS = $(ENB_APP_DIR)/enb_app.o
+
+ENB_APP_incl = \
+ -I$(ENB_APP_DIR)
diff --git a/openair2/ENB_APP/enb_app.c b/openair2/ENB_APP/enb_app.c
new file mode 100644
index 0000000000..a398edaa0d
--- /dev/null
+++ b/openair2/ENB_APP/enb_app.c
@@ -0,0 +1,209 @@
+/*******************************************************************************
+
+ Eurecom OpenAirInterface
+ Copyright(c) 1999 - 2012 Eurecom
+
+ This program is free software; you can redistribute it and/or modify it
+ under the terms and conditions of the GNU General Public License,
+ version 2, as published by the Free Software Foundation.
+
+ This program is distributed in the hope it will be useful, but WITHOUT
+ ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
+ more details.
+
+ You should have received a copy of the GNU General Public License along with
+ this program; if not, write to the Free Software Foundation, Inc.,
+ 51 Franklin St - Fifth Floor, Boston, MA 02110-1301 USA.
+
+ The full GNU General Public License is included in this distribution in
+ the file called "COPYING".
+
+ Contact Information
+ Openair Admin: openair_admin@eurecom.fr
+ Openair Tech : openair_tech@eurecom.fr
+ Forums : http://forums.eurecom.fr/openairinterface
+ Address : EURECOM, Campus SophiaTech, 450 Route des Chappes
+ 06410 Biot FRANCE
+
+*******************************************************************************/
+
+#include <string.h>
+
+#include "enb_app.h"
+#include "assertions.h"
+
+#include "log.h"
+#if defined(OAI_EMU)
+# include "OCG.h"
+# include "OCG_extern.h"
+#endif
+
+#if defined(ENABLE_ITTI)
+# include "intertask_interface.h"
+# include "timer.h"
+# if defined(ENABLE_USE_MME)
+# include "s1ap_eNB.h"
+# include "sctp_eNB_task.h"
+# endif
+#endif
+
+#if defined(ENABLE_ITTI)
+# if defined(ENABLE_USE_MME)
+
+#define ENB_REGISTER_RETRY_DELAY 10
+
+static uint32_t eNB_app_register()
+{
+ uint32_t eNB_id;
+ MessageDef *msg_p;
+ uint32_t register_enb_pending = 0;
+
+ for (eNB_id = oai_emulation.info.first_enb_local;
+ (eNB_id < (oai_emulation.info.first_enb_local + oai_emulation.info.nb_enb_local)) && (oai_emulation.info.cli_start_enb[eNB_id] == 1);
+ eNB_id++) {
+ char *mme_address_v4;
+
+ if (EPC_MODE_ENABLED){
+ mme_address_v4 = EPC_MODE_MME_ADDRESS;
+ } else {
+ mme_address_v4 = "192.168.12.87";
+ }
+ char *mme_address_v6 = "2001:660:5502:12:30da:829a:2343:b6cf";
+ s1ap_register_enb_req_t *s1ap_register_eNB;
+ uint32_t hash;
+
+ //note: there is an implicit relationship between the data struct and the message name
+ msg_p = itti_alloc_new_message(TASK_ENB_APP, S1AP_REGISTER_ENB_REQ);
+
+ s1ap_register_eNB = &S1AP_REGISTER_ENB_REQ(msg_p);
+
+ hash = s1ap_generate_eNB_id();
+
+ /* Some default/random parameters */
+ s1ap_register_eNB->eNB_id = eNB_id + (hash & 0xFFFF8);
+ s1ap_register_eNB->cell_type = CELL_MACRO_ENB;
+ s1ap_register_eNB->tac = 0;
+ s1ap_register_eNB->mcc = 208;
+ s1ap_register_eNB->mnc = 34;
+ s1ap_register_eNB->default_drx = PAGING_DRX_256;
+
+ s1ap_register_eNB->nb_mme = 1;
+ s1ap_register_eNB->mme_ip_address[0].ipv4 = 1;
+ s1ap_register_eNB->mme_ip_address[0].ipv6 = 0;
+ memcpy(s1ap_register_eNB->mme_ip_address[0].ipv4_address, mme_address_v4, strlen(mme_address_v4));
+ memcpy(s1ap_register_eNB->mme_ip_address[0].ipv6_address, mme_address_v6, strlen(mme_address_v6));
+
+# if defined ENB_APP_ENB_REGISTER_2_MME
+ s1ap_register_eNB->nb_mme = 2;
+ s1ap_register_eNB->mme_ip_address[1].ipv4 = 1;
+ s1ap_register_eNB->mme_ip_address[1].ipv6 = 0;
+ mme_address_v4 = "192.168.12.88";
+ memcpy(s1ap_register_eNB->mme_ip_address[1].ipv4_address, mme_address_v4, strlen(mme_address_v4));
+ memcpy(s1ap_register_eNB->mme_ip_address[1].ipv6_address, mme_address_v6, strlen(mme_address_v6));
+# endif
+
+ itti_send_msg_to_task(TASK_S1AP, eNB_id, msg_p);
+
+ register_enb_pending ++;
+ }
+
+ return register_enb_pending;
+}
+# endif
+#endif
+
+void *eNB_app_task(void *args_p) {
+#if defined(ENABLE_ITTI)
+# if defined(ENABLE_USE_MME)
+ static uint32_t register_enb_pending;
+ static uint32_t registered_enb;
+ static long enb_register_retry_timer_id;
+# endif
+ MessageDef *msg_p;
+ const char *msg_name;
+ instance_t instance;
+ itti_mark_task_ready (TASK_ENB_APP);
+
+# if defined(ENABLE_USE_MME)
+ /* Try to register each eNB */
+ registered_enb = 0;
+ register_enb_pending = eNB_app_register();
+# else
+ msg_p = itti_alloc_new_message(TASK_ENB_APP, INITIALIZE_MESSAGE);
+ itti_send_msg_to_task(TASK_L2L1, INSTANCE_DEFAULT, msg_p);
+# endif
+
+ do {
+ // Wait for a message
+ itti_receive_msg (TASK_ENB_APP, &msg_p);
+
+ msg_name = ITTI_MSG_NAME (msg_p);
+ instance = ITTI_MSG_INSTANCE (msg_p);
+
+ switch (ITTI_MSG_ID(msg_p)) {
+ case TERMINATE_MESSAGE:
+ itti_exit_task ();
+ break;
+
+ case MESSAGE_TEST:
+ LOG_I(EMU, "Received %s\n", ITTI_MSG_NAME(msg_p));
+ break;
+
+# if defined(ENABLE_USE_MME)
+ case S1AP_REGISTER_ENB_CNF:
+ LOG_I(EMU, "[eNB %d] Received %s: associated MME %d\n", instance, msg_name, S1AP_REGISTER_ENB_CNF(msg_p).nb_mme);
+
+ DevAssert(register_enb_pending > 0);
+ register_enb_pending--;
+
+ /* Check if at least eNB is registered with one MME */
+ if (S1AP_REGISTER_ENB_CNF(msg_p).nb_mme > 0) {
+ registered_enb ++;
+ }
+
+ /* Check if all register eNB requests have been processed */
+ if (register_enb_pending == 0) {
+ if (registered_enb == oai_emulation.info.nb_enb_local) {
+ /* If all eNB are registered, start L2L1 task */
+ MessageDef *msg_init_p;
+
+ msg_init_p = itti_alloc_new_message (TASK_ENB_APP, INITIALIZE_MESSAGE);
+ itti_send_msg_to_task (TASK_L2L1, INSTANCE_DEFAULT, msg_init_p);
+ }
+ else {
+ uint32_t not_associated = oai_emulation.info.nb_enb_local - registered_enb;
+
+ LOG_W(EMU, " %d eNB %s not associated with a MME, retrying registration in %d seconds ...\n",
+ not_associated, not_associated > 1 ? "are" : "is", ENB_REGISTER_RETRY_DELAY);
+
+ /* Restart the eNB registration process in ENB_REGISTER_RETRY_DELAY seconds */
+ if (timer_setup (ENB_REGISTER_RETRY_DELAY, 0, TASK_ENB_APP, INSTANCE_DEFAULT, TIMER_ONE_SHOT, NULL, &enb_register_retry_timer_id) < 0) {
+ LOG_E(EMU, " Can not start eNB register retry timer!\n");
+ }
+ }
+ }
+ break;
+
+ case TIMER_HAS_EXPIRED:
+ LOG_I(EMU, " Received %s: timer_id %d\n", msg_name, TIMER_HAS_EXPIRED(msg_p).timer_id);
+
+ if (TIMER_HAS_EXPIRED(msg_p).timer_id == enb_register_retry_timer_id) {
+ /* Restart the registration process */
+ registered_enb = 0;
+ register_enb_pending = eNB_app_register();
+ }
+ break;
+# endif
+
+ default:
+ LOG_E(EMU, "Received unexpected message %s\n", msg_name);
+ break;
+ }
+
+ free (msg_p);
+ } while(1);
+#endif
+
+ return NULL;
+}
diff --git a/openair2/ENB_APP/enb_app.h b/openair2/ENB_APP/enb_app.h
new file mode 100644
index 0000000000..fea50a0ad9
--- /dev/null
+++ b/openair2/ENB_APP/enb_app.h
@@ -0,0 +1,36 @@
+/*******************************************************************************
+
+ Eurecom OpenAirInterface
+ Copyright(c) 1999 - 2012 Eurecom
+
+ This program is free software; you can redistribute it and/or modify it
+ under the terms and conditions of the GNU General Public License,
+ version 2, as published by the Free Software Foundation.
+
+ This program is distributed in the hope it will be useful, but WITHOUT
+ ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
+ more details.
+
+ You should have received a copy of the GNU General Public License along with
+ this program; if not, write to the Free Software Foundation, Inc.,
+ 51 Franklin St - Fifth Floor, Boston, MA 02110-1301 USA.
+
+ The full GNU General Public License is included in this distribution in
+ the file called "COPYING".
+
+ Contact Information
+ Openair Admin: openair_admin@eurecom.fr
+ Openair Tech : openair_tech@eurecom.fr
+ Forums : http://forums.eurecom.fr/openairinterface
+ Address : EURECOM, Campus SophiaTech, 450 Route des Chappes
+ 06410 Biot FRANCE
+
+*******************************************************************************/
+
+#ifndef ENB_APP_H_
+#define ENB_APP_H_
+
+void *eNB_app_task(void *args_p);
+
+#endif /* ENB_APP_H_ */
--
GitLab