cleanup poller and discovery, add gpl notice at the top

git-svn-id: http://www.observium.org/svn/observer/trunk@1850 61d68cd4-352d-0410-923a-c4978735b2b8
This commit is contained in:
Tom Laermans
2011-03-15 15:12:16 +00:00
parent 0cbb3ab944
commit 53c3cab362
2 changed files with 69 additions and 30 deletions
+15 -4
View File
@@ -1,6 +1,17 @@
#!/usr/bin/env php #!/usr/bin/env php
<?php <?php
/* Observium Network Management and Monitoring System
* Copyright (C) 2006-2011, Observium Developers - http://www.observium.org
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* See COPYING for more details.
*/
include("includes/defaults.inc.php"); include("includes/defaults.inc.php");
include("config.php"); include("config.php");
include("includes/functions.php"); include("includes/functions.php");
@@ -55,7 +66,7 @@ if (isset($options['d']))
} }
if(!$where) if (!$where)
{ {
echo("-h <device id> | <device hostname> Poll single device\n"); echo("-h <device id> | <device hostname> Poll single device\n");
echo("-h odd Poll odd numbered devices (same as -i 2 -n 0)\n"); echo("-h odd Poll odd numbered devices (same as -i 2 -n 0)\n");
@@ -133,13 +144,13 @@ while ($device = mysql_fetch_array($device_query))
$device_start = utime(); // Start counting device poll time $device_start = utime(); // Start counting device poll time
echo($device['hostname'] . " ".$device['device_id']." ".$device['os']." "); echo($device['hostname'] . " ".$device['device_id']." ".$device['os']." ");
if($device['os'] != strtolower($device['os'])) if ($device['os'] != strtolower($device['os']))
{ {
mysql_query("UPDATE `devices` SET `os` = '".strtolower($device['os'])."' WHERE device_id = '".$device['device_id']."'"); mysql_query("UPDATE `devices` SET `os` = '".strtolower($device['os'])."' WHERE device_id = '".$device['device_id']."'");
$device['os'] = strtolower($device['os']); $device['os'] = strtolower($device['os']);
echo("OS lowercased."); echo("OS lowercased.");
} }
if($config['os'][$device['os']]['group']) if ($config['os'][$device['os']]['group'])
{ {
$device['os_group'] = $config['os'][$device['os']]['group']; $device['os_group'] = $config['os'][$device['os']]['group'];
echo("(".$device['os_group'].")"); echo("(".$device['os_group'].")");
@@ -195,7 +206,7 @@ while ($device = mysql_fetch_array($device_query))
$end = utime(); $run = $end - $start; $end = utime(); $run = $end - $start;
$proctime = substr($run, 0, 5); $proctime = substr($run, 0, 5);
if($discovered_devices) if ($discovered_devices)
{ {
mysql_query("INSERT INTO `perf_times` (`type`, `doing`, `start`, `duration`, `devices`) mysql_query("INSERT INTO `perf_times` (`type`, `doing`, `start`, `duration`, `devices`)
VALUES ('discover', '$doing', '$start', '$proctime', '$discovered_devices')"); VALUES ('discover', '$doing', '$start', '$proctime', '$discovered_devices')");
+54 -26
View File
@@ -1,6 +1,17 @@
#!/usr/bin/env php #!/usr/bin/env php
<?php <?php
/* Observium Network Management and Monitoring System
* Copyright (C) 2006-2011, Observium Developers - http://www.observium.org
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* See COPYING for more details.
*/
### Observium Device Poller ### Observium Device Poller
include("includes/defaults.inc.php"); include("includes/defaults.inc.php");
@@ -15,7 +26,8 @@ $options = getopt("h:t:i:n:d::a::");
if ($options['h'] == "odd") { $options['n'] = "1"; $options['i'] = "2"; } if ($options['h'] == "odd") { $options['n'] = "1"; $options['i'] = "2"; }
elseif ($options['h'] == "even") { $options['n'] = "0"; $options['i'] = "2"; } elseif ($options['h'] == "even") { $options['n'] = "0"; $options['i'] = "2"; }
elseif ($options['h'] == "all") { $where = " "; $doing = "all"; } elseif ($options['h'] == "all") { $where = " "; $doing = "all"; }
elseif ($options['h']) { elseif ($options['h'])
{
if (is_numeric($options['h'])) if (is_numeric($options['h']))
{ {
$where = "AND `device_id` = '".$options['h']."'"; $where = "AND `device_id` = '".$options['h']."'";
@@ -28,12 +40,14 @@ elseif ($options['h']) {
} }
} }
if (isset($options['i']) && $options['i'] && isset($options['n'])) { if (isset($options['i']) && $options['i'] && isset($options['n']))
{
$where = "AND MOD(device_id,".$options['i'].") = '" . $options['n'] . "'"; $where = "AND MOD(device_id,".$options['i'].") = '" . $options['n'] . "'";
$doing = $options['n'] ."/".$options['i']; $doing = $options['n'] ."/".$options['i'];
} }
if (!$where) { if (!$where)
{
echo("-h <device id> | <device hostname> Poll single device\n"); echo("-h <device id> | <device hostname> Poll single device\n");
echo("-h odd Poll odd numbered devices (same as -i 2 -n 0)\n"); echo("-h odd Poll odd numbered devices (same as -i 2 -n 0)\n");
echo("-h even Poll even numbered devices (same as -i 2 -n 1)\n"); echo("-h even Poll even numbered devices (same as -i 2 -n 1)\n");
@@ -46,7 +60,8 @@ if (!$where) {
exit; exit;
} }
if (isset($options['d'])) { if (isset($options['d']))
{
echo("DEBUG!\n"); echo("DEBUG!\n");
$debug = TRUE; $debug = TRUE;
ini_set('display_errors', 1); ini_set('display_errors', 1);
@@ -74,7 +89,7 @@ while ($device = mysql_fetch_assoc($device_query))
$device_start = utime(); // Start counting device poll time $device_start = utime(); // Start counting device poll time
echo($device['hostname'] . " ".$device['device_id']." ".$device['os']." "); echo($device['hostname'] . " ".$device['device_id']." ".$device['os']." ");
if($config['os'][$device['os']]['group']) if ($config['os'][$device['os']]['group'])
{ {
$device['os_group'] = $config['os'][$device['os']]['group']; $device['os_group'] = $config['os'][$device['os']]['group'];
echo("(".$device['os_group'].")"); echo("(".$device['os_group'].")");
@@ -89,9 +104,11 @@ while ($device = mysql_fetch_assoc($device_query))
$device['pingable'] = isPingable($device['hostname']); $device['pingable'] = isPingable($device['hostname']);
if($device['pingable']) { if ($device['pingable'])
{
$device['snmpable'] = isSNMPable($device['hostname'], $device['community'], $device['snmpver'], $device['port']); $device['snmpable'] = isSNMPable($device['hostname'], $device['community'], $device['snmpver'], $device['port']);
if($device['snmpable']) { if ($device['snmpable'])
{
$status = "1"; $status = "1";
} else { } else {
echo("SNMP Unreachable"); echo("SNMP Unreachable");
@@ -102,7 +119,7 @@ while ($device = mysql_fetch_assoc($device_query))
$status = "0"; $status = "0";
} }
if ( $device['status'] != $status ) if ($device['status'] != $status )
{ {
$poll_update .= $poll_separator . "`status` = '$status'"; $poll_update .= $poll_separator . "`status` = '$status'";
$poll_separator = ", "; $poll_separator = ", ";
@@ -159,7 +176,7 @@ while ($device = mysql_fetch_assoc($device_query))
if (is_numeric($uptime)) if (is_numeric($uptime))
{ {
if ( $uptime < $device['uptime'] ) { if ($uptime < $device['uptime'] ) {
notify($device,"Device rebooted: " . $device['hostname'], "Device Rebooted : " . $device['hostname'] . " " . formatUptime($uptime) . " ago."); notify($device,"Device rebooted: " . $device['hostname'], "Device Rebooted : " . $device['hostname'] . " " . formatUptime($uptime) . " ago.");
log_event('Device rebooted after '.formatUptime($device['uptime']), $device['device_id'], 'reboot', $device['uptime']); log_event('Device rebooted after '.formatUptime($device['uptime']), $device['device_id'], 'reboot', $device['uptime']);
} }
@@ -226,52 +243,60 @@ while ($device = mysql_fetch_assoc($device_query))
include("includes/polling/cisco-ipsec-flow-monitor.inc.php"); include("includes/polling/cisco-ipsec-flow-monitor.inc.php");
include("includes/polling/cisco-remote-access-monitor.inc.php"); include("includes/polling/cisco-remote-access-monitor.inc.php");
unset( $update ) ; unset($update);
unset( $seperator) ; unset($seperator);
if ( $serial && $serial != $device['serial'] ) { if ($serial && $serial != $device['serial'])
{
$poll_update .= $poll_separator . "`serial` = '".mres($serial)."'"; $poll_update .= $poll_separator . "`serial` = '".mres($serial)."'";
$poll_separator = ", "; $poll_separator = ", ";
log_event("Serial -> $serial", $device['device_id'], 'system'); log_event("Serial -> $serial", $device['device_id'], 'system');
} }
if ( $sysContact && $sysContact != $device['sysContact'] ) { if ($sysContact && $sysContact != $device['sysContact'])
{
$poll_update .= $poll_separator . "`sysContact` = '".mres($sysContact)."'"; $poll_update .= $poll_separator . "`sysContact` = '".mres($sysContact)."'";
$poll_separator = ", "; $poll_separator = ", ";
log_event("Contact -> $sysContact", $device['device_id'], 'system'); log_event("Contact -> $sysContact", $device['device_id'], 'system');
} }
if ( $sysName && $sysName != $device['sysName'] ) { if ($sysName && $sysName != $device['sysName'])
{
$poll_update .= $poll_separator . "`sysName` = '$sysName'"; $poll_update .= $poll_separator . "`sysName` = '$sysName'";
$poll_separator = ", "; $poll_separator = ", ";
log_event("sysName -> $sysName", $device['device_id'], 'system'); log_event("sysName -> $sysName", $device['device_id'], 'system');
} }
if ( $sysDescr && $sysDescr != $device['sysDescr'] ) { if ($sysDescr && $sysDescr != $device['sysDescr'])
{
$poll_update .= $poll_separator . "`sysDescr` = '$sysDescr'"; $poll_update .= $poll_separator . "`sysDescr` = '$sysDescr'";
$poll_separator = ", "; $poll_separator = ", ";
log_event("sysDescr -> $sysDescr", $device['device_id'], 'system'); log_event("sysDescr -> $sysDescr", $device['device_id'], 'system');
} }
if ( $sysLocation && $device['location'] != $sysLocation ) { if ($sysLocation && $device['location'] != $sysLocation)
{
$poll_update .= $poll_separator . "`location` = '$sysLocation'"; $poll_update .= $poll_separator . "`location` = '$sysLocation'";
$poll_separator = ", "; $poll_separator = ", ";
log_event("Location -> $sysLocation", $device['device_id'], 'system'); log_event("Location -> $sysLocation", $device['device_id'], 'system');
} }
if ( $version && $device['version'] != $version ) { if ($version && $device['version'] != $version)
{
$poll_update .= $poll_separator . "`version` = '$version'"; $poll_update .= $poll_separator . "`version` = '$version'";
$poll_separator = ", "; $poll_separator = ", ";
log_event("OS Version -> $version", $device['device_id'], 'system'); log_event("OS Version -> $version", $device['device_id'], 'system');
} }
if ( $features != $device['features'] ) { if ($features != $device['features'])
{
$poll_update .= $poll_separator . "`features` = '$features'"; $poll_update .= $poll_separator . "`features` = '$features'";
$poll_separator = ", "; $poll_separator = ", ";
log_event("OS Features -> $features", $device['device_id'], 'system'); log_event("OS Features -> $features", $device['device_id'], 'system');
} }
if ( $hardware && $hardware != $device['hardware'] ) { if ($hardware && $hardware != $device['hardware'])
{
$poll_update .= $poll_separator . "`hardware` = '$hardware'"; $poll_update .= $poll_separator . "`hardware` = '$hardware'";
$poll_separator = ", "; $poll_separator = ", ";
log_event("Hardware -> $hardware", $device['device_id'], 'system'); log_event("Hardware -> $hardware", $device['device_id'], 'system');
@@ -290,17 +315,19 @@ while ($device = mysql_fetch_assoc($device_query))
### Ideally we should hold graphs for xx days/weeks/polls so that we don't needlessly hide information. ### Ideally we should hold graphs for xx days/weeks/polls so that we don't needlessly hide information.
$query = mysql_query("SELECT `graph` FROM `device_graphs` WHERE `device_id` = '".$device['device_id']."'"); $query = mysql_query("SELECT `graph` FROM `device_graphs` WHERE `device_id` = '".$device['device_id']."'");
while($graph = mysql_fetch_array($query)){ while ($graph = mysql_fetch_array($query))
if(!isset($graphs[$graph[0]])) {
if (!isset($graphs[$graph[0]]))
{ {
mysql_query("DELETE FROM `device_graphs` WHERE `device_id` = '".$device['device_id']."' AND `graph` = '".$graph[0]."'"); mysql_query("DELETE FROM `device_graphs` WHERE `device_id` = '".$device['device_id']."' AND `graph` = '".$graph[0]."'");
} else { } else {
$oldgraphs[$graph[0]] = TRUE; $oldgraphs[$graph[0]] = TRUE;
} }
} }
foreach($graphs as $graph => $value)
foreach ($graphs as $graph => $value)
{ {
if(!isset($oldgraphs[$graph])) if (!isset($oldgraphs[$graph]))
{ {
mysql_query("INSERT INTO `device_graphs` (`device_id`, `graph`) VALUES ('".$device['device_id']."','".$graph."')"); mysql_query("INSERT INTO `device_graphs` (`device_id`, `graph`) VALUES ('".$device['device_id']."','".$graph."')");
} }
@@ -315,9 +342,9 @@ while ($device = mysql_fetch_assoc($device_query))
$poll_update_query = "UPDATE `devices` SET "; $poll_update_query = "UPDATE `devices` SET ";
$poll_update_query .= $poll_update; $poll_update_query .= $poll_update;
$poll_update_query .= " WHERE `device_id` = '" . $device['device_id'] . "'"; $poll_update_query .= " WHERE `device_id` = '" . $device['device_id'] . "'";
if($debug) {echo("Updating " . $device['hostname'] . " - $poll_update_query \n");} if ($debug) { echo("Updating " . $device['hostname'] . " - $poll_update_query \n"); }
$poll_update_result = mysql_query($poll_update_query); $poll_update_result = mysql_query($poll_update_query);
if(mysql_affected_rows() == "1") { echo("UPDATED!\n"); } else { echo("NOT UPDATED!\n"); } if (mysql_affected_rows() == "1") { echo("UPDATED!\n"); } else { echo("NOT UPDATED!\n"); }
unset($storage_cache); // Clear cache of hrStorage ** MAYBE FIXME? ** unset($storage_cache); // Clear cache of hrStorage ** MAYBE FIXME? **
unset($cache); // Clear cache (unify all things here?) unset($cache); // Clear cache (unify all things here?)
@@ -326,7 +353,8 @@ while ($device = mysql_fetch_assoc($device_query))
$poller_end = utime(); $poller_run = $poller_end - $poller_start; $poller_time = substr($poller_run, 0, 5); $poller_end = utime(); $poller_run = $poller_end - $poller_start; $poller_time = substr($poller_run, 0, 5);
if($polled_devices) { if ($polled_devices)
{
mysql_query("INSERT INTO `perf_times` (`type`, `doing`, `start`, `duration`, `devices`) mysql_query("INSERT INTO `perf_times` (`type`, `doing`, `start`, `duration`, `devices`)
VALUES ('poll', '$doing', '$poller_start', '$poller_time', '$polled_devices')"); VALUES ('poll', '$doing', '$poller_start', '$poller_time', '$polled_devices')");
} }