mirror of
https://github.com/open5gs/open5gs.git
synced 2025-11-03 05:23:38 +00:00
80ab4c4a1b
When we run the test, for example, ./tests/registration/registration simple-init, wee get an INFO message like the one below. ``` 05/17 14:24:03.933: [sbi] INFO: NF EndPoint(addr) setup [127.0.0.200:7777] (../lib/sbi/context.c:474) ``` When we run the code in Open5GS, the log level initially defaults to INFO. However, for test code, we change the log level to ERROR by automatically inserting the -e error option into argv. The reason for this is to prevent WARNING and INFO messages from appearing when the test code is run. However, the log level to ERROR is changed at the bottom of the initialize routine, which caused the above message to be printed during testing. To prevent this from being printed, I modified the code to change that log level to ERROR a little earlier.
141 lines
3.4 KiB
C
141 lines
3.4 KiB
C
/*
|
|
* Copyright (C) 2019-2023 by Sukchan Lee <acetcom@gmail.com>
|
|
*
|
|
* This file is part of Open5GS.
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Affero General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that 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, see <https://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "context.h"
|
|
#include "gtp-path.h"
|
|
#include "pfcp-path.h"
|
|
|
|
static ogs_thread_t *thread;
|
|
static void sgwu_main(void *data);
|
|
|
|
static int initialized = 0;
|
|
|
|
int sgwu_initialize(void)
|
|
{
|
|
int rv;
|
|
|
|
#define APP_NAME "sgwu"
|
|
rv = ogs_app_parse_local_conf(APP_NAME);
|
|
if (rv != OGS_OK) return rv;
|
|
|
|
ogs_gtp_context_init(OGS_MAX_NUM_OF_GTPU_RESOURCE);
|
|
ogs_pfcp_context_init();
|
|
|
|
sgwu_context_init();
|
|
sgwu_event_init();
|
|
sgwu_gtp_init();
|
|
|
|
rv = ogs_pfcp_xact_init();
|
|
if (rv != OGS_OK) return rv;
|
|
|
|
rv = ogs_log_config_domain(
|
|
ogs_app()->logger.domain, ogs_app()->logger.level);
|
|
if (rv != OGS_OK) return rv;
|
|
|
|
rv = ogs_gtp_context_parse_config(APP_NAME, "sgwc");
|
|
if (rv != OGS_OK) return rv;
|
|
|
|
rv = ogs_pfcp_context_parse_config(APP_NAME, "sgwc");
|
|
if (rv != OGS_OK) return rv;
|
|
|
|
rv = sgwu_context_parse_config();
|
|
if (rv != OGS_OK) return rv;
|
|
|
|
rv = sgwu_pfcp_open();
|
|
if (rv != OGS_OK) return rv;
|
|
|
|
rv = sgwu_gtp_open();
|
|
if (rv != OGS_OK) return rv;
|
|
|
|
thread = ogs_thread_create(sgwu_main, NULL);
|
|
if (!thread) return OGS_ERROR;
|
|
|
|
initialized = 1;
|
|
|
|
return OGS_OK;
|
|
}
|
|
|
|
void sgwu_terminate(void)
|
|
{
|
|
if (!initialized) return;
|
|
|
|
sgwu_event_term();
|
|
|
|
ogs_thread_destroy(thread);
|
|
|
|
sgwu_pfcp_close();
|
|
sgwu_gtp_close();
|
|
|
|
sgwu_context_final();
|
|
|
|
ogs_pfcp_context_final();
|
|
ogs_gtp_context_final();
|
|
|
|
ogs_pfcp_xact_final();
|
|
|
|
sgwu_gtp_final();
|
|
sgwu_event_final();
|
|
}
|
|
|
|
static void sgwu_main(void *data)
|
|
{
|
|
ogs_fsm_t sgwu_sm;
|
|
int rv;
|
|
|
|
ogs_fsm_init(&sgwu_sm, sgwu_state_initial, sgwu_state_final, 0);
|
|
|
|
for ( ;; ) {
|
|
ogs_pollset_poll(ogs_app()->pollset,
|
|
ogs_timer_mgr_next(ogs_app()->timer_mgr));
|
|
|
|
/*
|
|
* After ogs_pollset_poll(), ogs_timer_mgr_expire() must be called.
|
|
*
|
|
* The reason is why ogs_timer_mgr_next() can get the corrent value
|
|
* when ogs_timer_stop() is called internally in ogs_timer_mgr_expire().
|
|
*
|
|
* You should not use event-queue before ogs_timer_mgr_expire().
|
|
* In this case, ogs_timer_mgr_expire() does not work
|
|
* because 'if rv == OGS_DONE' statement is exiting and
|
|
* not calling ogs_timer_mgr_expire().
|
|
*/
|
|
ogs_timer_mgr_expire(ogs_app()->timer_mgr);
|
|
|
|
for ( ;; ) {
|
|
sgwu_event_t *e = NULL;
|
|
|
|
rv = ogs_queue_trypop(ogs_app()->queue, (void**)&e);
|
|
ogs_assert(rv != OGS_ERROR);
|
|
|
|
if (rv == OGS_DONE)
|
|
goto done;
|
|
|
|
if (rv == OGS_RETRY)
|
|
break;
|
|
|
|
ogs_assert(e);
|
|
ogs_fsm_dispatch(&sgwu_sm, e);
|
|
sgwu_event_free(e);
|
|
}
|
|
}
|
|
done:
|
|
|
|
ogs_fsm_fini(&sgwu_sm, 0);
|
|
}
|