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. More... | |
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. More... | |
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. More... | |
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 |
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
inlinevirtual |
Reimplemented from Engines_DSC_interface.
|
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. |
|
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. |
|
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. |
|
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. |
|
virtual |
Used to get the proxy of the parallel port.
provides_port_name | name of the parallel provides port. |
|
staticinherited |
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 |
|
pure virtualinherited |
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.
|
pure virtualinherited |
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.