mirror of
https://github.com/librenms/librenms.git
synced 2024-10-07 16:52:45 +00:00
b56c6b6adf
Fix missing IPs because the ARP entries are on different port_id Update arp discovery to use snmpwalk_group() additional fix in that function Fix removal of arp entries Fix a debug output type in fdb discovery
132 lines
4.7 KiB
PHP
132 lines
4.7 KiB
PHP
<?php
|
|
/**
|
|
* arp-table.php
|
|
*
|
|
* Collect arp table entries from devices and update the database
|
|
*
|
|
* 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.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* @package LibreNMS
|
|
* @link http://librenms.org
|
|
* @copyright 2016 Tony Murray
|
|
* @author Tony Murray <murraytony@gmail.com>
|
|
*/
|
|
|
|
if (key_exists('vrf_lite_cisco', $device) && (count($device['vrf_lite_cisco'])!=0)) {
|
|
$vrfs_lite_cisco = $device['vrf_lite_cisco'];
|
|
} else {
|
|
$vrfs_lite_cisco = array(array('context_name'=>null));
|
|
}
|
|
|
|
foreach ($vrfs_lite_cisco as $vrf) {
|
|
$context = $vrf['context_name'];
|
|
$device['context_name']=$context;
|
|
|
|
$arp_data = snmpwalk_group($device, 'ipNetToPhysicalPhysAddress', 'IP-MIB');
|
|
$arp_data = snmpwalk_group($device, 'ipNetToMediaPhysAddress', 'IP-MIB', 1, $arp_data);
|
|
|
|
$existing_data = dbFetchRows(
|
|
"SELECT * from `ipv4_mac` WHERE `device_id`=? AND `context_name`=?",
|
|
array($device['device_id'], $context)
|
|
);
|
|
$ipv4_addresses = array_map(function ($data) {
|
|
return $data['ipv4_address'];
|
|
}, $existing_data);
|
|
|
|
$arp_table = array();
|
|
$insert_data = array();
|
|
foreach ($arp_data as $ifIndex => $data) {
|
|
$interface = get_port_by_index_cache($device['device_id'], $ifIndex);
|
|
$port_id = $interface['port_id'];
|
|
|
|
$port_arp = array_merge(
|
|
(array)$data['ipNetToMediaPhysAddress'],
|
|
(array)$data['ipNetToPhysicalPhysAddress']['ipv4']
|
|
);
|
|
|
|
echo "{$interface['ifName']}: \n";
|
|
foreach ($port_arp as $ip => $raw_mac) {
|
|
if (empty($ip) || empty($raw_mac) || $raw_mac == '0:0:0:0:0:0' || isset($arp_table[$port_id][$ip])) {
|
|
continue;
|
|
}
|
|
|
|
$mac = implode(array_map('zeropad', explode(':', $raw_mac)));
|
|
$arp_table[$port_id][$ip] = $mac;
|
|
|
|
$index = array_search($ip, $ipv4_addresses);
|
|
if ($index !== false) {
|
|
$old_mac = $existing_data[$index]['mac_address'];
|
|
if ($mac != $old_mac && $mac != '') {
|
|
d_echo("Changed mac address for $ip from $old_mac to $mac\n");
|
|
log_event("MAC change: $ip : " . mac_clean_to_readable($old_mac) . ' -> ' . mac_clean_to_readable($mac), $device, 'interface', 4, $port_id);
|
|
dbUpdate(array('mac_address' => $mac), 'ipv4_mac', 'port_id=? AND ipv4_address=? AND context_name=?', array($port_id, $ip, $context));
|
|
}
|
|
d_echo("$raw_mac => $ip\n", '.');
|
|
} elseif (isset($interface['port_id'])) {
|
|
d_echo("$raw_mac => $ip\n", '+');
|
|
$insert_data[] = array(
|
|
'port_id' => $port_id,
|
|
'device_id' => $device['device_id'],
|
|
'mac_address' => $mac,
|
|
'ipv4_address' => $ip,
|
|
'context_name' => $context,
|
|
);
|
|
}
|
|
}
|
|
echo PHP_EOL;
|
|
}
|
|
|
|
unset(
|
|
$interface,
|
|
$arp_data,
|
|
$ipv4_addresses,
|
|
$data
|
|
);
|
|
|
|
// add new entries
|
|
if (!empty($insert_data)) {
|
|
dbBulkInsert($insert_data, 'ipv4_mac');
|
|
}
|
|
|
|
// remove stale entries
|
|
foreach ($existing_data as $entry) {
|
|
$entry_mac = $entry['mac_address'];
|
|
$entry_if = $entry['port_id'];
|
|
$entry_ip = $entry['ipv4_address'];
|
|
if ($arp_table[$entry_if][$entry_ip] != $entry_mac) {
|
|
dbDelete('ipv4_mac', '`port_id` = ? AND `mac_address`=? AND `ipv4_address`=? AND `context_name`=?', array($entry_if, $entry_mac, $entry_ip, $context));
|
|
d_echo(null, '-');
|
|
}
|
|
}
|
|
|
|
// remove entries that no longer have an owner
|
|
dbQuery('DELETE `ipv4_mac` FROM `ipv4_mac`
|
|
LEFT JOIN `ports` ON `ipv4_mac`.`port_id` = `ports`.`port_id`
|
|
LEFT JOIN `devices` ON `ipv4_mac`.`device_id` = `devices`.`device_id`
|
|
WHERE `ports`.`port_id` IS NULL OR `devices`.`device_id` IS NULL');
|
|
|
|
echo PHP_EOL;
|
|
unset(
|
|
$existing_data,
|
|
$arp_table,
|
|
$insert_data,
|
|
$sql,
|
|
$params,
|
|
$context,
|
|
$entry,
|
|
$device['context_name']
|
|
);
|
|
}
|
|
unset($vrfs_lite_cisco);
|