1 // Copyright (C) 2007 OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
2 // CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
4 // This library is free software; you can redistribute it and/or
5 // modify it under the terms of the GNU Lesser General Public
6 // License as published by the Free Software Foundation; either
7 // version 2.1 of the License.
9 // This library is distributed in the hope that it will be useful,
10 // but WITHOUT ANY WARRANTY; without even the implied warranty of
11 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 // Lesser General Public License for more details.
14 // You should have received a copy of the GNU Lesser General Public
15 // License along with this library; if not, write to the Free Software
16 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
18 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
22 // File : ConnectionManager_i.cxx
23 // Author : André RIBES (EDF)
26 #include "ConnectionManager_i.hxx"
27 #include "SALOME_NamingService.hxx"
29 ConnectionManager_i::ConnectionManager_i(CORBA::ORB_ptr orb) {
30 _orb = CORBA::ORB::_duplicate(orb) ;
31 SALOME_NamingService * ns = new SALOME_NamingService(orb);
32 const char * ConnectionManagerNameInNS = "/ConnectionManager";
33 CORBA::Object_var obref = _this();
35 ns->Register(obref, ConnectionManagerNameInNS);
39 pthread_mutex_init(&mutex, NULL);
42 ConnectionManager_i::~ConnectionManager_i() {}
44 Engines::ConnectionManager::connectionId
45 ConnectionManager_i::connect(Engines::DSC_ptr uses_component,
46 const char* uses_port_name,
47 Engines::DSC_ptr provides_component,
48 const char* provides_port_name)
51 Ports::Port_var p_port = provides_component->get_provides_port(provides_port_name, false);
52 uses_component->connect_uses_port(uses_port_name, p_port);
53 provides_component->connect_provides_port(provides_port_name);
55 // Creating a new connection id.
56 // We use a mutex for multithreaded applications.
57 pthread_mutex_lock(&mutex);
58 Engines::ConnectionManager::connectionId rtn_id = current_id;
60 pthread_mutex_unlock(&mutex);
62 // Creating a new structure containing connection's infos.
63 connection_infos * infos = new connection_infos();
64 infos->uses_component = Engines::DSC::_duplicate(uses_component);
65 infos->uses_port_name = uses_port_name;
66 infos->provides_component = Engines::DSC::_duplicate(provides_component);
67 infos->provides_port_name = provides_port_name;
68 infos->provides_port = Ports::Port::_duplicate(p_port);
70 // Adding the new connection into the map.
77 ConnectionManager_i::disconnect(Engines::ConnectionManager::connectionId id,
78 Engines::DSC::Message message)
81 // Connection id exist ?
82 ids_it = ids.find(id);
83 if (ids_it == ids.end())
84 throw Engines::ConnectionManager::BadId();
87 // We need to catch exceptions if one of these disconnect operation fails.
88 connection_infos * infos = ids[id];
91 infos->provides_component->disconnect_provides_port(infos->provides_port_name.c_str(),
94 catch(CORBA::SystemException& ex)
96 std::cerr << "Problem in disconnect(CORBA::SystemException) provides port: " << infos->provides_port_name << std::endl;
101 infos->uses_component->disconnect_uses_port(infos->uses_port_name.c_str(),
102 infos->provides_port,
105 catch(CORBA::SystemException& ex)
107 std::cerr << "Problem in disconnect(CORBA::SystemException) uses port: " << infos->uses_port_name << std::endl;
114 throw Engines::DSC::BadPortReference();
118 ConnectionManager_i::ShutdownWithExit()
120 if(!CORBA::is_nil(_orb))
123 //exit( EXIT_SUCCESS );
127 ConnectionManager_i::getPID()
129 return (CORBA::Long)getpid();