// Get variables from url
if (isset($_GET['sensor_name']) && $_GET['sensor_name'] != "none") {
$sensor_name = $_GET['sensor_name'];
} else {
$sensor_name = 'unset';
}
if (isset($_GET['interval']) && $_GET['interval'] != "none")
$interval = $_GET['interval'];
if (isset($_GET['timestamp']) && $_GET['timestamp'] != "none")
$timestamp = $_GET['timestamp'];
if (isset($_GET['subnet']) && $_GET['subnet'] != "none")
$subnet = $_GET['subnet'];
if (isset($_GET['limit']) && $_GET['limit'] != "none")
$limit = $_GET['limit'];
$tmp = explode(':',$db_connect_string);
if ($tmp[0] == 'sqlite' && ! file_exists($tmp[1])) {
die("Data not available. Please wait a couple of minutes, then reload the page.");
}
$db = ConnectDb();
?>
// Set defaults
if (!isset($interval))
$interval = DFLT_INTERVAL;
if (!isset($timestamp))
$timestamp = time() - $interval + (0.05*$interval);
if (!isset($limit))
$limit = 20;
// Validation
if (!isset($sensor_name))
exit(0);
// Print Title
if (isset($limit))
echo "
Top $limit
";
else
echo "
All Records
";
// Sqlize the incomming variables
if (isset($subnet)) {
$sql_subnet = prepare_sql_subnet($subnet);
}
// Sql Statement
$sql = "select tx.ip, rx.scale as rxscale, tx.scale as txscale, tx.total+rx.total as total, tx.total as sent,
rx.total as received, tx.tcp+rx.tcp as tcp, tx.udp+rx.udp as udp,
tx.icmp+rx.icmp as icmp, tx.http+rx.http as http,
tx.p2p+rx.p2p as p2p, tx.ftp+rx.ftp as ftp
from
(SELECT ip, max(total/sample_duration)*8 as scale, sum(total) as total, sum(tcp) as tcp, sum(udp) as udp, sum(icmp) as icmp,
sum(http) as http, sum(p2p) as p2p, sum(ftp) as ftp
from sensors, bd_tx_log
where sensor_name = '$sensor_name'
and sensors.sensor_id = bd_tx_log.sensor_id
$sql_subnet
and timestamp > $timestamp and timestamp < ".($timestamp+$interval)."
group by ip) as tx,
(SELECT ip, max(total/sample_duration)*8 as scale, sum(total) as total, sum(tcp) as tcp, sum(udp) as udp, sum(icmp) as icmp,
sum(http) as http, sum(p2p) as p2p, sum(ftp) as ftp
from sensors, bd_rx_log
where sensor_name = '$sensor_name'
and sensors.sensor_id = bd_rx_log.sensor_id
$sql_subnet
and timestamp > $timestamp and timestamp < ".($timestamp+$interval)."
group by ip) as rx
where tx.ip = rx.ip
order by total desc;";
//echo "
$sql
";
$pdoResult = $db->query($sql);
$result = $pdoResult->fetchAll();
$db = NULL;
$num_rows = count($result);
if ($limit == "all")
$limit = $num_rows;
echo "
Ip | Name | Total | Sent | Received | tcp | udp | icmp | http | smtp | ftp |
";
if (!isset($subnet)) // Set this now for total graphs
$subnet = "0.0.0.0/0";
// Output Total Line
echo "Total | $subnet";
foreach (array("total", "sent", "received", "tcp", "udp", "icmp", "http", "p2p", "ftp") as $key)
{
for($Counter=0, $Total = 0; $Counter < $num_rows; $Counter++)
{
$r = $result[$Counter];
$Total += $r[$key];
}
echo fmtb($Total);
}
echo "\n";
// Output Other Lines
for($Counter=0; $Counter < $num_rows && $Counter < $limit; $Counter++)
{
$r = $result[$Counter];
$r['ip'] = long2ip($r['ip']);
echo " |
";
echo $r['ip']." | ".gethostbyaddr($r['ip']);
echo "";
echo fmtb($r['total']).fmtb($r['sent']).fmtb($r['received']).
fmtb($r['tcp']).fmtb($r['udp']).fmtb($r['icmp']).fmtb($r['http']).
fmtb($r['p2p']).fmtb($r['ftp'])."\n";
}
echo " |
";
// Output Total Graph
for($Counter=0, $Total = 0; $Counter < $num_rows; $Counter++)
{
$r = $result[$Counter];
$scale = max($r['txscale'], $scale);
$scale = max($r['rxscale'], $scale);
}
if ($subnet == "0.0.0.0/0")
$total_table = "bd_tx_total_log";
else
$total_table = "bd_tx_log";
echo "
";
echo "";
echo "Send:
";
echo "
\n";
if ($subnet == "0.0.0.0/0")
$total_table = "bd_rx_total_log";
else
$total_table = "bd_rx_log";
echo "Receive:
";
echo "
\n";
// Output Other Graphs
for($Counter=0; $Counter < $num_rows && $Counter < $limit; $Counter++)
{
$r = $result[$Counter];
$r['ip'] = long2ip($r['ip']);
echo "
";
else
echo $r['ip']." - ".gethostbyaddr($r['ip'])."";
echo "";
echo "Send:
";
echo "
\n";
echo "Receive:
";
echo "
\n";
}
include('footer.php');