version 1.61, 2006/02/10 22:20:43
|
version 1.61.2.3, 2007/01/23 18:28:43
|
|
|
request->buildResponse()); | request->buildResponse()); |
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
OperationResponseHandler handler(request, response); |
OperationResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
GetInstanceResponseHandler handler(request, response); |
GetInstanceResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
EnumerateInstancesResponseHandler handler(request, response); |
EnumerateInstancesResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
EnumerateInstanceNamesResponseHandler handler(request, response); |
EnumerateInstanceNamesResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
// process the request | // process the request |
try | try |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
CreateInstanceResponseHandler handler(request, response); |
CreateInstanceResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
ModifyInstanceResponseHandler handler(request, response); |
ModifyInstanceResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
DeleteInstanceResponseHandler handler(request, response); |
DeleteInstanceResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
ExecQueryResponseHandler handler(request, response); |
ExecQueryResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
AssociatorsResponseHandler handler(request, response); |
AssociatorsResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
// process the request | // process the request |
try | try |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
AssociatorNamesResponseHandler handler(request, response); |
AssociatorNamesResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
// process the request | // process the request |
try | try |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
ReferencesResponseHandler handler(request, response); |
ReferencesResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
// process the request | // process the request |
try | try |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
ReferenceNamesResponseHandler handler(request, response); |
ReferenceNamesResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
// process the request | // process the request |
try | try |
|
|
request->buildResponse()); | request->buildResponse()); |
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
GetPropertyResponseHandler handler(request, response); |
GetPropertyResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
request->buildResponse()); | request->buildResponse()); |
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
SetPropertyResponseHandler handler(request, response); |
SetPropertyResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
// create a handler for this request | // create a handler for this request |
InvokeMethodResponseHandler handler(request, response); |
InvokeMethodResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME)); | context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME)); |
context.insert(request->operationContext.get(ContentLanguageListContainer::NAME)); | context.insert(request->operationContext.get(ContentLanguageListContainer::NAME)); |
| |
CIMObjectPath instanceReference(request->instanceName); |
|
|
|
// ATTN: propagate namespace |
|
instanceReference.setNameSpace(request->nameSpace); |
|
|
|
// forward request | // forward request |
STAT_PMS_PROVIDERSTART; | STAT_PMS_PROVIDERSTART; |
| |
|
|
| |
ph.GetProvider().invokeMethod( | ph.GetProvider().invokeMethod( |
context, | context, |
instanceReference, |
objectPath, |
request->methodName, | request->methodName, |
request->inParameters, | request->inParameters, |
handler); | handler); |
|
|
request->buildResponse()); | request->buildResponse()); |
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
OperationResponseHandler handler(request, response); |
OperationResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
request->buildResponse()); | request->buildResponse()); |
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
OperationResponseHandler handler(request, response); |
OperationResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
request->buildResponse()); | request->buildResponse()); |
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
OperationResponseHandler handler(request, response); |
OperationResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
request->buildResponse()); | request->buildResponse()); |
PEGASUS_ASSERT(response != 0); | PEGASUS_ASSERT(response != 0); |
| |
OperationResponseHandler handler(request, response); |
OperationResponseHandler handler( |
|
request, response, _responseChunkCallback); |
| |
try | try |
{ | { |
|
|
if (_indicationProviders[i]) | if (_indicationProviders[i]) |
{ | { |
// | // |
// Reset the indication provider's count of current |
|
// subscriptions since it has been disabled |
|
// |
|
if (physicalName.size () > 0) |
|
{ |
|
OpProviderHolder ph = providerManager.getProvider( |
|
physicalName, pName); |
|
|
|
ph.GetProvider ().resetSubscriptions (); |
|
} |
|
|
|
// |
|
// If it is an indication provider | // If it is an indication provider |
// remove the entry from the table since the | // remove the entry from the table since the |
// provider has been disabled | // provider has been disabled |
|
|
| |
void DefaultProviderManager::_callEnableIndications | void DefaultProviderManager::_callEnableIndications |
(CIMInstance & req_provider, | (CIMInstance & req_provider, |
PEGASUS_INDICATION_CALLBACK _indicationCallback, |
PEGASUS_INDICATION_CALLBACK_T _indicationCallback, |
OpProviderHolder & ph) | OpProviderHolder & ph) |
{ | { |
PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, | PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, |
|
|
CIMRequestMessage * request = 0; | CIMRequestMessage * request = 0; |
CIMResponseMessage * response = 0; | CIMResponseMessage * response = 0; |
EnableIndicationsResponseHandler * enableHandler = | EnableIndicationsResponseHandler * enableHandler = |
new EnableIndicationsResponseHandler |
new EnableIndicationsResponseHandler( |
(request, response, req_provider, _indicationCallback); |
request, |
|
response, |
|
req_provider, |
|
_indicationCallback, |
|
_responseChunkCallback); |
| |
PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4, | PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4, |
"Calling provider.enableIndications: " + | "Calling provider.enableIndications: " + |