X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=ntsimulator%2Fntsim-ng%2Fcore%2Fapp%2Fnetwork_function.c;h=c655dfb4293d9830832c5f8ef6701c7079bdaa60;hb=refs%2Fchanges%2F90%2F11090%2F1;hp=d7909c4db1f5a72ccbd19920ffaea70bd1876f2e;hpb=fd9a6164f9cff51682fcebe77f53d99b8d882bc7;p=sim%2Fo1-interface.git diff --git a/ntsimulator/ntsim-ng/core/app/network_function.c b/ntsimulator/ntsim-ng/core/app/network_function.c index d7909c4..c655dfb 100644 --- a/ntsimulator/ntsim-ng/core/app/network_function.c +++ b/ntsimulator/ntsim-ng/core/app/network_function.c @@ -33,6 +33,7 @@ #include "core/context.h" #include "core/session.h" #include "core/xpath.h" +#include "core/datastore/schema.h" #include "core/datastore/populate.h" #include "core/faults/faults.h" @@ -43,8 +44,11 @@ #include "features/manual_notification/manual_notification.h" #include "features/netconf_call_home/netconf_call_home.h" #include "features/web_cut_through/web_cut_through.h" +#include "features/ves_o1_pnf_registration/ves_o1_pnf_registration.h" #include "app_common.h" +#include "nf_oran_du.h" +#include "nf_oran_ru_supervision.h" #define NF_FUNCTION_CONTROL_BUFFER_LENGTH 32 @@ -93,9 +97,9 @@ int network_function_run(void) { } } - if(pthread_mutex_init(&nf_function_control_lock, NULL) != 0) { - log_error("mutex init has failed\n"); - return NTS_ERR_FAILED; + if(pthread_mutex_init(&nf_function_control_lock, NULL) != 0) { + log_error("mutex init has failed\n"); + return NTS_ERR_FAILED; } //ietf-netconf-monitoring schemas populate with modules and submodules (overwrite default Netopeer2 behaviour) @@ -164,9 +168,9 @@ int network_function_run(void) { return NTS_ERR_FAILED; } - if(pthread_mutex_init(&faults_lock, NULL) != 0) { - log_error("mutex init has failed\n"); - return NTS_ERR_FAILED; + if(pthread_mutex_init(&faults_lock, NULL) != 0) { + log_error("mutex init has failed\n"); + return NTS_ERR_FAILED; } if(pthread_create(&faults_thread, 0, faults_thread_routine, 0)) { @@ -185,7 +189,7 @@ int network_function_run(void) { nf_function_control_buffer_in = 0; } - log_add_verbose(1, LOG_COLOR_BOLD_YELLOW"running in NETWORK FUNCTION STANDALONE mode!\n"LOG_COLOR_RESET); + log_add_verbose(1, LOG_COLOR_BOLD_YELLOW"running in NETWORK FUNCTION STANDALONE mode as a %s\n"LOG_COLOR_RESET, framework_environment.nts.function_type); log_add_verbose(1, "Currently enabled features are: %s\n", framework_environment.nts.nf_standalone_start_features); log_add_verbose(1, LOG_COLOR_BOLD_YELLOW"Docker IP:"LOG_COLOR_RESET" %s\n", framework_environment.settings.ip_v6_enabled ? framework_environment.settings.ip_v6 : framework_environment.settings.ip_v4); log_add_verbose(1, LOG_COLOR_BOLD_YELLOW"Docker ports"LOG_COLOR_RESET": "); @@ -216,6 +220,22 @@ int network_function_run(void) { log_add(1,"\n"); } + if(strcmp(framework_environment.nts.function_type, "NTS_FUNCTION_TYPE_O_RAN_O_DU") == 0) { + rc = nf_oran_du_init(); + if(rc != NTS_ERR_OK) { + log_error("nf_oran_du_init failed\n"); + return NTS_ERR_FAILED; + } + } + + if(strcmp(framework_environment.nts.function_type, "NTS_FUNCTION_TYPE_O_RAN_O_RU_FH") == 0) { + log_add_verbose(1, "Initializing o-ran-supervision function...\n"); + rc = nf_oran_ru_supervision_init(); + if(rc != NTS_ERR_OK) { + log_error("nf_oran_ru_supervision_init failed, continuing...\n"); + } + } + while(!framework_sigint) { pthread_mutex_lock(&nf_function_control_lock); while(nf_function_control_buffer_in != nf_function_control_buffer_out) { @@ -227,10 +247,36 @@ int network_function_run(void) { } if(strstr(nf_function_control_string, "datastore-populate") != 0) { - rc = datastore_populate(3); + rc = datastore_populate_all(); if(rc != NTS_ERR_OK) { - log_error("datastore_populate() failed\n"); + log_error("datastore_populate_all() failed\n"); + } + + //subscribe to any changes so the operational is dynamic + char **xpaths = 0; + char **modules = 0; + int xpaths_count = datastore_schema_get_running_xpaths(&xpaths, &modules); + if(xpaths_count < 0) { + log_error("datastore_schema_get_running_xpaths failed\n"); + return NTS_ERR_FAILED; + } + + for(int i = 0; i < xpaths_count; i++) { + //subscribe + log_add_verbose(1, "subscribing to %s on module %s... ", xpaths[i], modules[i]); + rc = sr_module_change_subscribe(session_running, modules[i], xpaths[i], datastore_dynamic_operational_auto_callback, 0, 0, SR_SUBSCR_DONE_ONLY | SR_SUBSCR_CTX_REUSE, &session_subscription); + if(rc != SR_ERR_OK) { + log_error("sr_module_change_subscribe error\n"); + } + else { + log_add(1, "done\n"); + } + + free(xpaths[i]); + free(modules[i]); } + free(modules); + free(xpaths); } if(strstr(nf_function_control_string, "ves-file-ready") != 0) { @@ -260,6 +306,16 @@ int network_function_run(void) { } } + if(strstr(nf_function_control_string, "ves-o1-pnf-registration") != 0) { + if(nf_function_control_string[0] == '1') { + // check if O1 PNF registration is enabled and send PNF registration message if so + rc = ves_o1_pnf_registration_feature_start(session_running); + if(rc != 0) { + log_error("ves_o1_pnf_registration_feature_start() failed\n"); + } + } + } + if(strstr(nf_function_control_string, "ves-heartbeat") != 0) { if(nf_function_control_string[0] == '1') { // start feature for handling the heartbeat VES message @@ -330,6 +386,7 @@ int network_function_run(void) { } faults_free(); + nf_oran_du_free(); return NTS_ERR_OK; } @@ -349,7 +406,7 @@ static int netconf_monitoring_state_schemas_cb(sr_session_ctx_t *session, const if (!strcmp("sysrepo", mod->name) || !strcmp("sysrepo-monitoring", mod->name) || !strcmp("sysrepo-plugind", mod->name)) { continue; } - + list = lyd_new(root, NULL, "schema"); lyd_new_leaf(list, NULL, "identifier", mod->name); lyd_new_leaf(list, NULL, "version", (mod->rev ? mod->rev[0].date : NULL)); @@ -380,7 +437,7 @@ static int notifications_streams_cb(sr_session_ctx_t *session, const char *modul struct lyd_node *stream = lyd_new_path(root, 0, NC_NOTIFICATIONS_STREAMS_SCHEMA_XPATH"/stream[name='NETCONF']", NULL, 0, 0); lyd_new_leaf(stream, stream->schema->module, "description", "Default NETCONF stream containing notifications from all the modules. Replays only notifications for modules that support replay."); lyd_new_leaf(stream, stream->schema->module, "replaySupport", "true"); - + /* all other streams */ struct lyd_node *sr_data; struct lyd_node *sr_mod; @@ -415,7 +472,7 @@ static int notifications_streams_cb(sr_session_ctx_t *session, const char *modul rep_sup = set->set.d[0]; } ly_set_free(set); - + lyd_new_leaf(stream, NULL, "replaySupport", rep_sup ? "true" : "false"); if(rep_sup) { char buf[26]; @@ -546,7 +603,7 @@ static int network_function_feature_control_cb(sr_session_ctx_t *session, const pthread_mutex_unlock(&nf_function_control_lock); } - + return rc; } @@ -641,7 +698,7 @@ static int network_function_info_get_items_cb(sr_session_ctx_t *session, const c if(ves_file_ready_feature_get_status()) { strcat(started_features, "ves-file-ready "); } - + if(ves_pnf_registration_feature_get_status()) { strcat(started_features, "ves-pnf-registration "); } @@ -649,7 +706,7 @@ static int network_function_info_get_items_cb(sr_session_ctx_t *session, const c if(ves_heartbeat_feature_get_status()) { strcat(started_features, "ves-heartbeat "); } - + if(manual_notification_feature_get_status()) { strcat(started_features, "manual-notification-generation "); } @@ -657,11 +714,15 @@ static int network_function_info_get_items_cb(sr_session_ctx_t *session, const c if(netconf_call_home_feature_get_status()) { strcat(started_features, "netconf-call-home "); } - + if(web_cut_through_feature_get_status()) { strcat(started_features, "web-cut-through "); } - + + if(ves_o1_pnf_registration_feature_get_status()) { + strcat(started_features, "ves-o1-pnf-registration "); + } + if(strlen(started_features)) { started_features[strlen(started_features) - 1] = 0; } @@ -686,7 +747,7 @@ static int faults_update_config(sr_session_ctx_t *session) { assert_session(); int ret = NTS_ERR_OK; - + int rc; struct lyd_node *data; rc = sr_get_subtree(session, NTS_NF_FAULT_GENERATION_SCHEMA_XPATH, 0, &data); @@ -719,9 +780,9 @@ static int faults_update_config(sr_session_ctx_t *session) { } } } - + } - + faults_update_config_free: lyd_free(data); @@ -796,7 +857,7 @@ static void *faults_thread_routine(void *arg) { log_error("lyd_parse_mem failed\n"); goto fault_send_ves; } - + rc = sr_event_notif_send_tree(current_session_running, notif); lyd_free(notif); if(rc != SR_ERR_OK) { @@ -842,7 +903,7 @@ static int network_function_change_cb(sr_session_ctx_t *session, const char *mod } while((rc = sr_get_change_next(session, it, &oper, &old_value, &new_value)) == SR_ERR_OK) { - + if(new_value->xpath && (strcmp(new_value->xpath, NTS_NF_NETWORK_FUNCTION_FTYPE_SCHEMA_XPATH) == 0)) { if(old_value && !old_value->dflt) { rc = sr_set_item(session, old_value->xpath, old_value, 0);