pegasus/src/Pegasus/ProviderManager2/Default/DefaultProviderManager.cpp - diff

Return to DefaultProviderManager.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Default

Diff for /pegasus/src/Pegasus/ProviderManager2/Default/DefaultProviderManager.cpp between version 1.11.4.3 and 1.56.2.1

version 1.11.4.3, 2004/03/10 14:19:29

version 1.56.2.1, 2006/02/10 16:11:59

Line 1

//%2003////////////////////////////////////////////////////////////////////////

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

// Company, L. P., IBM Corp., The Open Group, 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.

// EMC Corporation; Symantec 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 30

Line 36

// Mike Day, IBM (mdday@us.ibm.com)

// Karl Schopmeyer(k.schopmeyer@opengroup.org) - Fix associators.

// Yi Zhou, Hewlett-Packard Company (yi_zhou@hp.com)

// Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)

// Seema Gupta (gseema@in.ibm.com) for PEP135

// Willis White (whiwill@us.ibm.com)

// Josephine Eskaline Joyce (jojustin@in.ibm.com) for PEP#101

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

Line 37

Line 47

#include <Pegasus/Common/CIMMessage.h>

#include <Pegasus/Common/OperationContext.h>

#include <Pegasus/Common/Destroyer.h>

#include <Pegasus/Common/Tracer.h>

#include <Pegasus/Common/StatisticalData.h>

#include <Pegasus/Common/Logger.h>

#include <Pegasus/Common/MessageLoader.h> //l10n

#include <Pegasus/Common/Constants.h>

//#include <Pegasus/Common/QueryExpression.h>

#include <Pegasus/Query/QueryExpression/QueryExpression.h>

//#include <Pegasus/ProviderManager2/QueryExpressionFactory.h>

#include <Pegasus/ProviderManager2/QueryExpressionFactory.h>

#include <Pegasus/Config/ConfigManager.h>

#include <Pegasus/ProviderManager2/Default/Provider.h>

#include <Pegasus/ProviderManager2/OperationResponseHandler.h>

#include <Pegasus/Server/ProviderRegistrationManager/ProviderRegistrationManager.h>

#include <Pegasus/ProviderManager2/ProviderManagerService.h>

#include <Pegasus/ProviderManager2/ProviderType.h>

#define HandleCatch(handler) \

catch(CIMException & e) \

{ \

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \

"Exception: " + e.getMessage()); \

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); \

} \

catch(Exception & e) \

{ \

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \

"Exception: " + e.getMessage()); \

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage());\

} \

catch(...) \

{ \

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \

"Exception: Unknown"); \

handler.setStatus(CIM_ERR_FAILED, "Unknown error."); \

} \

STAT_RESPONSEEND

PEGASUS_NAMESPACE_BEGIN

Line 77

Line 107

};

// Provider module status

// Default Provider Manager

static const Uint16 _MODULE_OK = 2;

static const Uint16 _MODULE_STOPPING = 9;

static const Uint16 _MODULE_STOPPED = 10;

// provider manager

static LocalProviderManager providerManager;

DefaultProviderManager::DefaultProviderManager(void)

{

_subscriptionInitComplete = false;

}

DefaultProviderManager::~DefaultProviderManager(void)

Line 128

Line 152

response = handleDeleteInstanceRequest(request);

break;

// case CIM_EXEC_QUERY_REQUEST_MESSAGE:

case CIM_EXEC_QUERY_REQUEST_MESSAGE:

// response = handleExecQueryRequest(request);

response = handleExecQueryRequest(request);

// break;

break;

case CIM_ASSOCIATORS_REQUEST_MESSAGE:

response = handleAssociatorsRequest(request);

Line 172

Line 196

response = handleDeleteSubscriptionRequest(request);

break;

case CIM_ENABLE_INDICATIONS_REQUEST_MESSAGE:

response = handleEnableIndicationsRequest(request);

break;

case CIM_DISABLE_INDICATIONS_REQUEST_MESSAGE:

response = handleDisableIndicationsRequest(request);

break;

case CIM_CONSUME_INDICATION_REQUEST_MESSAGE:

response = handleConsumeIndicationRequest(request);

break;

case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:

response = handleExportIndicationRequest(request);

break;

Line 200

Line 212

response = handleStopAllProvidersRequest(request);

break;

case CIM_INITIALIZE_PROVIDER_REQUEST_MESSAGE:

response = handleInitializeProviderRequest(request);

break;

case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE:

response = handleSubscriptionInitCompleteRequest (request);

break;

default:

response = handleUnsupportedRequest(request);

Line 221

Line 241

return(0);

}

Message * DefaultProviderManager::handleInitializeProviderRequest(

const Message * message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

"DefaultProviderManager::handleInitializeProviderRequest");

CIMInitializeProviderRequestMessage * request =

dynamic_cast<CIMInitializeProviderRequestMessage *>

(const_cast<Message *>(message));

PEGASUS_ASSERT(request != 0);

CIMInitializeProviderResponseMessage* response =

dynamic_cast<CIMInitializeProviderResponseMessage*>(

request->buildResponse());

PEGASUS_ASSERT(response != 0);

OperationResponseHandler handler(request, response);

try

{

// resolve provider name

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph = providerManager.getProvider(

name.getPhysicalName(), name.getLogicalName());

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL3,

"CIMException: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage());

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL3,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage());

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL3,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

PEG_METHOD_EXIT();

return(response);

}

Message * DefaultProviderManager::handleGetInstanceRequest(const Message * message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleGetInstanceRequest");

Line 231

Line 307

PEGASUS_ASSERT(request != 0);

CIMGetInstanceResponseMessage * response =

new CIMGetInstanceResponseMessage(

dynamic_cast<CIMGetInstanceResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

CIMInstance());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod(request->getHttpMethod());

// create a handler for this request

GetInstanceResponseHandler handler(request, response);

Line 263

Line 329

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

ProviderName name(

objectPath,

ProviderType::INSTANCE);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMPropertyList propertyList(request->propertyList);

Line 290

Line 353

pm_service_op_lock op_lock(&ph.GetProvider());

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

ph.GetProvider().getInstance(

context,

Line 299

Line 362

request->includeClassOrigin,

propertyList,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 339

Line 382

PEGASUS_ASSERT(request != 0);

CIMEnumerateInstancesResponseMessage * response =

new CIMEnumerateInstancesResponseMessage(

dynamic_cast<CIMEnumerateInstancesResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

Array<CIMInstance>());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// create a handler for this request

EnumerateInstancesResponseHandler handler(request, response);

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleEnumerateInstancesRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleEnumerateInstancesRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->className.getString());

request->className.getString()));

