mirror of
https://github.com/librenms/librenms.git
synced 2024-10-07 16:52:45 +00:00
a4388e6010
* fix: Fixed ospf polling not removing stale data * Fixed arrays * Fix port_id check for neighbors
411 lines
17 KiB
PHP
411 lines
17 KiB
PHP
<?php
|
|
|
|
use LibreNMS\RRD\RrdDefinition;
|
|
|
|
$ospf_instance_count = 0;
|
|
$ospf_port_count = 0;
|
|
$ospf_area_count = 0;
|
|
$ospf_neighbour_count = 0;
|
|
|
|
$ospf_oids_db = array(
|
|
'ospfRouterId',
|
|
'ospfAdminStat',
|
|
'ospfVersionNumber',
|
|
'ospfAreaBdrRtrStatus',
|
|
'ospfASBdrRtrStatus',
|
|
'ospfExternLsaCount',
|
|
'ospfExternLsaCksumSum',
|
|
'ospfTOSSupport',
|
|
'ospfOriginateNewLsas',
|
|
'ospfRxNewLsas',
|
|
'ospfExtLsdbLimit',
|
|
'ospfMulticastExtensions',
|
|
'ospfExitOverflowInterval',
|
|
'ospfDemandExtensions',
|
|
);
|
|
|
|
$ospf_area_oids = array(
|
|
'ospfAuthType',
|
|
'ospfImportAsExtern',
|
|
'ospfSpfRuns',
|
|
'ospfAreaBdrRtrCount',
|
|
'ospfAsBdrRtrCount',
|
|
'ospfAreaLsaCount',
|
|
'ospfAreaLsaCksumSum',
|
|
'ospfAreaSummary',
|
|
'ospfAreaStatus',
|
|
);
|
|
|
|
$ospf_port_oids = array(
|
|
'ospfIfIpAddress',
|
|
'port_id',
|
|
'ospfAddressLessIf',
|
|
'ospfIfAreaId',
|
|
'ospfIfType',
|
|
'ospfIfAdminStat',
|
|
'ospfIfRtrPriority',
|
|
'ospfIfTransitDelay',
|
|
'ospfIfRetransInterval',
|
|
'ospfIfHelloInterval',
|
|
'ospfIfRtrDeadInterval',
|
|
'ospfIfPollInterval',
|
|
'ospfIfState',
|
|
'ospfIfDesignatedRouter',
|
|
'ospfIfBackupDesignatedRouter',
|
|
'ospfIfEvents',
|
|
'ospfIfAuthKey',
|
|
'ospfIfStatus',
|
|
'ospfIfMulticastForwarding',
|
|
'ospfIfDemand',
|
|
'ospfIfAuthType',
|
|
);
|
|
|
|
$ospf_nbr_oids_db = array(
|
|
'ospfNbrIpAddr',
|
|
'ospfNbrAddressLessIndex',
|
|
'ospfNbrRtrId',
|
|
'ospfNbrOptions',
|
|
'ospfNbrPriority',
|
|
'ospfNbrState',
|
|
'ospfNbrEvents',
|
|
'ospfNbrLsRetransQLen',
|
|
'ospfNbmaNbrStatus',
|
|
'ospfNbmaNbrPermanence',
|
|
'ospfNbrHelloSuppressed',
|
|
);
|
|
|
|
$ospf_nbr_oids_rrd = array();
|
|
$ospf_nbr_oids = array_merge($ospf_nbr_oids_db, $ospf_nbr_oids_rrd);
|
|
|
|
if (key_exists('vrf_lite_cisco', $device) && ($device['vrf_lite_cisco'] != '')) {
|
|
$vrfs_lite_cisco = $device['vrf_lite_cisco'];
|
|
} else {
|
|
$vrfs_lite_cisco = array(array('context_name' => null));
|
|
}
|
|
|
|
foreach ($vrfs_lite_cisco as $vrf_lite) {
|
|
$device['context_name'] = $vrf_lite['context_name'];
|
|
|
|
echo 'Processes: ';
|
|
|
|
// Build array of existing entries
|
|
foreach (dbFetchRows('SELECT * FROM `ospf_instances` WHERE `device_id` = ? AND `context_name` = ?', array($device['device_id'], $device['context_name'])) as $entry) {
|
|
$ospf_instances_db[$entry['ospf_instance_id']][$entry['context_name']] = $entry;
|
|
}
|
|
|
|
// Pull data from device
|
|
$ospf_instances_poll = snmpwalk_cache_oid($device, 'OSPF-MIB::ospfGeneralGroup', array(), 'OSPF-MIB');
|
|
foreach ($ospf_instances_poll as $ospf_instance_id => $ospf_entry) {
|
|
// If the entry doesn't already exist in the prebuilt array, insert into the database and put into the array
|
|
if (empty($ospf_instances_db[$ospf_instance_id][$device['context_name']])) {
|
|
$tmp_insert = array(
|
|
'device_id' => $device['device_id'],
|
|
'ospf_instance_id' => $ospf_instance_id,
|
|
'context_name' => $device['context_name'],
|
|
);
|
|
foreach ($ospf_oids_db as $oid_db) {
|
|
$tmp_insert[$oid_db] = $ospf_entry[$oid_db];
|
|
}
|
|
dbInsert($tmp_insert, 'ospf_instances');
|
|
unset($tmp_insert);
|
|
echo '+';
|
|
$entry = dbFetchRow('SELECT * FROM `ospf_instances` WHERE `device_id` = ? AND `ospf_instance_id` = ? AND `context_name` = ?', array($device['device_id'], $ospf_instance_id, $device['context_name']));
|
|
$ospf_instances_db[$ospf_instance_id][$device['context_name']] = $entry;
|
|
}
|
|
}
|
|
|
|
d_echo("\nPolled: ");
|
|
d_echo($ospf_instances_poll);
|
|
d_echo('Database: ');
|
|
d_echo($ospf_instances_db);
|
|
|
|
// Loop array of entries and update
|
|
if (is_array($ospf_instances_db)) {
|
|
foreach ($ospf_instances_db as $ospf_instance_id => $ospf_instance_db) {
|
|
$ospf_instance_db = array_shift($ospf_instance_db);
|
|
if (is_array($ospf_instances_poll[$ospf_instance_id])) {
|
|
$ospf_instance_poll = $ospf_instances_poll[$ospf_instance_id];
|
|
foreach ($ospf_oids_db as $oid) {
|
|
// Loop the OIDs
|
|
if ($ospf_instance_db[$oid] != $ospf_instance_poll[$oid]) {
|
|
// If data has changed, build a query
|
|
$ospf_instance_update[$oid] = $ospf_instance_poll[$oid];
|
|
// log_event("$oid -> ".$this_port[$oid], $device, 'ospf', $port['port_id']); // FIXME
|
|
}
|
|
}
|
|
|
|
if ($ospf_instance_update) {
|
|
dbUpdate($ospf_instance_update, 'ospf_instances', '`device_id` = ? AND `ospf_instance_id` = ? AND `context_name`=? ', array($device['device_id'], $ospf_instance_id, $device['context_name']));
|
|
echo 'U';
|
|
unset($ospf_instance_update);
|
|
} else {
|
|
echo '.';
|
|
}
|
|
|
|
unset($ospf_instance_poll);
|
|
unset($ospf_instance_db);
|
|
$ospf_instance_count++;
|
|
} else {
|
|
dbDelete('ospf_instances', '`device_id` = ? AND `ospf_instance_id` = ? AND `context_name`=? ', array($device['device_id'], $ospf_area_db['ospfAreaId'], $device['context_name']));
|
|
}
|
|
}//end foreach
|
|
}//end if
|
|
unset($ospf_instances_poll);
|
|
unset($ospf_instances_db);
|
|
|
|
echo ' Areas: ';
|
|
|
|
// Build array of existing entries
|
|
foreach (dbFetchRows('SELECT * FROM `ospf_areas` WHERE `device_id` = ? AND `context_name`= ?', array($device['device_id'], $device['context_name'])) as $entry) {
|
|
$ospf_areas_db[$entry['ospfAreaId']][$entry['context_name']] = $entry;
|
|
}
|
|
|
|
// Pull data from device
|
|
$ospf_areas_poll = snmpwalk_cache_oid($device, 'OSPF-MIB::ospfAreaEntry', array(), 'OSPF-MIB');
|
|
|
|
foreach ($ospf_areas_poll as $ospf_area_id => $ospf_area) {
|
|
// If the entry doesn't already exist in the prebuilt array, insert into the database and put into the array
|
|
if (empty($ospf_areas_db[$ospf_area_id][$device['context_name']])) {
|
|
$tmp_insert = array('device_id' => $device['device_id'], 'ospfAreaId' => $ospf_area_id, 'context_name' => $device['context_name']);
|
|
foreach ($ospf_area_oids as $oid_db) {
|
|
$tmp_insert[$oid_db] = $ospf_area[$oid_db];
|
|
}
|
|
dbInsert($tmp_insert, 'ospf_areas');
|
|
unset($tmp_insert);
|
|
echo '+';
|
|
$entry = dbFetchRows('SELECT * FROM `ospf_areas` WHERE `device_id` = ? AND `ospfAreaId` = ? AND `context_name` = ?', array($device['device_id'], $ospf_area_id, $device['context_name']));
|
|
$ospf_areas_db[$ospf_area_id][$device['context_name']] = $entry;
|
|
}
|
|
}
|
|
|
|
d_echo("\nPolled: ");
|
|
d_echo($ospf_areas_poll);
|
|
d_echo('Database: ');
|
|
d_echo($ospf_areas_db);
|
|
|
|
// Loop array of entries and update
|
|
if (is_array($ospf_areas_db)) {
|
|
foreach ($ospf_areas_db as $ospf_area_id => $ospf_area_db) {
|
|
$ospf_area_db = array_shift($ospf_area_db);
|
|
if (is_array($ospf_areas_poll[$ospf_area_id])) {
|
|
$ospf_area_poll = $ospf_areas_poll[$ospf_area_id];
|
|
foreach ($ospf_area_oids as $oid) {
|
|
// Loop the OIDs
|
|
if ($ospf_area_db[$oid] != $ospf_area_poll[$oid]) {
|
|
// If data has changed, build a query
|
|
$ospf_area_update[$oid] = $ospf_area_poll[$oid];
|
|
// log_event("$oid -> ".$this_port[$oid], $device, 'interface', $port['port_id']); // FIXME
|
|
}
|
|
}
|
|
|
|
if ($ospf_area_update) {
|
|
dbUpdate($ospf_area_update, 'ospf_areas', '`device_id` = ? AND `ospfAreaId` = ? AND `context_name` = ?', array($device['device_id'], $ospf_area_id, $device['context_name']));
|
|
echo 'U';
|
|
unset($ospf_area_update);
|
|
} else {
|
|
echo '.';
|
|
}
|
|
|
|
unset($ospf_area_poll);
|
|
unset($ospf_area_db);
|
|
$ospf_area_count++;
|
|
} else {
|
|
dbDelete('ospf_ports', '`device_id` = ? AND `ospfIfAreaId` = ? AND `context_name` = ?', array($device['device_id'], $ospf_area_db['ospfAreaId'], $device['context_name']));
|
|
}//end if
|
|
}//end foreach
|
|
}//end if
|
|
|
|
unset($ospf_areas_db);
|
|
unset($ospf_areas_poll);
|
|
|
|
|
|
// $ospf_ports = snmpwalk_cache_oid($device, "OSPF-MIB::ospfIfEntry", array(), "OSPF-MIB");
|
|
// print_r($ospf_ports);
|
|
echo ' Ports: ';
|
|
|
|
// Build array of existing entries
|
|
foreach (dbFetchRows('SELECT * FROM `ospf_ports` WHERE `device_id` = ? AND `context_name` = ?', array($device['device_id'], $device['context_name'])) as $entry) {
|
|
$ospf_ports_db[$entry['ospf_port_id']][$device['context_name']] = $entry;
|
|
}
|
|
|
|
// Pull data from device
|
|
$ospf_ports_poll = snmpwalk_cache_oid($device, 'OSPF-MIB::ospfIfEntry', array(), 'OSPF-MIB');
|
|
|
|
foreach ($ospf_ports_poll as $ospf_port_id => $ospf_port) {
|
|
// If the entry doesn't already exist in the prebuilt array, insert into the database and put into the array
|
|
if (empty($ospf_ports_db[$ospf_port_id][$device['context_name']])) {
|
|
$tmp_insert = array('device_id' => $device['device_id'], 'ospf_port_id' => $ospf_port_id, 'context_name' => $device['context_name']);
|
|
foreach ($ospf_port_oids as $oid_db) {
|
|
$tmp_insert[$oid_db] = $ospf_port[$oid_db];
|
|
}
|
|
// Set port_id temporarily for mysql strict mode
|
|
$tmp_insert['port_id'] = 0;
|
|
dbInsert($tmp_insert, 'ospf_ports');
|
|
unset($tmp_insert);
|
|
echo '+';
|
|
$ospf_ports_db[$ospf_port_id][$device['context_name']] = dbFetchRow('SELECT * FROM `ospf_ports` WHERE `device_id` = ? AND `ospf_port_id` = ? AND `context_name` = ?', array($device['device_id'], $ospf_port_id, $device['context_name']));
|
|
}
|
|
}
|
|
|
|
d_echo("\nPolled: ");
|
|
d_echo($ospf_ports_poll);
|
|
d_echo('Database: ');
|
|
d_echo($ospf_ports_db);
|
|
|
|
// Loop array of entries and update
|
|
if (is_array($ospf_ports_db)) {
|
|
foreach ($ospf_ports_db as $ospf_port_id => $ospf_port_db) {
|
|
$ospf_port_db = array_shift($ospf_port_db);
|
|
if (is_array($ospf_ports_poll[$ospf_port_id])) {
|
|
$ospf_port_poll = $ospf_ports_poll[$ospf_port_id];
|
|
|
|
if ($ospf_port_poll['ospfAddressLessIf']) {
|
|
$ospf_port_poll['port_id'] = @dbFetchCell('SELECT `port_id` FROM `ports` WHERE `device_id` = ? AND `ifIndex` = ?', array($device['device_id'], $ospf_port_poll['ospfAddressLessIf']));
|
|
} else {
|
|
$ospf_port_poll['port_id'] = @dbFetchCell('SELECT A.`port_id` FROM ipv4_addresses AS A, ports AS I WHERE A.ipv4_address = ? AND I.port_id = A.port_id AND I.device_id = ? AND A.context_name = ?', array($ospf_port_poll['ospfIfIpAddress'], $device['device_id'], $device['context_name']));
|
|
}
|
|
|
|
foreach ($ospf_port_oids as $oid) {
|
|
// Loop the OIDs
|
|
if ($ospf_port_db[$oid] != $ospf_port_poll[$oid]) {
|
|
// If data has changed, build a query
|
|
$ospf_port_update[$oid] = $ospf_port_poll[$oid];
|
|
// log_event("$oid -> ".$this_port[$oid], $device, 'ospf', $port['port_id']); // FIXME
|
|
}
|
|
}
|
|
|
|
if ($ospf_port_update) {
|
|
dbUpdate($ospf_port_update, 'ospf_ports', '`device_id` = ? AND `ospf_port_id` = ? AND `context_name` = ?', array($device['device_id'], $ospf_port_id, $device['context_name']));
|
|
echo 'U';
|
|
unset($ospf_port_update);
|
|
} else {
|
|
echo '.';
|
|
}
|
|
|
|
unset($ospf_port_poll);
|
|
unset($ospf_port_db);
|
|
$ospf_port_count++;
|
|
} else {
|
|
dbDelete('ospf_ports', '`device_id` = ? AND `ospf_port_id` = ? AND `context_name` = ?', array($device['device_id'], $ospf_port_db['ospf_port_id'], $device['context_name']));
|
|
// ("DELETE FROM `ospf_ports` WHERE `device_id` = '".$device['device_id']."' AND `ospf_port_id` = '".$ospf_port_db['ospf_port_id']."'");
|
|
echo '-';
|
|
}//end if
|
|
}//end foreach
|
|
}//end if
|
|
unset($ospf_ports_poll);
|
|
|
|
echo ' Neighbours: ';
|
|
|
|
// Build array of existing entries
|
|
foreach (dbFetchRows('SELECT * FROM `ospf_nbrs` WHERE `device_id` = ? AND `context_name` = ?', array($device['device_id'], $device['context_name'])) as $nbr_entry) {
|
|
$ospf_nbrs_db[$nbr_entry['ospf_nbr_id']][$device['context_name']] = $nbr_entry;
|
|
}
|
|
|
|
// Pull data from device
|
|
$ospf_nbrs_poll = snmpwalk_cache_oid($device, 'OSPF-MIB::ospfNbrEntry', array(), 'OSPF-MIB');
|
|
|
|
foreach ($ospf_nbrs_poll as $ospf_nbr_id => $ospf_nbr) {
|
|
// If the entry doesn't already exist in the prebuilt array, insert into the database and put into the array
|
|
if (!isset($ospf_nbrs_db[$ospf_nbr_id][$device['context_name']])) {
|
|
$tmp_insert = array('device_id' => $device['device_id'], 'port_id' => 0, 'ospf_nbr_id' => $ospf_nbr_id, 'context_name' => $device['context_name']);
|
|
foreach ($ospf_nbr_oids_db as $oid_db) {
|
|
$tmp_insert[$oid_db] = $ospf_nbr[$oid_db];
|
|
}
|
|
dbInsert($tmp_insert, 'ospf_nbrs');
|
|
unset($tmp_insert);
|
|
echo '+';
|
|
$entry = dbFetchRow('SELECT * FROM `ospf_nbrs` WHERE `device_id` = ? AND `ospf_nbr_id` = ? AND `context_name` = ?', array($device['device_id'], $ospf_nbr_id,$device['context_name']));
|
|
$ospf_nbrs_db[$ospf_nbr_id][$device['context_name']] = $entry;
|
|
}
|
|
}
|
|
|
|
d_echo("\nPolled: ");
|
|
d_echo($ospf_nbrs_poll);
|
|
d_echo('Database: ');
|
|
d_echo($ospf_nbrs_db);
|
|
|
|
// Loop array of entries and update
|
|
if (is_array($ospf_nbrs_db)) {
|
|
foreach ($ospf_nbrs_db as $ospf_nbr_id => $ospf_nbr_db) {
|
|
$ospf_nbr_db = array_shift($ospf_nbr_db);
|
|
if (is_array($ospf_nbrs_poll[$ospf_nbr_id])) {
|
|
$ospf_nbr_poll = $ospf_nbrs_poll[$ospf_nbr_id];
|
|
|
|
$ospf_nbr_poll['port_id'] = (int)dbFetchCell('SELECT A.`port_id` FROM ipv4_addresses AS A, ospf_nbrs AS I WHERE A.ipv4_address = ? AND I.port_id = A.port_id AND I.device_id = ? AND A.context_name = ?', array($ospf_nbr_poll['ospfNbrIpAddr'], $device['device_id'], $device['context_name']));
|
|
|
|
if ($ospf_nbr_db['port_id'] != $ospf_nbr_poll['port_id']) {
|
|
if (!empty($ospf_nbr_poll['port_id'])) {
|
|
$ospf_nbr_update = array('port_id' => $ospf_nbr_poll['port_id']);
|
|
} else {
|
|
$ospf_nbr_update = array('port_id' => array('NULL'));
|
|
}
|
|
}
|
|
|
|
foreach ($ospf_nbr_oids as $oid) {
|
|
// Loop the OIDs
|
|
d_echo($ospf_nbr_db[$oid].'|'.$ospf_nbr_poll[$oid]."\n");
|
|
|
|
if ($ospf_nbr_db[$oid] != $ospf_nbr_poll[$oid]) {
|
|
// If data has changed, build a query
|
|
$ospf_nbr_update[$oid] = $ospf_nbr_poll[$oid];
|
|
// log_event("$oid -> ".$this_nbr[$oid], $device, 'ospf', $nbr['port_id']); // FIXME
|
|
}
|
|
}
|
|
|
|
if ($ospf_nbr_update) {
|
|
dbUpdate($ospf_nbr_update, 'ospf_nbrs', '`device_id` = ? AND `ospf_nbr_id` = ? AND `context_name` = ?', array($device['device_id'], $ospf_nbr_id, $device['context_name']));
|
|
echo 'U';
|
|
unset($ospf_nbr_update);
|
|
} else {
|
|
echo '.';
|
|
}
|
|
|
|
unset($ospf_nbr_poll);
|
|
unset($ospf_nbr_db);
|
|
$ospf_nbr_count++;
|
|
} else {
|
|
dbDelete('ospf_nbrs', '`device_id` = ? AND `ospf_nbr_id` = ? AND `context_name` = ?', array($device['device_id'], $ospf_nbr_db['ospf_nbr_id'], $device['context_name']));
|
|
echo '-';
|
|
}//end if
|
|
}//end foreach
|
|
}//end if
|
|
unset($ospf_nbrs_db);
|
|
unset($ospf_nbrs_poll);
|
|
echo "\n";
|
|
}
|
|
unset($device['context_name'], $vrfs_lite_cisco, $vrf_lite);
|
|
// Create device-wide statistics RRD
|
|
$rrd_def = RrdDefinition::make()
|
|
->addDataset('instances', 'GAUGE', 0, 1000000)
|
|
->addDataset('areas', 'GAUGE', 0, 1000000)
|
|
->addDataset('ports', 'GAUGE', 0, 1000000)
|
|
->addDataset('neighbours', 'GAUGE', 0, 1000000);
|
|
|
|
$fields = array(
|
|
'instances' => $ospf_instance_count,
|
|
'areas' => $ospf_area_count,
|
|
'ports' => $ospf_port_count,
|
|
'neighbours' => $ospf_neighbour_count,
|
|
);
|
|
|
|
$tags = compact('rrd_def');
|
|
data_update($device, 'ospf-statistics', $tags, $fields);
|
|
|
|
echo "\n";
|
|
|
|
unset(
|
|
$ospf_instance_count,
|
|
$ospf_port_count,
|
|
$ospf_area_count,
|
|
$ospf_neighbour_count,
|
|
$ospf_oids_db,
|
|
$ospf_area_oids,
|
|
$ospf_port_oids,
|
|
$ospf_nbr_oids_db,
|
|
$ospf_nbr_oids_rrd,
|
|
$ospf_nbr_oids,
|
|
$rrd_def,
|
|
$fields,
|
|
$tags
|
|
);
|