diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/EventChannel.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/EventChannel.cpp | 50 |
1 files changed, 19 insertions, 31 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/EventChannel.cpp b/TAO/orbsvcs/orbsvcs/Notify/EventChannel.cpp index a55f5e44f6c..74d4783a14a 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/EventChannel.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/EventChannel.cpp @@ -1,22 +1,20 @@ // $Id$ -#include "orbsvcs/Notify/EventChannel.h" - -#include "orbsvcs/Notify/Container_T.h" -#include "orbsvcs/Notify/EventChannelFactory.h" -#include "orbsvcs/Notify/ConsumerAdmin.h" -#include "orbsvcs/Notify/SupplierAdmin.h" -#include "orbsvcs/Notify/Properties.h" -#include "orbsvcs/Notify/Factory.h" -#include "orbsvcs/Notify/Builder.h" -#include "orbsvcs/Notify/Find_Worker_T.h" -#include "orbsvcs/Notify/Seq_Worker_T.h" -#include "orbsvcs/Notify/Topology_Saver.h" -#include "orbsvcs/Notify/Save_Persist_Worker_T.h" -#include "orbsvcs/Notify/Reconnect_Worker_T.h" -#include "orbsvcs/Notify/Proxy.h" -#include "orbsvcs/Notify/Event_Manager.h" -#include "orbsvcs/Notify/POA_Helper.h" +#include "EventChannel.h" + +#include "Container_T.h" +#include "EventChannelFactory.h" +#include "ConsumerAdmin.h" +#include "SupplierAdmin.h" +#include "Properties.h" +#include "Factory.h" +#include "Builder.h" +#include "Find_Worker_T.h" +#include "Seq_Worker_T.h" +#include "Topology_Saver.h" +#include "Save_Persist_Worker_T.h" +#include "Reconnect_Worker_T.h" +#include "Proxy.h" #include "tao/debug.h" //#define DEBUG_LEVEL 9 @@ -26,8 +24,6 @@ ACE_RCSID(Notify, TAO_Notify_EventChannel, "$Id$") -TAO_BEGIN_VERSIONED_NAMESPACE_DECL - typedef TAO_Notify_Find_Worker_T<TAO_Notify_ConsumerAdmin , CosNotifyChannelAdmin::ConsumerAdmin , CosNotifyChannelAdmin::ConsumerAdmin_ptr @@ -159,6 +155,7 @@ TAO_Notify_EventChannel::init (TAO_Notify::Topology_Parent* parent ACE_ENV_ARG_D this->sa_container().init (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; + // Set the admin properties. TAO_Notify_AdminProperties* admin_properties = 0; ACE_NEW_THROW_EX (admin_properties, @@ -209,10 +206,7 @@ TAO_Notify_EventChannel::release (void) int TAO_Notify_EventChannel::shutdown (ACE_ENV_SINGLE_ARG_DECL) { - int sd_ret = TAO_Notify_Object::shutdown (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK_RETURN (1); - - if (sd_ret == 1) + if (TAO_Notify_Object::shutdown (ACE_ENV_SINGLE_ARG_PARAMETER) == 1) return 1; this->ca_container().shutdown (ACE_ENV_SINGLE_ARG_PARAMETER); @@ -232,18 +226,13 @@ TAO_Notify_EventChannel::destroy (ACE_ENV_SINGLE_ARG_DECL) CORBA::SystemException )) { - TAO_Notify_EventChannel::Ptr guard( this ); + if (this->shutdown (ACE_ENV_SINGLE_ARG_PARAMETER) == 1) + return; - int result = this->shutdown (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - if ( result == 1) - return; this->ecf_->remove (this ACE_ENV_ARG_PARAMETER); ACE_CHECK; - - this->sa_container_.reset( 0 ); - this->ca_container_.reset( 0 ); } void @@ -682,4 +671,3 @@ TAO_Notify_EventChannel::sa_container() return *sa_container_; } -TAO_END_VERSIONED_NAMESPACE_DECL |