TAO_CosNotification: TAO_Notify_Object class Reference

00036 {
00037   if (TAO_debug_level > 2 )
00038     ACE_DEBUG ((LM_DEBUG,"object:%x  destroyed\n", this ));
00039 
00040   this->destroy_proxy_poa ();
00041   this->destroy_object_poa ();
00042   this->destroy_poa ();
00043 }

00022 : poa_ (0)
00023 , proxy_poa_ (0)
00024 , own_proxy_poa_ (false)
00025 , object_poa_ (0)
00026 , own_object_poa_ (false)
00027 , id_ (0)
00028 , own_worker_task_ (false)
00029 , shutdown_ (false)
00030 {
00031   if (TAO_debug_level > 2 )
00032     ACE_DEBUG ((LM_DEBUG,"object:%x  created\n", this ));
00033 }

00082 {
00083   this->id_ = id;
00084   return this->poa_->activate_with_id (servant, this->id_ ACE_ENV_ARG_PARAMETER);
00085 }

00072 {
00073   return this->poa_->activate (servant, this->id_ ACE_ENV_ARG_PARAMETER);
00074 }

00092 {
00093   ACE_ASSERT( this->admin_properties_.get() != 0 );
00094   return *this->admin_properties_;
00095 }

00037 {
00038   ACE_ASSERT( single != 0 );
00039   this->set_proxy_poa( single );
00040   this->set_object_poa( single );
00041   this->set_poa( single );
00042 
00043   // Maintain ownership of the poa
00044 }

00090 {
00091   ACE_TRY
00092   {
00093     this->poa_->deactivate (this->id_ ACE_ENV_ARG_PARAMETER);
00094     ACE_TRY_CHECK;
00095   }
00096   ACE_CATCHANY
00097   {
00098     // Do not propagate any exceptions
00099     if (TAO_debug_level > 2)
00100     {
00101       ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "(%P|%t)\n");
00102       ACE_DEBUG ((LM_DEBUG, "Could not deactivate object %d\n", this->id_));
00103     }
00104   }
00105   ACE_ENDTRY;
00106 }

00180 {
00181   if (this->object_poa_ != 0)
00182   {
00183     ACE_TRY_NEW_ENV
00184     {
00185       if ( this->object_poa_ == this->proxy_poa_ ) this->proxy_poa_ = 0;
00186       if ( this->object_poa_ == this->poa_ ) this->poa_ = 0;
00187 
00188       if ( this->own_object_poa_ == true )
00189       {
00190         this->own_object_poa_ = false;
00191         ACE_Auto_Ptr< TAO_Notify_POA_Helper > aop( object_poa_ );
00192         this->object_poa_->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
00193         ACE_TRY_CHECK;
00194       }
00195       this->object_poa_ = 0;
00196     }
00197     ACE_CATCHANY
00198     {
00199       if (TAO_debug_level > 2)
00200         ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
00201         "Proxy shutdown error (%P|%t)\n");
00202     }
00203     ACE_ENDTRY;
00204   }
00205 }

00209 {
00210   this->poa_ = 0;
00211 }

00151 {
00152   if (this->proxy_poa_ != 0)
00153   {
00154     ACE_TRY_NEW_ENV
00155     {
00156       if ( this->proxy_poa_ == this->object_poa_ ) this->object_poa_ = 0;
00157       if ( this->proxy_poa_ == this->poa_ ) this->poa_ = 0;
00158 
00159       if ( this->own_proxy_poa_ == true )
00160       {
00161         this->own_proxy_poa_ = false;
00162         ACE_Auto_Ptr< TAO_Notify_POA_Helper > app( object_poa_ );
00163         this->proxy_poa_->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
00164         ACE_TRY_CHECK;
00165       }
00166       this->proxy_poa_ = 0;
00167     }
00168     ACE_CATCHANY
00169     {
00170       if (TAO_debug_level > 2)
00171         ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
00172         "Proxy shutdown error (%P|%t)\n");
00173     }
00174     ACE_ENDTRY;
00175   }
00176 }

