1 files changed, 170 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Lifetime_Utils.inl b/TAO/orbsvcs/orbsvcs/Event/EC_Lifetime_Utils.inl
new file mode 100644
index 00000000000..87b31282a2d
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Event/EC_Lifetime_Utils.inl
@@ -0,0 +1,170 @@
+// -*- C++ -*-
+//
+// $Id$
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+ACE_INLINE
+TAO_EC_Object_Deactivator::TAO_EC_Object_Deactivator (void)
+  : poa_ ()
+  , id_ ()
+  , deactivate_ (0)
+{
+}
+
+ACE_INLINE
+TAO_EC_Object_Deactivator::TAO_EC_Object_Deactivator (
+                                        PortableServer::POA_ptr poa,
+                                        PortableServer::ObjectId const & id)
+  : poa_ (PortableServer::POA::_duplicate (poa))
+  , id_ (id)
+  , deactivate_ (1)
+{
+}
+
+ACE_INLINE void
+TAO_EC_Object_Deactivator::deactivate (void)
+{
+  if (this->deactivate_ && !CORBA::is_nil (this->poa_.in ()))
+  {
+    try
+    {
+      this->deactivate_ = 0;
+      this->poa_->deactivate_object (id_);
+    }
+    catch (const CORBA::Exception&)
+    {
+      // The deactivation can throw...
+    }
+  }
+}
+
+ACE_INLINE
+TAO_EC_Object_Deactivator::~TAO_EC_Object_Deactivator (void)
+{
+  this->deactivate ();
+}
+
+ACE_INLINE PortableServer::POA_var
+TAO_EC_Object_Deactivator::poa (void) const
+{
+  return this->poa_;
+}
+
+ACE_INLINE void
+TAO_EC_Object_Deactivator::allow_deactivation (void)
+{
+  this->deactivate_ = 1;
+}
+
+ACE_INLINE void
+TAO_EC_Object_Deactivator::disallow_deactivation (void)
+{
+  this->deactivate_ = 0;
+}
+
+ACE_INLINE void
+TAO_EC_Object_Deactivator::set_values (PortableServer::POA_ptr poa,
+                                       PortableServer::ObjectId const & id)
+{
+  this->poa_ = PortableServer::POA::_duplicate (poa);
+  this->id_ = id;
+  this->deactivate_ = 1;
+}
+
+ACE_INLINE void
+TAO_EC_Object_Deactivator::set_values (TAO_EC_Object_Deactivator & deactivator)
+{
+  if (this == &deactivator)
+    return;
+
+  this->poa_ = deactivator.poa_._retn ();
+  this->id_ = deactivator.id_;
+  this->deactivate_ = deactivator.deactivate_;
+  deactivator.deactivate_ = 0;
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_EC_Deactivated_Object::TAO_EC_Deactivated_Object (void)
+  : deactivator_ ()
+{
+}
+
+ACE_INLINE
+TAO_EC_Deactivated_Object::~TAO_EC_Deactivated_Object (void)
+{
+  // Prevent automatic deactivation in deactivator's destructor.
+  this->deactivator_.disallow_deactivation ();
+}
+
+ACE_INLINE void
+TAO_EC_Deactivated_Object::set_deactivator (
+                              TAO_EC_Object_Deactivator & deactivator)
+{
+  this->deactivator_.set_values (deactivator);
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_EC_ORB_Holder::TAO_EC_ORB_Holder (void)
+  : orb_ ()
+{
+}
+
+ACE_INLINE
+TAO_EC_ORB_Holder::~TAO_EC_ORB_Holder (void)
+{
+  if (!CORBA::is_nil (this->orb_.in ()))
+  {
+    try
+      {
+        this->orb_->destroy ();
+      }
+    catch (const CORBA::Exception&)
+      {
+        // Ignore.
+      }
+  }
+}
+
+ACE_INLINE void
+TAO_EC_ORB_Holder::init (CORBA::ORB_var orb_var)
+{
+  this->orb_ = orb_var;
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_EC_Event_Channel_Holder::TAO_EC_Event_Channel_Holder (void)
+  : ec_ ()
+{
+}
+
+ACE_INLINE
+TAO_EC_Event_Channel_Holder::~TAO_EC_Event_Channel_Holder (void)
+{
+  if (!CORBA::is_nil (this->ec_.in ()))
+  {
+    try
+      {
+        this->ec_->destroy ();
+      }
+    catch (const CORBA::Exception&)
+      {
+        // Ignore.
+      }
+  }
+}
+
+ACE_INLINE void
+TAO_EC_Event_Channel_Holder::init (
+                    RtecEventChannelAdmin::EventChannel_var ec_var)
+{
+  this->ec_ = ec_var;
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL