1 // Copyright (C) 2007-2010 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.
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
20 // SALOME TestContainer : test of container creation and its life cycle
21 // File : TestContainer.cxx
22 // Author : Paul RASCLE, EDF - MARC TAJCHMAN, CEA
26 #include "utilities.h"
31 #include <SALOMEconfig.h>
32 #include "SALOME_NamingService.hxx"
33 #include "SALOME_ContainerManager.hxx"
34 #include "SALOME_LifeCycleCORBA.hxx"
35 #include "NamingService_WaitForServerReadiness.hxx"
37 #include "Utils_ORB_INIT.hxx"
38 #include "Utils_SINGLETON.hxx"
39 #include "Utils_SALOME_Exception.hxx"
40 #include "Utils_CommException.hxx"
41 #include "Basics_DirUtils.hxx"
43 int main (int argc, char * argv[])
45 std::map<std::string, int> cycle;
46 std::map<std::string, int> first;
47 Engines::Container_ptr cont;
48 Engines::Component_ptr compo;
53 // Initializing omniORB
54 ORB_INIT &init = *SINGLETON_<ORB_INIT>::Instance() ;
55 CORBA::ORB_ptr orb = init( argc , argv ) ;
57 SALOME_NamingService *_NS=new SALOME_NamingService(orb);
59 CORBA::Object_var obj = _NS->Resolve(SALOME_ContainerManager::_ContainerManagerNameInNS);
60 ASSERT( !CORBA::is_nil(obj));
61 Engines::ContainerManager_var _ContManager=Engines::ContainerManager::_narrow(obj);
62 obj = _NS->Resolve(SALOME_ResourcesManager::_ResourcesManagerNameInNS);
63 ASSERT( !CORBA::is_nil(obj));
64 Engines::ResourcesManager_var _ResManager=Engines::ResourcesManager::_narrow(obj);
66 Engines::ContainerParameters p;
67 p.resource_params.componentList.length(2);
68 p.resource_params.componentList[0] = "MED";
69 p.resource_params.componentList[1] = "GEOM";
71 p.resource_params.hostname = "";
72 p.resource_params.OS = "LINUX";
73 p.resource_params.mem_mb = 1000;
74 p.resource_params.cpu_clock = 1000;
75 p.resource_params.nb_proc_per_node = 1;
76 p.resource_params.nb_node = 1;
80 for(int i=0;i<10;i++){
81 sprintf(st,"cycl_%d",i);
82 p.container_name = CORBA::string_dup(st);
83 p.resource_params.policy="cycl";
84 cont = _ContManager->GiveContainer(p);
85 if(CORBA::is_nil(cont)) error = true;
88 for(int i=0;i<10;i++){
89 sprintf(st,"first_%d",i);
90 p.container_name = CORBA::string_dup(st);
91 p.resource_params.policy="first";
92 cont = _ContManager->GiveContainer(p);
93 if(CORBA::is_nil(cont)) error = true;
96 p.container_name = CORBA::string_dup("best");
97 p.resource_params.policy="best";
98 cont = _ContManager->GiveContainer(p);
99 if(CORBA::is_nil(cont)) bestImplemented = false;
100 else bestImplemented = true;
102 SALOME_LifeCycleCORBA LCC(_NS);
103 p.container_name = CORBA::string_dup("FactoryServer");
104 compo = LCC.FindOrLoad_Component(p,"SMESH");
105 if(CORBA::is_nil(compo)) error = true;
106 compo = LCC.FindOrLoad_Component(p,"SMESH");
107 if(CORBA::is_nil(compo)) error = true;
109 _NS->Change_Directory("/Containers");
111 std::vector<std::string> vec = _NS->list_directory_recurs();
112 std::list<std::string> lstCont;
113 for(std::vector<std::string>::iterator iter = vec.begin();iter!=vec.end();iter++){
114 CORBA::Object_var obj=_NS->Resolve((*iter).c_str());
115 Engines::Container_var cont=Engines::Container::_narrow(obj);
116 if(!CORBA::is_nil(cont)){
117 cycle[cont->getHostName()]=0;
118 first[cont->getHostName()]=0;
119 lstCont.push_back((*iter));
122 for(std::list<std::string>::iterator iter=lstCont.begin();iter!=lstCont.end();iter++){
123 CORBA::Object_var obj=_NS->Resolve((*iter).c_str());
124 Engines::Container_var cont=Engines::Container::_narrow(obj);
125 if(!CORBA::is_nil(cont)){
126 std::string basename = Kernel_Utils::GetBaseName(cont->name());
127 if(basename.compare(0,4,"cycl")==0)
128 cycle[cont->getHostName()]++;
129 if(basename.compare(0,5,"first")==0)
130 first[cont->getHostName()]++;
133 _ContManager->ShutdownContainers();
140 for(std::map<std::string,int>::iterator iter=cycle.begin();iter!=cycle.end();iter++){
141 if(strcmp((*iter).first.c_str(),"localhost")!=0){
142 Engines::ResourceDefinition *p = _ResManager->GetResourceDefinition((*iter).first.c_str());
143 int nbproc = p->nb_node * p->nb_proc_per_node;
144 if(cycle[(*iter).first]/nbproc<cmin) cmin=cycle[(*iter).first]/nbproc;
145 if(cycle[(*iter).first]/nbproc>cmax) cmax=cycle[(*iter).first]/nbproc;
146 if(first[(*iter).first]/nbproc<fmin) fmin=first[(*iter).first]/nbproc;
147 if(first[(*iter).first]/nbproc>fmax){
148 fmax=first[(*iter).first]/nbproc;
154 if( ((cmax-cmin) <= 1) && (fmax == 10/nbpmax) && !error ){
158 msg = "TEST OK but FindBest not implemented!";
165 std::cout << msg << std::endl;