// make target object path

CIMObjectPath objectPath(

Line 370

Line 405

request->nameSpace,

request->className);

ProviderName name(

objectPath,

ProviderType::INSTANCE);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph = providerManager.getProvider(name.getPhysicalName(),

OpProviderHolder ph = providerManager.getProvider(

name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMPropertyList propertyList(request->propertyList);

Line 397

Line 429

pm_service_op_lock op_lock(&ph.GetProvider());

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

ph.GetProvider().enumerateInstances(

context,

Line 406

Line 438

request->includeClassOrigin,

propertyList,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 446

Line 458

PEGASUS_ASSERT(request != 0);

CIMEnumerateInstanceNamesResponseMessage * response =

new CIMEnumerateInstanceNamesResponseMessage(

dynamic_cast<CIMEnumerateInstanceNamesResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

Array<CIMObjectPath>());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

//set HTTP method in response from request

response->setHttpMethod(request->getHttpMethod());;

// create a handler for this request

EnumerateInstanceNamesResponseHandler handler(request, response);

// process the request

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleEnumerateInstanceNamesRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleEnumerateInstanceNamesRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->className.getString());

request->className.getString()));

// make target object path

CIMObjectPath objectPath(

Line 478

Line 482

request->nameSpace,

request->className);

// build an internal provider name from the request arguments

ProviderName name(

objectPath,

ProviderType::INSTANCE);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName());

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// forward request

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

Line 504

pm_service_op_lock op_lock(&ph.GetProvider());

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

ph.GetProvider().enumerateInstanceNames(

context,

objectPath,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 551

Line 531

// create response message

CIMCreateInstanceResponseMessage * response =

new CIMCreateInstanceResponseMessage(

dynamic_cast<CIMCreateInstanceResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

CIMObjectPath());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// create a handler for this request

CreateInstanceResponseHandler handler(request, response);

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleCreateInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleCreateInstanceRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->newInstance.getPath().getClassName().getString());

request->newInstance.getPath().getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 583

Line 555

request->newInstance.getPath().getClassName(),

request->newInstance.getPath().getKeyBindings());

ProviderName name(

objectPath,

ProviderType::INSTANCE);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// forward request

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

Line 608

Line 577

pm_service_op_lock op_lock(&ph.GetProvider());

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

ph.GetProvider().createInstance(

context,

objectPath,

request->newInstance,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 656

Line 605

// create response message

CIMModifyInstanceResponseMessage * response =

new CIMModifyInstanceResponseMessage(

dynamic_cast<CIMModifyInstanceResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// create a handler for this request

ModifyInstanceResponseHandler handler(request, response);

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleModifyInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleModifyInstanceRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->modifiedInstance.getPath().getClassName().getString());

request->modifiedInstance.getPath().getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 687

Line 629

request->modifiedInstance.getPath ().getClassName(),

request->modifiedInstance.getPath ().getKeyBindings());

ProviderName name(

objectPath,

ProviderType::INSTANCE);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMPropertyList propertyList(request->propertyList);

Line 714

Line 653

pm_service_op_lock op_lock(&ph.GetProvider());

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

ph.GetProvider().modifyInstance(

context,

Line 723

Line 662

request->includeQualifiers,

propertyList,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 764

Line 683

// create response message

CIMDeleteInstanceResponseMessage * response =

new CIMDeleteInstanceResponseMessage(

dynamic_cast<CIMDeleteInstanceResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// create a handler for this request

DeleteInstanceResponseHandler handler(request, response);

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleDeleteInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleDeleteInstanceRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

request->instanceName.getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 795

Line 707

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

ProviderName name(

objectPath,

ProviderType::INSTANCE);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// forward request

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

Line 820

Line 729

pm_service_op_lock op_lock(&ph.GetProvider());

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

ph.GetProvider().deleteInstance(

context,

objectPath,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Message * DefaultProviderManager::handleExecQueryRequest(const Message * message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleExecQueryRequest");

Line 866

Line 755

PEGASUS_ASSERT(request != 0);

CIMExecQueryResponseMessage * response =

new CIMExecQueryResponseMessage(

dynamic_cast<CIMExecQueryResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

Array<CIMObject>());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// create a handler for this request

ExecQueryResponseHandler handler(request, response);

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleExecQueryRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleExecQueryRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->className.getString());

request->className.getString()));

// make target object path

CIMObjectPath objectPath(

Line 897

Line 778

request->nameSpace,

request->className);

ProviderName name(

objectPath,

ProviderType::QUERY);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(),

name.getPhysicalName(), name.getLogicalName());

name.getLogicalName(), String::EMPTY);

