|
weathermap |
Subversion Repositories: |
| Rev 1 | Rev 85 | |
|---|---|---|
| Line 15... | Line 15... | |
|
| |
class WeatherMapDataSource_snmp extends WeatherMapDataSource { |
class WeatherMapDataSource_snmp extends WeatherMapDataSource { | |
|
| |
function Init(&$map) |
function Init(&$map) | |
{ |
{ | |
// We can keep a list of unresponsive nodes, so we can give up earlier | ||
$this->down_cache = array(); | ||
| ||
if(function_exists('snmpget')) { return(TRUE); } |
if(function_exists('snmpget')) { return(TRUE); } | |
debug("SNMP DS: snmpget() not found. Do you have the PHP SNMP module?\n"); |
debug("SNMP DS: snmpget() not found. Do you have the PHP SNMP module?\n"); | |
|
| |
return(FALSE); |
return(FALSE); | |
} |
} | |
|
| |
|
| |
function Recognise($targetstring) |
function Recognise($targetstring) | |
| Line 36... | Line 39... | |
} |
} | |
} |
} | |
|
| |
function ReadData($targetstring, &$map, &$item) |
function ReadData($targetstring, &$map, &$item) | |
{ |
{ | |
$inbw=-1; |
$data[IN] = NULL; | |
$outbw=-1; |
$data[OUT] = NULL; | |
$data_time=0; |
$data_time = 0; | |
|
| |
$timeout = 1000000; | ||
$retries = 2; | ||
$abort_count = 0; | ||
| ||
$in_result = NULL; | ||
$out_result = NULL; | ||
| ||
if($map->get_hint("snmp_timeout") != '') { | ||
$timeout = intval($map->get_hint("snmp_timeout")); | ||
debug("Timeout changed to ".$timeout." microseconds.\n"); | ||
} | ||
| ||
if($map->get_hint("snmp_abort_count") != '') { | ||
$abort_count = intval($map->get_hint("snmp_abort_count")); | ||
debug("Will abort after $abort_count failures for a given host.\n"); | ||
} | ||
| ||
if($map->get_hint("snmp_retries") != '') { | ||
$retries = intval($map->get_hint("snmp_retries")); | ||
debug("Number of retries changed to ".$retries.".\n"); | ||
} | ||
| ||
if(preg_match("/^snmp:([^:]+):([^:]+):([^:]+):([^:]+)$/",$targetstring,$matches)) |
if(preg_match("/^snmp:([^:]+):([^:]+):([^:]+):([^:]+)$/",$targetstring,$matches)) | |
{ |
{ | |
$community = $matches[1]; |
$community = $matches[1]; | |
$host = $matches[2]; |
$host = $matches[2]; | |
$in_oid = $matches[3]; |
$in_oid = $matches[3]; | |
$out_oid = $matches[4]; |
$out_oid = $matches[4]; | |
|
| |
$was = snmp_get_quick_print(); |
if( | |
snmp_set_quick_print(1); |
($abort_count == 0) | |
|| ( | ||
( $abort_count>0 ) | ||
&& ( !isset($this->down_cache[$host]) || intval($this->down_cache[$host]) < $abort_count ) | ||
) | ||
) | ||
{ | ||
if(function_exists("snmp_get_quick_print")) | ||
{ | ||
$was = snmp_get_quick_print(); | ||
snmp_set_quick_print(1); | ||
} | ||
if(function_exists("snmp_get_valueretrieval")) | ||
{ | ||
$was2 = snmp_get_valueretrieval(); | ||
} | ||
| ||
if(function_exists('snmp_set_oid_output_format')) | ||
{ | ||
snmp_set_oid_output_format ( SNMP_OID_OUTPUT_NUMERIC ); | ||
} | ||
if(function_exists('snmp_set_valueretrieval')) | ||
{ | ||
snmp_set_valueretrieval(SNMP_VALUE_PLAIN); | ||
} | ||
|
| |
$in_result = snmpget($host,$community,$in_oid,1000000,2); |
if($in_oid != '-') | |
$out_result = snmpget($host,$community,$out_oid,1000000,2); |
{ | |
$in_result = snmpget($host,$community,$in_oid,$timeout,$retries); | ||
if($in_result) | ||
{ | ||
$data[IN] = floatval($in_result); | ||
$item->add_hint("snmp_in_raw",$in_result); | ||
} | ||
else | ||
{ | ||
$this->down_cache{$host}++; | ||
} | ||
} | ||
if($out_oid != '-') | ||
{ | ||
$out_result = snmpget($host,$community,$out_oid,$timeout,$retries); | ||
if($out_result) | ||
{ | ||
// use floatval() here to force the output to be *some* kind of number | ||
// just in case the stupid formatting stuff doesn't stop net-snmp returning 'down' instead of 2 | ||
$data[OUT] = floatval($out_result); | ||
$item->add_hint("snmp_out_raw",$out_result); | ||
} | ||
else | ||
{ | ||
$this->down_cache{$host}++; | ||
} | ||
} | ||
| ||
debug ("SNMP ReadData: Got $in_result and $out_result\n"); | ||
| ||
$data_time = time(); | ||
|
| |
debug ("SNMP ReadData: Got $in_result and $out_result\n"); |
if(function_exists("snmp_set_quick_print")) | |
|
{ | |
if($in_result) { $in_bw = $in_result; } |
snmp_set_quick_print($was); | |
if($out_result) { $out_bw = $out_result;} |
} | |
$data_time = time(); |
} | |
snmp_set_quick_print($was); |
else | |
{ | ||
warn("SNMP for $host has reached $abort_count failures. Skipping. [WMSNMP01]"); | ||
} | ||
} |
} | |
|
| |
debug ("SNMP ReadData: Returning ($inbw,$outbw,$data_time)\n"); |
debug ("SNMP ReadData: Returning (".($data[IN]===NULL?'NULL':$data[IN]).",".($data[OUT]===NULL?'NULL':$data[OUT]).",$data_time)\n"); | |
|
| |
return ( array($inbw,$outbw,$data_time) ); |
return( array($data[IN], $data[OUT], $data_time) ); | |
} |
} | |
} |
} | |
|
| |
// vim:ts=4:sw=4: |
// vim:ts=4:sw=4: | |
?> |
?> |