#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 () |
Public Attributes | |
virtual CosEventChannelAdmin::ProxyPushConsumer_ptr virtual obtain_push_consumer() ACE_THROW_SPEC((CORBA CosEventChannelAdmin::ProxyPullConsumer_ptr virtual obtain_pull_consumer() ACE_THROW_SPEC((CORBA PortableServer::POA_pt | _default_POA )() |
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. |
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...
Definition at line 20 of file CEC_SupplierAdmin.cpp. References TAO_CEC_EventChannel::supplier_poa().
00021 : event_channel_ (ec), 00022 push_admin_ (ec), 00023 pull_admin_ (ec) 00024 { 00025 this->default_POA_ = 00026 this->event_channel_->supplier_poa (); 00027 } |
|
destructor...
Definition at line 29 of file CEC_SupplierAdmin.cpp.
00030 { 00031 } |
|
Definition at line 61 of file CEC_SupplierAdmin.cpp. References ACE_ENV_ARG_PARAMETER.
00063 { 00064 this->pull_admin_.connected (consumer ACE_ENV_ARG_PARAMETER); 00065 } |
|
Keep track of connected consumers.
Definition at line 40 of file CEC_SupplierAdmin.cpp. References ACE_ENV_ARG_PARAMETER. Referenced by TAO_CEC_EventChannel::connected().
00042 { 00043 this->push_admin_.connected (consumer ACE_ENV_ARG_PARAMETER); 00044 } |
|
Definition at line 75 of file CEC_SupplierAdmin.cpp. References ACE_ENV_ARG_PARAMETER.
00077 { 00078 this->pull_admin_.disconnected (consumer ACE_ENV_ARG_PARAMETER); 00079 } |
|
Definition at line 54 of file CEC_SupplierAdmin.cpp. References ACE_ENV_ARG_PARAMETER. Referenced by TAO_CEC_EventChannel::disconnected().
00056 { 00057 this->push_admin_.disconnected (consumer ACE_ENV_ARG_PARAMETER); 00058 } |
|
For each elements call <worker->work()>.
|
|
For each elements call <worker->work()>.
Referenced by TAO_CEC_Reactive_Pulling_Strategy::handle_timeout(), and TAO_CEC_Reactive_SupplierControl::query_suppliers(). |
|
Definition at line 68 of file CEC_SupplierAdmin.cpp. References ACE_ENV_ARG_PARAMETER.
00070 { 00071 this->pull_admin_.reconnected (consumer ACE_ENV_ARG_PARAMETER); 00072 } |
|
Definition at line 47 of file CEC_SupplierAdmin.cpp. References ACE_ENV_ARG_PARAMETER. Referenced by TAO_CEC_EventChannel::reconnected().
00049 { 00050 this->push_admin_.reconnected (consumer ACE_ENV_ARG_PARAMETER); 00051 } |
|
The event channel is shutting down, inform all the consumers of this Definition at line 82 of file CEC_SupplierAdmin.cpp. References ACE_CHECK, and ACE_ENV_SINGLE_ARG_PARAMETER.
00083 { 00084 this->push_admin_.shutdown (ACE_ENV_SINGLE_ARG_PARAMETER); 00085 ACE_CHECK; 00086 00087 this->pull_admin_.shutdown (ACE_ENV_SINGLE_ARG_PARAMETER); 00088 ACE_CHECK; 00089 } |
|
Definition at line 34 of file CEC_SupplierAdmin.cpp.
00035 {
00036 return PortableServer::POA::_duplicate (this->default_POA_.in ());
00037 }
|
|
Store the default POA.
Definition at line 116 of file CEC_SupplierAdmin.h. |
|
The Event Channel we belong to.
Definition at line 103 of file CEC_SupplierAdmin.h. |
|
Definition at line 113 of file CEC_SupplierAdmin.h. |
|
The push and pull aspects are implemented using these classes.
Definition at line 109 of file CEC_SupplierAdmin.h. |