if (dynamic_cast<CIMInstanceQueryProvider*>(ph.GetCIMProvider()) == 0) {

String errorString = " instance provider is registered supporting execQuery "

Line 919

Line 796

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

QueryExpression qx(QueryExpressionFactory::routeBuildQueryExpressionRep

QueryExpression qx(request->queryLanguage,request->query);

(request->queryLanguage,request->query));

// forward request

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

Line 933

Line 809

pm_service_op_lock op_lock(&ph.GetProvider());

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

ph.GetProvider().execQuery(

context,

objectPath,

qx,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

cout<<"--- exception not a CIMInstanceQueryProvider"<<endl;

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

return(response);

}

Message * DefaultProviderManager::handleAssociatorsRequest(const Message * message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleAssociatorsRequest");

Line 981

Line 834

PEGASUS_ASSERT(request != 0);

CIMAssociatorsResponseMessage * response =

new CIMAssociatorsResponseMessage(

dynamic_cast<CIMAssociatorsResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

Array<CIMObject>());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// create a handler for this request

AssociatorsResponseHandler handler(request, response);

// process the request

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleAssociatorsRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleAssociatorsRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

request->objectName.getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 1017

Line 865

request->nameSpace,

request->assocClass.getString());

ProviderName name(

assocPath,

ProviderType::ASSOCIATION);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// ATTN KS STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

pm_service_op_lock op_lock(&ph.GetProvider());

ph.GetProvider().associators(

Line 1047

Line 892

request->resultRole,

request->includeQualifiers,

request->includeClassOrigin,

request->propertyList.getPropertyNameArray(),

request->propertyList,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 1089

Line 914

PEGASUS_ASSERT(request != 0);

CIMAssociatorNamesResponseMessage * response =

new CIMAssociatorNamesResponseMessage(

dynamic_cast<CIMAssociatorNamesResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

Array<CIMObjectPath>());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod(request->getHttpMethod());

// create a handler for this request

AssociatorNamesResponseHandler handler(request, response);

// process the request

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleAssociationNamesRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleAssociationNamesRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

request->objectName.getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 1128

Line 945

request->nameSpace,

request->assocClass.getString());

ProviderName name(

assocPath,

ProviderType::ASSOCIATION);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

STAT_PMS_PROVIDERSTART;

pm_service_op_lock op_lock(&ph.GetProvider());

ph.GetProvider().associatorNames(

Line 1156

Line 971

request->role,

request->resultRole,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 1196

Line 991

PEGASUS_ASSERT(request != 0);

CIMReferencesResponseMessage * response =

new CIMReferencesResponseMessage(

dynamic_cast<CIMReferencesResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

Array<CIMObject>());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// create a handler for this request

ReferencesResponseHandler handler(request, response);

// process the request

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleReferencesRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleReferencesRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

request->objectName.getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 1235

Line 1022

request->nameSpace,

request->resultClass.getString());

ProviderName name(

resultPath,

ProviderType::ASSOCIATION);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.references: " +

Line 1268

Line 1052

request->role,

request->includeQualifiers,

request->includeClassOrigin,

request->propertyList.getPropertyNameArray(),

request->propertyList,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 1310

Line 1074

PEGASUS_ASSERT(request != 0);

CIMReferenceNamesResponseMessage * response =

new CIMReferenceNamesResponseMessage(

dynamic_cast<CIMReferenceNamesResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

PEGASUS_ASSERT(response != 0);

request->queueIds.copyAndPop(),

Array<CIMObjectPath>());

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// create a handler for this request

ReferenceNamesResponseHandler handler(request, response);

Line 1328

Line 1084

// process the request

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleReferenceNamesRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleReferenceNamesRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

request->objectName.getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 1347

Line 1105

request->nameSpace,

request->resultClass.getString());

ProviderName name(

resultPath,

ProviderType::ASSOCIATION);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.referenceNames: " +

Line 1379

Line 1134

request->resultClass,

request->role,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 1420

Line 1155

// create response message

CIMGetPropertyResponseMessage * response =

new CIMGetPropertyResponseMessage(

dynamic_cast<CIMGetPropertyResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

CIMValue());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod(request->getHttpMethod());

GetPropertyResponseHandler handler(request, response);

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleGetPropertyRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleGetPropertyRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

request->instanceName.getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 1451

Line 1178

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

ProviderName name(

objectPath,

0);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMName propertyName = request->propertyName;

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.getProperty: " +

Line 1485

Line 1209

objectPath,

propertyName,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 1525

Line 1229

PEGASUS_ASSERT(request != 0);

// create response message

//l10n

CIMSetPropertyResponseMessage * response =

new CIMSetPropertyResponseMessage(

dynamic_cast<CIMSetPropertyResponseMessage*>(

request->messageId,

request->buildResponse());

PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED, MessageLoaderParms(

"ProviderManager.DefaultProviderManager.NOT_IMPLEMENTED",

"not implemented")),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod(request->getHttpMethod());

SetPropertyResponseHandler handler(request, response);

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleSetPropertyRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleSetPropertyRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

request->instanceName.getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 1559

Line 1253

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

ProviderName name(

objectPath,

0);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMName propertyName = request->propertyName;

CIMValue propertyValue = request->newValue;

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.setProperty: " +

Line 1595

Line 1286

propertyName,

propertyValue,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

STAT_COPYDISPATCHER

return(response);

}

Line 1636

Line 1307

// create response message

CIMInvokeMethodResponseMessage * response =

new CIMInvokeMethodResponseMessage(

dynamic_cast<CIMInvokeMethodResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop(),

CIMValue(),

Array<CIMParamValue>(),

request->methodName);

PEGASUS_ASSERT(response != 0);

// propagate message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// create a handler for this request

InvokeMethodResponseHandler handler(request, response);

try

{

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleInvokeMethodRequest - Host name: $0 Name space: $1 Class name: $2",

Logger::TRACE,

"DefaultProviderManager::handleInvokeMethodRequest - "

"Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

request->instanceName.getClassName().getString()));

// make target object path

CIMObjectPath objectPath(

Line 1670

Line 1331

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

ProviderName name(

objectPath,

ProviderType::METHOD,

request->methodName);

// resolve provider name

name = _resolveProviderName(name);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMObjectPath instanceReference(request->instanceName);

Line 1695

Line 1352

instanceReference.setNameSpace(request->nameSpace);

// forward request

STAT_GETSTARTTIME;

STAT_PMS_PROVIDERSTART;

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.invokeMethod: " +

Line 1709

Line 1366

request->methodName,

request->inParameters,

handler);

STAT_PMS_PROVIDEREND;

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown error.");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

Line 1749

Line 1384

PEGASUS_ASSERT(request != 0);

CIMCreateSubscriptionResponseMessage * response =

new CIMCreateSubscriptionResponseMessage(

dynamic_cast<CIMCreateSubscriptionResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

OperationResponseHandler handler(request, response);

try

Line 1778

Line 1404

}

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleCreateSubscriptionRequest - Host name: $0 Name space: $1 Class name(s): $2",

Logger::TRACE,

"DefaultProviderManager::handleCreateSubscriptionRequest - "

