version 1.20, 2008/12/02 09:01:57
|
version 1.25.4.3, 2012/02/15 17:47:17
|
|
|
| |
PEGASUS_NAMESPACE_BEGIN | PEGASUS_NAMESPACE_BEGIN |
| |
|
String _toString(Boolean x) |
|
{ |
|
return((x)? "true" : "false"); |
|
} |
|
|
template<class T> | template<class T> |
inline T* getProviderInterface(CIMProvider* provider) | inline T* getProviderInterface(CIMProvider* provider) |
{ | { |
|
|
_subscriptionInitComplete = true; | _subscriptionInitComplete = true; |
} | } |
| |
|
void ProviderMessageHandler::indicationServiceDisabled() |
|
{ |
|
_subscriptionInitComplete = false; |
|
} |
|
|
CIMResponseMessage* ProviderMessageHandler::processMessage( | CIMResponseMessage* ProviderMessageHandler::processMessage( |
CIMRequestMessage* request) | CIMRequestMessage* request) |
{ | { |
|
|
"Object path: %s", | "Object path: %s", |
(const char*) objectPath.toString().getCString())); | (const char*) objectPath.toString().getCString())); |
| |
|
// KS_TODO_DELETE_PULL |
|
PEG_TRACE(( |
|
TRC_PROVIDERMANAGER, |
|
Tracer::LEVEL4, |
|
"ProviderMessageHandler::_handleEnumerateInstancesRequest " |
|
"deepInheritance: %s localOnly: %s includeQualifiers: %s " |
|
"includeClassOrigin: %s propertyList: %s", |
|
(const char*)_toString(request->deepInheritance).getCString(), |
|
(const char*)_toString(request->localOnly).getCString(), |
|
(const char*)_toString(request->includeQualifiers).getCString(), |
|
(const char*)_toString(request->includeClassOrigin).getCString(), |
|
(const char*)request->propertyList.toString().getCString() )); |
|
|
OperationContext providerContext( | OperationContext providerContext( |
_createProviderOperationContext(request->operationContext)); | _createProviderOperationContext(request->operationContext)); |
| |
|
|
"Object path: %s", | "Object path: %s", |
(const char*) objectPath.toString().getCString())); | (const char*) objectPath.toString().getCString())); |
| |
CIMObjectPath resultPath( |
// KS_TODO Confirm that the following is cruft and not needed. |
System::getHostName(), |
// CIMObjectPath resultPath( |
request->nameSpace, |
// System::getHostName(), |
request->resultClass.getString()); |
// request->nameSpace, |
|
// request->resultClass.getString()); |
| |
OperationContext providerContext( | OperationContext providerContext( |
_createProviderOperationContext(request->operationContext)); | _createProviderOperationContext(request->operationContext)); |
|
|
request->messageId, | request->messageId, |
request->nameSpace, | request->nameSpace, |
request->instanceName, | request->instanceName, |
false, // localOnly |
|
false, // includeQualifiers | false, // includeQualifiers |
false, // includeClassOrigin | false, // includeClassOrigin |
propertyList, | propertyList, |
|
|
| |
if (response->cimException.getCode() == CIM_ERR_SUCCESS) | if (response->cimException.getCode() == CIM_ERR_SUCCESS) |
{ | { |
CIMInstance instance = getInstanceResponse->getCimInstance(); |
CIMInstance instance = |
|
getInstanceResponse->getResponseData().getInstance(); |
| |
Uint32 pos = instance.findProperty(request->propertyName); | Uint32 pos = instance.findProperty(request->propertyName); |
| |
|
|
providerContext.insert(request->operationContext.get( | providerContext.insert(request->operationContext.get( |
ContentLanguageListContainer::NAME)); | ContentLanguageListContainer::NAME)); |
| |
AutoPThreadSecurity threadLevelSecurity(providerContext); |
|
|
|
CIMIndicationConsumerProvider* provider = | CIMIndicationConsumerProvider* provider = |
getProviderInterface<CIMIndicationConsumerProvider>(_provider); | getProviderInterface<CIMIndicationConsumerProvider>(_provider); |
| |