+++ /dev/null
-/*************************************************************************
-*
-* Copyright 2019 highstreet technologies GmbH and others
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-***************************************************************************/
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <signal.h>
-#include <inttypes.h>
-#include <time.h>
-#include <math.h>
-#include <sys/time.h>
-#include <cjson/cJSON.h>
-#include <string.h>
-
-#include "sysrepo.h"
-#include "sysrepo/values.h"
-
-#include "utils.h"
-
-#define LINE_BUFSIZE 128
-#define ORAN_FAULT_ALARMS_NUMBER 10
-#define AFFECTED_OBJECTS_MAX_NUMBER 100
-
-volatile int exit_application = 0;
-
-static counterAlarms netconf_alarm_counter = {
- .normal = 0,
- .warning = 0,
- .minor = 0,
- .major = 0,
- .critical = 0
-};
-static counterAlarms ves_alarm_counter= {
- .normal = 0,
- .warning = 0,
- .minor = 0,
- .major = 0,
- .critical = 0
-};
-
-struct faultAlarms
-{
- int faultId;
- char* faultSource;
- int cleared[10];
- char* faultSeverity;
- char* faultText;
- char* affectedObjects[AFFECTED_OBJECTS_MAX_NUMBER];
-};
-struct faultAlarms oran_fault_alarms[ORAN_FAULT_ALARMS_NUMBER] = {
- {.faultId = 1, .faultSource = "jknsdfnui", .affectedObjects = {"akddconoj", "asodmnjvf", "roiemfkmods"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "MAJOR", .faultText = "sdnjosopnojnsd"},
- {.faultId = 2, .faultSource = "onascokjnasc", .affectedObjects = {"sdouvncsjdfv13", "asjdn13ejlncd4"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "WARNING", .faultText = "4pionfcsofn42on"},
- {.faultId = 3, .faultSource = "asonxpkn", .affectedObjects = {"0j4fiwef320fd", "sdlvkmsdv-9023"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "CRITICAL", .faultText = "sdjnonj32onjsa23"},
- {.faultId = 4, .faultSource = "asnjcpkd", .affectedObjects = {"0j4fiwef320fd", "sdlvkmsdv-9023", "laksmdklmdas21"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "MINOR", .faultText = "asdjln12osa453"},
- {.faultId = 5, .faultSource = "dskmfl", .affectedObjects = {"sdkm31wdlk"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "MAJOR", .faultText = "dknovrf34ekl"},
- {.faultId = 6, .faultSource = "dsllkje232kl", .affectedObjects = {"sFKOM24KLMerw"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "MAJOR", .faultText = "frpkm24k lsd kmewfpm"},
- {.faultId = 7, .faultSource = "fvkdlsfjnwej23kloe", .affectedObjects = {"fvkm24km", "sdfk23d", "kmdfkmo32", "wekl2332"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "WARNING", .faultText = "dsm 2d 32j sdfmr32"},
- {.faultId = 8, .faultSource = "dkom32", .affectedObjects = {"kmsdfkpm23ds", "sdmkp32"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "CRITICAL", .faultText = "dsonj32 don32 mdson32pk654"},
- {.faultId = 9, .faultSource = "weflm3", .affectedObjects = {"klklm32kl3", "dsfln234poewj23-", "spmd32k"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "MINOR", .faultText = "dsflknjwej32"},
- {.faultId = 10, .faultSource = "fweiunvfrem32", .affectedObjects = {"sfkm23klsdf2343"}, .cleared = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1}, .faultSeverity = "MAJOR", .faultText = "dfskjnl4j dsfknl2 fodn54 65k"}
-};
-
-static CURL *curl;
-
-static int _init_curl()
-{
- curl = curl_easy_init();
-
- if (curl == NULL) {
- printf("cURL initialization error! Aborting call!\n");
- return SR_ERR_OPERATION_FAILED;
- }
-
- return SR_ERR_OK;
-}
-
-static int cleanup_curl()
-{
- if (curl != NULL)
- {
- curl_easy_cleanup(curl);
- }
-
- return SR_ERR_OK;
-}
-
-static int send_fault_ves_message(char *alarm_condition, char *alarm_object, char *severity, char *date_time, char *specific_problem, int port)
-{
- CURLcode res;
- static int sequence_id = 0;
- int netconf_port_base = 0;
-
- prepare_ves_message_curl(curl);
-
- cJSON *postDataJson = cJSON_CreateObject();
-
- cJSON *event = cJSON_CreateObject();
- if (event == NULL)
- {
- printf("Could not create JSON object: event\n");
- return SR_ERR_OPERATION_FAILED;
- }
- cJSON_AddItemToObject(postDataJson, "event", event);
-
- char *hostname = getenv("HOSTNAME");
-
- netconf_port_base = getIntFromString(getenv("NETCONF_BASE"), 1);
- netconf_port_base += port;
-
- char source_name[100];
- sprintf(source_name, "%s_%d", hostname, netconf_port_base);
-
- cJSON *commonEventHeader = vesCreateCommonEventHeader("fault", "O_RAN_COMPONENT_Alarms", source_name, sequence_id++);
- if (commonEventHeader == NULL)
- {
- printf("Could not create JSON object: commonEventHeader\n");
- return SR_ERR_OPERATION_FAILED;
- }
- cJSON_AddItemToObject(event, "commonEventHeader", commonEventHeader);
-
- cJSON *faultFields = vesCreateFaultFields(alarm_condition, alarm_object, severity, date_time, specific_problem);
- if (faultFields == NULL)
- {
- printf("Could not create JSON object: faultFields\n");
- if (postDataJson != NULL)
- {
- cJSON_Delete(postDataJson);
- }
- return SR_ERR_OPERATION_FAILED;
- }
- cJSON_AddItemToObject(event, "faultFields", faultFields);
-
- char *post_data_string = NULL;
-
- post_data_string = cJSON_PrintUnformatted(postDataJson);
-
- printf("Post data JSON:\n%s\n", post_data_string);
-
- if (postDataJson != NULL)
- {
- cJSON_Delete(postDataJson);
- }
-
- curl_easy_setopt(curl, CURLOPT_POSTFIELDS, post_data_string);
-
- res = curl_easy_perform(curl);
-
- if (res != CURLE_OK)
- {
- printf("Failed to send cURL...\n");
- return SR_ERR_OPERATION_FAILED;
- }
-
- return SR_ERR_OK;
-}
-
-static int send_dummy_notif(sr_session_ctx_t *sess)
-{
- int rc;
-
- char dateAndTime[256];
- time_t t = time(NULL);
- struct tm tm = *localtime(&t);
- struct timeval tv;
- int millisec;
-
- gettimeofday(&tv, NULL);
- millisec = lrint(tv.tv_usec/1000.0); // Round to nearest millisec
- if (millisec>=1000)
- { // Allow for rounding up to nearest second
- millisec -=1000;
- tv.tv_sec++;
- millisec /= 100;
- }
- sprintf(dateAndTime, "%04d-%02d-%02dT%02d:%02d:%02d.%01dZ",
- tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday,
- tm.tm_hour, tm.tm_min, tm.tm_sec, millisec/100);
-
- int ran = (int) random_at_most(ORAN_FAULT_ALARMS_NUMBER - 1);
-
- //TODO we hardcode here the number of ports for each device, 10
- int random_port = (int) random_at_most(9);
-
- if (oran_fault_alarms[ran].cleared[random_port] == 1)
- {
- oran_fault_alarms[ran].cleared[random_port] = 0;
- }
- else
- {
- oran_fault_alarms[ran].cleared[random_port] = 1;
- }
-
- sr_val_t *vnotif;
- size_t current_num_of_values= 0;
-
- CREATE_NEW_VALUE(rc, vnotif, current_num_of_values);
-
- sr_val_build_xpath(&vnotif[current_num_of_values - 1], "%s", "/o-ran-fm:alarm-notif/fault-id");
- vnotif[current_num_of_values - 1].type = SR_UINT16_T;
- vnotif[current_num_of_values - 1].data.uint16_val = oran_fault_alarms[ran].faultId;
-
- CREATE_NEW_VALUE(rc, vnotif, current_num_of_values);
-
- sr_val_build_xpath(&vnotif[current_num_of_values - 1], "%s", "/o-ran-fm:alarm-notif/fault-source");
- sr_val_set_str_data(&vnotif[current_num_of_values - 1], SR_STRING_T, oran_fault_alarms[ran].faultSource);
-
- CREATE_NEW_VALUE(rc, vnotif, current_num_of_values);
-
- sr_val_build_xpath(&vnotif[current_num_of_values - 1], "%s", "/o-ran-fm:alarm-notif/fault-severity");
- sr_val_set_str_data(&vnotif[current_num_of_values - 1], SR_ENUM_T, oran_fault_alarms[ran].faultSeverity);
-
- CREATE_NEW_VALUE(rc, vnotif, current_num_of_values);
-
- sr_val_build_xpath(&vnotif[current_num_of_values - 1], "%s", "/o-ran-fm:alarm-notif/is-cleared");
- vnotif[current_num_of_values - 1].type = SR_BOOL_T;
- vnotif[current_num_of_values - 1].data.bool_val = oran_fault_alarms[ran].cleared[random_port];
-
- CREATE_NEW_VALUE(rc, vnotif, current_num_of_values);
-
- sr_val_build_xpath(&vnotif[current_num_of_values - 1], "%s", "/o-ran-fm:alarm-notif/fault-text");
- sr_val_set_str_data(&vnotif[current_num_of_values - 1], SR_STRING_T, oran_fault_alarms[ran].faultText);
-
- CREATE_NEW_VALUE(rc, vnotif, current_num_of_values);
-
- sr_val_build_xpath(&vnotif[current_num_of_values - 1], "%s", "/o-ran-fm:alarm-notif/event-time");
- sr_val_build_str_data(&vnotif[current_num_of_values - 1], SR_STRING_T, "%s", dateAndTime);
-
- for (int i = 0; i < AFFECTED_OBJECTS_MAX_NUMBER; ++i)
- {
- char path[400];
- if (oran_fault_alarms[ran].affectedObjects[i] == NULL)
- {
- break;
- }
-
- sprintf(path, "/o-ran-fm:alarm-notif/affected-objects[name='%s']", oran_fault_alarms[ran].affectedObjects[i]);
-
- CREATE_NEW_VALUE(rc, vnotif, current_num_of_values);
-
- sr_val_build_xpath(&vnotif[current_num_of_values - 1], "%s", path);
- vnotif[current_num_of_values - 1].type = SR_LIST_T;
- }
-
- int isNetconfAvailable = getNetconfAvailableFromConfigJson();
- int isVesAvailable = getVesAvailableFromConfigJson();
-
- if (isNetconfAvailable)
- {
- rc = sr_event_notif_send(sess, "/o-ran-fm:alarm-notif", vnotif, current_num_of_values, SR_EV_NOTIF_DEFAULT);
- if (rc != SR_ERR_OK)
- {
- printf("Failed to send notification send_dummy_notif\n");
- return SR_ERR_OPERATION_FAILED;
- }
- if (oran_fault_alarms[ran].cleared[random_port])
- {
- netconf_alarm_counter.normal++;
- }
- else
- {
- if (strcmp(oran_fault_alarms[ran].faultSeverity, "WARNING") == 0)
- {
- netconf_alarm_counter.warning++;
- }
- else if (strcmp(oran_fault_alarms[ran].faultSeverity, "MINOR") == 0)
- {
- netconf_alarm_counter.minor++;
- }
- else if (strcmp(oran_fault_alarms[ran].faultSeverity, "MAJOR") == 0)
- {
- netconf_alarm_counter.major++;
- }
- else if (strcmp(oran_fault_alarms[ran].faultSeverity, "CRITICAL") == 0)
- {
- netconf_alarm_counter.critical++;
- }
- }
-
- printf("Successfully sent notification with timestamp=\"%s\"\n", dateAndTime);
- }
- if (isVesAvailable)
- {
- char faultId[10];
- sprintf(faultId, "%d", oran_fault_alarms[ran].faultId);
- rc = send_fault_ves_message(faultId, oran_fault_alarms[ran].faultSource,
- (oran_fault_alarms[ran].cleared[random_port]) ? "NORMAL" : oran_fault_alarms[ran].faultSeverity, dateAndTime, oran_fault_alarms[ran].faultText, random_port);
- if (rc != SR_ERR_OK)
- {
- printf("Could not send Fault VES message\n");
- }
- if (oran_fault_alarms[ran].cleared[random_port])
- {
- ves_alarm_counter.normal++;
- }
- else
- {
- if (strcmp(oran_fault_alarms[ran].faultSeverity, "WARNING") == 0)
- {
- ves_alarm_counter.warning++;
- }
- else if (strcmp(oran_fault_alarms[ran].faultSeverity, "MINOR") == 0)
- {
- ves_alarm_counter.minor++;
- }
- else if (strcmp(oran_fault_alarms[ran].faultSeverity, "MAJOR") == 0)
- {
- ves_alarm_counter.major++;
- }
- else if (strcmp(oran_fault_alarms[ran].faultSeverity, "CRITICAL") == 0)
- {
- ves_alarm_counter.critical++;
- }
- }
- }
- printf("Writing counters to file...\n");
- rc = writeStatusNotificationCounters(ves_alarm_counter, netconf_alarm_counter);
- if (rc != SR_ERR_OK)
- {
- printf("Could not write status to file...\n");
- }
-
- sr_free_values(vnotif, current_num_of_values);
-
- return SR_ERR_OK;
-}
-
-static void
-sigint_handler(int signum)
-{
- exit_application = 1;
-}
-
-int
-main(int argc, char **argv)
-{
- sr_conn_ctx_t *connection = NULL;
- sr_session_ctx_t *session = NULL;
- sr_subscription_ctx_t *subscription = NULL;
- int rc = SR_ERR_OK;
-
- setbuf(stdout, NULL);
-
- /* connect to sysrepo */
- rc = sr_connect("oran_notifications", SR_CONN_DEFAULT, &connection);
- if (SR_ERR_OK != rc) {
- fprintf(stderr, "Error by sr_connect: %s\n", sr_strerror(rc));
- goto cleanup;
- }
-
- /* start session */
- rc = sr_session_start(connection, SR_DS_RUNNING, SR_SESS_DEFAULT, &session);
- if (SR_ERR_OK != rc) {
- fprintf(stderr, "Error by sr_session_start: %s\n", sr_strerror(rc));
- goto cleanup;
- }
-
- rc = _init_curl();
- if (rc != SR_ERR_OK)
- {
- fprintf(stderr, "Could not initialize cURL: %s\n", sr_strerror(rc));
- goto cleanup;
- }
-
- /* loop until ctrl-c is pressed / SIGINT is received */
- signal(SIGINT, sigint_handler);
- signal(SIGPIPE, SIG_IGN);
-
- while (!exit_application) {
- int notif_delay[100], count = 0;
-
- rc = getFaultNotificationDelayPeriodFromConfigJson(notif_delay, &count);
- if (rc != SR_ERR_OK)
- {
- printf("Could not get fault notification delay period.");
- sleep(1);
- continue;
- }
-
- if (count > 1)
- {
- for (int i = 0; i < count; ++i)
- {
- sleep(notif_delay[i]);
- send_dummy_notif(session);
- }
- }
- else if (count == 1)
- {
- if (notif_delay[0] > 0)
- {
- sleep(notif_delay[0]);
- send_dummy_notif(session);
- }
- else
- {
- sleep(1);
- // reset the counters when the notifciation delay period is switched back to 0
- netconf_alarm_counter.normal = netconf_alarm_counter.warning = \
- netconf_alarm_counter.minor = netconf_alarm_counter.major = \
- netconf_alarm_counter.critical = 0;
-
- ves_alarm_counter.normal = ves_alarm_counter.warning = \
- ves_alarm_counter.minor = ves_alarm_counter.major = \
- ves_alarm_counter.critical = 0;
- }
- }
-
- }
-
- printf("Application exit requested, exiting.\n");
-
-cleanup:
- if (NULL != subscription) {
- sr_unsubscribe(session, subscription);
- }
- if (NULL != session) {
- sr_session_stop(session);
- }
- if (NULL != connection) {
- sr_disconnect(connection);
- }
- cleanup_curl();
- printf("Error encountered. Exiting...");
- return rc;
-}
-
-
-
-
Code Review / sim / o1-interface.git / blobdiff