}
}
+ char *ipv6 = strchr(odl_ip->data.string_val, ':');
+ char odl_ip_string[URL_AND_CREDENTIALS_MAX_LEN];
+ if (ipv6 != NULL)
+ {
+ sprintf(odl_ip_string, "[%s]", odl_ip->data.string_val);
+ }
+ else
+ {
+ sprintf(odl_ip_string, "%s", odl_ip->data.string_val);
+ }
+
+
//URL used for mounting/unmounting a device; the device name needs to be appended
char url[URL_AND_CREDENTIALS_MAX_LEN];
sprintf(url, "http://%s:%d/restconf/config/network-topology:network-topology/topology/"
"topology-netconf/node/",
- odl_ip->data.string_val, odl_port->data.uint32_val);
+ odl_ip_string, odl_port->data.uint32_val);
char credentials[URL_AND_CREDENTIALS_MAX_LEN];
sprintf(credentials, "%s:%s", odl_username->data.string_val, odl_password->data.string_val);
//URLs used for adding key pair to ODL, for TLS connections
char url_for_keystore_add[URL_AND_CREDENTIALS_MAX_LEN];
sprintf(url_for_keystore_add, "http://%s:%d/restconf/operations/netconf-keystore:add-keystore-entry",
- odl_ip->data.string_val, odl_port->data.uint32_val);
+ odl_ip_string, odl_port->data.uint32_val);
char url_for_private_key_add[URL_AND_CREDENTIALS_MAX_LEN];
sprintf(url_for_private_key_add, "http://%s:%d/restconf/operations/netconf-keystore:add-private-key",
- odl_ip->data.string_val, odl_port->data.uint32_val);
+ odl_ip_string, odl_port->data.uint32_val);
char url_for_trusted_ca_add[URL_AND_CREDENTIALS_MAX_LEN];
sprintf(url_for_trusted_ca_add, "http://%s:%d/restconf/operations/netconf-keystore:add-trusted-certificate",
- odl_ip->data.string_val, odl_port->data.uint32_val);
+ odl_ip_string, odl_port->data.uint32_val);
strcpy(controller_details.url, url);
strcpy(controller_details.credentials, credentials);
{
int rc = SR_ERR_OK;
+ if (strcmp(getenv("K8S_DEPLOYMENT"), "true") == 0)
+ {
+ if (new_value != simulated_devices_config)
+ {
+ simulated_devices_config = new_value;
+ rc = send_k8s_scale(new_value);
+ if (rc != SR_ERR_OK)
+ {
+ printf("Could not send new_scale=%d to k8s cluster.\n", new_value);
+ }
+ }
+ return SR_ERR_OK;
+ }
+
if (simulated_devices_config > new_value)
{
//we are configuring less elements that currently
for (int i = 0; i < new_value - simulated_devices_config; ++i)
{
rc = start_device(device_list);
+ if (rc != SR_ERR_OK)
+ {
+ printf("ERROR: Could not start simulated device. Ignoring, trying with the next simulated device, if any...\n");
+ }
}
}
sr_free_val(val);
val = NULL;
+ size_t count = 0;
+
/* get the value from sysrepo, we do not care if the value did not change in our case */
- rc = sr_get_item(session, "/network-topology-simulator:simulator-config/notification-config/fault-notification-delay-period", &val);
+ rc = sr_get_items(session, "/network-topology-simulator:simulator-config/notification-config/fault-notification-delay-period", &val, &count);
if (rc != SR_ERR_OK) {
goto sr_error;
}
- rc = notification_delay_period_changed(val->data.uint32_val);
+ rc = notification_delay_period_changed(val, count);
if (rc != SR_ERR_OK) {
goto sr_error;
}
-
- sr_free_val(val);
+ sr_free_values(val, count);
val = NULL;
/* get the value from sysrepo, we do not care if the value did not change in our case */
sr_free_val(val);
val = NULL;
+ /* get the value from sysrepo, we do not care if the value did not change in our case */
+ rc = sr_get_item(session, "/network-topology-simulator:simulator-config/ssh-connections", &val);
+ if (rc != SR_ERR_OK) {
+ printf("NTS Manager /network-topology-simulator:simulator-config/ssh-connections object not available, ignoring..");
+ }
+ else
+ {
+ rc = ssh_connections_changed(val->data.uint32_val);
+ if (rc != SR_ERR_OK) {
+ goto sr_error;
+ }
+
+ if (strcmp(getenv("K8S_DEPLOYMENT"), "true") == 0)
+ {
+ rc = send_k8s_extend_port();
+ if (rc != SR_ERR_OK)
+ {
+ printf("Could not send the extended port to k8s cluster.\n");
+ }
+ }
+ }
+
+ sr_free_val(val);
+ val = NULL;
+
+ /* get the value from sysrepo, we do not care if the value did not change in our case */
+ rc = sr_get_item(session, "/network-topology-simulator:simulator-config/tls-connections", &val);
+ if (rc != SR_ERR_OK) {
+ printf("NTS Manager /network-topology-simulator:simulator-config/tls-connections object not available, ignoring..");
+ }
+ else
+ {
+ rc = tls_connections_changed(val->data.uint32_val);
+ if (rc != SR_ERR_OK) {
+ goto sr_error;
+ }
+
+ if (strcmp(getenv("K8S_DEPLOYMENT"), "true") == 0)
+ {
+ rc = send_k8s_extend_port();
+ if (rc != SR_ERR_OK)
+ {
+ printf("Could not send the extended port to k8s cluster.\n");
+ }
+ }
+ }
+
+ sr_free_val(val);
+ val = NULL;
+
return SR_ERR_OK;
sr_error:
{
int rc;
- printf("\n\n ========== Called simulator_status_cb for xpath: %s ==========\n\n", xpath);
+ // printf("\n\n ========== Called simulator_status_cb for xpath: %s ==========\n\n", xpath);
+
+ counterAlarms ves_counter, netconf_counter;
+ rc = compute_notifications_count(&ves_counter, &netconf_counter);
+ if (rc != SR_ERR_OK)
+ {
+ printf("Could not compute the total number of notification count.\n");
+ }
- if (sr_xpath_node_name_eq(xpath, "simulated-devices-list")) {
+ if (sr_xpath_node_name_eq(xpath, "simulated-devices-list"))
+ {
sr_val_t *v;
size_t current_num_of_values= 0;
while (current_device != NULL)
{
+ counterAlarms vesCount, netconfCount;
+ rc = getDeviceCounters(current_device->device_id, &vesCount, &netconfCount);
+ if (rc != SR_ERR_OK)
+ {
+ printf("Could not get Notification Counters for device with uuid=\"%s\"", current_device->device_id);
+ }
+
CREATE_NEW_VALUE(rc, v, current_num_of_values);
sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/%s", xpath, current_device->device_id, "device-ip");
sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/%s", xpath, current_device->device_id, "operational-state");
sr_val_build_str_data(&v[current_num_of_values - 1], SR_ENUM_T, "%s", operational_state);
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/ves-notifications/%s", xpath, current_device->device_id, "normal");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = vesCount.normal;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/ves-notifications/%s", xpath, current_device->device_id, "warning");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = vesCount.warning;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/ves-notifications/%s", xpath, current_device->device_id, "minor");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = vesCount.minor;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/ves-notifications/%s", xpath, current_device->device_id, "major");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = vesCount.major;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/ves-notifications/%s", xpath, current_device->device_id, "critical");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = vesCount.critical;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/netconf-notifications/%s", xpath, current_device->device_id, "normal");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconfCount.normal;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/netconf-notifications/%s", xpath, current_device->device_id, "warning");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconfCount.warning;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/netconf-notifications/%s", xpath, current_device->device_id, "minor");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconfCount.minor;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/netconf-notifications/%s", xpath, current_device->device_id, "major");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconfCount.major;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s[uuid='%s']/notification-count/netconf-notifications/%s", xpath, current_device->device_id, "critical");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconfCount.critical;
+
current_device = current_device->next;
}
*values = v;
*values_cnt = current_num_of_values;
}
+ else if (sr_xpath_node_name_eq(xpath, "total-ves-notifications"))
+ {
+ sr_val_t *v;
+ /* convenient functions such as this can be found in sysrepo/values.h */
+ size_t current_num_of_values= 0;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "normal");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = ves_counter.normal;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "warning");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = ves_counter.warning;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "minor");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = ves_counter.minor;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "major");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = ves_counter.major;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "critical");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = ves_counter.critical;
+
+ //return the values that we have just created
+ *values = v;
+ *values_cnt = current_num_of_values;
+ }
+ else if (sr_xpath_node_name_eq(xpath, "total-netconf-notifications"))
+ {
+ sr_val_t *v;
+ /* convenient functions such as this can be found in sysrepo/values.h */
+ size_t current_num_of_values= 0;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "normal");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconf_counter.normal;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "warning");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconf_counter.warning;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "minor");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconf_counter.minor;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "major");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconf_counter.major;
+
+ CREATE_NEW_VALUE(rc, v, current_num_of_values);
+
+ sr_val_build_xpath(&v[current_num_of_values - 1], "%s/%s", xpath, "critical");
+ v[current_num_of_values - 1].type = SR_UINT32_T;
+ v[current_num_of_values - 1].data.uint32_val = netconf_counter.critical;
+
+ //return the values that we have just created
+ *values = v;
+ *values_cnt = current_num_of_values;
+ }
return SR_ERR_OK;
}
setbuf(stdout, NULL);
+ rc = _init_curl_k8s();
+ if (rc != SR_ERR_OK)
+ {
+ fprintf(stderr, "Could not initialize cURL for K8S connection: %s\n", sr_strerror(rc));
+ }
+
device_list = new_device_stack();
rc = _init_curl();
if (rc != SR_ERR_OK)
fprintf(stderr, "Could not initialize cURL: %s\n", sr_strerror(rc));
}
+ rc = writeSkeletonConfigFile();
+ if (rc != SR_ERR_OK)
+ {
+ fprintf(stderr, "Could not initialize configuration JSON file: %s\n", sr_strerror(rc));
+ }
+
/* connect to sysrepo */
rc = sr_connect("network-topology-simulator", SR_CONN_DEFAULT, &connection);
if (SR_ERR_OK != rc) {
goto cleanup;
}
+ // setting the values that come in an ENV variable as defaults - ves-heartbeat-period
+ int vesHeartbeatPeriod = getIntFromString(getenv("VesHeartbeatPeriod"), 0);
+
+ sr_val_t value = { 0 };
+ value.type = SR_UINT32_T;
+ value.data.uint32_val = vesHeartbeatPeriod;
+ rc = sr_set_item(session, "/network-topology-simulator:simulator-config/notification-config/ves-heartbeat-period",
+ &value, SR_EDIT_DEFAULT);
+ if (SR_ERR_OK != rc) {
+ printf("Error by sr_set_item: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ rc = ves_heartbeat_period_changed(vesHeartbeatPeriod);
+ if (SR_ERR_OK != rc) {
+ printf("Error by ves_heartbeat_period_changed: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ // setting the values that come in an ENV variable as defaults - is-netconf-available
+
+ int isNetconfAvailable = 1;
+
+ char *isNetconfAvailablString = getenv("IsNetconfAvailable");
+ if (isNetconfAvailablString != NULL)
+ {
+ if (strcmp(isNetconfAvailablString, "false") == 0)
+ {
+ isNetconfAvailable = 0;
+ }
+ }
+
+ value = (const sr_val_t) { 0 };
+ value.type = SR_BOOL_T;
+ value.data.bool_val = isNetconfAvailable;
+ rc = sr_set_item(session, "/network-topology-simulator:simulator-config/notification-config/is-netconf-available",
+ &value, SR_EDIT_DEFAULT);
+ if (SR_ERR_OK != rc) {
+ printf("Error by sr_set_item: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ rc = is_netconf_available_changed(isNetconfAvailable);
+ if (SR_ERR_OK != rc) {
+ printf("Error by is_netconf_available_changed: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ // setting the values that come in an ENV variable as defaults - is-ves-available
+
+ int isVesAvailable = 1;
+
+ char *isVesAvailablString = getenv("IsVesAvailable");
+ if (isVesAvailablString != NULL)
+ {
+ if (strcmp(isVesAvailablString, "false") == 0)
+ {
+ isVesAvailable = 0;
+ }
+ }
+
+ value = (const sr_val_t) { 0 };
+ value.type = SR_BOOL_T;
+ value.data.bool_val = isVesAvailable;
+ rc = sr_set_item(session, "/network-topology-simulator:simulator-config/notification-config/is-ves-available",
+ &value, SR_EDIT_DEFAULT);
+ if (SR_ERR_OK != rc) {
+ printf("Error by sr_set_item: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ rc = is_ves_available_changed(isVesAvailable);
+ if (SR_ERR_OK != rc) {
+ printf("Error by is_ves_available_changed: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ // setting the values that come in an ENV variable as defaults - ves-endpoint-port
+
+ int vesEndpointPort = getIntFromString(getenv("VesEndpointPort"), 8080);
+
+ value = (const sr_val_t) { 0 };
+ value.type = SR_UINT16_T;
+ value.data.uint16_val = vesEndpointPort;
+ rc = sr_set_item(session, "/network-topology-simulator:simulator-config/ves-endpoint-details/ves-endpoint-port",
+ &value, SR_EDIT_DEFAULT);
+ if (SR_ERR_OK != rc) {
+ printf("Error by sr_set_item: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ rc = ves_port_changed(vesEndpointPort);
+ if (SR_ERR_OK != rc) {
+ printf("Error by ves_port_changed: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ // setting the values that come in an ENV variable as defaults - ves-endpoint-ip
+
+ value = (const sr_val_t) { 0 };
+ value.type = SR_STRING_T;
+ value.data.string_val = getenv("VesEndpointIp");
+ rc = sr_set_item(session, "/network-topology-simulator:simulator-config/ves-endpoint-details/ves-endpoint-ip",
+ &value, SR_EDIT_DEFAULT);
+ if (SR_ERR_OK != rc) {
+ printf("Error by sr_set_item: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ rc = ves_ip_changed(getenv("VesEndpointIp"));
+ if (SR_ERR_OK != rc) {
+ printf("Error by ves_ip_changed: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ // setting the values that come in an ENV variable as defaults - ssh-connections
+
+ int sshConnections = getIntFromString(getenv("SshConnections"), 1);
+
+ value = (const sr_val_t) { 0 };
+ value.type = SR_UINT32_T;
+ value.data.uint32_val = sshConnections;
+ rc = sr_set_item(session, "/network-topology-simulator:simulator-config/ssh-connections",
+ &value, SR_EDIT_DEFAULT);
+ if (SR_ERR_OK != rc) {
+ printf("Error by sr_set_item: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ rc = ssh_connections_changed(sshConnections);
+ if (SR_ERR_OK != rc) {
+ printf("Error by ssh_connections_changed: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ // setting the values that come in an ENV variable as defaults - tls-connections
+
+ int tlsConnections = getIntFromString(getenv("TlsConnections"), 0);
+
+ value = (const sr_val_t) { 0 };
+ value.type = SR_UINT32_T;
+ value.data.uint32_val = tlsConnections;
+ rc = sr_set_item(session, "/network-topology-simulator:simulator-config/tls-connections",
+ &value, SR_EDIT_DEFAULT);
+ if (SR_ERR_OK != rc) {
+ printf("Error by sr_set_item: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ rc = tls_connections_changed(tlsConnections);
+ if (SR_ERR_OK != rc) {
+ printf("Error by tls_connections_changed: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
+ if (strcmp(getenv("K8S_DEPLOYMENT"), "true") == 0)
+ {
+ rc = send_k8s_extend_port();
+ if (rc != SR_ERR_OK)
+ {
+ printf("Could not send the number of ports to k8s cluster\n");
+ }
+ }
+
+ //commit the changes that we have done until now
+ rc = sr_commit(session);
+ if (SR_ERR_OK != rc) {
+ printf("Error by sr_commit: %s\n", sr_strerror(rc));
+ goto cleanup;
+ }
+
/* read startup config */
printf("\n\n ========== READING STARTUP CONFIG network-topology-simulator: ==========\n\n");
print_current_config(session, "network-topology-simulator");
goto cleanup;
}
- rc = notification_delay_period_changed(0);
+ rc = notification_delay_period_changed(NULL, 0);
if (rc != SR_ERR_OK) {
printf("Could not write the delay period to file!\n");
goto cleanup;
printf("\n\n ========== STARTUP CONFIG network-topology-simulator APPLIED AS RUNNING ==========\n\n");
+ rc = writeSkeletonStatusFile();
+ if (rc != SR_ERR_OK)
+ {
+ fprintf(stderr, "Could not initialize status JSON file: %s\n", sr_strerror(rc));
+ }
+
/* loop until ctrl-c is pressed / SIGINT is received */
signal(SIGINT, sigint_handler);
signal(SIGTERM, sigint_handler);
clean_current_docker_configuration();
rc = cleanup_curl();
rc = cleanup_curl_odl();
+ rc = cleanup_curl_k8s();
return rc;
}
static void clean_current_docker_configuration(void)
{
+ if (strcmp(getenv("K8S_DEPLOYMENT"), "true"))
+ {
+ return;
+ }
+
printf("Cleaning docker containers...\n");
if (device_list == NULL)
Code Review / sim / o1-interface.git / blobdiff