X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?p=sim%2Fo1-interface.git;a=blobdiff_plain;f=ntsimulator%2Fntsim-ng%2Ffeatures%2Fves_heartbeat%2Fves_heartbeat.c;h=4d9b3a6f5050600d0986db2c1c195f95e1a39a8c;hp=5e7db906504b0adff4607669838e021e41e48024;hb=c7e43513c1c4c3569d5079db0a9a31c124274e6c;hpb=908fe04b071e17feb1984cbc342ab9f45f325e18 diff --git a/ntsimulator/ntsim-ng/features/ves_heartbeat/ves_heartbeat.c b/ntsimulator/ntsim-ng/features/ves_heartbeat/ves_heartbeat.c index 5e7db90..4d9b3a6 100644 --- a/ntsimulator/ntsim-ng/features/ves_heartbeat/ves_heartbeat.c +++ b/ntsimulator/ntsim-ng/features/ves_heartbeat/ves_heartbeat.c @@ -32,8 +32,7 @@ #include "core/session.h" #include "core/framework.h" - -#define HEARTBEAT_SCHEMA_XPATH "/nts-network-function:simulation/network-function/ves/heartbeat-period" +#include "core/xpath.h" static volatile int ves_heartbeat_period; static int ves_sequence_number; @@ -73,7 +72,7 @@ int ves_heartbeat_feature_start(sr_session_ctx_t *current_session) { ves_heartbeat_period = 0; ves_sequence_number = 0; - int rc = sr_get_item(current_session, HEARTBEAT_SCHEMA_XPATH, 0, &value); + int rc = sr_get_item(current_session, NTS_NF_VES_HEARTBEAT_SCHEMA_XPATH, 0, &value); if(rc == SR_ERR_OK) { ves_heartbeat_period_set(value->data.uint16_val); sr_free_val(value); @@ -82,7 +81,7 @@ int ves_heartbeat_feature_start(sr_session_ctx_t *current_session) { log_error("sr_get_item failed\n"); } - rc = sr_module_change_subscribe(current_session, "nts-network-function", HEARTBEAT_SCHEMA_XPATH, heartbeat_change_cb, NULL, 0, SR_SUBSCR_CTX_REUSE, &ves_heartbeat_subscription); + rc = sr_module_change_subscribe(current_session, NTS_NETWORK_FUNCTION_MODULE, NTS_NF_VES_HEARTBEAT_SCHEMA_XPATH, heartbeat_change_cb, NULL, 0, SR_SUBSCR_CTX_REUSE, &ves_heartbeat_subscription); if(rc != SR_ERR_OK) { log_error("could not subscribe to heartbeat\n"); return NTS_ERR_FAILED; @@ -326,7 +325,7 @@ static int heartbeat_change_cb(sr_session_ctx_t *session, const char *module_nam sr_val_t *new_value = 0; if(event == SR_EV_DONE) { - rc = sr_get_changes_iter(session, HEARTBEAT_SCHEMA_XPATH, &it); + rc = sr_get_changes_iter(session, NTS_NF_VES_HEARTBEAT_SCHEMA_XPATH, &it); if(rc != SR_ERR_OK) { log_error("sr_get_changes_iter failed\n"); return SR_ERR_VALIDATION_FAILED;