TAO_CosNotification  2.3.4
Public Member Functions | Protected Member Functions | Protected Attributes | Private Member Functions | Private Attributes | List of all members
TAO_Notify_StructuredPushConsumer Class Reference

Wrapper for the StructuredPushConsumer that connect to the EventChannel. More...

#include <StructuredPushConsumer.h>

Inheritance diagram for TAO_Notify_StructuredPushConsumer:
Inheritance graph
[legend]
Collaboration diagram for TAO_Notify_StructuredPushConsumer:
Collaboration graph
[legend]

Public Member Functions

 TAO_Notify_StructuredPushConsumer (TAO_Notify_ProxySupplier *proxy)
 Constructor. More...
 
void init (CosNotifyComm::StructuredPushConsumer_ptr push_consumer)
 Init the Consumer. More...
 
virtual ~TAO_Notify_StructuredPushConsumer ()
 Destructor. More...
 
virtual void push (const CORBA::Any &event)
 Push <event> to this consumer. More...
 
virtual void push (const CosNotification::StructuredEvent &event)
 Push <event> to this consumer. More...
 
virtual void push (const CosNotification::EventBatch &event)
 Push a batch of events to this consumer. More...
 
virtual ACE_CString get_ior (void) const
 Retrieve the ior of this peer. More...
 
virtual void reconnect_from_consumer (TAO_Notify_Consumer *old_consumer)
 
- Public Member Functions inherited from TAO_Notify_Consumer
 TAO_Notify_Consumer (TAO_Notify_ProxySupplier *proxy)
 Constructor. More...
 
virtual ~TAO_Notify_Consumer ()
 Destructor. More...
 
CORBA::ULong _incr_refcnt (void)
 This method sigantures deliberately match the RefCounting methods required for ESF Proxy. More...
 
CORBA::ULong _decr_refcnt (void)
 
TAO_Notify_ProxySupplierproxy_supplier (void)
 Access Specific Proxy. More...
 
virtual TAO_Notify_Proxyproxy (void)
 Access Base Proxy. More...
 
void deliver (TAO_Notify_Method_Request_Event *request)
 Dispatch Event to consumer. More...
 
DispatchStatus dispatch_batch (const CosNotification::EventBatch &batch)
 Dispatch the batch of events to the attached consumer. More...
 
void dispatch_pending (void)
 Dispatch the pending events. More...
 
CORBA::Boolean is_suspended (void)
 Is the connection suspended? More...
 
void suspend (void)
 Suspend Connection. More...
 
void resume (void)
 Resume Connection. More...
 
virtual void shutdown (void)
 Shutdown the consumer. More...
 
virtual void qos_changed (const TAO_Notify_QoSProperties &qos_properties)
 Override, Peer::qos_changed. More...
 
void assume_pending_events (TAO_Notify_Consumer &rhs)
 
bool is_alive (bool allow_nil_consumer)
 Is the connected consumer still around? More...
 
size_t pending_count (void)
 
- Public Member Functions inherited from TAO_Notify_Peer
 TAO_Notify_Peer (void)
 Constructor. More...
 
virtual ~TAO_Notify_Peer ()
 Destructor. More...
 
CORBA::ULong _incr_refcnt (void)
 
CORBA::ULong _decr_refcnt (void)
 
virtual void dispatch_updates (const TAO_Notify_EventTypeSeq &added, const TAO_Notify_EventTypeSeq &removed)
 
void handle_dispatch_exception (void)
 Handle dispatch exceptions. More...
 
- Public Member Functions inherited from ACE_Event_Handler
virtual ~ACE_Event_Handler (void)
 
virtual ACE_HANDLE get_handle (void) const
 
virtual void set_handle (ACE_HANDLE)
 
virtual int priority (void) const
 
virtual void priority (int priority)
 
virtual int handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE)
 
virtual int handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)
 
virtual int handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE)
 
virtual int handle_exit (ACE_Process *)
 
virtual int handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask)
 
virtual int handle_signal (int signum, siginfo_t *=0, ucontext_t *=0)
 
virtual int resume_handler (void)
 
virtual int handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
 
virtual int handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
 
virtual void reactor (ACE_Reactor *reactor)
 
virtual ACE_Reactorreactor (void) const
 
virtual ACE_Reactor_Timer_Interfacereactor_timer_interface (void) const
 
virtual Reference_Count add_reference (void)
 
virtual Reference_Count remove_reference (void)
 
Reference_Counting_Policyreference_counting_policy (void)
 

Protected Member Functions

virtual CORBA::Object_ptr get_consumer (void)
 
- Protected Member Functions inherited from TAO_Notify_Consumer
DispatchStatus dispatch_request (TAO_Notify_Method_Request_Event *request)
 
virtual bool dispatch_from_queue (Request_Queue &requests, ACE_Guard< TAO_SYNCH_MUTEX > &ace_mon)
 Attempt to dispatch event from a queue. More...
 
void enqueue_request (TAO_Notify_Method_Request_Event *request)
 
virtual bool enqueue_if_necessary (TAO_Notify_Method_Request_Event *request)
 
virtual void dispatch_updates_i (const CosNotification::EventTypeSeq &added, const CosNotification::EventTypeSeq &removed)
 Implementation of Peer specific dispatch_updates. More...
 
TAO_SYNCH_MUTEXproxy_lock (void)
 Get the shared Proxy Lock. More...
 
