Return to
CMPIProviderManager.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / CMPI
|
Return to
CMPIProviderManager.cpp
CVS log
|
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / CMPI
|
|
File: [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / CMPI / CMPIProviderManager.cpp
(download)
Revision: 1.117, Fri Sep 7 17:34:11 2007 UTC (16 years, 9 months ago) by dave.sudlik Branch: MAIN CVS Tags: TASK-PEP305_VXWORKS-root Branch point for: TASK-PEP305_VXWORKS-branch Changes since 1.116: +9 -6 lines BUG#: 6867 TITLE: Adding Globalization messages in CMPI directory DESCRIPTION: committing approved fix |
//%2006////////////////////////////////////////////////////////////////////////
//
// Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
// Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;
// IBM Corp.; EMC Corporation, The Open Group.
// Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
// Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
// EMC Corporation; VERITAS Software Corporation; The Open Group.
// Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
// 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
// deal in the Software without restriction, including without limitation the
// rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
// sell copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
// ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
// "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
// LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
// PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
// HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
// 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.
//
//==============================================================================
//
//%/////////////////////////////////////////////////////////////////////////////
#include "CMPI_Version.h"
#include "CMPIProviderManager.h"
#include "CMPI_Object.h"
#include "CMPI_ContextArgs.h"
#include "CMPI_Instance.h"
#include "CMPI_ObjectPath.h"
#include "CMPI_Result.h"
#include "CMPI_SelectExp.h"
#include <Pegasus/Common/CIMMessage.h>
#include <Pegasus/Common/OperationContext.h>
#include <Pegasus/Common/OperationContextInternal.h>
#include <Pegasus/Common/Tracer.h>
#include <Pegasus/Common/StatisticalData.h>
#include <Pegasus/Common/Logger.h>
#include <Pegasus/Common/LanguageParser.h>
#include <Pegasus/Common/MessageLoader.h> //l10n
#include <Pegasus/Common/Constants.h>
#include <Pegasus/Common/FileSystem.h>
#include <Pegasus/Config/ConfigManager.h>
#include <Pegasus/Provider/CIMOMHandleQueryContext.h>
#include <Pegasus/ProviderManager2/CIMOMHandleContext.h>
#include <Pegasus/ProviderManager2/ProviderName.h>
#include <Pegasus/ProviderManager2/AutoPThreadSecurity.h>
#include <Pegasus/ProviderManager2/CMPI/CMPIProviderModule.h>
#include <Pegasus/ProviderManager2/CMPI/CMPIProvider.h>
PEGASUS_USING_STD;
PEGASUS_NAMESPACE_BEGIN
ReadWriteSem CMPIProviderManager::rwSemProvTab;
ReadWriteSem CMPIProviderManager::rwSemSelxTab;
CMPIProviderManager::IndProvTab CMPIProviderManager::provTab;
CMPIProviderManager::IndSelectTab CMPIProviderManager::selxTab;
class CMPIPropertyList
{
char **props;
int pCount;
public:
CMPIPropertyList(CIMPropertyList &propertyList) : props(0), pCount(0)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIPropertyList::CMPIPropertyList()");
if (!propertyList.isNull())
{
Array<CIMName> p=propertyList.getPropertyNameArray();
pCount=p.size();
props = new char*[1+pCount];
for (int i=0; i<pCount; i++)
{
props[i]=strdup(p[i].getString().getCString());
}
props[pCount]=NULL;
}
else props=NULL;
PEG_METHOD_EXIT();
}
~CMPIPropertyList()
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIPropertyList::~CMPIPropertyList()");
if (props)
{
for (int i=0; i<pCount; i++)
free(props[i]);
delete [] props;
}
PEG_METHOD_EXIT();
}
char **getList()
{
return props;
}
};
CMPIProviderManager::CMPIProviderManager(Mode m)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::CMPIProviderManager()");
mode=m;
_subscriptionInitComplete = false;
PEG_TRACE_CSTRING (
TRC_PROVIDERMANAGER,
Tracer::LEVEL2,
"-- CMPI Provider Manager activated");
PEG_METHOD_EXIT();
}
CMPIProviderManager::~CMPIProviderManager()
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::~CMPIProviderManager()");
/* Clean up the hash-tables */
indProvRecord *prec=NULL;
{
WriteLock writeLock(rwSemProvTab);
for (IndProvTab::Iterator i = provTab.start(); i; i++)
{
provTab.lookup(i.key(),prec);
if (prec->handler)
delete prec->handler;
delete prec;
//Remove is not neccessary, since the hashtable destructor takes
//care of this already. But instead removing entries while
//iterating the hashtable sometimes causes a segmentation fault!!!
//provTab.remove(i.key());
prec=NULL;
}
}
indSelectRecord *selx=NULL;
{
WriteLock writeLock(rwSemSelxTab);
for (IndSelectTab::Iterator i = selxTab.start(); i; i++)
{
selxTab.lookup(i.key(), selx);
if (selx->eSelx)
delete selx->eSelx;
if (selx->qContext)
delete selx->qContext;
delete selx;
//Same as above!
//selxTab.remove(i.key());
selx=NULL;
}
}
PEG_METHOD_EXIT();
}
Message * CMPIProviderManager::processMessage(Message * request)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::processMessage()");
Message * response = 0;
// pass the request message to a handler method based on message type
switch (request->getType())
{
case CIM_GET_INSTANCE_REQUEST_MESSAGE:
response = handleGetInstanceRequest(request);
break;
case CIM_ENUMERATE_INSTANCES_REQUEST_MESSAGE:
response = handleEnumerateInstancesRequest(request);
break;
case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE:
response = handleEnumerateInstanceNamesRequest(request);
break;
case CIM_CREATE_INSTANCE_REQUEST_MESSAGE:
response = handleCreateInstanceRequest(request);
break;
case CIM_MODIFY_INSTANCE_REQUEST_MESSAGE:
response = handleModifyInstanceRequest(request);
break;
case CIM_DELETE_INSTANCE_REQUEST_MESSAGE:
response = handleDeleteInstanceRequest(request);
break;
case CIM_EXEC_QUERY_REQUEST_MESSAGE:
response = handleExecQueryRequest(request);
break;
case CIM_ASSOCIATORS_REQUEST_MESSAGE:
response = handleAssociatorsRequest(request);
break;
case CIM_ASSOCIATOR_NAMES_REQUEST_MESSAGE:
response = handleAssociatorNamesRequest(request);
break;
case CIM_REFERENCES_REQUEST_MESSAGE:
response = handleReferencesRequest(request);
break;
case CIM_REFERENCE_NAMES_REQUEST_MESSAGE:
response = handleReferenceNamesRequest(request);
break;
case CIM_INVOKE_METHOD_REQUEST_MESSAGE:
response = handleInvokeMethodRequest(request);
break;
case CIM_CREATE_SUBSCRIPTION_REQUEST_MESSAGE:
response = handleCreateSubscriptionRequest(request);
break;
/* case CIM_MODIFY_SUBSCRIPTION_REQUEST_MESSAGE:
response = handleModifySubscriptionRequest(request);
break;
*/
case CIM_DELETE_SUBSCRIPTION_REQUEST_MESSAGE:
response = handleDeleteSubscriptionRequest(request);
break;
/* case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:
response = handleExportIndicationRequest(request);
break;
*/
case CIM_DISABLE_MODULE_REQUEST_MESSAGE:
response = handleDisableModuleRequest(request);
break;
case CIM_ENABLE_MODULE_REQUEST_MESSAGE:
response = handleEnableModuleRequest(request);
break;
case CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE:
response = handleStopAllProvidersRequest(request);
break;
// Note: The PG_Provider AutoStart property is not yet supported
#if 0
case CIM_INITIALIZE_PROVIDER_REQUEST_MESSAGE:
response = handleInitializeProviderRequest(request);
break;
#endif
case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE:
response = handleSubscriptionInitCompleteRequest (request);
break;
case CIM_GET_PROPERTY_REQUEST_MESSAGE:
response = handleGetPropertyRequest(request);
break;
case CIM_SET_PROPERTY_REQUEST_MESSAGE:
response = handleSetPropertyRequest(request);
break;
default:
response = handleUnsupportedRequest(request);
break;
}
PEG_METHOD_EXIT();
return(response);
}
Boolean CMPIProviderManager::hasActiveProviders()
{
return providerManager.hasActiveProviders();
}
void CMPIProviderManager::unloadIdleProviders()
{
providerManager.unloadIdleProviders();
}
#define CHARS(cstring) (char*)(strlen(cstring)?(const char*)cstring:NULL)
#define HandlerIntroBase(type,type1,message,request,response,handler) \
CIM##type##RequestMessage * request = \
dynamic_cast<CIM##type##RequestMessage *>(const_cast<Message *> \
(message)); \
PEGASUS_ASSERT(request != 0); \
CIM##type##ResponseMessage * response = \
dynamic_cast<CIM##type##ResponseMessage*>(request->buildResponse()); \
PEGASUS_ASSERT(response != 0); \
type1##ResponseHandler handler(request, response, _responseChunkCallback);
#define HandlerIntroInd(type,message,request,response,handler) \
HandlerIntroBase(type,Operation,message,request,response,handler)
#define HandlerIntroInit(type,message,request,response,handler) \
HandlerIntroBase(type,Operation,message,request,response,handler)
#define HandlerIntro(type,message,request,response,handler) \
HandlerIntroBase(type,type,message,request,response,handler)
#define HandlerCatch(handler) \
catch(const CIMException & e) \
{ PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \
"Exception: " + e.getMessage()); \
handler.setCIMException(e); \
} \
catch(const Exception & e) \
{ PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \
"Exception: " + e.getMessage()); \
handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), \
e.getMessage()); \
} \
catch(...) \
{ PEG_TRACE_CSTRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \
"Exception: Unknown"); \
handler.setStatus(CIM_ERR_FAILED, "Unknown error."); \
}
Message * CMPIProviderManager::handleGetInstanceRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleGetInstanceRequest()");
HandlerIntro(GetInstance,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CmpiProviderManager::handleGetInstanceRequest - Host name: $0 "
"hi sure man Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->instanceName.getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->instanceName.getClassName(),
request->instanceName.getKeyBindings());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
#ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT
#ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
// If normalization is enabled, then the normalizer will take care of
// any EmbeddedInstance / EmbeddedObject mismatches, and we don't need
// to add a NormalizerContextContainer. The presence of an
// ObjectNormalizer is determined by the presence of the
// CachedClassDefinitionContainer
if (request->operationContext.contains(
CachedClassDefinitionContainer::NAME))
{
request->operationContext.get(CachedClassDefinitionContainer::NAME);
}
else
#endif // PEGASUS_ENABLE_OBJECT_NORMALIZATION
{
// If a mechanism is needed to correct mismatches between the
// EmbeddedInstance and EmbeddedObject types, then insert
// containers for the class definition and a NormalizerContext.
AutoPtr<NormalizerContext> tmpNormalizerContext(
new CIMOMHandleContext(*pr._cimom_handle));
CIMClass classDef(tmpNormalizerContext->getClass(
request->nameSpace, request->className));
request->operationContext.insert(
CachedClassDefinitionContainer(classDef));
request->operationContext.insert(
NormalizerContextContainer(tmpNormalizerContext));
}
#endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.getInstance: " + pr.getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
CMPIPropertyList props(request->propertyList);
CMPIFlags flgs=0;
if (request->includeQualifiers) flgs|=CMPI_FLAG_IncludeQualifiers;
if (request->includeClassOrigin) flgs|=CMPI_FLAG_IncludeClassOrigin;
eCtx.ft->addEntry(
&eCtx,CMPIInvocationFlags,(CMPIValue*)&flgs,CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(
&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->getInstance(
pr.miVector.instMI,
&eCtx,
&eRes,
&eRef,
(const char **)props.getList());
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleEnumerateInstancesRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleEnumerateInstanceRequest()");
HandlerIntro(EnumerateInstances,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleEnumerateInstancesRequest - Host name:"
" $0 Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->className.getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->className);
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
CIMPropertyList propertyList(request->propertyList);
// forward request
CMPIProvider & pr=ph.GetProvider();
#ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT
#ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
// If normalization is enabled, then the normalizer will take care of
// any EmbeddedInstance / EmbeddedObject mismatches, and we don't need
// to add a NormalizerContextContainer. The presence of an
// ObjectNormalizer is determined by the presence of the
// CachedClassDefinitionContainer
if (request->operationContext.contains(
CachedClassDefinitionContainer::NAME))
{
request->operationContext.get(
CachedClassDefinitionContainer::NAME);
}
else
#endif // PEGASUS_ENABLE_OBJECT_NORMALIZATION
{
// If a mechanism is needed to correct mismatches between the
// EmbeddedInstance and EmbeddedObject types, then insert
// containers for the class definition and a NormalizerContext.
AutoPtr<NormalizerContext> tmpNormalizerContext(
new CIMOMHandleContext(*pr._cimom_handle));
CIMClass classDef(tmpNormalizerContext->getClass(
request->nameSpace, request->className));
request->operationContext.insert(
CachedClassDefinitionContainer(classDef));
request->operationContext.insert(
NormalizerContextContainer(tmpNormalizerContext));
}
#endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.enumerateInstances: " + pr.getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
CMPIPropertyList props(propertyList);
CMPIFlags flgs=0;
if (request->includeQualifiers) flgs|=CMPI_FLAG_IncludeQualifiers;
if (request->includeClassOrigin) flgs|=CMPI_FLAG_IncludeClassOrigin;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(
&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->enumInstances(
pr.miVector.instMI,
&eCtx,
&eRes,
&eRef,
(const char **)props.getList());
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry(&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleEnumerateInstanceNamesRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleEnumerateInstanceNamesRequest()");
HandlerIntro(EnumerateInstanceNames,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleEnumerateInstanceNamesRequest - Host "
"name: $0 Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->className.getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->className);
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
CMPIProvider & pr=ph.GetProvider();
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.enumerateInstanceNames: " + pr.getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
CMPIFlags flgs=0;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(
&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->enumInstanceNames(
pr.miVector.instMI,&eCtx,&eRes,&eRef);
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleCreateInstanceRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleCreateInstanceRequest()");
HandlerIntro(CreateInstance,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleCreateInstanceRequest - Host name: "
"$0 Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->newInstance.getPath().getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->newInstance.getPath().getClassName(),
request->newInstance.getPath().getKeyBindings());
request->newInstance.setPath(objectPath);
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.createInstance: " +
ph.GetProvider().getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_InstanceOnStack eInst(request->newInstance);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
CMPIFlags flgs=0;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(
&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->createInstance(
pr.miVector.instMI,&eCtx,&eRes,&eRef,&eInst);
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleModifyInstanceRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleModifyInstanceRequest()");
HandlerIntro(ModifyInstance,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleModifyInstanceRequest - Host name: $0"
" Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->modifiedInstance.getPath().getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->modifiedInstance.getPath ().getClassName(),
request->modifiedInstance.getPath ().getKeyBindings());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.modifyInstance: " + pr.getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_InstanceOnStack eInst(request->modifiedInstance);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
CMPIPropertyList props(request->propertyList);
CMPIFlags flgs=0;
if (request->includeQualifiers) flgs|=CMPI_FLAG_IncludeQualifiers;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->modifyInstance(
pr.miVector.instMI,&eCtx,&eRes,&eRef,&eInst,
(const char **)props.getList());
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleDeleteInstanceRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleDeleteInstanceRequest()");
HandlerIntro(DeleteInstance,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleDeleteInstanceRequest - Host name: $0"
" Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->instanceName.getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->instanceName.getClassName(),
request->instanceName.getKeyBindings());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.deleteInstance: " + pr.getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
CMPIFlags flgs=0;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->deleteInstance(
pr.miVector.instMI,&eCtx,&eRes,&eRef);
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleExecQueryRequest(const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleExecQueryRequest()");
HandlerIntro(ExecQuery,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::ExecQueryRequest - Host name: $0 Name "
"space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->className.getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->className);
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.execQuery: " + pr.getName());
const char **props=NULL;
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
const CString queryLan=request->queryLanguage.getCString();
const CString query=request->query.getCString();
CMPIFlags flgs=0;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
eCtx.ft->addEntry(
&eCtx,
CMPIInitNameSpace,
(CMPIValue*)(const char*)request->
nameSpace.getString().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->execQuery(
pr.miVector.instMI,&eCtx,&eRes,&eRef,
CHARS(queryLan),CHARS(query));
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleAssociatorsRequest(const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleAssociatorsRequest()");
HandlerIntro(Associators,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleAssociatorsRequest - Host name: $0 "
"Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->objectName.getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->objectName.getClassName());
objectPath.setKeyBindings(request->objectName.getKeyBindings());
CIMObjectPath assocPath(
System::getHostName(),
request->nameSpace,
request->assocClass.getString());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
#ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT
#ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
// If normalization is enabled, then the normalizer will take care of
// any EmbeddedInstance / EmbeddedObject mismatches, and we don't need
// to add a NormalizerContextContainer. The presence of an
// ObjectNormalizer is determined by the presence of the
// CachedClassDefinitionContainer
if (request->operationContext.contains(
CachedClassDefinitionContainer::NAME))
{
request->operationContext.get(
CachedClassDefinitionContainer::NAME);
}
else
#endif // PEGASUS_ENABLE_OBJECT_NORMALIZATION
{
// If a mechanism is needed to correct mismatches between the
// EmbeddedInstance and EmbeddedObject types, then insert
// containers for the class definition and a NormalizerContext.
AutoPtr<NormalizerContext> tmpNormalizerContext(
new CIMOMHandleContext(*pr._cimom_handle));
CIMClass classDef(tmpNormalizerContext->getClass(
request->nameSpace, request->className));
request->operationContext.insert(
CachedClassDefinitionContainer(classDef));
request->operationContext.insert(
NormalizerContextContainer(tmpNormalizerContext));
}
#endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.associators: " + pr.getName());
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
String("--- CMPIProviderManager::associators < role: >" ) +
request->role +
request->assocClass.getString());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
const CString aClass=request->assocClass.getString().getCString();
const CString rClass=request->resultClass.getString().getCString();
const CString rRole=request->role.getCString();
const CString resRole=request->resultRole.getCString();
CMPIPropertyList props(request->propertyList);
CMPIFlags flgs=0;
if (request->includeQualifiers) flgs|=CMPI_FLAG_IncludeQualifiers;
if (request->includeClassOrigin) flgs|=CMPI_FLAG_IncludeClassOrigin;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.assocMI->ft->associators(
pr.miVector.assocMI,&eCtx,&eRes,&eRef,
CHARS(aClass),CHARS(rClass),CHARS(rRole),CHARS(resRole),
(const char **)props.getList());
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata = eCtx.ft->getEntry (
&eCtx,
CMPIContentLanguage,
&tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleAssociatorNamesRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleAssociatorNamesRequest()");
HandlerIntro(AssociatorNames,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleAssociatorNamesRequest - Host name: $0"
" Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->objectName.getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->objectName.getClassName());
objectPath.setKeyBindings(request->objectName.getKeyBindings());
CIMObjectPath assocPath(
System::getHostName(),
request->nameSpace,
request->assocClass.getString());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.associatorNames: " + pr.getName());
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
String("--- CMPIProviderManager::associatorNames -- role: ") +
request->role + "< aCls " + request->assocClass.getString());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
const CString aClass=request->assocClass.getString().getCString();
const CString rClass=request->resultClass.getString().getCString();
const CString rRole=request->role.getCString();
const CString resRole=request->resultRole.getCString();
CMPIFlags flgs=0;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.assocMI->ft->associatorNames(
pr.miVector.assocMI,&eCtx,&eRes,&eRef,CHARS(aClass),
CHARS(rClass),CHARS(rRole),CHARS(resRole));
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleReferencesRequest(const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleReferencesRequest()");
HandlerIntro(References,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleReferencesRequest - Host name: $0 "
"Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->objectName.getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->objectName.getClassName());
objectPath.setKeyBindings(request->objectName.getKeyBindings());
CIMObjectPath resultPath(
System::getHostName(),
request->nameSpace,
request->resultClass.getString());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
#ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT
#ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
// If normalization is enabled, then the normalizer will take care of
// any EmbeddedInstance / EmbeddedObject mismatches, and we don't need
// to add a NormalizerContextContainer. The presence of an
// ObjectNormalizer is determined by the presence of the
// CachedClassDefinitionContainer
if (request->operationContext.contains(
CachedClassDefinitionContainer::NAME))
{
request->operationContext.get(
CachedClassDefinitionContainer::NAME);
}
else
#endif // PEGASUS_ENABLE_OBJECT_NORMALIZATION
{
// If a mechanism is needed to correct mismatches between the
// EmbeddedInstance and EmbeddedObject types, then insert
// containers for the class definition and a NormalizerContext.
AutoPtr<NormalizerContext> tmpNormalizerContext(
new CIMOMHandleContext(*pr._cimom_handle));
CIMClass classDef(tmpNormalizerContext->getClass(
request->nameSpace, request->className));
request->operationContext.insert(
CachedClassDefinitionContainer(classDef));
request->operationContext.insert(
NormalizerContextContainer(tmpNormalizerContext));
}
#endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.references: " + pr.getName());
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER, Tracer::LEVEL4,
String("--- CMPIProviderManager::references -- role:") +
request->role + "< aCls " + request->resultClass.getString());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
const CString rClass=request->resultClass.getString().getCString();
const CString rRole=request->role.getCString();
CMPIPropertyList props(request->propertyList);
CMPIFlags flgs=0;
if (request->includeQualifiers) flgs|=CMPI_FLAG_IncludeQualifiers;
if (request->includeClassOrigin) flgs|=CMPI_FLAG_IncludeClassOrigin;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.assocMI->ft->references(
pr.miVector.assocMI,&eCtx,&eRes,&eRef,
CHARS(rClass),CHARS(rRole),(const char **)props.getList());
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleReferenceNamesRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleReferenceNamesRequest()");
HandlerIntro(ReferenceNames,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleReferenceNamesRequest - Host name: $0"
" Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->objectName.getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->objectName.getClassName());
objectPath.setKeyBindings(request->objectName.getKeyBindings());
CIMObjectPath resultPath(
System::getHostName(),
request->nameSpace,
request->resultClass.getString());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
CMPIProvider & pr=ph.GetProvider();
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.referenceNames: " + pr.getName());
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
String("--- CMPIProviderManager::referenceNames -- role: ") +
request->role + "< aCls " + request->resultClass.getString());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
const CString rClass=request->resultClass.getString().getCString();
const CString rRole=request->role.getCString();
CMPIFlags flgs=0;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.assocMI->ft->referenceNames(
pr.miVector.assocMI,&eCtx,&eRes,&eRef,
CHARS(rClass),CHARS(rRole));
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleInvokeMethodRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleInvokeMethodRequest()");
HandlerIntro(InvokeMethod,message,request,response,handler);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleInvokeMethodRequest - Host name: $0 "
"Name space: $1 Class name: $2",
System::getHostName(),
request->nameSpace.getString(),
request->instanceName.getClassName().getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->instanceName.getClassName(),
request->instanceName.getKeyBindings());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
CIMObjectPath instanceReference(request->instanceName);
// ATTN: propagate namespace
instanceReference.setNameSpace(request->nameSpace);
// forward request
CMPIProvider & pr=ph.GetProvider();
#ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT
bool externalNormalizationEnabled = false;
#ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
// If normalization is enabled, then the normalizer will take care of
// any EmbeddedInstance / EmbeddedObject mismatches, and we don't need
// to add a NormalizerContextContainer. The presence of an
// ObjectNormalizer is determined by the presence of the
// CachedClassDefinitionContainer
if (request->operationContext.contains(
CachedClassDefinitionContainer::NAME))
{
request->operationContext.get(
CachedClassDefinitionContainer::NAME);
externalNormalizationEnabled = true;
}
else
#endif // PEGASUS_ENABLE_OBJECT_NORMALIZATION
{
// If a mechanism is needed to correct mismatches between the
// EmbeddedInstance and EmbeddedObject types, then insert
// containers for the class definition and a NormalizerContext.
AutoPtr<NormalizerContext> tmpNormalizerContext(
new CIMOMHandleContext(*pr._cimom_handle));
CIMClass classDef(tmpNormalizerContext->getClass(
request->nameSpace, request->className));
request->operationContext.insert(
CachedClassDefinitionContainer(classDef));
request->operationContext.insert(
NormalizerContextContainer(tmpNormalizerContext));
}
#endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.invokeMethod: " + pr.getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
CMPI_ArgsOnStack eArgsIn(request->inParameters);
Array<CIMParamValue> outArgs;
CMPI_ArgsOnStack eArgsOut(outArgs);
CString mName=request->methodName.getString().getCString();
CMPIFlags flgs=0;
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.methMI->ft->invokeMethod(
pr.miVector.methMI,&eCtx,&eRes,&eRef,
CHARS(mName),&eArgsIn,&eArgsOut);
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
#ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT
if (!externalNormalizationEnabled)
{
// There is no try catch here because if there is no external
// normalization, then these containers were added by this method.
const CachedClassDefinitionContainer * classCont =
dynamic_cast<const CachedClassDefinitionContainer *>(
&request->operationContext.get(
CachedClassDefinitionContainer::NAME));
PEGASUS_ASSERT(classCont != 0);
const NormalizerContextContainer * contextCont =
dynamic_cast<const NormalizerContextContainer*>(
&request->operationContext.get(
NormalizerContextContainer::NAME));
PEGASUS_ASSERT(contextCont != 0);
CIMClass classDef(classCont->getClass());
Uint32 methodIndex = classDef.findMethod(request->methodName);
PEGASUS_ASSERT(methodIndex != PEG_NOT_FOUND);
CIMMethod methodDef(classDef.getMethod(methodIndex));
for (unsigned int i = 0, n = outArgs.size(); i < n; ++i)
{
CIMParamValue currentParam(outArgs[i]);
CIMValue paramValue(currentParam.getValue());
// If the parameter value is an EmbeddedObject type, we have
// to check against the type of the parameter definition.
// CMPI does not distinguish between EmbeddedObjects and
// EmbeddedInstances, so if the parameter definition has a type
// of EmbeddedInstance, the type of the output parameter must
// be changed.
if (paramValue.getType() == CIMTYPE_OBJECT)
{
CIMObject paramObject;
paramValue.get(paramObject);
CIMInstance paramInst(paramObject);
resolveEmbeddedInstanceTypes(&handler, paramInst);
String currentParamName(currentParam.getParameterName());
Uint32 paramIndex = methodDef.findParameter(
CIMName(currentParamName));
if (paramIndex == PEG_NOT_FOUND)
{
MessageLoaderParms msg("ProviderManager.CMPI."
"CMPIProviderManager.PARAMETER_NOT_FOUND",
"Parameter $0 not found in definition for "
"method $1.", currentParamName,
request->methodName.getString());
PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
MessageLoader::getMessage(msg));
handler.setStatus(CIM_ERR_FAILED,
MessageLoader::getMessage(msg));
}
else
{
CIMConstParameter paramDef(
methodDef.getParameter(paramIndex));
if (paramDef.findQualifier(CIMName("EmbeddedInstance"))
!= PEG_NOT_FOUND)
{
currentParam = CIMParamValue(currentParamName,
CIMValue(paramInst));
}
else
{
currentParam = CIMParamValue(currentParamName,
CIMValue(paramObject));
}
handler.deliverParamValue(currentParam);
}
}
else
{
handler.deliverParamValue(currentParam);
}
}
}
#else
for (int i=0,s=outArgs.size(); i<s; i++)
{
handler.deliverParamValue(outArgs[i]);
}
#endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT
handler.complete();
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
int LocateIndicationProviderNames(
const CIMInstance& pInstance,
const CIMInstance& pmInstance,
String& providerName,
String& location)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager:LocateIndicationProviderNames()");
Uint32 pos = pInstance.findProperty(CIMName ("Name"));
pInstance.getProperty(pos).getValue().get(providerName);
pos = pmInstance.findProperty(CIMName ("Location"));
pmInstance.getProperty(pos).getValue().get(location);
PEG_METHOD_EXIT();
return 0;
}
Message * CMPIProviderManager::handleCreateSubscriptionRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleCreateSubscriptionRequest()");
HandlerIntroInd(CreateSubscription,message,request,response,
handler);
try
{
CIMInstance req_provider, req_providerModule;
ProviderIdContainer pidc =
(ProviderIdContainer)request->operationContext.get(
ProviderIdContainer::NAME);
req_provider = pidc.getProvider();
req_providerModule = pidc.getModule();
String providerName,providerLocation;
LocateIndicationProviderNames(req_provider, req_providerModule,
providerName,providerLocation);
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleCreateSubscriptionRequest - Host name:"
" $0 Name space: $1 Provider name(s): $2",
System::getHostName(),
request->nameSpace.getString(),
providerName);
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
providerLocation, providerName);
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
providerLocation, providerName);
}
indProvRecord *prec=NULL;
{
WriteLock writeLock(rwSemProvTab);
provTab.lookup(ph.GetProvider().getName(),prec);
if (prec) prec->count++;
else
{
prec=new indProvRecord();
#ifdef PEGASUS_ENABLE_REMOTE_CMPI
if (remote)
{
prec->remoteInfo = pidc.getRemoteInfo();
}
#endif
provTab.insert(ph.GetProvider().getName(),prec);
}
}
//
// Save the provider instance from the request
//
ph.GetProvider ().setProviderInstance (req_provider);
const CIMObjectPath &sPath=request->subscriptionInstance.getPath();
indSelectRecord *srec=NULL;
{
WriteLock writeLock(rwSemSelxTab);
selxTab.lookup(sPath,srec);
if (srec) srec->count++;
else
{
srec=new indSelectRecord();
selxTab.insert(sPath,srec);
}
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
context.insert(
request->operationContext.get(SubscriptionInstanceContainer::NAME));
context.insert(
request->operationContext.get(
SubscriptionFilterConditionContainer::NAME));
CIMObjectPath subscriptionName =
request->subscriptionInstance.getPath();
CMPIProvider & pr=ph.GetProvider();
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
SubscriptionFilterConditionContainer sub_cntr =
request->operationContext.get(
SubscriptionFilterConditionContainer::NAME);
CIMOMHandleQueryContext *_context=
new CIMOMHandleQueryContext(
CIMNamespaceName(
request->nameSpace.getString()),
*pr._cimom_handle);
CMPI_SelectExp *eSelx=new CMPI_SelectExp(
context,
_context,
request->query,
sub_cntr.getQueryLanguage());
srec->eSelx=eSelx;
srec->qContext=_context;
CMPI_ThreadContext thr(&pr.broker,&eCtx);
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.createSubscriptionRequest: " + pr.getName());
for (Uint32 i = 0, n = request->classNames.size(); i < n; i++)
{
CIMObjectPath className(
System::getHostName(),
request->nameSpace,
request->classNames[i]);
eSelx->classNames.append(className);
}
CMPI_ObjectPathOnStack eRef(eSelx->classNames[0]);
CIMPropertyList propertyList = request->propertyList;
if (!propertyList.isNull())
{
Array<CIMName> p=propertyList.getPropertyNameArray();
int pCount=p.size();
eSelx->props = new const char*[1+pCount];
for (int i=0; i<pCount; i++)
{
eSelx->props[i]=strdup(p[i].getString().getCString());
}
eSelx->props[pCount]=NULL;
}
Uint16 repeatNotificationPolicy = request->repeatNotificationPolicy;
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
eCtx.ft->addEntry(&eCtx,
CMPIInitNameSpace,
(CMPIValue*)(const char*)request->
nameSpace.getString().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
CString info;
if (remote)
{
info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
if (pr.miVector.indMI->ft->ftVersion >= 100)
{
rc = pr.miVector.indMI->ft->activateFilter(
pr.miVector.indMI,&eCtx,eSelx,
CHARS(eSelx->classNames[0].getClassName().getString().
getCString()),&eRef,false);
}
else
{
// Older version of (pre 1.00) also pass in a CMPIResult
rc = ((CMPIStatus (*)(CMPIIndicationMI*, CMPIContext*,
CMPIResult*, CMPISelectExp*,
const char *, CMPIObjectPath*, CMPIBoolean))
pr.miVector.indMI->ft->activateFilter)
(pr.miVector.indMI,&eCtx,NULL,eSelx,
CHARS(eSelx->classNames[0].getClassName().getString().
getCString()),&eRef,false);
}
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
}
if (rc.rc!=CMPI_RC_OK)
{
// Removed the select expression from the cache
WriteLock lock(rwSemSelxTab);
if (--srec->count<=0)
{
selxTab.remove(sPath);
delete _context;
delete eSelx;
delete srec;
}
throw CIMException((CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
}
else
{
//
// 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, (const char*)info);
}
}
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleDeleteSubscriptionRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleDeleteSubscriptionRequest()");
HandlerIntroInd(DeleteSubscription,message,request,response,
handler);
try
{
String providerName,providerLocation;
CIMInstance req_provider, req_providerModule;
ProviderIdContainer pidc =
(ProviderIdContainer)request->operationContext.get(
ProviderIdContainer::NAME);
req_provider = pidc.getProvider();
req_providerModule = pidc.getModule();
LocateIndicationProviderNames(req_provider, req_providerModule,
providerName,providerLocation);
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CMPIProviderManager::handleDeleteSubscriptionRequest - Host name:"
" $0 Name space: $1 Provider name(s): $2",
System::getHostName(),
request->nameSpace.getString(),
providerName);
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
providerLocation, providerName);
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
providerLocation, providerName);
}
indProvRecord *prec=NULL;
{
WriteLock writeLock(rwSemProvTab);
provTab.lookup(ph.GetProvider().getName(),prec);
if (--prec->count<=0)
{
if (prec->handler)
delete prec->handler;
delete prec;
provTab.remove(ph.GetProvider().getName());
prec=NULL;
}
}
indSelectRecord *srec=NULL;
const CIMObjectPath &sPath=request->subscriptionInstance.getPath();
WriteLock writeLock(rwSemSelxTab);
if (!selxTab.lookup(sPath,srec))
{
MessageLoaderParms parms(
"ProviderManager.CMPI.CMPIProviderManager."
"FAILED_LOCATE_SUBSCRIPTION_FILTER",
"Failed to locate the subscription filter.");
// failed to get select expression from hash table
throw CIMException(CIM_ERR_FAILED, parms);
};
CMPI_SelectExp *eSelx=srec->eSelx;
CIMOMHandleQueryContext *qContext=srec->qContext;
CMPI_ObjectPathOnStack eRef(eSelx->classNames[0]);
if (--srec->count<=0)
{
selxTab.remove(sPath);
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
context.insert(
request->operationContext.get(SubscriptionInstanceContainer::NAME));
CIMObjectPath subscriptionName =
request->subscriptionInstance.getPath();
CMPIProvider & pr=ph.GetProvider();
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.deleteSubscriptionRequest: " + pr.getName());
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
eCtx.ft->addEntry(
&eCtx,
CMPIInitNameSpace,
(CMPIValue*)(const char*)request->
nameSpace.getString().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
CString info;
if (remote)
{
info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
if (pr.miVector.indMI->ft->ftVersion >= 100)
{
rc = pr.miVector.indMI->ft->deActivateFilter(
pr.miVector.indMI,&eCtx,eSelx,
CHARS(eSelx->classNames[0].getClassName().getString().
getCString()),&eRef,prec==NULL);
}
else
{
// Older version of (pre 1.00) also pass in a CMPIResult
rc = ((CMPIStatus (*)(CMPIIndicationMI*, CMPIContext*,
CMPIResult*, CMPISelectExp*,
const char *, CMPIObjectPath*, CMPIBoolean))
pr.miVector.indMI->ft->deActivateFilter)
(pr.miVector.indMI,&eCtx,NULL,eSelx,
CHARS(eSelx->classNames[0].getClassName().getString().
getCString()),&eRef,prec==NULL);
}
}
if (srec->count<=0)
{
delete qContext;
delete eSelx;
delete srec;
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
}
if (rc.rc!=CMPI_RC_OK)
{
throw CIMException((CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
}
else
{
//
// Decrement count of current subscriptions for this provider
//
if (ph.GetProvider ().decrementSubscriptionsAndTestIfZero ())
{
//
// If there are no current subscriptions after the decrement,
// the last subscription has been deleted
// Call the provider's disableIndications method
//
if (_subscriptionInitComplete)
{
_callDisableIndications (ph, (const char*)info);
}
}
}
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleDisableModuleRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleDisableModuleRequest()");
CIMDisableModuleRequestMessage * request =
dynamic_cast<CIMDisableModuleRequestMessage *>(
const_cast<Message *>(message));
PEGASUS_ASSERT(request != 0);
// get provider module name
Boolean disableProviderOnly = request->disableProviderOnly;
Array<Uint16> operationalStatus;
// Assume success.
operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_STOPPED);
//
// Unload providers
//
Array<CIMInstance> _pInstances = request->providers;
Array <Boolean> _indicationProviders = request->indicationProviders;
/* The CIMInstances on request->providers array is completly _different_
than the request->providerModule CIMInstance. Hence */
String physicalName=(request->providerModule.getProperty(
request->
providerModule.findProperty("Location")).getValue().toString());
for (Uint32 i = 0, n = _pInstances.size(); i < n; i++)
{
String providerName;
_pInstances [i].getProperty (_pInstances [i].findProperty
(CIMName ("Name"))).getValue ().get (providerName);
Uint32 pos = _pInstances[i].findProperty("Name");
//
// Reset the indication provider's count of current
// subscriptions since it has been disabled
//
if (_indicationProviders [i])
{
if (physicalName.size () > 0)
{
try
{
CMPIProvider::OpProviderHolder ph =
providerManager.getProvider(
physicalName,
providerName);
ph.GetProvider ().resetSubscriptions ();
}
catch (const Exception &e)
{
PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL2,
e.getMessage());
}
}
}
providerManager.unloadProvider(
physicalName,
_pInstances[i].getProperty(
_pInstances[i].findProperty("Name")
).getValue ().toString ());
}
CIMDisableModuleResponseMessage * response =
new CIMDisableModuleResponseMessage(
request->messageId,
CIMException(),
request->queueIds.copyAndPop(),
operationalStatus);
PEGASUS_ASSERT(response != 0);
//
// Set HTTP method in response from request
//
response->setHttpMethod (request->getHttpMethod ());
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleEnableModuleRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleEnableModuleRequest()");
CIMEnableModuleRequestMessage * request =
dynamic_cast<CIMEnableModuleRequestMessage *>(
const_cast<Message *>(message));
PEGASUS_ASSERT(request != 0);
Array<Uint16> operationalStatus;
operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK);
CIMEnableModuleResponseMessage * response =
new CIMEnableModuleResponseMessage(
request->messageId,
CIMException(),
request->queueIds.copyAndPop(),
operationalStatus);
PEGASUS_ASSERT(response != 0);
// Set HTTP method in response from request
response->setHttpMethod (request->getHttpMethod ());
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleStopAllProvidersRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleStopAllProvidersRequest()");
CIMStopAllProvidersRequestMessage * request =
dynamic_cast<CIMStopAllProvidersRequestMessage *>(
const_cast<Message *>(message));
PEGASUS_ASSERT(request != 0);
CIMStopAllProvidersResponseMessage * response =
new CIMStopAllProvidersResponseMessage(
request->messageId,
CIMException(),
request->queueIds.copyAndPop());
PEGASUS_ASSERT(response != 0);
// Set HTTP method in response from request
response->setHttpMethod (request->getHttpMethod ());
// tell the provider manager to shutdown all the providers
providerManager.shutdownAllProviders();
PEG_METHOD_EXIT();
return(response);
}
// Note: The PG_Provider AutoStart property is not yet supported
#if 0
Message * CMPIProviderManager::handleInitializeProviderRequest(
const Message * message)
{
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleInitializeProviderRequest");
HandlerIntroInit(InitializeProvider,message,request,response,handler);
try
{
// resolve provider name
ProviderName name = _resolveProviderName(
request->operationContext.get(ProviderIdContainer::NAME));
// get cached or load new provider module
CMPIProvider::OpProviderHolder ph =
providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
HandlerCatch(handler);
PEG_METHOD_EXIT();
return(response);
}
#endif
Message * CMPIProviderManager::handleSubscriptionInitCompleteRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleSubscriptionInitCompleteRequest()");
CIMSubscriptionInitCompleteRequestMessage * request =
dynamic_cast <CIMSubscriptionInitCompleteRequestMessage *>
(const_cast <Message *> (message));
PEGASUS_ASSERT (request != 0);
CIMSubscriptionInitCompleteResponseMessage * response =
dynamic_cast <CIMSubscriptionInitCompleteResponseMessage *>
(request->buildResponse ());
PEGASUS_ASSERT (response != 0);
//
// Set indicator
//
_subscriptionInitComplete = true;
//
// For each provider that has at least one subscription, call
// provider's enableIndications method
//
Array <CMPIProvider *> enableProviders;
enableProviders = providerManager.getIndicationProvidersToEnable ();
Uint32 numProviders = enableProviders.size ();
for (Uint32 i = 0; i < numProviders; i++)
{
try
{
CIMInstance provider;
provider = enableProviders [i]->getProviderInstance ();
CString info;
#ifdef PEGASUS_ENABLE_REMOTE_CMPI
indProvRecord *provRec = 0;
if (provTab.lookup (enableProviders [i]->getName(), provRec))
{
if (provRec->remoteInfo != String::EMPTY)
{
info = provRec->remoteInfo.getCString();
}
}
#endif
//
// Get cached or load new provider module
//
CMPIProvider::OpProviderHolder ph;
if ((const char*)info)
{
ph = providerManager.getRemoteProvider
(enableProviders [i]->getModule ()->getFileName (),
enableProviders [i]->getName ());
}
else
{
ph = providerManager.getProvider
(enableProviders [i]->getModule ()->getFileName (),
enableProviders [i]->getName ());
}
_callEnableIndications(
provider,
_indicationCallback,
ph,
(const char*)info);
}
catch (const CIMException & e)
{
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL2,
"CIMException: " + e.getMessage ());
}
catch (const Exception & e)
{
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL2,
"Exception: " + e.getMessage ());
}
catch (...)
{
PEG_TRACE_CSTRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL2,
"Unknown error in handleSubscriptionInitCompleteRequest");
}
}
PEG_METHOD_EXIT ();
return(response);
}
Message * CMPIProviderManager::handleGetPropertyRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleGetPropertyRequest()");
HandlerIntro(GetProperty,message,request,response,handler);
// We're only going to be interested in the specific property from this
// instance.
Array<CIMName> localPropertyListArray;
localPropertyListArray.append(request->propertyName);
CIMPropertyList localPropertyList(localPropertyListArray);
// NOTE: GetProperty will use the CIMInstanceProvider interface, so we
// must manually define a request, response, and handler (emulate
// HandlerIntro macro)
CIMGetInstanceRequestMessage * GI_request =
new CIMGetInstanceRequestMessage(
request->messageId,
request->nameSpace,
request->instanceName,
false,
false,
false,
localPropertyList,
request->queueIds,
request->authType,
request->userName
);
PEGASUS_ASSERT(GI_request != 0);
CIMGetInstanceResponseMessage * GI_response =
dynamic_cast<CIMGetInstanceResponseMessage*>
(GI_request->buildResponse());
PEGASUS_ASSERT(GI_response != 0);
GetInstanceResponseHandler GI_handler(
GI_request,
GI_response,
_responseChunkCallback);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CmpiProviderManager::handleGetPropertyRequest - Host name: $0 "
"Name space: $1 Class name: $2 Property name: $3",
System::getHostName(),
request->nameSpace.getString(),
request->instanceName.getClassName().getString(),
request->propertyName.getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->instanceName.getClassName(),
request->instanceName.getKeyBindings());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
#ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT
#ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
// If normalization is enabled, then the normalizer will take care of
// any EmbeddedInstance / EmbeddedObject mismatches, and we don't need
// to add a NormalizerContextContainer. The presence of an
// ObjectNormalizer is determined by the presence of the
// CachedClassDefinitionContainer
if (request->operationContext.contains(
CachedClassDefinitionContainer::NAME))
{
request->operationContext.get(
CachedClassDefinitionContainer::NAME);
}
else
#endif // PEGASUS_ENABLE_OBJECT_NORMALIZATION
{
// If a mechanism is needed to correct mismatches between the
// EmbeddedInstance and EmbeddedObject types, then insert
// containers for the class definition and a NormalizerContext.
AutoPtr<NormalizerContext> tmpNormalizerContext(
new CIMOMHandleContext(*pr._cimom_handle));
CIMClass classDef(tmpNormalizerContext->getClass(
request->nameSpace, request->className));
request->operationContext.insert(
CachedClassDefinitionContainer(classDef));
request->operationContext.insert(
NormalizerContextContainer(tmpNormalizerContext));
}
#endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.getInstance via getProperty: " + pr.getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(GI_handler,&pr.broker);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
// For the getInstance provider call, use the property list that we
// created containing the single property from the getProperty call.
CMPIPropertyList props(localPropertyList);
CMPIFlags flgs=0;
// Leave includeQualifiers and includeClassOrigin as false for this
// call to getInstance
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->getInstance(
pr.miVector.instMI,&eCtx,&eRes,&eRef,
(const char **)props.getList());
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
// Copy property value from instance to getProperty response
if (!(GI_response->cimInstance.isUninitialized()))
{
Uint32 pos =
GI_response->cimInstance.findProperty(request->propertyName);
if (pos != PEG_NOT_FOUND)
{
response->value =
GI_response->cimInstance.getProperty(pos).getValue();
}
// Else property not found. Return CIM_ERR_NO_SUCH_PROPERTY.
else
{
throw PEGASUS_CIM_EXCEPTION(
CIM_ERR_NO_SUCH_PROPERTY,
request->propertyName.getString()
);
}
}
}
HandlerCatch(handler);
delete GI_request;
delete GI_response;
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleSetPropertyRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleSetPropertyRequest()");
HandlerIntro(SetProperty,message,request,response,handler);
// We're only going to be interested in the specific property from this
// instance.
Array<CIMName> localPropertyListArray;
localPropertyListArray.append(request->propertyName);
CIMPropertyList localPropertyList(localPropertyListArray);
// Build a modified instance with just the specific property and its
// new value.
CIMInstance localModifiedInstance(request->instanceName.getClassName());
localModifiedInstance.setPath(request->instanceName);
localModifiedInstance.addProperty(
CIMProperty(request->propertyName, request->newValue));
// NOTE: SetProperty will use the CIMInstanceProvider interface, so we must
// manually define a request, response, and handler.
CIMModifyInstanceRequestMessage * MI_request =
new CIMModifyInstanceRequestMessage(
request->messageId,
request->nameSpace,
localModifiedInstance,
false,
localPropertyList,
request->queueIds,
request->authType,
request->userName
);
PEGASUS_ASSERT(MI_request != 0);
CIMModifyInstanceResponseMessage * MI_response =
dynamic_cast<CIMModifyInstanceResponseMessage*>(
MI_request->buildResponse());
PEGASUS_ASSERT(MI_response != 0);
ModifyInstanceResponseHandler MI_handler(
MI_request,
MI_response,
_responseChunkCallback);
try
{
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
"CmpiProviderManager::handleSetPropertyRequest - Host name: $0 "
"Name space: $1 Class name: $2 Property name: $3",
System::getHostName(),
request->nameSpace.getString(),
request->instanceName.getClassName().getString(),
request->propertyName.getString());
// make target object path
CIMObjectPath objectPath(
System::getHostName(),
request->nameSpace,
request->instanceName.getClassName(),
request->instanceName.getKeyBindings());
Boolean remote=false;
CMPIProvider::OpProviderHolder ph;
// resolve provider name
ProviderIdContainer pidc =
request->operationContext.get(ProviderIdContainer::NAME);
ProviderName name = _resolveProviderName(pidc);
if ((remote=pidc.isRemoteNameSpace()))
{
ph = providerManager.getRemoteProvider(
name.getLocation(), name.getLogicalName());
}
else
{
// get cached or load new provider module
ph = providerManager.getProvider(
name.getPhysicalName(), name.getLogicalName());
}
// convert arguments
OperationContext context;
context.insert(request->operationContext.get(IdentityContainer::NAME));
context.insert(
request->operationContext.get(AcceptLanguageListContainer::NAME));
context.insert(
request->operationContext.get(ContentLanguageListContainer::NAME));
// forward request
CMPIProvider & pr=ph.GetProvider();
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.modifyInstance via setProperty: " + pr.getName());
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ObjectPathOnStack eRef(objectPath);
CMPI_ResultOnStack eRes(MI_handler,&pr.broker);
CMPI_InstanceOnStack eInst(localModifiedInstance);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
CMPIPropertyList props(localPropertyList);
CMPIFlags flgs=0;
// Leave includeQualifiers as false for this call to modifyInstance
eCtx.ft->addEntry(
&eCtx,
CMPIInvocationFlags,
(CMPIValue*)&flgs,
CMPI_uint32);
const IdentityContainer container =
request->operationContext.get(IdentityContainer::NAME);
eCtx.ft->addEntry(&eCtx,
CMPIPrincipal,
(CMPIValue*)(const char*)container.getUserName().getCString(),
CMPI_chars);
const AcceptLanguageListContainer accept_language=
request->operationContext.get(AcceptLanguageListContainer::NAME);
const AcceptLanguageList acceptLangs = accept_language.getLanguages();
eCtx.ft->addEntry(
&eCtx,
CMPIAcceptLanguage,
(CMPIValue*)(const char*)LanguageParser::buildAcceptLanguageHeader(
acceptLangs).getCString(),
CMPI_chars);
if (remote)
{
CString info=pidc.getRemoteInfo().getCString();
eCtx.ft->addEntry(
&eCtx,
"CMPIRRemoteInfo",
(CMPIValue*)(const char*)info,
CMPI_chars);
}
CMPIProvider::pm_service_op_lock op_lock(&pr);
AutoPThreadSecurity threadLevelSecurity(context);
{
StatProviderTimeMeasurement providerTime(response);
rc = pr.miVector.instMI->ft->modifyInstance(
pr.miVector.instMI,&eCtx,&eRes,&eRef,&eInst,
(const char **)props.getList());
}
// Need to save ContentLanguage value into operation context of response
// Do this before checking rc from provider to throw exception in case
// rc.msg is also localized.
CMPIStatus tmprc={CMPI_RC_OK,NULL};
CMPIData cldata =
eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc);
if (tmprc.rc == CMPI_RC_OK)
{
response->operationContext.set(
ContentLanguageListContainer(
ContentLanguageList(
LanguageParser::parseContentLanguageHeader(
CMGetCharPtr(cldata.value.string)))));
handler.setContext(response->operationContext);
}
if (rc.rc!=CMPI_RC_OK)
{
CIMException cimException(
(CIMStatusCode)rc.rc,
rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
if (eRes.resError)
{
for (CMPI_Error* currErr=eRes.resError;
currErr!=NULL;
currErr=currErr->nextError)
{
cimException.addError(
((CIMError*)currErr->hdl)->getInstance());
}
}
throw cimException;
}
}
HandlerCatch(handler);
delete MI_request;
delete MI_response;
PEG_METHOD_EXIT();
return(response);
}
Message * CMPIProviderManager::handleUnsupportedRequest(
const Message * message)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::handleUnsupportedRequest()");
CIMRequestMessage* request =
dynamic_cast<CIMRequestMessage *>(const_cast<Message *>(message));
PEGASUS_ASSERT(request != 0 );
CIMResponseMessage* response = request->buildResponse();
response->cimException =
PEGASUS_CIM_EXCEPTION(CIM_ERR_NOT_SUPPORTED, String::EMPTY);
PEG_METHOD_EXIT();
return response;
}
ProviderName CMPIProviderManager::_resolveProviderName(
const ProviderIdContainer & providerId)
{
String providerName;
String fileName;
String location;
String moduleName;
CIMValue genericValue;
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::_resolveProviderName()");
genericValue = providerId.getModule().getProperty(
providerId.getModule().findProperty("Name")).getValue();
genericValue.get(moduleName);
genericValue = providerId.getProvider().getProperty(
providerId.getProvider().findProperty("Name")).getValue();
genericValue.get(providerName);
genericValue = providerId.getModule().getProperty(
providerId.getModule().findProperty("Location")).getValue();
genericValue.get(location);
fileName = _resolvePhysicalName(location);
// An empty file name is only for interest if we are in the
// local name space. So the message is only issued if not
// in the remote Name Space.
if (fileName == String::EMPTY && (!providerId.isRemoteNameSpace()))
{
genericValue.get(location);
String fullName = FileSystem::buildLibraryFileName(location);
Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE,
"ProviderManager.CMPI.CMPIProviderManager.CANNOT_FIND_LIBRARY",
"For provider $0 library $1 was not found.",
providerName, fullName);
}
ProviderName name(moduleName, providerName, fileName);
name.setLocation(location);
PEG_METHOD_EXIT();
return name;
}
void CMPIProviderManager::_callEnableIndications
(CIMInstance & req_provider,
PEGASUS_INDICATION_CALLBACK_T _indicationCallback,
CMPIProvider::OpProviderHolder & ph,
const char* remoteInfo)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::_callEnableIndications()");
try
{
indProvRecord *provRec =0;
{
WriteLock lock(rwSemProvTab);
if (provTab.lookup (ph.GetProvider ().getName (), provRec))
{
provRec->enabled = true;
CIMRequestMessage * request = 0;
CIMResponseMessage * response = 0;
provRec->handler=new EnableIndicationsResponseHandler(
request,
response,
req_provider,
_indicationCallback,
_responseChunkCallback);
}
}
CMPIProvider & pr=ph.GetProvider();
//
// Versions prior to 86 did not include enableIndications routine
//
if (pr.miVector.indMI->ft->ftVersion >= 86)
{
OperationContext context;
#ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
// For the z/OS security model we always need an Identity container
// in the operation context. Since we don't have a client request
// ID here we have to use the cim servers identity for the time
// being.
IdentityContainer idContainer(System::getEffectiveUserName());
context.insert(idContainer);
#endif
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
CMPI_ThreadContext thr(&pr.broker,&eCtx);
// Add RemoteInformation -V 5245
if (remoteInfo)
{
eCtx.ft->addEntry(&eCtx,"CMPIRRemoteInfo",
(CMPIValue*)(const char*)remoteInfo,CMPI_chars);
}
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.enableIndications: " + pr.getName());
pr.protect();
// enableIndications() is defined by the CMPI standard as
// returning a CMPIStatus return value. Unfortunately, Pegasus
// originally implemented enableIndications() with a void
// return type, and this incompatibility was not detected for
// some time. Since exceptions thrown from enableIndications()
// are not reported (other than via logging), it was decided to
// discard the returned CMPIStatus here. This will prevent us from
// breaking existing CMPI Indication providers. This is ok since
// there really isn't a user to which the problem should be
// reported.
pr.miVector.indMI->ft->enableIndications(pr.miVector.indMI,&eCtx);
}
else
{
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Not calling provider.enableIndications: " + pr.getName() +
" routine as it is an earlier version that does not support " \
"this function");
}
}
catch (const Exception & e)
{
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL2,
"Exception in _callEnableIndications: " + e.getMessage ());
Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
"ProviderManager.CMPI.CMPIProviderManager."
"ENABLE_INDICATIONS_FAILED",
"Failed to enable indications for provider $0: $1.",
ph.GetProvider ().getName (), e.getMessage ());
}
catch (...)
{
PEG_TRACE_CSTRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL2,
"Unexpected error in _callEnableIndications");
Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
"ProviderManager.CMPI.CMPIProviderManager."
"ENABLE_INDICATIONS_FAILED_UNKNOWN",
"Failed to enable indications for provider $0.",
ph.GetProvider ().getName ());
}
PEG_METHOD_EXIT ();
}
void CMPIProviderManager::_callDisableIndications
(CMPIProvider::OpProviderHolder & ph, const char *remoteInfo)
{
PEG_METHOD_ENTER(
TRC_PROVIDERMANAGER,
"CMPIProviderManager::_callDisableIndications()");
try
{
indProvRecord * provRec = 0;
{
WriteLock writeLock(rwSemProvTab);
if (provTab.lookup (ph.GetProvider ().getName (), provRec))
{
provRec->enabled = false;
if (provRec->handler) delete provRec->handler;
provRec->handler = NULL;
}
}
CMPIProvider & pr=ph.GetProvider();
//
// Versions prior to 86 did not include disableIndications routine
//
if (pr.miVector.indMI->ft->ftVersion >= 86)
{
OperationContext context;
CMPIStatus rc={CMPI_RC_OK,NULL};
CMPI_ContextOnStack eCtx(context);
if (remoteInfo)
{
eCtx.ft->addEntry(&eCtx,"CMPIRRemoteInfo",
(CMPIValue*)(const char*)remoteInfo,CMPI_chars);
}
CMPI_ThreadContext thr(&pr.broker,&eCtx);
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Calling provider.disableIndications: " + pr.getName());
// disableIndications() is defined by the CMPI standard as
// returning a CMPIStatus return value. Unfortunately, Pegasus
// originally implemented disableIndications() with a void
// return type, and this incompatibility was not detected for
// some time. For consistency with the enableIndications()
// interface, it was decided to discard the returned CMPIStatus
// here. This will prevent us from breaking existing CMPI
// Indication providers. This is ok since there really isn't a
// user to which the problem should be reported.
pr.miVector.indMI->ft->disableIndications(
pr.miVector.indMI,
&eCtx);
pr.unprotect();
}
else
{
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL4,
"Not calling provider.disableIndications: "
+ pr.getName() +
" routine as it is an earlier version that does not support" \
" this function");
}
}
catch (const Exception & e)
{
PEG_TRACE_STRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL2,
"Exception in _callDisableIndications: " + e.getMessage ());
Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
"ProviderManager.CMPI.CMPIProviderManager."
"DISABLE_INDICATIONS_FAILED",
"Failed to disable indications for provider $0: $1.",
ph.GetProvider ().getName (), e.getMessage ());
}
catch (...)
{
PEG_TRACE_CSTRING(
TRC_PROVIDERMANAGER,
Tracer::LEVEL2,
"Unexpected error in _callDisableIndications");
Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
"ProviderManager.CMPI.CMPIProviderManager."
"DISABLE_INDICATIONS_FAILED_UNKNOWN",
"Failed to disable indications for provider $0.",
ph.GetProvider ().getName ());
}
PEG_METHOD_EXIT ();
}
PEGASUS_NAMESPACE_END
| No CVS admin address has been configured |
Powered by ViewCVS 0.9.2 |