---

TAO_Notify_SequenceProxyPushSupplier_i Class Reference

Implements CosNotifyChannelAdmin::SequenceProxyPushSupplier. More...

#include <Notify_SequenceProxyPushSupplier_i.h>

Inheritance diagram for TAO_Notify_SequenceProxyPushSupplier_i:

[legend]Collaboration diagram for TAO_Notify_SequenceProxyPushSupplier_i:

[legend]List of all members.

Public Methods
	TAO_Notify_SequenceProxyPushSupplier_i (TAO_Notify_ConsumerAdmin_i *consumer_admin)
	Constructor. More...
virtual	~TAO_Notify_SequenceProxyPushSupplier_i (void)
	Destructor. More...
virtual void	connect_sequence_push_consumer (CosNotifyComm::SequencePushConsumer_ptr push_consumer ACE_ENV_ARG_DECL) throw ( CORBA::SystemException, CosEventChannelAdmin::AlreadyConnected, CosEventChannelAdmin::TypeError )
virtual void	disconnect_sequence_push_supplier (ACE_ENV_SINGLE_ARG_DECL) throw ( CORBA::SystemException )
virtual void	shutdown (ACE_ENV_SINGLE_ARG_DECL)
	Shutdown. More...
Protected Methods
virtual void	dispatch_event_i (TAO_Notify_Event &event ACE_ENV_ARG_DECL)
	Deliver the event to the consumer. More...
virtual void	dispatch_update_i (CosNotification::EventTypeSeq added, CosNotification::EventTypeSeq removed ACE_ENV_ARG_DECL)
	Deliver the update to the consumer. More...
void	setup_qos_policies (ACE_ENV_SINGLE_ARG_DECL)
	Do what we need to do after the qos policies are set. More...
virtual int	handle_timeout (const ACE_Time_Value &current_time, const void *act=0)
	When the pacing interval is used, handle_timeout () is called by the reactor. More...
Protected Attributes
CosNotifyComm::SequencePushConsumer_var	push_consumer_
	The consumer that we're connect to. More...
Private Types
typedef TAO_Notify_ProxySupplier< POA_CosNotifyChannelAdmin::SequenceProxyPushSupplier >	proxy_inherited
Private Attributes
CosNotification::EventBatch	event_cache_
	Cache events until maximum batch size is reached. More...
CORBA::Boolean	from_timeout_
	Flag to specify that dispatch_event was called from the timeout. More...
CORBA::Boolean	reset_timeout_flag_
	Flag to specify that dispatch_event_i was successfully called from the timeout handler. More...
ACE_Lock *	batch_lock_
	Lock to synchronize the modification of event_cache_. More...

---

Detailed Description

Implements CosNotifyChannelAdmin::SequenceProxyPushSupplier.

---

Member Typedef Documentation

typedef TAO_Notify_ProxySupplier<POA_CosNotifyChannelAdmin::SequenceProxyPushSupplier> TAO_Notify_SequenceProxyPushSupplier_i::proxy_inherited [private]

---

Constructor & Destructor Documentation

TAO_Notify_SequenceProxyPushSupplier_i::TAO_Notify_SequenceProxyPushSupplier_i (  TAO_Notify_ConsumerAdmin_i *    consumer_admin )

Constructor.

TAO_Notify_SequenceProxyPushSupplier_i::~TAO_Notify_SequenceProxyPushSupplier_i (  void    )  [virtual]

Destructor.

---

Member Function Documentation

void TAO_Notify_SequenceProxyPushSupplier_i::connect_sequence_push_consumer (  CosNotifyComm::SequencePushConsumer_ptr push_consumer    ACE_ENV_ARG_DECL )  throw ( CORBA::SystemException, CosEventChannelAdmin::AlreadyConnected, CosEventChannelAdmin::TypeError ) [virtual]

void TAO_Notify_SequenceProxyPushSupplier_i::disconnect_sequence_push_supplier (  ACE_ENV_SINGLE_ARG_DECL    )  throw ( CORBA::SystemException ) [virtual]

virtual void TAO_Notify_SequenceProxyPushSupplier_i::dispatch_event_i (  TAO_Notify_Event &event    ACE_ENV_ARG_DECL )  [protected, virtual]

Deliver the event to the consumer. Reimplemented from TAO_Notify_ProxySupplier.

void TAO_Notify_SequenceProxyPushSupplier_i::dispatch_update_i (  CosNotification::EventTypeSeq    added, CosNotification::EventTypeSeq removed    ACE_ENV_ARG_DECL )  [protected, virtual]

Deliver the update to the consumer. Reimplemented from TAO_Notify_Proxy.

int TAO_Notify_SequenceProxyPushSupplier_i::handle_timeout (  const ACE_Time_Value &    current_time, const void *    act = 0 )  [protected, virtual]

When the pacing interval is used, handle_timeout () is called by the reactor. Reimplemented from ACE_Event_Handler.

void TAO_Notify_SequenceProxyPushSupplier_i::setup_qos_policies (  ACE_ENV_SINGLE_ARG_DECL    )  [protected, virtual]

Do what we need to do after the qos policies are set. Reimplemented from TAO_Notify_Proxy.

void TAO_Notify_SequenceProxyPushSupplier_i::shutdown (  ACE_ENV_SINGLE_ARG_DECL    )  [virtual]

Shutdown. Reimplemented from TAO_Notify_EventListener.

---

Member Data Documentation

ACE_Lock* TAO_Notify_SequenceProxyPushSupplier_i::batch_lock_ [private]

Lock to synchronize the modification of event_cache_.

CosNotification::EventBatch TAO_Notify_SequenceProxyPushSupplier_i::event_cache_ [private]

Cache events until maximum batch size is reached.

CORBA::Boolean TAO_Notify_SequenceProxyPushSupplier_i::from_timeout_ [private]

Flag to specify that dispatch_event was called from the timeout.

CosNotifyComm::SequencePushConsumer_var TAO_Notify_SequenceProxyPushSupplier_i::push_consumer_ [protected]

The consumer that we're connect to.

CORBA::Boolean TAO_Notify_SequenceProxyPushSupplier_i::reset_timeout_flag_ [private]

Flag to specify that dispatch_event_i was successfully called from the timeout handler.

---

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

• Notify_SequenceProxyPushSupplier_i.h
• Notify_SequenceProxyPushSupplier_i.cpp

---