virtual int handle_timeout (const ACE_Time_Value &current_time, const void *act=0)
 
void schedule_timer (bool is_error=false)
 Schedule timer. More...
 
void cancel_timer (void)
 Cancel timer. More...
 
Request_Queuepending_events ()
 = Protected Data Members More...
 
- Protected Member Functions inherited from ACE_Event_Handler
 ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)
 

Protected Attributes

CosNotifyComm::StructuredPushConsumer_var push_consumer_
 The Consumer. More...
 
- Protected Attributes inherited from TAO_Notify_Consumer
TAO_Notify_ProxySupplierproxy_
 The Proxy that we associate with. More...
 
CORBA::Boolean is_suspended_
 Suspended Flag. More...
 
CosNotifyComm::NotifyPublish_var publish_
 Interface that accepts offer_changes. More...
 
bool have_not_yet_verified_publish_
 
const TAO_Notify_Property_Timepacing_
 The Pacing Interval. More...
 
TAO_Notify_Property_Long max_batch_size_
 Max. batch size. More...
 
long timer_id_
 Timer Id. More...
 
TAO_Notify_Timer::Ptr timer_
 The Timer Manager that we use. More...
 
ACE_Atomic_Op< TAO_SYNCH_MUTEX, ACE_Time_Valuelast_ping_
 
- Protected Attributes inherited from ACE_Event_Handler
Atomic_Reference_Count reference_count_
 

Private Member Functions

virtual void release (void)
 Release. More...
 

Private Attributes

int connection_valid
 Connection valid flag. More...
 

Additional Inherited Members

- Public Types inherited from TAO_Notify_Consumer
enum  DispatchStatus {
  DISPATCH_SUCCESS, DISPATCH_RETRY, DISPATCH_DISCARD, DISPATCH_FAIL,
  DISPATCH_FAIL_TIMEOUT
}
 Status returned from dispatch attempts. More...
 
typedef TAO_Notify_Refcountable_Guard_T< TAO_Notify_ConsumerPtr
 
- Public Types inherited from TAO_Notify_Peer
typedef TAO_Notify_Refcountable_Guard_T< TAO_Notify_PeerPtr
 
- Public Types inherited from ACE_Event_Handler
typedef long Reference_Count
 
- Static Public Member Functions inherited from ACE_Event_Handler
static ACE_THR_FUNC_RETURN read_adapter (void *event_handler)
 
static int register_stdin_handler (ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)
 
static int remove_stdin_handler (ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr)
 
- Public Attributes inherited from ACE_Event_Handler
 LO_PRIORITY
 
 HI_PRIORITY
 
 NULL_MASK
 
 READ_MASK
 
 WRITE_MASK
 
 EXCEPT_MASK
 
 ACCEPT_MASK
 
 CONNECT_MASK
 
 TIMER_MASK
 
 QOS_MASK
 
 GROUP_QOS_MASK
 
 SIGNAL_MASK
 
 ALL_EVENTS_MASK
 
 RWE_MASK
 
 DONT_CALL
 
 ACE_EVENT_HANDLER_NOT_RESUMED
 
 ACE_REACTOR_RESUMES_HANDLER
 
 ACE_APPLICATION_RESUMES_HANDLER
 
- Protected Types inherited from TAO_Notify_Consumer
typedef ACE_Unbounded_Queue< TAO_Notify_Method_Request_Event_Queueable * > Request_Queue
 
- Protected Types inherited from ACE_Event_Handler
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_CountAtomic_Reference_Count
 

Detailed Description

Wrapper for the StructuredPushConsumer that connect to the EventChannel.

Constructor & Destructor Documentation

TAO_Notify_StructuredPushConsumer::TAO_Notify_StructuredPushConsumer ( TAO_Notify_ProxySupplier proxy)

Constructor.

TAO_Notify_StructuredPushConsumer::~TAO_Notify_StructuredPushConsumer ( )
virtual

Destructor.

Member Function Documentation

CORBA::Object_ptr TAO_Notify_StructuredPushConsumer::get_consumer ( void  )
protectedvirtual

This method is called by the is_alive() method. It should provide the connected consumer or nil if there is none.

Implements TAO_Notify_Consumer.

ACE_CString TAO_Notify_StructuredPushConsumer::get_ior ( void  ) const
virtual

Retrieve the ior of this peer.

Implements TAO_Notify_Peer.

void TAO_Notify_StructuredPushConsumer::init ( CosNotifyComm::StructuredPushConsumer_ptr  push_consumer)

Init the Consumer.

void TAO_Notify_StructuredPushConsumer::push ( const CORBA::Any &  event)
virtual

Push <event> to this consumer.

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_StructuredPushConsumer::push ( const CosNotification::StructuredEvent event)
virtual

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_StructuredPushConsumer::push ( const CosNotification::EventBatch event)
virtual

Push a batch of events to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_StructuredPushConsumer::reconnect_from_consumer ( TAO_Notify_Consumer old_consumer)
virtual

on reconnect we need to move events from the old consumer to the new one

Implements TAO_Notify_Consumer.

void TAO_Notify_StructuredPushConsumer::release ( void  )
privatevirtual

Release.

Implements TAO_Notify_Peer.

Member Data Documentation

int TAO_Notify_StructuredPushConsumer::connection_valid
private

Connection valid flag.

CosNotifyComm::StructuredPushConsumer_var TAO_Notify_StructuredPushConsumer::push_consumer_
protected

The Consumer.


The documentation for this class was generated from the following files: