1 // Copyright (C) 2015-2022 CEA/DEN, EDF R&D, OPEN CASCADE
3 // This library is free software; you can redistribute it and/or
4 // modify it under the terms of the GNU Lesser General Public
5 // License as published by the Free Software Foundation; either
6 // version 2.1 of the License, or (at your option) any later version.
8 // This library is distributed in the hope that it will be useful,
9 // but WITHOUT ANY WARRANTY; without even the implied warranty of
10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 // Lesser General Public License for more details.
13 // You should have received a copy of the GNU Lesser General Public
14 // License along with this library; if not, write to the Free Software
15 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
19 // Author: Adrien Bruneton (CEA)
21 #include "PVServer_ServiceLoader.h"
23 #include <SALOME_LifeCycleCORBA.hxx>
24 #include <SALOME_NamingService.hxx>
25 #include <utilities.h> // MESSAGE() macro
26 #include <SALOMEconfig.h>
27 #include "KernelBasis.hxx"
29 #include CORBA_CLIENT_HEADER(SALOME_ContainerManager)
31 PVServer_ServiceLoader::PVServer_ServiceLoader():
36 SALOME_NamingService_Abstract *ns(nullptr);
39 mySSLNS.reset( new SALOME_Fake_NamingService );
42 myLcc = new SALOME_LifeCycleCORBA(ns);
46 throw PVServer_ServiceLoader_Exception("Unable to instanciate SALOME_LifeCycleCORBA!");
50 PVServer_ServiceLoader::~PVServer_ServiceLoader()
55 SALOME_LifeCycleCORBA* PVServer_ServiceLoader::lcc()
60 std::string PVServer_ServiceLoader::findOrLoadService( const std::string& containerName )
62 std::string ior = findService( containerName );
64 ior = loadService( containerName );
68 std::string PVServer_ServiceLoader::findService( const std::string& containerName )
72 Engines::Container_var container = getContainer( containerName, "get" );
74 if ( !CORBA::is_nil( container ) )
76 CORBA::String_var hName = container->getHostName();
77 CORBA::Object_var obj = lcc()->namingService()->ResolveComponent( hName.in(),
78 containerName.c_str(),
81 if ( !CORBA::is_nil( obj ) )
83 CORBA::ORB_var orb = lcc()->orb();
84 CORBA::String_var cIor = orb->object_to_string( obj );
91 MESSAGE( "PVServer_ServiceLoader::findService(): Service NOT found!" );
95 MESSAGE( "PVServer_ServiceLoader::findService(): Service found!" );
101 std::string PVServer_ServiceLoader::loadService( const std::string& containerName )
103 std::string ior = "";
105 Engines::Container_var container = getContainer( containerName, "getorstart" );
107 if ( !CORBA::is_nil( container ) )
109 CORBA::String_var cReason;
110 CORBA::String_var cIor = container->create_python_service_instance( "PVSERVER", cReason.out() );
111 std::string reason = cReason.in();
115 MESSAGE( "PVServer_ServiceLoader::loadService(): Python service instance could not be created!" );
116 MESSAGE( "PVServer_ServiceLoader::loadService(): " << reason );
120 MESSAGE( "PVServer_ServiceLoader::loadService(): Container and service loaded!" );
126 MESSAGE( "PVServer_ServiceLoader::loadService(): Container could not be retrieved!" );
131 Engines::Container_ptr PVServer_ServiceLoader::getContainer( const std::string& containerName,
132 const std::string& mode )
134 Engines::ContainerParameters params;
135 params.isMPI = false;
136 params.mode = CORBA::string_dup( mode.c_str() );
138 int rg = containerName.find( "/" );
141 params.container_name = CORBA::string_dup( containerName.c_str() );
145 params.resource_params.hostname = CORBA::string_dup( containerName.substr(0, rg).c_str() );
146 params.container_name = CORBA::string_dup( containerName.substr(rg+1).c_str() );
149 Engines::ContainerManager_var cm = lcc()->getContainerManager();
150 Engines::Container_var container = cm->GiveContainer( params );
151 return container._retn();