mirror of
https://github.com/librenms/librenms.git
synced 2024-10-07 16:52:45 +00:00
673 lines
24 KiB
PHP
673 lines
24 KiB
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.
|
|
*/
|
|
|
|
function discover_new_device($hostname)
|
|
{
|
|
global $config, $debug;
|
|
|
|
if (!empty($config['mydomain']) && isDomainResolves($hostname . "." . $config['mydomain']) ) {
|
|
$dst_host = $hostname . "." . $config['mydomain'];
|
|
} else {
|
|
$dst_host = $hostname;
|
|
}
|
|
if ($debug) { echo("discovering $dst_host\n"); }
|
|
$ip = gethostbyname($dst_host);
|
|
if ($ip == $dst_host) {
|
|
if ($debug) { echo("name lookup of $dst_host failed\n"); }
|
|
return FALSE;
|
|
} else {
|
|
if ($debug) { echo("ip lookup result: $ip\n"); }
|
|
}
|
|
|
|
$dst_host = rtrim($dst_host, '.'); // remove trailing dot
|
|
|
|
if ( match_network($config['autodiscovery']['nets-exclude'], $ip)) {
|
|
if ($debug) { echo("$ip in an excluded network - skipping\n"); }
|
|
return FALSE;
|
|
}
|
|
|
|
if ( match_network($config['nets'], $ip) )
|
|
{
|
|
$remote_device_id = addHost ($dst_host, '', '161', 'udp', '0', $config['distributed_poller_group']);
|
|
if ($remote_device_id) {
|
|
$remote_device = device_by_id_cache($remote_device_id, 1);
|
|
echo("+[".$remote_device['hostname']."(".$remote_device['device_id'].")]");
|
|
discover_device($remote_device);
|
|
device_by_id_cache($remote_device_id, 1);
|
|
return $remote_device_id;
|
|
}
|
|
} else {
|
|
if ($debug) { echo("$ip not in a matched network - skipping\n"); }
|
|
}
|
|
}
|
|
|
|
function discover_device($device, $options = NULL)
|
|
{
|
|
global $config, $valid;
|
|
|
|
$valid = array(); // Reset $valid array
|
|
|
|
$attribs = get_dev_attribs($device['device_id']);
|
|
|
|
$device_start = utime(); // Start counting device poll time
|
|
|
|
echo($device['hostname'] . " ".$device['device_id']." ".$device['os']." ");
|
|
|
|
if ($device['os'] == 'generic') // verify if OS has changed from generic
|
|
{
|
|
$device['os']= getHostOS($device);
|
|
if ($device['os'] != 'generic')
|
|
{
|
|
echo "\nDevice os was updated to ".$device['os']."!";
|
|
dbUpdate(array('os' => $device['os']), 'devices', '`device_id` = ?', array($device['device_id']));
|
|
}
|
|
}
|
|
|
|
if ($config['os'][$device['os']]['group'])
|
|
{
|
|
$device['os_group'] = $config['os'][$device['os']]['group'];
|
|
echo(" (".$device['os_group'].")");
|
|
}
|
|
|
|
echo("\n");
|
|
|
|
// If we've specified modules, use them, else walk the modules array
|
|
if ($options['m']) {
|
|
foreach (explode(',', $options['m']) as $module) {
|
|
if (is_file("includes/discovery/$module.inc.php")) {
|
|
include("includes/discovery/$module.inc.php");
|
|
}
|
|
}
|
|
} else {
|
|
foreach ($config['discovery_modules'] as $module => $module_status)
|
|
{
|
|
if ($attribs['discover_'.$module] || ( $module_status && !isset($attribs['discover_'.$module])))
|
|
{
|
|
include('includes/discovery/'.$module.'.inc.php');
|
|
} elseif (isset($attribs['discover_'.$module]) && $attribs['discover_'.$module] == "0") {
|
|
echo("Module [ $module ] disabled on host.\n");
|
|
} else {
|
|
echo("Module [ $module ] disabled globally.\n");
|
|
}
|
|
}
|
|
}
|
|
|
|
// Set type to a predefined type for the OS if it's not already set
|
|
|
|
if ($device['type'] == "unknown" || $device['type'] == "")
|
|
{
|
|
if ($config['os'][$device['os']]['type'])
|
|
{
|
|
$device['type'] = $config['os'][$device['os']]['type'];
|
|
}
|
|
}
|
|
|
|
$device_end = utime(); $device_run = $device_end - $device_start; $device_time = substr($device_run, 0, 5);
|
|
|
|
dbUpdate(array('last_discovered' => array('NOW()'), 'type' => $device['type'], 'last_discovered_timetaken' => $device_time), 'devices', '`device_id` = ?', array($device['device_id']));
|
|
|
|
echo("Discovered in $device_time seconds\n");
|
|
|
|
global $discovered_devices;
|
|
|
|
echo("\n"); $discovered_devices++;
|
|
}
|
|
|
|
// Discover sensors
|
|
function discover_sensor(&$valid, $class, $device, $oid, $index, $type, $descr, $divisor = '1', $multiplier = '1', $low_limit = NULL, $low_warn_limit = NULL, $warn_limit = NULL, $high_limit = NULL, $current = NULL, $poller_type = 'snmp', $entPhysicalIndex = NULL, $entPhysicalIndex_measured = NULL)
|
|
{
|
|
global $config, $debug;
|
|
|
|
if ($debug) { echo("Discover sensor: $oid, $index, $type, $descr, $poller_type, $precision, $entPhysicalIndex\n"); }
|
|
|
|
if (is_null($low_warn_limit) && !is_null($warn_limit))
|
|
{
|
|
// Warn limits only make sense when we have both a high and a low limit
|
|
$low_warn_limit = NULL;
|
|
$warn_limit = NULL;
|
|
}
|
|
elseif ($low_warn_limit > $warn_limit)
|
|
{
|
|
// Fix high/low thresholds (i.e. on negative numbers)
|
|
list($warn_limit, $low_warn_limit) = array($low_warn_limit, $warn_limit);
|
|
}
|
|
|
|
if (dbFetchCell("SELECT COUNT(sensor_id) FROM `sensors` WHERE `poller_type`= ? AND `sensor_class` = ? AND `device_id` = ? AND sensor_type = ? AND `sensor_index` = ?", array($poller_type, $class, $device['device_id'], $type, $index)) == '0')
|
|
{
|
|
if (!$high_limit) { $high_limit = sensor_limit($class, $current); }
|
|
if (!$low_limit) { $low_limit = sensor_low_limit($class, $current); }
|
|
|
|
if ($low_limit > $high_limit)
|
|
{
|
|
// Fix high/low thresholds (i.e. on negative numbers)
|
|
list($high_limit, $low_limit) = array($low_limit, $high_limit);
|
|
}
|
|
|
|
$insert = array(
|
|
'poller_type' => $poller_type,
|
|
'sensor_class' => $class,
|
|
'device_id' => $device['device_id'],
|
|
'sensor_oid' => $oid,
|
|
'sensor_index' => $index,
|
|
'sensor_type' => $type,
|
|
'sensor_descr' => $descr,
|
|
'sensor_divisor' => $divisor,
|
|
'sensor_multiplier' => $multiplier,
|
|
'sensor_limit' => $high_limit,
|
|
'sensor_limit_warn' => $warn_limit,
|
|
'sensor_limit_low' => $low_limit,
|
|
'sensor_limit_low_warn' => $low_warn_limit,
|
|
'sensor_current' => $current,
|
|
'entPhysicalIndex' => $entPhysicalIndex,
|
|
'entPhysicalIndex_measured' => $entPhysicalIndex_measured
|
|
);
|
|
|
|
foreach ($insert as $key => $val_check){
|
|
if (!isset($val_check)) {
|
|
unset($insert[$key]);
|
|
}
|
|
}
|
|
|
|
$inserted = dbInsert($insert, 'sensors');
|
|
|
|
if ($debug) { echo("( $inserted inserted )\n"); }
|
|
echo("+");
|
|
log_event("Sensor Added: ".mres($class)." ".mres($type)." ". mres($index)." ".mres($descr), $device, 'sensor', $inserted);
|
|
}
|
|
else
|
|
{
|
|
$sensor_entry = dbFetchRow("SELECT * FROM `sensors` WHERE `sensor_class` = ? AND `device_id` = ? AND `sensor_type` = ? AND `sensor_index` = ?", array($class, $device['device_id'], $type, $index));
|
|
|
|
if (!isset($high_limit))
|
|
{
|
|
if (!$sensor_entry['sensor_limit'])
|
|
{
|
|
// Calculate a reasonable limit
|
|
$high_limit = sensor_limit($class, $current);
|
|
} else {
|
|
// Use existing limit
|
|
$high_limit = $sensor_entry['sensor_limit'];
|
|
}
|
|
}
|
|
|
|
if (!isset($low_limit))
|
|
{
|
|
if (!$sensor_entry['sensor_limit_low'])
|
|
{
|
|
// Calculate a reasonable limit
|
|
$low_limit = sensor_low_limit($class, $current);
|
|
} else {
|
|
// Use existing limit
|
|
$low_limit = $sensor_entry['sensor_limit_low'];
|
|
}
|
|
}
|
|
|
|
// Fix high/low thresholds (i.e. on negative numbers)
|
|
if ($low_limit > $high_limit)
|
|
{
|
|
list($high_limit, $low_limit) = array($low_limit, $high_limit);
|
|
}
|
|
|
|
if ($high_limit != $sensor_entry['sensor_limit'] && $sensor_entry['sensor_custom'] == 'No')
|
|
{
|
|
$update = array('sensor_limit' => ($high_limit == NULL ? array('NULL') : $high_limit));
|
|
$updated = dbUpdate($update, 'sensors', '`sensor_id` = ?', array($sensor_entry['sensor_id']));
|
|
if ($debug) { echo("( $updated updated )\n"); }
|
|
echo("H");
|
|
log_event("Sensor High Limit Updated: ".mres($class)." ".mres($type)." ". mres($index)." ".mres($descr)." (".$high_limit.")", $device, 'sensor', $sensor_id);
|
|
}
|
|
|
|
if ($sensor_entry['sensor_limit_low'] != $low_limit && $sensor_entry['sensor_custom'] == 'No')
|
|
{
|
|
$update = array('sensor_limit_low' => ($low_limit == NULL ? array('NULL') : $low_limit));
|
|
$updated = dbUpdate($update, 'sensors', '`sensor_id` = ?', array($sensor_entry['sensor_id']));
|
|
if ($debug) { echo("( $updated updated )\n"); }
|
|
echo("L");
|
|
log_event("Sensor Low Limit Updated: ".mres($class)." ".mres($type)." ". mres($index)." ".mres($descr)." (".$low_limit.")", $device, 'sensor', $sensor_id);
|
|
}
|
|
|
|
if ($warn_limit != $sensor_entry['sensor_limit_warn'] && $sensor_entry['sensor_custom'] == 'No')
|
|
{
|
|
$update = array('sensor_limit_warn' => ($warn_limit == NULL ? array('NULL') : $warn_limit));
|
|
$updated = dbUpdate($update, 'sensors', '`sensor_id` = ?', array($sensor_entry['sensor_id']));
|
|
if ($debug) { echo("( $updated updated )\n"); }
|
|
echo("WH");
|
|
log_event("Sensor Warn High Limit Updated: ".mres($class)." ".mres($type)." ". mres($index)." ".mres($descr)." (".$warn_limit.")", $device, 'sensor', $sensor_id);
|
|
}
|
|
|
|
if ($sensor_entry['sensor_limit_low_warn'] != $low_warn_limit && $sensor_entry['sensor_custom'] == 'No')
|
|
{
|
|
$update = array('sensor_limit_low_warn' => ($low_warn_limit == NULL ? array('NULL') : $low_warn_limit));
|
|
$updated = dbUpdate($update, 'sensors', '`sensor_id` = ?', array($sensor_entry['sensor_id']));
|
|
if ($debug) { echo("( $updated updated )\n"); }
|
|
echo("WL");
|
|
log_event("Sensor Warn Low Limit Updated: ".mres($class)." ".mres($type)." ". mres($index)." ".mres($descr)." (".$low_warn_limit.")", $device, 'sensor', $sensor_id);
|
|
}
|
|
|
|
if ($oid == $sensor_entry['sensor_oid'] && $descr == $sensor_entry['sensor_descr'] && $multiplier == $sensor_entry['sensor_multiplier'] && $divisor == $sensor_entry['sensor_divisor'] && $entPhysicalIndex_measured == $sensor_entry['entPhysicalIndex_measured'] && $entPhysicalIndex == $sensor_entry['entPhysicalIndex'])
|
|
{
|
|
echo(".");
|
|
}
|
|
else
|
|
{
|
|
$update = array('sensor_oid' => $oid, 'sensor_descr' => $descr, 'sensor_multiplier' => $multiplier, 'sensor_divisor' => $divisor,
|
|
'entPhysicalIndex' => $entPhysicalIndex, 'entPhysicalIndex_measured' => $entPhysicalIndex_measured);
|
|
$updated = dbUpdate($update, 'sensors', '`sensor_id` = ?', array($sensor_entry['sensor_id']));
|
|
echo("U");
|
|
log_event("Sensor Updated: ".mres($class)." ".mres($type)." ". mres($index)." ".mres($descr), $device, 'sensor', $sensor_id);
|
|
if ($debug) { echo("( $updated updated )\n"); }
|
|
}
|
|
}
|
|
$valid[$class][$type][$index] = 1;
|
|
}
|
|
|
|
function sensor_low_limit($class, $current)
|
|
{
|
|
$limit = NULL;
|
|
|
|
switch($class)
|
|
{
|
|
case 'temperature':
|
|
$limit = $current * 0.7;
|
|
break;
|
|
case 'voltage':
|
|
if ($current < 0)
|
|
{
|
|
$limit = $current * (1 + (sgn($current) * 0.15));
|
|
}
|
|
else
|
|
{
|
|
$limit = $current * (1 - (sgn($current) * 0.15));
|
|
}
|
|
break;
|
|
case 'humidity':
|
|
$limit = "70";
|
|
break;
|
|
case 'frequency':
|
|
$limit = $current * 0.95;
|
|
break;
|
|
case 'current':
|
|
$limit = NULL;
|
|
break;
|
|
case 'fanspeed':
|
|
$limit = $current * 0.80;
|
|
break;
|
|
case 'power':
|
|
$limit = NULL;
|
|
break;
|
|
}
|
|
return $limit;
|
|
}
|
|
|
|
function sensor_limit($class, $current)
|
|
{
|
|
$limit = NULL;
|
|
|
|
switch($class)
|
|
{
|
|
case 'temperature':
|
|
$limit = $current * 1.60;
|
|
break;
|
|
case 'voltage':
|
|
if ($current < 0)
|
|
{
|
|
$limit = $current * (1 - (sgn($current) * 0.15));
|
|
}
|
|
else
|
|
{
|
|
$limit = $current * (1 + (sgn($current) * 0.15));
|
|
}
|
|
break;
|
|
case 'humidity':
|
|
$limit = "70";
|
|
break;
|
|
case 'frequency':
|
|
$limit = $current * 1.05;
|
|
break;
|
|
case 'current':
|
|
$limit = $current * 1.50;
|
|
break;
|
|
case 'fanspeed':
|
|
$limit = $current * 1.80;
|
|
break;
|
|
case 'power':
|
|
$limit = $current * 1.50;
|
|
break;
|
|
}
|
|
return $limit;
|
|
}
|
|
|
|
function check_valid_sensors($device, $class, $valid, $poller_type = 'snmp')
|
|
{
|
|
$entries = dbFetchRows("SELECT * FROM sensors AS S, devices AS D WHERE S.sensor_class=? AND S.device_id = D.device_id AND D.device_id = ? AND S.poller_type = ?", array($class, $device['device_id'], $poller_type));
|
|
|
|
if (count($entries))
|
|
{
|
|
foreach ($entries as $entry)
|
|
{
|
|
$index = $entry['sensor_index'];
|
|
$type = $entry['sensor_type'];
|
|
if ($debug) { echo($index . " -> " . $type . "\n"); }
|
|
if (!$valid[$class][$type][$index])
|
|
{
|
|
echo("-");
|
|
dbDelete('sensors', "`sensor_id` = ?", array($entry['sensor_id']));
|
|
log_event("Sensor Deleted: ".$entry['sensor_class']." ".$entry['sensor_type']." ". $entry['sensor_index']." ".$entry['sensor_descr'], $device, 'sensor', $sensor_id);
|
|
}
|
|
unset($oid); unset($type);
|
|
}
|
|
}
|
|
}
|
|
|
|
function discover_juniAtmVp(&$valid, $port_id, $vp_id, $vp_descr)
|
|
{
|
|
global $config, $debug;
|
|
|
|
if (dbFetchCell("SELECT COUNT(*) FROM `juniAtmVp` WHERE `port_id` = ? AND `vp_id` = ?", array($port_id, $vp_id)) == "0")
|
|
{
|
|
$inserted = dbInsert(array('port_id' => $port_id,'vp_id' => $vp_id,'vp_descr' => $vp_descr), 'juniAtmVp');
|
|
if ($debug) { echo("( $inserted inserted )\n"); }
|
|
#FIXME vv no $device!
|
|
log_event("Juniper ATM VP Added: port ".mres($port_id)." vp ".mres($vp_id)." descr". mres($vp_descr), 'juniAtmVp', $inserted);
|
|
}
|
|
else
|
|
{
|
|
echo(".");
|
|
}
|
|
$valid[$port_id][$vp_id] = 1;
|
|
}
|
|
|
|
function discover_link($local_port_id, $protocol, $remote_port_id, $remote_hostname, $remote_port, $remote_platform, $remote_version, $local_device_id, $remote_device_id)
|
|
{
|
|
global $config, $debug, $link_exists;
|
|
|
|
if ($debug) {
|
|
echo("\n");
|
|
var_dump($local_port_id, $protocol, $remote_port_id, $remote_hostname, $remote_port, $remote_platform, $remote_version);
|
|
}
|
|
|
|
if (dbFetchCell("SELECT COUNT(*) FROM `links` WHERE `remote_hostname` = ? AND `local_port_id` = ? AND `protocol` = ? AND `remote_port` = ?",
|
|
array($remote_hostname, $local_port_id, $protocol, $remote_port)) == "0")
|
|
{
|
|
$insert_data = array(
|
|
'local_port_id' => $local_port_id,
|
|
'local_device_id' => $local_device_id,
|
|
'protocol' => $protocol,
|
|
'remote_hostname' => $remote_hostname,
|
|
'remote_device_id'=> $remote_device_id,
|
|
'remote_port' => $remote_port,
|
|
'remote_platform' => $remote_platform,
|
|
'remote_version' => $remote_version
|
|
);
|
|
|
|
if (!empty($remote_port_id)) {
|
|
$insert_data['remote_port_id'] = $remote_port_id;
|
|
}
|
|
|
|
$inserted = dbInsert($insert_data, 'links');
|
|
|
|
echo("+"); if ($debug) { echo("( $inserted inserted )"); }
|
|
}
|
|
else
|
|
{
|
|
$data = dbFetchRow("SELECT * FROM `links` WHERE `remote_hostname` = ? AND `local_port_id` = ? AND `protocol` = ? AND `remote_port` = ?", array($remote_hostname, $local_port_id, $protocol, $remote_port));
|
|
if ($data['remote_port_id'] == $remote_port_id && $data['remote_platform'] == $remote_platform && $remote_version == $remote_version && $data['local_device_id'] > 0 && $data['remote_device_id'] > 0)
|
|
{
|
|
echo(".");
|
|
}
|
|
else
|
|
{
|
|
$update_data = array(
|
|
'remote_platform' => $remote_platform,
|
|
'remote_version' => $remote_version,
|
|
'remote_version' => $remote_version,
|
|
'local_device_id' => $local_device_id,
|
|
'remote_device_id' => $remote_device_id
|
|
);
|
|
|
|
if (!empty($remote_port_id)) {
|
|
$update_data['remote_port_id'] = $remote_port_id;
|
|
}
|
|
|
|
$updated = dbUpdate($update_data, 'links', '`id` = ?', array($data['id']));
|
|
echo("U"); if ($debug) { echo("( $updated updated )"); }
|
|
}
|
|
}
|
|
$link_exists[$local_port_id][$remote_hostname][$remote_port] = 1;
|
|
}
|
|
|
|
function discover_storage(&$valid, $device, $index, $type, $mib, $descr, $size, $units, $used = NULL)
|
|
{
|
|
global $config, $debug;
|
|
|
|
if ($debug) { echo("$device, $index, $type, $mib, $descr, $units, $used, $size\n"); }
|
|
if ($descr && $size > "0")
|
|
{
|
|
$storage = dbFetchRow("SELECT * FROM `storage` WHERE `storage_index` = ? AND `device_id` = ? AND `storage_mib` = ?", array($index, $device['device_id'], $mib));
|
|
if ($storage === FALSE || !count($storage))
|
|
{
|
|
$insert = dbInsert(array('device_id' => $device['device_id'], 'storage_descr' => $descr, 'storage_index' => $index, 'storage_mib' => $mib, 'storage_type' => $type,
|
|
'storage_units' => $units, 'storage_size' => $size, 'storage_used' => $used), 'storage');
|
|
if ($debug) { mysql_error(); }
|
|
echo("+");
|
|
}
|
|
else
|
|
{
|
|
$updated = dbUpdate(array('storage_descr' => $descr, 'storage_type' => $type, 'storage_units' => $units, 'storage_size' => $size), 'storage', '`device_id` = ? AND `storage_index` = ? AND `storage_mib` = ?', array($device['device_id'], $index, $mib));
|
|
if ($updated) { echo("U"); } else { echo("."); }
|
|
}
|
|
$valid[$mib][$index] = 1;
|
|
}
|
|
}
|
|
|
|
function discover_processor(&$valid, $device, $oid, $index, $type, $descr, $precision = "1", $current = NULL, $entPhysicalIndex = NULL, $hrDeviceIndex = NULL)
|
|
{
|
|
global $config, $debug;
|
|
|
|
if ($debug) {
|
|
echo("$device, $oid, $index, $type, $descr, $precision, $current, $entPhysicalIndex, $hrDeviceIndex\n");
|
|
}
|
|
|
|
if ($descr)
|
|
{
|
|
$descr = trim(str_replace("\"", "", $descr));
|
|
if (dbFetchCell("SELECT COUNT(processor_id) FROM `processors` WHERE `processor_index` = ? AND `device_id` = ? AND `processor_type` = ?",array($index,$device['device_id'], $type)) == '0')
|
|
{
|
|
$insert_data = array(
|
|
'device_id' => $device['device_id'],
|
|
'processor_descr' => $descr,
|
|
'processor_index' => $index,
|
|
'processor_oid' => $oid,
|
|
'processor_usage' => $current,
|
|
'processor_type' => $type,
|
|
'processor_precision' => $precision
|
|
);
|
|
if (!empty($hrDeviceIndex)) {
|
|
$insert_data['hrDeviceIndex'] = $hrDeviceIndex;
|
|
}
|
|
if( !empty($entPhysicalIndex) ) {
|
|
$insert_data['entPhysicalIndex'] = $entPhysicalIndex;
|
|
}
|
|
|
|
$inserted = dbInsert($insert_data, 'processors');
|
|
echo("+");
|
|
log_event("Processor added: type ".mres($type)." index ".mres($index)." descr ". mres($descr), $device, 'processor', $inserted);
|
|
}
|
|
else
|
|
{
|
|
echo(".");
|
|
$update_data = array(
|
|
'processor_descr' => $descr,
|
|
'processor_oid' => $oid,
|
|
'processor_usage' => $current,
|
|
'processor_precision' => $precision
|
|
);
|
|
dbUpdate($update_data, 'processors', '`device_id`=? AND `processor_index`=? AND `processor_type`=?',array($device['device_id'],$index,$type));
|
|
if ($debug) { print $query . "\n"; }
|
|
}
|
|
$valid[$type][$index] = 1;
|
|
}
|
|
}
|
|
|
|
function discover_mempool(&$valid, $device, $index, $type, $descr, $precision = "1", $entPhysicalIndex = NULL, $hrDeviceIndex = NULL)
|
|
{
|
|
global $config, $debug;
|
|
|
|
if ($debug) {
|
|
echo("$device, $oid, $index, $type, $descr, $precision, $current, $entPhysicalIndex, $hrDeviceIndex\n");
|
|
}
|
|
|
|
#FIXME implement the mempool_perc, mempool_used, etc.
|
|
if ($descr)
|
|
{
|
|
if (dbFetchCell("SELECT COUNT(mempool_id) FROM `mempools` WHERE `mempool_index` = ? AND `device_id` = ? AND `mempool_type` = ?",array($index,$device['device_id'], $type)) == '0')
|
|
{
|
|
$insert_data = array(
|
|
'device_id' => $device['device_id'],
|
|
'mempool_descr' => $descr,
|
|
'mempool_index' => $index,
|
|
'mempool_type' => $type,
|
|
'mempool_precision' => $precision,
|
|
'mempool_perc' => 0,
|
|
'mempool_used' => 0,
|
|
'mempool_free' => 0,
|
|
'mempool_total' => 0
|
|
);
|
|
|
|
if (!empty($entPhysicalIndex)) {
|
|
$insert_data['entPhysicalIndex'] = $entPhysicalIndex;
|
|
}
|
|
|
|
if (!empty($hrDeviceIndex)) {
|
|
$insert_data['hrDeviceIndex'] = $hrDeviceIndex;
|
|
}
|
|
|
|
$inserted = dbInsert($insert_data, 'mempools');
|
|
echo("+");
|
|
log_event("Memory pool added: type ".mres($type)." index ".mres($index)." descr ". mres($descr), $device, 'mempool', $inserted);
|
|
}
|
|
else
|
|
{
|
|
echo(".");
|
|
$update_data['mempool_descr'] = $descr;
|
|
|
|
if (!empty($entPhysicalIndex)) {
|
|
$update_data['entPhysicalIndex'] = $entPhysicalIndex;
|
|
}
|
|
|
|
if (!empty($hrDeviceIndex)) {
|
|
$update_data['hrDeviceIndex'] = $hrDeviceIndex;
|
|
}
|
|
|
|
dbUpdate($update_data, 'mempools', 'device_id=? AND mempool_index=? AND mempool_type=?',array($device['device_id'],$index,$type));
|
|
if ($debug) { print $query . "\n"; }
|
|
}
|
|
$valid[$type][$index] = 1;
|
|
}
|
|
}
|
|
|
|
function discover_toner(&$valid, $device, $oid, $index, $type, $descr, $capacity_oid = NULL, $capacity = NULL, $current = NULL)
|
|
{
|
|
global $config, $debug;
|
|
|
|
if ($debug) {
|
|
echo("$oid, $index, $type, $descr, $capacity, $capacity_oid\n");
|
|
}
|
|
if (dbFetchCell("SELECT COUNT(toner_id) FROM `toner` WHERE device_id = ? AND toner_type = ? AND `toner_index` = ? AND `toner_capacity_oid` =?",array($device['device_id'], $type,$index,$capacity_oid)) == '0')
|
|
{
|
|
$inserted = dbInsert(array('device_id' => $device['device_id'], 'toner_oid' => $oid, 'toner_capacity_oid' => $capacity_oid, 'toner_index' => $index, 'toner_type' => $type, 'toner_descr' => $descr, 'toner_capacity' => $capacity, 'toner_current' => $current), 'toner');
|
|
echo("+");
|
|
log_event("Toner added: type ".mres($type)." index ".mres($index)." descr ". mres($descr), $device, 'toner', $inserted);
|
|
}
|
|
else
|
|
{
|
|
$toner_entry = dbFetchRow("SELECT * FROM `toner` WHERE `device_id` = ? AND `toner_type` = ? AND `toner_index` =?",array($device['device_id'],$type,$index));
|
|
if ($oid == $toner_entry['toner_oid'] && $descr == $toner_entry['toner_descr'] && $capacity == $toner_entry['toner_capacity'] && $capacity_oid == $toner_entry['toner_capacity_oid'])
|
|
{
|
|
echo(".");
|
|
}
|
|
else
|
|
{
|
|
dbUpdate(array('toner_descr' => $descr, 'toner_oid' => $oid, 'toner_capacity_oid' => $capacity_oid, 'toner_capacity' => $capacity), 'toner', 'device_id=? AND toner_type=? AND `toner_index`=?',array($device['device_id'],$type,$index));
|
|
echo("U");
|
|
}
|
|
}
|
|
$valid[$type][$index] = 1;
|
|
}
|
|
|
|
function discover_process_ipv6(&$valid, $ifIndex,$ipv6_address,$ipv6_prefixlen,$ipv6_origin)
|
|
{
|
|
global $device,$config;
|
|
|
|
$ipv6_network = Net_IPv6::getNetmask("$ipv6_address/$ipv6_prefixlen") . '/' . $ipv6_prefixlen;
|
|
$ipv6_compressed = Net_IPv6::compress($ipv6_address);
|
|
|
|
if (Net_IPv6::getAddressType($ipv6_address) == NET_IPV6_LOCAL_LINK)
|
|
{
|
|
# ignore link-locals (coming from IPV6-MIB)
|
|
return;
|
|
}
|
|
|
|
if (dbFetchCell("SELECT COUNT(*) FROM `ports` WHERE device_id = ? AND `ifIndex` = ?",array($device['device_id'], $ifIndex)) != '0' && $ipv6_prefixlen > '0' && $ipv6_prefixlen < '129' && $ipv6_compressed != '::1')
|
|
{
|
|
$port_id = dbFetchCell("SELECT port_id FROM `ports` WHERE device_id = ? AND ifIndex = ?",array($device['device_id'], $ifIndex));
|
|
if (dbFetchCell("SELECT COUNT(*) FROM `ipv6_networks` WHERE `ipv6_network` = ?",array($ipv6_network)) < '1')
|
|
{
|
|
dbInsert(array('ipv6_network' => $ipv6_network), 'ipv6_networks');
|
|
echo("N");
|
|
}
|
|
|
|
// Below looks like a duplicate of the above FIXME
|
|
if (dbFetchCell("SELECT COUNT(*) FROM `ipv6_networks` WHERE `ipv6_network` = ?",array($ipv6_network)) < '1')
|
|
{
|
|
dbInsert(array('ipv6_network' => $ipv6_network), 'ipv6_networks');
|
|
echo("N");
|
|
}
|
|
|
|
$ipv6_network_id = dbFetchCell("SELECT `ipv6_network_id` FROM `ipv6_networks` WHERE `ipv6_network` = ?",array($ipv6_network));
|
|
|
|
if (dbFetchCell("SELECT COUNT(*) FROM `ipv6_addresses` WHERE `ipv6_address` = ? AND `ipv6_prefixlen` = ? AND `port_id` = ?",array($ipv6_address, $ipv6_prefixlen, $port_id)) == '0')
|
|
{
|
|
dbInsert(array('ipv6_address' => $ipv6_address, 'ipv6_compressed' => $ipv6_compressed, 'ipv6_prefixlen' => $ipv6_prefixlen,'ipv6_origin' => $ipv6_origin, 'ipv6_network_id' => $ipv6_network_id, 'port_id' => $port_id), 'ipv6_addresses');
|
|
echo("+");
|
|
}
|
|
else
|
|
{
|
|
echo(".");
|
|
}
|
|
$full_address = "$ipv6_address/$ipv6_prefixlen";
|
|
$valid_address = $full_address . "-" . $port_id;
|
|
$valid['ipv6'][$valid_address] = 1;
|
|
}
|
|
}
|
|
|
|
// maintain a simple cache of seen IPs during ARP discovery
|
|
function arp_discovery_add_cache($ip)
|
|
{
|
|
global $arp_discovery;
|
|
$arp_discovery[$ip] = TRUE;
|
|
}
|
|
|
|
function arp_discovery_is_cached($ip)
|
|
{
|
|
global $arp_discovery;
|
|
if (array_key_exists($ip, $arp_discovery)) {
|
|
return $arp_discovery[$ip];
|
|
}
|
|
else {
|
|
return FALSE;
|
|
}
|
|
}
|
|
|
|
?>
|