"Host name: $0 Name space: $1 Class name(s): $2",

System::getHostName(),

request->nameSpace.getString(),

temp);

temp));

String physicalName=_resolvePhysicalName(

CIMInstance req_provider, req_providerModule;

request->providerModule.getProperty(

ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);

request->providerModule.findProperty("Location")).getValue().toString());

req_provider = pidc.getProvider();

req_providerModule = pidc.getModule();

String physicalName=_resolvePhysicalName( req_providerModule.getProperty(

req_providerModule.findProperty("Location")).getValue().toString());

ProviderName name(

ProviderName name(req_provider.getProperty(req_provider.findProperty("Name")).getValue ().toString (),

request->provider.getProperty(request->provider.findProperty

("Name")).getValue ().toString (),

physicalName,

request->providerModule.getProperty(request->providerModule.findProperty

req_providerModule.getProperty(req_providerModule.findProperty

("InterfaceType")).getValue().toString(),

0);

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// Save the provider instance from the request

ph.GetProvider ().setProviderInstance (req_provider);

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(SubscriptionInstanceContainer

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

(request->subscriptionInstance));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

context.insert(SubscriptionFilterConditionContainer

context.insert(request->operationContext.get(SubscriptionInstanceContainer::NAME));

(request->condition, request->queryLanguage));

context.insert(request->operationContext.get(SubscriptionLanguageListContainer::NAME));

context.insert(SubscriptionLanguageListContainer

context.insert(request->operationContext.get(SubscriptionFilterConditionContainer::NAME));

(request->acceptLanguages));

context.insert(request->operationContext.get(SubscriptionFilterQueryContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(ContentLanguageListContainer(request->contentLanguages));

CIMObjectPath subscriptionName = request->subscriptionInstance.getPath();

Line 1843

Line 1476

classNames,

propertyList,

repeatNotificationPolicy);

// Increment count of current subscriptions for this provider

if (ph.GetProvider ().testIfZeroAndIncrementSubscriptions ())

{

// If there were no current subscriptions before the increment,

// the first subscription has been created

// Call the provider's enableIndications method

if (_subscriptionInitComplete)

{

_callEnableIndications (req_provider,

_indicationCallback, ph);

}

catch(CIMException & e)

{

Line 1881

Line 1531

PEGASUS_ASSERT(request != 0);

CIMModifySubscriptionResponseMessage * response =

new CIMModifySubscriptionResponseMessage(

dynamic_cast<CIMModifySubscriptionResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

OperationResponseHandler handler(request, response);

try

Line 1910

Line 1551

}

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleCreateSubscriptionRequest - Host name: $0 Name space: $1 Class name(s): $2",

Logger::TRACE,

"DefaultProviderManager::handleCreateSubscriptionRequest - "

"Host name: $0 Name space: $1 Class name(s): $2",

System::getHostName(),

request->nameSpace.getString(),

temp);

temp));

String physicalName=_resolvePhysicalName(

CIMInstance req_provider, req_providerModule;

request->providerModule.getProperty(

ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);

request->providerModule.findProperty("Location")).getValue().toString());

req_provider = pidc.getProvider();

req_providerModule = pidc.getModule();

String physicalName=_resolvePhysicalName( req_providerModule.getProperty(

req_providerModule.findProperty("Location")).getValue().toString());

ProviderName name(

ProviderName name(req_provider.getProperty(req_provider.findProperty("Name")).getValue ().toString (),

request->provider.getProperty(request->provider.findProperty

("Name")).getValue ().toString (),

physicalName,

request->providerModule.getProperty(request->providerModule.findProperty

req_providerModule.getProperty(req_providerModule.findProperty

("InterfaceType")).getValue().toString(),

0);

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(SubscriptionInstanceContainer

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

(request->subscriptionInstance));

context.insert(request->operationContext.get(SubscriptionInstanceContainer::NAME));

context.insert(SubscriptionFilterConditionContainer

context.insert(request->operationContext.get(SubscriptionLanguageListContainer::NAME));

(request->condition, request->queryLanguage));

context.insert(request->operationContext.get(SubscriptionFilterConditionContainer::NAME));

context.insert(SubscriptionLanguageListContainer

context.insert(request->operationContext.get(SubscriptionFilterQueryContainer::NAME));

(request->acceptLanguages));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(ContentLanguageListContainer(request->contentLanguages));

CIMObjectPath subscriptionName = request->subscriptionInstance.getPath();

Line 2013

Line 1655

PEGASUS_ASSERT(request != 0);

CIMDeleteSubscriptionResponseMessage * response =

new CIMDeleteSubscriptionResponseMessage(

dynamic_cast<CIMDeleteSubscriptionResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod(request->getHttpMethod());

OperationResponseHandler handler(request, response);

try

Line 2042

Line 1675

}

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

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,

"DefaultProviderManager::handleDeleteSubscriptionRequest - Host name: $0 Name space: $1 Class name(s): $2",

Logger::TRACE,

"DefaultProviderManager::handleDeleteSubscriptionRequest - "

"Host name: $0 Name space: $1 Class name(s): $2",

System::getHostName(),

request->nameSpace.getString(),

temp);

temp));

String physicalName=_resolvePhysicalName(

CIMInstance req_provider, req_providerModule;

request->providerModule.getProperty(

ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);

request->providerModule.findProperty("Location")).getValue().toString());

req_provider = pidc.getProvider();

req_providerModule = pidc.getModule();

String physicalName=_resolvePhysicalName( req_providerModule.getProperty(

req_providerModule.findProperty("Location")).getValue().toString());

ProviderName name(

ProviderName name(req_provider.getProperty(req_provider.findProperty("Name")).getValue ().toString (),

request->provider.getProperty(request->provider.findProperty

("Name")).getValue ().toString (),

physicalName,

request->providerModule.getProperty(request->providerModule.findProperty

req_providerModule.getProperty(req_providerModule.findProperty

("InterfaceType")).getValue().toString(),

0);

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(SubscriptionInstanceContainer

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

(request->subscriptionInstance));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

context.insert(SubscriptionLanguageListContainer

context.insert(request->operationContext.get(SubscriptionInstanceContainer::NAME));

(request->acceptLanguages));

context.insert(request->operationContext.get(SubscriptionLanguageListContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(ContentLanguageListContainer(request->contentLanguages));

CIMObjectPath subscriptionName = request->subscriptionInstance.getPath();

Line 2099

Line 1735

context,

subscriptionName,

classNames);

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

// Decrement count of current subscriptions for this provider

catch(Exception & e)

if (ph.GetProvider ().decrementSubscriptionsAndTestIfZero ())

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

// If there are no current subscriptions after the decrement,

// the last subscription has been deleted

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

// Call the provider's disableIndications method

}

catch(...)

if (_subscriptionInitComplete)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown Error");

}

PEG_METHOD_EXIT();

return(response);

}

Message * DefaultProviderManager::handleEnableIndicationsRequest(const Message * message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager:: handleEnableIndicationsRequest");

CIMEnableIndicationsRequestMessage * request =

dynamic_cast<CIMEnableIndicationsRequestMessage *>(const_cast<Message *>(message));

PEGASUS_ASSERT(request != 0);

CIMEnableIndicationsResponseMessage * response =

new CIMEnableIndicationsResponseMessage(

request->messageId,

CIMException(),

request->queueIds.copyAndPop());

CIMEnableIndicationsResponseMessage * responseforhandler =

new CIMEnableIndicationsResponseMessage(

request->messageId,

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod(request->getHttpMethod());

response->dest = request->queueIds.top();

// ATTN: need pointer to Provider Manager Server!

EnableIndicationsResponseHandler *handler =

new EnableIndicationsResponseHandler(request, response,

request->provider, ProviderManagerService::providerManagerService);

try

{

String physicalName=_resolvePhysicalName(

request->providerModule.getProperty(

request->providerModule.findProperty("Location")).getValue().toString());

ProviderName name(

request->provider.getProperty(request->provider.findProperty

("Name")).getValue ().toString (),

physicalName,

request->providerModule.getProperty(request->providerModule.findProperty

("InterfaceType")).getValue().toString(),

0);

// get cached or load new provider module

OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.enableIndications: " +

ph.GetProvider().getName());

pm_service_op_lock op_lock(&ph.GetProvider());

ph.GetProvider().enableIndications(*handler);

// if no exception, store the handler so it is persistent for as

// long as the provider has indications enabled.

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Storing indication handler for " + ph.GetProvider().getName());

_insertEntry(ph.GetProvider(), handler);

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

response->cimException = CIMException(e);

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(

"ProviderManager.DefaultProviderManager.INTERNAL_ERROR",

"Internal Error"));

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(

"ProviderManager.DefaultProviderManager.UNKNOWN_ERROR",

"Unknown Error"));

}

PEG_METHOD_EXIT();

return(response);

}

Message * DefaultProviderManager::handleDisableIndicationsRequest(const Message * message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDisableIndicationsRequest");

CIMDisableIndicationsRequestMessage * request =

dynamic_cast<CIMDisableIndicationsRequestMessage *>(const_cast<Message *>(message));

PEGASUS_ASSERT(request != 0);

CIMDisableIndicationsResponseMessage * response =

new CIMDisableIndicationsResponseMessage(

request->messageId,

CIMException(),

request->queueIds.copyAndPop());

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

OperationResponseHandler handler(request, response);

try

{

String physicalName=_resolvePhysicalName(

request->providerModule.getProperty(

request->providerModule.findProperty("Location")).getValue().toString());

ProviderName name(

request->provider.getProperty(request->provider.findProperty

("Name")).getValue ().toString (),

physicalName,

request->providerModule.getProperty(request->providerModule.findProperty

("InterfaceType")).getValue().toString(),

0);

// get cached or load new provider module

OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.disableIndications: " +

ph.GetProvider().getName());

Line 2275

Line 1756

ph.GetProvider().unprotect();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Removing and Destroying indication handler for " +

ph.GetProvider().getName());

delete _removeEntry(_generateKey(ph.GetProvider()));

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

response->cimException = CIMException(e);

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(

"ProviderManager.DefaultProviderManager.INTERNAL_ERROR",

"Internal Error"));

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(

"ProviderManager.DefaultProviderManager.UNKNOWN_ERROR",

"Unknown Error"));

}

PEG_METHOD_EXIT();

return(response);

}

Message * DefaultProviderManager::handleConsumeIndicationRequest(const Message *message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handlConsumeIndicationRequest");

CIMConsumeIndicationRequestMessage *request =

dynamic_cast<CIMConsumeIndicationRequestMessage *>(const_cast<Message *>(message));

PEGASUS_ASSERT(request != 0);

CIMResponseMessage * response =

new CIMResponseMessage(

CIM_CONSUME_INDICATION_RESPONSE_MESSAGE,

request->messageId,

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

Uint32 type = 3;

try

{

ProviderName name(

String::EMPTY,

0);

ProviderName name(

String::EMPTY,

objectPath.toString());

// resolve provider name

name = _resolveProviderName(name);

// get cached or load new provider module

OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.: " +

ph.GetProvider().getName());

OperationContext context;

//l10n

// ATTN-CEC 06/04/03 NOTE: I can't find where the consume msg is sent. This

// does not appear to be hooked-up. When it is added, need to

// make sure that Content-Language is set in the consume msg.

// NOTE: A-L is not needed to be set in the consume msg.

// add the langs to the context

context.insert(ContentLanguageListContainer(request->contentLanguages));

CIMInstance indication_copy = request->indicationInstance;

SimpleIndicationResponseHandler handler;

ph.GetProvider().consumeIndication(context,

"",

indication_copy);

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

response->cimException = CIMException(e);

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

//l10n

//response->cimException = CIMException(CIM_ERR_FAILED, "Internal Error");

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(

"ProviderManager.DefaultProviderManager.INTERNAL_ERROR",

"Internal Error"));

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

//l10n

//response->cimException = CIMException(CIM_ERR_FAILED, "Unknown Error");

handler.setStatus(CIM_ERR_FAILED, "Unknown Error");

response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(

"ProviderManager.DefaultProviderManager.UNKNOWN_ERROR",

"Unknown Error"));

}

PEG_METHOD_EXIT();

Line 2413

Line 1794

return(response);

}

Message *DefaultProviderManager::handleExportIndicationRequest(const Message *message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManagerService::handlExportIndicationRequest");

Line 2424

Line 1804

PEGASUS_ASSERT(request != 0);

CIMExportIndicationResponseMessage * response =

new CIMExportIndicationResponseMessage(

dynamic_cast<CIMExportIndicationResponseMessage*>(

request->messageId,

request->buildResponse());

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

OperationResponseHandler handler(request, response);

try

{

ProviderName name(

String::EMPTY,

0);

// resolve provider name

name = _resolveProviderName(request->destinationPath);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

OpProviderHolder ph =

OpProviderHolder ph = providerManager.getProvider(

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

name.getPhysicalName(), name.getLogicalName());

STAT_PMS_PROVIDERSTART

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.: " +

Line 2460

Line 1828

OperationContext context;

context.insert(request->operationContext.get(IdentityContainer::NAME));

//L10N_TODO

//l10n

// ATTN-CEC 06/04/03 NOTE: I can't find where the consume msg is sent. This

Line 2467

Line 1837

// make sure that Content-Language is set in the consume msg.

// NOTE: A-L is not needed to be set in the consume msg.

// add the langs to the context

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMInstance indication_copy = request->indicationInstance;

pm_service_op_lock op_lock(&ph.GetProvider());

Line 2475

Line 1846

ph.GetProvider().consumeIndication(context,

request->destinationPath,

indication_copy);

}

catch(CIMException & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n

}

catch(Exception & e)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: " + e.getMessage());

handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n

}

catch(...)

{

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Exception: Unknown");

handler.setStatus(CIM_ERR_FAILED, "Unknown Error");

}

HandleCatch(handler);

PEG_METHOD_EXIT();

Line 2527

Line 1876

PEGASUS_ASSERT(request != 0);

Array<Uint16> operationalStatus;

Boolean disableProviderOnly = request->disableProviderOnly;

CIMException cimException;

ProviderRegistrationManager * _providerRegistrationManager = GetProviderRegistrationManager();

try

{

// get provider module name

String moduleName;

CIMInstance mInstance = request->providerModule;

Uint32 pos = mInstance.findProperty(CIMName ("Name"));

PEGASUS_ASSERT(pos != PEG_NOT_FOUND);

if(pos != PEG_NOT_FOUND)

{

mInstance.getProperty(pos).getValue().get(moduleName);

}

Boolean disableProviderOnly = request->disableProviderOnly;

// get operational status

if (!disableProviderOnly)

{

Uint32 pos2 = mInstance.findProperty(CIMName ("OperationalStatus"));

if (pos2 != PEG_NOT_FOUND)

{

// ATTN-CAKG-P2-20020821: Check for null status?

mInstance.getProperty(pos2).getValue().get(operationalStatus);

}

// update module status from OK to Stopping

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

{

if (operationalStatus[i] == _MODULE_OK)

{

operationalStatus.remove(i);

}

operationalStatus.append(_MODULE_STOPPING);

if(_providerRegistrationManager->setProviderModuleStatus

(moduleName, operationalStatus) == false)

{

//l10n

//throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED, "set module status failed.");

throw PEGASUS_CIM_EXCEPTION_L(

CIM_ERR_FAILED,

MessageLoaderParms(

"ProviderManager.ProviderManagerService."

"SET_MODULE_STATUS_FAILED",

"set module status failed."));

}

// Unload providers

Array<CIMInstance> _pInstances = request->providers;

Array<Boolean> _indicationProviders = request->indicationProviders;

Line 2600

Line 1904

String pName(_pInstances[i].getProperty(

_pInstances[i].findProperty("Name")).getValue().toString());

Sint16 ret_value = providerManager.disableProvider(physicalName,pName);

Sint16 ret_value = providerManager.disableProvider(pName);

if (ret_value == 0)

{

// disable failed since there are pending requests,

// update module status from Stopping to OK if

// stop trying to disable other providers in this module.

// disableProviderOnly is not true

operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK);

if (!disableProviderOnly)

break;

}

else if (ret_value == 1) // Success

{

for(Uint32 j=0, m = operationalStatus.size(); j < m; j++)

if (_indicationProviders[i])

{

if (operationalStatus[j] == _MODULE_STOPPING)

// Reset the indication provider's count of current

// subscriptions since it has been disabled

if (physicalName.size () > 0)

{

operationalStatus.remove(j);

OpProviderHolder ph = providerManager.getProvider(

}

physicalName, pName);

}

operationalStatus.append(_MODULE_OK);

if(_providerRegistrationManager->setProviderModuleStatus

ph.GetProvider ().resetSubscriptions ();

(moduleName, operationalStatus) == false)

{

throw PEGASUS_CIM_EXCEPTION_L(

CIM_ERR_FAILED,

MessageLoaderParms(

"ProviderManager.ProviderManagerService."

"SET_MODULE_STATUS_FAILED",

"set module status failed."));

}

else if (ret_value == 1)

{

// If it is an indication provider

// if It is an indication provider

// remove the entry from the table since the

// provider has been disabled

if (_indicationProviders[i])

{

delete _removeEntry(_generateKey(pName,physicalName));

_removeEntry(_generateKey(pName,physicalName));

}

else

{

// disable failed for other reason, throw exception

// update module status from Stopping to OK if

// disableProviderOnly is not true

if (!disableProviderOnly)

{

for(Uint32 j=0, m = operationalStatus.size(); j < m; j++)

{

if (operationalStatus[j] == _MODULE_STOPPING)

{

operationalStatus.remove(j);

}

operationalStatus.append(_MODULE_OK);

if(_providerRegistrationManager->setProviderModuleStatus

(moduleName, operationalStatus) == false)

{

throw PEGASUS_CIM_EXCEPTION_L(

CIM_ERR_FAILED,

MessageLoaderParms(

"ProviderManager.ProviderManagerService."

"SET_MODULE_STATUS_FAILED",

"set module status failed."));

}

throw PEGASUS_CIM_EXCEPTION_L(

CIM_ERR_FAILED,

MessageLoaderParms(

Line 2678

Line 1948

"Failed to disable the provider."));

}

// disable succeed

// update module status from Stopping to Stopped if

// disableProviderOnly is not true

if (!disableProviderOnly)

{

// update module status from Stopping to Stopped

for(Uint32 j=0, m = operationalStatus.size(); j < m; j++)

{

if (operationalStatus[j] == _MODULE_STOPPING)

{

operationalStatus.remove(j);

operationalStatus.append(_MODULE_STOPPED);

}

if(_providerRegistrationManager->setProviderModuleStatus

(moduleName, operationalStatus) == false)

{

//l10n

//throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED,

//"set module status failed.");

throw PEGASUS_CIM_EXCEPTION_L(

CIM_ERR_FAILED,

MessageLoaderParms(

"ProviderManager.ProviderManagerService."

"SET_MODULE_STATUS_FAILED",

"set module status failed."));

}

catch(CIMException & e)

{

Line 2733

Line 1974

"Unknown Error"));

}

CIMDisableModuleResponseMessage * response =

if (cimException.getCode() == CIM_ERR_SUCCESS)

new CIMDisableModuleResponseMessage(

{

request->messageId,

// Status is set to OK if a provider was busy

CIMException(),

if (operationalStatus.size() == 0)

request->queueIds.copyAndPop(),

{

operationalStatus);

operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_STOPPED);

}

else

{

// If exception occurs, module is not stopped

operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK);

}

// preserve message key

CIMDisableModuleResponseMessage* response =

response->setKey(request->getKey());

dynamic_cast<CIMDisableModuleResponseMessage*>(

request->buildResponse());

PEGASUS_ASSERT(response != 0);

// Set HTTP method in response from request

response->operationalStatus = operationalStatus;

response->setHttpMethod (request->getHttpMethod ());

PEG_METHOD_EXIT();

Line 2753

Line 2002

Message * DefaultProviderManager::handleEnableModuleRequest(const Message * message)

{

// HACK

ProviderRegistrationManager * _providerRegistrationManager = GetProviderRegistrationManager();

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleEnableModuleRequest");

CIMEnableModuleRequestMessage * request =

Line 2763

Line 2009

PEGASUS_ASSERT(request != 0);

// get module status

CIMInstance mInstance = request->providerModule;

Array<Uint16> operationalStatus;

Uint32 pos = mInstance.findProperty(CIMName ("OperationalStatus"));

operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK);

if(pos != PEG_NOT_FOUND)

CIMEnableModuleResponseMessage* response =

{

dynamic_cast<CIMEnableModuleResponseMessage*>(

request->buildResponse());

// ATTN-CAKG-P2-20020821: Check for null status?

PEGASUS_ASSERT(response != 0);

mInstance.getProperty(pos).getValue().get(operationalStatus);

response->operationalStatus = operationalStatus;

PEG_METHOD_EXIT();

return(response);

}

// update module status from Stopped to OK

Message * DefaultProviderManager::handleStopAllProvidersRequest(const Message * message)

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

{

if(operationalStatus[i] == _MODULE_STOPPED)

{

operationalStatus.remove(i);

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleStopAllProvidersRequest");

}

operationalStatus.append(_MODULE_OK);

CIMStopAllProvidersRequestMessage * request =

dynamic_cast<CIMStopAllProvidersRequestMessage *>(const_cast<Message *>(message));

PEGASUS_ASSERT(request != 0);

// get module name

String moduleName;

Uint32 pos2 = mInstance.findProperty(CIMName ("Name"));

CIMStopAllProvidersResponseMessage* response =

dynamic_cast<CIMStopAllProvidersResponseMessage*>(

request->buildResponse());

PEGASUS_ASSERT(response != 0);

if(pos2 != PEG_NOT_FOUND)

// tell the provider manager to shutdown all the providers

providerManager.shutdownAllProviders();

try

{

mInstance.getProperty(pos2).getValue().get(moduleName);

// Delete the response handlers that were not explicitly disabled.

}

AutoMutex lock(_responseTableMutex);

if(_providerRegistrationManager->setProviderModuleStatus

for (IndicationResponseTable::Iterator i = _responseTable.start();

(moduleName, operationalStatus) == false)

i != 0; i++)

{

//l10n

EnableIndicationsResponseHandler *handler = i.value();

//throw PEGASUS_CIM_EXCEPTION(CIM_ERR_FAILED, "set module status failed.");

delete handler;

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_FAILED, MessageLoaderParms(

"ProviderManager.DefaultProviderManager.SET_MODULE_STATUS_FAILED",

"set module status failed."));

}

CIMEnableModuleResponseMessage * response =

_responseTable.clear();

new CIMEnableModuleResponseMessage(

}

request->messageId,

catch (...) { }

CIMException(),

request->queueIds.copyAndPop(),

operationalStatus);

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

PEG_METHOD_EXIT();

return(response);

}

Message * DefaultProviderManager::handleStopAllProvidersRequest(const Message * message)

Message *

DefaultProviderManager::handleSubscriptionInitCompleteRequest

(const Message * message)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleStopAllProvidersRequest");

PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,

"DefaultProviderManager::handleSubscriptionInitCompleteRequest");

CIMStopAllProvidersRequestMessage * request =

CIMSubscriptionInitCompleteRequestMessage * request =

dynamic_cast<CIMStopAllProvidersRequestMessage *>(const_cast<Message *>(message));

dynamic_cast <CIMSubscriptionInitCompleteRequestMessage *>

(const_cast <Message *> (message));

PEGASUS_ASSERT(request != 0);

CIMStopAllProvidersResponseMessage * response =

CIMSubscriptionInitCompleteResponseMessage * response =

new CIMStopAllProvidersResponseMessage(

dynamic_cast <CIMSubscriptionInitCompleteResponseMessage *>

request->messageId,

(request->buildResponse ());

CIMException(),

request->queueIds.copyAndPop());

PEGASUS_ASSERT(response != 0);

// preserve message key

response->setKey(request->getKey());

// Set indicator

_subscriptionInitComplete = true;

// Set HTTP method in response from request

response->setHttpMethod (request->getHttpMethod ());

// For each provider that has at least one subscription, call

// provider's enableIndications method

Array <Provider *> enableProviders;

enableProviders = providerManager.getIndicationProvidersToEnable ();

// tell the provider manager to shutdown all the providers

Uint32 numProviders = enableProviders.size ();

providerManager.shutdownAllProviders();

for (Uint32 i = 0; i < numProviders; i++)

{

try

{

CIMInstance provider;

provider = enableProviders [i]->getProviderInstance ();

PEG_METHOD_EXIT();

// Get cached or load new provider module

OpProviderHolder ph = providerManager.getProvider(

enableProviders[i]->getModule()->getFileName(),

enableProviders[i]->getName());

_callEnableIndications (provider, _indicationCallback, ph);

}

catch (CIMException & e)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"CIMException: " + e.getMessage ());

}

catch (Exception & e)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"Exception: " + e.getMessage ());

}

