|
version 1.1, 2010/07/05 08:58:36
|
version 1.2, 2011/02/22 14:08:31
|
|
|
|
| #include <Pegasus/Common/CIMInstance.h> | #include <Pegasus/Common/CIMInstance.h> |
| #include <Pegasus/Common/OperationContext.h> | #include <Pegasus/Common/OperationContext.h> |
| #include <Pegasus/Common/Mutex.h> | #include <Pegasus/Common/Mutex.h> |
| |
#include <Pegasus/Common/CIMMessage.h> |
| | |
| #include <Pegasus/HandlerService/Linkage.h> | #include <Pegasus/HandlerService/Linkage.h> |
| #include <Pegasus/HandlerService/IndicationHandlerConstants.h> | #include <Pegasus/HandlerService/IndicationHandlerConstants.h> |
|
|
|
| DestinationQueue(const CIMInstance &handler); | DestinationQueue(const CIMInstance &handler); |
| ~DestinationQueue(); | ~DestinationQueue(); |
| | |
| Boolean isIdle(); |
|
| Sint64 getSequenceNumber(); | Sint64 getSequenceNumber(); |
| | |
| String getSequenceContext() | String getSequenceContext() |
|
|
|
| return Uint32(_minDeliveryRetryIntervalUsec / 1000000); | return Uint32(_minDeliveryRetryIntervalUsec / 1000000); |
| } | } |
| | |
| void enqueue(IndicationInfo* message); |
void enqueue( |
| |
CIMHandleIndicationRequestMessage *message); |
| | |
| /** | /** |
| Cleanup all the indications from the DestinationQueue. This method | Cleanup all the indications from the DestinationQueue. This method |
|
|
|
| IndicationInfo* getNextIndicationForDelivery( | IndicationInfo* getNextIndicationForDelivery( |
| Uint64 &timeNowUsec, Uint64 &nextIndDRIExpTimeUsec); | Uint64 &timeNowUsec, Uint64 &nextIndDRIExpTimeUsec); |
| | |
| void updateLastSuccessfulDeliveryTime(); |
|
| |
|
| void getInfo(QueueInfo &qinfo); | void getInfo(QueueInfo &qinfo); |
| |
|
| private: | private: |
| void _cleanup(int reasonCode); | void _cleanup(int reasonCode); |
| CIMInstance _getInstance(const CIMName &className); | CIMInstance _getInstance(const CIMName &className); |
Return to
DestinationQueue.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / HandlerService