#! /usr/bin/perl
use CGI;
use DBI;
use Time::HiRes;
use POSIX ":sys_wait_h";
use strict;
use warnings;
use lib '../../include';
use nms;
use File::Basename;
my $cgi = CGI->new;
my $cwd = dirname($0);
my $switch = $cgi->param('id');
my $width = $cgi->param('width');
my $height = $cgi->param('height');
my @pids = ();
my $resthtml = "";
$width = 500 unless (defined($width));
$height = 250 unless (defined($height));
require "$cwd/mygraph.pl";
my $start = [Time::HiRes::gettimeofday];
my $dbh = nms::db_connect();
sub filename($$$$) {
my ($switch, $last_port, $width, $height) = @_;
$last_port =~ y,/,_,;
return "$switch-$last_port-$width-$height.png";
}
# Fetch the name
my $ref = $dbh->selectrow_hashref('SELECT sysname,ip FROM switches WHERE switch=?', undef, $switch);
print $cgi->header(-type=>'text/html; charset=utf-8');
print <<"EOF";
snmp
Switch $switch ($ref->{'sysname'} - $ref->{'ip'})
EOF
my $q = $dbh->prepare('select ifname,\'Port \' || ifname as description,extract(epoch from time) as time,ifhcinoctets,ifhcoutoctets from switches natural join polls where time between now() - \'1 day\'::interval and now() and switch=? order by switch,ifname,time;') or die $dbh->errstr;
$q->execute($switch) or die $dbh->errstr;
my (@totx, @toty1, @toty2) = ();
my (@x, @y1, @y2) = ();
my $last_port;
my $portname = "";
my $min_x = time;
my $max_x = time - 86400;
my ($min_y, $max_y, $prev_time, $prev_in, $prev_out);
my ($if,$of,$ifv,$ofv);
my $idx;
my ($min_ty,$max_ty) = (0, 10_000_000/8);
$prev_time = -1;
my $last_totx;
# Buffer all the rows so we can fancy-sort them
my @rows;
while (my $ref = $q->fetchrow_hashref()) {
push @rows, $ref;
}
sub cmp_ports {
my @a = split(/(\d+)/, $_[0]);
my @b = split(/(\d+)/, $_[1]);
for (my $i = 0; $i < scalar @a; ++$i) {
last if $i >= scalar @b;
my $a = $a[$i];
my $b = $b[$i];
if ($a =~ /^\d+$/ && $a =~ /^\d+$/) {
return $a <=> $b if ($a != $b);
} else {
return $a cmp $b if ($a ne $b);
}
}
# None of the N first parts differed, this means the shortest one is first
return scalar @a <=> scalar @b;
}
sort { cmp_ports($a->{'ifname'}, $b->{'ifname'}) } @rows;
foreach my $ref (@rows) {
my $time = $ref->{'time'};
my $in = $ref->{'ifhcinoctets'};
my $out = $ref->{'ifhcoutoctets'};
next if ($time == $prev_time);
if ($ref->{'ifname'} ne $last_port) {
if (defined $last_port) {
my $filename = filename($switch, $last_port, $width, $height);
# reap children
waitpid(-1, WNOHANG);
my $pid = fork();
if ($pid == 0) {
# write out the graph
my $graph = makegraph($width, $height, $min_x, $max_x, $min_y, $max_y, 5);
plotseries($graph, \@x, \@y1, 255, 0, 0, $min_x, $max_y);
plotseries($graph, \@x, \@y2, 0, 0, 255, $min_x, $max_y);
open GRAPH, ">$cwd/img/$filename"
or die "$cwd/img/$filename: $!";
print GRAPH $graph->png;
close GRAPH;
exit;
}
push @pids, $pid;
$resthtml .= "$portname
\n";
$resthtml .= "
![](\"img/$filename\")
$portname
\n";
$resthtml .= "
Total
\n";
print "
Page and all graphs generated in %.2f seconds.
\n", $elapsed;
print "\n\n";