ACE/ASNMP/examples/next/next.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file    next.cpp
   5  *
   6  *  Sample application demonstrating synchronous Snmp::get_next API
   7  *  to access an SNMP Version 1 agent.
   8  */
   9 //=============================================================================
  10
  11 /*===================================================================
  12   Copyright (c) 1996
  13   Hewlett-Packard Company
  14
  15   ATTENTION: USE OF THIS SOFTWARE IS SUBJECT TO THE FOLLOWING TERMS.
  16   Permission to use, copy, modify, distribute and/or sell this software
  17   and/or its documentation is hereby granted without fee. User agrees
  18   to display the above copyright notice and this license notice in all
  19   copies of the software and any documentation of the software. User
  20   agrees to assume all liability for the use of the software; Hewlett-Packard
  21   makes no representations about the suitability of this software for any
  22   purpose. It is provided "AS-IS without warranty of any kind,either express
  23   or implied. User hereby grants a royalty-free license to any and all
  24   derivatives based upon this software code base.
  25 =====================================================================*/
  26
  27 #include "asnmp/snmp.h"
  28 #include "ace/Argv_Type_Converter.h"
  29 #include "ace/Get_Opt.h"
  30
  31 // FUZZ: disable check_for_streams_include
  32 #include "ace/streams.h"
  33
  34 //
  35 // SNMPv1 Get Next Application
  36 //
  37 class nextapp
  38 {
  39 public:
  40   nextapp(int argc, char **argv); // process command line args
  41   int valid() const;             // verify transaction can proceed
  42   int run();                     //  issue transaction
  43   static void usage();           // operator help message
  44
  45 private:
  46   nextapp(const nextapp&);
  47
  48   UdpAddress address_;
  49   Pdu pdu_;                                // construct a request Pdu
  50   Oid oid_;
  51   OctetStr community_;
  52   Snmp snmp_;
  53   UdpTarget target_;
  54   int valid_;
  55 };
  56
  57
  58 // main entry point
  59 int ACE_TMAIN (int argc, ACE_TCHAR *argv[])
  60 {
  61   ACE_Argv_Type_Converter atc (argc, argv);
  62   nextapp get (atc.get_argc (), atc.get_ASCII_argv ());
  63   if (get.valid())
  64      return get.run();
  65   else
  66     nextapp::usage();
  67   return 1;
  68 }
  69
  70 int nextapp::valid() const
  71 {
  72  return valid_;
  73 }
  74 nextapp::nextapp(int argc, char *argv[]): valid_(0)
  75 {
  76    Oid req, def_oid("1.3.6.1.2.1.1.1.0");      // default is sysDescr
  77    if ( argc < 2)
  78      return;
  79
  80    address_ = argv[argc - 1];
  81    if ( !address_.valid()) {
  82       cout << "ERROR: Invalid IPv4 address or DNS hostname: " \
  83      << argv[argc] << "\n";
  84       return;
  85    }
  86
  87    ACE_Argv_Type_Converter to_tchar (argc, argv);
  88    ACE_Get_Opt get_opt (argc,
  89                         to_tchar.get_TCHAR_argv (),
  90                         ACE_TEXT ("o:c:r:t:"));
  91    for (int c; (c = get_opt ()) != -1; )
  92      switch (c)
  93        {
  94        case 'o':
  95          req = ACE_TEXT_ALWAYS_CHAR (get_opt.opt_arg());
  96          if (req.valid() == 0)
  97          cout << "ERROR: oid value: "
  98               << ACE_TEXT_ALWAYS_CHAR (get_opt.opt_arg())
  99               << "is not valid. using default.\n";
 100          break;
 101
 102        case 'c':
 103          community_ = ACE_TEXT_ALWAYS_CHAR (get_opt.opt_arg());
 104          target_.set_read_community(community_);
 105          break;
 106
 107        case 'r':
 108          target_.set_retry(ACE_OS::atoi (get_opt.opt_arg()));
 109          break;
 110
 111        case 't':
 112          target_.set_timeout(ACE_OS::atoi (get_opt.opt_arg()));
 113          break;
 114
 115        default:
 116          break;
 117        }
 118
 119   Vb vb;                                  // construct a Vb object
 120   if (req.valid())
 121      vb.set_oid( req);                    // set the Oid portion of the Vb
 122   else {
 123      vb.set_oid( def_oid);               // set the Oid portion of the Vb
 124   }
 125   pdu_ += vb;
 126   vb.get_oid(oid_); // store for later use
 127   valid_ = 1;
 128 }
 129
 130 void nextapp::usage()
 131 {
 132   cout << "Usage:\n";
 133   cout << "next [options] dotted-quad | DNSName[:port]\n";
 134   cout << "      -o OID starts with oid after 1.3.6.1.2.1.1.1.0 (mibII sysDescr.0)\n";
 135   cout << "      -c Community_name, default is 'public'\n";
 136   cout << "      -r N  retries default is N = 1 retry\n";
 137   cout << "      -t N  timeout in seconds default is 1 second" << endl;
 138 }
 139
 140
 141 int nextapp::run()
 142 {
 143    //----------[ create a ASNMP session ]-----------------------------------
 144    if ( snmp_.valid() != SNMP_CLASS_SUCCESS) {
 145       cout << "\nASNMP:ERROR:Create session failed: "<<
 146           snmp_.error_string()<< "\n";
 147       return 1;
 148    }
 149
 150    //--------[ build up ASNMP object needed ]-------------------------------
 151    if (address_.get_port() == 0)
 152      address_.set_port(DEF_AGENT_PORT);
 153    target_.set_address( address_);         // make a target using the address
 154
 155    //-------[ issue the request, blocked mode ]-----------------------------
 156    cout << "\nASNMP:INFO:SNMP Version " << (target_.get_version()+ 1) << \
 157        " GET_NEXT SAMPLE PROGRAM \nOID: " << oid_.to_string() << "\n";
 158    target_.get_address(address_); // target updates port used
 159    int rc;
 160    const char *name = address_.resolve_hostname(rc);
 161
 162    cout << "Device: " << address_ << " ";
 163
 164    //FUZZ: disable check_for_lack_ACE_OS
 165    cout << (rc ? "<< did not resolve via gethostbyname() >>" : name) << "\n";
 166    //FUZZ: enable check_for_lack_ACE_OS
 167
 168    cout << "[ Retries=" << target_.get_retry() << " \
 169         Timeout=" << target_.get_timeout() <<" ms " << "Community=" << \
 170          community_.to_string() << " ]"<< endl;
 171
 172    if (snmp_.get_next( pdu_, target_) == SNMP_CLASS_SUCCESS) {
 173        Vb vb;
 174       // check to see if there are any errors
 175       if (pdu_.get_error_status()) {
 176         cout << "ERROR: agent replied as follows\n";
 177         cout << pdu_.agent_error_reason() << endl;
 178       }
 179       else {
 180         VbIter iter(pdu_);
 181         while (iter.next(vb)) {
 182           cout << "\tOid = " << vb.to_string_oid() << "\n";
 183           cout << "\tValue = " << vb.to_string_value() << "\n";
 184        }
 185      }
 186    }
 187    else {
 188     const char *ptr = snmp_.error_string();
 189     cout << "ASNMP:ERROR: get_next command failed reason: " << ptr << endl;
 190   }
 191   cout << "ASNMP:INFO:command completed normally. ACE Rocks...\n"<< endl;
 192   return 0;
 193 }
 194