00085 {
00086   ACE_ASSERT( this->event_manager_.get() != 0 );
00087   return *this->event_manager_;
00088 }

00316 {
00317   return this->qos_properties_.find (name, value);
00318 }

00300 {
00301   CosNotification::QoSProperties_var properties;
00302 
00303   ACE_NEW_THROW_EX (properties,
00304     CosNotification::QoSProperties (),
00305     CORBA::NO_MEMORY ());
00306 
00307   this->qos_properties_.populate (properties);
00308 
00309   return properties._retn ();
00310 }

00072 {
00073   return this->shutdown_;
00074 }

00009 {
00010   return id_;
00011 }

00025 {
00026   this->set_proxy_poa( parent.proxy_poa() );
00027   this->set_object_poa( parent.object_poa() );
00028   this->set_poa( parent.poa() );
00029 
00030   // Do not take ownership of parent's poas
00031   own_proxy_poa_ = false;
00032   own_object_poa_ = false;
00033 }

00047 {
00048   ACE_ASSERT (parent != 0 && this->event_manager_.get() == 0);
00049 
00050   // Do not use sets to avoid asserts.
00051   // Object must be able to inherit NULL references
00052   // due to current design.
00053   this->event_manager_ = parent->event_manager_;
00054   this->admin_properties_ = parent->admin_properties_;
00055   this->inherit_poas( *parent );
00056   this->worker_task_ = parent->worker_task_;
00057 
00058   // Pass  QoS
00059   parent->qos_properties_.transfer (this->qos_properties_);
00060   this->qos_changed (this->qos_properties_);
00061 }

00360 {
00361   attrs.load (this->qos_properties_.event_reliability ());
00362   attrs.load (this->qos_properties_.connection_reliability ());
00363   attrs.load (this->qos_properties_.priority ());
00364   attrs.load (this->qos_properties_.timeout ());
00365   attrs.load (this->qos_properties_.stop_time_supported ());
00366   attrs.load (this->qos_properties_.maximum_batch_size ());
00367   attrs.load (this->qos_properties_.pacing_interval ());
00368   this->qos_properties_.init ();
00369 }

00060 {
00061   return this->object_poa_;
00062 }

00054 {
00055   return this->poa_;
00056 }

00066 {
00067   return this->proxy_poa_;
00068 }

00323 {
00324   // NOP.
00325 }

00130 {
00131   return this->poa_->id_to_reference (this->id_ ACE_ENV_ARG_PARAMETER);
00132 }

00348 {
00349   add_qos_attr(attrs, this->qos_properties_.event_reliability ());
00350   add_qos_attr(attrs, this->qos_properties_.connection_reliability ());
00351   add_qos_attr(attrs, this->qos_properties_.priority ());
00352   add_qos_attr(attrs, this->qos_properties_.timeout ());
00353   add_qos_attr(attrs, this->qos_properties_.stop_time_supported ());
00354   add_qos_attr(attrs, this->qos_properties_.maximum_batch_size ());
00355   add_qos_attr(attrs, this->qos_properties_.pacing_interval ());
00356 }

00078 {
00079   ACE_ASSERT( admin_properties != 0 );
00080   this->admin_properties_.reset( admin_properties );
00081 }

00065 {
00066   ACE_ASSERT( event_manager != 0 );
00067   this->event_manager_.reset( event_manager );
00068 }

00239 {
00240   // shutdown current object poa.
00241   this->destroy_object_poa ();
00242 
00243   this->object_poa_ = object_poa;
00244 
00245   this->own_object_poa_ = true;
00246 }

00250 {
00251   this->poa_ = poa;
00252 }

00048 {
00049   this->set_poa( this->proxy_poa() );
00050 }

00228 {
00229   // shutdown current proxy poa.
00230   this->destroy_proxy_poa ();
00231 
00232   this->proxy_poa_ = proxy_poa;
00233 
00234   this->own_proxy_poa_ = true;
00235 }

00256 {
00257   CosNotification::PropertyErrorSeq err_seq;
00258 
00259   TAO_Notify_QoSProperties new_qos_properties;
00260 
00261   if (new_qos_properties.init (qos, err_seq) == -1)
00262     ACE_THROW (CORBA::INTERNAL ());
00263 
00264   // Apply the appropriate concurrency QoS
00265   if (new_qos_properties.thread_pool ().is_valid ())
00266   {
00267     if (new_qos_properties.thread_pool ().value ().static_threads == 0)
00268       {
00269         TAO_Notify_PROPERTIES::instance()->builder()->apply_reactive_concurrency (*this ACE_ENV_ARG_PARAMETER);
00270         ACE_CHECK;
00271       }
00272     else
00273       {
00274         TAO_Notify_PROPERTIES::instance()->builder()->
00275         apply_thread_pool_concurrency (*this, new_qos_properties.thread_pool ().value () ACE_ENV_ARG_PARAMETER);
00276         ACE_CHECK;
00277       }
00278   }
00279   else if (new_qos_properties.thread_pool_lane ().is_valid ())
00280     TAO_Notify_PROPERTIES::instance()->builder()->
00281     apply_lane_concurrency (*this, new_qos_properties.thread_pool_lane ().value () ACE_ENV_ARG_PARAMETER);
00282   ACE_CHECK;
00283 
00284   // Update the Thread Task's QoS properties..
00285   this->worker_task_->update_qos_properties (new_qos_properties);
00286 
00287   // Inform subclasses of QoS changed.
00288   this->qos_changed (new_qos_properties);
00289 
00290   // Init the the overall QoS on this object.
00291   if (new_qos_properties.copy (this->qos_properties_) == -1)
00292     ACE_THROW (CORBA::INTERNAL ());
00293 
00294   if (err_seq.length () > 0) // Unsupported Property
00295     ACE_THROW (CosNotification::UnsupportedQoS (err_seq));
00296 }

00215 {
00216   ACE_ASSERT( worker_task != 0 );
00217 
00218   // shutdown the current worker.
00219   this->shutdown_worker_task ();
00220 
00221   this->worker_task_.reset (worker_task);
00222 
00223   this->own_worker_task_ = true;
00224 }

00110 {
00111   {
00112     ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->lock_, 1);
00113 
00114     if (this->shutdown_ == 1)
00115       return 1; // Another thread has already run shutdown.
00116 
00117     this->shutdown_ = 1;
00118   }
00119 
00120   this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
00121   ACE_CHECK_RETURN (1);
00122 
00123   this->shutdown_worker_task ();
00124 
00125   return 0;
00126 }

00136 {
00137   // Only do this if we are the owner.
00138   TAO_Notify_Worker_Task::Ptr task( this->worker_task_ );
00139   this->worker_task_.reset();
00140   if ( task.isSet() )
00141   {
00142     if ( this->own_worker_task_ )
00143     {
00144       task->shutdown ();
00145     }
00146   }
00147 }

00329 {
00330   ACE_ASSERT (worker_task_.get() != 0);
00331   return this->worker_task_->timer ();
00332 }


Public Types
typedef CORBA::Long	ID
	Id for Objects.
Public Member Functions
virtual	~TAO_Notify_Object (void)
	Destructor.
ID	id (void) const
	This Object's ID.
virtual CORBA::Object_ptr	activate (PortableServer::Servant servant)
	Activate.
virtual CORBA::Object_ptr	activate (PortableServer::Servant servant, CORBA::Long id)
	Activate with existing id.
void	deactivate ()
	Deactivate.
int	has_shutdown (void)
	Have we been shutdown. returns 1 if shutdown.
void	execute_task (TAO_Notify_Method_Request &method_request)
CORBA::Object_ptr	ref ()
	Get CORBA Ref.
virtual void	set_qos (const CosNotification::QoSProperties &qos)
	Set the QoS Properties.
CosNotification::QoSProperties *	get_qos ()
	Get the QoS Properties.
bool	find_qos_property_value (const char *name, CosNotification::PropertyValue &value) const
virtual TAO_Notify_Timer *	timer (void)
	Obtain the Timer manager associated with this object.
TAO_Notify_Event_Manager &	event_manager (void)
	Accessor for the Event Manager.
virtual int	shutdown ()
	shutdown. Returns 1 ifif the shutdown was already run once before.
virtual void	load_attrs (const TAO_Notify::NVPList &attrs)
Protected Member Functions
	TAO_Notify_Object (void)
	Constructor.
void	initialize (TAO_Notify_Object *parent)
	Init this object with data from .
void	inherit_poas (TAO_Notify_Object &parent)
	Uses the poas from the supplied object.
void	adopt_poa (TAO_Notify_POA_Helper *single)
	Adopts the supplied poa as all are poas.
void	set_primary_as_proxy_poa ()
	Changes the primary poa to the current proxy poa.
TAO_Notify_POA_Helper *	proxy_poa (void)
	Accessor for the proxy_poa_.
TAO_Notify_POA_Helper *	object_poa (void)
	Accessor for the object_poa_.
TAO_Notify_POA_Helper *	poa (void)
	Get the POA assigned to us.
void	set_event_manager (TAO_Notify_Event_Manager *event_manager)
void	set_admin_properties (TAO_Notify_AdminProperties *admin_properties)
TAO_Notify_AdminProperties &	admin_properties (void)
	Accessor for the Admin Properties.
virtual void	qos_changed (const TAO_Notify_QoSProperties &qos_properties)
	Notification that can be overridden by subclasses to be informed that have been modified.
virtual void	save_attrs (TAO_Notify::NVPList &attrs)
Protected Attributes
TAO_Notify_QoSProperties	qos_properties_
	= Protected data members. QoS Properties.
TAO_SYNCH_MUTEX	lock_
	The mutex to serialize access to state variables.
Private Member Functions
void	set_worker_task (TAO_Notify_Worker_Task *worker_task)
	Set Worker Task. This object assume ownership of the set object.
void	set_proxy_poa (TAO_Notify_POA_Helper *proxy_poa)
	Setting the proxy_poa_ gives ownership to this class.
void	set_object_poa (TAO_Notify_POA_Helper *object_poa)
	Setting the object_poa_ gives ownership to this class.
void	set_poa (TAO_Notify_POA_Helper *object_poa)
	Setting the object_poa_ gives ownership to this class.
void	shutdown_worker_task (void)
	Shutdown the current worker task and delete it if we own it.
void	destroy_proxy_poa (void)
	Shutdown the current proxy poa.
void	destroy_object_poa (void)
	Shutdown the current object poa.
void	destroy_poa (void)
	Shutdown the current poa.
Private Attributes
TAO_Notify_POA_Helper *	poa_
	The POA in which the object is activated.
TAO_Notify_POA_Helper *	proxy_poa_
	The POA in which the proxys are activated.
bool	own_proxy_poa_
TAO_Notify_POA_Helper *	object_poa_
	The POA in which the object's children are activated.
bool	own_object_poa_
ID	id_
	Id assigned to this object.
TAO_Notify_Refcountable_Guard_T< TAO_Notify_Event_Manager >	event_manager_
	The event manager.
TAO_Notify_AdminProperties::Ptr	admin_properties_
	Admin Properties.
TAO_Notify_Worker_Task::Ptr	worker_task_
	Worker Task.
bool	own_worker_task_
bool	shutdown_
	Are we shutdown (i,e. scheduled for destroy).
Friends
class	TAO_Notify_Builder
class	TAO_Notify_RT_Builder

TAO_Notify_Object Class Reference

Public Types

Public Member Functions

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation