1 #include "SALOME_ContainerManager.hxx"
2 #include "SALOME_NamingService.hxx"
8 #define TIME_OUT_TO_LAUNCH_CONT 21
12 const char *SALOME_ContainerManager::_ContainerManagerNameInNS="/ContainerManager";
14 SALOME_ContainerManager::SALOME_ContainerManager(CORBA::ORB_ptr orb)
16 _NS=new SALOME_NamingService(orb);
17 PortableServer::POA_var root_poa=PortableServer::POA::_the_root_poa();
18 PortableServer::POAManager_var pman = root_poa->the_POAManager();
19 PortableServer::POA_var my_poa;
20 CORBA::PolicyList policies;
22 PortableServer::ThreadPolicy_var threadPol=root_poa->create_thread_policy(PortableServer::SINGLE_THREAD_MODEL);
23 policies[0]=PortableServer::ThreadPolicy::_duplicate(threadPol);
24 my_poa=root_poa->create_POA("SThreadPOA",pman,policies);
26 PortableServer::ObjectId_var id=my_poa->activate_object(this);
27 CORBA::Object_var obj=my_poa->id_to_reference(id);
28 Engines::ContainerManager_var refContMan = Engines::ContainerManager::_narrow(obj);
29 _NS->Register(refContMan,_ContainerManagerNameInNS);
32 SALOME_ContainerManager::~SALOME_ContainerManager()
37 void SALOME_ContainerManager::Shutdown()
40 PortableServer::ObjectId_var oid = _default_POA()->servant_to_id(this);
41 _default_POA()->deactivate_object(oid);
46 void SALOME_ContainerManager::ShutdownContainers()
48 _NS->Change_Directory("/Containers");
49 vector<string> vec=_NS->list_directory_recurs();
50 for(vector<string>::iterator iter=vec.begin();iter!=vec.end();iter++)
53 CORBA::Object_var obj=_NS->Resolve((*iter).c_str());
54 Engines::Container_var cont=Engines::Container::_narrow(obj);
55 if(!CORBA::is_nil(cont))
60 Engines::Container_ptr SALOME_ContainerManager::FindOrStartContainer(const char *containerName, const Engines::MachineList& possibleComputers)
62 Engines::Container_ptr ret=FindContainer(containerName,possibleComputers);
63 if(!CORBA::is_nil(ret))
65 // Container doesn't exist try to launch it ...
66 vector<string> vector;
67 string theMachine=_LoadManager.FindBest(possibleComputers);
69 if(theMachine==GetHostname())
70 command=_ResManager.BuildCommandToLaunchLocalContainer(containerName);
72 command=_ResManager.BuildTempFileToLaunchRemoteContainer(theMachine,containerName);
73 _ResManager.RmTmpFile();
74 int status=system(command.c_str());
76 MESSAGE("SALOME_LifeCycleCORBA::StartOrFindContainer rsh failed (system command status -1)");
77 return Engines::Container::_nil();
79 else if (status == 217) {
80 MESSAGE("SALOME_LifeCycleCORBA::StartOrFindContainer rsh failed (system command status 217)");
81 return Engines::Container::_nil();
84 int count=TIME_OUT_TO_LAUNCH_CONT;
85 while ( CORBA::is_nil(ret) && count ) {
89 MESSAGE( count << ". Waiting for FactoryServer on " << theMachine);
90 string containerNameInNS=BuildContainerNameInNS(containerName,theMachine.c_str());
91 SCRUTE(containerNameInNS);
92 CORBA::Object_var obj = _NS->Resolve(containerNameInNS.c_str());
93 ret=Engines::Container::_narrow(obj);
95 if ( CORBA::is_nil(ret) ) {
96 MESSAGE("SALOME_LifeCycleCORBA::StartOrFindContainer rsh failed");
102 Engines::MachineList *SALOME_ContainerManager::GetFittingResources(const Engines::MachineParameters& params, const char *componentName)
104 vector<string> vec=_ResManager.GetFittingResources(params,componentName);
105 Engines::MachineList *ret=new Engines::MachineList;
106 ret->length(vec.size());
107 for(unsigned int i=0;i<vec.size();i++)
109 (*ret)[i]=(vec[i]).c_str();
114 char* SALOME_ContainerManager::FindBest(const Engines::MachineList& possibleComputers)
116 string theMachine=_LoadManager.FindBest(possibleComputers);
117 return CORBA::string_dup(theMachine.c_str());
120 Engines::Container_ptr SALOME_ContainerManager::FindContainer(const char *containerName,const char *theMachine)
122 string containerNameInNS(BuildContainerNameInNS(containerName,theMachine));
123 SCRUTE(containerNameInNS);
124 CORBA::Object_var obj = _NS->Resolve(containerNameInNS.c_str());
125 if( !CORBA::is_nil(obj) )
126 return Engines::Container::_narrow(obj);
128 return Engines::Container::_nil();
131 Engines::Container_ptr SALOME_ContainerManager::FindContainer(const char *containerName,const Engines::MachineList& possibleComputers)
133 for(unsigned int i=0;i<possibleComputers.length();i++)
135 Engines::Container_ptr cont=FindContainer(containerName,possibleComputers[i]);
136 if( !CORBA::is_nil(cont) )
139 return Engines::Container::_nil();
142 string SALOME_ContainerManager::BuildContainerNameInNS(const char *containerName,const char *machineName)
144 string containerNameInNS("/Containers/");
145 containerNameInNS+=machineName;
146 containerNameInNS+="/";
147 containerNameInNS+=containerName;
148 return containerNameInNS;