1 files changed, 191 insertions, 0 deletions
diff --git a/vnfs/VES5.0/evel/evel-library/code/VESreporting_vAFX/afx_linkmon.c b/vnfs/VES5.0/evel/evel-library/code/VESreporting_vAFX/afx_linkmon.c
new file mode 100644
index 00000000..ac816b2f
--- /dev/null
+++ b/vnfs/VES5.0/evel/evel-library/code/VESreporting_vAFX/afx_linkmon.c
@@ -0,0 +1,191 @@
+ /*****************************************************************************//***
+ * Copyright(c) <2017>, AT&T Intellectual Property.  All other rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright notice,
+ *    this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright notice,
+ *    this list of conditions and the following disclaimer in the documentation
+ *    and/or other materials provided with the distribution.
+ * 3. All advertising materials mentioning features or use of this software
+ *    must display the following acknowledgement:  This product includes
+ *    software developed by the AT&T.
+ * 4. Neither the name of AT&T nor the names of its contributors may be used to
+ *    endorse or promote products derived from this software without specific
+ *    prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY AT&T INTELLECTUAL PROPERTY ''AS IS'' AND ANY
+ * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL AT&T INTELLECTUAL PROPERTY BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
+ * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ *****************************************************************************/
+
+#include <pthread.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <ctype.h>
+#include <string.h>
+#include <stdint.h>
+#include <unistd.h>
+#include <sys/stat.h>
+#include <sys/time.h>
+#include <sys/types.h>
+
+#include "evel.h"
+#include "afx_ves_reporter.h"
+
+
+/**************************************************************************//**
+ * Thread function to Monitor Ethernet links
+ * Checks status of afx inout and afx output service every service monitor
+ * interval. It reports fault event at startup and whenever status changes
+ *
+ * @param threadarg  Thread arguments for startup message
+ *
+ * @retvalue  int   Success 1 service running 0 service inactive
+ *****************************************************************************/
+void *LinkMonitorAfxThread(void *threadarg)
+{
+   int taskid, sum;
+   char *hello_msg;
+   struct thread_data *my_data;
+    FILE *fp;
+    char const* const fileName = AFX_INTERFACE_FILE;
+    char line[256];
+    char cmd[256];
+    char intf[256];
+    char descr[256];
+    char linkdata[256];
+    int linkcount = 0;
+    char *search = ":";
+    char *token;
+    char *pch;
+    time_t filetime = 0;
+    int newrun = 1;
+    int n_spaces = 0, i;
+    char ** res  = NULL;
+    char *pos;
+    int tlinkstat;
+    LINKSTAT intfstats[MAX_INTERFACES];
+    char vesevid[128];
+    int status = 1; /** VFS Status is Active **/
+
+
+   sleep(1);
+   my_data = (struct thread_data *) threadarg;
+   taskid = my_data->thread_id;
+   sum = my_data->sum;
+   hello_msg = my_data->message;
+   EVEL_INFO("AFX: Linkmon Thread %d: %s  Sum=%d\n", taskid, hello_msg, sum);
+
+while(1)
+{
+    /*Check if file is modified recently */
+    if( file_is_modified(fileName, &filetime) )  newrun = 1;
+
+    FILE* file = fopen(fileName, "r"); /* should check the result */
+    if( file == NULL ){
+      EVEL_ERROR("AFX: Linkmon Interface config file unavailable\n");
+      pthread_exit(NULL);
+    }
+
+    while ( file != NULL && fgets(line, sizeof(line), file)) {
+        /* note that fgets don't strip the terminating \n, checking its
+           presence would allow to handle lines longer that sizeof(line) */
+        sscanf(line,"%s %s",intf,descr);
+	//remove_spaces(line);
+        if ((pos=strchr(line, '\n')) != NULL)
+           *pos = '\0';
+        //printf("%s", line);
+        sprintf(cmd,"/sbin/ethtool %s\n", intf);
+        //printf("%s", cmd);
+        if( newrun ){
+                strcpy(intfstats[linkcount].linkname,intf);
+                strcpy(intfstats[linkcount].linkdescr,line);
+        }
+
+  /* Open the ethtool interface command for reading. */
+  fp = popen(cmd, "r");
+  if (fp == NULL) {
+    EVEL_DEBUG("AFX Linkmon: Failed to run command\n" );
+    //pthread_exit(NULL);
+    sleep(LINK_MONITOR_INTERVAL);
+    continue;
+  }
+
+  while( !feof(fp) ) {
+  /* Read the output a line at a time - output it. */
+  while (fgets(linkdata, sizeof(linkdata)-1, fp) != NULL) {
+    //EVEL_INFO("AFX: LinkMon :%s:",linkdata);
+    if ((pos=strchr(linkdata, '\n')) != NULL)
+           *pos = '\0';
+    if( strstr(linkdata,"Supported link modes"))
+    {
+          pch = strstr(linkdata, search);
+          while( pch != NULL &&( *pch == ':' || *pch == ' ')) pch++;
+          if(pch!=NULL){
+            //printf("Link mode %s\n",pch);
+            strcpy(intfstats[linkcount].linkmode,pch);
+          }
+    }
+    else if( strstr(linkdata,"Speed"))
+    {
+          token = strtok(linkdata, search);
+          token = strtok(NULL, search);
+          intfstats[linkcount].speedmbps = atoi(token);
+            //printf("Link speed %d\n",intfstats[linkcount].speedmbps);
+    }
+    else if( strstr(linkdata,"Link detected:"))
+    {
+	  /* parse link data for connectivity */
+          token = strtok(linkdata, search);
+          token = strtok(NULL, search);
+          while( *token == ' ') token++;
+          if( !strcmp(token,"yes")){
+            tlinkstat = 1;
+          } else {
+            tlinkstat = 0;
+          }
+          if( newrun || tlinkstat !=  intfstats[linkcount].linkstat)
+          {
+            EVEL_DEBUG("AFX LinkMon Status changed report fault\n");
+            if( tlinkstat == 1 ){
+               sprintf(vesevid,"Fault_vAfx_LinkState_%s",oam_intfaddr);
+               report_fault("Fault_vAfx_Link_Status",vesevid,EVEL_SEVERITY_NORMAL,"link",intfstats[linkcount].linkdescr,"link up trap_alarm","physical or logical connection to a remote router is up","remrouter","rname",NULL, status);
+            } else {
+               sprintf(vesevid,"Fault_vAfx_LinkState_%s",oam_intfaddr);
+               report_fault("Fault_vAfx_Link_Status",vesevid,EVEL_SEVERITY_CRITICAL,"link",intfstats[linkcount].linkdescr,"link down trap_alarm","physical or logical connection to a remote router is down","remrouter","rname",NULL, status);
+            }
+          }
+          intfstats[linkcount].linkstat = tlinkstat;
+    }
+    else if( strstr(linkdata,"Cannot get link status:"))
+    {
+         sprintf(vesevid,"Fault_vAfx_LinkState_%s",oam_intfaddr);
+         report_fault("Fault_vAfx_Link_Status",vesevid,EVEL_SEVERITY_CRITICAL,"link",intfstats[linkcount].linkname,"link down trap_alarm","physical or logical connection to a remote router is down","remrouter","rname",NULL, status);
+    }
+   }
+  }
+
+  /* close */
+  pclose(fp);
+  linkcount++;
+  }
+
+  newrun = linkcount = 0;
+  if(file)fclose(file);
+
+    sleep(LINK_MONITOR_INTERVAL);
+  }
+
+   pthread_exit(NULL);
+}
+