#include <ParallelDSC_i.hxx>

Inheritance diagram for Engines_ParallelDSC_i:

[legend]

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	~Engines_ParallelDSC_i ()

virtual void	add_provides_port (Ports::Port_ptr ref, const char *provides_port_name, Ports::PortProperties_ptr port_prop)

virtual void	add_uses_port (const char repository_id, const char uses_port_name, Ports::PortProperties_ptr port_prop)

virtual Ports::Port_ptr	get_provides_port (const char *provides_port_name, const CORBA::Boolean connection_error)

virtual Engines::DSC::uses_port *	get_uses_port (const char *uses_port_name)

virtual void	connect_provides_port (const char *provides_port_name)

virtual void	connect_uses_port (const char *uses_port_name, Ports::Port_ptr provides_port_ref)

virtual CORBA::Boolean	is_connected (const char *port_name)

virtual void	disconnect_provides_port (const char *provides_port_name, const Engines::DSC::Message message)

virtual void	disconnect_uses_port (const char *uses_port_name, Ports::Port_ptr provides_port_ref, const Engines::DSC::Message message)

virtual Ports::PortProperties_ptr	get_port_properties (const char *port_name)

virtual void	set_paco_proxy (CORBA::Object_ptr ref, const char *provides_port_name, Ports::PortProperties_ptr port_prop)
	This method is used to register the proxy of the parallel port into all the nodes of the parallel component. More...

virtual CORBA::Boolean	add_parallel_provides_proxy_port (const CORBA::Object_ptr ref, const char *provides_port_name, Ports::PortProperties_ptr port_prop)
	This method is used by the node that want to add the parallel proxy port. More...

virtual CORBA::Boolean	add_parallel_provides_proxy_wait (const char *provides_port_name)
	This method by the nodes that do not add the proxy to wait is reference. More...

virtual CORBA::Boolean	add_parallel_provides_node_port (Ports::Port_PaCO_ptr ref, const char *provides_port_name)
	Permits to add a parallel node of a parallel provides port. More...

virtual const char *	get_proxy (const char *provides_port_name)
	Used to get the proxy of the parallel port. More...

char *	instanceName ()
	CORBA method: return name of the instance, unique in this Container. More...

char *	interfaceName ()
	CORBA method: return name of the component class. More...

void	ping ()
	CORBA method: Test if instance is alive and responds. More...

void	destroy ()
	CORBA method: Deactivate this instance. More...

Engines::Container_ptr	GetContainerRef ()
	CORBA method: return CORBA reference of the Container. More...

void	setProperties (const Engines::FieldsDict &dico)
	CORBA method: Gives a sequence of (key=string,value=any) to the component. More...

Engines::FieldsDict *	getProperties ()
	CORBA method: returns a previously stored map (key=string,value=any) as a sequence. More...

void	Names (const char graphName, const char nodeName)
	CORBA method: used by Supervision to give names to this instance. More...

bool	Kill_impl ()
	CORBA method: used in Supervision. More...

bool	Stop_impl ()
	CORBA method: used in Supervision. More...

bool	Suspend_impl ()
	CORBA method: used in Supervision. More...

bool	Resume_impl ()
	CORBA method: used in Supervision. More...

CORBA::Long	CpuUsed_impl ()
	CORBA method: More...

virtual Engines::TMPFile *	DumpPython (CORBA::Boolean isPublished, CORBA::Boolean isMultiFile, CORBA::Boolean &isValidScript)
	C++ method: DumpPython default implementation. More...

virtual Engines::Salome_file_ptr	getInputFileToService (const char service_name, const char Salome_file_name)

virtual Engines::Salome_file_ptr	getOutputFileToService (const char service_name, const char Salome_file_name)

virtual void	checkInputFilesToService (const char *service_name)

virtual Engines::Salome_file_ptr	setInputFileToService (const char service_name, const char Salome_file_name)

virtual void	checkOutputFilesToService (const char *service_name)

virtual Engines::Salome_file_ptr	setOutputFileToService (const char service_name, const char Salome_file_name)

void	send_parallel_proxy_object (CORBA::Object_ptr proxy_ref)
	C++ method: Used by the Parallel Component to deploy a Parallel Salome_file. More...

virtual bool	hasObjectInfo ()

virtual char *	getObjectInfo (const char *entry)

PortableServer::ObjectId *	getId ()
	C++ method: return CORBA instance id, the id is set in derived class constructor, when instance is activated. More...

Engines_Parallel_Container_i *	GetContainerPtr ()
	C++ method: return Container Servant. More...

void	beginService (const char *serviceName)
	C++ method: used by derived classes for supervision. More...

void	endService (const char *serviceName)
	C++ method: used by derived classes for supervision. More...

void	sendMessage (const char event_type, const char message)
	C++ method: Send message to event channel. More...

char *	graphName ()
	C++ method: – CHECK IF USED –. More...

char *	nodeName ()
	C++ method: – CHECK IF USED –. More...

bool	Killer (pthread_t ThreadId, int signum)
	C++ method: used in Supervision (see kill_impl) More...

void	SetCurCpu ()
	C++ method: More...

long	CpuUsed ()
	C++ method: More...

void	CancelThread ()
	C++ method: More...

void	wait_parallel_object_proxy ()
	C++ method: Used by the Parallel Component to deploy a Parallel Salome_file. More...

char *	get_parallel_proxy_object ()
	C++ method: Used by the Parallel Component to deploy a Parallel Salome_file. More...

virtual void	configureSalome_file (std::string service_name, std::string file_port_name, Engines::Parallel_Salome_file_proxy_impl *file)
	C++ method: used to configure the Salome_file into the runtime. More...

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 bool	isMultiInstance ()

static std::string	GetDynLibraryName (const char *componentName)
	C++ method: return standard library name built on component name. More...

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
typedef std::map< std::string, Parallel_Salome_file_i * >	_t_Salome_file_map

typedef std::map< std::string, Engines::Parallel_Salome_file_proxy_impl * >	_t_Proxy_Salome_file_map

typedef std::map< std::string, std::string >	_t_IOR_Proxy_Salome_file_map

typedef std::map< std::string, Engines_Parallel_Component_i::_t_Salome_file_map * >	_t_Service_file_map

typedef std::map< std::string, Engines_Parallel_Component_i::_t_Proxy_Salome_file_map * >	_t_Proxy_Service_file_map

typedef std::map< std::string, Engines_Parallel_Component_i::_t_IOR_Proxy_Salome_file_map * >	_t_IOR_Proxy_Service_file_map

enum	port_type { uses , provides , none }

typedef std::map< std::string, port_t * >	ports

Protected Attributes
std::string	_instanceName

std::string	_interfaceName

CORBA::ORB_var	_orb

PortableServer::POA_var	_poa

PortableServer::ObjectId *	_id

PortableServer::ObjectId *	_contId

Engines_Parallel_Component_i *	_thisObj

RegistryConnexion *	_myConnexionToRegistry

NOTIFICATION_Supplier *	_notifSupplier

std::map< std::string, CORBA::Any >	_fieldsDict

_t_Service_file_map	_Input_Service_file_map

_t_Service_file_map	_Output_Service_file_map

_t_Service_file_map::iterator	_Service_file_map_it

_t_Salome_file_map::iterator	_Salome_file_map_it

_t_Proxy_Service_file_map	_Proxy_Input_Service_file_map

_t_Proxy_Service_file_map	_Proxy_Output_Service_file_map

_t_Proxy_Service_file_map::iterator	_Proxy_Service_file_map_it

_t_Proxy_Salome_file_map::iterator	_Proxy_Salome_file_map_it

_t_IOR_Proxy_Service_file_map	_IOR_Proxy_Input_Service_file_map

_t_IOR_Proxy_Service_file_map	_IOR_Proxy_Output_Service_file_map

_t_IOR_Proxy_Service_file_map::iterator	_IOR_Proxy_Service_file_map_it

_t_IOR_Proxy_Salome_file_map::iterator	_IOR_Proxy_Salome_file_map_it

std::string	_serviceName

std::string	_graphName

std::string	_nodeName

pthread_mutex_t *	deploy_mutex

char *	_proxy

ports	my_ports

ports::iterator	my_ports_it

Static Protected Attributes
static bool	_isMultiInstance = false

Private Attributes
pthread_t	_ThreadId

long	_StartUsed

long	_ThreadCpuUsed

bool	_Executed

bool	_CanceledThread

bool	_destroyed

Member Typedef Documentation

◆ _t_IOR_Proxy_Salome_file_map

typedef std::map<std::string, std::string> Engines_Parallel_Component_i::_t_IOR_Proxy_Salome_file_map

protectedinherited

◆ _t_IOR_Proxy_Service_file_map

typedef std::map<std::string, Engines_Parallel_Component_i::_t_IOR_Proxy_Salome_file_map*> Engines_Parallel_Component_i::_t_IOR_Proxy_Service_file_map

protectedinherited

◆ _t_Proxy_Salome_file_map

typedef std::map<std::string, Engines::Parallel_Salome_file_proxy_impl*> Engines_Parallel_Component_i::_t_Proxy_Salome_file_map

protectedinherited

◆ _t_Proxy_Service_file_map

typedef std::map<std::string, Engines_Parallel_Component_i::_t_Proxy_Salome_file_map*> Engines_Parallel_Component_i::_t_Proxy_Service_file_map

protectedinherited

◆ _t_Salome_file_map

typedef std::map<std::string, Parallel_Salome_file_i*> Engines_Parallel_Component_i::_t_Salome_file_map

protectedinherited

◆ _t_Service_file_map

typedef std::map<std::string, Engines_Parallel_Component_i::_t_Salome_file_map*> Engines_Parallel_Component_i::_t_Service_file_map

protectedinherited

◆ ports

typedef std::map<std::string, port_t *> Engines_DSC_interface::ports

protectedinherited

Member Enumeration Documentation

◆ port_type

enum Engines_DSC_interface::port_type

protectedinherited

Enumerator
uses
provides
none

Constructor & Destructor Documentation

◆ Engines_ParallelDSC_i()

Engines_ParallelDSC_i::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`
	)

◆ ~Engines_ParallelDSC_i()

Engines_ParallelDSC_i::~Engines_ParallelDSC_i ( )

virtual

Member Function Documentation

◆ add_parallel_provides_node_port()

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.

Parameters

ref	CORBA node reference.
provides_port_name	provides port associated with the node.

Returns: true if the node is correctly added.

Referenced by Param_Double_Port_provides_i::init_port().

◆ add_parallel_provides_proxy_port()

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.

Parameters

ref	CORBA proxy reference.
provides_port_name	provides port associated with the proxy.

Returns: true if the proxy is correctly added.

Referenced by Param_Double_Port_provides_i::init_port().

◆ add_parallel_provides_proxy_wait()

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.

Parameters

provides_port_name provides port associated with the proxy.

Returns: true if the proxy is correctly added.

References get_proxy().

Referenced by Param_Double_Port_provides_i::init_port().

◆ add_provides_port()

virtual void Engines_ParallelDSC_i::add_provides_port	(	Ports::Port_ptr	ref,
		const char *	provides_port_name,
		Ports::PortProperties_ptr	port_prop
	)

virtual

See also: Engines::DSC::add_provides_port

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::add_provides_port().

◆ add_uses_port()

virtual void Engines_ParallelDSC_i::add_uses_port	(	const char *	repository_id,
		const char *	uses_port_name,
		Ports::PortProperties_ptr	port_prop
	)

virtual

See also: Engines::DSC::add_uses_port

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::add_uses_port().

Referenced by Param_Double_Port_uses_i::add_port_to_component().

◆ beginService()

void Engines_Parallel_Component_i::beginService ( const char * serviceName )

inherited

C++ method: used by derived classes for supervision.

References Engines_Parallel_Component_i::_Executed, Engines_Parallel_Component_i::_fieldsDict, Engines_Parallel_Component_i::_instanceName, Engines_Parallel_Component_i::_serviceName, Engines_Parallel_Component_i::_StartUsed, Engines_Parallel_Component_i::_ThreadCpuUsed, Engines_Parallel_Component_i::_ThreadId, Engines_Parallel_Component_i::CpuUsed_impl(), and MESSAGE.

◆ CancelThread()

void Engines_Parallel_Component_i::CancelThread ( )

inherited

C++ method:

References Engines_Parallel_Component_i::_CanceledThread.

Referenced by CallCancelThread().

◆ checkInputFilesToService()

void Engines_Parallel_Component_i::checkInputFilesToService ( const char * service_name )

virtualinherited

References Engines_Parallel_Component_i::_Proxy_Input_Service_file_map, Engines_Parallel_Component_i::_Proxy_Service_file_map_it, and Engines_Parallel_Component_i::configureSalome_file().

◆ checkOutputFilesToService()

void Engines_Parallel_Component_i::checkOutputFilesToService ( const char * service_name )

virtualinherited

References Engines_Parallel_Component_i::_Proxy_Output_Service_file_map, Engines_Parallel_Component_i::_Proxy_Service_file_map_it, and Engines_Parallel_Component_i::configureSalome_file().

◆ configureSalome_file()

void Engines_Parallel_Component_i::configureSalome_file	(	std::string	service_name,
		std::string	file_port_name,
		Engines::Parallel_Salome_file_proxy_impl *	file
	)

virtualinherited

C++ method: used to configure the Salome_file into the runtime.

Parameters

service_name	name of the service that use this Salome_file
file_port_name	name of the Salome_file
file	Parallel Salome_file C++ object

Referenced by Engines_Parallel_Component_i::checkInputFilesToService(), and Engines_Parallel_Component_i::checkOutputFilesToService().

◆ connect_provides_port()

virtual void Engines_ParallelDSC_i::connect_provides_port ( const char * provides_port_name )

virtual

See also: Engines::DSC::connect_provides_port

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::connect_provides_port().

◆ connect_uses_port()

virtual void Engines_ParallelDSC_i::connect_uses_port	(	const char *	uses_port_name,
		Ports::Port_ptr	provides_port_ref
	)

virtual

See also: Engines::DSC::connect_uses_port

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::connect_uses_port().

◆ CpuUsed()

long Engines_Parallel_Component_i::CpuUsed ( )

inherited

C++ method:

References Engines_Parallel_Component_i::_Executed, Engines_Parallel_Component_i::_StartUsed, Engines_Parallel_Component_i::_ThreadId, and prepare_test::usage.

Referenced by Engines_Parallel_Component_i::CpuUsed_impl(), and Engines_Parallel_Component_i::SetCurCpu().

◆ CpuUsed_impl()

CORBA::Long Engines_Parallel_Component_i::CpuUsed_impl ( )

inherited

CORBA method:

References Engines_Parallel_Component_i::_Executed, _Sleeping, Engines_Parallel_Component_i::_ThreadCpuUsed, Engines_Parallel_Component_i::_ThreadId, Engines_Parallel_Component_i::CpuUsed(), Engines_Parallel_Component_i::Killer(), and theEngines_Component.

Referenced by Engines_Parallel_Component_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), Engines_Parallel_Component_i::endService(), and SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::endService().

◆ destroy()

void Engines_Parallel_Component_i::destroy ( )

inherited

CORBA method: Deactivate this instance.

CORBA object is deactivated (do not respond any more to CORBA calls), the connection to Regsitry is removed (Registry informed of deactivation), internal server reference counter on the derived servant class is decremented, to allow destruction of the class (delete) by POA, when there are no more references. – TO BE USED BY CONTAINER ONLY (Container housekeeping) –

References Engines_Parallel_Component_i::_destroyed, and MESSAGE.

◆ disconnect_provides_port()

virtual void Engines_ParallelDSC_i::disconnect_provides_port	(	const char *	provides_port_name,
		const Engines::DSC::Message	message
	)

virtual

See also: Engines::DSC::disconnect_provides_port

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::disconnect_provides_port().

◆ disconnect_uses_port()

virtual void Engines_ParallelDSC_i::disconnect_uses_port	(	const char *	uses_port_name,
		Ports::Port_ptr	provides_port_ref,
		const Engines::DSC::Message	message
	)

virtual

See also: Engines::DSC::disconnect_uses_port

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::disconnect_uses_port().

◆ DumpPython()

Engines::TMPFile * Engines_Parallel_Component_i::DumpPython	(	CORBA::Boolean	isPublished,
		CORBA::Boolean	isMultiFile,
		CORBA::Boolean &	isValidScript
	)

virtualinherited

C++ method: DumpPython default implementation.

◆ endService()

void Engines_Parallel_Component_i::endService ( const char * serviceName )

inherited

C++ method: used by derived classes for supervision.

References Engines_Parallel_Component_i::_CanceledThread, Engines_Parallel_Component_i::_instanceName, Engines_Parallel_Component_i::_StartUsed, Engines_Parallel_Component_i::_ThreadCpuUsed, Engines_Parallel_Component_i::_ThreadId, Engines_Parallel_Component_i::CpuUsed_impl(), and MESSAGE.

◆ get_parallel_proxy_object()

char * Engines_Parallel_Component_i::get_parallel_proxy_object ( )

inherited

C++ method: Used by the Parallel Component to deploy a Parallel Salome_file.

References Engines_Parallel_Component_i::_proxy.

Referenced by Engines_Parallel_Component_i::setInputFileToService(), Engines_Parallel_Component_i::setOutputFileToService(), and Engines_Parallel_Component_i::wait_parallel_object_proxy().

◆ get_port_properties()

virtual Ports::PortProperties_ptr Engines_ParallelDSC_i::get_port_properties ( const char * port_name )

virtual

See also: Engines::DSC::get_port_properties

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::get_port_properties().

◆ get_provides_port()

virtual Ports::Port_ptr Engines_ParallelDSC_i::get_provides_port	(	const char *	provides_port_name,
		const CORBA::Boolean	connection_error
	)

virtual

See also: Engines::DSC::get_provides_port

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::get_provides_port().

◆ get_proxy()

const char * Engines_ParallelDSC_i::get_proxy ( const char * provides_port_name )

virtual

Used to get the proxy of the parallel port.

Parameters

provides_port_name name of the parallel provides port.

Returns: IOR of the proxy.

References Engines_Parallel_Component_i::_orb, and Engines_DSC_interface::get_provides_port().

Referenced by add_parallel_provides_proxy_wait(), Param_Double_Port_provides_i::init_port(), and Param_Double_Port_provides_i::wait_init_port().

◆ get_uses_port()

virtual Engines::DSC::uses_port* Engines_ParallelDSC_i::get_uses_port ( const char * uses_port_name )

virtual

See also: Engines::DSC::get_uses_port

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::get_uses_port().

Referenced by Param_Double_Port_uses_i::start_port().

◆ GetContainerPtr()

Engines_Parallel_Container_i * Engines_Parallel_Component_i::GetContainerPtr ( )

inherited

C++ method: return Container Servant.

References Engines_Parallel_Component_i::_contId, and Engines_Parallel_Component_i::_poa.

◆ GetContainerRef()

Engines::Container_ptr Engines_Parallel_Component_i::GetContainerRef ( )

inherited

CORBA method: return CORBA reference of the Container.

References Engines_Parallel_Component_i::_contId, Engines_Parallel_Component_i::_poa, and MESSAGE.

◆ GetDynLibraryName()

std::string Engines_Parallel_Component_i::GetDynLibraryName ( const char * componentName )

staticinherited

C++ method: return standard library name built on component name.

References TestKernelHelpers::ret.

◆ getId()

PortableServer::ObjectId * Engines_Parallel_Component_i::getId ( )

inherited

C++ method: return CORBA instance id, the id is set in derived class constructor, when instance is activated.

References Engines_Parallel_Component_i::_id.

◆ getInputFileToService()

Engines::Salome_file_ptr Engines_Parallel_Component_i::getInputFileToService	(	const char *	service_name,
		const char *	Salome_file_name
	)

virtualinherited

References Engines_Parallel_Component_i::_Proxy_Input_Service_file_map, Engines_Parallel_Component_i::_Proxy_Salome_file_map_it, Engines_Parallel_Component_i::_Proxy_Service_file_map_it, SALOME::INTERNAL_ERROR, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

◆ getObjectInfo()

virtual char* Engines_Parallel_Component_i::getObjectInfo ( const char * entry )

virtualinherited

◆ getOutputFileToService()

Engines::Salome_file_ptr Engines_Parallel_Component_i::getOutputFileToService	(	const char *	service_name,
		const char *	Salome_file_name
	)

virtualinherited

References Engines_Parallel_Component_i::_Proxy_Output_Service_file_map, Engines_Parallel_Component_i::_Proxy_Salome_file_map_it, Engines_Parallel_Component_i::_Proxy_Service_file_map_it, SALOME::INTERNAL_ERROR, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

◆ getProperties()

Engines::FieldsDict * Engines_Parallel_Component_i::getProperties ( )

inherited

CORBA method: returns a previously stored map (key=string,value=any) as a sequence.

(see setProperties)

References Engines_Parallel_Component_i::_fieldsDict.

◆ graphName()

char * Engines_Parallel_Component_i::graphName ( )

inherited

C++ method: – CHECK IF USED –.

References Engines_Parallel_Component_i::_graphName.

Referenced by Engines_Parallel_Component_i::Names(), Engines_Parallel_Component_i::sendMessage(), and SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::sendMessage().

◆ hasObjectInfo()

virtual bool Engines_Parallel_Component_i::hasObjectInfo ( )

virtualinherited

◆ instanceName()

char * Engines_Parallel_Component_i::instanceName ( )

inherited

CORBA method: return name of the instance, unique in this Container.

References Engines_Parallel_Component_i::_instanceName.

Referenced by Engines_Parallel_Component_i::Engines_Parallel_Component_i().

◆ interfaceName()

char * Engines_Parallel_Component_i::interfaceName ( )

inherited

CORBA method: return name of the component class.

References Engines_Parallel_Component_i::_interfaceName.

◆ is_connected()

virtual CORBA::Boolean Engines_ParallelDSC_i::is_connected ( const char * port_name )

virtual

See also: Engines::DSC::is_connected

Reimplemented from Engines_DSC_interface.

References Engines_DSC_interface::is_connected().

◆ isMultiInstance()

static bool Engines_Parallel_Component_i::isMultiInstance ( )

staticinherited

◆ Kill_impl()

bool Engines_Parallel_Component_i::Kill_impl ( )

inherited

CORBA method: used in Supervision.

References Engines_Parallel_Component_i::_ThreadId, and Engines_Parallel_Component_i::Killer().

◆ Killer()

bool Engines_Parallel_Component_i::Killer	(	pthread_t	ThreadId,
		int	signum
	)

inherited

C++ method: used in Supervision (see kill_impl)

References MESSAGE.

Referenced by Engines_Parallel_Component_i::CpuUsed_impl(), Engines_Parallel_Component_i::Kill_impl(), Engines_Parallel_Component_i::Stop_impl(), and Engines_Parallel_Component_i::Suspend_impl().

◆ Names()

void Engines_Parallel_Component_i::Names	(	const char *	graphName,
		const char *	nodeName
	)

inherited

CORBA method: used by Supervision to give names to this instance.

References Engines_Parallel_Component_i::_graphName, Engines_Parallel_Component_i::_nodeName, Engines_Parallel_Component_i::graphName(), MESSAGE, and Engines_Parallel_Component_i::nodeName().

◆ nodeName()

char * Engines_Parallel_Component_i::nodeName ( )

inherited

C++ method: – CHECK IF USED –.

References Engines_Parallel_Component_i::_nodeName.

◆ ping()

void Engines_Parallel_Component_i::ping ( )

inherited

CORBA method: Test if instance is alive and responds.

References MESSAGE.

◆ provides_port_changed()

virtual void DSC_Callbacks::provides_port_changed	(	const char *	provides_port_name,
		int	connection_nbr,
		const Engines::DSC::Message	message
	)

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.

Parameters

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.

Referenced by Engines_DSC_interface::connect_provides_port(), and Engines_DSC_interface::disconnect_provides_port().

◆ Resume_impl()

bool Engines_Parallel_Component_i::Resume_impl ( )

inherited

CORBA method: used in Supervision.

References Engines_Parallel_Component_i::_id, Engines_Parallel_Component_i::_instanceName, Engines_Parallel_Component_i::_interfaceName, _Sleeping, Engines_Parallel_Component_i::_ThreadId, and MESSAGE.

◆ send_parallel_proxy_object()

void Engines_Parallel_Component_i::send_parallel_proxy_object ( CORBA::Object_ptr proxy_ref )

inherited

C++ method: Used by the Parallel Component to deploy a Parallel Salome_file.

References Engines_Parallel_Component_i::_orb, and Engines_Parallel_Component_i::_proxy.

◆ sendMessage()

void Engines_Parallel_Component_i::sendMessage	(	const char *	event_type,
		const char *	message
	)

inherited

C++ method: Send message to event channel.

References Engines_Parallel_Component_i::_notifSupplier, Engines_Parallel_Component_i::graphName(), Engines_Parallel_Component_i::nodeName(), and NOTIFICATION_Supplier::Send().

◆ set_paco_proxy()

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.

Parameters

ref	CORBA proxy reference.
provides_port_name	provides port associated with the proxy.
port_prop	port properties.

References Engines_DSC_interface::add_provides_port().

◆ SetCurCpu()

void Engines_Parallel_Component_i::SetCurCpu ( )

inherited

C++ method:

References Engines_Parallel_Component_i::_ThreadCpuUsed, and Engines_Parallel_Component_i::CpuUsed().

Referenced by SetCpuUsed().

◆ setInputFileToService()

Engines::Salome_file_ptr Engines_Parallel_Component_i::setInputFileToService	(	const char *	service_name,
		const char *	Salome_file_name
	)

virtualinherited

◆ setOutputFileToService()

Engines::Salome_file_ptr Engines_Parallel_Component_i::setOutputFileToService	(	const char *	service_name,
		const char *	Salome_file_name
	)

virtualinherited

◆ setProperties()

void Engines_Parallel_Component_i::setProperties ( const Engines::FieldsDict & dico )

inherited

CORBA method: Gives a sequence of (key=string,value=any) to the component.

Base class component stores the sequence in a map. The map is cleared before. This map is for use by derived classes.

Parameters

dico	sequence of (key=string,value=any)

References Engines_Parallel_Component_i::_fieldsDict.

◆ Stop_impl()

bool Engines_Parallel_Component_i::Stop_impl ( )

inherited

CORBA method: used in Supervision.

References Engines_Parallel_Component_i::_id, Engines_Parallel_Component_i::_instanceName, Engines_Parallel_Component_i::_interfaceName, Engines_Parallel_Component_i::_ThreadId, Engines_Parallel_Component_i::Killer(), and MESSAGE.

◆ Suspend_impl()

bool Engines_Parallel_Component_i::Suspend_impl ( )

inherited

CORBA method: used in Supervision.

References Engines_Parallel_Component_i::_id, Engines_Parallel_Component_i::_instanceName, Engines_Parallel_Component_i::_interfaceName, _Sleeping, Engines_Parallel_Component_i::_ThreadId, Engines_Parallel_Component_i::Killer(), and MESSAGE.

◆ uses_port_changed()

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 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.

Parameters

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.

Referenced by Engines_DSC_interface::connect_uses_port(), and Engines_DSC_interface::disconnect_uses_port().

◆ wait_parallel_object_proxy()

void Engines_Parallel_Component_i::wait_parallel_object_proxy ( )

inherited

C++ method: Used by the Parallel Component to deploy a Parallel Salome_file.

References Engines_Parallel_Component_i::get_parallel_proxy_object().

Referenced by Engines_Parallel_Component_i::setInputFileToService(), and Engines_Parallel_Component_i::setOutputFileToService().

◆ writeEvent()

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
	)

staticinherited

Write a record in the trace file.

Parameters

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

References SALOME_ContainerPy::containerName, IDLparser::error(), initTrace(), TestMinimalExample::msg, out, traceLevel, and traceType.

Referenced by create_calcium_port(), CalciumInterface::ecp_cd(), CalciumInterface::ecp_ecriture(), CalciumInterface::ecp_effi(), CalciumInterface::ecp_efft(), CalciumInterface::ecp_fin(), CalciumInterface::ecp_fini(), CalciumInterface::ecp_fint(), CalciumInterface::ecp_lecture(), GenericPort< DataManipulator, COUPLING_POLICY >::get(), and GenericPort< DataManipulator, COUPLING_POLICY >::next().

Field Documentation

◆ _CanceledThread

bool Engines_Parallel_Component_i::_CanceledThread

privateinherited

Referenced by Engines_Parallel_Component_i::CancelThread(), and Engines_Parallel_Component_i::endService().

◆ _contId

PortableServer::ObjectId* Engines_Parallel_Component_i::_contId

protectedinherited

Referenced by SALOME_ComponentPy.SALOME_ComponentPy_i::__init__(), Engines_Parallel_Component_i::Engines_Parallel_Component_i(), Engines_Parallel_Component_i::GetContainerPtr(), Engines_Parallel_Component_i::GetContainerRef(), and SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::GetContainerRef().

◆ _destroyed

bool Engines_Parallel_Component_i::_destroyed

privateinherited

Referenced by Engines_Parallel_Component_i::destroy().

◆ _Executed

bool Engines_Parallel_Component_i::_Executed

privateinherited

Referenced by Engines_Parallel_Component_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), Engines_Parallel_Component_i::CpuUsed(), Engines_Parallel_Component_i::CpuUsed_impl(), and SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::CpuUsed_impl().

◆ _fieldsDict

std::map<std::string,CORBA::Any> Engines_Parallel_Component_i::_fieldsDict

protectedinherited

Referenced by Engines_Parallel_Component_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), Engines_Parallel_Component_i::getProperties(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::getProperties(), and Engines_Parallel_Component_i::setProperties().

◆ _graphName

std::string Engines_Parallel_Component_i::_graphName

protectedinherited

Referenced by SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::endService(), Engines_Parallel_Component_i::graphName(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::graphName(), Engines_Parallel_Component_i::Names(), and SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::Names().

◆ _id

PortableServer::ObjectId* Engines_Parallel_Component_i::_id

protectedinherited

Referenced by Engines_Parallel_Component_i::getId(), KERNEL_PY.kernel.threadhelper.Runner::getId(), Engines_Parallel_Component_i::Resume_impl(), Engines_Parallel_Component_i::Stop_impl(), Engines_Parallel_Component_i::Suspend_impl(), and Engines_Parallel_Component_i::~Engines_Parallel_Component_i().

◆ _Input_Service_file_map

_t_Service_file_map Engines_Parallel_Component_i::_Input_Service_file_map

protectedinherited

Referenced by Engines_Parallel_Component_i::setInputFileToService().

◆ _instanceName

std::string Engines_Parallel_Component_i::_instanceName

protectedinherited

◆ _interfaceName

std::string Engines_Parallel_Component_i::_interfaceName

protectedinherited

Referenced by SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::_get_interfaceName(), Engines_Parallel_Component_i::interfaceName(), Engines_Parallel_Component_i::Resume_impl(), Engines_Parallel_Component_i::Stop_impl(), Engines_Parallel_Component_i::Suspend_impl(), and Engines_Parallel_Component_i::~Engines_Parallel_Component_i().

◆ _IOR_Proxy_Input_Service_file_map

_t_IOR_Proxy_Service_file_map Engines_Parallel_Component_i::_IOR_Proxy_Input_Service_file_map

protectedinherited

Referenced by Engines_Parallel_Component_i::setInputFileToService().

◆ _IOR_Proxy_Output_Service_file_map

_t_IOR_Proxy_Service_file_map Engines_Parallel_Component_i::_IOR_Proxy_Output_Service_file_map

protectedinherited

Referenced by Engines_Parallel_Component_i::setOutputFileToService().

◆ _IOR_Proxy_Salome_file_map_it

_t_IOR_Proxy_Salome_file_map::iterator Engines_Parallel_Component_i::_IOR_Proxy_Salome_file_map_it

protectedinherited

◆ _IOR_Proxy_Service_file_map_it

_t_IOR_Proxy_Service_file_map::iterator Engines_Parallel_Component_i::_IOR_Proxy_Service_file_map_it

protectedinherited

◆ _isMultiInstance

bool Engines_Parallel_Component_i::_isMultiInstance = false

staticprotectedinherited

◆ _myConnexionToRegistry

RegistryConnexion* Engines_Parallel_Component_i::_myConnexionToRegistry

protectedinherited

Referenced by Engines_Parallel_Component_i::Engines_Parallel_Component_i(), and Engines_Parallel_Component_i::~Engines_Parallel_Component_i().

◆ _nodeName

std::string Engines_Parallel_Component_i::_nodeName

protectedinherited

Referenced by SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::endService(), Engines_Parallel_Component_i::Names(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::Names(), Engines_Parallel_Component_i::nodeName(), and SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::nodeName().

◆ _notifSupplier

NOTIFICATION_Supplier* Engines_Parallel_Component_i::_notifSupplier

protectedinherited

Referenced by Engines_Parallel_Component_i::Engines_Parallel_Component_i(), Engines_Parallel_Component_i::sendMessage(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::sendMessage(), and Engines_Parallel_Component_i::~Engines_Parallel_Component_i().

◆ _orb

CORBA::ORB_var Engines_Parallel_Component_i::_orb

protectedinherited

Referenced by SALOME_Container.SALOME_Container_Abstract_i::__init__(), SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::__init__(), SALOME_ContainerPy.SALOME_ContainerPy_i::__init__(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::__init__(), SALOME_NamingServicePy.SALOME_NamingServicePy_i::__init__(), SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::create_component_instance(), SALOME_Container.SALOME_Container_Abstract_i::create_component_instance(), SALOME_Container.SALOME_Container_Abstract_i::create_pynode(), SALOME_Container.SALOME_Container_Abstract_i::create_pyscriptnode(), Engines_Parallel_Component_i::Engines_Parallel_Component_i(), get_proxy(), SALOME_Embedded_NamingService_ClientPy.SALOME_Embedded_NamingService_ClientPy::Register(), SALOME_Embedded_NamingService_ClientPy.SALOME_Embedded_NamingService_ClientPy::Resolve(), Engines_Parallel_Component_i::send_parallel_proxy_object(), Engines_Parallel_Component_i::setInputFileToService(), Engines_Parallel_Component_i::setOutputFileToService(), and SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::Shutdown().

◆ _Output_Service_file_map

_t_Service_file_map Engines_Parallel_Component_i::_Output_Service_file_map

protectedinherited

Referenced by Engines_Parallel_Component_i::setOutputFileToService().

◆ _poa

PortableServer::POA_var Engines_Parallel_Component_i::_poa

protectedinherited

Referenced by SALOME_Container.SALOME_Container_Abstract_i::__init__(), SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::__init__(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::__init__(), SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::create_component_instance(), SALOME_Container.SALOME_Container_Abstract_i::create_component_instance(), SALOME_Container.SALOME_Container_Abstract_i::create_pynode(), SALOME_Container.SALOME_Container_Abstract_i::create_pyscriptnode(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::destroy(), Engines_Parallel_Component_i::Engines_Parallel_Component_i(), Engines_Parallel_Component_i::GetContainerPtr(), Engines_Parallel_Component_i::GetContainerRef(), SALOME_PyNode.ContextExchanger_i::getInputContext(), and SALOME_PyNode.ContextExchanger_i::getPOA().

◆ _proxy

char* Engines_Parallel_Component_i::_proxy

protectedinherited

Referenced by Engines_Parallel_Component_i::Engines_Parallel_Component_i(), Engines_Parallel_Component_i::get_parallel_proxy_object(), Engines_Parallel_Component_i::send_parallel_proxy_object(), Engines_Parallel_Component_i::setInputFileToService(), Engines_Parallel_Component_i::setOutputFileToService(), and Engines_Parallel_Component_i::~Engines_Parallel_Component_i().

◆ _Proxy_Input_Service_file_map

_t_Proxy_Service_file_map Engines_Parallel_Component_i::_Proxy_Input_Service_file_map

protectedinherited

Referenced by Engines_Parallel_Component_i::checkInputFilesToService(), Engines_Parallel_Component_i::getInputFileToService(), and Engines_Parallel_Component_i::setInputFileToService().

◆ _Proxy_Output_Service_file_map

_t_Proxy_Service_file_map Engines_Parallel_Component_i::_Proxy_Output_Service_file_map

protectedinherited

Referenced by Engines_Parallel_Component_i::checkOutputFilesToService(), Engines_Parallel_Component_i::getOutputFileToService(), and Engines_Parallel_Component_i::setOutputFileToService().

◆ _Proxy_Salome_file_map_it

_t_Proxy_Salome_file_map::iterator Engines_Parallel_Component_i::_Proxy_Salome_file_map_it

protectedinherited

Referenced by Engines_Parallel_Component_i::getInputFileToService(), and Engines_Parallel_Component_i::getOutputFileToService().

◆ _Proxy_Service_file_map_it

_t_Proxy_Service_file_map::iterator Engines_Parallel_Component_i::_Proxy_Service_file_map_it

protectedinherited

Referenced by Engines_Parallel_Component_i::checkInputFilesToService(), Engines_Parallel_Component_i::checkOutputFilesToService(), Engines_Parallel_Component_i::getInputFileToService(), and Engines_Parallel_Component_i::getOutputFileToService().

◆ _Salome_file_map_it

_t_Salome_file_map::iterator Engines_Parallel_Component_i::_Salome_file_map_it

protectedinherited

Referenced by Engines_Parallel_Component_i::setInputFileToService(), and Engines_Parallel_Component_i::setOutputFileToService().

◆ _Service_file_map_it

_t_Service_file_map::iterator Engines_Parallel_Component_i::_Service_file_map_it

protectedinherited

Referenced by Engines_Parallel_Component_i::setInputFileToService(), and Engines_Parallel_Component_i::setOutputFileToService().

◆ _serviceName

std::string Engines_Parallel_Component_i::_serviceName

protectedinherited

Referenced by Engines_Parallel_Component_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), and SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::CpuUsed_impl().

◆ _StartUsed

long Engines_Parallel_Component_i::_StartUsed

privateinherited

Referenced by Engines_Parallel_Component_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), Engines_Parallel_Component_i::CpuUsed(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::CpuUsed_impl(), and Engines_Parallel_Component_i::endService().

◆ _thisObj

Engines_Parallel_Component_i* Engines_Parallel_Component_i::_thisObj

protectedinherited

◆ _ThreadCpuUsed

long Engines_Parallel_Component_i::_ThreadCpuUsed

privateinherited

Referenced by Engines_Parallel_Component_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), Engines_Parallel_Component_i::CpuUsed_impl(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::CpuUsed_impl(), Engines_Parallel_Component_i::endService(), and Engines_Parallel_Component_i::SetCurCpu().

◆ _ThreadId

pthread_t Engines_Parallel_Component_i::_ThreadId

privateinherited

Referenced by Engines_Parallel_Component_i::beginService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::beginService(), Engines_Parallel_Component_i::CpuUsed(), Engines_Parallel_Component_i::CpuUsed_impl(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::CpuUsed_impl(), Engines_Parallel_Component_i::endService(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::endService(), Engines_Parallel_Component_i::Kill_impl(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::Kill_impl(), Engines_Parallel_Component_i::Resume_impl(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::Resume_impl(), Engines_Parallel_Component_i::Stop_impl(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::Stop_impl(), Engines_Parallel_Component_i::Suspend_impl(), and SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::Suspend_impl().

◆ deploy_mutex

pthread_mutex_t* Engines_Parallel_Component_i::deploy_mutex

protectedinherited

Referenced by Engines_Parallel_Component_i::Engines_Parallel_Component_i(), Engines_Parallel_Component_i::setInputFileToService(), Engines_Parallel_Component_i::setOutputFileToService(), and Engines_Parallel_Component_i::~Engines_Parallel_Component_i().

◆ my_ports

ports Engines_DSC_interface::my_ports

protectedinherited

◆ my_ports_it

ports::iterator Engines_DSC_interface::my_ports_it

protectedinherited

Public Member Functions

Static Public Member Functions

Protected Types

Protected Attributes

Static Protected Attributes

Private Attributes

Member Typedef Documentation

◆ _t_IOR_Proxy_Salome_file_map

◆ _t_IOR_Proxy_Service_file_map

◆ _t_Proxy_Salome_file_map

◆ _t_Proxy_Service_file_map

◆ _t_Salome_file_map

◆ _t_Service_file_map

◆ ports

Member Enumeration Documentation

◆ port_type

Constructor & Destructor Documentation

◆ Engines_ParallelDSC_i()

◆ ~Engines_ParallelDSC_i()

Member Function Documentation

◆ add_parallel_provides_node_port()

◆ add_parallel_provides_proxy_port()

◆ add_parallel_provides_proxy_wait()

◆ add_provides_port()

◆ add_uses_port()

◆ beginService()

◆ CancelThread()

◆ checkInputFilesToService()

◆ checkOutputFilesToService()

◆ configureSalome_file()

◆ connect_provides_port()

◆ connect_uses_port()

◆ CpuUsed()

◆ CpuUsed_impl()

◆ destroy()

◆ disconnect_provides_port()

◆ disconnect_uses_port()

◆ DumpPython()

◆ endService()

◆ get_parallel_proxy_object()

◆ get_port_properties()

◆ get_provides_port()

◆ get_proxy()

◆ get_uses_port()

◆ GetContainerPtr()

◆ GetContainerRef()

◆ GetDynLibraryName()

◆ getId()

◆ getInputFileToService()

◆ getObjectInfo()

◆ getOutputFileToService()

◆ getProperties()

◆ graphName()

◆ hasObjectInfo()

◆ instanceName()

◆ interfaceName()

◆ is_connected()

◆ isMultiInstance()

◆ Kill_impl()

◆ Killer()

◆ Names()

◆ nodeName()

◆ ping()

◆ provides_port_changed()

◆ Resume_impl()

◆ send_parallel_proxy_object()

◆ sendMessage()

◆ set_paco_proxy()

◆ SetCurCpu()

◆ setInputFileToService()

◆ setOutputFileToService()

◆ setProperties()

◆ Stop_impl()

◆ Suspend_impl()

◆ uses_port_changed()

◆ wait_parallel_object_proxy()

◆ writeEvent()

Field Documentation

◆ _CanceledThread

◆ _contId