mirror of
https://github.com/librenms/librenms.git
synced 2024-09-30 06:46:43 +00:00
591 lines
24 KiB
PHP
591 lines
24 KiB
PHP
<?php
|
|
|
|
// Build SNMP Cache Array
|
|
$data_oids = array(
|
|
'ifName',
|
|
'ifDescr',
|
|
'ifAlias',
|
|
'ifAdminStatus',
|
|
'ifOperStatus',
|
|
'ifMtu',
|
|
'ifSpeed',
|
|
'ifHighSpeed',
|
|
'ifType',
|
|
'ifPhysAddress',
|
|
'ifPromiscuousMode',
|
|
'ifConnectorPresent',
|
|
'ifDuplex',
|
|
'ifTrunk',
|
|
'ifVlan',
|
|
);
|
|
|
|
$stat_oids = array(
|
|
'ifInErrors',
|
|
'ifOutErrors',
|
|
'ifInUcastPkts',
|
|
'ifOutUcastPkts',
|
|
'ifInNUcastPkts',
|
|
'ifOutNUcastPkts',
|
|
'ifHCInMulticastPkts',
|
|
'ifHCInBroadcastPkts',
|
|
'ifHCOutMulticastPkts',
|
|
'ifHCOutBroadcastPkts',
|
|
'ifInOctets',
|
|
'ifOutOctets',
|
|
'ifHCInOctets',
|
|
'ifHCOutOctets',
|
|
'ifInDiscards',
|
|
'ifOutDiscards',
|
|
'ifInUnknownProtos',
|
|
'ifInBroadcastPkts',
|
|
'ifOutBroadcastPkts',
|
|
'ifInMulticastPkts',
|
|
'ifOutMulticastPkts',
|
|
);
|
|
|
|
$stat_oids_db = array(
|
|
'ifInOctets',
|
|
'ifOutOctets',
|
|
'ifInErrors',
|
|
'ifOutErrors',
|
|
'ifInUcastPkts',
|
|
'ifOutUcastPkts',
|
|
);
|
|
// From above for DB
|
|
$etherlike_oids = array(
|
|
'dot3StatsAlignmentErrors',
|
|
'dot3StatsFCSErrors',
|
|
'dot3StatsSingleCollisionFrames',
|
|
'dot3StatsMultipleCollisionFrames',
|
|
'dot3StatsSQETestErrors',
|
|
'dot3StatsDeferredTransmissions',
|
|
'dot3StatsLateCollisions',
|
|
'dot3StatsExcessiveCollisions',
|
|
'dot3StatsInternalMacTransmitErrors',
|
|
'dot3StatsCarrierSenseErrors',
|
|
'dot3StatsFrameTooLongs',
|
|
'dot3StatsInternalMacReceiveErrors',
|
|
'dot3StatsSymbolErrors',
|
|
);
|
|
|
|
$cisco_oids = array(
|
|
'locIfHardType',
|
|
'locIfInRunts',
|
|
'locIfInGiants',
|
|
'locIfInCRC',
|
|
'locIfInFrame',
|
|
'locIfInOverrun',
|
|
'locIfInIgnored',
|
|
'locIfInAbort',
|
|
'locIfCollisions',
|
|
'locIfInputQueueDrops',
|
|
'locIfOutputQueueDrops',
|
|
);
|
|
|
|
$pagp_oids = array(
|
|
'pagpOperationMode',
|
|
'pagpPortState',
|
|
'pagpPartnerDeviceId',
|
|
'pagpPartnerLearnMethod',
|
|
'pagpPartnerIfIndex',
|
|
'pagpPartnerGroupIfIndex',
|
|
'pagpPartnerDeviceName',
|
|
'pagpEthcOperationMode',
|
|
'pagpDeviceId',
|
|
'pagpGroupIfIndex',
|
|
);
|
|
|
|
$ifmib_oids = array_merge($data_oids, $stat_oids);
|
|
|
|
$ifmib_oids = array(
|
|
'ifEntry',
|
|
'ifXEntry',
|
|
);
|
|
|
|
echo 'Caching Oids: ';
|
|
foreach ($ifmib_oids as $oid) {
|
|
echo "$oid ";
|
|
$port_stats = snmpwalk_cache_oid($device, $oid, $port_stats, 'IF-MIB');
|
|
}
|
|
|
|
if ($config['enable_ports_etherlike']) {
|
|
echo 'dot3Stats ';
|
|
$port_stats = snmpwalk_cache_oid($device, 'dot3StatsEntry', $port_stats, 'EtherLike-MIB');
|
|
}
|
|
else {
|
|
echo 'dot3StatsDuplexStatus';
|
|
$port_stats = snmpwalk_cache_oid($device, 'dot3StatsDuplexStatus', $port_stats, 'EtherLike-MIB');
|
|
}
|
|
|
|
if ($config['enable_ports_adsl']) {
|
|
$device['adsl_count'] = dbFetchCell("SELECT COUNT(*) FROM `ports` WHERE `device_id` = ? AND `ifType` = 'adsl'", array($device['device_id']));
|
|
}
|
|
|
|
if ($device['adsl_count'] > '0') {
|
|
echo 'ADSL ';
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.1.1', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.2.1', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.3.1', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.4.1', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.5.1', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.6.1.1', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.6.1.2', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.6.1.3', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.6.1.4', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.6.1.5', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.6.1.6', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.6.1.7', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.6.1.8', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.7.1.1', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.7.1.2', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.7.1.3', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.7.1.4', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.7.1.5', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.7.1.6', $port_stats, 'ADSL-LINE-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, '.1.3.6.1.2.1.10.94.1.1.7.1.7', $port_stats, 'ADSL-LINE-MIB');
|
|
}//end if
|
|
|
|
// FIXME This probably needs re-enabled. We need to clear these things when they get unset, too.
|
|
// foreach ($etherlike_oids as $oid) { $port_stats = snmpwalk_cache_oid($device, $oid, $port_stats, "EtherLike-MIB"); }
|
|
// foreach ($cisco_oids as $oid) { $port_stats = snmpwalk_cache_oid($device, $oid, $port_stats, "OLD-CISCO-INTERFACES-MIB"); }
|
|
// foreach ($pagp_oids as $oid) { $port_stats = snmpwalk_cache_oid($device, $oid, $port_stats, "CISCO-PAGP-MIB"); }
|
|
if ($device['os_group'] == 'cisco') {
|
|
$port_stats = snmp_cache_portIfIndex($device, $port_stats);
|
|
$port_stats = snmp_cache_portName($device, $port_stats);
|
|
foreach ($pagp_oids as $oid) {
|
|
$port_stats = snmpwalk_cache_oid($device, $oid, $port_stats, 'CISCO-PAGP-MIB');
|
|
}
|
|
|
|
$data_oids[] = 'portName';
|
|
|
|
// Grab data to put ports into vlans or make them trunks
|
|
// FIXME we probably shouldn't be doing this from the VTP MIB, right?
|
|
$port_stats = snmpwalk_cache_oid($device, 'vmVlan', $port_stats, 'CISCO-VLAN-MEMBERSHIP-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, 'vlanTrunkPortEncapsulationOperType', $port_stats, 'CISCO-VTP-MIB');
|
|
$port_stats = snmpwalk_cache_oid($device, 'vlanTrunkPortNativeVlan', $port_stats, 'CISCO-VTP-MIB');
|
|
}
|
|
else {
|
|
$port_stats = snmpwalk_cache_oid($device, 'dot1qPortVlanTable', $port_stats, 'Q-BRIDGE-MIB');
|
|
|
|
$vlan_ports = snmpwalk_cache_twopart_oid($device, 'dot1qVlanCurrentEgressPorts', $vlan_stats, 'Q-BRIDGE-MIB');
|
|
$vlan_ifindex_map = snmpwalk_cache_oid($device, 'dot1dBasePortIfIndex', $vlan_stats, 'Q-BRIDGE-MIB');
|
|
|
|
foreach ($vlan_ports as $instance) {
|
|
foreach (array_keys($instance) as $vlan_id) {
|
|
$parts = explode(' ', $instance[$vlan_id]['dot1qVlanCurrentEgressPorts']);
|
|
$binary = '';
|
|
foreach ($parts as $part) {
|
|
$binary .= zeropad(decbin($part), 8);
|
|
}
|
|
|
|
for ($i = 0; $i < strlen($binary); $i++) {
|
|
if ($binary[$i]) {
|
|
$ifindex = $i;
|
|
// FIXME $vlan_ifindex_map[$i]
|
|
$q_bridge_mib[$ifindex][] = $vlan_id;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}//end if
|
|
|
|
$polled = time();
|
|
|
|
// End Building SNMP Cache Array
|
|
if ($debug) {
|
|
print_r($port_stats);
|
|
}
|
|
|
|
// Build array of ports in the database
|
|
// FIXME -- this stuff is a little messy, looping the array to make an array just seems wrong. :>
|
|
// -- i can make it a function, so that you don't know what it's doing.
|
|
// -- $ports = adamasMagicFunction($ports_db); ?
|
|
$ports_db = dbFetchRows('SELECT * FROM `ports` WHERE `device_id` = ?', array($device['device_id']));
|
|
foreach ($ports_db as $port) {
|
|
$ports[$port['ifIndex']] = $port;
|
|
}
|
|
|
|
// New interface detection
|
|
foreach ($port_stats as $ifIndex => $port) {
|
|
if (is_port_valid($port, $device)) {
|
|
echo 'valid';
|
|
if (!is_array($ports[$port['ifIndex']])) {
|
|
$port_id = dbInsert(array('device_id' => $device['device_id'], 'ifIndex' => $ifIndex), 'ports');
|
|
$ports[$port['ifIndex']] = dbFetchRow('SELECT * FROM `ports` WHERE `port_id` = ?', array($port_id));
|
|
echo 'Adding: '.$port['ifName'].'('.$ifIndex.')('.$ports[$port['ifIndex']]['port_id'].')';
|
|
// print_r($ports);
|
|
}
|
|
else if ($ports[$ifIndex]['deleted'] == '1') {
|
|
dbUpdate(array('deleted' => '0'), 'ports', '`port_id` = ?', array($ports[$ifIndex]['port_id']));
|
|
$ports[$ifIndex]['deleted'] = '0';
|
|
}
|
|
}
|
|
else {
|
|
if ($ports[$port['ifIndex']]['deleted'] != '1') {
|
|
dbUpdate(array('deleted' => '1'), 'ports', '`port_id` = ?', array($ports[$ifIndex]['port_id']));
|
|
$ports[$ifIndex]['deleted'] = '1';
|
|
}
|
|
}
|
|
}
|
|
|
|
// End New interface detection
|
|
echo "\n";
|
|
// Loop ports in the DB and update where necessary
|
|
foreach ($ports as $port) {
|
|
echo 'Port '.$port['ifDescr'].'('.$port['ifIndex'].') ';
|
|
if ($port_stats[$port['ifIndex']] && $port['disabled'] != '1') {
|
|
// Check to make sure Port data is cached.
|
|
$this_port = &$port_stats[$port['ifIndex']];
|
|
|
|
if ($device['os'] == 'vmware' && preg_match('/Device ([a-z0-9]+) at .*/', $this_port['ifDescr'], $matches)) {
|
|
$this_port['ifDescr'] = $matches[1];
|
|
}
|
|
|
|
if ($config['memcached']['enable'] === true) {
|
|
$state = $memcache->get('port-'.$port['port_id'].'-state');
|
|
if ($debug) {
|
|
print_r($state);
|
|
}
|
|
|
|
if (is_array($state)) {
|
|
$port = array_merge($port, $state);
|
|
}
|
|
|
|
unset($state);
|
|
}
|
|
|
|
$polled_period = ($polled - $port['poll_time']);
|
|
|
|
$port['update'] = array();
|
|
$port['state'] = array();
|
|
|
|
if ($config['slow_statistics'] == true) {
|
|
$port['update']['poll_time'] = $polled;
|
|
$port['update']['poll_prev'] = $port['poll_time'];
|
|
$port['update']['poll_period'] = $polled_period;
|
|
}
|
|
|
|
if ($config['memcached']['enable'] === true) {
|
|
$port['state']['poll_time'] = $polled;
|
|
$port['state']['poll_prev'] = $port['poll_time'];
|
|
$port['state']['poll_period'] = $polled_period;
|
|
}
|
|
|
|
// Copy ifHC[In|Out]Octets values to non-HC if they exist
|
|
if ($this_port['ifHCInOctets'] > 0 && is_numeric($this_port['ifHCInOctets']) && $this_port['ifHCOutOctets'] > 0 && is_numeric($this_port['ifHCOutOctets'])) {
|
|
echo 'HC ';
|
|
$this_port['ifInOctets'] = $this_port['ifHCInOctets'];
|
|
$this_port['ifOutOctets'] = $this_port['ifHCOutOctets'];
|
|
}
|
|
|
|
// rewrite the ifPhysAddress
|
|
if (strpos($this_port['ifPhysAddress'], ':')) {
|
|
list($a_a, $a_b, $a_c, $a_d, $a_e, $a_f) = explode(':', $this_port['ifPhysAddress']);
|
|
$this_port['ifPhysAddress'] = zeropad($a_a).zeropad($a_b).zeropad($a_c).zeropad($a_d).zeropad($a_e).zeropad($a_f);
|
|
}
|
|
|
|
if (is_numeric($this_port['ifHCInBroadcastPkts']) && is_numeric($this_port['ifHCOutBroadcastPkts']) && is_numeric($this_port['ifHCInMulticastPkts']) && is_numeric($this_port['ifHCOutMulticastPkts'])) {
|
|
echo 'HC ';
|
|
$this_port['ifInBroadcastPkts'] = $this_port['ifHCInBroadcastPkts'];
|
|
$this_port['ifOutBroadcastPkts'] = $this_port['ifHCOutBroadcastPkts'];
|
|
$this_port['ifInMulticastPkts'] = $this_port['ifHCInMulticastPkts'];
|
|
$this_port['ifOutMulticastPkts'] = $this_port['ifHCOutMulticastPkts'];
|
|
}
|
|
|
|
// Overwrite ifSpeed with ifHighSpeed if it's over 1G
|
|
if (is_numeric($this_port['ifHighSpeed']) && $this_port['ifSpeed'] > '1000000000') {
|
|
echo 'HighSpeed ';
|
|
$this_port['ifSpeed'] = ($this_port['ifHighSpeed'] * 1000000);
|
|
}
|
|
|
|
// Overwrite ifDuplex with dot3StatsDuplexStatus if it exists
|
|
if (isset($this_port['dot3StatsDuplexStatus'])) {
|
|
echo 'dot3Duplex ';
|
|
$this_port['ifDuplex'] = $this_port['dot3StatsDuplexStatus'];
|
|
}
|
|
|
|
// Set VLAN and Trunk from Cisco
|
|
if (isset($this_port['vlanTrunkPortEncapsulationOperType']) && $this_port['vlanTrunkPortEncapsulationOperType'] != 'notApplicable') {
|
|
$this_port['ifTrunk'] = $this_port['vlanTrunkPortEncapsulationOperType'];
|
|
if (isset($this_port['vlanTrunkPortNativeVlan'])) {
|
|
$this_port['ifVlan'] = $this_port['vlanTrunkPortNativeVlan'];
|
|
}
|
|
}
|
|
|
|
if (isset($this_port['vmVlan'])) {
|
|
$this_port['ifVlan'] = $this_port['vmVlan'];
|
|
}
|
|
|
|
// Set VLAN and Trunk from Q-BRIDGE-MIB
|
|
if (!isset($this_port['ifVlan']) && isset($this_port['dot1qPvid'])) {
|
|
$this_port['ifVlan'] = $this_port['dot1qPvid'];
|
|
}
|
|
|
|
// FIXME use $q_bridge_mib[$this_port['ifIndex']] to see if it is a trunk (>1 array count)
|
|
echo 'VLAN == '.$this_port['ifVlan'];
|
|
|
|
// Update IF-MIB data
|
|
foreach ($data_oids as $oid) {
|
|
if ($port[$oid] != $this_port[$oid] && !isset($this_port[$oid])) {
|
|
$port['update'][$oid] = array('NULL');
|
|
log_event($oid.': '.$port[$oid].' -> NULL', $device, 'interface', $port['port_id']);
|
|
if ($debug) {
|
|
echo $oid.': '.$port[$oid].' -> NULL ';
|
|
}
|
|
else {
|
|
echo $oid.' ';
|
|
}
|
|
}
|
|
else if ($port[$oid] != $this_port[$oid]) {
|
|
$port['update'][$oid] = $this_port[$oid];
|
|
log_event($oid.': '.$port[$oid].' -> '.$this_port[$oid], $device, 'interface', $port['port_id']);
|
|
if ($debug) {
|
|
echo $oid.': '.$port[$oid].' -> '.$this_port[$oid].' ';
|
|
}
|
|
else {
|
|
echo $oid.' ';
|
|
}
|
|
}
|
|
|
|
if (( $oid == 'ifOperStatus' || $oid == 'ifAdminStatus' ) && $this_port[$oid] == 'down') {
|
|
break;
|
|
}
|
|
}//end foreach
|
|
|
|
if (($port['update']['ifAlias'] == '' || $port['update']['ifAlias'] == NULL) && $config['os'][$os]['ifalias_null'] == 1) {
|
|
$port['update']['ifAlias'] = $port['ifDescr'];
|
|
d_echo('Using ifDescr due to ifAlias being NULL');
|
|
}
|
|
|
|
// Parse description (usually ifAlias) if config option set
|
|
if (isset($config['port_descr_parser']) && is_file($config['install_dir'].'/'.$config['port_descr_parser'])) {
|
|
$port_attribs = array(
|
|
'type',
|
|
'descr',
|
|
'circuit',
|
|
'speed',
|
|
'notes',
|
|
);
|
|
|
|
include $config['install_dir'].'/'.$config['port_descr_parser'];
|
|
|
|
foreach ($port_attribs as $attrib) {
|
|
$attrib_key = 'port_descr_'.$attrib;
|
|
if ($port_ifAlias[$attrib] != $port[$attrib_key]) {
|
|
if (!isset($port_ifAlias[$attrib])) {
|
|
$port_ifAlias[$attrib] = array('NULL');
|
|
$log_port = 'NULL';
|
|
}
|
|
else {
|
|
$log_port = $port_ifAlias[$attrib];
|
|
}
|
|
|
|
$port['update'][$attrib_key] = $port_ifAlias[$attrib];
|
|
log_event($attrib.': '.$port[$attrib_key].' -> '.$log_port, $device, 'interface', $port['port_id']);
|
|
unset($log_port);
|
|
}
|
|
}
|
|
}//end if
|
|
|
|
// End parse ifAlias
|
|
// Update IF-MIB metrics
|
|
foreach ($stat_oids_db as $oid) {
|
|
if ($config['slow_statistics'] == true) {
|
|
$port['update'][$oid] = $this_port[$oid];
|
|
$port['update'][$oid.'_prev'] = $port[$oid];
|
|
}
|
|
|
|
if ($config['memcached']['enable'] === true) {
|
|
$port['state'][$oid] = $this_port[$oid];
|
|
$port['state'][$oid.'_prev'] = $port[$oid];
|
|
}
|
|
|
|
$oid_prev = $oid.'_prev';
|
|
if (isset($port[$oid])) {
|
|
$oid_diff = ($this_port[$oid] - $port[$oid]);
|
|
$oid_rate = ($oid_diff / $polled_period);
|
|
if ($oid_rate < 0) {
|
|
$oid_rate = '0';
|
|
echo "negative $oid";
|
|
}
|
|
|
|
$port['stats'][$oid.'_rate'] = $oid_rate;
|
|
$port['stats'][$oid.'_diff'] = $oid_diff;
|
|
|
|
if ($config['slow_statistics'] == true) {
|
|
$port['update'][$oid.'_rate'] = $oid_rate;
|
|
$port['update'][$oid.'_delta'] = $oid_diff;
|
|
}
|
|
|
|
if ($config['memcached']['enable'] === true) {
|
|
$port['state'][$oid.'_rate'] = $oid_rate;
|
|
$port['state'][$oid.'_delta'] = $oid_diff;
|
|
}
|
|
|
|
if ($debug) {
|
|
echo "\n $oid ($oid_diff B) $oid_rate Bps $polled_period secs\n";
|
|
}
|
|
}//end if
|
|
}//end foreach
|
|
|
|
if ($config['debug_port'][$port['port_id']]) {
|
|
$port_debug = $port['port_id'].'|'.$polled.'|'.$polled_period.'|'.$this_port['ifHCInOctets'].'|'.$this_port['ifHCOutOctets'];
|
|
$port_debug .= '|'.$port['stats']['ifInOctets_rate'].'|'.$port['stats']['ifOutOctets_rate']."\n";
|
|
file_put_contents('/tmp/port_debug.txt', $port_debug, FILE_APPEND);
|
|
echo 'Wrote port debugging data';
|
|
}
|
|
|
|
$port['stats']['ifInBits_rate'] = round(($port['stats']['ifInOctets_rate'] * 8));
|
|
$port['stats']['ifOutBits_rate'] = round(($port['stats']['ifOutOctets_rate'] * 8));
|
|
|
|
// If we have a valid ifSpeed we should populate the stats for checking.
|
|
if (is_numeric($this_port['ifSpeed'])) {
|
|
$port['stats']['ifInBits_perc'] = round(($port['stats']['ifInBits_rate'] / $this_port['ifSpeed'] * 100));
|
|
$port['stats']['ifOutBits_perc'] = round(($port['stats']['ifOutBits_rate'] / $this_port['ifSpeed'] * 100));
|
|
}
|
|
|
|
echo 'bps('.formatRates($port['stats']['ifInBits_rate']).'/'.formatRates($port['stats']['ifOutBits_rate']).')';
|
|
echo 'bytes('.formatStorage($port['stats']['ifInOctets_diff']).'/'.formatStorage($port['stats']['ifOutOctets_diff']).')';
|
|
echo 'pkts('.format_si($port['stats']['ifInUcastPkts_rate']).'pps/'.format_si($port['stats']['ifOutUcastPkts_rate']).'pps)';
|
|
|
|
// Store aggregate in/out state
|
|
if ($config['memcached']['enable'] === true) {
|
|
$port['state']['ifOctets_rate'] = ($port['stats']['ifOutOctets_rate'] + $port['stats']['ifInOctets_rate']);
|
|
$port['state']['ifUcastPkts_rate'] = ($port['stats']['ifOutUcastPkts_rate'] + $port['stats']['ifInUcastPkts_rate']);
|
|
$port['state']['ifErrors_rate'] = ($port['stats']['ifOutErrors_rate'] + $port['stats']['ifInErrors_rate']);
|
|
}
|
|
|
|
// Port utilisation % threshold alerting. // FIXME allow setting threshold per-port. probably 90% of ports we don't care about.
|
|
if ($config['alerts']['port_util_alert'] && $port['ignore'] == '0') {
|
|
// Check for port saturation of $config['alerts']['port_util_perc'] or higher. Alert if we see this.
|
|
// Check both inbound and outbound rates
|
|
$saturation_threshold = ($this_port['ifSpeed'] * ( $config['alerts']['port_util_perc'] / 100 ));
|
|
echo 'IN: '.$port['stats']['ifInBits_rate'].' OUT: '.$port['stats']['ifOutBits_rate'].' THRESH: '.$saturation_threshold;
|
|
if (($port['stats']['ifInBits_rate'] >= $saturation_threshold || $port['stats']['ifOutBits_rate'] >= $saturation_threshold) && $saturation_threshold > 0) {
|
|
log_event('Port reached saturation threshold: '.formatRates($port['stats']['ifInBits_rate']).'/'.formatRates($port['stats']['ifOutBits_rate']).' - ifspeed: '.formatRates($this_port['stats']['ifSpeed']), $device, 'interface', $port['port_id']);
|
|
}
|
|
}
|
|
|
|
// Update RRDs
|
|
$rrdfile = $host_rrd.'/port-'.safename($port['ifIndex'].'.rrd');
|
|
if (!is_file($rrdfile)) {
|
|
rrdtool_create(
|
|
$rrdfile,
|
|
' --step 300 \
|
|
DS:INOCTETS:DERIVE:600:0:12500000000 \
|
|
DS:OUTOCTETS:DERIVE:600:0:12500000000 \
|
|
DS:INERRORS:DERIVE:600:0:12500000000 \
|
|
DS:OUTERRORS:DERIVE:600:0:12500000000 \
|
|
DS:INUCASTPKTS:DERIVE:600:0:12500000000 \
|
|
DS:OUTUCASTPKTS:DERIVE:600:0:12500000000 \
|
|
DS:INNUCASTPKTS:DERIVE:600:0:12500000000 \
|
|
DS:OUTNUCASTPKTS:DERIVE:600:0:12500000000 \
|
|
DS:INDISCARDS:DERIVE:600:0:12500000000 \
|
|
DS:OUTDISCARDS:DERIVE:600:0:12500000000 \
|
|
DS:INUNKNOWNPROTOS:DERIVE:600:0:12500000000 \
|
|
DS:INBROADCASTPKTS:DERIVE:600:0:12500000000 \
|
|
DS:OUTBROADCASTPKTS:DERIVE:600:0:12500000000 \
|
|
DS:INMULTICASTPKTS:DERIVE:600:0:12500000000 \
|
|
DS:OUTMULTICASTPKTS:DERIVE:600:0:12500000000 '.$config['rrd_rra']
|
|
);
|
|
}//end if
|
|
|
|
$this_port['rrd_update'] = array(
|
|
$this_port['ifInOctets'],
|
|
$this_port['ifOutOctets'],
|
|
$this_port['ifInErrors'],
|
|
$this_port['ifOutErrors'],
|
|
$this_port['ifInUcastPkts'],
|
|
$this_port['ifOutUcastPkts'],
|
|
$this_port['ifInNUcastPkts'],
|
|
$this_port['ifOutNUcastPkts'],
|
|
$this_port['ifInDiscards'],
|
|
$this_port['ifOutDiscards'],
|
|
$this_port['ifInUnknownProtos'],
|
|
$this_port['ifInBroadcastPkts'],
|
|
$this_port['ifOutBroadcastPkts'],
|
|
$this_port['ifInMulticastPkts'],
|
|
$this_port['ifOutMulticastPkts'],
|
|
);
|
|
|
|
rrdtool_update("$rrdfile", $this_port['rrd_update']);
|
|
// End Update IF-MIB
|
|
// Update PAgP
|
|
if ($this_port['pagpOperationMode'] || $port['pagpOperationMode']) {
|
|
foreach ($pagp_oids as $oid) {
|
|
// Loop the OIDs
|
|
if ($this_port[$oid] != $port[$oid]) {
|
|
// If data has changed, build a query
|
|
$port['update'][$oid] = $this_port[$oid];
|
|
echo 'PAgP ';
|
|
log_event("$oid -> ".$this_port[$oid], $device, 'interface', $port['port_id']);
|
|
}
|
|
}
|
|
}
|
|
|
|
// End Update PAgP
|
|
// Do EtherLike-MIB
|
|
if ($config['enable_ports_etherlike']) {
|
|
include 'port-etherlike.inc.php';
|
|
}
|
|
|
|
// Do ADSL MIB
|
|
if ($config['enable_ports_adsl']) {
|
|
include 'port-adsl.inc.php';
|
|
}
|
|
|
|
// Do PoE MIBs
|
|
if ($config['enable_ports_poe']) {
|
|
include 'port-poe.inc.php';
|
|
}
|
|
|
|
// Do Alcatel Detailed Stats
|
|
if ($device['os'] == 'aos') {
|
|
include 'port-alcatel.inc.php';
|
|
}
|
|
|
|
// Update Memcached
|
|
if ($config['memcached']['enable'] === true) {
|
|
if ($debug) {
|
|
print_r($port['state']);
|
|
}
|
|
|
|
$memcache->set('port-'.$port['port_id'].'-state', $port['state']);
|
|
}
|
|
|
|
foreach ($port['update'] as $key => $val_check) {
|
|
if (!isset($val_check)) {
|
|
unset($port['update'][$key]);
|
|
}
|
|
}
|
|
|
|
// Update Database
|
|
if (count($port['update'])) {
|
|
$updated = dbUpdate($port['update'], 'ports', '`port_id` = ?', array($port['port_id']));
|
|
if ($debug) {
|
|
echo "$updated updated";
|
|
}
|
|
}
|
|
|
|
// End Update Database
|
|
}
|
|
else if ($port['disabled'] != '1') {
|
|
echo 'Port Deleted';
|
|
// Port missing from SNMP cache.
|
|
if ($port['deleted'] != '1') {
|
|
dbUpdate(array('deleted' => '1'), 'ports', '`device_id` = ? AND `ifIndex` = ?', array($device['device_id'], $port['ifIndex']));
|
|
}
|
|
}
|
|
else {
|
|
echo 'Port Disabled.';
|
|
}//end if
|
|
|
|
echo "\n";
|
|
|
|
// Clear Per-Port Variables Here
|
|
unset($this_port);
|
|
}//end foreach
|
|
|
|
// Clear Variables Here
|
|
unset($port_stats);
|