|
version 1.7, 2006/01/30 16:17:48
|
version 1.8, 2006/07/11 18:39:33
|
|
|
|
| #include <Pegasus/Common/ArrayInternal.h> | #include <Pegasus/Common/ArrayInternal.h> |
| #include <Pegasus/Common/System.h> | #include <Pegasus/Common/System.h> |
| #include <Pegasus/Common/Thread.h> | #include <Pegasus/Common/Thread.h> |
| #include <Pegasus/Common/DQueue.h> |
#include <Pegasus/Common/List.h> |
| |
#include <Pegasus/Common/RecursiveMutex.h> |
| #include <Pegasus/DynListener/Linkage.h> | #include <Pegasus/DynListener/Linkage.h> |
| #include <Pegasus/Provider/CIMOMHandle.h> | #include <Pegasus/Provider/CIMOMHandle.h> |
| |
|
| #include "DynamicConsumerFacade.h" | #include "DynamicConsumerFacade.h" |
| #include "ConsumerModule.h" | #include "ConsumerModule.h" |
| | |
|
|
|
| * of the CIMIndicationConsumer interface. Additionally, we need to store the number of retries in order to resend | * of the CIMIndicationConsumer interface. Additionally, we need to store the number of retries in order to resend |
| * indications if the consumer fails. | * indications if the consumer fails. |
| */ | */ |
| class PEGASUS_DYNLISTENER_LINKAGE IndicationDispatchEvent |
class PEGASUS_DYNLISTENER_LINKAGE IndicationDispatchEvent : public Linkable |
| { | { |
| public: | public: |
| | |
|
|
|
| friend class ConsumerManager; | friend class ConsumerManager; |
| | |
| //indication queue | //indication queue |
| DQueue<IndicationDispatchEvent> _eventqueue; |
List<IndicationDispatchEvent,RecursiveMutex> _eventqueue; |
| | |
| //this mutex controls the state of the consumer to ensure it is not initializing, terminating, etc at the same time | //this mutex controls the state of the consumer to ensure it is not initializing, terminating, etc at the same time |
| //ATTN: Do we need this? The ConsumerManager will be controlling the status of the consumers. | //ATTN: Do we need this? The ConsumerManager will be controlling the status of the consumers. |
Return to
DynamicConsumer.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / DynListener