|
version 1.106, 2003/11/17 19:14:14
|
version 1.107, 2003/11/19 23:14:28
|
|
|
|
| // subscription's OnFatalErrorPolicy | // subscription's OnFatalErrorPolicy |
| // | // |
| | |
| response = |
CIMHandleIndicationResponseMessage* handler_response = |
| reinterpret_cast<CIMProcessIndicationResponseMessage *> |
reinterpret_cast<CIMHandleIndicationResponseMessage *> |
| ((static_cast<AsyncLegacyOperationResult *> | ((static_cast<AsyncLegacyOperationResult *> |
| (async_reply))->get_result()); | (async_reply))->get_result()); |
| |
delete handler_response; |
| | |
| // | // |
| // Recipient deletes request | // Recipient deletes request |
| // | // |
| | |
| delete async_reply; | delete async_reply; |
| |
op->release(); |
| |
this->return_op(op); |
| } | } |
| } | } |
| } | } |
|
|
|
| PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, | PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, |
| "IndicationService::_sendCreateRequests"); | "IndicationService::_sendCreateRequests"); |
| | |
| |
// If there are no providers to accept the subscription, just return |
| |
if (indicationProviders.size() == 0) |
| |
{ |
| |
return; |
| |
} |
| |
|
| // | // |
| // Get repeat notification policy value from subscription instance | // Get repeat notification policy value from subscription instance |
| // | // |
|
|
|
| PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, | PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, |
| "IndicationService::_sendModifyRequests"); | "IndicationService::_sendModifyRequests"); |
| | |
| |
// If there are no providers to accept the subscription update, just return |
| |
if (indicationProviders.size() == 0) |
| |
{ |
| |
return; |
| |
} |
| |
|
| // | // |
| // Get repeat notification policy value from subscription instance | // Get repeat notification policy value from subscription instance |
| // | // |
|
|
|
| PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, | PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, |
| "IndicationService::_sendDeleteRequests"); | "IndicationService::_sendDeleteRequests"); |
| | |
| |
// If there are no providers to delete the subscription, just return |
| |
if (indicationProviders.size() == 0) |
| |
{ |
| |
return; |
| |
} |
| |
|
| CIMRequestMessage * aggRequest; | CIMRequestMessage * aggRequest; |
| | |
| if (origRequest == 0) | if (origRequest == 0) |
|
|
|
| { | { |
| PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, "IndicationService::_sendEnable"); | PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, "IndicationService::_sendEnable"); |
| | |
| |
// If there are no providers to enable, just return |
| |
if (enableProviders.size() == 0) |
| |
{ |
| |
return; |
| |
} |
| |
|
| CIMRequestMessage * aggRequest; | CIMRequestMessage * aggRequest; |
| | |
| if (origRequest == 0) | if (origRequest == 0) |
|
|
|
| PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, | PEG_METHOD_ENTER (TRC_INDICATION_SERVICE, |
| "IndicationService::_sendDisable"); | "IndicationService::_sendDisable"); |
| | |
| |
// If there are no providers to disable, just return |
| |
if (disableProviders.size() == 0) |
| |
{ |
| |
return; |
| |
} |
| |
|
| CIMRequestMessage * aggRequest; | CIMRequestMessage * aggRequest; |
| | |
| if (origRequest == 0) | if (origRequest == 0) |
Return to
IndicationService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / IndicationService