catch(...)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"Unknown error in handleSubscriptionInitCompleteRequest");

}

PEG_METHOD_EXIT ();

return(response);

}

void DefaultProviderManager::_insertEntry (

const Provider & provider,

const EnableIndicationsResponseHandler *handler)

EnableIndicationsResponseHandler* handler)

{

PEG_METHOD_ENTER (TRC_INDICATION_SERVICE,

PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,

"DefaultProviderManager::_insertEntry");

String tableKey = _generateKey

String tableKey = _generateKey(provider);

(provider);

_responseTable.insert (tableKey, const_cast<EnableIndicationsResponseHandler *>(handler));

AutoMutex lock(_responseTableMutex);

_responseTable.insert(tableKey, handler);

PEG_METHOD_EXIT();

}

Line 2880

Line 2148

EnableIndicationsResponseHandler * DefaultProviderManager::_removeEntry(

const String & key)

{

PEG_METHOD_ENTER (TRC_INDICATION_SERVICE,

PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,

"DefaultProviderManager::_removeEntry");

EnableIndicationsResponseHandler *ret = 0;

AutoMutex lock(_responseTableMutex);

_responseTable.lookup(key, ret);

_responseTable.remove(key); // why is this needed ? - we get killed when removed...

_responseTable.remove(key);

PEG_METHOD_EXIT();

Line 2897

Line 2166

{

String tableKey;

PEG_METHOD_ENTER (TRC_INDICATION_SERVICE,

PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,

"DefaultProviderManager::_generateKey");

Line 2919

Line 2188

{

String tableKey;

PEG_METHOD_ENTER (TRC_INDICATION_SERVICE,

PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,

"DefaultProviderManagerService::_generateKey");

Line 2932

Line 2201

return tableKey;

}

ProviderName DefaultProviderManager::_resolveProviderName(const ProviderName & providerName)

ProviderName DefaultProviderManager::_resolveProviderName(

const ProviderIdContainer & providerId)

{

ProviderName temp = findProvider(providerName);

String providerName;

String physicalName = _resolvePhysicalName(temp.getPhysicalName());

String fileName;

temp.setPhysicalName(physicalName);

String interfaceName;

CIMValue genericValue;

genericValue = providerId.getProvider().getProperty(

providerId.getProvider().findProperty("Name")).getValue();

genericValue.get(providerName);

genericValue = providerId.getModule().getProperty(

providerId.getModule().findProperty("Location")).getValue();

genericValue.get(fileName);

fileName = _resolvePhysicalName(fileName);

// ATTN: This attribute is probably not required

genericValue = providerId.getModule().getProperty(

providerId.getModule().findProperty("InterfaceType")).getValue();

genericValue.get(interfaceName);

return(temp);

return ProviderName(providerName, fileName, interfaceName, 0);

}

ProviderName DefaultProviderManager::_resolveProviderName(String & destinationPath)

Boolean DefaultProviderManager::hasActiveProviders()

{

ProviderName temp = findProvider(destinationPath);

return providerManager.hasActiveProviders();

}

void DefaultProviderManager::unloadIdleProviders()

{

providerManager.unloadIdleProviders();

}

void DefaultProviderManager::_callEnableIndications

(CIMInstance & req_provider,

PEGASUS_INDICATION_CALLBACK _indicationCallback,

OpProviderHolder & ph)

{

PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,

"DefaultProviderManager::_callEnableIndications");

String physicalName = _resolvePhysicalName(temp.getPhysicalName());

try

{

CIMRequestMessage * request = 0;

CIMResponseMessage * response = 0;

EnableIndicationsResponseHandler * enableHandler =

new EnableIndicationsResponseHandler

(request, response, req_provider, _indicationCallback);

temp.setPhysicalName(physicalName);

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.enableIndications: " +

ph.GetProvider ().getName ());

return(temp);

pm_service_op_lock op_lock (& ph.GetProvider ());

ph.GetProvider ().protect ();

ph.GetProvider ().enableIndications (* enableHandler);

// Store the handler so it is persistent for as

// long as the provider has indications enabled

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Storing indication handler for " +

ph.GetProvider ().getName ());

_insertEntry (ph.GetProvider (), enableHandler);

}

catch (CIMException & e)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"CIMException: " + e.getMessage ());

Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,

"ProviderManager.Default.DefaultProviderManager."

"ENABLE_INDICATIONS_FAILED",

"Failed to enable indications for provider $0: $1.",

ph.GetProvider ().getName (), e.getMessage ());

}

catch (Exception & e)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"Exception: " + e.getMessage ());

Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,

"ProviderManager.Default.DefaultProviderManager."

"ENABLE_INDICATIONS_FAILED",

"Failed to enable indications for provider $0: $1.",

ph.GetProvider ().getName (), e.getMessage ());

}

catch(...)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"Unexpected error in _callEnableIndications");

Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,

"ProviderManager.Default.DefaultProviderManager."

"ENABLE_INDICATIONS_FAILED_UNKNOWN",

"Failed to enable indications for provider $0.",

ph.GetProvider ().getName ());

}

PEG_METHOD_EXIT ();

}

PEGASUS_NAMESPACE_END

Legend:

Removed from v.1.11.4.3
changed lines
	Added in v.1.56.2.1

No CVS admin address has been configured