#include <CEC_TypedSupplierAdmin.h>
Collaboration diagram for TAO_CEC_TypedSupplierAdmin:
Public Member Functions | |
TAO_CEC_TypedSupplierAdmin (TAO_CEC_TypedEventChannel *event_channel) | |
virtual | ~TAO_CEC_TypedSupplierAdmin (void) |
void | for_each (TAO_ESF_Worker< TAO_CEC_TypedProxyPushConsumer > *worker) |
For each elements call <worker->work()>. | |
virtual void | connected (TAO_CEC_TypedProxyPushConsumer *) |
Keep track of connected consumers. | |
virtual void | reconnected (TAO_CEC_TypedProxyPushConsumer *) |
virtual void | disconnected (TAO_CEC_TypedProxyPushConsumer *) |
virtual void | shutdown (void) |
virtual CosTypedEventChannelAdmin::TypedProxyPushConsumer_ptr | obtain_typed_push_consumer (const char *supported_interface) |
virtual CosEventChannelAdmin::ProxyPullConsumer_ptr | obtain_typed_pull_consumer (const char *uses_interface) |
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_TypedEventChannel * | typed_event_channel_ |
The Event Channel we belong to. | |
PortableServer::POA_var | default_POA_ |
Store the default POA. | |
TAO_ESF_Proxy_Admin< TAO_CEC_TypedEventChannel, TAO_CEC_TypedProxyPushConsumer, CosTypedEventChannelAdmin::TypedProxyPushConsumer > | typed_push_admin_ |
The push and pull aspects are implemented using these classes. |
Definition at line 36 of file CEC_TypedSupplierAdmin.h.
TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_CEC_TypedSupplierAdmin::TAO_CEC_TypedSupplierAdmin | ( | TAO_CEC_TypedEventChannel * | event_channel | ) |
Definition at line 14 of file CEC_TypedSupplierAdmin.cpp.
References default_POA_, typed_event_channel_, and TAO_CEC_TypedEventChannel::typed_supplier_poa().
00015 : typed_event_channel_ (ec), 00016 typed_push_admin_ (ec) 00017 { 00018 this->default_POA_ = 00019 this->typed_event_channel_->typed_supplier_poa (); 00020 }
TAO_CEC_TypedSupplierAdmin::~TAO_CEC_TypedSupplierAdmin | ( | void | ) | [virtual] |
PortableServer::POA_ptr TAO_CEC_TypedSupplierAdmin::_default_POA | ( | void | ) | [virtual] |
Definition at line 28 of file CEC_TypedSupplierAdmin.cpp.
Referenced by TAO_CEC_TypedEventChannel::shutdown().
void TAO_CEC_TypedSupplierAdmin::connected | ( | TAO_CEC_TypedProxyPushConsumer * | ) | [virtual] |
Keep track of connected consumers.
Definition at line 34 of file CEC_TypedSupplierAdmin.cpp.
References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::connected(), and typed_push_admin_.
Referenced by TAO_CEC_TypedEventChannel::connected().
00035 { 00036 this->typed_push_admin_.connected (consumer); 00037 }
void TAO_CEC_TypedSupplierAdmin::disconnected | ( | TAO_CEC_TypedProxyPushConsumer * | ) | [virtual] |
Definition at line 46 of file CEC_TypedSupplierAdmin.cpp.
References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::disconnected(), and typed_push_admin_.
Referenced by TAO_CEC_TypedEventChannel::disconnected().
00047 { 00048 this->typed_push_admin_.disconnected (consumer); 00049 }
TAO_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE void TAO_CEC_TypedSupplierAdmin::for_each | ( | TAO_ESF_Worker< TAO_CEC_TypedProxyPushConsumer > * | worker | ) |
For each elements call <worker->work()>.
Definition at line 9 of file CEC_TypedSupplierAdmin.inl.
References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::for_each(), and typed_push_admin_.
00010 { 00011 this->typed_push_admin_.for_each (worker); 00012 }
CosEventChannelAdmin::ProxyPullConsumer_ptr TAO_CEC_TypedSupplierAdmin::obtain_pull_consumer | ( | void | ) | [virtual] |
CosEventChannelAdmin::ProxyPushConsumer_ptr TAO_CEC_TypedSupplierAdmin::obtain_push_consumer | ( | void | ) | [virtual] |
CosEventChannelAdmin::ProxyPullConsumer_ptr TAO_CEC_TypedSupplierAdmin::obtain_typed_pull_consumer | ( | const char * | uses_interface | ) | [virtual] |
CosTypedEventChannelAdmin::TypedProxyPushConsumer_ptr TAO_CEC_TypedSupplierAdmin::obtain_typed_push_consumer | ( | const char * | supported_interface | ) | [virtual] |
Definition at line 58 of file CEC_TypedSupplierAdmin.cpp.
References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::obtain(), TAO_CEC_TypedEventChannel::supplier_register_supported_interface(), typed_event_channel_, and typed_push_admin_.
00062 { 00063 int result = this->typed_event_channel_->supplier_register_supported_interface (supported_interface); 00064 00065 if (result == -1) 00066 { 00067 throw CosTypedEventChannelAdmin::InterfaceNotSupported (); 00068 } 00069 00070 return this->typed_push_admin_.obtain (); 00071 }
void TAO_CEC_TypedSupplierAdmin::reconnected | ( | TAO_CEC_TypedProxyPushConsumer * | ) | [virtual] |
Definition at line 40 of file CEC_TypedSupplierAdmin.cpp.
References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::reconnected(), and typed_push_admin_.
Referenced by TAO_CEC_TypedEventChannel::reconnected().
00041 { 00042 this->typed_push_admin_.reconnected (consumer); 00043 }
void TAO_CEC_TypedSupplierAdmin::shutdown | ( | void | ) | [virtual] |
The typed event channel is shutting down, inform all the consumers of this
Definition at line 52 of file CEC_TypedSupplierAdmin.cpp.
References TAO_ESF_Proxy_Admin< EVENT_CHANNEL, PROXY, INTERFACE >::shutdown(), and typed_push_admin_.
Referenced by TAO_CEC_TypedEventChannel::shutdown().
00053 { 00054 this->typed_push_admin_.shutdown (); 00055 }
Store the default POA.
Definition at line 80 of file CEC_TypedSupplierAdmin.h.
Referenced by TAO_CEC_TypedSupplierAdmin().
The Event Channel we belong to.
Definition at line 77 of file CEC_TypedSupplierAdmin.h.
Referenced by obtain_typed_push_consumer(), and TAO_CEC_TypedSupplierAdmin().
TAO_ESF_Proxy_Admin<TAO_CEC_TypedEventChannel, TAO_CEC_TypedProxyPushConsumer, CosTypedEventChannelAdmin::TypedProxyPushConsumer> TAO_CEC_TypedSupplierAdmin::typed_push_admin_ [private] |
The push and pull aspects are implemented using these classes.
Definition at line 86 of file CEC_TypedSupplierAdmin.h.
Referenced by connected(), disconnected(), for_each(), obtain_typed_push_consumer(), reconnected(), and shutdown().