]> SALOME platform Git repositories - modules/kernel.git/blob - src/DSC/DSC_User/Datastream/Calcium/Calcium.cxx
Salome HOME
Merge branch 'omu/multijob'
[modules/kernel.git] / src / DSC / DSC_User / Datastream / Calcium / Calcium.cxx
1 // Copyright (C) 2007-2020  CEA/DEN, EDF R&D, OPEN CASCADE
2 //
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.
7 //
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.
12 //
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
16 //
17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
18 //
19
20 #include "Calcium.hxx"
21 #include "CalciumInterface.hxx"
22 #include "calcium.h"
23 #include <iostream>
24 #include <sstream>
25 #include <string>
26 #include <exception>
27 #include <cstring>
28
29 PySupervCompo::PySupervCompo( CORBA::ORB_ptr orb,
30                               PortableServer::POA_ptr poa,
31                               Engines::Container_ptr contain,
32                               const char *instanceName,
33                               const char *interfaceName,
34                               bool notif) :
35   Superv_Component_i(orb, poa,contain, instanceName, interfaceName,false,false)
36 {
37 }
38
39 PySupervCompo::~PySupervCompo()
40 {
41 }
42
43
44 extern "C"
45 {
46   void cp_exit(int);
47   void setDependency(provides_port*, char*, CalciumTypes::DependencyType);
48
49   void cp_exit(int err)
50     {
51       throw CalciumException(err,LOC("Abort coupling"));
52     }
53
54   void setDependency(provides_port * port,char* type,CalciumTypes::DependencyType depend)
55   {
56     if(std::string(type)=="CALCIUM_real")
57       {
58         dynamic_cast<calcium_real_port_provides *>(port)->setDependencyType(depend);
59       }
60     else if(std::string(type)=="CALCIUM_double")
61       {
62         dynamic_cast<calcium_double_port_provides *>(port)->setDependencyType(depend);
63       }
64     else if(std::string(type)=="CALCIUM_integer")
65       {
66         dynamic_cast<calcium_integer_port_provides *>(port)->setDependencyType(depend);
67       }
68     else if(std::string(type)=="CALCIUM_long")
69       {
70         dynamic_cast<calcium_long_port_provides *>(port)->setDependencyType(depend);
71       }
72     else if(std::string(type)=="CALCIUM_string")
73       {
74         dynamic_cast<calcium_string_port_provides *>(port)->setDependencyType(depend);
75       }
76     else if(std::string(type)=="CALCIUM_logical")
77       {
78         dynamic_cast<calcium_logical_port_provides *>(port)->setDependencyType(depend);
79       }
80     else if(std::string(type)=="CALCIUM_complex")
81       {
82         dynamic_cast<calcium_complex_port_provides *>(port)->setDependencyType(depend);
83       }
84     else
85       {
86         std::cerr << "unknown type:" << std::endl;
87       }
88   }
89
90   void create_calcium_port(Superv_Component_i* compo,char* name,char* type,char *mode,char* depend)
91   {
92     std::stringstream msg;
93     msg << type << " " << mode << " " << depend;
94     CORBA::String_var componentName=compo->instanceName();
95     std::string containerName=compo->getContainerName();
96     Engines_DSC_interface::writeEvent("create_calcium_port",containerName,componentName,name,"",msg.str().c_str());
97
98     if(std::string(mode) == "IN")
99       {
100         provides_port * port ;
101         //provides port
102         try
103           {
104             port = compo->create_provides_data_port(type);
105             compo->add_port(port, name);
106             if(std::string(depend) == "I")
107               setDependency(port,type,CalciumTypes::ITERATION_DEPENDENCY);
108             else if(std::string(depend) == "T")
109               setDependency(port,type,CalciumTypes::TIME_DEPENDENCY);
110             else
111               {
112                 std::cerr << "create_calcium_port:unknown dependency: " << depend << std::endl;
113               }
114           }
115         catch(const Superv_Component_i::PortAlreadyDefined& ex)
116           {
117             //Port already defined : we use the old one
118             delete port;
119             std::cerr << "create_calcium_port: " << ex.what() << std::endl;
120           }
121         catch ( ... )
122           {
123             std::cerr << "create_calcium_port: unknown exception" << std::endl;
124           }
125       }
126     else if(std::string(mode) == "OUT")
127       {
128         uses_port * uport ;
129         try
130           {
131             uport = compo->create_uses_data_port(type);
132             compo->add_port(uport, name);
133           }
134         catch(const Superv_Component_i::PortAlreadyDefined& ex)
135           {
136             //Port already defined : we use the old one
137             delete uport;
138             std::cerr << "create_calcium_port: " << ex.what() << std::endl;
139           }
140         catch ( ... )
141           {
142             std::cerr << "create_calcium_port: unknown exception" << std::endl;
143           }
144       }
145     else
146       {
147         //Unknown mode
148         std::cerr << "create_calcium_port:Unknown mode: " << mode << std::endl;
149       }
150   }
151
152   char** create_multiple_calcium_port(Superv_Component_i* compo,char* name,char* type,char *mode,char* depend, int number)
153   {
154     if (number <= 0)
155     {
156       std::cerr << "Cannot create a multiple calcium port with number <= 0, value is " << number << std::endl;
157       return NULL;
158     }
159     char** names = new char*[number];
160     for (int i = 0; i < number; i++)
161     {
162       std::ostringstream new_name;
163       new_name << name << "_" << i;
164       std::string cpp_name = new_name.str();
165       char * c_name = new char [cpp_name.size()+1];
166       strcpy(c_name, cpp_name.c_str());
167       names[i] = c_name;
168     }
169
170     // Create ports
171     for (int i = 0; i < number; i++)
172     {
173       create_calcium_port(compo, (char*)std::string(names[i]).c_str(), type, mode, depend);
174     }
175
176     return names;
177   }
178
179 }
180
181