TAO_CEC_SupplierAdmin Class Reference

ProxyPushSupplier. More...

#include <CEC_SupplierAdmin.h>

Collaboration diagram for TAO_CEC_SupplierAdmin:


Public Member Functions
	TAO_CEC_SupplierAdmin (TAO_CEC_EventChannel *event_channel)
	constructor...
virtual	~TAO_CEC_SupplierAdmin (void)
	destructor...
void	for_each (TAO_ESF_Worker< TAO_CEC_ProxyPushConsumer > *worker)
	For each elements call <worker->work()>.
void	for_each (TAO_ESF_Worker< TAO_CEC_ProxyPullConsumer > *worker)
	For each elements call <worker->work()>.
virtual void	connected (TAO_CEC_ProxyPushConsumer *)
	Keep track of connected consumers.
virtual void	reconnected (TAO_CEC_ProxyPushConsumer *)
virtual void	disconnected (TAO_CEC_ProxyPushConsumer *)
virtual void	connected (TAO_CEC_ProxyPullConsumer *)
virtual void	reconnected (TAO_CEC_ProxyPullConsumer *)
virtual void	disconnected (TAO_CEC_ProxyPullConsumer *)
virtual void	shutdown (void)
virtual CosEventChannelAdmin::ProxyPushConsumer_ptr	obtain_push_consumer (void)
virtual CosEventChannelAdmin::ProxyPullConsumer_ptr	obtain_pull_consumer (void)
virtual PortableServer::POA_ptr	_default_POA (void)
Private Attributes
TAO_CEC_EventChannel *	event_channel_
	The Event Channel we belong to.
TAO_ESF_Proxy_Admin< TAO_CEC_EventChannel, TAO_CEC_ProxyPushConsumer, CosEventChannelAdmin::ProxyPushConsumer >	push_admin_
	The push and pull aspects are implemented using these classes.
TAO_ESF_Proxy_Admin< TAO_CEC_EventChannel, TAO_CEC_ProxyPullConsumer, CosEventChannelAdmin::ProxyPullConsumer >	pull_admin_
PortableServer::POA_var	default_POA_
	Store the default POA.

Detailed Description

ProxyPushSupplier.

Implement the CosEventChannelAdmin::SupplierAdmin interface. This class is an Abstract Factory for the TAO_CEC_ProxyPushConsumer. = MEMORY MANAGMENT It does not assume ownership of the TAO_CEC_EventChannel object = LOCKING @ TODO No provisions for locking, access must be serialized externally. = TODO

Definition at line 54 of file CEC_SupplierAdmin.h.

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_CEC_SupplierAdmin::TAO_CEC_SupplierAdmin ( TAO_CEC_EventChannel * event_channel )

constructor...

Definition at line 20 of file CEC_SupplierAdmin.cpp.

00021   :  event_channel_ (ec),
00022      push_admin_ (ec),
00023      pull_admin_ (ec)
00024 {
00025   this->default_POA_ =
00026     this->event_channel_->supplier_poa ();
00027 }

TAO_CEC_SupplierAdmin::~TAO_CEC_SupplierAdmin ( void ) [virtual]

destructor...

Definition at line 29 of file CEC_SupplierAdmin.cpp.

00030 {
00031 }

Member Function Documentation

PortableServer::POA_ptr TAO_CEC_SupplierAdmin::_default_POA ( void ) [virtual]

Definition at line 34 of file CEC_SupplierAdmin.cpp.

Referenced by TAO_CEC_EventChannel::shutdown().

00035 {
00036   return PortableServer::POA::_duplicate (this->default_POA_.in ());
00037 }

void TAO_CEC_SupplierAdmin::connected ( TAO_CEC_ProxyPullConsumer * ) [virtual]

Definition at line 58 of file CEC_SupplierAdmin.cpp.

References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::connected(), and pull_admin_.

00059 {
00060   this->pull_admin_.connected (consumer);
00061 }

void TAO_CEC_SupplierAdmin::connected ( TAO_CEC_ProxyPushConsumer * ) [virtual]

Keep track of connected consumers.

Definition at line 40 of file CEC_SupplierAdmin.cpp.

References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::connected(), and push_admin_.

Referenced by TAO_CEC_EventChannel::connected().

00041 {
00042   this->push_admin_.connected (consumer);
00043 }

void TAO_CEC_SupplierAdmin::disconnected ( TAO_CEC_ProxyPullConsumer * ) [virtual]

Definition at line 70 of file CEC_SupplierAdmin.cpp.

References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::disconnected(), and pull_admin_.

00071 {
00072   this->pull_admin_.disconnected (consumer);
00073 }

void TAO_CEC_SupplierAdmin::disconnected ( TAO_CEC_ProxyPushConsumer * ) [virtual]

Definition at line 52 of file CEC_SupplierAdmin.cpp.

References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::disconnected(), and push_admin_.

Referenced by TAO_CEC_EventChannel::disconnected().

00053 {
00054   this->push_admin_.disconnected (consumer);
00055 }

ACE_INLINE void TAO_CEC_SupplierAdmin::for_each ( TAO_ESF_Worker< TAO_CEC_ProxyPullConsumer > * worker )

For each elements call <worker->work()>.

Definition at line 16 of file CEC_SupplierAdmin.inl.

References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::for_each(), and pull_admin_.

00017 {
00018   this->pull_admin_.for_each (worker);
00019 }

TAO_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE void TAO_CEC_SupplierAdmin::for_each ( TAO_ESF_Worker< TAO_CEC_ProxyPushConsumer > * worker )

For each elements call <worker->work()>.

Definition at line 9 of file CEC_SupplierAdmin.inl.

References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::for_each(), and push_admin_.

Referenced by TAO_CEC_Reactive_Pulling_Strategy::handle_timeout(), and TAO_CEC_Reactive_SupplierControl::query_suppliers().

00010 {
00011   this->push_admin_.for_each (worker);
00012 }

CosEventChannelAdmin::ProxyPullConsumer_ptr TAO_CEC_SupplierAdmin::obtain_pull_consumer ( void ) [virtual]

Definition at line 90 of file CEC_SupplierAdmin.cpp.

References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::obtain(), and pull_admin_.

00091 {
00092   return this->pull_admin_.obtain ();
00093 }

CosEventChannelAdmin::ProxyPushConsumer_ptr TAO_CEC_SupplierAdmin::obtain_push_consumer ( void ) [virtual]

Definition at line 84 of file CEC_SupplierAdmin.cpp.

References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::obtain(), and push_admin_.

00085 {
00086   return this->push_admin_.obtain ();
00087 }

void TAO_CEC_SupplierAdmin::reconnected ( TAO_CEC_ProxyPullConsumer * ) [virtual]

Definition at line 64 of file CEC_SupplierAdmin.cpp.

References pull_admin_, and TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::reconnected().

00065 {
00066   this->pull_admin_.reconnected (consumer);
00067 }

void TAO_CEC_SupplierAdmin::reconnected ( TAO_CEC_ProxyPushConsumer * ) [virtual]

Definition at line 46 of file CEC_SupplierAdmin.cpp.

References push_admin_, and TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::reconnected().

Referenced by TAO_CEC_EventChannel::reconnected().

00047 {
00048   this->push_admin_.reconnected (consumer);
00049 }

void TAO_CEC_SupplierAdmin::shutdown ( void ) [virtual]

The event channel is shutting down, inform all the consumers of this

Definition at line 76 of file CEC_SupplierAdmin.cpp.

References pull_admin_, push_admin_, and TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::shutdown().

Referenced by TAO_CEC_EventChannel::shutdown().

00077 {
00078   this->push_admin_.shutdown ();
00079 
00080   this->pull_admin_.shutdown ();
00081 }

Member Data Documentation

PortableServer::POA_var TAO_CEC_SupplierAdmin::default_POA_ [private]

Store the default POA.

Definition at line 106 of file CEC_SupplierAdmin.h.

TAO_CEC_EventChannel* TAO_CEC_SupplierAdmin::event_channel_ [private]

The Event Channel we belong to.

Definition at line 93 of file CEC_SupplierAdmin.h.

TAO_ESF_Proxy_Admin<TAO_CEC_EventChannel, TAO_CEC_ProxyPullConsumer, CosEventChannelAdmin::ProxyPullConsumer> TAO_CEC_SupplierAdmin::pull_admin_ [private]

Definition at line 103 of file CEC_SupplierAdmin.h.

Referenced by connected(), disconnected(), for_each(), obtain_pull_consumer(), reconnected(), and shutdown().

TAO_ESF_Proxy_Admin<TAO_CEC_EventChannel, TAO_CEC_ProxyPushConsumer, CosEventChannelAdmin::ProxyPushConsumer> TAO_CEC_SupplierAdmin::push_admin_ [private]

The push and pull aspects are implemented using these classes.

Definition at line 99 of file CEC_SupplierAdmin.h.

Referenced by connected(), disconnected(), for_each(), obtain_push_consumer(), reconnected(), and shutdown().

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

Generated on Tue Feb 2 17:45:01 2010 for TAO_CosEvent by

1.4.7

TAO_CEC_SupplierAdmin Class Reference

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation