ConnectionManager Class Reference

This class implements the interface Engines::ConnectionManager. It is used to make connections between CALCIUM ports. More...

#include <ConnectionManager.hxx>

Collaboration diagram for ConnectionManager:

Classes
struct	connection_infos

Public Types
typedef short	connectionId

Public Member Functions
	ConnectionManager ()
	~ConnectionManager ()
ConnectionManager::connectionId	connect (Engines::DSC_ptr uses_component, const char *uses_port_name, Engines::DSC_ptr provides_component, const char *provides_port_name)
void	disconnect (ConnectionManager::connectionId id, Engines::DSC::Message message)
void	ShutdownWithExit ()

Private Types
typedef std::map< Engines::ConnectionManager::connectionId, connection_infos * >	ids_type
typedef std::map< Engines::ConnectionManager::connectionId, connection_infos * >::iterator	ids_it_type

Private Attributes
ids_type	_ids
int	_current_id
std::mutex	_mutex

Detailed Description

This class implements the interface Engines::ConnectionManager. It is used to make connections between CALCIUM ports.

Definition at line 38 of file ConnectionManager.hxx.

Member Typedef Documentation

connectionId

typedef short ConnectionManager::connectionId

Definition at line 44 of file ConnectionManager.hxx.

ids_it_type

typedef std::map<Engines::ConnectionManager::connectionId, connection_infos *>::iterator ConnectionManager::ids_it_type

private

Definition at line 78 of file ConnectionManager.hxx.

ids_type

typedef std::map<Engines::ConnectionManager::connectionId, connection_infos *> ConnectionManager::ids_type

private

Definition at line 76 of file ConnectionManager.hxx.

Constructor & Destructor Documentation

ConnectionManager()

ConnectionManager::ConnectionManager

(

)

Definition at line 23 of file ConnectionManager.cxx.

: _ids()
, _current_id(0)
, _mutex()
{
}

~ConnectionManager()

ConnectionManager::~ConnectionManager

(

)

Definition at line 30 of file ConnectionManager.cxx.

{
}

Member Function Documentation

connect()

ConnectionManager::connectionId ConnectionManager::connect	(	Engines::DSC_ptr	uses_component,
		const char *	uses_port_name,
		Engines::DSC_ptr	provides_component,
		const char *	provides_port_name
	)

connect two CALCIUM ports of two components.

Definition at line 35 of file ConnectionManager.cxx.

{
  // We use a mutex for multithreaded applications.
  std::unique_lock<std::mutex> lock(_mutex);
  Ports::Port_var p_port = provides_component->get_provides_port(provides_port_name, false);
  uses_component->connect_uses_port(uses_port_name, p_port);
  provides_component->connect_provides_port(provides_port_name);
 
  // Creating a new structure containing connection's infos.
  connection_infos * infos = new connection_infos();
  infos->uses_component = Engines::DSC::_duplicate(uses_component);
  infos->uses_port_name = uses_port_name;
  infos->provides_component = Engines::DSC::_duplicate(provides_component);
  infos->provides_port_name = provides_port_name;
  infos->provides_port = Ports::Port::_duplicate(p_port);
 
  // Creating a new connection id.
  ConnectionManager::connectionId rtn_id = _current_id;
  _current_id += 1;
  // Adding the new connection into the map.
  _ids[rtn_id] = infos;
 
  return rtn_id;
}

References _current_id, _ids, _mutex, ConnectionManager::connection_infos::provides_component, ConnectionManager::connection_infos::provides_port, ConnectionManager::connection_infos::provides_port_name, ConnectionManager::connection_infos::uses_component, and ConnectionManager::connection_infos::uses_port_name.

Referenced by gui.browser_catalog.Browser::init().

disconnect()

void ConnectionManager::disconnect	(	ConnectionManager::connectionId	id,
		Engines::DSC::Message	message
	)

releases a connection performed with ConnectionManager::connect.

Definition at line 64 of file ConnectionManager.cxx.

{
  std::unique_lock<std::mutex> lock(_mutex);
  int err=0;
  // Connection id exist ?
  ids_it_type ids_it = _ids.find(id);
  if (ids_it == _ids.end())
    return;
 
  // TODO
  // We need to catch exceptions if one of these disconnect operation fails.
  // connection_infos * infos = ids[id];
  connection_infos * infos = ids_it->second;
  try
    {
      infos->provides_component->disconnect_provides_port(infos->provides_port_name.c_str(), message);
    }
  catch(CORBA::SystemException& ex)
    {
      std::cerr << "Problem in disconnect(CORBA::SystemException) provides port: " << infos->provides_port_name.c_str() << std::endl;
      err=1;
    }
  try
    {
      infos->uses_component->disconnect_uses_port(infos->uses_port_name.c_str(),
                                                  infos->provides_port, message);
    }
  catch(CORBA::SystemException& ex)
    {
      std::cerr << "Problem in disconnect(CORBA::SystemException) uses port: " << infos->uses_port_name.c_str() << std::endl;
      err=1;
    }
  delete infos;
  _ids.erase(id);
 
  if(err)
    throw Engines::DSC::BadPortReference();
}

References _ids, _mutex, testCppPluginInvokation::ex, ConnectionManager::connection_infos::provides_component, ConnectionManager::connection_infos::provides_port, ConnectionManager::connection_infos::provides_port_name, ConnectionManager::connection_infos::uses_component, and ConnectionManager::connection_infos::uses_port_name.

Referenced by ShutdownWithExit().

ShutdownWithExit()

void ConnectionManager::ShutdownWithExit

(

)

Shutdown the ConnectionManager process.

Definition at line 105 of file ConnectionManager.cxx.

{
  ids_it_type ids_it = _ids.begin();
  while(ids_it != _ids.end())
    {
      disconnect(ids_it->first, Engines::DSC::RemovingConnection);
      ids_it = _ids.begin();
    }
}

References _ids, and disconnect().

Member Data Documentation

_current_id

int ConnectionManager::_current_id

private

Definition at line 81 of file ConnectionManager.hxx.

Referenced by connect().

_ids

ids_type ConnectionManager::_ids

private

Definition at line 80 of file ConnectionManager.hxx.

Referenced by connect(), disconnect(), and ShutdownWithExit().

_mutex

std::mutex ConnectionManager::_mutex

private

Definition at line 82 of file ConnectionManager.hxx.

Referenced by connect(), and disconnect().

---

The documentation for this class was generated from the following files:

• src/runtime/ConnectionManager.hxx
• src/runtime/ConnectionManager.cxx