#!/usr/bin/perl -w strict

use strict;
use DBI; 

my $dbh = DBI->connect('DBI:mysql:noc', 'root', '') or die "Couldn't open database: $DBI::errstr; stopped"; 

while (1) { 
my $sth = $dbh->prepare("select assetid,ip,snmpname from assets") or die "Couldn't prepare statement: $DBI::errstr; stopped"; 
$sth->execute() or die "Couldnt execute statement: $DBI::errsrt; stopped"; 
  my @a;
  while ( my ($aid, $aip, $asnmp) = $sth->fetchrow_array() ) { 
    my @a = ($aid, $aip, $asnmp);
    forkin($aid, $aip, $asnmp);
  } 
  sleep(5); 
  print "repeating\n"; 
} 

sub forkin {
  my $aid = shift;
  my $aip = shift;
  my $asnmp = shift;
  my @ret;
  my $pid=fork();
  die "Cannot fork: $!" if (! defined $pid);
  if (! $pid) {
    my @ret = ping_remote($aip,$asnmp);
    commitDB($aip,$aid,$asnmp,@ret);
    exit 0;
  }
  waitpid($pid,0);
}

sub commitDB { 
  my $ip = shift; 
  my $assetid = shift; 
  my $snmpname = shift; 
  my @ret = @_;
    if (@ret) {
      my $sth2 = $dbh->prepare("insert into history set assetid='$assetid', trafficload='$ret[1]'") or die "Couldn't prepare statement: $DBI::errstr; stopped"; 
      $sth2->execute() or die "Couldnt execute statement: $DBI::errsrt; stopped"; 
      $sth2 = $dbh->prepare("update assets set firmware='$ret[2]', uptime='$ret[1]', status='u', trafficload='$ret[0]' where assetid='$assetid'") or die "Couldn't prepare statement: $DBI::
errstr; stopped"; 
      $sth2->execute() or die "Couldnt execute statement: $DBI::errsrt; stopped"; 
    } else { 
      my $sth2 = $dbh->prepare("update assets set status='d' where assetid='$assetid'") or die "Couldn't prepare statement: $DBI::errstr; stopped"; 
      $sth2->execute() or die "Couldnt execute statement: $DBI::errsrt; stopped"; 
    } 
} 
 
sub ping_remote { 
  my $ip = shift; 
  my $snmpname = shift; 
  my @ret = undef; 
  my @p = split(/(,)/,`ping -c 1 $ip | grep "0% loss"`);
  if ($p[4] eq " 0% loss") {
    my $a=`/etc/poller/snmptraffic.php "$ip" "$snmpname"`; 
    my $u=`/etc/poller/snmpuptime.php "$ip" "$snmpname"`; 
    my $f=`/etc/poller/snmpfirmware.php "$ip" "$snmpname"`; 
    @ret = ($a,$u,$f);
  } 
  return @ret; 
}