From a2cbca7a7b0880a1e7235a1d9b0f1b94adb8a54f Mon Sep 17 00:00:00 2001
From: "Costa Tsaousis (ktsaou)" <costa@tsaousis.gr>
Date: Sun, 16 Oct 2016 02:38:56 +0300
Subject: [PATCH] added option -N to allow fping output statistics in the
 format expected by netdata

---
 src/fping.c | 124 ++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 121 insertions(+), 3 deletions(-)

diff --git a/src/fping.c b/src/fping.c
index f185a2e7..8b4c3008 100644
--- a/src/fping.c
+++ b/src/fping.c
@@ -89,6 +89,7 @@ extern "C"
 
 #include <arpa/inet.h>
 #include <netdb.h>
+#include <ctype.h>
 
 /* RS6000 has sys/select.h */
 #ifdef HAVE_SYS_SELECT_H
@@ -295,7 +296,7 @@ struct timezone tz;
 /* switches */
 int generate_flag = 0;              /* flag for IP list generation */
 int verbose_flag, quiet_flag, stats_flag, unreachable_flag, alive_flag;
-int elapsed_flag, version_flag, count_flag, loop_flag;
+int elapsed_flag, version_flag, count_flag, loop_flag, netdata_flag;
 int per_recv_flag, report_all_rtts_flag, name_flag, addr_flag, backoff_flag;
 int multif_flag;
 int outage_flag = 0;
@@ -325,6 +326,7 @@ void usage( int );
 int wait_for_reply( long );
 void print_per_system_stats( void );
 void print_per_system_splits( void );
+void print_netdata( void );
 void print_global_stats( void );
 void main_loop();
 void finish();
@@ -377,7 +379,7 @@ int main( int argc, char **argv )
 
     /* get command line options */
 
-    while( ( c = getopt( argc, argv, "gedhlmnqusaAvDRz:t:H:i:p:f:r:c:b:C:Q:B:S:I:T:O:M:o" ) ) != EOF )
+    while( ( c = getopt( argc, argv, "gedhlmnNqusaAvDRz:t:H:i:p:f:r:c:b:C:Q:B:S:I:T:O:M:o" ) ) != EOF )
     {
         switch( c )
         {
@@ -459,6 +461,10 @@ int main( int argc, char **argv )
             multif_flag = 1;
             break;
 
+        case 'N':
+            netdata_flag = 1;
+            break;
+
         case 'd': 
         case 'n':
             name_flag = 1;
@@ -1098,7 +1104,11 @@ void main_loop()
         if( report_interval && ( loop_flag || count_flag ) &&
             ( timeval_diff ( &current_time, &last_report_time ) > report_interval ) )
         {
-            print_per_system_splits();
+            if(netdata_flag)
+                print_netdata();
+            else
+                print_per_system_splits();
+
             last_report_time = current_time;
         }
     }
@@ -1278,6 +1288,106 @@ void print_per_system_stats( void )
 } /* print_per_system_stats() */
 
 
+/************************************************************
+
+  Function: print_netdata
+
+*************************************************************
+
+  Inputs:  void (none)
+
+  Description:
+
+
+************************************************************/
+
+void print_netdata( void )
+{
+    static int sent_charts = 0;
+
+    int i, avg /*, outage_ms_i */;
+    HOST_ENTRY *h;
+    char *buf;
+    int bufsize;
+
+    bufsize = max_hostname_len + 1;
+    buf = ( char* )malloc( bufsize );
+    if( !buf )
+        crash_and_burn( "can't malloc print buf" );
+
+    memset( buf, 0, bufsize );
+
+    fflush( stdout );
+
+    for( i = 0; i < num_hosts; i++ )
+    {
+        h = table[i];
+
+        if(!sent_charts) {
+            printf("CHART fping_%s.packets '' 'FPing Packets for host %s' packets 'packets' fping.packets line 70020 %d\n", h->name, h->host, report_interval / 100000);
+            printf("DIMENSION xmt sent absolute 1 1\n");
+            printf("DIMENSION rcv received absolute 1 1\n");
+        }
+
+        printf("BEGIN fping_%s.packets\n", h->name);
+        printf("SET xmt = %d\n", h->num_sent_i);
+        printf("SET rcv = %d\n", h->num_recv_i);
+        printf("END\n");
+
+        if(!sent_charts) {
+            printf("CHART fping_%s.loss '' 'FPing Packet Loss for host %s' percentage loss fping.loss line 70010 %d\n", h->name, h->host, report_interval / 100000);
+            printf("DIMENSION pcent '' absolute 1 1\n");
+        }
+
+        printf("BEGIN fping_%s.loss\n", h->name);
+        if( h->num_recv_i <= h->num_sent_i )
+        {
+            printf("SET pcent = %d\n", h->num_sent_i > 0 ?
+                                                  ( ( h->num_sent_i - h->num_recv_i ) * 100 ) / h->num_sent_i : 0 );
+
+/*            if (outage_flag) {
+                // Time outage
+                outage_ms_i = (h->num_sent_i - h->num_recv_i) * perhost_interval/100;
+                fprintf( stderr, ", outage(ms) = %d", outage_ms_i );
+            }
+*/
+        }/* IF */
+        else
+        {
+            printf("SET pcent = %d\n", h->num_sent_i > 0 ?
+                                                  ( ( h->num_recv_i * 100 ) / h->num_sent_i ) : 0 );
+
+        }/* ELSE */
+        printf("END\n");
+
+        if(!sent_charts) {
+            printf("CHART fping_%s.latency '' 'FPing Latency for host %s' ms latency fping.latency line 70000 %d\n", h->name, h->host, report_interval / 100000);
+            printf("DIMENSION min minimum absolute 10 1000\n");
+            printf("DIMENSION max maximum absolute 10 1000\n");
+            printf("DIMENSION avg average absolute 10 1000\n");
+        }
+
+        printf("BEGIN fping_%s.latency\n", h->name);
+        if( h->num_recv_i )
+        {
+            avg = h->total_time_i / h->num_recv_i;
+            printf("SET min = %d\n", h->min_reply_i);
+            printf("SET avg = %d\n", avg);
+            printf("SET max = %d\n", h->max_reply_i);
+
+        }/* IF */
+        printf("END\n");
+
+        h->num_sent_i = h->num_recv_i = h->max_reply_i =
+        h->min_reply_i = h->total_time_i = 0;
+
+    }/* FOR */
+
+    sent_charts = 1;
+    free( buf );
+
+} /* print_per_system_splits() */
+
 /************************************************************
 
   Function: print_per_system_splits
@@ -1963,6 +2073,14 @@ void add_addr( char *name, char *host, struct sockaddr *ipaddr, socklen_t ipaddr
     p->running = 1;
     p->min_reply = 0;
 
+    if(netdata_flag) {
+        char *s = p->name;
+        while(*s) {
+            if(!isalnum(*s)) *s = '_';
+            s++;
+        }
+    }
+
     if( strlen( p->host ) > max_hostname_len )
         max_hostname_len = strlen( p->host );