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

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*_############################################################################
  2.   _## 
  3.   _##  snmpSet.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.   snmpSet.cpp 
  31.   Copyright (c) 1996
  32.   Hewlett-Packard Company
  33.   ATTENTION: USE OF THIS SOFTWARE IS SUBJECT TO THE FOLLOWING TERMS.
  34.   Permission to use, copy, modify, distribute and/or sell this software
  35.   and/or its documentation is hereby granted without fee. User agrees
  36.   to display the above copyright notice and this license notice in all
  37.   copies of the software and any documentation of the software. User
  38.   agrees to assume all liability for the use of the software; Hewlett-Packard
  39.   makes no representations about the suitability of this software for any
  40.   purpose. It is provided "AS-IS" without warranty of any kind,either express
  41.   or implied. User hereby grants a royalty-free license to any and all
  42.   derivatives based upon this software code base.
  43.   Peter E. Mellquist
  44. */
  45. char snmpset_cpp_version[]="@(#) SNMP++ $Id: snmpSet.cpp,v 1.8 2005/10/11 18:08:05 katz Exp $";
  46. #include "snmp_pp/snmp_pp.h"
  47. #include <stdlib.h>
  48. #include <stdio.h>
  49. #ifdef SNMP_PP_NAMESPACE
  50. using namespace Snmp_pp;
  51. #endif
  52. #if (__GNUC__ > 2)
  53. #include <iostream>
  54. using std::cerr;
  55. using std::cout;
  56. using std::cin;
  57. using std::endl;
  58. using std::flush;
  59. #else
  60. #include <iostream.h>
  61. #endif
  62. // determine the smi type and get a value from the user
  63. int determine_vb( SmiUINT32 val, Vb &vb)
  64. {
  65.   char buffer[255];
  66.   if (val == sNMP_SYNTAX_NOSUCHINSTANCE)
  67.   {
  68.     cout << "Instance does not exists but can be created.n";
  69.     cout << "Please enter one of the following types:nn";
  70.     cout << "Integer:  " << sNMP_SYNTAX_INT << "n";
  71.     cout << "Bits:     " << sNMP_SYNTAX_BITS << "n";
  72.     cout << "STRING:   " << sNMP_SYNTAX_OCTETS << "n";
  73.     cout << "Oid:      " << sNMP_SYNTAX_OID << "n";
  74.     cout << "IpAddress:" << sNMP_SYNTAX_IPADDR << "nn";
  75.     cout << "Please choose value type: ";
  76.     cin >> val;
  77.     vb.set_syntax(val);
  78.   }
  79.   cout << "Value Type is ";
  80.   switch (val) {
  81.     // octet string
  82.     case sNMP_SYNTAX_OCTETS:
  83.     {
  84.       cout << "Octet Stringn";
  85.       cout << "Please enter new value: ";
  86.       cin >> buffer;
  87.       OctetStr octetstr( buffer);
  88.       if ( octetstr.valid()) {
  89. vb.set_value( octetstr);
  90. return TRUE;
  91.       }
  92.       else {
  93. cout << "Invalid OctetStrn";
  94. return FALSE;
  95.       }
  96.     }
  97.     // IP Address
  98.     case sNMP_SYNTAX_IPADDR:
  99.     {
  100.       cout << "IP Addressn";
  101.       cout << "Please enter new value: ";
  102.       cin >> buffer;
  103.       IpAddress ipaddress( buffer);
  104.       if ( ipaddress.valid()) {
  105. vb.set_value( ipaddress);
  106. return TRUE;
  107.       }
  108.       else {
  109. cout << "Invalid IP Addressn";
  110. return FALSE;
  111.       }
  112.     }
  113.     // Oid
  114.     case sNMP_SYNTAX_OID:
  115.     {
  116.       cout << "Oidn";
  117.       cout << "Please enter new value: ";
  118.       cin >> buffer;
  119.       Oid oid( buffer);
  120.       if ( oid.valid()) {
  121. vb.set_value( oid);
  122. return TRUE;
  123.       }
  124.       else {
  125. cout << "Invalid Oidn";
  126. return FALSE;
  127.       }
  128.     }
  129.     // TimeTicks
  130.     case sNMP_SYNTAX_TIMETICKS:
  131.     {
  132.       cout << "TimeTicksn";
  133.       cout << "Please enter new value: ";
  134.       cin >> buffer;
  135.       unsigned long i;
  136.       i = atol( buffer);
  137.       TimeTicks timeticks( i);
  138.       if ( timeticks.valid()) {
  139. vb.set_value( timeticks);
  140. return TRUE;
  141.       }
  142.       else {
  143. cout << "Invalid TimeTicksn";
  144. return FALSE;
  145.       }
  146.     }
  147.     // Gauge32
  148.     case sNMP_SYNTAX_GAUGE32:
  149.     {
  150.       cout << "Gauge32n";
  151.       cout << "Please enter new value: ";
  152.       cin >> buffer;
  153.       unsigned long i;
  154.       i = atol( buffer);
  155.       Gauge32 gauge32(i); 
  156.       if ( gauge32.valid()) {
  157. vb.set_value( gauge32);
  158. return TRUE;
  159.       }
  160.       else {
  161. cout << "Invalid Gauge32n";
  162. return FALSE;
  163.       }
  164.     }
  165.     case sNMP_SYNTAX_CNTR32:
  166.     {
  167.       cout << "Counter32n";
  168.       cout << "Please enter new value: ";
  169.       cin >> buffer;
  170.       unsigned long i;
  171.       i = atol( buffer);
  172.       Counter32 counter32(i);
  173.       if ( counter32.valid()) {
  174. vb.set_value( counter32);
  175. return TRUE;
  176.       }
  177.       else {
  178. cout << "Invalid Counter32n";
  179. return FALSE;
  180.       }
  181.     }
  182.     case sNMP_SYNTAX_CNTR64:
  183.     {
  184.       cout << "Counter64n";
  185.       cout << "Please enter value (low 32 bit): ";
  186.       cin >> buffer;
  187.       unsigned long i;
  188.       i = atol( buffer);
  189.       Counter64 counter64;
  190.       counter64.set_low(i);
  191.       cout << "Please enter value (high 32 bit): ";
  192.       cin >> buffer;
  193.       i = atol( buffer);
  194.       counter64.set_high(i);
  195.       if ( counter64.valid()) {
  196. vb.set_value( counter64);
  197. return TRUE;
  198.       }
  199.       else {
  200. cout << "Invalid Counter64n";
  201. return FALSE;
  202.       }
  203.     }
  204.     case sNMP_SYNTAX_INT:
  205.     {
  206.       cout << "Integern";
  207.       cout << "Please enter new value: ";
  208.       cin >> buffer;
  209.       unsigned long i;
  210.       i = atol( buffer);
  211.       long l ;
  212.       l = ( long) i;
  213.       vb.set_value( l);
  214.       return TRUE;
  215.     }
  216.     case sNMP_SYNTAX_NOSUCHOBJECT:
  217.     {
  218.       cout << "NO SUCH OBJECTn";
  219.       cout << "Object cannot be created.n";
  220.       return FALSE;
  221.     }
  222.     default:
  223.     cout << "Unknown Data Type " << val << "n";
  224.     return FALSE;
  225.   }
  226. }
  227. int main(int argc, char **argv)
  228. {
  229.    //---------[ check the arg count ]----------------------------------------
  230.    if ( argc < 2) {
  231.   cout << "Usage:n";
  232.   cout << argv[0] << " IpAddress | DNSName [Oid] [options]n";
  233.   cout << "Oid: sysDescr object is defaultn";
  234.   cout << "options: -vN , use SNMP version 1, 2 or 3, default is 1n";
  235.   cout << "         -PPort , remote port to usen";
  236.   cout << "         -CCommunity_name, specify SET community default is 'public' n";
  237.   cout << "         -GCommunity_name, specify GET community default is set community value n";
  238.   cout << "         -rN , retries default is N = 1 retryn";
  239.   cout << "         -tN , timeout in hundredths of seconds; default is N = 100n";
  240. #ifdef _SNMPv3
  241.           cout << "         -snSecurityName, " << endl;
  242.           cout << "         -slN , securityLevel to use, default N = 3 = authPriv" << endl;
  243.           cout << "         -smN , securityModel to use, only default N = 3 = USM possiblen";
  244.           cout << "         -cnContextName, default empty string" << endl;
  245.           cout << "         -ceContextEngineID, as hex e.g. 800007E580, default empty string" << endl;
  246.           cout << "         -authPROT, use authentication protocol NONE, SHA or MD5n";
  247.           cout << "         -privPROT, use privacy protocol NONE, DES, 3DESEDE, IDEA, AES128, AES192 or AES256n";
  248.           cout << "         -uaAuthPasswordn";
  249.           cout << "         -upPrivPasswordn";
  250. #endif
  251.   return 1;
  252.    }
  253.   Snmp::socket_startup();  // Initialize socket subsystem
  254.    //---------[ make a GenAddress and Oid object to retrieve ]---------------
  255.    UdpAddress address( argv[1]);      // make a SNMP++ Generic address
  256.    if ( !address.valid()) {           // check validity of address
  257.   cout << "Invalid Address or DNS Name, " << argv[1] << "n";
  258.   return 1;
  259.    }
  260.    Oid oid("1.3.6.1.2.1.1.4.0");      // default is sysName
  261.    if ( argc >= 3) {                  // if 3 args, then use the callers Oid
  262.   if ( strstr( argv[2],"-")==0) {
  263.      oid = argv[2];
  264.      if ( !oid.valid()) {            // check validity of user oid
  265.     cout << "Invalid Oid, " << argv[2] << "n";
  266.     return 1;
  267.          }
  268.       }
  269.    }
  270.    //---------[ determine options to use ]-----------------------------------
  271.    snmp_version version=version1;                  // default is v1
  272.    int retries=1;                                  // default retries is 1
  273.    int timeout=100;                                // default is 1 second
  274.    u_short port=161;                               // default snmp port is 161
  275.    OctetStr community("public");                   // community name
  276.    OctetStr get_community;
  277. #ifdef _SNMPv3
  278.    OctetStr privPassword("");
  279.    OctetStr authPassword("");
  280.    OctetStr securityName("");
  281.    int securityModel = SecurityModel_USM;
  282.    int securityLevel = SecurityLevel_authPriv;
  283.    OctetStr contextName("");
  284.    OctetStr contextEngineID("");
  285.    long authProtocol = SNMPv3_usmNoAuthProtocol;
  286.    long privProtocol = SNMPv3_usmNoPrivProtocol;
  287.    v3MP *v3_MP;
  288. #endif
  289.    char *ptr;
  290.    for(int x=1;x<argc;x++) {                           // parse for version
  291.      if ( strstr( argv[x],"-v2")!= 0) {
  292.        version = version2c;
  293.        continue;
  294.      }
  295.      if ( strstr( argv[x],"-r")!= 0) {                 // parse for retries
  296.        ptr = argv[x]; ptr++; ptr++;
  297.        retries = atoi(ptr);
  298.        if (( retries<0)|| (retries>5)) retries=1; 
  299.        continue;
  300.      }
  301.      if ( strstr( argv[x], "-t")!=0) {                 // parse for timeout
  302.        ptr = argv[x]; ptr++; ptr++;
  303.        timeout = atoi( ptr);
  304.        if (( timeout < 100)||( timeout>500)) timeout=100;
  305.        continue;
  306.      }
  307.      if ( strstr( argv[x],"-C")!=0) {
  308.        ptr = argv[x]; ptr++; ptr++;
  309.        community = ptr;
  310.        continue;
  311.      }
  312.      if ( strstr( argv[x],"-G")!=0) {
  313.        ptr = argv[x]; ptr++; ptr++;
  314.        get_community = ptr;
  315.        continue;
  316.      }
  317.      if ( strstr( argv[x],"-P")!=0) {
  318.        ptr = argv[x]; ptr++; ptr++;
  319.        sscanf(ptr, "%hu", &port);
  320.        continue;
  321.      }
  322. #ifdef _SNMPv3
  323.      if ( strstr( argv[x],"-v3")!= 0) {
  324.        version = version3;
  325.        continue;
  326.      }
  327.      if ( strstr( argv[x],"-auth") != 0) {
  328.        ptr = argv[x]; ptr+=5;
  329.        if (strcasecmp(ptr, "SHA") == 0)
  330.    authProtocol = SNMP_AUTHPROTOCOL_HMACSHA;
  331.        else if (strcasecmp(ptr, "MD5") == 0)
  332.    authProtocol = SNMP_AUTHPROTOCOL_HMACMD5;
  333.        else
  334.    authProtocol = SNMP_AUTHPROTOCOL_NONE;
  335.        continue;
  336.      }
  337.      if ( strstr( argv[x],"-priv") != 0) {
  338.        ptr = argv[x]; ptr+=5;
  339.        if (strcasecmp(ptr, "DES") == 0)
  340.    privProtocol = SNMP_PRIVPROTOCOL_DES;
  341.        else if (strcasecmp(ptr, "3DESEDE") == 0)
  342.    privProtocol = SNMP_PRIVPROTOCOL_3DESEDE;
  343.        else if (strcasecmp(ptr, "IDEA") == 0)
  344.    privProtocol = SNMP_PRIVPROTOCOL_IDEA;
  345.        else if (strcasecmp(ptr, "AES128") == 0)
  346.    privProtocol = SNMP_PRIVPROTOCOL_AES128;
  347.        else if (strcasecmp(ptr, "AES192") == 0)
  348.    privProtocol = SNMP_PRIVPROTOCOL_AES192;
  349.        else if (strcasecmp(ptr, "AES256") == 0)
  350.    privProtocol = SNMP_PRIVPROTOCOL_AES256;
  351.        else
  352.    privProtocol = SNMP_PRIVPROTOCOL_NONE;
  353.        printf("nnPrivProt : %ldn", privProtocol);
  354.        continue;
  355.      }
  356.      if ( strstr( argv[x],"-sn")!=0) {
  357.        ptr = argv[x]; ptr+=3;
  358.        securityName = ptr;
  359.        continue;
  360.       }
  361.      if ( strstr( argv[x], "-sl")!=0) {
  362.        ptr = argv[x]; ptr+=3;
  363.        securityLevel = atoi( ptr);
  364.        if (( securityLevel < SecurityLevel_noAuthNoPriv) ||
  365.            ( securityLevel > SecurityLevel_authPriv))
  366.          securityLevel = SecurityLevel_authPriv;
  367.        continue;
  368.      }
  369.      if ( strstr( argv[x], "-sm")!=0) {
  370.        ptr = argv[x]; ptr+=3;
  371.        securityModel = atoi( ptr);
  372.        if (( securityModel < SecurityModel_v1) ||
  373.            ( securityModel > SecurityModel_USM))
  374.          securityModel = SecurityModel_USM;
  375.        continue;
  376.      }
  377.      if ( strstr( argv[x],"-cn")!=0) {
  378.        ptr = argv[x]; ptr+=3;
  379.        contextName = ptr;
  380.        continue;
  381.      }
  382.      if ( strstr( argv[x],"-ce")!=0) {
  383.        ptr = argv[x]; ptr+=3;
  384.        contextEngineID = OctetStr::from_hex_string(ptr);
  385.        continue;
  386.      }
  387.      if ( strstr( argv[x],"-ua")!=0) {
  388.        ptr = argv[x]; ptr+=3;
  389.        authPassword = ptr;
  390.        continue;
  391.      }
  392.      if ( strstr( argv[x],"-up")!=0) {
  393.        ptr = argv[x]; ptr+=3;
  394.        privPassword = ptr;
  395.        continue;
  396.      }
  397. #endif
  398.   }
  399.    if (get_community.len() == 0)
  400.      get_community = community;
  401.    //----------[ create a SNMP++ session ]-----------------------------------
  402.    int status;
  403.    // bind to any port and use IPv6 if needed
  404.    Snmp snmp(status, 0, (address.get_ip_version() == Address::version_ipv6));
  405.    if ( status != SNMP_CLASS_SUCCESS) {
  406.       cout << "SNMP++ Session Create Fail, " << snmp.error_msg(status) << "n";
  407.       return 1;
  408.    }
  409.    //---------[ init SnmpV3 ]--------------------------------------------
  410. #ifdef _SNMPv3
  411.    if (version == version3) {
  412.      char *engineId = "snmpSet";
  413.      char *filename = "snmpv3_boot_counter";
  414.      unsigned int snmpEngineBoots = 0;
  415.      int status;
  416.      status = getBootCounter(filename, engineId, snmpEngineBoots);
  417.      if ((status != SNMPv3_OK) && (status < SNMPv3_FILEOPEN_ERROR))
  418.      {
  419.        cout << "Error loading snmpEngineBoots counter: " << status << endl;
  420.        return 1;
  421.      }
  422.      snmpEngineBoots++;
  423.      status = saveBootCounter(filename, engineId, snmpEngineBoots);
  424.      if (status != SNMPv3_OK)
  425.      {
  426.        cout << "Error saving snmpEngineBoots counter: " << status << endl;
  427.        return 1;
  428.      }
  429.      int construct_status;
  430.      v3_MP = new v3MP(engineId, snmpEngineBoots, construct_status);
  431.      USM *usm = v3_MP->get_usm();
  432.      usm->add_usm_user(securityName,
  433.        authProtocol, privProtocol,
  434.        authPassword, privPassword);
  435.    }
  436.    else
  437.    {
  438.      // MUST create a dummy v3MP object if _SNMPv3 is enabled!
  439.      int construct_status;
  440.      v3_MP = new v3MP("dummy", 0, construct_status);
  441.    }
  442. #endif
  443.    //--------[ build up SNMP++ object needed ]-------------------------------
  444.    Pdu pdu;                               // construct a Pdu object
  445.    Vb vb;                                 // construct a Vb object
  446.    vb.set_oid( oid);                      // set the Oid portion of the Vb
  447.    pdu += vb;                             // add the vb to the Pdu
  448.    address.set_port(port);
  449.    CTarget ctarget( address);             // make a target using the address
  450. #ifdef _SNMPv3
  451.    UTarget utarget( address);
  452.    if (version == version3) {
  453.      utarget.set_version( version);          // set the SNMP version SNMPV1 or V2 or V3
  454.      utarget.set_retry( retries);            // set the number of auto retries
  455.      utarget.set_timeout( timeout);          // set timeout
  456.      utarget.set_security_model( securityModel);
  457.      utarget.set_security_name( securityName);
  458.      pdu.set_security_level( securityLevel);
  459.      pdu.set_context_name (contextName);
  460.      pdu.set_context_engine_id(contextEngineID);
  461.    }
  462.    else {
  463. #endif
  464.      ctarget.set_version( version);         // set the SNMP version SNMPV1 or V2
  465.      ctarget.set_retry( retries);           // set the number of auto retries
  466.      ctarget.set_timeout( timeout);         // set timeout
  467.      ctarget.set_readcommunity( get_community); // set the read community name
  468.      ctarget.set_writecommunity( community);// set the write community name
  469. #ifdef _SNMPv3
  470.    }
  471. #endif
  472.   //-------[ issue the request, blocked mode ]-----------------------------
  473.   cout << "SNMP++ Set to " << argv[1] << " SNMPV" 
  474. #ifdef _SNMPv3
  475.         << ((version==version3) ? (version) : (version+1))
  476. #else
  477.         << (version+1)
  478. #endif
  479.         << " Retries=" << retries
  480.         << " Timeout=" << timeout * 10 <<"ms";
  481. #ifdef _SNMPv3
  482.    if (version == version3)
  483.      cout << endl
  484.           << "securityName= " << securityName.get_printable()
  485.           << ", securityLevel= " << securityLevel
  486.           << ", securityModel= " << securityModel << endl
  487.           << "contextName= " << contextName.get_printable()
  488.           << ", contextEngineID= " << contextEngineID.get_printable()
  489.           << endl;
  490.    else
  491. #endif
  492.      cout << " SET-community=" << community.get_printable()
  493.   << " GET-community=" << get_community.get_printable() << endl << flush;
  494.    SnmpTarget *target;
  495. #ifdef _SNMPv3
  496.    if (version == version3)
  497.      target = &utarget;
  498.    else
  499. #endif
  500.      target = &ctarget;
  501.   // first get the variabel to determine its type
  502.   if (( status = snmp.get( pdu,*target))== SNMP_CLASS_SUCCESS) {
  503.     pdu.get_vb( vb,0);
  504.     cout << "Oid = " << vb.get_printable_oid() << endl
  505.  << "Current Value = " << vb.get_printable_value() << endl;
  506. #ifdef _SNMPv3
  507.     if (pdu.get_type() == REPORT_MSG) {
  508.       cout << "Received a reportPdu: "
  509.            << snmp.error_msg( vb.get_printable_oid()) 
  510.            << endl
  511.            << vb.get_printable_oid() << " = "
  512.            << vb.get_printable_value() << endl;
  513.       return -5;
  514.     }
  515. #endif
  516.     if ( determine_vb(vb.get_syntax(), vb)) {
  517.       // do the Set
  518.       Pdu setpdu;
  519. #ifdef _SNMPv3
  520.       setpdu.set_security_level(securityLevel);
  521.       setpdu.set_context_name (contextName);
  522.       setpdu.set_context_engine_id(contextEngineID);
  523. #endif
  524.       vb.set_oid( oid);           // use the same oid as the inquire
  525.       setpdu += vb; 
  526.       status = snmp.set( setpdu, *target);
  527.       cout << "Set Status = " << snmp.error_msg( status) << "n";
  528.     }
  529.   }
  530.   else
  531.     cout << "SNMP++ Set Error, " << snmp.error_msg( status) << "n";
  532.   Snmp::socket_cleanup();  // Shut down socket subsystem
  533. }