diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Object.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Object.cpp | 174 |
1 files changed, 174 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Object.cpp b/TAO/orbsvcs/orbsvcs/Notify/Object.cpp new file mode 100644 index 00000000000..6fcc8cb8495 --- /dev/null +++ b/TAO/orbsvcs/orbsvcs/Notify/Object.cpp @@ -0,0 +1,174 @@ +// $Id$ + +#include "Object.h" +#include "POA_Helper.h" +#include "Worker_Task.h" +#include "Properties.h" +#include "Builder.h" +#include "tao/debug.h" + +#if ! defined (__ACE_INLINE__) +#include "Object.inl" +#endif /* __ACE_INLINE__ */ + +ACE_RCSID(RT_Notify, TAO_NS_Object, "$Id$") + +TAO_NS_Object::TAO_NS_Object (void) + :event_manager_ (0), admin_properties_ (0), id_ (0), poa_ (0), worker_task_ (0), delete_worker_task_ (0), proxy_poa_ (0), delete_proxy_poa_ (0), shutdown_ (0) +{ + if (TAO_debug_level > 1 ) + ACE_DEBUG ((LM_DEBUG,"object:%x created\n", this )); +} + +TAO_NS_Object::~TAO_NS_Object () +{ + if (TAO_debug_level > 1 ) + ACE_DEBUG ((LM_DEBUG,"object:%x destroyed\n", this )); + + this->shutdown_worker_task (); +} + +void +TAO_NS_Object::init (TAO_NS_POA_Helper* poa, TAO_NS_POA_Helper* proxy_poa, TAO_NS_Worker_Task* worker_task) +{ + poa_ = poa; + proxy_poa_ = proxy_poa; + worker_task_ = worker_task; +} + +CORBA::Object_ptr +TAO_NS_Object::activate (ACE_ENV_SINGLE_ARG_DECL) +{ + return poa_->activate (this->servant (), id_ ACE_ENV_ARG_PARAMETER); +} + +void +TAO_NS_Object::deactivate (ACE_ENV_SINGLE_ARG_DECL) +{ + poa_->deactivate (id_ ACE_ENV_ARG_PARAMETER); +} + +void +TAO_NS_Object::shutdown (ACE_ENV_SINGLE_ARG_DECL) +{ + this->shutdown_ = 1; + this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER); +} + +CORBA::Object_ptr +TAO_NS_Object::ref (ACE_ENV_SINGLE_ARG_DECL) +{ + return poa_->id_to_reference (id_ ACE_ENV_ARG_PARAMETER); +} + +void +TAO_NS_Object::shutdown_worker_task (void) +{ + ACE_DECLARE_NEW_CORBA_ENV; + + /// Only do this if we are the owner. + if (delete_worker_task_ == 1) + { + this->worker_task_->shutdown (); + delete this->worker_task_; + } + + if (delete_proxy_poa_ == 1) + { + proxy_poa_->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); + delete proxy_poa_; + } +} + +void +TAO_NS_Object::worker_task_own (TAO_NS_Worker_Task* worker_task) +{ + this->worker_task (worker_task); + + /// claim ownership. + delete_worker_task_ = 1; +} + +void +TAO_NS_Object::worker_task (TAO_NS_Worker_Task* worker_task) +{ + /// shutdown the current worker. + this->shutdown_worker_task (); + + this->worker_task_ = worker_task; + + delete_worker_task_ = 0; +} + + +void +TAO_NS_Object::proxy_poa (TAO_NS_POA_Helper* proxy_poa) +{ + proxy_poa_ = proxy_poa; + delete_proxy_poa_ = 1; +} + +TAO_NS_POA_Helper* +TAO_NS_Object::proxy_poa (void) +{ + return this->proxy_poa_; +} + +void +TAO_NS_Object::set_qos (const CosNotification::QoSProperties & qos ACE_ENV_ARG_DECL) +{ + CosNotification::PropertyErrorSeq err_seq; + + TAO_NS_QoSProperties qos_properties; + + qos_properties.init (qos, err_seq); + + // Init the Worker Task QoS + if (qos_properties.thread_pool ().is_valid ()) + { + TAO_NS_PROPERTIES::instance()->builder ()->apply_threadpool_qos (*this, + qos_properties.thread_pool ().value (), + *this->admin_properties_ + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + } + else if (qos_properties.thread_pool_lane ().is_valid ()) + { + TAO_NS_PROPERTIES::instance()->builder ()-> + apply_threadpool_lane_qos (*this, + qos_properties.thread_pool_lane ().value (), + *this->admin_properties_ + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + } + + // Update the Thread Task's QoS properties.. + this->worker_task_->update_qos_properties (qos_properties); + + // Inform subclasses of QoS changed. + this->qos_changed (qos_properties); + + // Init the the overall QoS on this object. + if (this->qos_properties_.init (qos, err_seq) == 1) // Unsupported Property + ACE_THROW (CosNotification::UnsupportedQoS (err_seq)); +} + +CosNotification::QoSProperties* +TAO_NS_Object::get_qos (ACE_ENV_SINGLE_ARG_DECL) +{ + CosNotification::QoSProperties_var properties; + + ACE_NEW_THROW_EX (properties, + CosNotification::QoSProperties (), + CORBA::NO_MEMORY ()); + + this->qos_properties_.populate (properties); + + return properties._retn (); +} + +void +TAO_NS_Object::qos_changed (const TAO_NS_QoSProperties& /*qos_properties*/) +{ + // NOP. +} |