开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > SNMP编程 > 查看源码
SNMP_util.pm
资源名称：mrtg-2.13.2.zip　[点击查看]
上传用户：shbosideng
上传日期：2013-05-04
资源大小：1555k
文件大小：40k
源码类别：

SNMP编程

开发平台：

C/C++

SNMP_util.pm：源码内容
  1. ### - *- mode: Perl -*-
  2. ######################################################################
  3. ### SNMP_util -- SNMP utilities using SNMP_Session.pm and BER.pm
  4. ######################################################################
  5. ### Copyright (c) 1998-2002, Mike Mitchell.
  6. ###
  7. ### This program is free software; you can redistribute it under the
  8. ### "Artistic License" included in this distribution (file "Artistic").
  9. ######################################################################
  10. ### Created by:  Mike Mitchell   <Mike.Mitchell@sas.com>
  11. ###
  12. ### Contributions and fixes by:
  13. ###
  14. ### Tobias Oetiker <oetiker@ee.ethz.ch>:  Basic layout
  15. ### Simon Leinen <simon@switch.ch>: SNMP_session.pm/BER.pm
  16. ### Jeff Allen <jeff.allen@acm.org>: length() of undefined value
  17. ### Johannes Demel <demel@zid.tuwien.ac.at>: MIB file parse problem
  18. ### Simon Leinen <simon@switch.ch>: more OIDs from Interface MIB
  19. ### Jacques Supcik <supcik@ip-plus.net>: Specify local IP, port
  20. ### Tobias Oetiker <oetiker@ee.ethz.ch>: HASH as first OID to set SNMP options
  21. ### Simon Leinen <simon@switch.ch>: 'undefined port' bug
  22. ### Daniel McDonald <dmcdonald@digicontech.com>: request for getbulk support
  23. ### Laurent Girod <girod.laurent@pmintl.ch>: code for snmpwalkhash
  24. ### Ian Duplisse <i.duplisse@cablelabs.com>: MIB parsing suggestions
  25. ### Jakob Ilves <jakob.ilves@oracle.com>: return_array_refs for snmpwalk()
  26. ### Valerio Bontempi <v.bontempi@inwind.it>: IPv6 support
  27. ### Lorenzo Colitti <lorenzo@colitti.com>: IPv6 support
  28. ### Joerg Kummer <JOERG.KUMMER@Roche.COM>: TimeTicks support in snmpset()
  29. ### Christopher J. Tengi <tengi@CS.Princeton.EDU>: Gauge32 support in snmpset()
  30. ### Nicolai Petri <nicolai@catpipe.net>: hashref passing for snmpwalkhash()
  31. ######################################################################
  33. package SNMP_util;
  35. require 5.004;
  37. use strict;
  38. use vars qw(@ISA @EXPORT $VERSION);
  39. use Exporter;
  40. use Carp;
  42. use BER "1.05";
  43. use SNMP_Session "1.05";
  44. use Socket;
  46. $VERSION = '1.04';
  48. @ISA = qw(Exporter);
  50. @EXPORT = qw(snmpget snmpgetnext snmpwalk snmpset snmptrap snmpgetbulk snmpmaptable snmpmaptable4 snmpwalkhash snmpmapOID snmpMIB_to_OID snmpLoad_OID_Cache snmpQueue_MIB_File);
  52. # The OID numbers from RFC1213 (MIB-II) and RFC1315 (Frame Relay)
  53. # are pre-loaded below.
  54. %SNMP_util::OIDS = 
  55.   (
  56.     'iso' => '1',
  57.     'org' => '1.3',
  58.     'dod' => '1.3.6',
  59.     'internet' => '1.3.6.1',
  60.     'directory' => '1.3.6.1.1',
  61.     'mgmt' => '1.3.6.1.2',
  62.     'mib-2' => '1.3.6.1.2.1',
  63.     'system' => '1.3.6.1.2.1.1',
  64.     'sysDescr' => '1.3.6.1.2.1.1.1.0',
  65.     'sysObjectID' => '1.3.6.1.2.1.1.2.0',
  66.     'sysUpTime' => '1.3.6.1.2.1.1.3.0',
  67.     'sysUptime' => '1.3.6.1.2.1.1.3.0',
  68.     'sysContact' => '1.3.6.1.2.1.1.4.0',
  69.     'sysName' => '1.3.6.1.2.1.1.5.0',
  70.     'sysLocation' => '1.3.6.1.2.1.1.6.0',
  71.     'sysServices' => '1.3.6.1.2.1.1.7.0',
  72.     'interfaces' => '1.3.6.1.2.1.2',
  73.     'ifNumber' => '1.3.6.1.2.1.2.1.0',
  74.     'ifTable' => '1.3.6.1.2.1.2.2',
  75.     'ifEntry' => '1.3.6.1.2.1.2.2.1',
  76.     'ifIndex' => '1.3.6.1.2.1.2.2.1.1',
  77.     'ifInOctets' => '1.3.6.1.2.1.2.2.1.10',
  78.     'ifInUcastPkts' => '1.3.6.1.2.1.2.2.1.11',
  79.     'ifInNUcastPkts' => '1.3.6.1.2.1.2.2.1.12',
  80.     'ifInDiscards' => '1.3.6.1.2.1.2.2.1.13',
  81.     'ifInErrors' => '1.3.6.1.2.1.2.2.1.14',
  82.     'ifInUnknownProtos' => '1.3.6.1.2.1.2.2.1.15',
  83.     'ifOutOctets' => '1.3.6.1.2.1.2.2.1.16',
  84.     'ifOutUcastPkts' => '1.3.6.1.2.1.2.2.1.17',
  85.     'ifOutNUcastPkts' => '1.3.6.1.2.1.2.2.1.18',
  86.     'ifOutDiscards' => '1.3.6.1.2.1.2.2.1.19',
  87.     'ifDescr' => '1.3.6.1.2.1.2.2.1.2',
  88.     'ifOutErrors' => '1.3.6.1.2.1.2.2.1.20',
  89.     'ifOutQLen' => '1.3.6.1.2.1.2.2.1.21',
  90.     'ifSpecific' => '1.3.6.1.2.1.2.2.1.22',
  91.     'ifType' => '1.3.6.1.2.1.2.2.1.3',
  92.     'ifMtu' => '1.3.6.1.2.1.2.2.1.4',
  93.     'ifSpeed' => '1.3.6.1.2.1.2.2.1.5',
  94.     'ifPhysAddress' => '1.3.6.1.2.1.2.2.1.6',
  95.     'ifAdminHack' => '1.3.6.1.2.1.2.2.1.7',  
  96.     'ifAdminStatus' => '1.3.6.1.2.1.2.2.1.7',
  97.     'ifOperHack' => '1.3.6.1.2.1.2.2.1.8',             
  98.     'ifOperStatus' => '1.3.6.1.2.1.2.2.1.8',
  99.     'ifLastChange' => '1.3.6.1.2.1.2.2.1.9',
  100.     'at' => '1.3.6.1.2.1.3',
  101.     'atTable' => '1.3.6.1.2.1.3.1',
  102.     'atEntry' => '1.3.6.1.2.1.3.1.1',
  103.     'atIfIndex' => '1.3.6.1.2.1.3.1.1.1',
  104.     'atPhysAddress' => '1.3.6.1.2.1.3.1.1.2',
  105.     'atNetAddress' => '1.3.6.1.2.1.3.1.1.3',
  106.     'ip' => '1.3.6.1.2.1.4',
  107.     'ipForwarding' => '1.3.6.1.2.1.4.1',
  108.     'ipOutRequests' => '1.3.6.1.2.1.4.10',
  109.     'ipOutDiscards' => '1.3.6.1.2.1.4.11',
  110.     'ipOutNoRoutes' => '1.3.6.1.2.1.4.12',
  111.     'ipReasmTimeout' => '1.3.6.1.2.1.4.13',
  112.     'ipReasmReqds' => '1.3.6.1.2.1.4.14',
  113.     'ipReasmOKs' => '1.3.6.1.2.1.4.15',
  114.     'ipReasmFails' => '1.3.6.1.2.1.4.16',
  115.     'ipFragOKs' => '1.3.6.1.2.1.4.17',
  116.     'ipFragFails' => '1.3.6.1.2.1.4.18',
  117.     'ipFragCreates' => '1.3.6.1.2.1.4.19',
  118.     'ipDefaultTTL' => '1.3.6.1.2.1.4.2',
  119.     'ipAddrTable' => '1.3.6.1.2.1.4.20',
  120.     'ipAddrEntry' => '1.3.6.1.2.1.4.20.1',
  121.     'ipAdEntAddr' => '1.3.6.1.2.1.4.20.1.1',
  122.     'ipAdEntIfIndex' => '1.3.6.1.2.1.4.20.1.2',
  123.     'ipAdEntNetMask' => '1.3.6.1.2.1.4.20.1.3',
  124.     'ipAdEntBcastAddr' => '1.3.6.1.2.1.4.20.1.4',
  125.     'ipAdEntReasmMaxSize' => '1.3.6.1.2.1.4.20.1.5',
  126.     'ipRouteTable' => '1.3.6.1.2.1.4.21',
  127.     'ipRouteEntry' => '1.3.6.1.2.1.4.21.1',
  128.     'ipRouteDest' => '1.3.6.1.2.1.4.21.1.1',
  129.     'ipRouteAge' => '1.3.6.1.2.1.4.21.1.10',
  130.     'ipRouteMask' => '1.3.6.1.2.1.4.21.1.11',
  131.     'ipRouteMetric5' => '1.3.6.1.2.1.4.21.1.12',
  132.     'ipRouteInfo' => '1.3.6.1.2.1.4.21.1.13',
  133.     'ipRouteIfIndex' => '1.3.6.1.2.1.4.21.1.2',
  134.     'ipRouteMetric1' => '1.3.6.1.2.1.4.21.1.3',
  135.     'ipRouteMetric2' => '1.3.6.1.2.1.4.21.1.4',
  136.     'ipRouteMetric3' => '1.3.6.1.2.1.4.21.1.5',
  137.     'ipRouteMetric4' => '1.3.6.1.2.1.4.21.1.6',
  138.     'ipRouteNextHop' => '1.3.6.1.2.1.4.21.1.7',
  139.     'ipRouteType' => '1.3.6.1.2.1.4.21.1.8',
  140.     'ipRouteProto' => '1.3.6.1.2.1.4.21.1.9',
  141.     'ipNetToMediaTable' => '1.3.6.1.2.1.4.22',
  142.     'ipNetToMediaEntry' => '1.3.6.1.2.1.4.22.1',
  143.     'ipNetToMediaIfIndex' => '1.3.6.1.2.1.4.22.1.1',
  144.     'ipNetToMediaPhysAddress' => '1.3.6.1.2.1.4.22.1.2',
  145.     'ipNetToMediaNetAddress' => '1.3.6.1.2.1.4.22.1.3',
  146.     'ipNetToMediaType' => '1.3.6.1.2.1.4.22.1.4',
  147.     'ipRoutingDiscards' => '1.3.6.1.2.1.4.23',
  148.     'ipInReceives' => '1.3.6.1.2.1.4.3',
  149.     'ipInHdrErrors' => '1.3.6.1.2.1.4.4',
  150.     'ipInAddrErrors' => '1.3.6.1.2.1.4.5',
  151.     'ipForwDatagrams' => '1.3.6.1.2.1.4.6',
  152.     'ipInUnknownProtos' => '1.3.6.1.2.1.4.7',
  153.     'ipInDiscards' => '1.3.6.1.2.1.4.8',
  154.     'ipInDelivers' => '1.3.6.1.2.1.4.9',
  155.     'icmp' => '1.3.6.1.2.1.5',
  156.     'icmpInMsgs' => '1.3.6.1.2.1.5.1',
  157.     'icmpInTimestamps' => '1.3.6.1.2.1.5.10',
  158.     'icmpInTimestampReps' => '1.3.6.1.2.1.5.11',
  159.     'icmpInAddrMasks' => '1.3.6.1.2.1.5.12',
  160.     'icmpInAddrMaskReps' => '1.3.6.1.2.1.5.13',
  161.     'icmpOutMsgs' => '1.3.6.1.2.1.5.14',
  162.     'icmpOutErrors' => '1.3.6.1.2.1.5.15',
  163.     'icmpOutDestUnreachs' => '1.3.6.1.2.1.5.16',
  164.     'icmpOutTimeExcds' => '1.3.6.1.2.1.5.17',
  165.     'icmpOutParmProbs' => '1.3.6.1.2.1.5.18',
  166.     'icmpOutSrcQuenchs' => '1.3.6.1.2.1.5.19',
  167.     'icmpInErrors' => '1.3.6.1.2.1.5.2',
  168.     'icmpOutRedirects' => '1.3.6.1.2.1.5.20',
  169.     'icmpOutEchos' => '1.3.6.1.2.1.5.21',
  170.     'icmpOutEchoReps' => '1.3.6.1.2.1.5.22',
  171.     'icmpOutTimestamps' => '1.3.6.1.2.1.5.23',
  172.     'icmpOutTimestampReps' => '1.3.6.1.2.1.5.24',
  173.     'icmpOutAddrMasks' => '1.3.6.1.2.1.5.25',
  174.     'icmpOutAddrMaskReps' => '1.3.6.1.2.1.5.26',
  175.     'icmpInDestUnreachs' => '1.3.6.1.2.1.5.3',
  176.     'icmpInTimeExcds' => '1.3.6.1.2.1.5.4',
  177.     'icmpInParmProbs' => '1.3.6.1.2.1.5.5',
  178.     'icmpInSrcQuenchs' => '1.3.6.1.2.1.5.6',
  179.     'icmpInRedirects' => '1.3.6.1.2.1.5.7',
  180.     'icmpInEchos' => '1.3.6.1.2.1.5.8',
  181.     'icmpInEchoReps' => '1.3.6.1.2.1.5.9',
  182.     'tcp' => '1.3.6.1.2.1.6',
  183.     'tcpRtoAlgorithm' => '1.3.6.1.2.1.6.1',
  184.     'tcpInSegs' => '1.3.6.1.2.1.6.10',
  185.     'tcpOutSegs' => '1.3.6.1.2.1.6.11',
  186.     'tcpRetransSegs' => '1.3.6.1.2.1.6.12',
  187.     'tcpConnTable' => '1.3.6.1.2.1.6.13',
  188.     'tcpConnEntry' => '1.3.6.1.2.1.6.13.1',
  189.     'tcpConnState' => '1.3.6.1.2.1.6.13.1.1',
  190.     'tcpConnLocalAddress' => '1.3.6.1.2.1.6.13.1.2',
  191.     'tcpConnLocalPort' => '1.3.6.1.2.1.6.13.1.3',
  192.     'tcpConnRemAddress' => '1.3.6.1.2.1.6.13.1.4',
  193.     'tcpConnRemPort' => '1.3.6.1.2.1.6.13.1.5',
  194.     'tcpInErrs' => '1.3.6.1.2.1.6.14',
  195.     'tcpOutRsts' => '1.3.6.1.2.1.6.15',
  196.     'tcpRtoMin' => '1.3.6.1.2.1.6.2',
  197.     'tcpRtoMax' => '1.3.6.1.2.1.6.3',
  198.     'tcpMaxConn' => '1.3.6.1.2.1.6.4',
  199.     'tcpActiveOpens' => '1.3.6.1.2.1.6.5',
  200.     'tcpPassiveOpens' => '1.3.6.1.2.1.6.6',
  201.     'tcpAttemptFails' => '1.3.6.1.2.1.6.7',
  202.     'tcpEstabResets' => '1.3.6.1.2.1.6.8',
  203.     'tcpCurrEstab' => '1.3.6.1.2.1.6.9',
  204.     'udp' => '1.3.6.1.2.1.7',
  205.     'udpInDatagrams' => '1.3.6.1.2.1.7.1',
  206.     'udpNoPorts' => '1.3.6.1.2.1.7.2',
  207.     'udpInErrors' => '1.3.6.1.2.1.7.3',
  208.     'udpOutDatagrams' => '1.3.6.1.2.1.7.4',
  209.     'udpTable' => '1.3.6.1.2.1.7.5',
  210.     'udpEntry' => '1.3.6.1.2.1.7.5.1',
  211.     'udpLocalAddress' => '1.3.6.1.2.1.7.5.1.1',
  212.     'udpLocalPort' => '1.3.6.1.2.1.7.5.1.2',
  213.     'egp' => '1.3.6.1.2.1.8',
  214.     'egpInMsgs' => '1.3.6.1.2.1.8.1',
  215.     'egpInErrors' => '1.3.6.1.2.1.8.2',
  216.     'egpOutMsgs' => '1.3.6.1.2.1.8.3',
  217.     'egpOutErrors' => '1.3.6.1.2.1.8.4',
  218.     'egpNeighTable' => '1.3.6.1.2.1.8.5',
  219.     'egpNeighEntry' => '1.3.6.1.2.1.8.5.1',
  220.     'egpNeighState' => '1.3.6.1.2.1.8.5.1.1',
  221.     'egpNeighStateUps' => '1.3.6.1.2.1.8.5.1.10',
  222.     'egpNeighStateDowns' => '1.3.6.1.2.1.8.5.1.11',
  223.     'egpNeighIntervalHello' => '1.3.6.1.2.1.8.5.1.12',
  224.     'egpNeighIntervalPoll' => '1.3.6.1.2.1.8.5.1.13',
  225.     'egpNeighMode' => '1.3.6.1.2.1.8.5.1.14',
  226.     'egpNeighEventTrigger' => '1.3.6.1.2.1.8.5.1.15',
  227.     'egpNeighAddr' => '1.3.6.1.2.1.8.5.1.2',
  228.     'egpNeighAs' => '1.3.6.1.2.1.8.5.1.3',
  229.     'egpNeighInMsgs' => '1.3.6.1.2.1.8.5.1.4',
  230.     'egpNeighInErrs' => '1.3.6.1.2.1.8.5.1.5',
  231.     'egpNeighOutMsgs' => '1.3.6.1.2.1.8.5.1.6',
  232.     'egpNeighOutErrs' => '1.3.6.1.2.1.8.5.1.7',
  233.     'egpNeighInErrMsgs' => '1.3.6.1.2.1.8.5.1.8',
  234.     'egpNeighOutErrMsgs' => '1.3.6.1.2.1.8.5.1.9',
  235.     'egpAs' => '1.3.6.1.2.1.8.6',
  236.     'transmission' => '1.3.6.1.2.1.10',
  237.     'frame-relay' => '1.3.6.1.2.1.10.32',
  238.     'frDlcmiTable' => '1.3.6.1.2.1.10.32.1',
  239.     'frDlcmiEntry' => '1.3.6.1.2.1.10.32.1.1',
  240.     'frDlcmiIfIndex' => '1.3.6.1.2.1.10.32.1.1.1',
  241.     'frDlcmiState' => '1.3.6.1.2.1.10.32.1.1.2',
  242.     'frDlcmiAddress' => '1.3.6.1.2.1.10.32.1.1.3',
  243.     'frDlcmiAddressLen' => '1.3.6.1.2.1.10.32.1.1.4',
  244.     'frDlcmiPollingInterval' => '1.3.6.1.2.1.10.32.1.1.5',
  245.     'frDlcmiFullEnquiryInterval' => '1.3.6.1.2.1.10.32.1.1.6',
  246.     'frDlcmiErrorThreshold' => '1.3.6.1.2.1.10.32.1.1.7',
  247.     'frDlcmiMonitoredEvents' => '1.3.6.1.2.1.10.32.1.1.8',
  248.     'frDlcmiMaxSupportedVCs' => '1.3.6.1.2.1.10.32.1.1.9',
  249.     'frDlcmiMulticast' => '1.3.6.1.2.1.10.32.1.1.10',
  250.     'frCircuitTable' => '1.3.6.1.2.1.10.32.2',
  251.     'frCircuitEntry' => '1.3.6.1.2.1.10.32.2.1',
  252.     'frCircuitIfIndex' => '1.3.6.1.2.1.10.32.2.1.1',
  253.     'frCircuitDlci' => '1.3.6.1.2.1.10.32.2.1.2',
  254.     'frCircuitState' => '1.3.6.1.2.1.10.32.2.1.3',
  255.     'frCircuitReceivedFECNs' => '1.3.6.1.2.1.10.32.2.1.4',
  256.     'frCircuitReceivedBECNs' => '1.3.6.1.2.1.10.32.2.1.5',
  257.     'frCircuitSentFrames' => '1.3.6.1.2.1.10.32.2.1.6',
  258.     'frCircuitSentOctets' => '1.3.6.1.2.1.10.32.2.1.7',
  259.     'frOutOctets' => '1.3.6.1.2.1.10.32.2.1.7',
  260.     'frCircuitReceivedFrames' => '1.3.6.1.2.1.10.32.2.1.8',
  261.     'frCircuitReceivedOctets' => '1.3.6.1.2.1.10.32.2.1.9',
  262.     'frInOctets' => '1.3.6.1.2.1.10.32.2.1.9',
  263.     'frCircuitCreationTime' => '1.3.6.1.2.1.10.32.2.1.10',
  264.     'frCircuitLastTimeChange' => '1.3.6.1.2.1.10.32.2.1.11',
  265.     'frCircuitCommittedBurst' => '1.3.6.1.2.1.10.32.2.1.12',
  266.     'frCircuitExcessBurst' => '1.3.6.1.2.1.10.32.2.1.13',
  267.     'frCircuitThroughput' => '1.3.6.1.2.1.10.32.2.1.14',
  268.     'frErrTable' => '1.3.6.1.2.1.10.32.3',
  269.     'frErrEntry' => '1.3.6.1.2.1.10.32.3.1',
  270.     'frErrIfIndex' => '1.3.6.1.2.1.10.32.3.1.1',
  271.     'frErrType' => '1.3.6.1.2.1.10.32.3.1.2',
  272.     'frErrData' => '1.3.6.1.2.1.10.32.3.1.3',
  273.     'frErrTime' => '1.3.6.1.2.1.10.32.3.1.4',
  274.     'frame-relay-globals' => '1.3.6.1.2.1.10.32.4',
  275.     'frTrapState' => '1.3.6.1.2.1.10.32.4.1',
  276.     'snmp' => '1.3.6.1.2.1.11',
  277.     'snmpInPkts' => '1.3.6.1.2.1.11.1',
  278.     'snmpInBadValues' => '1.3.6.1.2.1.11.10',
  279.     'snmpInReadOnlys' => '1.3.6.1.2.1.11.11',
  280.     'snmpInGenErrs' => '1.3.6.1.2.1.11.12',
  281.     'snmpInTotalReqVars' => '1.3.6.1.2.1.11.13',
  282.     'snmpInTotalSetVars' => '1.3.6.1.2.1.11.14',
  283.     'snmpInGetRequests' => '1.3.6.1.2.1.11.15',
  284.     'snmpInGetNexts' => '1.3.6.1.2.1.11.16',
  285.     'snmpInSetRequests' => '1.3.6.1.2.1.11.17',
  286.     'snmpInGetResponses' => '1.3.6.1.2.1.11.18',
  287.     'snmpInTraps' => '1.3.6.1.2.1.11.19',
  288.     'snmpOutPkts' => '1.3.6.1.2.1.11.2',
  289.     'snmpOutTooBigs' => '1.3.6.1.2.1.11.20',
  290.     'snmpOutNoSuchNames' => '1.3.6.1.2.1.11.21',
  291.     'snmpOutBadValues' => '1.3.6.1.2.1.11.22',
  292.     'snmpOutGenErrs' => '1.3.6.1.2.1.11.24',
  293.     'snmpOutGetRequests' => '1.3.6.1.2.1.11.25',
  294.     'snmpOutGetNexts' => '1.3.6.1.2.1.11.26',
  295.     'snmpOutSetRequests' => '1.3.6.1.2.1.11.27',
  296.     'snmpOutGetResponses' => '1.3.6.1.2.1.11.28',
  297.     'snmpOutTraps' => '1.3.6.1.2.1.11.29',
  298.     'snmpInBadVersions' => '1.3.6.1.2.1.11.3',
  299.     'snmpEnableAuthenTraps' => '1.3.6.1.2.1.11.30',
  300.     'snmpInBadCommunityNames' => '1.3.6.1.2.1.11.4',
  301.     'snmpInBadCommunityUses' => '1.3.6.1.2.1.11.5',
  302.     'snmpInASNParseErrs' => '1.3.6.1.2.1.11.6',
  303.     'snmpInTooBigs' => '1.3.6.1.2.1.11.8',
  304.     'snmpInNoSuchNames' => '1.3.6.1.2.1.11.9',
  305.     'ifName' => '1.3.6.1.2.1.31.1.1.1.1',
  306.     'ifInMulticastPkts' => '1.3.6.1.2.1.31.1.1.1.2',
  307.     'ifInBroadcastPkts' => '1.3.6.1.2.1.31.1.1.1.3',
  308.     'ifOutMulticastPkts' => '1.3.6.1.2.1.31.1.1.1.4',
  309.     'ifOutBroadcastPkts' => '1.3.6.1.2.1.31.1.1.1.5',
  310.     'ifHCInOctets' => '1.3.6.1.2.1.31.1.1.1.6',
  311.     'ifHCInUcastPkts' => '1.3.6.1.2.1.31.1.1.1.7',
  312.     'ifHCInMulticastPkts' => '1.3.6.1.2.1.31.1.1.1.8',
  313.     'ifHCInBroadcastPkts' => '1.3.6.1.2.1.31.1.1.1.9',
  314.     'ifHCOutOctets' => '1.3.6.1.2.1.31.1.1.1.10',
  315.     'ifHCOutUcastPkts' => '1.3.6.1.2.1.31.1.1.1.11',
  316.     'ifHCOutMulticastPkts' => '1.3.6.1.2.1.31.1.1.1.12',
  317.     'ifHCOutBroadcastPkts' => '1.3.6.1.2.1.31.1.1.1.13',
  318.     'ifLinkUpDownTrapEnable' => '1.3.6.1.2.1.31.1.1.1.14',
  319.     'ifHighSpeed' => '1.3.6.1.2.1.31.1.1.1.15',
  320.     'ifPromiscuousMode' => '1.3.6.1.2.1.31.1.1.1.16',
  321.     'ifConnectorPresent' => '1.3.6.1.2.1.31.1.1.1.17',
  322.     'ifAlias' => '1.3.6.1.2.1.31.1.1.1.18',
  323.     'ifCounterDiscontinuityTime' => '1.3.6.1.2.1.31.1.1.1.19',
  324.     'experimental' => '1.3.6.1.3',
  325.     'private' => '1.3.6.1.4',
  326.     'enterprises' => '1.3.6.1.4.1',
  327.   );
  329. # GIL
  330. my %revOIDS = (); # Reversed %SNMP_util::OIDS hash
  331. my $RevNeeded = 1;
  333. my $agent_start_time = time;
  335. undef $SNMP_util::Host;
  336. undef $SNMP_util::Session;
  337. undef $SNMP_util::Version;
  338. undef $SNMP_util::LHost;
  339. undef $SNMP_util::IPv4only;
  340. $SNMP_util::Debug = 0;
  341. $SNMP_util::CacheFile = "OID_cache.txt";
  342. $SNMP_util::CacheLoaded = 0;
  343. $SNMP_util::Return_array_refs = 0;
  344. $SNMP_util::Return_hash_refs = 0;
  346. srand(time + $$);
  348. ### Prototypes
  349. sub snmpget ($@);
  350. sub snmpgetnext ($@);
  351. sub snmpopen ($$$);
  352. sub snmpwalk ($@);
  353. sub snmpwalk_flg ($$@);
  354. sub snmpset ($@);
  355. sub snmptrap ($$$$$@);
  356. sub snmpgetbulk ($$$@);
  357. sub snmpmaptable ($$@);
  358. sub snmpmaptable4 ($$$@);
  359. sub snmpwalkhash ($$@);
  360. sub toOID (@);
  361. sub snmpmapOID (@);
  362. sub snmpMIB_to_OID ($);
  363. sub encode_oid_with_errmsg ($);
  364. sub Check_OID ($);
  365. sub snmpLoad_OID_Cache ($);
  366. sub snmpQueue_MIB_File (@);
  368. sub version () { $VERSION; }
  370. #
  371. # Start an snmp session
  372. #
  373. sub snmpopen ($$$) {
  374.   my($host, $type, $vars) = @_;
  375.   my($nhost, $port, $community, $lhost, $lport, $nlhost);
  376.   my($timeout, $retries, $backoff, $version);
  377.   my $v4onlystr;
  379.   $type = 0 if (!defined($type));
  380.   $community = "public";
  381.   $nlhost = "";
  383.   ($community, $host) = ($1, $2) if ($host =~ /^(.*)@([^@]+)$/);
  385.   # We can't split on the : character because a numeric IPv6
  386.   # address contains a variable number of :'s
  387.   my $opts;
  388.  if( ($host =~ /^([.*]):(.*)$/) || ($host =~ /^([.*])$/) ) {
  389.     # Numeric IPv6 address between []
  390.     ($host, $opts) = ($1, $2);
  391.   } else {
  392.     # Hostname or numeric IPv4 address
  393.     ($host, $opts) = split(':', $host, 2);
  394.   }
  395.   ($port, $timeout, $retries, $backoff, $version, $v4onlystr) = split(':', $opts, 6)
  396.     if(defined($opts) && (length $opts > 0) );
  398.   undef($version) if (defined($version) && length($version) <= 0);
  399.   $v4onlystr = "" unless defined $v4onlystr;
  400.   $version = '1' unless defined $version;
  401.   if (defined($port) && ($port =~ /^([^!]*)!(.*)$/)) {
  402.     ($port, $lhost) = ($1, $2);
  403.     $nlhost = $lhost;
  404.     ($lhost, $lport) = ($1, $2) if ($lhost =~ /^(.*)!(.*)$/);
  405.     undef($lhost) if (defined($lhost) && (length($lhost) <= 0));
  406.     undef($lport) if (defined($lport) && (length($lport) <= 0));
  407.   }
  408.   undef($port) if (defined($port) && length($port) <= 0);
  409.   $port = 162 if ($type == 1 && !defined($port));
  410.   $nhost = "$community@$host";
  411.   $nhost .= ":" . $port if (defined($port));
  413.   if ((!defined($SNMP_util::Session))
  414.     || ($SNMP_util::Host ne $nhost)
  415.     || ($SNMP_util::Version ne $version)
  416.     || ($SNMP_util::LHost ne $nlhost)
  417.     || ($SNMP_util::IPv4only ne $v4onlystr)) {
  418.     if (defined($SNMP_util::Session)) {
  419.       $SNMP_util::Session->close();    
  420.       undef $SNMP_util::Session;
  421.       undef $SNMP_util::Host;
  422.       undef $SNMP_util::Version;
  423.       undef $SNMP_util::LHost;
  424.       undef $SNMP_util::IPv4only;
  425.     }
  426.     $SNMP_util::Session = ($version =~ /^2c?$/i)
  427.       ? SNMPv2c_Session->open($host, $community, $port, undef,
  428. $lport, undef, $lhost, ($v4onlystr eq 'v4only') ? 1:0 )
  429.       : SNMP_Session->open($host, $community, $port, undef,
  430. $lport, undef, $lhost, ($v4onlystr eq 'v4only') ? 1:0 );
  431.     ($SNMP_util::Host = $nhost, $SNMP_util::Version = $version,
  432.       $SNMP_util::LHost = $nlhost, $SNMP_util::IPv4only = $v4onlystr) if defined($SNMP_util::Session);
  433.   }
  435.   if (defined($SNMP_util::Session)) {
  436.     if (ref $vars->[0] eq 'HASH') {
  437.       my $opts = shift @$vars;
  438.       foreach $type (keys %$opts) {
  439. if ($type eq 'return_array_refs') {
  440.   $SNMP_util::Return_array_refs = $opts->{$type};
  441. } elsif ($type eq 'return_hash_refs') {
  442.   $SNMP_util::Return_hash_refs = $opts->{$type};
  443. } else {
  444.   if (exists $SNMP_util::Session->{$type}) {
  445.     if ($type eq 'timeout') {
  446.       $SNMP_util::Session->set_timeout($opts->{$type});
  447.     } elsif ($type eq 'retries') {
  448.       $SNMP_util::Session->set_retries($opts->{$type});
  449.     } elsif ($type eq 'backoff') {
  450.       $SNMP_util::Session->set_backoff($opts->{$type});
  451.     } else {
  452.       $SNMP_util::Session->{$type} = $opts->{$type};
  453.     }
  454.   } else {
  455.     carp "SNMPopen Unknown SNMP Option Key '$type'n"
  456.       unless ($SNMP_Session::suppress_warnings > 1);
  457.   }
  458. }
  459.       }
  460.     }
  461.     $SNMP_util::Session->set_timeout($timeout)
  462.       if (defined($timeout) && (length($timeout) > 0));
  463.     $SNMP_util::Session->set_retries($retries)
  464.       if (defined($retries) && (length($retries) > 0));
  465.     $SNMP_util::Session->set_backoff($backoff)
  466.       if (defined($backoff) && (length($backoff) > 0));
  467.   }
  468.   return $SNMP_util::Session;
  469. }
  472. #
  473. # A restricted snmpget.
  474. #
  475. sub snmpget ($@) {
  476.   my($host, @vars) = @_;
  477.   my(@enoid, $var, $response, $bindings, $binding, $value, $oid, @retvals);
  478.   my $session;
  480.   $session = &snmpopen($host, 0, @vars);
  481.   if (!defined($session)) {
  482.     carp "SNMPGET Problem for $hostn"
  483.       unless ($SNMP_Session::suppress_warnings > 1);
  484.     return undef;
  485.   }
  487.   @enoid = &toOID(@vars);
  488.   return undef unless defined $enoid[0];
  490.   if ($session->get_request_response(@enoid)) {
  491.     $response = $session->pdu_buffer;
  492.     ($bindings) = $session->decode_get_response($response);
  493.     while ($bindings) {
  494.       ($binding, $bindings) = decode_sequence($bindings);
  495.       ($oid, $value) = decode_by_template($binding, "%O%@");
  496.       my $tempo = pretty_print($value);
  497.       push @retvals, $tempo;
  498.     }
  499.     return wantarray ? @retvals : $retvals[0];
  500.   }
  501.   $var = join(' ', @vars);
  502.   carp "SNMPGET Problem for $var on $hostn"
  503.     unless ($SNMP_Session::suppress_warnings > 1);
  504.   return undef;
  505. }
  507. #
  508. # A restricted snmpgetnext.
  509. #
  510. sub snmpgetnext ($@) {
  511.   my($host, @vars) = @_;
  512.   my(@enoid, $var, $response, $bindings, $binding);
  513.   my($value, $upoid, $oid, @retvals);
  514.   my($noid);
  515.   my $session;
  517.   $session = &snmpopen($host, 0, @vars);
  518.   if (!defined($session)) {
  519.     carp "SNMPGETNEXT Problem for $hostn"
  520.       unless ($SNMP_Session::suppress_warnings > 1);
  521.     return undef;
  522.   }
  524.   @enoid = &toOID(@vars);
  525.   return undef unless defined $enoid[0];
  527.   undef @vars;
  528.   undef @retvals;
  529.   foreach $noid (@enoid) {
  530.     $upoid = pretty_print($noid);
  531.     push(@vars, $upoid);
  532.   }
  533.   if ($session->getnext_request_response(@enoid)) {
  534.     $response = $session->pdu_buffer;
  535.     ($bindings) = $session->decode_get_response($response);
  536.     while ($bindings) {
  537.       ($binding, $bindings) = decode_sequence($bindings);
  538.       ($oid, $value) = decode_by_template($binding, "%O%@");
  539.       my $tempo = pretty_print($oid);
  540.       my $tempv = pretty_print($value);
  541.       push @retvals, "$tempo:$tempv";
  542.     }
  543.     return wantarray ? @retvals : $retvals[0];
  544.   } else {
  545.     $var = join(' ', @vars);
  546.     carp "SNMPGETNEXT Problem for $var on $hostn"
  547.       unless ($SNMP_Session::suppress_warnings > 1);
  548.     return undef;
  549.   }
  550. }
  552. #
  553. # A restricted snmpwalk.
  554. #
  555. sub snmpwalk ($@) {
  556.   my($host, @vars) = @_;
  557.   return(&snmpwalk_flg($host, undef, @vars));
  558. }
  560. #
  561. # Walk the MIB, putting everything you find into hashes.
  562. #
  563. sub snmpwalkhash($$@) {
  564. #  my($host, $hash_sub, @vars) = @_;
  565.   return(&snmpwalk_flg( @_ ));
  566. }
  568. sub snmpwalk_flg ($$@) {
  569.   my($host, $hash_sub, @vars) = @_;
  570.   my(@enoid, $var, $response, $bindings, $binding);
  571.   my($value, $upoid, $oid, @retvals, @retvaltmprefs);
  572.   my($got, @nnoid, $noid, $ok, $ix, @avars);
  573.   my $session;
  574.   my(%soid);
  575.   my(%done, %rethash, $h_ref);
  577.   $session = &snmpopen($host, 0, @vars);
  578.   if (!defined($session)) {
  579.     carp "SNMPWALK Problem for $hostn"
  580.       unless ($SNMP_Session::suppress_warnings > 1);
  581.     return undef;
  582.   }
  584.   $h_ref = (ref $vars[$#vars] eq "HASH") ? pop(@vars) : %rethash;
  586.   @enoid = toOID(@vars);
  587.   return undef unless defined $enoid[0];
  589.   # GIL
  590.   #
  591.   # Create/Refresh a reversed hash with oid -> name
  592.   #
  593.   if (defined($hash_sub) && ($RevNeeded)) {
  594.       %revOIDS = reverse %SNMP_util::OIDS;
  595.       $RevNeeded = 0;
  596.   }
  598.   $got = 0;
  599.   @nnoid = @enoid;
  600.   undef @vars;
  601.   foreach $noid (@enoid) {
  602.     $upoid = pretty_print($noid);
  603.     push(@vars, $upoid);
  604.   }
  606.   # @vars is the original set of walked variables.
  607.   # @avars is the current set of walked variables as the
  608.   # walk goes on.
  609.   # @vars stays static while @avars may shrink as we reach end
  610.   # of walk for individual variables during PDU exchange.
  611.    
  612.   @avars = @vars;
  614.   # IlvJa
  615.   #
  616.   # Create temporary array of refs to return vals.
  618.   if ($SNMP_util::Return_array_refs) {
  619.     for($ix = 0;$ix < scalar @vars; $ix++) {
  620.       my $tmparray = [];
  621.       $retvaltmprefs[$ix] = $tmparray;
  622.       $retvals[$ix] = $tmparray;
  623.     }
  624.   }
  627.   while(($SNMP_util::Version ne '1' && $session->{'use_getbulk'})
  628.     ? $session->getbulk_request_response(0,
  629.   $session->default_max_repetitions(),
  630.   @nnoid)
  631.     : $session->getnext_request_response(@nnoid))
  632.   {
  633.     $got = 1;
  634.     $response = $session->pdu_buffer;
  635.     ($bindings) = $session->decode_get_response($response);
  636.     $ix = 0;
  637.     while ($bindings) {
  638.       ($binding, $bindings) = decode_sequence($bindings);
  639.       unless ($nnoid[$ix]) { # IlvJa
  640. $ix = ++$ix % (scalar @avars);
  641. next;
  642.       }
  643.       ($oid, $value) = decode_by_template($binding, "%O%@");
  644.       $ok = 0;
  645.       my $tempo = pretty_print($oid);
  646.       $noid = $avars[$ix];  # IlvJa
  647.       if ($tempo =~ /^$noid./ || $tempo eq $noid ) {
  648. $ok = 1;
  649. $upoid = $noid;
  650.       } else {
  651. # IlvJa
  652. #
  653. # The walk for variable $var[$ix] has been finished as
  654. # $nnoid[$ix] no longer is in the $avar[$ix] OID tree.
  655. # So we exclude this variable from further requests.
  657. $avars[$ix] = "";
  658. $nnoid[$ix] = "";
  659. $retvaltmprefs[$ix] = undef if $SNMP_util::Return_array_refs;
  660.       }
  661.       if ($ok) {
  662. my $tmp = encode_oid_with_errmsg ($tempo);
  663. return undef unless defined $tmp;
  664. next if (exists($done{$tmp})); # GIL
  665. $nnoid[$ix] = $tmp;   # Keep on walking. (IlvJa)
  666. my $tempv = pretty_print($value);
  667. if (defined($hash_sub)) {
  668.   #
  669.   # extract name of the oid, if possible, the rest becomes the instance
  670.   #
  671.   my $inst = "";
  672.   my $upo = $upoid;
  673.   while (!exists($revOIDS{$upo}) && length($upo)) {
  674.     $upo =~ s/(.d+?)$//;
  675.     if (defined($1) && length($1)) {
  676.       $inst = $1 . $inst;
  677.     } else {
  678.       $upo = "";
  679.       last;
  680.     }
  681.   }
  682.   if (length($upo) && exists($revOIDS{$upo})) {
  683.     $upo = $revOIDS{$upo} . $inst;
  684.   } else {
  685.     $upo = $upoid;
  686.   }
  688.   $inst = "";
  689.   while (!exists($revOIDS{$tempo}) && length($tempo)) {
  690.     $tempo =~ s/(.d+?)$//;
  691.     if (defined($1) && length($1)) {
  692.       $inst = $1 . $inst;
  693.     } else {
  694.       $tempo = "";
  695.       last;
  696.     }
  697.   }
  698.   if (length($tempo) && exists($revOIDS{$tempo})) {
  699.     $tempo = $revOIDS{$tempo} . $inst;
  700.   } else {
  701.     $tempo = pretty_print($oid);
  702.   }
  703.   #
  704.   # call hash_sub
  705.   #
  706.   &$hash_sub($h_ref, $host, $revOIDS{$tempo}, $tempo, $inst,
  707. $tempv, $upo);
  708. } else {
  709.   if ($SNMP_util::Return_array_refs) {
  710.     $tempo=~s/^$upoid.//;
  711.     push @{$retvaltmprefs[$ix]}, "$tempo:$tempv";
  712.   } else {
  713.     $tempo=~s/^$upoid.// if ($#enoid <= 0);
  714.     push @retvals, "$tempo:$tempv";
  715.   }
  716. }
  717. $done{$tmp} = 1; # GIL
  718.       }
  719.       $ix = ++$ix % (scalar @avars);
  720.     }
  722.     # Ok, @nnoid should contain the remaining variables for the
  723.     # next request.  Some or all entries in @nnoid might be the empty
  724.     # string.  If the nth element in @nnoid is "" that means that
  725.     # the walk related to the nth variable in the last request has been
  726.     # completed and we should not include that var in subsequent reqs.
  728.     # Clean up both @nnoid and @avars so "" elements are removed.
  729.     @nnoid = grep (($_), @nnoid);
  730.     @avars = grep (($_), @avars);
  731.     @retvaltmprefs = grep (($_), @retvaltmprefs);
  733.     last if ($#nnoid < 0);   # @nnoid empty means we are done walking.
  734.   }
  735.   if ($got) {
  736.     if (defined($hash_sub)) {
  737. return ($h_ref) if ($SNMP_util::Return_hash_refs);
  738.      return (%$h_ref);
  739.     } else {
  740.      return (@retvals);
  741.     }
  742.   } else {
  743.     $var = join(' ', @vars);
  744.     carp "SNMPWALK Problem for $var on $hostn"
  745.       unless ($SNMP_Session::suppress_warnings > 1);
  746.     return undef;
  747.   }
  748. }
  750. #
  751. # A restricted snmpset.
  752. #
  753. sub snmpset($@) {
  754.   my($host, @vars) = @_;
  755.   my(@enoid, $response, $bindings, $binding);
  756.   my($oid, @retvals, $type, $value, $val);
  757.   my $session;
  759.   $session = &snmpopen($host, 0, @vars);
  760.   if (!defined($session)) {
  761.     carp "SNMPSET Problem for $hostn"
  762.       unless ($SNMP_Session::suppress_warnings > 1);
  763.     return undef;
  764.   }
  766.   while(@vars) {
  767.     ($oid) = toOID((shift @vars));
  768.     $type  = shift @vars;
  769.     $value = shift @vars;
  770.     $type =~ tr/A-Z/a-z/;
  771.     if ($type eq "int") {
  772.       $val = encode_int($value);
  773.     } elsif ($type eq "integer") {
  774.       $val = encode_int($value);
  775.     } elsif ($type eq "string") {
  776.       $val = encode_string($value);
  777.     } elsif ($type eq "octetstring") {
  778.       $val = encode_string($value);
  779.     } elsif ($type eq "octet string") {
  780.       $val = encode_string($value);
  781.     } elsif ($type eq "oid") {
  782.       $val = encode_oid_with_errmsg($value);
  783.     } elsif ($type eq "object id") {
  784.       $val = encode_oid_with_errmsg($value);
  785.     } elsif ($type eq "object identifier") {
  786.       $val = encode_oid_with_errmsg($value);
  787.     } elsif ($type eq "ipaddr") {
  788.       $val = encode_ip_address($value);
  789.     } elsif ($type eq "ip address") {
  790.       $val = encode_ip_address($value);
  791.     } elsif ($type eq "timeticks") {
  792.       $val = encode_timeticks($value);
  793.     } elsif ($type eq "uint") {
  794.       $val = encode_uinteger32($value);
  795.     } elsif ($type eq "uinteger") {
  796.       $val = encode_uinteger32($value);
  797.     } elsif ($type eq "uinteger32") {
  798.       $val = encode_uinteger32($value);
  799.     } elsif ($type eq "unsigned int") {
  800.       $val = encode_uinteger32($value);
  801.     } elsif ($type eq "unsigned integer") {
  802.       $val = encode_uinteger32($value);
  803.     } elsif ($type eq "unsigned integer32") {
  804.       $val = encode_uinteger32($value);
  805.     } elsif ($type eq "counter") {
  806.       $val = encode_counter32($value);
  807.     } elsif ($type eq "counter32") {
  808.       $val = encode_counter32($value);
  809.     } elsif ($type eq "counter64") {
  810.       $val = encode_counter64($value);
  811.     } elsif ($type eq "gauge") {
  812.       $val = encode_gauge32($value);
  813.     } elsif ($type eq "gauge32") {
  814.       $val = encode_gauge32($value);
  815.     } else {
  816.       carp "unknown SNMP type: $typen"
  817. unless ($SNMP_Session::suppress_warnings > 1);
  818.       return undef;
  819.     }
  820.     if (!defined($val)) {
  821.       carp "SNMP type $type value $value didn't encode properlyn"
  822. unless ($SNMP_Session::suppress_warnings > 1);
  823.       return undef;
  824.     }
  825.     push @enoid, [$oid,$val];
  826.   }
  827.   return undef unless defined $enoid[0];
  828.   if ($session->set_request_response(@enoid)) {
  829.     $response = $session->pdu_buffer;
  830.     ($bindings) = $session->decode_get_response($response);
  831.     while ($bindings) {
  832.       ($binding, $bindings) = decode_sequence($bindings);
  833.       ($oid, $value) = decode_by_template($binding, "%O%@");
  834.       my $tempo = pretty_print($value);
  835.       push @retvals, $tempo;
  836.     }
  837.     return wantarray ? @retvals : $retvals[0];
  838.   }
  839.   return undef;
  840. }
  842. #
  843. # Send an SNMP trap
  844. #
  845. sub snmptrap($$$$$@) {
  846.   my($host, $ent, $agent, $gen, $spec, @vars) = @_;
  847.   my($oid, @retvals, $type, $value);
  848.   my(@enoid);
  849.   my $session;
  851.   $session = &snmpopen($host, 1, @vars);
  852.   if (!defined($session)) {
  853.     carp "SNMPTRAP Problem for $hostn"
  854.       unless ($SNMP_Session::suppress_warnings > 1);
  855.     return undef;
  856.   }
  858.   if ($agent =~ /^d+.d+.d+.d+(.*)/ ) {
  859.     $agent = pack("C*", split /./, $agent);
  860.   } else {
  861.     $agent = inet_aton($agent);
  862.   }
  863.   push @enoid, toOID(($ent));
  864.   push @enoid, encode_ip_address($agent);
  865.   push @enoid, encode_int($gen);
  866.   push @enoid, encode_int($spec);
  867.   push @enoid, encode_timeticks((time-$agent_start_time) * 100);
  868.   while(@vars) {
  869.     ($oid) = toOID((shift @vars));
  870.     $type  = shift @vars;
  871.     $value = shift @vars;
  872.     if ($type =~ /string/i) {
  873.       $value = encode_string($value);
  874.       push @enoid, [$oid,$value];
  875.     } elsif ($type =~ /ipaddr/i) {
  876.       $value = encode_ip_address($value);
  877.       push @enoid, [$oid,$value];
  878.     } elsif ($type =~ /int/i) {
  879.       $value = encode_int($value);
  880.       push @enoid, [$oid,$value];
  881.     } elsif ($type =~ /oid/i) {
  882.       my $tmp = encode_oid_with_errmsg($value);
  883.       return undef unless defined $tmp;
  884.       push @enoid, [$oid,$tmp];
  885.     } else {
  886.       carp "unknown SNMP type: $typen"
  887. unless ($SNMP_Session::suppress_warnings > 1);
  888.       return undef;
  889.     }
  890.   }
  891.   return($session->trap_request_send(@enoid));
  892. }
  894. #
  895. # A restricted snmpgetbulk.
  896. #
  897. sub snmpgetbulk ($$$@) {
  898.   my($host, $nr, $mr, @vars) = @_;
  899.   my(@enoid, $var, $response, $bindings, $binding);
  900.   my($value, $upoid, $oid, @retvals);
  901.   my($noid);
  902.   my $session;
  904.   $session = &snmpopen($host, 0, @vars);
  905.   if (!defined($session)) {
  906.     carp "SNMPGETBULK Problem for $hostn"
  907.       unless ($SNMP_Session::suppress_warnings > 1);
  908.     return undef;
  909.   }
  911.   @enoid = &toOID(@vars);
  912.   return undef unless defined $enoid[0];
  914.   undef @vars;
  915.   undef @retvals;
  916.   foreach $noid (@enoid) {
  917.     $upoid = pretty_print($noid);
  918.     push(@vars, $upoid);
  919.   }
  920.   if ($session->getbulk_request_response($nr, $mr, @enoid)) {
  921.     $response = $session->pdu_buffer;
  922.     ($bindings) = $session->decode_get_response($response);
  923.     while ($bindings) {
  924.       ($binding, $bindings) = decode_sequence($bindings);
  925.       ($oid, $value) = decode_by_template($binding, "%O%@");
  926.       my $tempo = pretty_print($oid);
  927.       my $tempv = pretty_print($value);
  928.       push @retvals, "$tempo:$tempv";
  929.     }
  930.     return (@retvals);
  931.   } else {
  932.     $var = join(' ', @vars);
  933.     carp "SNMPGETBULK Problem for $var on $hostn"
  934.       unless ($SNMP_Session::suppress_warnings > 1);
  935.     return undef;
  936.   }
  937. }
  939. #
  940. # walk a table, calling a user-supplied function for each
  941. # column of a table.
  942. #
  943. sub snmpmaptable($$@) {
  944.   my($host, $fun, @vars) = @_;
  945.   return snmpmaptable4($host, $fun, 0, @vars);
  946. }
  948. sub snmpmaptable4($$$@) {
  949.   my($host, $fun, $max_reps, @vars) = @_;
  950.   my(@enoid, $var, $session);
  952.   $session = &snmpopen($host, 0, @vars);
  953.   if (!defined($session)) {
  954.     carp "SNMPMAPTABLE Problem for $hostn"
  955.       unless ($SNMP_Session::suppress_warnings > 1);
  956.     return undef;
  957.   }
  959.   foreach $var (toOID(@vars)) {
  960.     push(@enoid, [split('.', pretty_print($var))]);
  961.   }
  963.   $max_reps = $session->default_max_repetitions() if ($max_reps <= 0);
  965.   return $session->map_table_start_end( [@enoid],
  966. sub() {
  967.   my ($ind, @vals) = @_;
  968.   my (@pvals, $val);
  970.   foreach $val (@vals) {
  971.     push(@pvals, pretty_print($val));
  972.   }
  973.   &$fun($ind, @pvals);
  974. },
  975. "", undef, $max_reps);
  976. }
  979. #
  980. #  Given an OID in either ASN.1 or mixed text/ASN.1 notation, return an
  981. #  encoded OID.
  982. #
  983. sub toOID(@) {
  984.   my(@vars) = @_;
  985.   my($oid, $var, $tmp, $tmpv, @retvar);
  987.   undef @retvar;
  988.   foreach $var (@vars) {
  989.     ($oid, $tmp) = &Check_OID($var);
  990.     if (!$oid && $SNMP_util::CacheLoaded == 0) {
  991.       $tmp = $SNMP_Session::suppress_warnings;
  992.       $SNMP_Session::suppress_warnings = 1000;
  994.       &snmpLoad_OID_Cache($SNMP_util::CacheFile);
  996.       $SNMP_util::CacheLoaded = 1;
  997.       $SNMP_Session::suppress_warnings = $tmp;
  999.       ($oid, $tmp) = &Check_OID($var);
  1000.     }
  1001.     while (!$oid && $#SNMP_util::MIB_Files >= 0) {
  1002.       $tmp = $SNMP_Session::suppress_warnings;
  1003.       $SNMP_Session::suppress_warnings = 1000;
  1005.       snmpMIB_to_OID(shift(@SNMP_util::MIB_Files));
  1007.       $SNMP_Session::suppress_warnings = $tmp;
  1009.       ($oid, $tmp) = &Check_OID($var);
  1010.       if ($oid) {
  1011. open(CACHE, ">>$SNMP_util::CacheFile");
  1012. print CACHE "$tmpt$oidn";
  1013. close(CACHE);
  1014.       }
  1015.     }
  1016.     if ($oid) {
  1017.       $var =~ s/^$tmp/$oid/;
  1018.     } else {
  1019.       carp "Unknown SNMP var $varn"
  1020.       unless ($SNMP_Session::suppress_warnings > 1);
  1021.       next;
  1022.     }
  1023.     while ($var =~ /"([^"]*)"/) {
  1024.       $tmp = sprintf("%d.%s", length($1), join(".", map(ord, split(//, $1))));
  1025.       $var =~ s/"$1"/$tmp/;
  1026.     }
  1027.     print "toOID: $varn" if $SNMP_util::Debug;
  1028.     $tmp = encode_oid_with_errmsg($var);
  1029.     return undef unless defined $tmp;
  1030.     push(@retvar, $tmp);
  1031.   }
  1032.   return @retvar;
  1033. }
  1035. #
  1036. #  Add passed-in text, OID pairs to the OID mapping table.
  1037. #
  1038. sub snmpmapOID(@)
  1039. {
  1040.   my(@vars) = @_;
  1041.   my($oid, $txt, $ind);
  1043.   $ind = 0;
  1044.   while($ind <= $#vars) {
  1045.     $txt = $vars[$ind++];
  1046.     next unless($txt =~ /^(([a-zA-Z][a-zA-Zd-]*.)*([a-zA-Z][a-zA-Zd-]*))$/);
  1048.     $oid = $vars[$ind++];
  1049.     next unless($oid =~ /^((d+.)*d+)$/);
  1051.     $SNMP_util::OIDS{$txt} = $oid;
  1052.     $RevNeeded = 1;
  1053.     print "snmpmapOID: $txt => $oidn" if $SNMP_util::Debug;
  1054.   }
  1055.   
  1056.   return undef;
  1057. }
  1059. #
  1060. # Open the passed-in file name and read it in to populate
  1061. # the cache of text-to-OID map table.  It expects lines
  1062. # with two fields, the first the textual string like "ifInOctets",
  1063. # and the second the OID value, like "1.3.6.1.2.1.2.2.1.10".
  1064. #
  1065. # blank lines and anything after a '#' or between '--' is ignored.
  1066. #
  1067. sub snmpLoad_OID_Cache ($) {
  1068.   my($arg) = @_;
  1069.   my($txt, $oid);
  1071.   if (!open(CACHE, $arg)) {
  1072.     carp "snmpLoad_OID_Cache: Can't open $arg: $!"
  1073.       unless ($SNMP_Session::suppress_warnings > 1);
  1074.     return -1;
  1075.   }
  1077.   while(<CACHE>) {
  1078.     s/#.*//;
  1079.     s/--.*--//g;
  1080.     s/--.*//;
  1081.     next if (/^$/);
  1082.     next unless (/s/);
  1083.     chop;
  1084.     ($txt, $oid) = split(' ', $_, 2);
  1085.     &snmpmapOID($txt, $oid);
  1086.   }
  1087.   close(CACHE);
  1088.   return 0;
  1089. }
  1091. #
  1092. # Check to see if an OID is in the text-to-OID cache.
  1093. # Returns the OID and the corresponding text as two separate
  1094. # elements.
  1095. #
  1096. sub Check_OID ($) {
  1097.   my($var) = @_;
  1098.   my($tmp, $tmpv, $oid);
  1100.   if ($var =~ /^(([a-zA-Z][a-zA-Zd-]*.)*([a-zA-Z][a-zA-Zd-]*))/)
  1101.   {
  1102.     $tmp = $&;
  1103.     $tmpv = $tmp;
  1104.     for (;;) {
  1105.       last if defined($SNMP_util::OIDS{$tmpv});
  1106.       last if !($tmpv =~ s/^[^.]*.//);
  1107.     }
  1108.     $oid = $SNMP_util::OIDS{$tmpv};
  1109.     if ($oid) {
  1110.       return ($oid, $tmp);
  1111.     } else {
  1112.       return undef;
  1113.     }
  1114.   }
  1115.   return ($var, $var);
  1116. }
  1118. #
  1119. # Save the passed-in list of MIB files until an OID can't be
  1120. # found in the existing table.  At that time the MIB file will
  1121. # be loaded, and the lookup attempted again.
  1122. #
  1123. sub snmpQueue_MIB_File (@) {
  1124.   my(@files) = @_;
  1125.   my($file);
  1127.   foreach $file (@files) {
  1128.     push(@SNMP_util::MIB_Files, $file);
  1129.   }
  1130. }
  1132. #
  1133. # Read in the passed MIB file, parsing it
  1134. # for their text-to-OID mappings
  1135. #
  1136. sub snmpMIB_to_OID ($) {
  1137.   my($arg) = @_;
  1138.   my($quote, $buf, $var, $code, $val, $tmp, $tmpv, $strt);
  1139.   my($ret, $pass, $pos, $need2pass, $cnt, %prev);
  1140.   my(%Link) = (
  1141.     'org' => 'iso',
  1142.     'dod' => 'org',
  1143.     'internet' => 'dod',
  1144.     'directory' => 'internet',
  1145.     'mgmt' => 'internet',
  1146.     'mib-2' => 'mgmt',
  1147.     'experimental' => 'internet',
  1148.     'private' => 'internet',
  1149.     'enterprises' => 'private',
  1150.   );
  1152.   if (!open(MIB, $arg)) {
  1153.     carp "snmpMIB_to_OID: Can't open $arg: $!"
  1154.       unless ($SNMP_Session::suppress_warnings > 1);
  1155.     return -1;
  1156.   }
  1157.   print "snmpMIB_to_OID: loading $argn" if $SNMP_util::Debug;
  1158.   $ret = 0;
  1159.   $pass = 0;
  1160.   $need2pass = 1;
  1161.   $cnt = 0;
  1162.   $pos = tell(MIB);
  1163.   while($need2pass) {
  1164.     while(<MIB>) {
  1165.       s/--.*--//g; # throw away comments (-- anything --)
  1166.       s/--.*//; # throw away comments (-- anything EOL)
  1167.       if ($quote) {
  1168. next unless /"/;
  1169. $quote = 0;
  1170.       }
  1171.       chop;
  1172. #
  1173. # $buf = "$buf $_";
  1174. # Previous line removed (and following replacement)
  1175. # suggested by Brian Reichert, reichert@numachi.com
  1176. #
  1177.       $buf .= ' ' . $_;
  1178.       $buf =~ s/s+/ /g;
  1180.       if ($buf =~ / DEFINITIONS ::= BEGIN/) {
  1181. if ($pass == 0 && $need2pass) {
  1182.   seek(MIB, $pos, 0);
  1183.   $buf = "";
  1184.   $pass = 1;
  1185.   $need2pass = 0;
  1186.   $cnt = 0;
  1187.   next;
  1188. }
  1189. $need2pass = 0;
  1190. $pass = 0;
  1191. $pos = tell(MIB);
  1192. undef %Link;
  1193. undef %prev;
  1194. %Link = (
  1195.   'org' => 'iso',
  1196.   'dod' => 'org',
  1197.   'internet' => 'dod',
  1198.   'directory' => 'internet',
  1199.   'mgmt' => 'internet',
  1200.   'mib-2' => 'mgmt',
  1201.   'experimental' => 'internet',
  1202.   'private' => 'internet',
  1203.   'enterprises' => 'private',
  1204. );
  1205. $buf = "";
  1206. next;
  1207.       }
  1209.       $buf =~ s/OBJECT-TYPE/OBJECT IDENTIFIER/;
  1210.       $buf =~ s/OBJECT-IDENTITY/OBJECT IDENTIFIER/;
  1211.       $buf =~ s/OBJECT-GROUP/OBJECT IDENTIFIER/;
  1212.       $buf =~ s/MODULE-IDENTITY/OBJECT IDENTIFIER/;
  1213.       $buf =~ s/ IMPORTS .*;//;
  1214.       $buf =~ s/ SEQUENCE {.*}//;
  1215.       $buf =~ s/ SYNTAX .*//;
  1216.       $buf =~ s/ [w-]+ ::= OBJECT IDENTIFIER//;
  1217.       $buf =~ s/ OBJECT IDENTIFIER .* ::= {/ OBJECT IDENTIFIER ::= {/;
  1218.       $buf =~ s/".*"//;
  1219.       if ($buf =~ /"/) {
  1220. $quote = 1;
  1221.       }
  1223.       if ($buf =~ / ([w-]+) OBJECT IDENTIFIER ::= {([^}]+)}/) {
  1224. $var = $1;
  1225. $buf = $2;
  1226. undef $val;
  1227. $buf =~ s/ +$//;
  1228. ($code, $val) = split(' ', $buf, 2);
  1230. if (!defined($val) || (length($val) <= 0)) {
  1231.   $SNMP_util::OIDS{$var} = $code;
  1232.   $cnt++;
  1233.   print "'$var' => '$code'n" if $SNMP_util::Debug;
  1234. } else {
  1235.   $strt = $code;
  1236.   while($val =~ / /) {
  1237.     ($tmp, $val) = split(' ', $val, 2);
  1238.     if ($tmp =~ /([w-]+)((d+))/) {
  1239.       $tmp = $1;
  1240.       $tmpv = "$SNMP_util::OIDS{$strt}.$2";
  1241.       $Link{$tmp} = $strt;
  1242.       if (!defined($prev{$tmp}) && defined($SNMP_util::OIDS{$tmp})) {
  1243. if ($tmpv ne $SNMP_util::OIDS{$tmp}) {
  1244.   $strt = "$strt.$tmp";
  1245.   $SNMP_util::OIDS{$strt} = $tmpv;
  1246.   $cnt++;
  1247. }
  1248.       } else {
  1249. $prev{$tmp} = 1;
  1250. $SNMP_util::OIDS{$tmp} = $tmpv;
  1251. $cnt++;
  1252. $strt = $tmp;
  1253.       }
  1254.     }
  1255.   }
  1257.   if (!defined($SNMP_util::OIDS{$strt})) {
  1258.     if ($pass) {
  1259.       carp "snmpMIB_to_OID: $arg: "$strt" prefix unknown, load the parent MIB first.n"
  1260. unless ($SNMP_Session::suppress_warnings > 1);
  1261.     } else {
  1262. $need2pass = 1;
  1263.     }
  1264.   }
  1265.   $Link{$var} = $strt;
  1266.   $val = "$SNMP_util::OIDS{$strt}.$val";
  1267.   if (!defined($prev{$var}) && defined($SNMP_util::OIDS{$var})) {
  1268.     if ($val ne $SNMP_util::OIDS{$var}) {
  1269.       $var = "$strt.$var";
  1270.     }
  1271.   }
  1273.   $SNMP_util::OIDS{$var} = $val;
  1274.   $prev{$var} = 1;
  1275.   $cnt++;
  1277.   print "'$var' => '$val'n" if $SNMP_util::Debug;
  1278. }
  1279. undef $buf;
  1280.       }
  1281.     }
  1282.     if ($pass == 0 && $need2pass) {
  1283.       seek(MIB, $pos, 0);
  1284.       $buf = "";
  1285.       $pass = 1;
  1286.       $cnt = 0;
  1287.     } else {
  1288.       $ret += $cnt;
  1289.       $need2pass = 0;
  1290.     }
  1291.   }
  1292.   close(MIB);
  1293.   $RevNeeded = 1;
  1294.   return $ret;
  1295. }
  1297. sub encode_oid_with_errmsg ($) {
  1298.   my ($oid) = @_;
  1299.   my $tmp = encode_oid(split(/./, $oid));
  1300.   if (! defined $tmp) {
  1301.     carp "cannot encode Object ID $oid: $BER::errmsg"
  1302.       unless ($SNMP_Session::suppress_warnings > 1);
  1303.     return undef;
  1304.   }
  1305.   return $tmp;
  1306. }
  1308. 1;