X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=ntsimulator%2Fntsim-ng%2Fcore%2Fapp%2Fnetwork_function.c;h=5a66d18125879bb7a4447034a2eda29b12a582d3;hb=312a154cc4d60a09596fba8fd1259345e048cdc2;hp=fbd2478e5d3e2d7134d299f37cb2b31ea13ebcc9;hpb=f1d5c9198acde7a7ce296490087cad37e008f688;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 fbd2478..5a66d18 100644 --- a/ntsimulator/ntsim-ng/core/app/network_function.c +++ b/ntsimulator/ntsim-ng/core/app/network_function.c @@ -26,6 +26,7 @@ #include #include +#include #include "core/framework.h" #include "core/context.h" @@ -39,14 +40,27 @@ #include "features/ves_file_ready/ves_file_ready.h" #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" -#define POPULATE_RPC_SCHEMA_XPATH "/nts-network-function:datastore-random-populate" -#define FEATURE_CONTROL_SCHEMA_XPATH "/nts-network-function:feature-control" -#define FAULTS_CLEAR_SCHEMA_XPATH "/nts-network-function:clear-fault-counters" -#define FAULTS_LIST_SCHEMA_XPATH "/nts-network-function:simulation/network-function/fault-generation" -#define FAULTS_COUNT_LIST_SCHEMA_XPATH "/nts-network-function:simulation/network-function/fault-generation/fault-count" -#define FAULTS_NC_ENABLED_SCHEMA_XPATH "/nts-network-function:simulation/network-function/netconf/faults-enabled" -#define FAULTS_VES_ENABLED_SCHEMA_XPATH "/nts-network-function:simulation/network-function/ves/faults-enabled" +#define IETF_NETCONF_MONITORING_MODULE "ietf-netconf-monitoring" +#define IETF_NETCONF_MONITORING_STATE_SCHEMAS_SCHEMA_XPATH "/ietf-netconf-monitoring:netconf-state/schemas" + +#define NC_NOTIFICATIONS_MODULE "nc-notifications" +#define NC_NOTIFICATIONS_STREAMS_SCHEMA_XPATH "/nc-notifications:netconf/streams" + +#define NTS_NETWORK_FUNCTION_MODULE "nts-network-function" +#define NTS_NETWORK_FUNCTION_SCHEMA_XPATH "/nts-network-function:simulation/network-function" + +#define POPULATE_RPC_SCHEMA_XPATH "/nts-network-function:datastore-random-populate" +#define FEATURE_CONTROL_SCHEMA_XPATH "/nts-network-function:feature-control" +#define FAULTS_CLEAR_SCHEMA_XPATH "/nts-network-function:clear-fault-counters" +#define FAULTS_LIST_SCHEMA_XPATH "/nts-network-function:simulation/network-function/fault-generation" +#define FAULTS_COUNT_LIST_SCHEMA_XPATH "/nts-network-function:simulation/network-function/fault-generation/fault-count" +#define FAULTS_NC_ENABLED_SCHEMA_XPATH "/nts-network-function:simulation/network-function/netconf/faults-enabled" +#define FAULTS_VES_ENABLED_SCHEMA_XPATH "/nts-network-function:simulation/network-function/ves/faults-enabled" + +static int netconf_monitoring_state_schemas_cb(sr_session_ctx_t *session, const char *module_name, const char *path, const char *request_xpath, uint32_t request_id, struct lyd_node **parent, void *private_data); +static int notifications_streams_cb(sr_session_ctx_t *session, const char *module_name, const char *path, const char *request_xpath, uint32_t request_id, struct lyd_node **parent, void *private_data); static int network_function_populate_cb(sr_session_ctx_t *session, const char *path, const sr_val_t *input, const size_t input_cnt, sr_event_t event, uint32_t request_id, sr_val_t **output, size_t *output_cnt, void *private_data); static int network_function_feature_control_cb(sr_session_ctx_t *session, const char *path, const sr_val_t *input, const size_t input_cnt, sr_event_t event, uint32_t request_id, sr_val_t **output, size_t *output_cnt, void *private_data); @@ -54,6 +68,8 @@ static int network_function_faults_clear_cb(sr_session_ctx_t *session, const cha static int network_function_faults_change_cb(sr_session_ctx_t *session, const char *module_name, const char *xpath, sr_event_t event, uint32_t request_id, void *private_data); static int network_function_faults_count_get_items_cb(sr_session_ctx_t *session, const char *module_name, const char *xpath, const char *request_xpath, uint32_t request_id, struct lyd_node **parent, void *private_data); +static int network_function_change_cb(sr_session_ctx_t *session, const char *module_name, const char *xpath, sr_event_t event, uint32_t request_id, void *private_data); + static int faults_update_config(sr_session_ctx_t *session); //not protected by lock static void *faults_thread_routine(void *arg); @@ -63,6 +79,12 @@ static char *nf_function_control_string = 0; static pthread_t faults_thread; static pthread_mutex_t faults_lock; +static pthread_mutex_t network_function_change_lock; +static char *function_type_default = 0; +static char *function_type_val = 0; +static char *mount_point_addressing_method_default = 0; +static char *mount_point_addressing_method_val = 0; + int network_function_run(void) { assert_session(); @@ -73,8 +95,22 @@ int network_function_run(void) { return NTS_ERR_FAILED; } + //ietf-netconf-monitoring schemas populate with modules and submodules (overwrite default Netopeer2 behaviour) + int rc = sr_oper_get_items_subscribe(session_running, IETF_NETCONF_MONITORING_MODULE, IETF_NETCONF_MONITORING_STATE_SCHEMAS_SCHEMA_XPATH, netconf_monitoring_state_schemas_cb, 0, SR_SUBSCR_DEFAULT, &session_subscription); + if(rc != SR_ERR_OK) { + log_error("error from sr_oper_get_items_subscribe: %s", sr_strerror(rc)); + return 0; + } + + //nc-notifications overwrite + rc = sr_oper_get_items_subscribe(session_running, NC_NOTIFICATIONS_MODULE, NC_NOTIFICATIONS_STREAMS_SCHEMA_XPATH, notifications_streams_cb, 0, SR_SUBSCR_DEFAULT, &session_subscription); + if(rc != SR_ERR_OK) { + log_error("error from sr_oper_get_items_subscribe: %s", sr_strerror(rc)); + return 0; + } + //populate - int rc = sr_rpc_subscribe(session_running, POPULATE_RPC_SCHEMA_XPATH, network_function_populate_cb, 0, 0, SR_SUBSCR_CTX_REUSE, &session_subscription); + rc = sr_rpc_subscribe(session_running, POPULATE_RPC_SCHEMA_XPATH, network_function_populate_cb, 0, 0, SR_SUBSCR_CTX_REUSE, &session_subscription); if(rc != SR_ERR_OK) { log_error("error from sr_rpc_subscribe: %s", sr_strerror(rc)); return NTS_ERR_FAILED; @@ -88,13 +124,13 @@ int network_function_run(void) { } //faults - rc = sr_module_change_subscribe(session_running, "nts-network-function", FAULTS_LIST_SCHEMA_XPATH, network_function_faults_change_cb, NULL, 0, SR_SUBSCR_CTX_REUSE, &session_subscription); + rc = sr_module_change_subscribe(session_running, NTS_NETWORK_FUNCTION_MODULE, FAULTS_LIST_SCHEMA_XPATH, network_function_faults_change_cb, NULL, 0, SR_SUBSCR_CTX_REUSE, &session_subscription); if(rc != SR_ERR_OK) { log_error("could not subscribe to faults"); return 0; } - rc = sr_oper_get_items_subscribe(session_running, "nts-network-function", FAULTS_COUNT_LIST_SCHEMA_XPATH, network_function_faults_count_get_items_cb, NULL, SR_SUBSCR_CTX_REUSE, &session_subscription); + rc = sr_oper_get_items_subscribe(session_running, NTS_NETWORK_FUNCTION_MODULE, FAULTS_COUNT_LIST_SCHEMA_XPATH, network_function_faults_count_get_items_cb, NULL, SR_SUBSCR_CTX_REUSE, &session_subscription); if(rc != SR_ERR_OK) { log_error("could not subscribe to oper faults: %s", sr_strerror(rc)); return 0; @@ -106,6 +142,13 @@ int network_function_run(void) { return NTS_ERR_FAILED; } + //subscribe to any changes on the main + rc = sr_module_change_subscribe(session_running, NTS_NETWORK_FUNCTION_MODULE, NTS_NETWORK_FUNCTION_SCHEMA_XPATH, network_function_change_cb, NULL, 0, SR_SUBSCR_CTX_REUSE, &session_subscription); + if(rc != SR_ERR_OK) { + log_error("could not subscribe to simulation changes"); + return NTS_ERR_FAILED; + } + rc = faults_init(); if(rc != NTS_ERR_OK) { log_error("faults_init error", sr_strerror(rc)); @@ -122,7 +165,41 @@ int network_function_run(void) { return NTS_ERR_FAILED; } + if(pthread_mutex_init(&network_function_change_lock, NULL) != 0) { + log_error("mutex init has failed"); + return NTS_ERR_FAILED; + } + while(!framework_sigint) { + pthread_mutex_lock(&network_function_change_lock); + if(function_type_val) { + rc = sr_set_item_str(session_running, NTS_NETWORK_FUNCTION_SCHEMA_XPATH"/function-type", function_type_val, 0, 0); + if(rc != SR_ERR_OK) { + log_error("sr_set_item_str failed"); + } + + rc = sr_apply_changes(session_running, 0, 0); + if(rc != SR_ERR_OK) { + log_error("sr_apply_changes failed"); + } + + function_type_val = 0; + } + + if(mount_point_addressing_method_val) { + rc = sr_set_item_str(session_running, NTS_NETWORK_FUNCTION_SCHEMA_XPATH"/mount-point-addressing-method", mount_point_addressing_method_val, 0, 0); + if(rc != SR_ERR_OK) { + log_error("sr_set_item_str failed"); + } + + rc = sr_apply_changes(session_running, 0, 0); + if(rc != SR_ERR_OK) { + log_error("sr_apply_changes failed"); + } + + mount_point_addressing_method_val = 0; + } + pthread_mutex_unlock(&network_function_change_lock); pthread_mutex_lock(&nf_function_control_lock); if(nf_function_control_string) { @@ -166,6 +243,14 @@ int network_function_run(void) { } } + if(strstr(nf_function_control_string, "web-cut-through") != 0) { + // start feature for NETCONF Call Home + rc = web_cut_through_feature_start(session_running); + if(rc != 0) { + log_error("web_cut_through_feature_start() failed"); + } + } + free(nf_function_control_string); nf_function_control_string = 0; } @@ -179,6 +264,98 @@ int network_function_run(void) { return NTS_ERR_OK; } +static int netconf_monitoring_state_schemas_cb(sr_session_ctx_t *session, const char *module_name, const char *path, const char *request_xpath, uint32_t request_id, struct lyd_node **parent, void *private_data) { + struct lyd_node *root = 0; + root = lyd_new_path(*parent, session_context, IETF_NETCONF_MONITORING_STATE_SCHEMAS_SCHEMA_XPATH, 0, 0, 0); + + struct lyd_node *list = 0; + const struct lys_module *mod = 0; + const struct lys_submodule *submod = 0; + uint32_t i = 0; + + // get all modules from context + while ((mod = ly_ctx_get_module_iter(session_context, &i))) { + 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)); + lyd_new_leaf(list, NULL, "format", "yang"); + lyd_new_leaf(list, NULL, "namespace", lys_main_module(mod)->ns); + lyd_new_leaf(list, NULL, "location", "NETCONF"); + + // iterate all the submodules included by a module + for (int j = 0; j < mod->inc_size; j++) { + submod = mod->inc[j].submodule; + + list = lyd_new(root, NULL, "schema"); + lyd_new_leaf(list, NULL, "identifier", submod->name); + lyd_new_leaf(list, NULL, "version", (submod->rev ? submod->rev[0].date : NULL)); + lyd_new_leaf(list, NULL, "format", "yang"); + lyd_new_leaf(list, NULL, "namespace", lys_main_module(mod)->ns); + lyd_new_leaf(list, NULL, "location", "NETCONF"); + } + } + + return SR_ERR_OK; +} + +static int notifications_streams_cb(sr_session_ctx_t *session, const char *module_name, const char *path, const char *request_xpath, uint32_t request_id, struct lyd_node **parent, void *private_data) { + struct lyd_node *root = lyd_new_path(0, session_context, NC_NOTIFICATIONS_STREAMS_SCHEMA_XPATH, 0, 0, 0); + + /* generic stream */ + struct lyd_node *stream = lyd_new_path(root, 0, "/nc-notifications:netconf/streams/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; + /* go through all the sysrepo modules */ + int rc = sr_get_module_info(session_connection, &sr_data); + if(rc != SR_ERR_OK) { + log_error("sr_get_module_info failed"); + return SR_ERR_OPERATION_FAILED; + } + + LY_TREE_FOR(sr_data->child, sr_mod) { + const char *mod_name = ((struct lyd_node_leaf_list *)sr_mod->child)->value_str; + const struct lys_module *mod = ly_ctx_get_module(session_context, mod_name, 0, 1); + int has_notifications = 0; + struct lys_node *data = mod->data; + while(data) { + if(data->nodetype == LYS_NOTIF) { + has_notifications = 1; + } + data = data->next; + } + + if(has_notifications) { + /* generate information about the stream/module */ + stream = lyd_new(root->child, NULL, "stream"); + lyd_new_leaf(stream, NULL, "name", mod_name); + lyd_new_leaf(stream, NULL, "description", "Stream with all notifications of a module."); + + struct lyd_node *rep_sup = 0; + struct ly_set *set = lyd_find_path(sr_mod, "replay-support"); + if(set && (set->number == 1)) { + 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]; + nc_time2datetime(((struct lyd_node_leaf_list *)rep_sup)->value.uint64, NULL, buf); + lyd_new_leaf(stream, NULL, "replayLogCreationTime", buf); + } + } + } + + lyd_free_withsiblings(sr_data); + *parent = root; + + return SR_ERR_OK; +} + static int network_function_populate_cb(sr_session_ctx_t *session, const char *path, const sr_val_t *input, const size_t input_cnt, sr_event_t event, uint32_t request_id, sr_val_t **output, size_t *output_cnt, void *private_data) { int rc; @@ -450,3 +627,62 @@ static void *faults_thread_routine(void *arg) { return 0; } + +static int network_function_change_cb(sr_session_ctx_t *session, const char *module_name, const char *xpath, sr_event_t event, uint32_t request_id, void *private_data) { + sr_change_iter_t *it = 0; + int rc = SR_ERR_OK; + sr_change_oper_t oper; + sr_val_t *old_value = 0; + sr_val_t *new_value = 0; + + static bool function_type_set = false; + static bool mount_point_addressing_method_set = false; + + if(event == SR_EV_DONE) { + rc = sr_get_changes_iter(session, NTS_NETWORK_FUNCTION_SCHEMA_XPATH"//.", &it); + if(rc != SR_ERR_OK) { + log_error("sr_get_changes_iter failed"); + return SR_ERR_VALIDATION_FAILED; + } + + 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_NETWORK_FUNCTION_SCHEMA_XPATH"/function-type") == 0)) { + if(function_type_set == false) { + function_type_set = true; + function_type_default = strdup(new_value->data.string_val); + } + else { + //prevent changing function_type + if(strcmp(new_value->data.string_val, function_type_default) != 0) { + pthread_mutex_lock(&network_function_change_lock); + function_type_val = function_type_default; + pthread_mutex_unlock(&network_function_change_lock); + } + } + } + + if(new_value->xpath && (strcmp(new_value->xpath, NTS_NETWORK_FUNCTION_SCHEMA_XPATH"/mount-point-addressing-method") == 0)) { + if(mount_point_addressing_method_set == false) { + mount_point_addressing_method_set = true; + mount_point_addressing_method_default = strdup(new_value->data.string_val); + } + else { + //prevent changing mount_point_addressing_method + if(strcmp(new_value->data.string_val, mount_point_addressing_method_default) != 0) { + pthread_mutex_lock(&network_function_change_lock); + mount_point_addressing_method_val = mount_point_addressing_method_default; + pthread_mutex_unlock(&network_function_change_lock); + } + } + } + + sr_free_val(old_value); + sr_free_val(new_value); + } + + sr_free_change_iter(it); + } + + return SR_ERR_OK; +}