pegasus/src/Pegasus/ControlProviders/InteropProvider/Server.cpp - diff

Return to Server.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / ControlProviders / InteropProvider

Diff for /pegasus/src/Pegasus/ControlProviders/InteropProvider/Server.cpp between version 1.5.4.1 and 1.20

version 1.5.4.1, 2008/02/22 23:13:52

version 1.20, 2009/06/22 07:36:53

Line 1

//%2006////////////////////////////////////////////////////////////////////////

//%LICENSE////////////////////////////////////////////////////////////////

// Licensed to The Open Group (TOG) under one or more contributor license

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

// agreements. Refer to the OpenPegasusNOTICE.txt file distributed with

// this work for additional information regarding copyright ownership.

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

// Each contributor licenses this file to you under the OpenPegasus Open

// Source License; you may not use this file except in compliance with the

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

// License.

// 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"),

// EMC Corporation; Symantec Corporation; The Open Group.

// to deal in the Software without restriction, including without limitation

// the rights to use, copy, modify, merge, publish, distribute, sublicense,

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

// and/or sell copies of the Software, and to permit persons to whom the

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

// Software is furnished to do so, subject to the following conditions:

// deal in the Software without restriction, including without limitation the

// rights to use, copy, modify, merge, publish, distribute, sublicense, and/or

// The above copyright notice and this permission notice shall be included

// sell copies of the Software, and to permit persons to whom the Software is

// in all copies or substantial portions of the Software.

// furnished to do so, subject to the following conditions:

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS

// THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN

// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

// ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED

// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.

// "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT

// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY

// LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR

// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,

// PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT

// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE

// HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN

// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

// ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION

// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

//=============================================================================

//////////////////////////////////////////////////////////////////////////

///////////////////////////////////////////////////////////////////////////////

Line 49

Line 47

#include <Pegasus/Common/Config.h>

#include <Pegasus/Common/HostAddress.h>

#include <Pegasus/Common/PegasusVersion.h>

#include <cctype>

Line 57

Line 56

#include "InteropProvider.h"

#include "InteropProviderUtils.h"

#include "InteropConstants.h"

#include "Guid.h"

#include <Pegasus/Common/StatisticalData.h>

#include <Pegasus/General/Guid.h>

PEGASUS_USING_STD;

PEGASUS_NAMESPACE_BEGIN

Line 142

Line 141

profileDescriptions.append("Instance Manipulation");

ConfigManager* configManager = ConfigManager::getInstance();

if (String::equal(configManager->getCurrentValue(

if (ConfigManager::parseBooleanValue(

"enableAssociationTraversal"), "true"))

configManager->getCurrentValue("enableAssociationTraversal")))

{

profiles.append(6);

profileDescriptions.append("Association Traversal");

Line 155

Line 154

profiles.append(8);

profileDescriptions.append("Qualifier Declaration");

if (String::equal(configManager->getCurrentValue(

if (ConfigManager::parseBooleanValue(

"enableIndicationService"), "true"))

configManager->getCurrentValue("enableIndicationService")))

{

profiles.append(9);

profileDescriptions.append("Indications");

Line 185

Line 184

PEGASUS_CLASSNAME_PG_CIMXMLCOMMUNICATIONMECHANISM.getString());

// Name Property

String nameProperty(STRLIT_ARGS("PEGASUSCOMM"));

nameProperty.append(namespaceType);

nameProperty.append(Char16('+'));

nameProperty.append(IPAddress);

setPropertyValue(instance, CIMXMLCOMMMECH_PROPERTY_NAME,

(String("PEGASUSCOMM") + namespaceType));

nameProperty);

// CommunicationMechanism Property - Force to 2.

setPropertyValue(instance, CIMXMLCOMMMECH_PROPERTY_COMMUNICATIONMECHANISM,

Line 262

Line 266

// AdvertiseTypes property

Array<Uint16> advertiseTypes;

ConfigManager* configManager = ConfigManager::getInstance();

if (enableSLP)

if (String::equal(configManager->getCurrentValue("slp"), "true"))

{

advertiseTypes.append(3); // Advertised via SLP

}

Line 294

Line 297

"InteropProvider::enumCIMXMLCommunicationMechanismInstances");

ConfigManager* configManager = ConfigManager::getInstance();

Boolean enableHttpConnection = String::equal(

Boolean enableHttpConnection = ConfigManager::parseBooleanValue(

configManager->getCurrentValue("enableHttpConnection"), "true");

configManager->getCurrentValue("enableHttpConnection"));

