Make ping.pl ping linknets.

1 files changed, 26 insertions, 0 deletions

diff --git a/clients/ping.pl b/clients/ping.pl
index c33c8cf..6968b4d 100755
--- a/clients/ping.pl
+++ b/clients/ping.pl
@@ -14,8 +14,10 @@ $dbh->{AutoCommit} = 0;
 $dbh->{RaiseError} = 1;
 
 my $q = $dbh->prepare("SELECT switch,ip FROM switches WHERE ip<>'127.0.0.1'");
+my $lq = $dbh->prepare("SELECT linknet,addr1,addr2 FROM linknets");
 
 while (1) {
+	# ping loopbacks
 	my $ping = Net::Oping->new;
 	$ping->timeout(0.2);
 
@@ -41,6 +43,30 @@ while (1) {
 	}
 	$dbh->pg_putcopyend();
 	$dbh->commit;
+
+	# ping linknets
+	$ping = Net::Oping->new;
+	$ping->timeout(0.2);
+
+	$lq->execute;
+	my @linknets = ();
+	while (my $ref = $lq->fetchrow_hashref) {
+		push @linknets, $ref;
+		$ping->host_add($ref->{'addr1'});
+		$ping->host_add($ref->{'addr2'});
+	}
+	$result = $ping->ping();
+	die $ping->get_error if (!defined($result));
+
+	$dbh->do('COPY linknet_ping (linknet, latency1_ms, latency2_ms) FROM STDIN');  # date is implicitly now.
+	for my $linknet (@linknets) {
+		my $id = $linknet->{'linknet'};
+		my $latency1 = $result->{$linknet->{'addr1'}} // '\N';
+		my $latency2 = $result->{$linknet->{'addr2'}} // '\N';
+		$dbh->pg_putcopydata("$id\t$latency1\t$latency2\n");
+	}
+	$dbh->pg_putcopyend();
+	$dbh->commit;
 	
 	sleep 1;
 }