sysmocom
/
open5gs
forked from acouzens/open5gs
11
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Follow-up on #1758

This commit is contained in:
Sukchan Lee 2022-09-23 21:25:58 +09:00
parent 7f5476b111
commit a0d643e17f
7 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/app/ogs-context.c
View File

@ -350,7 +350,8 @@ int ogs_app_context_parse_config(void)
} else if (!strcmp(parameter_key, "no_pfcp_rr_select")) { } else if (!strcmp(parameter_key, "no_pfcp_rr_select")) {
self.parameter.no_pfcp_rr_select = self.parameter.no_pfcp_rr_select =
ogs_yaml_iter_bool(&parameter_iter); ogs_yaml_iter_bool(&parameter_iter);
} else if (!strcmp(parameter_key, "use_mongodb_change_stream")) { } else if (!strcmp(parameter_key,
"use_mongodb_change_stream")) {
self.use_mongodb_change_stream = self.use_mongodb_change_stream =
ogs_yaml_iter_bool(&parameter_iter); ogs_yaml_iter_bool(&parameter_iter);
} else } else

6
lib/dbi/ogs-mongoc.c
View File

@ -189,7 +189,8 @@ void ogs_dbi_final()
ogs_mongoc_final(); ogs_mongoc_final();
} }
int ogs_dbi_collection_watch_init(void) { int ogs_dbi_collection_watch_init(void)
{
bson_t empty = BSON_INITIALIZER; bson_t empty = BSON_INITIALIZER;
const bson_t *err_doc; const bson_t *err_doc;
bson_error_t error; bson_error_t error;
@ -214,7 +215,8 @@ int ogs_dbi_collection_watch_init(void) {
return OGS_OK; return OGS_OK;
} }
int ogs_dbi_poll_change_stream(void) { int ogs_dbi_poll_change_stream(void)
{
int rv; int rv;
const bson_t *document; const bson_t *document;

5
lib/dbi/path.c
View File

@ -19,7 +19,8 @@
#include "ogs-dbi.h" #include "ogs-dbi.h"
int ogs_dbi_process_change_stream(const bson_t *document) { int ogs_dbi_process_change_stream(const bson_t *document)
{
int rv; int rv;
ogs_event_t *e = NULL; ogs_event_t *e = NULL;
@ -37,4 +38,4 @@ int ogs_dbi_process_change_stream(const bson_t *document) {
} }
return OGS_OK; return OGS_OK;
} }

4
lib/proto/timer.c
View File

@ -31,8 +31,6 @@ const char *OGS_TIMER_NAME_SUBSCRIPTION_VALIDITY =
"OGS_TIMER_SUBSCRIPTION_VALIDITY"; "OGS_TIMER_SUBSCRIPTION_VALIDITY";
const char *OGS_TIMER_NAME_SBI_CLIENT_WAIT = const char *OGS_TIMER_NAME_SBI_CLIENT_WAIT =
"OGS_TIMER_SBI_CLIENT_WAIT"; "OGS_TIMER_SBI_CLIENT_WAIT";
const char *OGS_TIMER_NAME_DBI_POLL_CHANGE_STREAM =
"OGS_TIMER_DBI_POLL_CHANGE_STREAM";
const char *ogs_timer_get_name(int timer_id) const char *ogs_timer_get_name(int timer_id)
{ {
@ -50,7 +48,7 @@ const char *ogs_timer_get_name(int timer_id)
case OGS_TIMER_SBI_CLIENT_WAIT: case OGS_TIMER_SBI_CLIENT_WAIT:
return OGS_TIMER_NAME_SBI_CLIENT_WAIT; return OGS_TIMER_NAME_SBI_CLIENT_WAIT;
case OGS_TIMER_DBI_POLL_CHANGE_STREAM: case OGS_TIMER_DBI_POLL_CHANGE_STREAM:
return OGS_TIMER_NAME_DBI_POLL_CHANGE_STREAM; return "OGS_TIMER_DBI_POLL_CHANGE_STREAM";
default: default:
break; break;
} }

6
src/hss/hss-context.c
View File

@ -1175,7 +1175,8 @@ char *hss_cx_download_user_data(
return user_data; return user_data;
} }
int hss_db_poll_change_stream(void) { int hss_db_poll_change_stream(void)
{
int rv; int rv;
ogs_thread_mutex_lock(&self.db_lock); ogs_thread_mutex_lock(&self.db_lock);
@ -1187,7 +1188,8 @@ int hss_db_poll_change_stream(void) {
return rv; return rv;
} }
int hss_handle_change_event(const bson_t *document) { int hss_handle_change_event(const bson_t *document)
{
bson_iter_t iter, child1_iter, child2_iter, child3_iter; bson_iter_t iter, child1_iter, child2_iter, child3_iter;
char *utf8 = NULL; char *utf8 = NULL;

2
src/hss/hss-sm.c
View File

@ -21,6 +21,8 @@
#include "hss-context.h" #include "hss-context.h"
#include "hss-event.h" #include "hss-event.h"
#define DB_POLLING_TIME ogs_time_from_msec(100)
static ogs_timer_t *t_db_polling = NULL; static ogs_timer_t *t_db_polling = NULL;
void hss_state_initial(ogs_fsm_t *s, ogs_event_t *e) void hss_state_initial(ogs_fsm_t *s, ogs_event_t *e)

2
src/hss/hss-sm.h
View File

@ -27,8 +27,6 @@
extern "C" { extern "C" {
#endif #endif
#define DB_POLLING_TIME ogs_time_from_msec(100)
void hss_state_initial(ogs_fsm_t *s, ogs_event_t *e); void hss_state_initial(ogs_fsm_t *s, ogs_event_t *e);
void hss_state_final(ogs_fsm_t *s, ogs_event_t *e); void hss_state_final(ogs_fsm_t *s, ogs_event_t *e);
void hss_state_operational(ogs_fsm_t *s, ogs_event_t *e); void hss_state_operational(ogs_fsm_t *s, ogs_event_t *e);