Sometimes destroy of a component ===> hangup

diff --git a/src/ContainersManager/ContainersManager_i.cxx b/src/ContainersManager/ContainersManager_i.cxx
index cddddc8701953957d55cecbb653ab2517b5f93df..fc3abe6da4eaa227dcc620ebfdee013282434242 100644 (file)
--- a/src/ContainersManager/ContainersManager_i.cxx
+++ b/src/ContainersManager/ContainersManager_i.cxx
@@ -109,27 +109,32 @@ void Manager_i::Init( CORBA::ORB_ptr orb ,
 void Manager_i::destroy() {
   MESSAGE( "Manager_i::destroy" ) ;
   int i ;
-  MESSAGE( "Manager_i::destroy " << _ListOfEnginesComponents.size() << " components" ) ;
-  for ( i = 0 ; i < _ListOfEnginesComponents.size() ; i++ ) {
+  Containers::MachineParameters * MyParams = Parameters() ;
+  MyParams->ContainerType = Engines::Undefined ;
+  Engines::ListOfComponents_var aListOfEnginesComponents = FindComponents( *MyParams , "" ) ;
+  Engines::ListOfContainers_var aListOfEnginesContainers = FindContainers( *MyParams ) ;
+  MESSAGE( "Manager_i::destroy " << aListOfEnginesComponents->length() << " components" ) ;
+  for ( i = 0 ; i < aListOfEnginesComponents->length() ; i++ ) {
+    string interfaceName = aListOfEnginesComponents[ i ]->interfaceName() ;
     try {
-//      _NamingService->Destroy_Name( _ListOfComponentsNames[ i ].c_str() ) ;
-      MESSAGE( "Manager_i::destroy try destroy Component " << _ListOfComponentsNames[ i ] ) ;
-      _ListOfEnginesComponents[ i ]->destroy() ;
-      MESSAGE( "Manager_i::destroy Component " << _ListOfComponentsNames[ i ] << " destroyed" ) ;
+      MESSAGE( "Manager_i::destroy trying to destroy Component " << interfaceName ) ;
+      aListOfEnginesComponents[ i ]->destroy() ;
+      MESSAGE( "Manager_i::destroy Component " << interfaceName << " destroyed" ) ;
     }
     catch ( ... ) {
-      MESSAGE( "Manager_i::destroy Component " << _ListOfComponentsNames[ i ] << " failed" ) ;
+      MESSAGE( "Manager_i::destroy Component " << interfaceName << " failed" ) ;
     }
   }
-  MESSAGE( "Manager_i::destroy " << _ListOfEnginesContainers.size() << " containers" ) ;
-  for ( i = 0 ; i < _ListOfEnginesContainers.size() ; i++ ) {
+  MESSAGE( "Manager_i::destroy " << aListOfEnginesContainers->length() << " containers" ) ;
+  for ( i = 0 ; i < aListOfEnginesContainers->length() ; i++ ) {
+    string aContainerName = aListOfEnginesContainers[ i ]->name() ;
     try {
-//      _NamingService->Destroy_Name( _ListOfContainersNames[ i ].c_str() ) ;
-      _ListOfEnginesContainers[ i ]->destroy() ;
-      MESSAGE( "Manager_i::destroy Container " << _ListOfContainersNames[ i ] ) ;
+      MESSAGE( "Manager_i::destroy trying to destroy Container " << aContainerName ) ;
+      aListOfEnginesContainers[ i ]->destroy() ;
+      MESSAGE( "Manager_i::destroy Container " << aContainerName << " destroyed" ) ;
     }
     catch ( ... ) {
-      MESSAGE( "Manager_i::destroy Container " << _ListOfContainersNames[ i ] << " failed" ) ;
+      MESSAGE( "Manager_i::destroy destroy of Container " << aContainerName << " failed" ) ;
     }
   }
   _Poa->deactivate_object(*_Id) ;
@@ -713,13 +718,6 @@ Engines::Container_ptr Manager_i::StartContainer( const Containers::MachineParam
              << MyParams.ContainerName ) ;
     _EnginesContainer = _EnginesContainer->start_impl( MyParams.ContainerName , MyParams.ContainerType ) ;
   }
-  if ( !CORBA::is_nil( _EnginesContainer ) ) {
-    int size = _ListOfEnginesContainers.size() ;
-    _ListOfEnginesContainers.resize( size + 1 ) ;
-    _ListOfContainersNames.resize( size + 1 ) ;
-    _ListOfEnginesContainers[ size ] = Engines::Container::_duplicate( _EnginesContainer ) ;
-    _ListOfContainersNames[ size ] = _EnginesContainer->name() ;
-  }
   return Engines::Container::_duplicate( _EnginesContainer ) ;
 }
 
@@ -911,24 +909,6 @@ Engines::Component_ptr Manager_i::FindOrLoad_ComponentPath( const Containers::Ma
       MESSAGE( "FindOrLoad_ComponentPath Component NOT launched ! " << aFullComponentName ) ;
     }
   }
-  if ( !CORBA::is_nil( _EnginesComponent ) ) {
-    MESSAGE( "Manager_i::FindOrLoad_ComponentPath MutexManager pthread_mutex_lock :" ) ;
-    if ( pthread_mutex_lock( &_MutexManager ) ) {
-      perror("Manager_i::FindOrLoad_ComponentPath MutexManager pthread_mutex_lock ") ;
-      exit( 0 ) ;
-    }
-    MESSAGE( "Manager_i::FindOrLoad_ComponentPath MutexManager pthread_mutex_locked" ) ;
-    int size = _ListOfEnginesComponents.size() ;
-    _ListOfEnginesComponents.resize( size + 1 ) ;
-    _ListOfComponentsNames.resize( size + 1 ) ;
-    _ListOfEnginesComponents[ size ] = Engines::Component::_duplicate( EnginesComponent ) ;
-    _ListOfComponentsNames[ size ] = aFullComponentName ;
-    if ( pthread_mutex_unlock( &_MutexManager ) ) {
-      perror("Manager_i::FindOrLoad_ComponentPath MutexManager pthread_mutex_unlock ") ;
-      exit( 0 ) ;
-    }
-    MESSAGE( "Manager_i::FindOrLoad_ComponentPath MutexManager pthread_mutex_unlocked" ) ;
-  }
   return Engines::Component::_duplicate( EnginesComponent ) ;
 }
 
