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

update it

This commit is contained in:
Sukchan Lee 2017-07-14 19:00:26 +09:00
parent 2e33ece64f
commit 020602b42d
5 changed files with 315 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib/base/context.c
View File

@ -53,8 +53,6 @@ status_t context_parse_config()
}
case ROOT:
{
root_tokens--;
if (jsmntok_equal(json, t, "DB_URI") == 0)
self.db_uri = jsmntok_to_string(json, t+1);
else if (jsmntok_equal(json, t, "LOG_PATH") == 0)
@ -63,15 +61,16 @@ status_t context_parse_config()
state = SKIP;
skip_tokens = t->size;
root_tokens--;
if (root_tokens == 0) state = STOP;
break;
}
case SKIP:
{
skip_tokens--;
skip_tokens += t->size;
skip_tokens--;
if (skip_tokens == 0) state = ROOT;
break;

305
src/mme/mme_context.c
View File

@ -6,6 +6,7 @@
#include "gtp_path.h"
#include "s1ap_message.h"
#include "context.h"
#include "mme_context.h"
#include "mme_event.h"
@ -103,6 +104,310 @@ status_t mme_context_init()
return CORE_OK;
}
status_t mme_context_parse_config()
{
config_t *config = &context_self()->config;
char *json = config->json;
jsmntok_t *token = config->token;
typedef enum {
START, ROOT,
MME_START, MME_ROOT,
SGW_START, SGW_ROOT,
SKIP, STOP
} parse_state;
parse_state state = START;
parse_state stack = STOP;
size_t root_tokens = 0;
size_t mme_tokens = 0;
size_t sgw_tokens = 0;
size_t skip_tokens = 0;
int i, j, m, n, p;
int arr, size;
for (i = 0, j = 1; j > 0; i++, j--)
{
jsmntok_t *t = &token[i];
j += t->size;
switch (state)
{
case START:
{
state = ROOT;
root_tokens = t->size;
break;
}
case ROOT:
{
printf("root key = %s\n", jsmntok_to_string(json, t));
if (jsmntok_equal(json, t, "MME") == 0)
{
state = MME_START;
}
else if (jsmntok_equal(json, t, "SGW") == 0)
{
state = SGW_START;
}
else
{
state = SKIP;
stack = ROOT;
skip_tokens = t->size;
}
root_tokens--;
if (root_tokens == 0) state = STOP;
break;
}
case MME_START:
{
state = MME_ROOT;
mme_tokens = t->size;
break;
}
case MME_ROOT:
{
if (jsmntok_equal(json, t, "DEFAULT_PAGING_DRX") == 0)
{
printf("paging_drx : %s\n", jsmntok_to_string(json, t+1));
}
else if (jsmntok_equal(json, t, "RELATIVE_CAPACITY") == 0)
{
printf("relative : %s\n", jsmntok_to_string(json, t+1));
}
else if (jsmntok_equal(json, t, "NETWORK") == 0)
{
m = 1;
size = 1;
if ((t+1)->type == JSMN_ARRAY)
{
m = 2;
}
for (arr = 0; arr < size; arr++)
{
for (n = 1; n > 0; m++, n--)
{
n += (t+m)->size;
if (jsmntok_equal(json, t+m, "S1AP_ADDR") == 0)
{
printf("s1ap_addr : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "S1AP_PORT") == 0)
{
printf("s1ap_port : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "S11_ADDR") == 0)
{
printf("s11_addr : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "S11_PORT") == 0)
{
printf("s11_port : %s\n", jsmntok_to_string(json, t+m+1));
}
}
}
}
else if (jsmntok_equal(json, t, "GUMMEI") == 0)
{
m = 1;
size = 1;
if ((t+1)->type == JSMN_ARRAY)
{
m = 2;
size = (t+1)->size;
}
for (arr = 0; arr < size; arr++)
{
for (n = 1; n > 0; m++, n--)
{
n += (t+m)->size;
if (jsmntok_equal(json, t+m, "MCC") == 0)
{
printf("mcc : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "MNC") == 0)
{
printf("mnc : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "MME_GID") == 0)
{
printf("gid : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "MME_CODE") == 0)
{
printf("code : %s\n", jsmntok_to_string(json, t+m+1));
}
}
}
}
else if (jsmntok_equal(json, t, "TAI") == 0)
{
m = 1;
size = 1;
if ((t+1)->type == JSMN_ARRAY)
{
m = 2;
size = (t+1)->size;
}
for (arr = 0; arr < size; arr++)
{
for (n = 1; n > 0; m++, n--)
{
n += (t+m)->size;
if (jsmntok_equal(json, t+m, "MCC") == 0)
{
printf("mcc : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "MNC") == 0)
{
printf("mnc : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "TAC") == 0)
{
printf("tac : %s\n", jsmntok_to_string(json, t+m+1));
}
}
}
}
else if (jsmntok_equal(json, t, "SECURITY") == 0)
{
for (m = 1, n = 1; n > 0; m++, n--)
{
n += (t+m)->size;
if (jsmntok_equal(json, t+m, "INTEGRITY_ORDER") == 0)
{
p = 1;
size = 1;
if ((t+m+1)->type == JSMN_ARRAY)
{
p = 2;
size = (t+m+1)->size;
}
for (arr = 0; arr < size; arr++)
{
printf("%s\n",
jsmntok_to_string(json, t+m+p));
p++;
}
}
else if (jsmntok_equal(json, t+m, "CIPHERING_ORDER") == 0)
{
p = 1;
size = 1;
if ((t+m+1)->type == JSMN_ARRAY)
{
p = 2;
size = (t+m+1)->size;
}
for (arr = 0; arr < size; arr++)
{
printf("%s\n",
jsmntok_to_string(json, t+m+p));
p++;
}
}
}
}
state = SKIP;
stack = MME_ROOT;
skip_tokens = t->size;
mme_tokens--;
if (mme_tokens == 0) stack = ROOT;
break;
}
case SGW_START:
{
state = SGW_ROOT;
sgw_tokens = t->size;
break;
}
case SGW_ROOT:
{
printf("sgw key = %s\n", jsmntok_to_string(json, t));
if (jsmntok_equal(json, t, "NETWORK") == 0)
{
m = 1;
size = 1;
if ((t+1)->type == JSMN_ARRAY)
{
m = 2;
size = (t+1)->size;
}
for (arr = 0; arr < size; arr++)
{
for (n = 1; n > 0; m++, n--)
{
n += (t+m)->size;
if (jsmntok_equal(json, t+m, "S11_ADDR") == 0)
{
printf("s11_addr : %s\n", jsmntok_to_string(json, t+m+1));
}
else if (jsmntok_equal(json, t+m, "S11_PORT") == 0)
{
printf("s11_port : %s\n", jsmntok_to_string(json, t+m+1));
}
}
}
}
state = SKIP;
stack = SGW_ROOT;
skip_tokens = t->size;
sgw_tokens--;
if (sgw_tokens == 0) stack = ROOT;
break;
}
case SKIP:
{
skip_tokens += t->size;
skip_tokens--;
if (skip_tokens == 0) state = stack;
break;
}
case STOP:
{
break;
}
default:
{
d_error("Failed to parse configuration in the state(%u)",
state);
break;
}
}
}
return CORE_OK;
}
status_t mme_context_final()
{
d_assert(context_initialized == 1, return CORE_ERROR,

1
src/mme/mme_context.h
View File

@ -244,6 +244,7 @@ typedef struct _mme_bearer_t {
} mme_bearer_t;
CORE_DECLARE(status_t) mme_context_init(void);
CORE_DECLARE(status_t) mme_context_parse_config(void);
CORE_DECLARE(status_t) mme_context_final(void);
CORE_DECLARE(mme_context_t*) mme_self(void);

3
src/mme/mme_init.c
View File

@ -18,6 +18,9 @@ status_t mme_initialize()
rv = mme_context_init();
if (rv != CORE_OK) return rv;
rv = mme_context_parse_config();
if (rv != CORE_OK) return rv;
ret = mme_s6a_init();
if (ret != 0) return -1;

8
support/nextepc.conf.in
View File

@ -18,7 +18,7 @@
{
S1AP_ADDR : "10.1.35.215",
#S1AP_PORT : 36412,
#S11_ADDR: "10.1.35.215",
S11_ADDR: "10.1.35.215",
#S11_PORT: 2123
}
GUMMEI:
@ -52,12 +52,12 @@
{
S11_ADDR: "10.1.35.216",
#S11_PORT: 2123,
#S1U_ADDR: "10.1.35.216",
S1U_ADDR: "10.1.35.216",
#S1U_PORT: 2125,
S5C_ADDR: "10.1.35.217",
#S5C_PORT: 2123,
#S5U_ADDR: "10.1.35.217",
S5U_ADDR: "10.1.35.217",
#S5U_PORT: 2125
}
]
@ -69,7 +69,7 @@
{
S5C_ADDR: "10.1.35.219",
#S5C_PORT: 2123,
#S5U_ADDR: "10.1.35.219",
S5U_ADDR: "10.1.35.219",
#S5U_PORT: 2125
}