snmpWalk.cpp~
上传用户:cnryan
上传日期:2008-12-15
资源大小:260k
文件大小:14k
源码类别:

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*_############################################################################
  2.   _## 
  3.   _##  snmpWalk.cpp  
  4.   _##
  5.   _##  SNMP++v3.2.21
  6.   _##  -----------------------------------------------
  7.   _##  Copyright (c) 2001-2006 Jochen Katz, Frank Fock
  8.   _##
  9.   _##  This software is based on SNMP++2.6 from Hewlett Packard:
  10.   _##  
  11.   _##    Copyright (c) 1996
  12.   _##    Hewlett-Packard Company
  13.   _##  
  14.   _##  ATTENTION: USE OF THIS SOFTWARE IS SUBJECT TO THE FOLLOWING TERMS.
  15.   _##  Permission to use, copy, modify, distribute and/or sell this software 
  16.   _##  and/or its documentation is hereby granted without fee. User agrees 
  17.   _##  to display the above copyright notice and this license notice in all 
  18.   _##  copies of the software and any documentation of the software. User 
  19.   _##  agrees to assume all liability for the use of the software; 
  20.   _##  Hewlett-Packard and Jochen Katz make no representations about the 
  21.   _##  suitability of this software for any purpose. It is provided 
  22.   _##  "AS-IS" without warranty of any kind, either express or implied. User 
  23.   _##  hereby grants a royalty-free license to any and all derivatives based
  24.   _##  upon this software code base. 
  25.   _##  
  26.   _##  Stuttgart, Germany, Fri Jun 16 17:48:57 CEST 2006 
  27.   _##  
  28.   _##########################################################################*/
  29. /*
  30.   snmpWalk.cpp 
  31.   
  32.   Copyright (c) 1996
  33.   Hewlett-Packard Company
  34.   ATTENTION: USE OF THIS SOFTWARE IS SUBJECT TO THE FOLLOWING TERMS.
  35.   Permission to use, copy, modify, distribute and/or sell this software
  36.   and/or its documentation is hereby granted without fee. User agrees
  37.   to display the above copyright notice and this license notice in all
  38.   copies of the software and any documentation of the software. User
  39.   agrees to assume all liability for the use of the software; Hewlett-Packard
  40.   makes no representations about the suitability of this software for any
  41.   purpose. It is provided "AS-IS" without warranty of any kind,either express
  42.   or implied. User hereby grants a royalty-free license to any and all
  43.   derivatives based upon this software code base.
  44.   Peter E. Mellquist
  45. */
  46. char snmpwalk_cpp_version[]="@(#) SNMP++ $Id: snmpWalk.cpp,v 1.9 2005/10/11 18:08:05 katz Exp $";
  47. #include "snmp_pp/snmp_pp.h"
  48. #include <stdlib.h>
  49. #include <stdio.h>
  50. #ifdef SNMP_PP_NAMESPACE
  51. using namespace Snmp_pp;
  52. #endif
  53. #if (__GNUC__ > 2)
  54. #include <iostream>
  55. using std::cerr;
  56. using std::cout;
  57. using std::endl;
  58. using std::flush;
  59. #else
  60. #include <iostream.h>
  61. #endif
  62. #define BULK_MAX 10
  63. int main(int argc, char **argv)
  64. {
  65.   int requests = 0;        // keep track of # of requests
  66.   int objects  = 0;
  67.    //---------[ check the arg count ]----------------------------------------
  68.    if ( argc < 2) {
  69.   cout << "Usage:n";
  70.   cout << "snmpWalk IpAddress | DNSName [StartOid] [options]n";
  71.   cout << "StartOid: sysDescr object is defaultn";
  72.   cout << "options: -vN , use SNMP version 1, 2 or 3, default is 1n";
  73.   cout << "         -PPort , remote port to usen";
  74.   cout << "         -S , only walk within subtreen";
  75.   cout << "         -CCommunity_name, specify community default is 'public' n";
  76.   cout << "         -rN , retries default is N = 1 retryn";
  77.   cout << "         -tN , timeout in hundredths of seconds; default is N = 100n";
  78. #ifdef _SNMPv3
  79.           cout << "         -snSecurityName, " << endl;
  80.           cout << "         -slN , securityLevel to use, default N = 3 = authPriv" << endl;
  81.           cout << "         -smN , securityModel to use, only default N = 3 = USM possiblen";
  82.           cout << "         -cnContextName, default empty string" << endl;
  83.           cout << "         -ceContextEngineID, as hex e.g. 800007E580, default empty string" << endl;
  84.           cout << "         -authPROT, use authentication protocol NONE, SHA or MD5n";
  85.           cout << "         -privPROT, use privacy protocol NONE, DES, 3DESEDE, IDEA, AES128, AES192 or AES256n";
  86.           cout << "         -uaAuthPasswordn";
  87.           cout << "         -upPrivPasswordn";
  88. #endif
  89.   return 1;
  90.    }
  91.    Snmp::socket_startup();  // Initialize socket subsystem
  92.    //---------[ make a GenAddress and Oid object to retrieve ]---------------
  93.    UdpAddress address( argv[1]);      // make a SNMP++ Generic address
  94.    if ( !address.valid()) {           // check validity of address
  95.   cout << "Invalid Address or DNS Name, " << argv[1] << "n";
  96.   return 1;
  97.    }
  98.    Oid oid("1");                      // default is beginning of MIB 
  99.    if ( argc >= 3) {                  // if 3 args, then use the callers Oid
  100.   if ( strstr( argv[2],"-")==0) {
  101.      oid = argv[2];
  102.      if ( !oid.valid()) {            // check validity of user oid
  103.     cout << "Invalid Oid, " << argv[2] << "n";
  104.     return 1;
  105.          }
  106.       }
  107.    }
  108.    //---------[ determine options to use ]-----------------------------------
  109.    snmp_version version=version1;                  // default is v1
  110.    int retries=1;                                  // default retries is 1
  111.    int timeout=100;                                // default is 1 second
  112.    u_short port=161;                               // default snmp port is 161
  113.    OctetStr community("public");                   // community name
  114.    bool subtree = false;
  115. #ifdef _SNMPv3
  116.    OctetStr privPassword("");
  117.    OctetStr authPassword("");
  118.    OctetStr securityName("");
  119.    int securityModel = SecurityModel_USM;
  120.    int securityLevel = SecurityLevel_authPriv;
  121.    OctetStr contextName("");
  122.    OctetStr contextEngineID("");
  123.    long authProtocol = SNMPv3_usmNoAuthProtocol;
  124.    long privProtocol = SNMPv3_usmNoPrivProtocol;
  125.    v3MP *v3_MP;
  126. #endif
  127.    char *ptr;
  128.    for(int x=1;x<argc;x++) {                           // parse for version
  129.      if ( strstr( argv[x],"-v2")!= 0) {
  130.        version = version2c;
  131.        continue;
  132.      }
  133.      if ( strstr( argv[x],"-r")!= 0) {                 // parse for retries
  134.        ptr = argv[x]; ptr++; ptr++;
  135.        retries = atoi(ptr);
  136.        if (( retries<0)|| (retries>5)) retries=1; 
  137.        continue;
  138.      }
  139.      if ( strstr( argv[x], "-t")!=0) {                 // parse for timeout
  140.        ptr = argv[x]; ptr++; ptr++;
  141.        timeout = atoi( ptr);
  142.        if (( timeout < 100)||( timeout>500)) timeout=100;
  143.        continue;
  144.      }
  145.      if ( strstr( argv[x],"-C")!=0) {
  146.        ptr = argv[x]; ptr++; ptr++;
  147.        community = ptr;
  148.        continue;
  149.      }
  150.      if ( strstr( argv[x],"-P")!=0) {
  151.        ptr = argv[x]; ptr++; ptr++;
  152.        sscanf(ptr, "%hu", &port);
  153.        continue;
  154.      }
  155.      if ( strstr( argv[x],"-S") != 0) {
  156.        subtree = true;
  157.        continue;
  158.      }
  159. #ifdef _SNMPv3
  160.      if ( strstr( argv[x],"-v3")!= 0) {
  161.        version = version3;
  162.        continue;
  163.      }
  164.      if ( strstr( argv[x],"-auth") != 0) {
  165.        ptr = argv[x]; ptr+=5;
  166.        if (strcasecmp(ptr, "SHA") == 0)
  167.    authProtocol = SNMP_AUTHPROTOCOL_HMACSHA;
  168.        else if (strcasecmp(ptr, "MD5") == 0)
  169.    authProtocol = SNMP_AUTHPROTOCOL_HMACMD5;
  170.        else
  171.    authProtocol = SNMP_AUTHPROTOCOL_NONE;
  172.        continue;
  173.      }
  174.      if ( strstr( argv[x],"-priv") != 0) {
  175.        ptr = argv[x]; ptr+=5;
  176.        if (strcasecmp(ptr, "DES") == 0)
  177.    privProtocol = SNMP_PRIVPROTOCOL_DES;
  178.        else if (strcasecmp(ptr, "3DESEDE") == 0)
  179.    privProtocol = SNMP_PRIVPROTOCOL_3DESEDE;
  180.        else if (strcasecmp(ptr, "IDEA") == 0)
  181.    privProtocol = SNMP_PRIVPROTOCOL_IDEA;
  182.        else if (strcasecmp(ptr, "AES128") == 0)
  183.    privProtocol = SNMP_PRIVPROTOCOL_AES128;
  184.        else if (strcasecmp(ptr, "AES192") == 0)
  185.    privProtocol = SNMP_PRIVPROTOCOL_AES192;
  186.        else if (strcasecmp(ptr, "AES256") == 0)
  187.    privProtocol = SNMP_PRIVPROTOCOL_AES256;
  188.        else
  189.    privProtocol = SNMP_PRIVPROTOCOL_NONE;
  190.        printf("nnPrivProt : %ldn", privProtocol);
  191.        continue;
  192.      }
  193.      if ( strstr( argv[x],"-sn")!=0) {
  194.        ptr = argv[x]; ptr+=3;
  195.        securityName = ptr;
  196.        continue;
  197.       }
  198.      if ( strstr( argv[x], "-sl")!=0) {
  199.        ptr = argv[x]; ptr+=3;
  200.        securityLevel = atoi( ptr);
  201.        if (( securityLevel < SecurityLevel_noAuthNoPriv) ||
  202.            ( securityLevel > SecurityLevel_authPriv))
  203.          securityLevel = SecurityLevel_authPriv;
  204.        continue;
  205.      }
  206.      if ( strstr( argv[x], "-sm")!=0) {
  207.        ptr = argv[x]; ptr+=3;
  208.        securityModel = atoi( ptr);
  209.        if (( securityModel < SecurityModel_v1) ||
  210.            ( securityModel > SecurityModel_USM))
  211.          securityModel = SecurityModel_USM;
  212.        continue;
  213.      }
  214.      if ( strstr( argv[x],"-cn")!=0) {
  215.        ptr = argv[x]; ptr+=3;
  216.        contextName = ptr;
  217.        continue;
  218.      }
  219.      if ( strstr( argv[x],"-ce")!=0) {
  220.        ptr = argv[x]; ptr+=3;
  221.        contextEngineID = OctetStr::from_hex_string(ptr);
  222.        continue;
  223.      }
  224.      if ( strstr( argv[x],"-ua")!=0) {
  225.        ptr = argv[x]; ptr+=3;
  226.        authPassword = ptr;
  227.        continue;
  228.      }
  229.      if ( strstr( argv[x],"-up")!=0) {
  230.        ptr = argv[x]; ptr+=3;
  231.        privPassword = ptr;
  232.        continue;
  233.      }
  234. #endif
  235.    }
  236.    //----------[ create a SNMP++ session ]-----------------------------------
  237.    int status;
  238.    // bind to any port and use IPv6 if needed
  239.    Snmp snmp(status, 0, (address.get_ip_version() == Address::version_ipv6));
  240.    if ( status != SNMP_CLASS_SUCCESS) {
  241.       cout << "SNMP++ Session Create Fail, " << snmp.error_msg(status) << "n";
  242.       return 1;
  243.    }
  244.    //---------[ init SnmpV3 ]--------------------------------------------
  245. #ifdef _SNMPv3
  246.    if (version == version3) {
  247.      char *engineId = "snmpWalk";
  248.      char *filename = "snmpv3_boot_counter";
  249.      unsigned int snmpEngineBoots = 0;
  250.      int status;
  251.      status = getBootCounter(filename, engineId, snmpEngineBoots);
  252.      if ((status != SNMPv3_OK) && (status < SNMPv3_FILEOPEN_ERROR))
  253.      {
  254.        cout << "Error loading snmpEngineBoots counter: " << status << endl;
  255.        return 1;
  256.      }
  257.      snmpEngineBoots++;
  258.      status = saveBootCounter(filename, engineId, snmpEngineBoots);
  259.      if (status != SNMPv3_OK)
  260.      {
  261.        cout << "Error saving snmpEngineBoots counter: " << status << endl;
  262.        return 1;
  263.      }
  264.      int construct_status;
  265.      v3_MP = new v3MP(engineId, snmpEngineBoots, construct_status);
  266.      USM *usm = v3_MP->get_usm();
  267.      usm->add_usm_user(securityName,
  268.        authProtocol, privProtocol,
  269.        authPassword, privPassword);
  270.    }
  271.    else
  272.    {
  273.      // MUST create a dummy v3MP object if _SNMPv3 is enabled!
  274.      int construct_status;
  275.      v3_MP = new v3MP("dummy", 0, construct_status);
  276.    }
  277. #endif
  278.    //--------[ build up SNMP++ object needed ]-------------------------------
  279.    Pdu pdu;                               // construct a Pdu object
  280.    Vb vb;                                 // construct a Vb object
  281.    vb.set_oid( oid);                      // set the Oid portion of the Vb
  282.    pdu += vb;                             // add the vb to the Pdu
  283.    address.set_port(port);
  284.    CTarget ctarget( address);             // make a target using the address
  285. #ifdef _SNMPv3
  286.    UTarget utarget( address);
  287.    if (version == version3) {
  288.      utarget.set_version( version);          // set the SNMP version SNMPV1 or V2 or V3
  289.      utarget.set_retry( retries);            // set the number of auto retries
  290.      utarget.set_timeout( timeout);          // set timeout
  291.      utarget.set_security_model( securityModel);
  292.      utarget.set_security_name( securityName);
  293.      pdu.set_security_level( securityLevel);
  294.      pdu.set_context_name (contextName);
  295.      pdu.set_context_engine_id(contextEngineID);
  296.    }
  297.    else {
  298. #endif
  299.      ctarget.set_version( version);         // set the SNMP version SNMPV1 or V2
  300.      ctarget.set_retry( retries);           // set the number of auto retries
  301.      ctarget.set_timeout( timeout);         // set timeout
  302.      ctarget.set_readcommunity( community); // set the read community name
  303. #ifdef _SNMPv3
  304.    }
  305. #endif
  306.    //-------[ issue the request, blocked mode ]-----------------------------
  307.    cout << "SNMP++ snmpWalk to " << argv[1] << " SNMPV" 
  308. #ifdef _SNMPv3
  309.         << ((version==version3) ? (version) : (version+1))
  310. #else
  311.         << (version+1)
  312. #endif
  313.         << " Retries=" << retries
  314.         << " Timeout=" << timeout * 10 <<"ms";
  315. #ifdef _SNMPv3
  316.    if (version == version3)
  317.      cout << endl
  318.           << "securityName= " << securityName.get_printable()
  319.           << ", securityLevel= " << securityLevel
  320.           << ", securityModel= " << securityModel << endl
  321.           << "contextName= " << contextName.get_printable()
  322.           << ", contextEngineID= " << contextEngineID.get_printable()
  323.           << endl;
  324.    else
  325. #endif
  326.      cout << " Community=" << community.get_printable() << endl << flush;
  327.    SnmpTarget *target;
  328. #ifdef _SNMPv3
  329.    if (version == version3)
  330.      target = &utarget;
  331.    else
  332. #endif
  333.      target = &ctarget;
  334.    while (( status = snmp.get_bulk( pdu,*target,0,BULK_MAX))== SNMP_CLASS_SUCCESS) {
  335.   requests++;
  336.   for ( int z=0;z<pdu.get_vb_count(); z++) {
  337.      pdu.get_vb( vb,z);
  338. #ifdef _SNMPv3
  339.      if (pdu.get_type() == REPORT_MSG) {
  340.        Oid tmp;
  341.        vb.get_oid(tmp);
  342.        cout << "Received a reportPdu: "
  343.     << snmp.error_msg( tmp) 
  344.     << endl
  345.     << vb.get_printable_oid() << " = "
  346.     << vb.get_printable_value() << endl;
  347.        return -5;
  348.      }
  349. #endif
  350.      Oid tmp;
  351.      vb.get_oid(tmp);
  352.      if (subtree && (oid.nCompare(oid.len(), tmp) != 0))
  353.      {
  354.  cout << "End of SUBTREE Reachedn";
  355.  cout << "Total # of Requests = " << requests << "n";
  356.  cout << "Total # of Objects  = " << objects  << "n";
  357.  return -4;
  358.      }
  359.  objects++;
  360.  // look for var bind exception, applies to v2 only   
  361.  if ( vb.get_syntax() != sNMP_SYNTAX_ENDOFMIBVIEW) {
  362.    cout << vb.get_printable_oid() << " = ";
  363.    cout << vb.get_printable_value() << "n";
  364.  }
  365.  else {
  366.    cout << "End of MIB Reachedn";
  367.    cout << "Total # of Requests = " << requests << "n";
  368.    cout << "Total # of Objects  = " << objects  << "n";
  369.    return -4;
  370.  }
  371.   }
  372.   // last vb becomes seed of next rquest
  373.   pdu.set_vblist(&vb, 1);
  374.    }
  375.    if ( status != SNMP_ERROR_NO_SUCH_NAME)
  376.      cout << "SNMP++ snmpWalk Error, " << snmp.error_msg( status) << "n";
  377.    cout << "Total # of Requests = " << requests << "n";
  378.    cout << "Total # of Objects  = " << objects  << "n";
  379.    Snmp::socket_cleanup();  // Shut down socket subsystem
  380. }