pegasus/src/Pegasus/Handler/snmpIndicationHandler/snmpDeliverTrap_emanate.cpp - diff

Return to snmpDeliverTrap_emanate.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / Handler / snmpIndicationHandler

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

version 1.4, 2002/03/21 23:00:08

version 1.21, 2006/01/27 19:21:20

Line 1

//%/////////////////////////////////////////////////////////////////////////////

//%2005////////////////////////////////////////////////////////////////////////

// Tivoli Systems

// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.

// IBM Corp.; EMC Corporation, The Open Group.

// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.

// EMC Corporation; VERITAS Software Corporation; The Open Group.

// Permission is hereby granted, free of charge, to any person obtaining a copy

// of this software and associated documentation files (the "Software"), to

Line 23

Line 29

// 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 <fcntl.h>

#include <Pegasus/Common/ArrayInternal.h>

#include <unistd.h>

#include <Pegasus/Common/InternalException.h>

#include <ctype.h>

#include <sys/stat.h>

#include "snmpDeliverTrap_emanate.h"

#include "prnt_lib.h"

PEGASUS_NAMESPACE_BEGIN

// l10n

#include <Pegasus/Common/MessageLoader.h>

PEGASUS_USING_STD;

// EMANATE specific declarations and entry points - MUST be in begining

// and outside NAMESPACE.

static char *sr_filename = __FILE__;

// 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 const char *sr_filename = __FILE__;

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

ObjectInfo OidList[] =

Line 59

Line 68

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 */

int k_initialize()

Line 69

Line 78

return 1;

}

// END EMANATE specific declarations.

PEGASUS_NAMESPACE_BEGIN

PEGASUS_USING_STD;

snmpDeliverTrap_emanate::snmpDeliverTrap_emanate()

{

// Initialize Subagent and establish comunication with the Master Agent

initialize();

}

snmpDeliverTrap_emanate::~snmpDeliverTrap_emanate()

{

// Close the connection to the Master Agent and shut down the

// Subagent

EndSubagent();

}

// initialize sub-agent

// This also defines the communication protocol to be used between master

// and sub-agent.

void snmpDeliverTrap_emanate::initialize()

{

#ifndef SR_UDS_IPC

Line 89

Line 117

if(InitSubagent() == -1)

{

cout << "InitSubagent Failed to initialize" << endl;

exit(1);

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INITSUBAGENT_FAILED);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INITSUBAGENT_FAILED_KEY,

_MSG_INITSUBAGENT_FAILED));

}

void snmpDeliverTrap_emanate::deliverTrap(

const String& trapOid,

const String& community,

const String& securityName,

const String& destination,

const String& targetHost,

const String& trapType,

const Uint16& targetHostFormat,

Array<String>& vbOids,

const String& otherTargetHostFormat,

Array<String>& vbTypes,

const Uint32& portNumber,

Array<String>& vbValues)

const Uint16& snmpVersion,

const String& engineID,

const Array<String>& vbOids,

const Array<String>& vbTypes,

const Array<String>& vbValues)

{

initialize();

VarBind *vbhead = NULL;

//void* newValue;

OctetString* newValue;

char* entV2Trap;

int vb_link_flag = 0;

VarBind *vb = NULL;

VarBind *vb2 = NULL;

VarBind *vblast = NULL;

VarBind *vb3 = NULL;

OID *object = NULL;

// getting IP address of the host

// Translate a string into an OID

char* hostname = System::getHostName().allocateCString();

OID *sendtrapOid = MakeOIDFromDot(trapOid.getCString());

char **p;

struct hostent *hp;

if (sendtrapOid == NULL)

struct in_addr in;

{

hp=gethostbyname(hostname);

p = hp->h_addr_list;

// l10n

(void)memcpy(&in.s_addr, *p, sizeof(in.s_addr));

char* IP_string = inet_ntoa(in);

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INVALID_TRAPOID);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INVALID_KEY,

_MSG_INVALID_TRAPOID));

}

// Destination : convert targetHost into Transport

CString trap_dest = targetHost.getCString();

// converting destination into Transport

TransportInfo global_ti;

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)

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_DESTINATION_NOT_FOUND);

throw PEGASUS_CIM_EXCEPTION_L (CIM_ERR_FAILED,

MessageLoaderParms(_MSG_DESTINATION_NOT_FOUND_KEY,

_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:

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_NOT_SUPPORTED,

// _MSG_TARGETHOSTFORMAT_NOT_SUPPORTED);

throw PEGASUS_CIM_EXCEPTION_L (CIM_ERR_NOT_SUPPORTED,

MessageLoaderParms(_MSG_TARGETHOSTFORMAT_NOT_SUPPORTED_KEY,

_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)

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INVALID_SECURITY_NAME);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INVALID_SECURITY_NAME_KEY,

_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

OctetString* agent_addr;

SR_INT32 s1, s2, s3, s4;

SR_UINT32 ipaddr;

// pull out each of the 4 octet values from IP address

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

if (!_isValidOctet(s1) || !_isValidOctet(s2) ||

!_isValidOctet(s3) || !_isValidOctet(s4))

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INVALID_OCTET_VALUE);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INVALID_OCTET_VALUE_KEY,

_MSG_INVALID_OCTET_VALUE));

}

// create an empty 4 length OctetString

agent_addr = MakeOctetString(NULL,4);

if (agent_addr == NULL)

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_CREATE_OCTET_FAILED);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_CREATE_OCTET_FAILED_KEY,

_MSG_CREATE_OCTET_FAILED));

}

// fill in values for OctetString

agent_addr->octet_ptr[0] = (unsigned char)s1;

agent_addr->octet_ptr[1] = (unsigned char)s2;

agent_addr->octet_ptr[2] = (unsigned char)s3;

agent_addr->octet_ptr[3] = (unsigned char)s4;

// ATTN-NU-20020312 : Write code to get enterprise, genTrap and

// specTrap from trapOid.

String enterprise;

SR_INT32 genTrap = 0;

SR_INT32 specTrap = 0;

OID* enterpriseOid = MakeOIDFromDot(enterprise.allocateCString());

OID* enterpriseOid ;

// getting trap data for do_trap()

Array<String> standard_traps;

entV2Trap = trapOid.allocateCString();

// getting trapOid

standard_traps.append(String("1.3.6.1.6.3.1.1.5.1"));

OID *sendtrapOid = MakeOIDFromDot(trapOid.allocateCString());

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];

}

if (oids[oids.size()-2] != "0")

{

ent = ent + "." + oids[oids.size()-2];

}

enterpriseOid = MakeOIDFromDot(ent.getCString());

if (enterpriseOid == NULL)

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INVALID_ENTERPRISEOID);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INVALID_ENTERPRISEOID_KEY,

_MSG_INVALID_ENTERPRISEOID));

}

// creates VarBind

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;

return;

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INVALID_PROPERTYOID);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INVALID_PROPERTYOID_KEY,

_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;

return;

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INVALID_PROPERTYVALUE);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INVALID_PROPERTYVALUE_KEY,

_MSG_INVALID_PROPERTYVALUE));

}

if ((vb2 = MakeVarBindWithValue(object,

if ((vb = MakeVarBindWithValue(object,

(OID *) NULL,

OCTET_PRIM_TYPE,

newValue)) == NULL)

value)) == NULL)

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_MAKE_VARBIND_FAILED_FOR_OCTET_PRIM_TYPE);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_MAKE_VARBIND_FAILED_FOR_OCTET_PRIM_TYPE_KEY,

_MSG_MAKE_VARBIND_FAILED_FOR_OCTET_PRIM_TYPE));

}

else if (String::equalNoCase(vbTypes[i], "OID"))

{

void* value = MakeOIDFromDot(_vbValue);

if (value == NULL)

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INVALID_PROPERTYVALUE);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INVALID_PROPERTYVALUE_KEY,

_MSG_INVALID_PROPERTYVALUE));

}

if ((vb = MakeVarBindWithValue(object,

(OID *) NULL,

OBJECT_ID_TYPE,

value)) == NULL)

{

cout << "Invalid OctetString value: " << vbValues[i] << endl;

return;

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_MAKE_VARBIND_FAILED_FOR_OBJECT_ID_TYPE);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_MAKE_VARBIND_FAILED_FOR_OBJECT_ID_TYPE_KEY,

_MSG_MAKE_VARBIND_FAILED_FOR_OBJECT_ID_TYPE));

}

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;

return;

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_INVALID_PROPERTYVALUE);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_INVALID_PROPERTYVALUE_KEY,

_MSG_INVALID_PROPERTYVALUE));

}

if ((vb2 = MakeVarBindWithValue(object,

if ((vb = MakeVarBindWithValue(object,

(OID *) NULL,

INTEGER_TYPE,

newValue)) == NULL)

value)) == NULL)

{

cout << "Invalid Integer Value: " << vbValues[i] << endl;

return;

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

// _MSG_MAKE_VARBIND_FAILED_FOR_INTEGER_TYPE);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED,

MessageLoaderParms(_MSG_MAKE_VARBIND_FAILED_FOR_INTEGER_TYPE_KEY,

_MSG_MAKE_VARBIND_FAILED_FOR_INTEGER_TYPE));

}

if (i == 0)

{

vb = vb2;

vbhead = vb;

vb3 = vb2;

vblast = vb;

}

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(

1, // notifyType

1, // notifyType - TRAP

6, // genTrap

genTrap, // genTrap

1, // specTrap

specTrap, // specTrap

enterpriseOid, // enterprise

agent_addr, // agent_addr

vb2, // vb

vbhead, // vb

NULL, // contextName

1, // retryCount

1, // timeout

MakeOctetStringFromText(community.allocateCString()), // securityName,

community_name, // securityName,

SR_SECURITY_LEVEL_NOAUTH, // securityLevel

SR_SECURITY_MODEL_V1, // securityModel

&global_ti, // Transport Info

0); // cfg_chk

break;

FreeVarBindList(vb);

FreeVarBindList(vb2);

}

else if (trapType == String("SNMPv2"))

case _SNMPv2C_TRAP:

{

cout << "Sending SNMPv2 Trap : " << trapOid << endl;

SendNotificationToDestSMIv2Params(

1, // notifyType

(SR_INT32)SNMPv2_TRAP_TYPE, // notifyType - NOTIFICATION

sendtrapOid, // snmpTrapOID

agent_addr, // agent_addr

//vb2, // vb

vbhead, // vb

vb, // vb

NULL, // contextName

1, // retryCount

100, // timeout

MakeOctetStringFromText(community.allocateCString()), // securityName or community

community_name, // securityName or community

SR_SECURITY_LEVEL_NOAUTH, // securityLevel

SR_SECURITY_MODEL_V1, // securityModel

SR_SECURITY_MODEL_V2C, // securityModel

&global_ti, // TransportInfo

0); // cfg_chk

break;

}

default:

{

// l10n

// throw PEGASUS_CIM_EXCEPTION(CIM_ERR_NOT_SUPPORTED,

// _MSG_VERSION_NOT_SUPPORTED);

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_NOT_SUPPORTED,

MessageLoaderParms(_MSG_VERSION_NOT_SUPPORTED_KEY,

_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(vb2);

FreeVarBindList(vblast);

}

// get the IP address of a host

char * snmpDeliverTrap_emanate::_getIPAddress(const CString& hostName)

{

struct hostent *targetHostInfo;

struct in_addr in;

#if defined(PEGASUS_OS_LINUX)

char hostEntryBuffer[8192];

struct hostent hostEntryStruct;

int hostEntryErrno;

gethostbyname_r(

hostName,

&hostEntryStruct,

hostEntryBuffer,

sizeof(hostEntryBuffer),

&targetHostInfo,

&hostEntryErrno);

#elif defined(PEGASUS_OS_SOLARIS)

char hostEntryBuffer[8192];

struct hostent hostEntryStruct;

int hostEntryErrno;

targetHostInfo = gethostbyname_r(

(char *)hostName,

&hostEntryStruct,

hostEntryBuffer,

sizeof(hostEntryBuffer),

&hostEntryErrno);

#else

targetHostInfo = gethostbyname(hostName);

#endif

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

{

cout << "Trap type not supported : " << trapType << endl;

return false;

exit(2);

}

Legend:

Removed from v.1.4
changed lines
	Added in v.1.21

No CVS admin address has been configured