From 8f301c0d9386e2e8fe72e88ce6b07032cd7270e8 Mon Sep 17 00:00:00 2001 From: Ovidiu Mircescu Date: Thu, 2 Sep 2021 11:29:36 +0200 Subject: [PATCH] Shutdown data servers scopes in driver command. --- src/yacsloader/driver.cxx | 36 +++++++++++++++++++++++++++++++----- 1 file changed, 31 insertions(+), 5 deletions(-) diff --git a/src/yacsloader/driver.cxx b/src/yacsloader/driver.cxx index c03dfcd2d..95f0e4de6 100644 --- a/src/yacsloader/driver.cxx +++ b/src/yacsloader/driver.cxx @@ -31,16 +31,14 @@ #include "LinkInfo.hxx" #include "ObserverAsPlugin.hxx" -#ifdef SALOME_KERNEL - #include "KernelBasis.hxx" #include "SALOME_Launcher.hxx" #include "ServiceUnreachable.hxx" #include "SALOME_NamingService_Wrapper.hxx" #include "SALOME_NamingService.hxx" #include "SALOME_ModuleCatalog.hh" +#include "SALOMESDS_DataServerManager.hxx" #include "Basics_Utils.hxx" -#endif #include #include @@ -305,6 +303,33 @@ void InitializeSSL() KERNEL::getLauncherSA(); } +void shutdownServers() +{ + // shutdown data server scopes + try + { + YACS::ENGINE::RuntimeSALOME* runTime = YACS::ENGINE::getSALOMERuntime(); + runTime->loadModulCatalog(); + CORBA::ORB_ptr orb = runTime->getOrb(); + if (orb) + { + SALOME_NamingService_Wrapper namingService(orb); + CORBA::Object_var objDSM(namingService.Resolve(SALOMESDS::DataServerManager::NAME_IN_NS)); + SALOME::DataServerManager_var dsm(SALOME::DataServerManager::_narrow(objDSM)); + if ( !CORBA::is_nil(dsm) ) + dsm->shutdownScopes(); + } + } + catch(const CORBA::Exception& ) + { + // ignore and continue + } + catch(ServiceUnreachable& e) + { + // ignore and continue + } +} + int main (int argc, char* argv[]) { @@ -366,7 +391,6 @@ int main (int argc, char* argv[]) if (orb) { SALOME_NamingService_Wrapper namingService(orb); - //SALOME_NamingService namingService(orb); CORBA::Object_var obj = namingService.Resolve("/Kernel/ModulCatalog"); SALOME_ModuleCatalog::ModuleCatalog_var aModuleCatalog = SALOME_ModuleCatalog::ModuleCatalog::_narrow(obj); if (! CORBA::is_nil(aModuleCatalog)) @@ -502,11 +526,12 @@ int main (int argc, char* argv[]) } if (myArgs.stop) + { if (strlen(myArgs.dumpErrorFile) >0) executor.setStopOnError(true, myArgs.dumpErrorFile); else executor.setStopOnError(false, myArgs.dumpErrorFile); - + } if(myArgs.display>0) { std::ofstream f("toto"); @@ -568,6 +593,7 @@ int main (int argc, char* argv[]) if(myArgs.shutdown < 999) { p->shutdown(myArgs.shutdown); + shutdownServers(); } delete p; Runtime* r=YACS::ENGINE::getRuntime(); -- 2.39.2