Observium_CE/includes/discovery/processors.inc.php

<?php
/**
 * Observium
 *
 *   This file is part of Observium.
 *
 * @package    observium
 * @subpackage discovery
 * @copyright  (C) 2006-2013 Adam Armstrong, (C) 2013-2021 Observium Limited
 *
 */

// Include all discovery modules by supported MIB

$include_dir = "includes/discovery/processors";
include("includes/include-dir-mib.inc.php");

// Detect processors by simple MIB-based discovery :
// FIXME - this should also be extended to understand multiple entries in a table, and take descr from an OID but this is all I need right now :)
foreach (get_device_mibs_permitted($device) as $mib)
{
  if (is_array($config['mibs'][$mib]['processor']))
  {
    print_cli_data_field("$mib");
    foreach ($config['mibs'][$mib]['processor'] as $entry_name => $entry)
    {
      $entry['found'] = FALSE;

      // Check duplicate processors by $valid['processor'] array
      if (discovery_check_if_type_exist($entry, 'processor')) { continue 2; }

      // Precision (scale)
      $precision = 1;
      if (isset($entry['scale']) && is_numeric($entry['scale']) && $entry['scale'] != 1)
      {
        // FIXME, currently we support only int precision, need convert all to float scale!
        $precision = round(1 / $entry['scale'], 0);
      }

      if ($entry['type'] == 'table')
      {

        // Use the type as the table if no table is set.
        if(!isset($entry['table'])) { $entry['table'] = $entry_name; }

        $processors_array = snmpwalk_cache_oid($device, $entry['table'], array(), $mib, NULL, OBS_SNMP_ALL_NUMERIC_INDEX);
        if ($entry['table_descr'])
        {
          // If descr in separate table with same indexes
          $processors_array = snmpwalk_cache_oid($device, $entry['table_descr'], $processors_array, $mib, NULL, OBS_SNMP_ALL_NUMERIC_INDEX);
        }
        if (empty($entry['oid_num']))
        {
          // Use snmptranslate if oid_num not set
          $entry['oid_num'] = snmp_translate($entry['oid'], $mib);
        }

        $i = 1; // Used in descr as $i++
        $processors_count = count($processors_array);
        foreach ($processors_array as $index => $processor)
        {
          $dot_index = '.' . $index;
          $oid_num   = $entry['oid_num'] . $dot_index;

          // Rewrite specific keys
          $replace_array = array(
            'index' => $index,    // Index in descr
            'i'     => $i,        // i++ counter in descr
          );

          $descr = entity_descr_definition('processor', $entry, array_merge($replace_array, $processor), $processors_count);

          $idle  = (isset($entry['idle']) && $entry['idle'] ? 1 : 0);

          $usage = snmp_fix_numeric($processor[$entry['oid']]);
          if (is_numeric($usage))
          {
            if (isset($entry['rename_rrd']))
            {
              $old_rrd = 'processor-'.$entry['rename_rrd'].'-'.$index;
              $new_rrd = 'processor-'.$entry_name.'-'.$entry['table'] . $dot_index;
              rename_rrd($device, $old_rrd, $new_rrd);
              unset($old_rrd, $new_rrd);
            }
            discover_processor($valid['processor'], $device, $oid_num, $entry['oid'] . $dot_index, $entry_name, $descr, $precision, $usage, NULL, NULL, $idle);
            $entry['found'] = TRUE;
          }
          $i++;
        }
      } else {
        // Static processor
        $index = 0; // FIXME. Need use same indexes style as in sensors

        // Fetch description from oid if specified
        $replace_array = array('index' => $index);
        if (isset($entry['oid_descr']))
        {
          $replace_array[$entry['oid_descr']] = snmp_get_oid($device, $entry['oid_descr'], $mib);
        }
        $descr = entity_descr_definition('processor', $entry, $replace_array);

        if (isset($entry['oid_count']) && $entry['oid_count'])
        {
          // Get processors count if exist for MIB
          $processor_count = snmp_get_oid($device, $entry['oid_count'], $mib);
          if ($processor_count > 1)
          {
            $descr .= ' x'.$processor_count;
          }
        }

        if (empty($entry['oid_num']))
        {
          // Use snmptranslate if oid_num not set
          $entry['oid_num'] = snmp_translate($entry['oid'], $mib);
        }

        // Idle
        $idle  = (isset($entry['idle']) && $entry['idle'] ? 1 : 0);

        $usage = snmp_fix_numeric(snmp_get_oid($device, $entry['oid'], $mib));

        // If we have valid usage, discover the processor
        if (is_numeric($usage) && $usage != '4294967295')
        {
          // Rename RRD if requested
          if (isset($entry['rename_rrd']))
          {
            $old_rrd = 'processor-'.$entry['rename_rrd'];
            $new_rrd = 'processor-'.$entry_name.'-'.$index;
            rename_rrd($device, $old_rrd, $new_rrd);
            unset($old_rrd, $new_rrd);
          }
          discover_processor($valid['processor'], $device, $entry['oid_num'], $index, $entry_name, $descr, $precision, $usage, NULL, NULL, $idle);
          $entry['found'] = TRUE;
        }
      }
      unset($processors_array, $processor, $dot_index, $descr, $i); // Clean up
      if (isset($entry['stop_if_found']) && $entry['stop_if_found'] && $entry['found']) { break; } // Stop loop if processor found
    }
    print_cli(PHP_EOL); // Close MIB entry line.
  }
}

// Remove processors which weren't redetected here
foreach (dbFetchRows('SELECT * FROM `processors` WHERE `device_id` = ?', array($device['device_id'])) as $test_processor)
{
  $processor_index = $test_processor['processor_index'];
  $processor_type  = $test_processor['processor_type'];
  $processor_descr = $test_processor['processor_descr'];
  print_debug($processor_index . " -> " . $processor_type);

  if (!$valid['processor'][$processor_type][$processor_index])
  {
    $GLOBALS['module_stats'][$module]['deleted']++; //echo('-');
    dbDelete('processors', '`processor_id` = ?', array($test_processor['processor_id']));
    log_event("Processor removed: type ".$processor_type." index ".$processor_index." descr ". $processor_descr, $device, 'processor', $test_processor['processor_id']);
  }
  unset($processor_oid); unset($processor_type);
}

$GLOBALS['module_stats'][$module]['status'] = safe_count($valid['processor']);
if (OBS_DEBUG && $GLOBALS['module_stats'][$module]['status'])
{
  print_vars($valid['processor']);
}

// EOF