#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. |
1.3.6