(file) Return to snmpDeliverTrap_emanate.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Handler / snmpIndicationHandler

Diff for /pegasus/src/Pegasus/Handler/snmpIndicationHandler/snmpDeliverTrap_emanate.cpp between version 1.4 and 1.11.12.1

version 1.4, 2002/03/21 23:00:08 version 1.11.12.1, 2003/07/29 15:08:29
Line 1 
Line 1 
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001 BMC Software, Hewlett Packard, IBM, The Open Group,  // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM,
 // Tivoli Systems  // The Open Group, Tivoli Systems
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a copy // Permission is hereby granted, free of charge, to any person obtaining a copy
 // of this software and associated documentation files (the "Software"), to // of this software and associated documentation files (the "Software"), to
Line 23 
Line 23 
 // //
 // Author: Nitin Upasani, Hewlett-Packard Company (Nitin_Upasani@hp.com) // Author: Nitin Upasani, Hewlett-Packard Company (Nitin_Upasani@hp.com)
 // //
 // Modified By:  // Modified By: Yi Zhou, Hewlett-Packard Company (yi_zhou@hp.com)
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #include <Pegasus/Common/Config.h>  
 #include <Pegasus/Common/System.h> #include <Pegasus/Common/System.h>
 #include <fcntl.h>  #include <Pegasus/Common/ArrayInternal.h>
 #include <unistd.h>  #include <Pegasus/Common/Destroyer.h>
 #include <ctype.h>  #include <Pegasus/Common/InternalException.h>
 #include <sys/stat.h>  
 #include "snmpDeliverTrap_emanate.h" #include "snmpDeliverTrap_emanate.h"
 #include "prnt_lib.h"  
  
 PEGASUS_NAMESPACE_BEGIN  // EMANATE specific declarations and entry points - MUST be in begining
   // and outside NAMESPACE.
  
 PEGASUS_USING_STD;  // master agent needs these two declarations for communication with sub-agent.
   // Following two declarations must be in the CODE.
   
   #include <prnt_lib.h>  // MUST be at the end in include list.
  
 static char *sr_filename = __FILE__; static char *sr_filename = __FILE__;
  
 IPCFunctionP IPCfp;  /* IPC functions pointer  */ IPCFunctionP IPCfp;  /* IPC functions pointer  */
  
 // This code should be generated by Emanate  // This code would normally be generated by Emanate from defined MIB objects.
 // Since we do not have MIB objects defined,  // Since we do not have MIB objects defined, just defined here to load
 // just defined here to load subagent as library  // subagent as library. OidList[] provides objects for entry point to master agent.
  
 // The objects internal to the agent // The objects internal to the agent
 ObjectInfo OidList[] = ObjectInfo OidList[] =
Line 59 
Line 60 
     NULL, NULL }     NULL, NULL }
 }; };
  
 // This code should be generated by Emanate in k_* routine  // This code would normally be generated by Emanate in k_* routine from defined MIB objects.
 // Since we do not have MIB objects defined,  // Since we do not have MIB objects defined, just define here to pass compile and
 // just defined here to pass compile  // enable entry point for master agent to start communication with library.
  
 // Called by the master agent during initialization */ // Called by the master agent during initialization */
 int k_initialize() int k_initialize()
Line 69 
Line 70 
    return 1;    return 1;
 } }
  
   // END EMANATE specific declarations.
   
   PEGASUS_NAMESPACE_BEGIN
   
   PEGASUS_USING_STD;
   
 snmpDeliverTrap_emanate::snmpDeliverTrap_emanate() snmpDeliverTrap_emanate::snmpDeliverTrap_emanate()
 { {
  
Line 79 
Line 86 
  
 } }
  
   
   // initialize sub-agent
   
   // This also defines the communication protocol to be used between master
   // and sub-agent.
   
 void snmpDeliverTrap_emanate::initialize() void snmpDeliverTrap_emanate::initialize()
 { {
 #ifndef SR_UDS_IPC #ifndef SR_UDS_IPC
Line 89 
Line 102 
  
     if(InitSubagent() == -1)     if(InitSubagent() == -1)
     {     {
         cout << "InitSubagent Failed to initialize" << endl;          throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
         exit(1);              _MSG_INITSUBAGENT_FAILED);
     }     }
 } }
  
 void snmpDeliverTrap_emanate::deliverTrap( void snmpDeliverTrap_emanate::deliverTrap(
     const String& trapOid,     const String& trapOid,
     const String& community,          const String& securityName,
     const String& destination,          const String& targetHost,
     const String& trapType,          const Uint16& targetHostFormat,
           const String& otherTargetHostFormat,
           const Uint32& portNumber,
           const Uint16& snmpVersion,
           const String& engineID,
     Array<String>& vbOids,     Array<String>& vbOids,
     Array<String>& vbTypes,     Array<String>& vbTypes,
     Array<String>& vbValues)     Array<String>& vbValues)
 { {
       VarBind *vbhead = NULL;
       VarBind *vb = NULL;
       VarBind *vblast = NULL;
   
       OID     *object = NULL;
   
       // Initialize with Master agent
   
     initialize();     initialize();
  
     //void*   newValue;      // Translate a string into an OID
     OctetString*   newValue;      OID *sendtrapOid = MakeOIDFromDot(trapOid.getCString());
     char*   entV2Trap;  
     int     vb_link_flag = 0;  
  
     VarBind *vb = NULL;      if (sendtrapOid == NULL)
     VarBind *vb2 = NULL;      {
     VarBind *vb3 = NULL;          throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                   _MSG_INVALID_TRAPOID);
       }
  
     OID     *object = NULL;      // Destination : convert targetHost into Transport
  
     // getting IP address of the host      CString trap_dest = targetHost.getCString();
     char* hostname = System::getHostName().allocateCString();  
     char **p;  
     struct hostent *hp;  
     struct in_addr in;  
     hp=gethostbyname(hostname);  
     p = hp->h_addr_list;  
     (void)memcpy(&in.s_addr, *p, sizeof(in.s_addr));  
     char* IP_string = inet_ntoa(in);  
  
     // converting destination into Transport  
     TransportInfo   global_ti;     TransportInfo   global_ti;
     global_ti.type = SR_IP_TRANSPORT;     global_ti.type = SR_IP_TRANSPORT;
     // address to which to send trap  
     global_ti.t_ipAddr = inet_addr(destination.allocateCString());      switch (targetHostFormat)
     // port to which to send trap      {
     global_ti.t_ipPort = htons((unsigned short)GetSNMPTrapPort());          case _HOST_NAME:
           {
               char * ipAddr = _getIPAddress(trap_dest);
   
               if (ipAddr == NULL)
               {
                   throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                       _MSG_DESTINATION_NOT_FOUND);
               }
               global_ti.t_ipAddr = inet_addr(trap_dest);
               break;
           }
           case _IPV4_ADDRESS:
           {
               global_ti.t_ipAddr = inet_addr(trap_dest);
               break;
           }
           default:
           {
               throw PEGASUS_CIM_EXCEPTION(CIM_ERR_NOT_SUPPORTED,
                   _MSG_TARGETHOSTFORMAT_NOT_SUPPORTED);
               break;
           }
       }
   
       global_ti.t_ipPort = htons((unsigned short)portNumber);
   
       // Community Name, default is public
       CString _community;
       if (securityName.size() == 0)
       {
           String community;
           community.assign("public");
           _community = community.getCString();
       }
       else
       {
           _community = securityName.getCString();
       }
   
       OctetString* community_name = MakeOctetStringFromText(_community);
   
       if (community_name == NULL)
       {
           throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
               _MSG_INVALID_SECURITY_NAME);
       }
   
       // getting IP address of the host
   
       CString hostname = System::getHostName().getCString();
       char* IP_string = _getIPAddress(hostname);
  
     // formatting agent(host) address into OctetString format     // formatting agent(host) address into OctetString format
   
     OctetString* agent_addr;     OctetString* agent_addr;
  
     SR_INT32 s1, s2, s3, s4;     SR_INT32 s1, s2, s3, s4;
     SR_UINT32 ipaddr;     SR_UINT32 ipaddr;
  
     // pull out each of the 4 octet values from IP address     // pull out each of the 4 octet values from IP address
   
     sscanf(IP_string,"%d.%d.%d.%d", &s1, &s2, &s3, &s4);     sscanf(IP_string,"%d.%d.%d.%d", &s1, &s2, &s3, &s4);
  
     // Probably should perform some checks on values for      // validate the values for s1, s2, s3, and s4 to make sure values are
     // s1, s2, s3, and s4 here to make sure values are  
     // between 0 and 255     // between 0 and 255
       if (!_isValidOctet(s1) || !_isValidOctet(s2) ||
           !_isValidOctet(s3) || !_isValidOctet(s4))
       {
           throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
               _MSG_INVALID_OCTET_VALUE);
       }
  
     // create an empty 4 length OctetString     // create an empty 4 length OctetString
   
     agent_addr = MakeOctetString(NULL,4);     agent_addr = MakeOctetString(NULL,4);
  
       if (agent_addr == NULL)
       {
           throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
               _MSG_CREATE_OCTET_FAILED);
       }
   
     // fill in values for OctetString     // fill in values for OctetString
   
     agent_addr->octet_ptr[0] = (unsigned char)s1;     agent_addr->octet_ptr[0] = (unsigned char)s1;
     agent_addr->octet_ptr[1] = (unsigned char)s2;     agent_addr->octet_ptr[1] = (unsigned char)s2;
     agent_addr->octet_ptr[2] = (unsigned char)s3;     agent_addr->octet_ptr[2] = (unsigned char)s3;
     agent_addr->octet_ptr[3] = (unsigned char)s4;     agent_addr->octet_ptr[3] = (unsigned char)s4;
  
     // ATTN-NU-20020312 : Write code to get enterprise, genTrap and  
     // specTrap from trapOid.     // specTrap from trapOid.
  
     String enterprise;      SR_INT32 genTrap = 0;
       SR_INT32 specTrap = 0;
   
       OID* enterpriseOid ;
   
       Array<String> standard_traps;
   
       standard_traps.append(String("1.3.6.1.6.3.1.1.5.1"));
       standard_traps.append(String("1.3.6.1.6.3.1.1.5.2"));
       standard_traps.append(String("1.3.6.1.6.3.1.1.5.3"));
       standard_traps.append(String("1.3.6.1.6.3.1.1.5.4"));
       standard_traps.append(String("1.3.6.1.6.3.1.1.5.5"));
       standard_traps.append(String("1.3.6.1.6.3.1.1.5.6"));
   
       Array<String> oids;
       String tmpoid = trapOid;
   
       while(tmpoid.find(".") != PEG_NOT_FOUND)
       {
           oids.append(tmpoid.subString(0, tmpoid.find(".")));
           tmpoid = tmpoid.subString(tmpoid.find(".") + 1);
       }
   
       oids.append(tmpoid);
   
       String ent;
       if (Contains(standard_traps, trapOid))
       {
           //
           // if the trapOid is one of the standard traps,
           // then the SNMPV1 enterprise parameter must be set
           // to the value of the trapOid, the generic-trap
           // parameter must be set to one of (0 - 5), and the
           // specific-trap parameter must be set to 0
           //
   
           enterpriseOid = sendtrapOid;
   
           // the generic trap is last sub-identifier of the
           // trapOid minus 1
           genTrap = atoi(oids[oids.size() - 1].getCString()) - 1;
           specTrap = 0;
       }
       else
       {
           //
           // if the trapOid is not one of the standard traps:
           // then 1) the generic-trap parameter must be set to 6,
           // 2) if the next-to-last sub-identifier of the
           // trapOid is zero, then the SNMPV1 enterprise
           // parameter is the trapOid with the last 2
           // sub-identifiers removed, otherwise, the
           // SNMPV1 enterprise parameter is the trapOid
           // with the last sub-identifier removed;
           // 3) the SNMPv1 specific-trap parameter is the last
           // sub-identifier of the trapOid;
           //
   
           genTrap = 6;
   
           specTrap = atoi(oids[oids.size()-1].getCString());
   
           ent = oids[0];
           for (Uint8 i = 1; i < oids.size()-2; i++)
           {
               ent = ent + "." + oids[i];
           }
  
     OID* enterpriseOid = MakeOIDFromDot(enterprise.allocateCString());          if (oids[oids.size()-2] != "0")
           {
               ent = ent + "." + oids[oids.size()-2];
           }
  
     // getting trap data for do_trap()          enterpriseOid = MakeOIDFromDot(ent.getCString());
     entV2Trap = trapOid.allocateCString();  
  
     // getting trapOid          if (enterpriseOid == NULL)
     OID *sendtrapOid = MakeOIDFromDot(trapOid.allocateCString());          {
               throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                   _MSG_INVALID_ENTERPRISEOID);
           }
       }
  
       // creates VarBind
     for(Uint32 i = 0; i < vbOids.size(); i++)     for(Uint32 i = 0; i < vbOids.size(); i++)
     {     {
         if ((object = MakeOIDFromDot(vbOids[i].allocateCString())) == NULL)          CString _vbOid = vbOids[i].getCString();
           CString _vbValue = vbValues[i].getCString();
   
           if ((object = MakeOIDFromDot(_vbOid)) == NULL)
         {         {
             cout << "Invalid OID received: " << vbOids[i] << endl;              throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
             return;                  _MSG_INVALID_PROPERTYOID);
         }         }
  
         if (strcmp(vbTypes[i].allocateCString(),"OctetString") == 0)          if (String::equalNoCase(vbTypes[i], "OctetString"))
         {         {
             newValue = CloneOctetString(MakeOctetStringFromText               OctetString*    value;
                            (vbValues[i].allocateCString()));  
             if (newValue == NULL)               value = CloneOctetString(MakeOctetStringFromText(_vbValue));
                if (value == NULL)
             {             {
                 cout << "Invalid Value provided : " << vbValues[i] << endl;                   throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                 return;                       _MSG_INVALID_PROPERTYVALUE);
             }             }
             if ((vb2 = MakeVarBindWithValue(object,  
                if ((vb = MakeVarBindWithValue(object,
                 (OID *) NULL,                 (OID *) NULL,
                 OCTET_PRIM_TYPE,                 OCTET_PRIM_TYPE,
                 newValue)) == NULL)                                          value)) == NULL)
             {             {
                 cout << "Invalid OctetString value: " << vbValues[i] << endl;                   throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                 return;                       _MSG_MAKE_VARBIND_FAILED_FOR_OCTET_PRIM_TYPE);
               }
           }
           else if (String::equalNoCase(vbTypes[i], "OID"))
           {
               void* value = MakeOIDFromDot(_vbValue);
               if (value == NULL)
               {
                    throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                        _MSG_INVALID_PROPERTYVALUE);
               }
   
               if ((vb = MakeVarBindWithValue(object,
                                           (OID *) NULL,
                                           OBJECT_ID_TYPE,
                                           value)) == NULL)
               {
                    throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                        _MSG_MAKE_VARBIND_FAILED_FOR_OBJECT_ID_TYPE);
             }             }
         }         }
         else         else
         {         {
             newValue = CloneOctetString(MakeOctetString(              int vbvalue = atoi(_vbValue);
                 (unsigned char *) vbValues[i].allocateCString(),              void* value = &vbvalue;
                 strlen(vbValues[i].allocateCString())));  
  
             if (newValue == NULL)              if (value == NULL)
             {             {
                 cout << "Invalid Value provided : " << vbValues[i] << endl;                   throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                 return;                       _MSG_INVALID_PROPERTYVALUE);
             }             }
             if ((vb2 = MakeVarBindWithValue(object,  
               if ((vb = MakeVarBindWithValue(object,
                 (OID *) NULL,                 (OID *) NULL,
                 INTEGER_TYPE,                 INTEGER_TYPE,
                 newValue)) == NULL)                                          value)) == NULL)
             {             {
                 cout << "Invalid Integer Value: " << vbValues[i] << endl;                   throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,
                 return;                       _MSG_MAKE_VARBIND_FAILED_FOR_INTEGER_TYPE);
             }             }
         }         }
   
         if (i == 0)         if (i == 0)
         {         {
             vb = vb2;              vbhead = vb;
             vb3 = vb2;              vblast = vb;
         }         }
         else         else
         {         {
             vb3->next_var = vb2;              vblast->next_var = vb;
             vb3 = vb3->next_var;              vblast = vblast->next_var;
         }         }
  
         FreeOID(object);  
     }     }
  
     vb3->next_var = NULL;      vblast->next_var = NULL;
  
     // Now sending the trap      // Now send the trap
     if (trapType == String("SNMPGeneric"))      switch (snmpVersion)
     {     {
         do_trap(6, 4, vb2, enterpriseOid, entV2Trap);          case _SNMPv1_TRAP:
         FreeVarBindList(vb);  
         FreeVarBindList(vb2);  
     }  
     else if (trapType == String("SNMPv1"))  
     {     {
         cout << "Sending SNMPv1 Trap : " << trapOid << endl;  
         SendNotificationToDestSMIv1Params(         SendNotificationToDestSMIv1Params(
             1,                                  // notifyType              1,                                  // notifyType - TRAP
             6,                                  // genTrap              genTrap,                            // genTrap
             1,                                  // specTrap              specTrap,                           // specTrap
             enterpriseOid,                      // enterprise             enterpriseOid,                      // enterprise
             agent_addr,                         // agent_addr             agent_addr,                         // agent_addr
             vb2,                                // vb              vbhead,                             // vb
             NULL,                               // contextName             NULL,                               // contextName
             1,                                  // retryCount             1,                                  // retryCount
             1,                                  // timeout             1,                                  // timeout
             MakeOctetStringFromText(community.allocateCString()),       // securityName,              community_name,                     // securityName,
             SR_SECURITY_LEVEL_NOAUTH,           // securityLevel             SR_SECURITY_LEVEL_NOAUTH,           // securityLevel
             SR_SECURITY_MODEL_V1,               // securityModel             SR_SECURITY_MODEL_V1,               // securityModel
             &global_ti,                         // Transport Info             &global_ti,                         // Transport Info
             0);                                 // cfg_chk             0);                                 // cfg_chk
               break;
         FreeVarBindList(vb);  
         FreeVarBindList(vb2);  
     }     }
     else if (trapType == String("SNMPv2"))          case _SNMPv2C_TRAP:
     {     {
         cout << "Sending SNMPv2 Trap : " << trapOid << endl;  
         SendNotificationToDestSMIv2Params(         SendNotificationToDestSMIv2Params(
             1,                                  // notifyType              (SR_INT32)SNMPv2_TRAP_TYPE,         // notifyType - NOTIFICATION
             sendtrapOid,                        // snmpTrapOID             sendtrapOid,                        // snmpTrapOID
             agent_addr,                         // agent_addr             agent_addr,                         // agent_addr
             //vb2,                              // vb              vbhead,                             // vb
             vb,                         // vb  
             NULL,                               // contextName             NULL,                               // contextName
             1,                                  // retryCount             1,                                  // retryCount
             100,                                // timeout             100,                                // timeout
             MakeOctetStringFromText(community.allocateCString()),       // securityName or community              community_name,                     // securityName or community
             SR_SECURITY_LEVEL_NOAUTH,           // securityLevel             SR_SECURITY_LEVEL_NOAUTH,           // securityLevel
             SR_SECURITY_MODEL_V1,               // securityModel              SR_SECURITY_MODEL_V2C,              // securityModel
             &global_ti,                         // TransportInfo             &global_ti,                         // TransportInfo
             0);                                 // cfg_chk             0);                                 // cfg_chk
               break;
           }
           default:
           {
               throw PEGASUS_CIM_EXCEPTION(CIM_ERR_NOT_SUPPORTED,
                   _MSG_VERSION_NOT_SUPPORTED);
               break;
           }
       }
   
       // Free OID built by calls MakeOIDFromDot()
       FreeOID(sendtrapOid);
       FreeOID(enterpriseOid);
       FreeOID(object);
   
       // Free the data structures allocated and built by calls
       // MakeOctetString() and MakeOctetStringFrom Text()
       FreeOctetString(community_name);
       FreeOctetString(agent_addr);
   
       // Free the VarBind data structures allocated and built
       // by calls MakeVarBindWithValue()
       FreeVarBindList(vbhead);
         FreeVarBindList(vb);         FreeVarBindList(vb);
         FreeVarBindList(vb2);      FreeVarBindList(vblast);
   }
   
   // get the IP address of a host
   char * snmpDeliverTrap_emanate::_getIPAddress(const CString& hostName)
   {
       struct hostent *targetHostInfo;
       struct in_addr in;
   
       targetHostInfo = gethostbyname(hostName);
   
       if (targetHostInfo == NULL)
       {
           return(NULL);
       }
   
       char ** networkAddr;
       networkAddr = targetHostInfo->h_addr_list;
       (void)memcpy(&in.s_addr, *networkAddr, sizeof(in.s_addr));
       char * ipAddr = inet_ntoa(in);
       return(ipAddr);
   }
   
   // check the value of each part of an IP address which should be
   // between 0 and 255
   Boolean snmpDeliverTrap_emanate::_isValidOctet(const Uint32& octetValue)
   {
       if (octetValue > 0 && octetValue < 255)
       {
           return true;
     }     }
     else     else
     {     {
         cout << "Trap type not supported : " << trapType << endl;          return false;
         exit(2);  
     }     }
 } }
  

Legend:
Removed from v.1.4  
changed lines
  Added in v.1.11.12.1
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2