#include <CEC_SupplierControl.h>
Inheritance diagram for TAO_CEC_SupplierControl:
Public Member Functions | |
TAO_CEC_SupplierControl (void) | |
virtual | ~TAO_CEC_SupplierControl (void) |
destructor... | |
virtual int | activate (void) |
virtual int | shutdown (void) |
virtual void | supplier_not_exist (TAO_CEC_ProxyPushConsumer *proxy) |
virtual void | supplier_not_exist (TAO_CEC_ProxyPullConsumer *proxy) |
virtual void | system_exception (TAO_CEC_ProxyPullConsumer *proxy, CORBA::SystemException &) |
Some system exception was rasied while trying to push an event. | |
virtual bool | need_to_disconnect (PortableServer::ServantBase *proxy) |
virtual void | successful_transmission (PortableServer::ServantBase *proxy) |
Allow others to inform us when a send or receive was successful. |
Defines the interface for the supplier control strategy. This strategy handles misbehaving or failing suppliers. = MEMORY MANAGMENT = LOCKING = TODO
Definition at line 58 of file CEC_SupplierControl.h.
|
Constructor. It does not assume ownership of the parameter. Definition at line 9 of file CEC_SupplierControl.cpp.
00010 { 00011 } |
|
destructor...
Definition at line 13 of file CEC_SupplierControl.cpp.
00014 { 00015 } |
|
Activate any internal threads or timers used to poll the state of the suppliers Reimplemented in TAO_CEC_Reactive_SupplierControl. Definition at line 18 of file CEC_SupplierControl.cpp. Referenced by TAO_CEC_TypedEventChannel::activate().
00019 {
00020 return 0;
00021 }
|
|
Do we need to disconnect this supplier? The parameter type for proxy is PortableServer::ServantBase* due to the fact that this method will be used for TAO_CEC_ProxyPushSupplier's and TAO_CEC_ProxyPullSupplier's. Reimplemented in TAO_CEC_Reactive_SupplierControl. Definition at line 57 of file CEC_SupplierControl.cpp. Referenced by TAO_CEC_Ping_Pull_Supplier::work(), and TAO_CEC_Ping_Push_Supplier::work().
00058 { 00059 return true; 00060 } |
|
Reimplemented in TAO_CEC_Reactive_SupplierControl. Definition at line 24 of file CEC_SupplierControl.cpp. Referenced by TAO_CEC_TypedEventChannel::shutdown().
00025 {
00026 return 0;
00027 }
|
|
Allow others to inform us when a send or receive was successful.
Reimplemented in TAO_CEC_Reactive_SupplierControl. Definition at line 63 of file CEC_SupplierControl.cpp. Referenced by TAO_CEC_ProxyPullConsumer::try_pull_from_supplier().
00064 { 00065 } |
|
Invoked by helper classes when they detect that a supplier does not exists (i.e. _non_existent() returns true and/or the CORBA::OBJECT_NOT_EXIST exception has been raised). Reimplemented in TAO_CEC_Reactive_SupplierControl. Definition at line 44 of file CEC_SupplierControl.cpp.
00046 { 00047 } |
|
Invoked by helper classes when they detect that a supplier does not exists (i.e. _non_existent() returns true and/or the CORBA::OBJECT_NOT_EXIST exception has been raised). Reimplemented in TAO_CEC_Reactive_SupplierControl. Definition at line 30 of file CEC_SupplierControl.cpp. Referenced by TAO_CEC_ProxyPullConsumer::try_pull_from_supplier(), TAO_CEC_Ping_Pull_Supplier::work(), and TAO_CEC_Ping_Push_Supplier::work().
00032 { 00033 } |
|
Some system exception was rasied while trying to push an event.
Reimplemented in TAO_CEC_Reactive_SupplierControl. Definition at line 50 of file CEC_SupplierControl.cpp. Referenced by TAO_CEC_ProxyPullConsumer::try_pull_from_supplier().
00053 { 00054 } |