@@ -1004,29 +984,6 @@ Engines::Component_ptr Manager_i::FindOrLoad_Component( const Containers::Machin
       MESSAGE( "Component NOT launched ! " << aFullComponentName << " load_impl catched" ) ;
     }
   }
-  if ( !CORBA::is_nil( EnginesComponent ) ) {
-    MESSAGE( "Manager_i::FindOrLoad_Component MutexManager pthread_mutex_lock :" ) ;
-    if ( pthread_mutex_lock( &_MutexManager ) ) {
-      perror("Manager_i::FindOrLoad_Component MutexManager pthread_mutex_lock ") ;
-      exit( 0 ) ;
-    }
-    MESSAGE( "Manager_i::FindOrLoad_Component MutexManager pthread_mutex_locked" ) ;
-    int size = _ListOfEnginesComponents.size() ;
-    _ListOfEnginesComponents.resize( size + 1 ) ;
-    _ListOfComponentsNames.resize( size + 1 ) ;
-    _ListOfEnginesComponents[ size ] = Engines::Component::_duplicate( EnginesComponent ) ;
-    _ListOfComponentsNames[ size ] = aFullComponentName ;
-    MESSAGE( "FindOrLoad_Component " << aFullComponentName << " added in listofcomponents" ) ;
-    int i ;
-    for ( i = 0 ; i < size + 1 ; i++ ) {
-      MESSAGE( "FindOrLoad_Component " << i << ". " << _ListOfComponentsNames[ i ] ) ;
-    }
-    if ( pthread_mutex_unlock( &_MutexManager ) ) {
-      perror("Manager_i::FindOrLoad_Component MutexManager pthread_mutex_unlock ") ;
-      exit( 0 ) ;
-    }
-    MESSAGE( "Manager_i::FindOrLoad_Component MutexManager pthread_mutex_unlocked" ) ;
-  }
   return Engines::Component::_duplicate( EnginesComponent ) ;
 }
 //  try {
@@ -1137,6 +1094,9 @@ bool Manager_i::DestroyContainer( const char * aHostName ,
   int i ;
   for ( i = 0 ; i < aListOfComponents->length() ; i++ ) {
     try {
+      MESSAGE( "Manager_i::DestroyContainer trying to destroy component "
+               << aListOfComponents[ i ]->interfaceName() ) ;
+      aListOfComponents[ i ]->ping() ;
       aListOfComponents[ i ]->destroy() ;
       MESSAGE( "Manager_i::DestroyContainer component destroyed" ) ;
     }
@@ -1145,6 +1105,8 @@ bool Manager_i::DestroyContainer( const char * aHostName ,
     }
   }
   try {
+    MESSAGE( "Manager_i::DestroyContainer trying to destroy container " << aContainer->name() ) ;
+    aContainer->ping() ;
     aContainer->destroy() ;
     MESSAGE( "Manager_i::DestroyContainer " << aContainerName << " on " << aHostName
              << " destroyed" ) ;

diff --git a/src/ContainersManager/ContainersManager_i.hxx b/src/ContainersManager/ContainersManager_i.hxx
index b0bcd2d4702f6f45e8a9cec77c7a7ec3ac27c5f7..596db1d2de4cbb39f0966d5e0368a21a6e6bb05e 100644 (file)
--- a/src/ContainersManager/ContainersManager_i.hxx
+++ b/src/ContainersManager/ContainersManager_i.hxx
@@ -83,15 +83,6 @@ class Manager_i : public POA_Containers::Manager ,
     CORBA::Object_var                 _ComponentObject ;
     Engines::Component_var            _EnginesComponent ;
 
-    vector< string >                  _ListOfContainersNames ;
-    vector< Engines::Container_var >  _ListOfEnginesContainers ;
-    vector< string >                  _ListOfComponentsNames ;
-    vector< Engines::Component_var >  _ListOfEnginesComponents ;
-
-//    std::string ContainerName( const char * aComputerContainer ,
-//                               std::string * theComputer ,
-//                               std::string * theContainer ) ;
-
     Engines::Container_ptr StartContainer( const Containers::MachineParameters & myParams ) ;
 
     Engines::ListOfContainers * FindContainersLocked( Containers::MachineParameters & MyParams ) ;

diff --git a/src/ContainersManager/TestContainersManager.py b/src/ContainersManager/TestContainersManager.py
index e2dd9348a9c24986144aab7bcfd8c761332c039c..b524db371d7e7423704cf552edc9a925b85a5ff8 100644 (file)
--- a/src/ContainersManager/TestContainersManager.py
+++ b/src/ContainersManager/TestContainersManager.py
@@ -316,7 +316,7 @@ while i < len( ListOfComponents ) :
     i = i + 1
 
 
-ListOfComponents = MyContainersMgr.FindComponents( DefaultParams , '' )
+ListOfComponents = MyContainersMgr.FindComponents( DefaultParams , 'SubComponent' )
 i = 0
 while i < len( ListOfComponents ) :
     print ListOfComponents[ i ].GetContainerRef()._get_name(),ListOfComponents[ i ]._get_instanceName(),ListOfComponents[ i ]._get_interfaceName()