diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h | 20 |
1 files changed, 3 insertions, 17 deletions
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h index bede8d09893..1aefc64bb71 100644 --- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h +++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h @@ -25,7 +25,7 @@ # pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ -#include "orbsvcs/ESF/ESF_Worker.h" +#include "orbsvcs/orbsvcs/ESF/ESF_Worker.h" #include "tao/ORB.h" @@ -47,7 +47,7 @@ class TAO_CEC_TypedEventChannel; * periodically wakeup and verify the state of the suppliers * registered with the Event Channel. */ -class TAO_Event_Serv_Export TAO_CEC_SupplierControl_Adapter +class TAO_Event_Export TAO_CEC_SupplierControl_Adapter : public ACE_Event_Handler { public: @@ -74,7 +74,7 @@ private: * = LOCKING * = TODO */ -class TAO_Event_Serv_Export TAO_CEC_Reactive_SupplierControl +class TAO_Event_Export TAO_CEC_Reactive_SupplierControl : public TAO_CEC_SupplierControl { public: @@ -82,7 +82,6 @@ public: /// parameter. TAO_CEC_Reactive_SupplierControl (const ACE_Time_Value &rate, const ACE_Time_Value &timeout, - unsigned int retries, TAO_CEC_EventChannel *event_channel, CORBA::ORB_ptr orb); @@ -91,7 +90,6 @@ public: TAO_CEC_Reactive_SupplierControl ( const ACE_Time_Value &rate, const ACE_Time_Value &timeout, - unsigned int retries, TAO_CEC_TypedEventChannel *typed_event_channel, CORBA::ORB_ptr orb ); @@ -119,15 +117,6 @@ public: CORBA::SystemException & ACE_ENV_ARG_DECL_NOT_USED); - /// 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. - virtual bool need_to_disconnect (PortableServer::ServantBase* proxy); - - /// Allow others to inform us when a send or receive was successful. - virtual void successful_transmission (PortableServer::ServantBase* proxy); - private: /// Check if the suppliers still exists. It is a helper method for /// handle_timeout() to isolate the exceptions. @@ -140,9 +129,6 @@ private: /// The polling timeout ACE_Time_Value timeout_; - /// The number of retries per proxy until it is disconnected - unsigned int retries_; - /// The Adapter for the reactor events TAO_CEC_SupplierControl_Adapter adapter_; |