Public Member Functions | |
Engines_ParallelDSC_i (CORBA::ORB_ptr orb, char *ior, int rank, PortableServer::POA_ptr poa, PortableServer::ObjectId *contId, const char *instanceName, const char *interfaceName, bool notif=false) | |
virtual void | add_provides_port (Ports::Port_ptr ref, const char *provides_port_name, Ports::PortProperties_ptr port_prop) throw (Engines::DSC::PortAlreadyDefined, Engines::DSC::NilPort, Engines::DSC::BadProperty) |
virtual void | add_uses_port (const char *repository_id, const char *uses_port_name, Ports::PortProperties_ptr port_prop) throw (Engines::DSC::PortAlreadyDefined, Engines::DSC::BadProperty) |
virtual Ports::Port_ptr | get_provides_port (const char *provides_port_name, const CORBA::Boolean connection_error) throw (Engines::DSC::PortNotDefined, Engines::DSC::PortNotConnected) |
virtual Engines::DSC::uses_port * | get_uses_port (const char *uses_port_name) throw (Engines::DSC::PortNotDefined, Engines::DSC::PortNotConnected) |
virtual void | connect_provides_port (const char *provides_port_name) throw (Engines::DSC::PortNotDefined) |
virtual void | connect_uses_port (const char *uses_port_name, Ports::Port_ptr provides_port_ref) throw (Engines::DSC::PortNotDefined, Engines::DSC::BadPortType, Engines::DSC::NilPort) |
virtual CORBA::Boolean | is_connected (const char *port_name) throw (Engines::DSC::PortNotDefined) |
virtual void | disconnect_provides_port (const char *provides_port_name, const Engines::DSC::Message message) throw (Engines::DSC::PortNotDefined, Engines::DSC::PortNotConnected) |
virtual void | disconnect_uses_port (const char *uses_port_name, Ports::Port_ptr provides_port_ref, const Engines::DSC::Message message) throw (Engines::DSC::PortNotDefined, Engines::DSC::PortNotConnected, Engines::DSC::BadPortReference) |
virtual Ports::PortProperties_ptr | get_port_properties (const char *port_name) throw (Engines::DSC::PortNotDefined) |
virtual void | set_paco_proxy (CORBA::Object_ptr ref, const char *provides_port_name, Ports::PortProperties_ptr port_prop) |
virtual CORBA::Boolean | add_parallel_provides_proxy_port (const CORBA::Object_ptr ref, const char *provides_port_name, Ports::PortProperties_ptr port_prop) |
virtual CORBA::Boolean | add_parallel_provides_proxy_wait (const char *provides_port_name) |
virtual CORBA::Boolean | add_parallel_provides_node_port (Ports::Port_PaCO_ptr ref, const char *provides_port_name) |
virtual const char * | get_proxy (const char *provides_port_name) |
virtual void | provides_port_changed (const char *provides_port_name, int connection_nbr, const Engines::DSC::Message message)=0 |
This method is used by the component when the number of connection on a provides port changes. | |
virtual void | uses_port_changed (const char *uses_port_name, Engines::DSC::uses_port *new_uses_port, const Engines::DSC::Message message)=0 |
This method is used by the component when the number of connection on a uses port changes. | |
Static Public Member Functions | |
static void | writeEvent (const char *request, const std::string &containerName, const char *instance_name, const char *port_name, const char *error, const char *message) |
Write a record in the trace file. | |
Protected Types | |
enum | port_type { uses, provides, none } |
typedef std::map< std::string, port_t * > | ports |
Protected Attributes | |
ports | my_ports |
ports::iterator | my_ports_it |
virtual void Engines_ParallelDSC_i::add_provides_port | ( | Ports::Port_ptr | ref, | |
const char * | provides_port_name, | |||
Ports::PortProperties_ptr | port_prop | |||
) | throw (Engines::DSC::PortAlreadyDefined, Engines::DSC::NilPort, Engines::DSC::BadProperty) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual void Engines_ParallelDSC_i::add_uses_port | ( | const char * | repository_id, | |
const char * | uses_port_name, | |||
Ports::PortProperties_ptr | port_prop | |||
) | throw (Engines::DSC::PortAlreadyDefined, Engines::DSC::BadProperty) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual Ports::Port_ptr Engines_ParallelDSC_i::get_provides_port | ( | const char * | provides_port_name, | |
const CORBA::Boolean | connection_error | |||
) | throw (Engines::DSC::PortNotDefined, Engines::DSC::PortNotConnected) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual Engines::DSC::uses_port* Engines_ParallelDSC_i::get_uses_port | ( | const char * | uses_port_name | ) | throw (Engines::DSC::PortNotDefined, Engines::DSC::PortNotConnected) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual void Engines_ParallelDSC_i::connect_provides_port | ( | const char * | provides_port_name | ) | throw (Engines::DSC::PortNotDefined) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual void Engines_ParallelDSC_i::connect_uses_port | ( | const char * | uses_port_name, | |
Ports::Port_ptr | provides_port_ref | |||
) | throw (Engines::DSC::PortNotDefined, Engines::DSC::BadPortType, Engines::DSC::NilPort) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual CORBA::Boolean Engines_ParallelDSC_i::is_connected | ( | const char * | port_name | ) | throw (Engines::DSC::PortNotDefined) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual void Engines_ParallelDSC_i::disconnect_provides_port | ( | const char * | provides_port_name, | |
const Engines::DSC::Message | message | |||
) | throw (Engines::DSC::PortNotDefined, Engines::DSC::PortNotConnected) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual void Engines_ParallelDSC_i::disconnect_uses_port | ( | const char * | uses_port_name, | |
Ports::Port_ptr | provides_port_ref, | |||
const Engines::DSC::Message | message | |||
) | throw (Engines::DSC::PortNotDefined, Engines::DSC::PortNotConnected, Engines::DSC::BadPortReference) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
virtual Ports::PortProperties_ptr Engines_ParallelDSC_i::get_port_properties | ( | const char * | port_name | ) | throw (Engines::DSC::PortNotDefined) [inline, virtual] |
Reimplemented from Engines_DSC_interface.
void Engines_ParallelDSC_i::set_paco_proxy | ( | CORBA::Object_ptr | ref, | |
const char * | provides_port_name, | |||
Ports::PortProperties_ptr | port_prop | |||
) | [virtual] |
This method is used to register the proxy of the parallel port into all the nodes of the parallel component.
ref | CORBA proxy reference. | |
provides_port_name | provides port associated with the proxy. | |
port_prop | port properties. |
CORBA::Boolean Engines_ParallelDSC_i::add_parallel_provides_proxy_port | ( | const CORBA::Object_ptr | ref, | |
const char * | provides_port_name, | |||
Ports::PortProperties_ptr | port_prop | |||
) | [virtual] |
This method is used by the node that want to add the parallel proxy port.
ref | CORBA proxy reference. | |
provides_port_name | provides port associated with the proxy. |
CORBA::Boolean Engines_ParallelDSC_i::add_parallel_provides_proxy_wait | ( | const char * | provides_port_name | ) | [virtual] |
This method by the nodes that do not add the proxy to wait is reference.
provides_port_name | provides port associated with the proxy. |
CORBA::Boolean Engines_ParallelDSC_i::add_parallel_provides_node_port | ( | Ports::Port_PaCO_ptr | ref, | |
const char * | provides_port_name | |||
) | [virtual] |
Permits to add a parallel node of a parallel provides port.
ref | CORBA node reference. | |
provides_port_name | provides port associated with the node. |
const char * Engines_ParallelDSC_i::get_proxy | ( | const char * | provides_port_name | ) | [virtual] |
Used to get the proxy of the parallel port.
provides_port_name | name of the parallel provides port. |
void Engines_DSC_interface::writeEvent | ( | const char * | request, | |
const std::string & | containerName, | |||
const char * | instance_name, | |||
const char * | port_name, | |||
const char * | error, | |||
const char * | message | |||
) | [static, inherited] |
Write a record in the trace file.
request | the name of the request executed | |
containerName | the name of the container where the request is executed | |
instance_name | the name of the component where the request is executed | |
port_name | the name of the port that is concerned | |
error | if an error has occured, a string that identifies the error | |
message | informations about error or about the request |
virtual void DSC_Callbacks::provides_port_changed | ( | const char * | provides_port_name, | |
int | connection_nbr, | |||
const Engines::DSC::Message | message | |||
) | [pure virtual, inherited] |
This method is used by the component when the number of connection on a provides port changes.
This information helps the user code to detect operation on its ports.
provides_port_name | the name of the provides name that has changed. | |
connection_nbr | the new number of connection on the provides port. | |
message | contains informations about the modification of the port. |
Implemented in Superv_Component_i.
virtual void DSC_Callbacks::uses_port_changed | ( | const char * | uses_port_name, | |
Engines::DSC::uses_port * | new_uses_port, | |||
const Engines::DSC::Message | message | |||
) | [pure virtual, inherited] |
This method is used by the component when the number of connection on a uses port changes.
This information helps the user code to detect operation on its ports.
uses_port_name | the name of the uses name that has changed. | |
new_uses_port | the new sequence representing the uses port. | |
message | contains informations about the modification of the port. |
Implemented in Superv_Component_i.