admin/cacti
1
0 Fork 0
mirror of https://github.com/Cacti/cacti.git synced 2026-11-01 17:47:26 +09:00
Code Issues Packages Projects Releases Wiki Activity
Files
main
cacti/lib/snmpagent.php
T

990 lines
36 KiB
PHP
Raw Permalink Blame History

<?php
/*
+-------------------------------------------------------------------------+
| Copyright (C) 2004-2023 The Cacti Group |
| |
| 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 2 |
| 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. |
+-------------------------------------------------------------------------+
| Cacti: The Complete RRDtool-based Graphing Solution |
+-------------------------------------------------------------------------+
| This code is designed, written, and maintained by the Cacti Group. See |
| about.php and/or the AUTHORS file for specific developer information. |
+-------------------------------------------------------------------------+
| http://www.cacti.net/ |
+-------------------------------------------------------------------------+
*/
function snmpagent_enabled() {
return read_config_option('enable_snmp_agent') == 'on';
}
function snmpagent_cacti_stats_update($data){
$mc = new MibCache();
if (!snmpagent_enabled()) {
return false;
}
/* refresh total stats */
$mc->object('cactiStatsTotalsDevices')->set( snmpagent_read('cactiStatsTotalsDevices') );
$mc->object('cactiStatsTotalsDataSources')->set( snmpagent_read('cactiStatsTotalsDataSources') );
$mc->object('cactiStatsTotalsGraphs')->set( snmpagent_read('cactiStatsTotalsGraphs') );
/* local polling stats - does not support distributed environments so far. */
$mc->object('cactiStatsLocalPollerRuntime')->set($data[0]);
$index = 1;
$values = array(
'cactiStatsPollerRunTime' => $data[0],
'cactiStatsPollerConcurrentProcesses' => $data[2],
'cactiStatsPollerThreads' => $data[3],
'cactiStatsPollerHosts' => $data[4],
'cactiStatsPollerHostsPerProcess' => $data[5],
'cactiStatsPollerItems' => $data[6],
'cactiStatsPollerRrrdsProcessed' => $data[7],
'cactiStatsPollerUtilization' => round($data[0]/read_config_option('poller_interval', true)*100, 10)
);
try
{
$mc->table('cactiStatsPollerTable')->row($index)->update($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
$mc->object('cactiStatsLastUpdate')->set( time() );
}
function snmpagent_global_settings_update(){
$mc = new MibCache();
$mc->object('cactiApplVersion')->set( snmpagent_read('cactiApplVersion') );
$mc->object('cactiApplSnmpVersion')->set( snmpagent_read('cactiApplSnmpVersion') );
$mc->object('cactiApplRrdtoolVersion')->set( get_rrdtool_version() );
$mc->object('cactiApplPollerEnabled')->set( (read_config_option('poller_enabled', true) == 'on') ? 1 : 2 );
$mc->object('cactiApplPollerType')->set( read_config_option('poller_type', true) );
$mc->object('cactiApplPollerInterval')->set( read_config_option('poller_interval', true) );
$mc->object('cactiApplPollerMaxProcesses')->set( read_config_option('concurrent_processes', true) );
$mc->object('cactiApplPollerLoadBalance')->set( (read_config_option('process_leveling', true) == 'on') ? 1 : 2 );
$mc->object('cactiApplSpineMaxThreads')->set( read_config_option('max_threads', true) );
$mc->object('cactiApplSpineScriptServers')->set( read_config_option('php_servers', true) );
$mc->object('cactiApplSpineScriptTimeout')->set( read_config_option('script_timeout', true) );
$mc->object('cactiApplSpineMaxOids')->set( read_config_option('max_get_size', true) );
$mc->object('cactiApplLastUpdate')->set( time() );
/* update boost settings */
$mc->mib('CACTI-BOOST-MIB');
$mc->object('boostApplRrdUpdateEnabled')->set( (read_config_option('boost_rrd_update_enable', true) == 'on') ? 1 : 2 );
$mc->object('boostApplRrdUpdateInterval')->set( read_config_option('boost_rrd_update_interval', true) );
$mc->object('boostApplRrdUpdateMaxRecords')->set( read_config_option('boost_rrd_update_max_records', true) );
$mc->object('boostApplRrdUpdateMaxRecordsPerSelect')->set( read_config_option('boost_rrd_update_max_records_per_select', true) );
$mc->object('boostApplRrdUpdateMaxStringLength')->set( read_config_option('boost_rrd_update_string_length', true) );
$mc->object('boostApplRrdUpdatePollerMemLimit')->set( read_config_option('boost_poller_mem_limit', true) );
$mc->object('boostApplRrdUpdateMaxRunTime')->set( read_config_option('boost_rrd_update_max_runtime', true) );
$mc->object('boostApplRrdUpdateRedirect')->set( (read_config_option('boost_redirect', true) == 'on') ? 1 : 2 );
$mc->object('boostApplImageCacheEnabled')->set( (read_config_option('boost_png_cache_enable', true) == 'on') ? 1 : 2 );
$mc->object('boostApplLoggingEnabled')->set( (read_config_option('path_boost_log', true) == true) ? 1 : 2 );
$mc->object('boostApplLastUpdate')->set( time() );
}
function snmpagent_api_device_new($device){
if (!snmpagent_enabled()) {
return false;
}
$mc = new MibCache();
/* add device to cactiApplDeviceTable and cactiStatsDeviceTable*/
$device_data = db_fetch_row_prepared('SELECT * FROM `host` WHERE id = ?', array($device['id']));
$appl_values = array(
'cactiApplDeviceIndex' => $device_data['id'],
'cactiApplDeviceDescription' => $device_data['description'],
'cactiApplDeviceHostname' => $device_data['hostname'],
'cactiApplDeviceStatus' => $device_data['status'],
'cactiApplDeviceEventCount' => $device_data['status_event_count'],
'cactiApplDeviceFailDate' => $device_data['status_fail_date'],
'cactiApplDeviceRecoveryDate' => $device_data['status_rec_date'],
'cactiApplDeviceLastError' => $device_data['status_last_error'],
);
$stats_values = array(
'cactiStatsDeviceIndex' => $device_data['id'],
'cactiStatsDeviceHostname' => $device_data['hostname'],
'cactiStatsDeviceMinTime' => $device_data['min_time'],
'cactiStatsDeviceMaxTime' => $device_data['max_time'],
'cactiStatsDeviceCurTime' => $device_data['cur_time'],
'cactiStatsDeviceAvgTime' => $device_data['avg_time'],
'cactiStatsDeviceTotalPolls' => $device_data['total_polls'],
'cactiStatsDeviceFailedPolls' => $device_data['failed_polls'],
'cactiStatsDeviceAvailability' => $device_data['availability']
);
try
{
$mc->table('cactiApplDeviceTable')->row($device['id'])->replace($appl_values);
$mc->object('cactiApplLastUpdate')->set(time());
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
try
{
$mc->table('cactiStatsDeviceTable')->row($device['id'])->replace($stats_values);
$mc->object('cactiStatsTotalsDevices')->set(snmpagent_read('cactiStatsTotalsDevices'));
$mc->object('cactiStatsLastUpdate')->set(time());
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
function snmpagent_data_source_action_bottom($data){
if (!snmpagent_enabled()) {
return false;
}
$mc = new MibCache();
$action = $data[0];
if ($action == '1') {
/* delete data sources */
$mc->object('cactiStatsTotalsDataSources')->set(snmpagent_read('cactiStatsTotalsDataSources'));
$mc->object('cactiStatsTotalsGraphs')->set(snmpagent_read('cactiStatsTotalsGraphs'));
$mc->object('cactiStatsLastUpdate')->set(time());
} elseif ($action == '4') {
/* duplicate data sources */
$mc->object('cactiStatsTotalsDataSources')->set(snmpagent_read('cactiStatsTotalsDataSources'));
$mc->object('cactiStatsLastUpdate')->set(time());
}
}
function snmpagent_graphs_action_bottom($data){
if (!snmpagent_enabled()) {
return false;
}
$mc = new MibCache();
$action = $data[0];
if ($action == '1') {
/* delete graphs */
$mc->object('cactiStatsTotalsDataSources')->set(snmpagent_read('cactiStatsTotalsDataSources'));
$mc->object('cactiStatsTotalsGraphs')->set(snmpagent_read('cactiStatsTotalsGraphs'));
$mc->object('cactiStatsLastUpdate')->set(time());
} elseif ($action == '3') {
/* duplicate graphs */
$mc->object('cactiStatsTotalsGraphs')->set(snmpagent_read('cactiStatsTotalsGraphs'));
$mc->object('cactiStatsLastUpdate')->set(time());
}
}
function snmpagent_device_action_bottom($data){
if (!snmpagent_enabled()) {
return false;
}
$mc = new MibCache();
$action = $data[0];
$selected_items = $data[1];
if ($selected_items != false) {
switch($action){
case '1':
/* delete devices */
foreach($selected_items as $device_id) {
try
{
$mc->table('cactiApplDeviceTable')->row($device_id)->delete();
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
try
{
$mc->table('cactiStatsDeviceTable')->row($device_id)->delete();
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
/* update total statistics */
$mc->object('cactiStatsTotalsDevices')->set( snmpagent_read('cactiStatsTotalsDevices') );
$mc->object('cactiStatsTotalsDataSources')->set( snmpagent_read('cactiStatsTotalsDataSources') );
$mc->object('cactiStatsTotalsGraphs')->set( snmpagent_read('cactiStatsTotalsGraphs') );
$mc->object('cactiStatsLastUpdate')->set(time());
break;
case '2':
/* enable devices */
foreach($selected_items as $device_id) {
$device_status = db_fetch_cell_prepared('SELECT status FROM host WHERE id = ?', array($device_id));
try
{
$mc->table('cactiApplDeviceTable')->row($device_id)->update(array('cactiApplDeviceStatus' => $device_status));
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
$mc->object('cactiApplLastUpdate')->set(time());
break;
case '3':
/* disable devices */
foreach($selected_items as $device_id) {
$device_status = db_fetch_cell_prepared('SELECT status FROM host WHERE id = ?', array($device_id));
try
{
$mc->table('cactiApplDeviceTable')->row($device_id)->update(array('cactiApplDeviceStatus' => 4));
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
$mc->object('cactiApplLastUpdate')->set(time());
break;
case '5':
/* clear device statistics */
$values = array(
'cactiStatsDeviceMinTime' => '9.99999',
'cactiStatsDeviceMaxTime' => '0',
'cactiStatsdeviceCurTime' => '0',
'cactiStatsDeviceAvgTime' => '0',
'cactiStatsDeviceTotalPolls' => '0',
'cactiStatsDeviceFailedPolls' => '0',
'cactiStatsDeviceAvailability' => '100'
);
foreach($selected_items as $device_id) {
try
{
$mc->table('cactiStatsDeviceTable')->row($device_id)->update($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
$mc->object('cactiStatsLastUpdate')->set( time() );
break;
default:
/* nothing to do */
;
} //switch
}
}
function snmpagent_poller_exiting($poller_index = 1){
if (!snmpagent_enabled()) {
return false;
}
$mc = new MibCache();
try
{
$poller = $mc->table('cactiApplPollerTable')->row($poller_index)->select();
if ($poller == false) {
throw new Exception('Unable to find a poller');
}
$varbinds = array(
'cactiApplPollerIndex' => $poller_index,
'cactiApplPollerHostname' => $poller['cactiApplPollerHostname'],
'cactiApplPollerIpAddress' => $poller['cactiApplPollerIpAddress']
);
snmpagent_notification('cactiNotifyPollerRuntimeExceeding', 'CACTI-MIB', $varbinds, SNMPAGENT_EVENT_SEVERITY_HIGH);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
function snmpagent_poller_bottom() {
global $config;
if (!db_table_exists('snmpagent_cache')) {
return true;
}
if (!snmpagent_enabled()) {
snmpagent_cache_uninstall();
return false;
} elseif (!snmpagent_cache_initialized()) {
snmpagent_cache_rebuilt();
}
if (api_plugin_is_enabled('maint')) {
include_once($config['base_path'] . '/plugins/maint/functions.php');
}
$device_in_maintenance = false;
$mc = new MibCache();
/* START: update total device stats table */
/***** deprecated ******/
$devicestatus_indices = array(0 => 0, 1 => 1, 2 => 2, 3 => 3, 4 => 4);
$current_states = db_fetch_assoc('SELECT status, COUNT(*) as cnt FROM `host` GROUP BY status');
if ($current_states && cacti_sizeof($current_states)>0) {
foreach($current_states as $current_state) {
$index = $devicestatus_indices[$current_state['status']];
$values = array(
'cactiStatsTotalsDeviceStatusIndex' => $current_state['status'],
'cactiStatsTotalsDeviceStatusCounter' => $current_state['cnt']
);
try
{
$mc->table('cactiStatsTotalsDeviceStatusTable')->row($index)->replace($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
unset($devicestatus_indices[$current_state['status']]);
}
}
if (cacti_sizeof($devicestatus_indices)>0) {
foreach($devicestatus_indices as $status => $index) {
$values = array(
'cactiStatsTotalsDeviceStatusIndex' => $status,
'cactiStatsTotalsDeviceStatusCounter' => 0
);
try
{
$mc->table('cactiStatsTotalsDeviceStatusTable')->row($index)->replace($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
}
/************************/
$mc->object('cactiStatsTotalsDeviceStatusUnknown')->set( snmpagent_read('cactiStatsTotalsDeviceStatusUnknown') );
$mc->object('cactiStatsTotalsDeviceStatusDown')->set( snmpagent_read('cactiStatsTotalsDeviceStatusDown') );
$mc->object('cactiStatsTotalsDeviceStatusRecovering')->set( snmpagent_read('cactiStatsTotalsDeviceStatusRecovering') );
$mc->object('cactiStatsTotalsDeviceStatusUp')->set( snmpagent_read('cactiStatsTotalsDeviceStatusUp') );
$mc->object('cactiStatsTotalsDeviceStatusDisabled')->set( snmpagent_read('cactiStatsTotalsDeviceStatusDisabled') );
/* END: update total device stats table */
/* update state and statistics of all devices */
$mc_dstatus = array();
try
{
$mc_devices = $mc->table('cactiApplDeviceTable')->select(array('cactiApplDeviceIndex', 'cactiApplDeviceStatus'));
if ($mc_devices && cacti_sizeof($mc_devices)) {
foreach($mc_devices as $mc_device) {
if (isset($mc_device['cactiApplDeviceStatus']) && isset($mc_device['cactiApplDeviceIndex'])) {
$mc_dstatus[$mc_device['cactiApplDeviceIndex']] = $mc_device['cactiApplDeviceStatus'];
}
}
}
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
$mc_dfailed = array();
try
{
$mc_device_stats = $mc->table('cactiStatsDeviceTable')->select(array('cactiStatsDeviceIndex','cactiStatsDeviceFailedPolls'));
if ($mc_device_stats && cacti_sizeof($mc_device_stats)>0) {
foreach($mc_device_stats as $mc_device_stat) {
if (isset($mc_device_stat['cactiStatsDeviceFailedPolls']) && isset($mc_device_stat['cactiStatsDeviceIndex'])) {
$mc_dfailed[$mc_device_stat['cactiStatsDeviceIndex']] = $mc_device_stat['cactiStatsDeviceFailedPolls'];
}
}
}
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
$devices = db_fetch_assoc('SELECT id, description, hostname, status,
disabled, status_event_count, status_fail_date, status_rec_date,
status_last_error, min_time, max_time, cur_time, avg_time,
total_polls, failed_polls, availability, snmp_engine_id
FROM host
ORDER BY id ASC');
if (cacti_sizeof($devices)) {
foreach($devices as $device) {
if (function_exists('plugin_maint_check_cacti_host')) {
$device_in_maintenance = plugin_maint_check_cacti_host($index);
}
if (!$device_in_maintenance) {
$varbinds = array(
'cactiApplDeviceIndex' => $device['id'],
'cactiApplDeviceDescription' => $device['description'],
'cactiApplDeviceHostname' => $device['hostname'],
'cactiApplDeviceLastError' => $device['status_last_error']
);
$overwrite['snmp_engine_id'] = $device['snmp_engine_id'];
if (isset($mc_dfailed[$device['id']]) && $device['failed_polls'] > $mc_dfailed[$device['id']]) {
snmpagent_notification('cactiNotifyDeviceFailedPoll', 'CACTI-MIB', $varbinds, SNMPAGENT_EVENT_SEVERITY_MEDIUM, $overwrite);
}
if (isset($mc_dstatus[$device['id']]) && $mc_dstatus[$device['id']] == HOST_UP && $device['status'] == HOST_DOWN ) {
snmpagent_notification('cactiNotifyDeviceDown', 'CACTI-MIB', $varbinds, SNMPAGENT_EVENT_SEVERITY_HIGH, $overwrite);
} elseif (isset($mc_dstatus[$device['id']]) && $mc_dstatus[$device['id']] == HOST_DOWN && $device['status'] == HOST_RECOVERING ){
snmpagent_notification('cactiNotifyDeviceRecovering', 'CACTI-MIB', $varbinds, SNMPAGENT_EVENT_SEVERITY_MEDIUM, $overwrite);
}
}
$values = array(
'cactiApplDeviceStatus' => ($device['disabled'] == 'on') ? 4 : $device['status'],
'cactiApplDeviceEventCount' => $device['status_event_count'],
'cactiApplDeviceFailDate' => $device['status_fail_date'],
'cactiApplDeviceRecoveryDate' => $device['status_rec_date'],
'cactiApplDeviceLastError' => $device['status_last_error']
);
try
{
$mc->table('cactiApplDeviceTable')->row($device['id'])->update($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
$values = array(
'cactiStatsDeviceMinTime' => $device['min_time'],
'cactiStatsDeviceMaxTime' => $device['max_time'],
'cactiStatsDeviceCurTime' => $device['cur_time'],
'cactiStatsDeviceAvgTime' => $device['avg_time'],
'cactiStatsDeviceTotalPolls' => $device['total_polls'],
'cactiStatsDeviceFailedPolls' => $device['failed_polls'],
'cactiStatsDeviceAvailability' => $device['availability']
);
try
{
$mc->table('cactiStatsDeviceTable')->row($device['id'])->update($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
}
/* get a list of all plugins available on that system */
$pluginslist = snmpagent_get_pluginslist();
/* truncate plugin mib table */
try
{
$mc->table('cactiApplPluginTable')->truncate();
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
/* refill plugin mib table */
if ($pluginslist && cacti_sizeof($pluginslist)>0) {
$i = 1;
foreach($pluginslist as $plugin) {
$values = array(
'cactiApplPluginIndex' => $i,
'cactiApplPluginType' => 2,
'cactiApplPluginName' => $plugin['directory'],
'cactiApplPluginStatus' => $plugin['status'],
'cactiApplPluginVersion' => $plugin['version']
);
try
{
$mc->table('cactiApplPluginTable')->row($i)->insert($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
$i++;
}
}
$mc->object('cactiApplLastUpdate')->set(time());
$recache_stats = db_fetch_cell("SELECT value
FROM settings
WHERE name = 'stats_recache'");
if ($recache_stats) {
list($time, $hosts) = explode(' ', $recache_stats);
$time = str_replace('RecacheTime:', '', $time);
$hosts = str_replace('HostsRecached:', '', $hosts);
$mc->object('cactiStatsRecacheTime')->set($time);
$mc->object('cactiStatsRecachedHosts')->set($hosts);
}
$mc->object('cactiStatsLastUpdate')->set(time());
/* clean up the notification log */
$snmp_notification_managers = db_fetch_assoc('SELECT id, max_log_size FROM snmpagent_managers');
if ($snmp_notification_managers && cacti_sizeof($snmp_notification_managers)>0) {
foreach($snmp_notification_managers as $snmp_notification_manager) {
db_execute_prepared('DELETE FROM snmpagent_notifications_log
WHERE manager_id = ?
AND `time` <= ?',
array($snmp_notification_manager['id'], time()-86400*$snmp_notification_manager['max_log_size']));
}
}
}
function snmpagent_get_pluginslist(){
global $config, $plugins, $plugins_integrated;
/* update the list of known plugins only once per polling cycle. In all other cases we would
have to create too many new hooks to update that MIB table just in time.
We have to do the same like function plugins_load_temp_table(), which will not be available
during the execution of that function. */
$pluginslist = array();
$registered_plugins = db_fetch_assoc('SELECT * FROM plugin_config ORDER BY name');
foreach ($registered_plugins as $t) {
$pluginslist[$t['directory']] = $t;
}
$path = $config['base_path'] . '/plugins/';
$dh = opendir($path);
if ($dh !== false) {
while (($file = readdir($dh)) !== false) {
if ((is_dir("$path$file")) && !in_array($file, $plugins_integrated) &&
(file_exists("$path$file/setup.php")) && (!array_key_exists($file, $pluginslist))) {
if (file_exists("$path$file/INFO")) {
$cinfo = plugin_load_info_file("$path$file/INFO");
$pluginslist[$file] = $cinfo;
}
}
}
closedir($dh);
}
return $pluginslist;
}
/**
* snmpagent_cache_install()
* Generates a SNMP caching tables reflecting all objects of the Cacti MIB
* @return
*/
function snmpagent_cache_install() {
global $config;
if (!snmpagent_enabled()) {
return false;
}
/* drop everything */
snmpagent_cache_uninstall();
$mc = new MibCache();
$mc->install($config['base_path'] . '/mibs/CACTI-MIB');
$mc->install($config['base_path'] . '/mibs/CACTI-SNMPAGENT-MIB');
$mc->install($config['base_path'] . '/mibs/CACTI-BOOST-MIB');
snmpagent_cache_init();
/* call install routine of plugins supporting the SNMPAgent */
api_plugin_hook('snmpagent_cache_install');
}
function snmpagent_cache_uninstall() {
/* drop everything if not empty */
$tables = array(
'snmpagent_cache',
'snmpagent_mibs',
'snmpagent_cache_notifications',
'snmpagent_cache_textual_conventions'
);
foreach($tables as $table) {
$rows = db_fetch_cell("SELECT COUNT(*) FROM $table");
if ($rows > 0) {
db_execute("TRUNCATE $table");
}
}
}
function snmpagent_cache_initialized() {
return db_fetch_cell('SELECT COUNT(*) FROM `snmpagent_cache`') > 0;
}
function snmpagent_cache_rebuilt(){
snmpagent_cache_install();
}
function snmpagent_cache_init(){
/* fill up the cache with a minimum of data and ignore all values that
* will be updated automatically at the bottom of the next poller run
*/
$mc = new MibCache();
if (!is_object($mc)) {
return false;
}
/* update global settings */
snmpagent_global_settings_update();
/* add pollers of a distributed system (future) */
$pollers = db_fetch_assoc('SELECT id FROM poller ORDER BY id ASC');
if ($pollers && cacti_sizeof($pollers)>0) {
foreach($pollers as $poller){
$poller_data = db_fetch_row_prepared('SELECT * FROM poller WHERE id = ?', array($poller['id']));
}
} else {
/* this is NOT a distributed system, but it should have at least one local poller. */
$poller_lastrun = read_config_option('poller_lastrun', true);
$values = array(
'cactiApplPollerIndex' => 1,
'cactiApplPollerHostname' => 'localhost',
'cactiApplPollerIpAddress' => '127.0.0.1',
'cactiApplPollerLastUpdate' => $poller_lastrun
);
try
{
$mc->table('cactiApplPollerTable')->row(1)->insert($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
$values = array(
'cactiStatsPollerIndex' => 1,
'cactiStatsPollerHostname' => 'localhost',
'cactiStatsPollerMethod' => read_config_option('poller_type', true)
);
try
{
$mc->table('cactiStatsPollerTable')->row(1)->insert($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
/* add all devices as devicetable entries to the snmp cache */
$devices = db_fetch_assoc('SELECT id, description, hostname, disabled, status_event_count, status_fail_date,
status_rec_date, status_last_error, min_time, max_time, cur_time,
avg_time, total_polls, failed_polls, availability
FROM host
ORDER BY id ASC');
if (cacti_sizeof($devices)) {
foreach($devices as $device) {
$device = db_fetch_row_prepared('SELECT * FROM host WHERE id = ?', array($device['id']));
/* add device to cactiApplDeviceTable */
if (cacti_sizeof($device)) {
$values = array(
'cactiApplDeviceIndex' => $device['id'],
'cactiApplDeviceDescription' => $device['description'],
'cactiApplDeviceHostname' => $device['hostname'],
'cactiApplDeviceStatus' => ($device['disabled'] == 'on') ? 4 : $device['status'],
'cactiApplDeviceEventCount' => $device['status_event_count'],
'cactiApplDeviceFailDate' => $device['status_fail_date'],
'cactiApplDeviceRecoveryDate' => $device['status_rec_date'],
'cactiApplDeviceLastError' => $device['status_last_error'],
);
try
{
$mc->table('cactiApplDeviceTable')->row($device['id'])->insert($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
/* add device to cactiStatsDeviceTable */
$values = array(
'cactiStatsDeviceIndex' => $device['id'],
'cactiStatsDeviceHostname' => $device['hostname'],
'cactiStatsDeviceMinTime' => $device['min_time'],
'cactiStatsDeviceMaxTime' => $device['max_time'],
'cactiStatsDeviceCurTime' => $device['cur_time'],
'cactiStatsDeviceAvgTime' => $device['avg_time'],
'cactiStatsDeviceTotalPolls' => $device['total_polls'],
'cactiStatsDeviceFailedPolls' => $device['failed_polls'],
'cactiStatsDeviceAvailability' => $device['availability']
);
try
{
$mc->table('cactiStatsDeviceTable')->row($device['id'])->insert($values);
}
catch (Exception $e)
{
cacti_log('WARNING: SNMPAgent: ' . $e->getMessage(), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
}
}
}
function snmpagent_read($object){
switch($object) {
case 'cactiApplVersion':
$value = db_fetch_cell('SELECT `cacti` FROM `version`');
break;
case 'cactiApplSnmpVersion':
$snmp_version = read_config_option('snmp_version', true);
$value = $snmp_version;
if (function_exists('snmpget')) {
$value = 3;
}
break;
case 'cactiStatsTotalsDevices':
$value = db_fetch_cell('SELECT COUNT(*) FROM host');
break;
case 'cactiStatsTotalsDataSources':
$value = db_fetch_cell('SELECT COUNT(*) FROM data_local');
break;
case 'cactiStatsTotalsGraphs':
$value = db_fetch_cell('SELECT COUNT(*) FROM graph_local');
break;
case 'cactiStatsTotalsDeviceStatusUnknown':
$value = db_fetch_cell('SELECT COUNT(*) FROM host WHERE status = 0');
break;
case 'cactiStatsTotalsDeviceStatusDown':
$value = db_fetch_cell('SELECT COUNT(*) FROM host WHERE status = 1');
break;
case 'cactiStatsTotalsDeviceStatusRecovering':
$value = db_fetch_cell('SELECT COUNT(*) FROM host WHERE status = 2');
break;
case 'cactiStatsTotalsDeviceStatusUp':
$value = db_fetch_cell('SELECT COUNT(*) FROM host WHERE status = 3');
break;
case 'cactiStatsTotalsDeviceStatusDisabled':
$value = db_fetch_cell('SELECT COUNT(*) FROM host WHERE status = 4');
break;
default:
$value = false;
}
return $value;
}
function snmpagent_notification($notification, $mib, $varbinds, $severity = SNMPAGENT_EVENT_SEVERITY_MEDIUM, $overwrite = false){
global $config, $snmpagent_event_severity;
if (isset($config['snmpagent']['notifications']['ignore'][$notification])) {
return false;
}
$path_snmptrap = read_config_option('path_snmptrap');
if (!in_array($severity, array(SNMPAGENT_EVENT_SEVERITY_LOW, SNMPAGENT_EVENT_SEVERITY_MEDIUM, SNMPAGENT_EVENT_SEVERITY_HIGH, SNMPAGENT_EVENT_SEVERITY_CRITICAL))) {
cacti_log('ERROR: Unknown event severity: "' . $severity . '" for ' . $notification . ' (' . $mib . ')', false, 'SNMPAGENT', POLLER_VERBOSITY_NONE);
return false;
}
$enterprise_oid = db_fetch_cell_prepared('SELECT oid
FROM snmpagent_cache
WHERE `name` = ?
AND `mib` = ?',
array($notification, $mib));
if (!$enterprise_oid) {
/* system does not know this event */
cacti_log('ERROR: Unknown event: ' . $notification . ' (' . $mib . ')', false, 'SNMPAGENT', POLLER_VERBOSITY_NONE);
return false;
} else {
$branches = explode('.', $enterprise_oid);
$specific_trap_number = array_pop($branches);
}
/* generate a list of SNMP notification receivers listening for this notification */
$notification_managers = db_fetch_assoc_prepared('SELECT snmpagent_managers.*
FROM snmpagent_managers_notifications
INNER JOIN snmpagent_managers
ON (snmpagent_managers.id = snmpagent_managers_notifications.manager_id)
WHERE snmpagent_managers.disabled = 0
AND snmpagent_managers_notifications.notification = ?
AND snmpagent_managers_notifications.mib = ?',
array($notification, $mib));
if (cacti_sizeof($notification_managers) == 0) {
/* No receivers found for the message, record it to the cacti.log */
cacti_log('WARNING: No notification receivers configured for event: ' . $notification . ' (' . $mib . '), severity: ' . $snmpagent_event_severity[$severity], false, 'SNMPAGENT', POLLER_VERBOSITY_NONE);
if (!in_array($severity, array(SNMPAGENT_EVENT_SEVERITY_HIGH, SNMPAGENT_EVENT_SEVERITY_CRITICAL))) {
/* Prevent log spam of messages lower than a high severity */
$config['snmpagent']['notifications']['ignore'][$notification] = 1;
}
return false;
}
$registered_var_binds = array();
/* get a list of registered var binds */
$reg_var_binds = db_fetch_assoc_prepared('SELECT
scn.attribute, sc.oid, sc.type, sctc.type as tcType
FROM snmpagent_cache_notifications AS scn
LEFT JOIN snmpagent_cache AS sc
ON sc.mib = scn.mib AND sc.name = scn.attribute
LEFT JOIN snmpagent_cache_textual_conventions AS sctc
ON sc.mib = sctc.mib AND sc.type = sctc.name
WHERE scn.name = ?
AND scn.mib = ?
ORDER BY scn.sequence_id',
array($notification, $mib));
if (cacti_sizeof($reg_var_binds)) {
foreach($reg_var_binds as $reg_var_bind) {
$registered_var_binds[$reg_var_bind['attribute']] = array(
'oid' => $reg_var_bind['oid'],
'type' => ($reg_var_bind['tcType']) ? $reg_var_bind['tcType'] : $reg_var_bind['type']
);
}
}
$difference = array_diff(array_keys($registered_var_binds), array_keys($varbinds));
if (cacti_sizeof($difference) == 0) {
/* order the managers by message type to send out all notifications immediately. Informs
will take more processing time.
*/
$notification_managers = db_fetch_assoc_prepared('SELECT sm.*
FROM snmpagent_managers_notifications AS smn
INNER JOIN snmpagent_managers AS sm
ON sm.id = smn.manager_id
WHERE smn.notification = ?
AND smn.mib = ?
ORDER BY sm.snmp_message_type', array($notification, $mib));
if (cacti_sizeof($notification_managers)) {
include_once($config['library_path'] . '/poller.php');
/*
TYPE: one of i, u, t, a, o, s, x, d, b
i: INTEGER, u: unsigned INTEGER, t: TIMETICKS, a: IPADDRESS
o: OBJID, s: STRING, x: HEX STRING, d: DECIMAL STRING, b: BITS
U: unsigned int64, I: signed int64, F: float, D: double
*/
$smi2netsnmp_datatypes = array(
'integer' => 'i',
'integer32' => 'i',
'unsigned32' => 'u',
'gauge' => 'i',
'gauge32' => 'i',
'counter' => 'i',
'counter32' => 'i',
'counter64' => 'I',
'timeticks' => 't',
'octect string' => 's',
'opaque' => 's',
'object identifier' => 'o',
'ipaddress' => 'a',
'networkaddress' => 'IpAddress',
'bits' => 'b',
'displaystring' => 's',
'physaddress' => 's',
'macaddress' => 's',
'truthvalue' => 'i',
'testandincr' => 'i',
'autonomoustype' => 'o',
'variablepointer' => 'o',
'rowpointer' => 'o',
'rowstatus' => 'i',
'timestamp' => 't',
'timeinterval' => 'i',
'dateandtime' => 's',
'storagetype' => 'i',
'tdomain' => 'o',
'taddress' => 's'
);
$log_notification_varbinds = '';
$snmp_notification_varbinds = '';
foreach($notification_managers as $notification_manager) {
if (!$snmp_notification_varbinds) {
foreach($registered_var_binds as $name => $attributes ) {
$snmp_notification_varbinds .= ' ' . $attributes['oid'] . ' ' . $smi2netsnmp_datatypes[strtolower($attributes['type'])] . " \"" . str_replace('"', "'", $varbinds[$name]) . "\"";
$log_notification_varbinds .= $name . ":\"" . str_replace('"', "'", $varbinds[$name]) . "\" ";
}
}
if ($notification_manager['snmp_version'] == 1 ) {
$args = ' -v 1 -c ' . $notification_manager['snmp_community'] . ' ' . $notification_manager['hostname'] . ':' . $notification_manager['snmp_port'] . ' ' . $enterprise_oid . " \"\" 6 " . $specific_trap_number . " \"\"" . $snmp_notification_varbinds;
}else if ($notification_manager['snmp_version'] == 2 ) {
$args = ' -v 2c -c ' . $notification_manager['snmp_community'] . ( ($notification_manager['snmp_message_type'] == 2 )? ' -Ci ' : '' ) . ' ' . $notification_manager['hostname'] . ':' . $notification_manager['snmp_port'] . " \"\" " . $enterprise_oid . $snmp_notification_varbinds;
}else if ($notification_manager['snmp_version'] == 3 ) {
if ( $overwrite && isset($overwrite['snmp_engine_id']) && $overwrite['snmp_engine_id'] ) {
$notification_manager['snmp_engine_id'] = $overwrite['snmp_engine_id'];
}
$args = ' -v 3 -e ' . $notification_manager['snmp_engine_id'] . (($notification_manager['snmp_message_type'] == 2 )? ' -Ci ' : '' ) . ' -u ' . $notification_manager['snmp_username'];
if ( $notification_manager['snmp_password'] && $notification_manager['snmp_priv_passphrase']) {
$snmp_security_level = 'authPriv';
} elseif ( $notification_manager['snmp_password'] && !$notification_manager['snmp_priv_passphrase']) {
$snmp_security_level = 'authNoPriv';
} else {
$snmp_security_level = 'noAuthNoPriv';
}
$args .= ' -l ' . $snmp_security_level . (($snmp_security_level != 'noAuthNoPriv') ? ' -a ' . $notification_manager['snmp_auth_protocol'] . ' -A ' . $notification_manager['snmp_password'] : '' ) . (($snmp_security_level == 'authPriv')? ' -x ' . $notification_manager['snmp_priv_protocol'] . ' -X ' . $notification_manager['snmp_priv_passphrase'] : '') . ' ' . $notification_manager['hostname'] . ':' . $notification_manager['snmp_port'] . " \"\" " . $enterprise_oid . $snmp_notification_varbinds;
}
/* execute net-snmp to generate this notification in the background */
exec_background( escapeshellcmd($path_snmptrap), escapeshellcmd($args));
/* insert a new entry into the notification log for that SNMP receiver */
$save = array();
$save['id'] = 0;
$save['time'] = time();
$save['severity'] = $severity;
$save['manager_id'] = $notification_manager['id'];
$save['notification'] = $notification;
$save['mib'] = $mib;
$save['varbinds'] = substr($log_notification_varbinds, 0, 5000);
sql_save($save, 'snmpagent_notifications_log');
/* log the net-snmp command for Cacti admins if they wish for */
cacti_log("NOTE: $path_snmptrap " . str_replace(array($notification_manager['snmp_password'], $notification_manager['snmp_priv_passphrase']), '********', $args), false, 'SNMPAGENT', POLLER_VERBOSITY_MEDIUM);
}
}
} else {
/* mismatching number of var binds */
cacti_log('ERROR: Incomplete number of varbinds given for event: ' . $notification . ' (' . $mib . ')', false, 'SNMPAGENT', POLLER_VERBOSITY_NONE);
return false;
}
}
Reference in new issue View Git Blame Copy Permalink