Boolean enableHttpsConnection = String::equal(

Boolean enableHttpsConnection = ConfigManager::parseBooleanValue(

configManager->getCurrentValue("enableHttpsConnection"), "true");

configManager->getCurrentValue("enableHttpsConnection"));

Array<CIMInstance> instances;

Uint32 namespaceAccessProtocol;

Line 307

Line 310

PEGASUS_NAMESPACENAME_INTEROP,

PEGASUS_CLASSNAME_PG_CIMXMLCOMMUNICATIONMECHANISM, false, true, false);

Array<String> ips;

#ifdef PEGASUS_ENABLE_IPV6

ips = System::getInterfaceAddrs();

#endif

if (enableHttpConnection)

{

// Build the CommunicationMechanism instance for the HTTP protocol

namespaceAccessProtocol = 2;

namespaceType = "http";

String httpPort = configManager->getCurrentValue("httpPort");

CIMInstance instance;

if (httpPort == String::EMPTY)

for (Uint32 i = 0; i < ips.size() ; ++i)

{

Uint32 portNumberHttp = System::lookupPort(

String addr = ips[i];

WBEM_HTTP_SERVICE_NAME, WBEM_DEFAULT_HTTP_PORT);

if (HostAddress::isValidIPV6Address(ips[i]))

char buffer[32];

{

sprintf(buffer, "%u", portNumberHttp);

addr = "[" + addr + "]";

httpPort.assign(buffer);

}

CIMInstance instance =

addr.append(":");

addr.append(httpPort);

instance =

buildCIMXMLCommunicationMechanismInstance(

namespaceType,

namespaceAccessProtocol,

addr,

commMechClass);

instances.append(instance);

}

// If System::getInterfaceAddrs() fails add ip4 addr here.

if (!ips.size())

{

instance = buildCIMXMLCommunicationMechanismInstance(

namespaceType,

namespaceAccessProtocol,

getHostAddress(hostName, namespaceAccessProtocol, httpPort),

commMechClass);

instances.append(instance);

}

if (enableHttpsConnection)

{

// Build the CommunicationMechanism instance for the HTTPS protocol

namespaceAccessProtocol = 3;

namespaceType = "https";

String httpsPort = configManager->getCurrentValue("httpsPort");

CIMInstance instance;

if (httpsPort == String::EMPTY)

for (Uint32 i = 0; i < ips.size() ; ++i)

{

Uint32 portNumberHttps = System::lookupPort(

String addr = ips[i];

WBEM_HTTPS_SERVICE_NAME, WBEM_DEFAULT_HTTPS_PORT);

if (HostAddress::isValidIPV6Address(ips[i]))

char buffer[32];

{

sprintf(buffer, "%u", portNumberHttps);

addr = "[" + addr + "]";

httpsPort.assign(buffer);

}

CIMInstance instance =

addr.append(":");

addr.append(httpsPort);

instance =

buildCIMXMLCommunicationMechanismInstance(

namespaceType,

namespaceAccessProtocol,

addr,

commMechClass);

instances.append(instance);

}

// If System::getInterfaceAddrs() fails add ip4 addr here.

if (!ips.size())

{

instance = buildCIMXMLCommunicationMechanismInstance(

namespaceType,

namespaceAccessProtocol,

getHostAddress(hostName, namespaceAccessProtocol, httpsPort),

commMechClass);

instances.append(instance);

}

PEG_METHOD_EXIT();

return instances;

Line 381

Line 412

bool found = false;

Array<CIMInstance> tmpInstances = repository->enumerateInstancesForClass(

PEGASUS_NAMESPACENAME_INTEROP,

PEGASUS_CLASSNAME_PG_OBJECTMANAGER, false, false, false,

PEGASUS_CLASSNAME_PG_OBJECTMANAGER, false, false,

CIMPropertyList());

Uint32 numInstances = tmpInstances.size();

if(numInstances == 1)

Line 398

Line 429

CIMClass omClass;

instance = buildInstanceSkeleton(PEGASUS_NAMESPACENAME_INTEROP,

PEGASUS_CLASSNAME_PG_OBJECTMANAGER, omClass);

PEGASUS_CLASSNAME_PG_OBJECTMANAGER, false, omClass);

// Set the common key properties

setCommonKeys(instance);

Line 451

Line 482

// write instance to the repository

CIMObjectPath instancePath = repository->createInstance(

PEGASUS_NAMESPACENAME_INTEROP, instance);

// Get an updated copy of the instance that was saved

instance = repository->getInstance(

PEGASUS_NAMESPACENAME_INTEROP, instancePath);

instance.setPath(instancePath);

}

Line 520

Line 554

// Modify the instance on disk

repository->modifyInstance(instanceReference.getNameSpace(),

omInstance, false, propertyList);

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

PEG_TRACE((

"Interop Provider Set Statistics gathering in CIM_ObjectManager: $0",

TRC_CONTROLPROVIDER,

(statisticsFlag? "true" : "false"));

Tracer::LEVEL3,

"Interop Provider Set Statistics gathering in CIM_ObjectManager: %s",

(statisticsFlag? "true" : "false")));

StatisticalData* sd = StatisticalData::current();

sd->setCopyGSD(statisticsFlag);

PEG_METHOD_EXIT();

Line 673

Line 709

CIMClass targetClass;

CIMInstance instanceskel = buildInstanceSkeleton(

PEGASUS_NAMESPACENAME_INTEROP,

PEGASUS_CLASSNAME_PG_COMMMECHANISMFORMANAGER, targetClass);

PEGASUS_CLASSNAME_PG_COMMMECHANISMFORMANAGER, true, targetClass);

for (Uint32 i = 0, n = commInstances.size(); i < n; ++i)

{

CIMInstance instance = instanceskel.clone();

Line 691

Line 727

return assocInstances;

}

#ifdef PEGASUS_ENABLE_DMTF_INDICATION_PROFILE_SUPPORT

CIMInstance InteropProvider::buildAssociationInstance(

const CIMName &className,

const CIMName &propName1,

const CIMObjectPath &objPath1,

const CIMName &propName2,

const CIMObjectPath &objPath2)

{

CIMClass cimClass = repository->getClass(

PEGASUS_NAMESPACENAME_INTEROP,

className,

false,

true,

true);

CIMInstance instance = cimClass.buildInstance(

true,

CIMPropertyList());

instance.getProperty(instance.findProperty(propName1)).setValue(objPath1);

instance.getProperty(instance.findProperty(propName2)).setValue(objPath2);

instance.setPath(instance.buildPath(cimClass));

return instance;

}

Array<CIMInstance> InteropProvider::enumElementCapabilityInstances(

const OperationContext &opContext)

{

// Get CIM_IndicationServiceCapabilities instance

Array<CIMObjectPath> capPaths = cimomHandle.enumerateInstanceNames(

opContext,

PEGASUS_NAMESPACENAME_INTEROP,

PEGASUS_CLASSNAME_CIM_INDICATIONSERVICECAPABILITIES);

PEGASUS_ASSERT(capPaths.size() == 1);

// Get CIM_IndicationService instance

Array<CIMObjectPath> servicePaths = cimomHandle.enumerateInstanceNames(

opContext,

PEGASUS_NAMESPACENAME_INTEROP,

PEGASUS_CLASSNAME_CIM_INDICATIONSERVICE);

PEGASUS_ASSERT(servicePaths.size() == 1);

Array<CIMInstance> instances;

instances.append(

buildAssociationInstance(

PEGASUS_CLASSNAME_PG_ELEMENTCAPABILITIES,

PROPERTY_CAPABILITIES,

capPaths[0],

PROPERTY_MANAGEDELEMENT,

servicePaths[0]));

return instances;

}

Array<CIMInstance> InteropProvider::enumHostedIndicationServiceInstances(

const OperationContext &opContext)

{

Array<CIMInstance> instances;

CIMInstance cInst = getComputerSystemInstance();

// Get CIM_IndicationService instance

Array<CIMObjectPath> servicePaths = cimomHandle.enumerateInstanceNames(

opContext,

PEGASUS_NAMESPACENAME_INTEROP,

PEGASUS_CLASSNAME_CIM_INDICATIONSERVICE);

PEGASUS_ASSERT(servicePaths.size() == 1);

instances.append(

buildAssociationInstance(

PEGASUS_CLASSNAME_PG_HOSTEDINDICATIONSERVICE,

PROPERTY_ANTECEDENT,

cInst.getPath(),

PROPERTY_DEPENDENT,

servicePaths[0]));

return instances;

}

Array<CIMInstance> InteropProvider::enumServiceAffectsElementInstances(

const OperationContext &opContext)

{

Array<CIMInstance> instances;

// Get CIM_IndicationService instance

Array<CIMObjectPath> servicePaths = cimomHandle.enumerateInstanceNames(

opContext,

PEGASUS_NAMESPACENAME_INTEROP,

PEGASUS_CLASSNAME_CIM_INDICATIONSERVICE);

PEGASUS_ASSERT(servicePaths.size() == 1);

Array<CIMNamespaceName> namespaceNames = repository->enumerateNameSpaces();

// Get CIM_IndicationFilter and CIM_ListenerDestination instances in all

// namespaces and associate them with CIM_IndicationService instance using

// PG_ServiceAffectsElement instance.

for (Uint32 i = 0, n = namespaceNames.size() ; i < n ; ++i)

{

Array<CIMObjectPath> filterPaths;

try

{

// Get CIM_IndicationFilter instance names

filterPaths = cimomHandle.enumerateInstanceNames(

opContext,

namespaceNames[i],

PEGASUS_CLASSNAME_INDFILTER);

}

catch(CIMException &e)

{

// Ignore exception with CIM_ERR_INVALID_CLASS code. This will

// happen when the class CIM_IndicationFilter can not be found

// in this namespace.

if (e.getCode() != CIM_ERR_INVALID_CLASS)

{

PEG_TRACE((

TRC_CONTROLPROVIDER,

Tracer::LEVEL2,

"CIMException while enumerating the "

"CIM_IndicationFilter instances"

" in the namespace %s: %s.",

(const char*)namespaceNames[i].getString().getCString(),

(const char*)e.getMessage().getCString()));

}

catch(Exception &e)

{

PEG_TRACE((

TRC_CONTROLPROVIDER,

Tracer::LEVEL1,

"Exception while enumerating the "

"CIM_IndicationFilter instances"

" in the namespace %s: %s.",

(const char*)namespaceNames[i].getString().getCString(),

(const char*)e.getMessage().getCString()));

}

catch(...)

{

PEG_TRACE((

TRC_CONTROLPROVIDER,

Tracer::LEVEL1,

"Unknown error occurred while enumerating the "

"CIM_IndicationFilter instances in the namespace %s.",

(const char*)namespaceNames[i].getString().getCString()));

}

for (Uint32 f = 0, fn = filterPaths.size(); f < fn ; ++f)

{

filterPaths[f].setNameSpace(namespaceNames[i]);

instances.append(

buildAssociationInstance(

PEGASUS_CLASSNAME_PG_SERVICEAFFECTSELEMENT,

PROPERTY_AFFECTEDELEMENT,

filterPaths[f],

PROPERTY_AFFECTINGELEMENT,

servicePaths[0]));

}

Array<CIMObjectPath> handlerPaths;

try

{

// Get CIM_ListenerDestination instance names

handlerPaths = cimomHandle.enumerateInstanceNames(

opContext,

namespaceNames[i],

PEGASUS_CLASSNAME_LSTNRDST);

}

catch(CIMException &e)

{

// Ignore exception with CIM_ERR_INVALID_CLASS code. This will

// happen when the class CIM_ListenerDestination can not be found

// in this namespace.

if (e.getCode() != CIM_ERR_INVALID_CLASS)

{

PEG_TRACE((

TRC_CONTROLPROVIDER,

Tracer::LEVEL2,

"CIMException while enumerating the "

"CIM_ListenerDestination instances"

" in the namespace %s: %s.",

(const char*)namespaceNames[i].getString().getCString(),

(const char*)e.getMessage().getCString()));

}

catch(Exception &e)

{

PEG_TRACE((

TRC_CONTROLPROVIDER,

Tracer::LEVEL1,

"Exception while enumerating the "

"CIM_ListenerDestination instances"

" in the namespace %s: %s.",

(const char*)namespaceNames[i].getString().getCString(),

(const char*)e.getMessage().getCString()));

}

catch(...)

{

PEG_TRACE((

TRC_CONTROLPROVIDER,

Tracer::LEVEL1,

"Unknown error occurred while enumerating the "

"CIM_ListenerDestination instances in the namespace %s.",

(const char*)namespaceNames[i].getString().getCString()));

}

for (Uint32 h = 0, hn = handlerPaths.size(); h < hn ; ++h)

{

handlerPaths[h].setNameSpace(namespaceNames[i]);

instances.append(

buildAssociationInstance(

PEGASUS_CLASSNAME_PG_SERVICEAFFECTSELEMENT,

PROPERTY_AFFECTEDELEMENT,

handlerPaths[h],

PROPERTY_AFFECTINGELEMENT,

servicePaths[0]));

}

return instances;

}

#endif

PEGASUS_NAMESPACE_END

// END OF FILE

Legend:

Removed from v.1.5.4.1
changed lines
	Added in v.1.20

No CVS admin address has been configured