2010-02-15 01:26:50 +00:00
< ? php
2010-08-11 17:08:56 +00:00
2015-07-13 18:10:26 +00:00
/*
* Observium Network Management and Monitoring System
2011-09-15 15:03:42 +00:00
* 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 .
*/
2015-07-13 18:10:26 +00:00
function discover_new_device ( $hostname , $device = '' , $method = '' , $interface = '' ) {
2015-08-20 13:59:43 +00:00
global $config ;
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
if ( ! empty ( $config [ 'mydomain' ]) && isDomainResolves ( $hostname . '.' . $config [ 'mydomain' ])) {
$dst_host = $hostname . '.' . $config [ 'mydomain' ];
}
else {
$dst_host = $hostname ;
}
2015-08-20 13:59:43 +00:00
d_echo ( " discovering $dst_host\n " );
2015-07-13 18:10:26 +00:00
2011-09-15 15:03:42 +00:00
$ip = gethostbyname ( $dst_host );
2015-07-13 18:10:26 +00:00
if ( filter_var ( $ip , FILTER_VALIDATE_IP , FILTER_FLAG_IPV4 ) === false && filter_var ( $ip , FILTER_VALIDATE_IP , FILTER_FLAG_IPV6 ) === false ) {
2015-07-07 18:43:25 +00:00
// $ip isn't a valid IP so it must be a name.
if ( $ip == $dst_host ) {
2015-08-20 13:59:43 +00:00
d_echo ( " name lookup of $dst_host failed \n " );
2015-07-13 18:10:26 +00:00
return false ;
2015-07-07 18:43:25 +00:00
}
2014-07-17 05:43:46 +00:00
}
2015-11-18 21:48:54 +00:00
elseif ( filter_var ( $dst_host , FILTER_VALIDATE_IP , FILTER_FLAG_IPV4 ) === true || filter_var ( $dst_host , FILTER_VALIDATE_IP , FILTER_FLAG_IPV6 ) === true ){
// gethostbyname returned a valid $ip, was $dst_host an IP?
2015-10-20 16:12:03 +00:00
if ( $config [ 'discovery_by_ip' ] === false ) {
d_echo ( 'Discovery by IP disabled, skipping ' . $dst_host );
return false ;
}
}
2011-09-15 15:03:42 +00:00
2015-08-20 13:59:43 +00:00
d_echo ( " ip lookup result: $ip\n " );
2013-10-28 05:55:57 +00:00
2015-07-13 18:10:26 +00:00
$dst_host = rtrim ( $dst_host , '.' );
// remove trailing dot
if ( match_network ( $config [ 'autodiscovery' ][ 'nets-exclude' ], $ip )) {
2015-08-20 13:59:43 +00:00
d_echo ( " $ip in an excluded network - skipping \n " );
2015-07-13 18:10:26 +00:00
return false ;
2011-09-15 15:03:42 +00:00
}
2015-07-13 18:10:26 +00:00
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 );
if ( $remote_device_id && is_array ( $device ) && ! empty ( $method )) {
$extra_log = '' ;
$int = ifNameDescr ( $interface );
if ( is_array ( $int )) {
$extra_log = ' (port ' . $int [ 'label' ] . ') ' ;
}
2015-08-05 20:05:45 +00:00
log_event ( 'Device $' . $remote_device [ 'hostname' ] . " ( $ip ) $extra_log autodiscovered through $method on " . $device [ 'hostname' ], $remote_device_id , 'discovery' );
2015-07-13 18:10:26 +00:00
}
else {
2015-08-05 20:05:45 +00:00
log_event ( " $method discovery of " . $remote_device [ 'hostname' ] . " ( $ip ) failed - check ping and SNMP access " , $device [ 'device_id' ], 'discovery' );
2015-07-13 18:10:26 +00:00
}
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
return $remote_device_id ;
}
}
else {
2015-08-20 13:59:43 +00:00
d_echo ( " $ip not in a matched network - skipping \n " );
2015-07-13 18:10:26 +00:00
} //end if
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
} //end discover_new_device()
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
function discover_device ( $device , $options = null ) {
global $config , $valid ;
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
$valid = array ();
// Reset $valid array
$attribs = get_dev_attribs ( $device [ 'device_id' ]);
2011-09-15 15:03:42 +00:00
2016-01-08 12:33:32 +00:00
$device_start = microtime ( true );
2015-07-13 18:10:26 +00:00
// Start counting device poll time
echo $device [ 'hostname' ] . ' ' . $device [ 'device_id' ] . ' ' . $device [ 'os' ] . ' ' ;
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
if ( $device [ 'os' ] == 'generic' ) {
// verify if OS has changed from generic
$device [ 'os' ] = getHostOS ( $device );
if ( $device [ 'os' ] != 'generic' ) {
echo " \n Device os was updated to " . $device [ 'os' ] . '!' ;
dbUpdate ( array ( 'os' => $device [ 'os' ]), 'devices' , '`device_id` = ?' , array ( $device [ 'device_id' ]));
2015-06-06 11:04:23 +00:00
}
2011-09-15 15:03:42 +00:00
}
2015-07-13 18:10:26 +00:00
if ( $config [ 'os' ][ $device [ 'os' ]][ 'group' ]) {
$device [ 'os_group' ] = $config [ 'os' ][ $device [ 'os' ]][ 'group' ];
echo ' (' . $device [ 'os_group' ] . ')' ;
2011-09-15 15:03:42 +00:00
}
2015-07-13 18:10:26 +00:00
echo " \n " ;
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
// 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 ]))) {
2016-01-08 07:41:12 +00:00
$module_start = microtime ( true );
2015-07-13 18:10:26 +00:00
include 'includes/discovery/' . $module . '.inc.php' ;
2016-01-08 07:41:12 +00:00
$module_time = microtime ( true ) - $module_start ;
2016-01-07 20:04:51 +00:00
echo " Runtime for discovery module ' $module ': $module_time\n " ;
2015-07-13 18:10:26 +00:00
}
else if ( isset ( $attribs [ 'discover_' . $module ]) && $attribs [ 'discover_' . $module ] == '0' ) {
echo " Module [ $module ] disabled on host. \n " ;
}
else {
echo " Module [ $module ] disabled globally. \n " ;
}
}
2011-09-15 15:03:42 +00:00
}
2015-08-16 12:09:17 +00:00
if ( is_mib_poller_enabled ( $device )) {
$devicemib = array ( $device [ 'sysObjectID' ] => 'all' );
register_mibs ( $device , $devicemib , " includes/discovery/functions.inc.php " );
}
2015-07-13 18:10:26 +00:00
// 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' ];
}
}
2015-02-26 22:02:09 +00:00
2016-01-08 12:33:32 +00:00
$device_end = microtime ( true );
2015-07-13 18:10:26 +00:00
$device_run = ( $device_end - $device_start );
$device_time = substr ( $device_run , 0 , 5 );
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
dbUpdate ( array ( 'last_discovered' => array ( 'NOW()' ), 'type' => $device [ 'type' ], 'last_discovered_timetaken' => $device_time ), 'devices' , '`device_id` = ?' , array ( $device [ 'device_id' ]));
2011-09-15 15:03:42 +00:00
2015-07-13 18:10:26 +00:00
echo " Discovered in $device_time seconds \n " ;
global $discovered_devices ;
echo " \n " ;
$discovered_devices ++ ;
} //end discover_device()
2011-09-15 15:03:42 +00:00
2012-05-25 12:24:34 +00:00
// Discover sensors
2012-04-09 12:57:02 +00:00
2011-05-17 19:21:20 +00:00
2015-07-13 18:10:26 +00:00
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 ) {
2015-08-20 13:59:43 +00:00
global $config ;
2010-08-11 17:08:56 +00:00
2015-08-20 13:59:43 +00:00
d_echo ( " Discover sensor: $oid , $index , $type , $descr , $poller_type , $precision , $entPhysicalIndex\n " );
2010-08-11 17:08:56 +00:00
2015-07-13 18:10:26 +00:00
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 ;
2012-04-09 12:57:02 +00:00
}
2015-07-13 18:10:26 +00:00
else if ( $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 );
2012-04-09 12:57:02 +00:00
}
2015-07-13 18:10:26 +00:00
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 );
}
2010-08-11 12:46:07 +00:00
2015-07-13 18:10:26 +00:00
if ( ! $low_limit ) {
$low_limit = sensor_low_limit ( $class , $current );
}
2012-04-09 12:57:02 +00:00
2015-07-13 18:10:26 +00:00
if ( $low_limit > $high_limit ) {
// Fix high/low thresholds (i.e. on negative numbers)
list ( $high_limit , $low_limit ) = array ( $low_limit , $high_limit );
}
2012-04-09 12:57:02 +00:00
2015-07-13 18:10:26 +00:00
$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' );
2015-08-20 13:59:43 +00:00
d_echo ( " ( $inserted inserted ) \n " );
2015-07-13 18:10:26 +00:00
echo '+' ;
log_event ( 'Sensor Added: ' . mres ( $class ) . ' ' . mres ( $type ) . ' ' . mres ( $index ) . ' ' . mres ( $descr ), $device , 'sensor' , $inserted );
2010-07-07 14:55:21 +00:00
}
2015-07-13 18:10:26 +00:00
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' ];
}
}
2010-02-28 22:04:15 +00:00
2015-07-13 18:10:26 +00:00
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' ]));
2015-08-20 13:59:43 +00:00
d_echo ( " ( $updated updated ) \n " );
2015-07-13 18:10:26 +00:00
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' ]));
2015-08-20 13:59:43 +00:00
d_echo ( " ( $updated updated ) \n " );
2015-07-13 18:10:26 +00:00
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' ]));
2015-08-20 13:59:43 +00:00
d_echo ( " ( $updated updated ) \n " );
2015-07-13 18:10:26 +00:00
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' ]));
2015-08-20 13:59:43 +00:00
d_echo ( " ( $updated updated ) \n " );
2015-07-13 18:10:26 +00:00
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 );
2015-08-20 13:59:43 +00:00
d_echo ( " ( $updated updated ) \n " );
2015-07-13 18:10:26 +00:00
}
} //end if
$valid [ $class ][ $type ][ $index ] = 1 ;
} //end discover_sensor()
2010-08-11 12:46:07 +00:00
2015-07-13 18:10:26 +00:00
function sensor_low_limit ( $class , $current ) {
$limit = null ;
switch ( $class ) {
2010-08-11 12:46:07 +00:00
case 'temperature' :
2015-07-13 18:10:26 +00:00
$limit = ( $current * 0.7 );
break ;
2010-08-11 12:46:07 +00:00
case 'voltage' :
2015-07-13 18:10:26 +00:00
if ( $current < 0 ) {
$limit = ( $current * ( 1 + ( sgn ( $current ) * 0.15 )));
}
else {
$limit = ( $current * ( 1 - ( sgn ( $current ) * 0.15 )));
}
break ;
2010-08-11 12:46:07 +00:00
case 'humidity' :
2015-07-13 18:10:26 +00:00
$limit = '70' ;
break ;
2011-04-21 10:41:43 +00:00
case 'frequency' :
2015-07-13 18:10:26 +00:00
$limit = ( $current * 0.95 );
break ;
2010-08-11 12:46:07 +00:00
case 'current' :
2015-07-13 18:10:26 +00:00
$limit = null ;
break ;
2010-08-11 12:46:07 +00:00
case 'fanspeed' :
2015-07-13 18:10:26 +00:00
$limit = ( $current * 0.80 );
break ;
2011-04-20 09:59:48 +00:00
case 'power' :
2015-07-13 18:10:26 +00:00
$limit = null ;
break ;
} //end switch
return $limit ;
} //end sensor_low_limit()
function sensor_limit ( $class , $current ) {
$limit = null ;
switch ( $class ) {
2010-08-11 12:46:07 +00:00
case 'temperature' :
2015-07-13 18:10:26 +00:00
$limit = ( $current * 1.60 );
break ;
2010-08-11 12:46:07 +00:00
case 'voltage' :
2015-07-13 18:10:26 +00:00
if ( $current < 0 ) {
$limit = ( $current * ( 1 - ( sgn ( $current ) * 0.15 )));
}
else {
$limit = ( $current * ( 1 + ( sgn ( $current ) * 0.15 )));
}
break ;
2010-08-11 12:46:07 +00:00
case 'humidity' :
2015-07-13 18:10:26 +00:00
$limit = '70' ;
break ;
2011-04-21 10:41:43 +00:00
case 'frequency' :
2015-07-13 18:10:26 +00:00
$limit = ( $current * 1.05 );
break ;
2010-08-11 12:46:07 +00:00
case 'current' :
2015-07-13 18:10:26 +00:00
$limit = ( $current * 1.50 );
break ;
2010-08-11 12:46:07 +00:00
case 'fanspeed' :
2015-07-13 18:10:26 +00:00
$limit = ( $current * 1.80 );
break ;
2011-04-20 09:59:48 +00:00
case 'power' :
2015-07-13 18:10:26 +00:00
$limit = ( $current * 1.50 );
break ;
} //end switch
2011-05-17 19:21:20 +00:00
2015-07-13 18:10:26 +00:00
return $limit ;
2011-05-17 19:21:20 +00:00
2015-07-13 18:10:26 +00:00
} //end sensor_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' ];
2015-08-20 13:59:43 +00:00
d_echo ( $index . ' -> ' . $type . " \n " );
2015-07-13 18:10:26 +00:00
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 );
}
2010-03-11 19:09:19 +00:00
}
2015-07-13 18:10:26 +00:00
} //end check_valid_sensors()
function discover_juniAtmVp ( & $valid , $port_id , $vp_id , $vp_descr ) {
2015-08-20 13:59:43 +00:00
global $config ;
2015-07-13 18:10:26 +00:00
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' );
2015-08-20 13:59:43 +00:00
d_echo ( " ( $inserted inserted ) \n " );
2015-07-13 18:10:26 +00:00
// FIXME vv no $device!
log_event ( 'Juniper ATM VP Added: port ' . mres ( $port_id ) . ' vp ' . mres ( $vp_id ) . ' descr' . mres ( $vp_descr ), 'juniAtmVp' , $inserted );
2010-03-11 19:09:19 +00:00
}
2015-07-13 18:10:26 +00:00
else {
echo '.' ;
2010-03-11 19:09:19 +00:00
}
2015-07-13 18:10:26 +00:00
$valid [ $port_id ][ $vp_id ] = 1 ;
} //end discover_juniAtmVp()
function discover_link ( $local_port_id , $protocol , $remote_port_id , $remote_hostname , $remote_port , $remote_platform , $remote_version , $local_device_id , $remote_device_id ) {
2015-08-20 13:59:43 +00:00
global $config , $link_exists ;
2015-07-13 18:10:26 +00:00
2015-07-15 20:32:18 +00:00
d_echo ( " $local_port_id , $protocol , $remote_port_id , $remote_hostname , $remote_port , $remote_platform , $remote_version " );
2015-07-13 18:10:26 +00:00
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 '+' ;
2015-08-20 13:59:43 +00:00
d_echo ( " ( $inserted inserted ) " );
2010-03-11 19:09:19 +00:00
}
2015-07-13 18:10:26 +00:00
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' ;
2015-08-20 13:59:43 +00:00
d_echo ( " ( $updated updated ) " );
2015-07-13 18:10:26 +00:00
} //end if
} //end if
$link_exists [ $local_port_id ][ $remote_hostname ][ $remote_port ] = 1 ;
} //end discover_link()
function discover_storage ( & $valid , $device , $index , $type , $mib , $descr , $size , $units , $used = null ) {
2015-08-20 13:59:43 +00:00
global $config ;
2015-07-13 18:10:26 +00:00
2015-08-20 13:59:43 +00:00
d_echo ( " $device , $index , $type , $mib , $descr , $units , $used , $size\n " );
2015-07-13 18:10:26 +00:00
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'
);
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 '.' ;
}
} //end if
$valid [ $mib ][ $index ] = 1 ;
} //end if
} //end discover_storage()
function discover_processor ( & $valid , $device , $oid , $index , $type , $descr , $precision = '1' , $current = null , $entPhysicalIndex = null , $hrDeviceIndex = null ) {
2015-08-20 13:59:43 +00:00
global $config ;
2015-07-13 18:10:26 +00:00
2015-08-20 13:59:43 +00:00
d_echo ( " $device , $oid , $index , $type , $descr , $precision , $current , $entPhysicalIndex , $hrDeviceIndex\n " );
2015-07-13 18:10:26 +00:00
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 ));
} //end if
$valid [ $type ][ $index ] = 1 ;
} //end if
} //end discover_processor()
function discover_mempool ( & $valid , $device , $index , $type , $descr , $precision = '1' , $entPhysicalIndex = null , $hrDeviceIndex = null ) {
2015-08-20 13:59:43 +00:00
global $config ;
2015-07-13 18:10:26 +00:00
2015-08-20 13:59:43 +00:00
d_echo ( " $device , $oid , $index , $type , $descr , $precision , $current , $entPhysicalIndex , $hrDeviceIndex\n " );
2015-07-13 18:10:26 +00:00
// 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 '.' ;
2015-08-04 16:34:24 +00:00
$update_data = array (
'mempool_descr' => $descr ,
);
2015-07-13 18:10:26 +00:00
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 ));
} //end if
$valid [ $type ][ $index ] = 1 ;
} //end if
} //end discover_mempool()
function discover_toner ( & $valid , $device , $oid , $index , $type , $descr , $capacity_oid = null , $capacity = null , $current = null ) {
2015-08-20 13:59:43 +00:00
global $config ;
2015-07-13 18:10:26 +00:00
2015-08-20 13:59:43 +00:00
d_echo ( " $oid , $index , $type , $descr , $capacity , $capacity_oid\n " );
2015-07-13 18:10:26 +00:00
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 );
2010-03-11 19:09:19 +00:00
}
2015-07-13 18:10:26 +00:00
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' ;
}
2010-03-11 19:09:19 +00:00
}
2015-07-13 18:10:26 +00:00
2011-05-04 13:22:41 +00:00
$valid [ $type ][ $index ] = 1 ;
2011-05-04 10:45:38 +00:00
2015-07-13 18:10:26 +00:00
} //end discover_toner()
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 ;
2011-05-04 10:45:38 +00:00
}
2015-07-13 18:10:26 +00:00
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 ));
2011-05-04 10:45:38 +00:00
2015-07-13 18:10:26 +00:00
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 ;
} //end if
} //end discover_process_ipv6()