diff options
Diffstat (limited to 'vnfs/VES5.0/evel/evel-library/code/VESreporting_vAFX/afx_util.c')
| -rw-r--r-- | vnfs/VES5.0/evel/evel-library/code/VESreporting_vAFX/afx_util.c | 194 |
1 files changed, 194 insertions, 0 deletions
diff --git a/vnfs/VES5.0/evel/evel-library/code/VESreporting_vAFX/afx_util.c b/vnfs/VES5.0/evel/evel-library/code/VESreporting_vAFX/afx_util.c new file mode 100644 index 00000000..6820aaa6 --- /dev/null +++ b/vnfs/VES5.0/evel/evel-library/code/VESreporting_vAFX/afx_util.c @@ -0,0 +1,194 @@ +/*************************************************************************//** + * + * Main Agent which spins up monitoring threads + * + * Version 1.0: Gokul Singaraju gs244f Tech Mahindra Inc. + * + * Copyright © 2017 AT&T Intellectual Property. All rights reserved. + * + * 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 <unistd.h> +#include <string.h> /* for strncpy */ + +#include <sys/types.h> +#include <sys/socket.h> +#include <sys/ioctl.h> +#include <netinet/in.h> +#include <net/if.h> +#include <arpa/inet.h> + +#include "evel.h" +#include "afx_ves_reporter.h" + + +/**************************************************************************//** + * Utility function to Create and send fault events. + *****************************************************************************/ +void report_fault( char* evname, char *evid, EVEL_SEVERITIES sevty, char *categ, char *intf, char *trapname, char *descr, char *rem_router, char *routername, char *router_ip, int status ) +{ + EVENT_FAULT * fault = NULL; + EVEL_ERR_CODES evel_rc = EVEL_SUCCESS; + + /***************************************************************************/ + /* Fault */ + /***************************************************************************/ + if (status == 1) /** ACTIVE **/ + { + fault = evel_new_fault(evname, + evid, + trapname, + descr, + EVEL_PRIORITY_HIGH, + sevty, + EVEL_SOURCE_ROUTER, + EVEL_VF_STATUS_ACTIVE); + } + else + { + fault = evel_new_fault(evname, + evid, + trapname, + descr, + EVEL_PRIORITY_HIGH, + sevty, + EVEL_SOURCE_ROUTER, + EVEL_VF_STATUS_IDLE); + } + + if (fault != NULL) + { + evel_header_type_set((EVENT_HEADER *)fault, "applicationVnf"); + evel_nfcnamingcode_set((EVENT_HEADER *)fault, "AFX"); + evel_nfnamingcode_set((EVENT_HEADER *)fault, "AFX"); + + evel_fault_category_set(fault, categ); + if( intf != NULL) + evel_fault_interface_set(fault, intf ); + + if( strstr(evname,"Fault_vAfx_Link") != NULL || strstr(evname,"Fault_vAfx_bgp") != NULL) + { + evel_fault_addl_info_add(fault, "remote_router", rem_router); + evel_fault_addl_info_add(fault, "router_name", routername); + } + + if( strstr(evname,"Fault_vAfx_bgp") != NULL ) + evel_fault_addl_info_add(fault, "router_ip", router_ip); + + evel_rc = evel_post_event((EVENT_HEADER *)fault); + if (evel_rc != EVEL_SUCCESS) + { + EVEL_ERROR("Post failed %d (%s)", evel_rc, evel_error_string()); + } + } + else + { + EVEL_ERROR("New Fault failed"); + } + printf(" Generated Fault event\n"); +} + + +int file_is_modified(const char *path, time_t *oldMTime) { + struct stat file_stat; + int err = stat(path, &file_stat); + if (err != 0) { + perror(" [file_is_modified] stat"); + exit(1); + } + if( file_stat.st_mtime > *oldMTime) + { + *oldMTime = file_stat.st_mtime; + return 1; + } + else + return 0; +} + +void remove_spaces(char* source) +{ + char* i = source; + char* j = source; + while(*j != 0) + { + *i = *j++; + if(*i != ' ') + i++; + } + *i = 0; +} + + +char *get_oam_intfaddr() +{ + int fd; + int ret; + struct ifreq ifr; + char oamaddr[64]; + + fd = socket(AF_INET, SOCK_DGRAM, 0); + + /* I want to get an IPv4 IP address */ + ifr.ifr_addr.sa_family = AF_INET; + + /* I want IP address attached to "eth0" */ + strncpy(ifr.ifr_name, OAM_INTERFACE, IFNAMSIZ-1); + + ret = ioctl(fd, SIOCGIFADDR, &ifr); + + close(fd); + + if( ret == 0 ) + { + /* display result */ + sprintf(oamaddr,"%s", inet_ntoa(((struct sockaddr_in *)&ifr.ifr_addr)->sin_addr)); + //printf("Loopback address %s\n", oamaddr); + } + else + sprintf(oamaddr,"127.0.0.1"); + + return strdup(oamaddr); +} + + +char *escape_json(char *in) { + char out[2048]; + char *c; + char *o; + o = &out[0]; + for (c = in; *c != '\0'; c++) { + switch (*c) { + case '"': strcat(o,"\\\"");o+=2; break; + case '\\': strcat(o, "\\\\");o+=2; break; + case '\b': strcat(o, "\\b");o+=2; break; + case '\f': strcat(o, "\\f");o+=2; break; + case '\n': strcat(o, "\\n");o+=2; break; + case '\r': strcat(o, "\\r");o+=2; break; + case '\t': strcat(o, "\\t");o+=2; break; + default: + if ('\x00' <= *c && *c <= '\x1f') { + char tmp[8]; + strcat(o, "\\u"); + sprintf(tmp,"%04X",(int)*c); + strcat(o,tmp); o+=6; + } else { + *o = *c; o++; + } + } + } + *o = '\0'; + //free(in); + return strdup(out); +} + |