Add some scripts to ping all the switches, and display the ping status on a map.

author: Steinar H. Gunderson <sgunderson@bigfoot.com> 2014-04-07 23:08:30 +0200
committer: Steinar H. Gunderson <sgunderson@bigfoot.com> 2014-04-07 23:08:30 +0200
commit: 7685165ad046cbe73e5e545fc66cd5f5b24aedcf (patch)
tree: a5724eb41e4fbe846ba37a7887da2cbb5d1f880c
parent: b83b26425343dae0e587c759574e6193822ce7fa (diff)
5 files changed, 200 insertions, 0 deletions
diff --git a/clients/ping.pl b/clients/ping.pl
new file mode 100755
index 0000000..b0eb57d
--- /dev/null
+++ b/clients/ping.pl
@@ -0,0 +1,48 @@
+#! /usr/bin/perl
+use DBI;
+use POSIX;
+use Time::HiRes;
+use Net::Oping;
+use Data::Dumper;
+use strict;
+use warnings;
+
+use lib '../include';
+use nms;
+
+my $dbh = nms::db_connect();
+$dbh->{AutoCommit} = 0;
+$dbh->{RaiseError} = 1;
+
+my $q = $dbh->prepare("SELECT switch,ip FROM switches WHERE ip<>'127.0.0.1'");
+
+while (1) {
+	my $ping = Net::Oping->new;
+	$ping->timeout(0.2);
+
+	$q->execute;
+	my %ip_to_switch = ();
+	while (my $ref = $q->fetchrow_hashref) {
+		my $switch = $ref->{'switch'};
+		my $ip = $ref->{'ip'};
+		$ping->host_add($ip);
+		$ip_to_switch{$ip} = $switch;
+	}
+	my $result = $ping->ping();
+	die $ping->get_error if (!defined($result));
+
+	$dbh->do('COPY ping (switch, latency_ms) FROM STDIN');  # date is implicitly now.
+	while (my ($ip, $latency) = each %$result) {
+		my $switch = $ip_to_switch{$ip};
+		if (!defined($latency)) {
+			$dbh->pg_putcopydata("$switch\t\\N\n");
+		} else {
+			$dbh->pg_putcopydata("$switch\t$latency\n");
+		}
+	}
+	$dbh->pg_putcopyend();
+	$dbh->commit;
+	
+	sleep 1;
+}
+
diff --git a/sql/nms.sql b/sql/nms.sql
index acadcc5..3b2c029 100644
--- a/sql/nms.sql
+++ b/sql/nms.sql
@@ -606,6 +606,10 @@ CREATE TABLE uplinks (
 
 ALTER TABLE public.uplinks OWNER TO nms;
 
+create table ping ( switch integer not null, updated timestamptz not null default current_timestamp, latency_ms float );
+create index updated_index on ping ( updated );
+alter table public.ping owner to nms;
+
 --
 -- Data for Name: ap_poll; Type: TABLE DATA; Schema: public; Owner: nms
 --
diff --git a/web/nms.gathering.org/ping-json.pl b/web/nms.gathering.org/ping-json.pl
new file mode 100755
index 0000000..b304de6
--- /dev/null
+++ b/web/nms.gathering.org/ping-json.pl
@@ -0,0 +1,20 @@
+#! /usr/bin/perl
+use CGI;
+use GD;
+use DBI;
+use JSON::XS;
+use lib '../../include';
+use nms;
+my $cgi = CGI->new;
+
+my $dbh = nms::db_connect();
+
+my $q = $dbh->prepare("SELECT DISTINCT ON (switch) switch, latency_ms FROM ping WHERE updated >= NOW() - INTERVAL '15 secs' ORDER BY switch, updated DESC;");
+$q->execute();
+
+my %json = ();
+while (my $ref = $q->fetchrow_hashref()) {
+	$json{$ref->{'switch'}} = $ref->{'latency_ms'};
+}
+print $cgi->header(-type=>'text/json; charset=utf-8');
+print JSON::XS::encode_json(\%json);
diff --git a/web/nms.gathering.org/ping.html b/web/nms.gathering.org/ping.html
new file mode 100644
index 0000000..b1d9b0f
--- /dev/null
+++ b/web/nms.gathering.org/ping.html
@@ -0,0 +1,100 @@
+<html>
+  <body>
+    <p style="border: 1px solid black;" id="playground"><img src="bg07.png" alt="" id="map" style="border: 1px solid black"; /></p>
+    <script type="text/javascript">
+    <!--
+var switches = [];
+var last_dataset = [];
+get_switches();
+get_ping();
+
+function json_request(url, func, repeat_ms) {
+	var request = new XMLHttpRequest();
+	request.open('GET', url, true);
+
+	request.onload = function() {
+		if (this.status >= 200 && this.status < 400) {
+			func(JSON.parse(this.response));
+		} else if (this.status != 410) {
+			json_request(url, func, repeat_ms);
+		}
+	};
+	request.onerror = function() {
+		json_request(url, func, repeat_ms);
+	};
+	request.send();
+}
+
+function get_switches() {
+	json_request('/switches-json.pl', draw_switches, 1000);
+}
+
+function get_ping() {
+	json_request('/ping-json.pl', update_ping, 1000);
+}
+
+function draw_switches(json) {
+	for (var switchnum in switches) {
+		document.body.removeChild(switches[switchnum]);
+	}
+	switches = [];
+	
+	for (var switchnum in json) {
+		var s = json[switchnum];
+		create_switch(switchnum,
+	  	              s['sysname'],
+		              parseInt(s['x']),
+			      parseInt(s['y']),
+		              parseInt(s['width']),
+		              parseInt(s['height']));
+	}
+	setTimeout(get_switches, 60000);
+	really_update_ping(last_dataset);
+}
+
+function update_ping(json) {
+	last_dataset = json;
+	really_update_ping(json);
+	setTimeout(get_ping, 1000);
+}
+
+function really_update_ping(json) {
+	for (var switchnum in switches) {
+		if (json[switchnum] === null || json[switchnum] === undefined) {
+			switches[switchnum].style.backgroundColor = '#0000ff';
+		} else {
+			// 10ms is max
+			var l = json[switchnum] / 10.0;
+			if (l >= 1.0) { l = 1.0; }
+			l = Math.pow(l, 1.0/2.2);
+			l = Math.round(l * 255.0);
+
+			switches[switchnum].style.backgroundColor = 'rgb(' + l + ', 255, 0)';
+		}
+	}
+}
+
+function create_switch(switchnum, sysname, x, y, width, height) {
+	var s = document.createElement("div");
+	var map = document.getElementById('map');
+	var top_offset = map.getBoundingClientRect().top;
+	var left_offset = map.getBoundingClientRect().left;
+
+	s.style.position = 'absolute';
+	s.style.left = (left_offset + x) + 'px';
+	s.style.top = (top_offset + y) + 'px';
+	s.style.width = width + 'px';
+	s.style.height = height + 'px';
+	s.style.backgroundColor = '#0000ff';
+	s.style.border = '1px solid black';
+	switches[switchnum] = s;
+
+	var text = document.createTextNode(sysname);
+	s.appendChild(text);
+
+	document.body.appendChild(s);
+}
+    -->
+    </script>
+  </body>
+</html>
diff --git a/web/nms.gathering.org/switches-json.pl b/web/nms.gathering.org/switches-json.pl
new file mode 100755
index 0000000..1dccfe2
--- /dev/null
+++ b/web/nms.gathering.org/switches-json.pl
@@ -0,0 +1,28 @@
+#! /usr/bin/perl
+use CGI;
+use GD;
+use DBI;
+use JSON::XS;
+use lib '../../include';
+use nms;
+my $cgi = CGI->new;
+
+my $dbh = nms::db_connect();
+
+my $q = $dbh->prepare('select switch,sysname,placement from switches natural join placements');
+$q->execute();
+
+my %json = ();
+while (my $ref = $q->fetchrow_hashref()) {
+	$ref->{'placement'} =~ /\((\d+),(\d+)\),\((\d+),(\d+)\)/;
+	my ($x1, $y1, $x2, $y2) = ($1, $2, $3, $4);
+	$json{$ref->{'switch'}} = {
+		sysname => $ref->{'sysname'},
+		x => $x2,
+		y => $y1,
+		width => $x1 - $x2,
+		height => $y1 - $y2
+	};
+}
+print $cgi->header(-type=>'text/json; charset=utf-8');
+print JSON::XS::encode_json(\%json);
author	Steinar H. Gunderson <sgunderson@bigfoot.com>	2014-04-07 23:08:30 +0200
committer	Steinar H. Gunderson <sgunderson@bigfoot.com>	2014-04-07 23:08:30 +0200
commit	7685165ad046cbe73e5e545fc66cd5f5b24aedcf (patch)
tree	a5724eb41e4fbe846ba37a7887da2cbb5d1f880c
parent	b83b26425343dae0e587c759574e6193822ce7fa (diff)