Parallel_Salome_file_i Class Reference

#include <Parallel_Salome_file_i.hxx>

Inheritance diagram for Parallel_Salome_file_i:

Public Member Functions
	Parallel_Salome_file_i (CORBA::ORB_ptr orb, const char *ior, int rank)
virtual	~Parallel_Salome_file_i ()
virtual void	setFileNode (const char *file_name, CORBA::Long node)
virtual CORBA::Long	getFileNode (const char *file_name)
virtual Engines::Container_ptr	updateFile (const Engines::file &file)
virtual void	load (const char *hdf5_file)
	CORBA method. More...
virtual void	save (const char *hdf5_file)
	CORBA method. More...
virtual void	save_all (const char *hdf5_file)
	CORBA method. More...
virtual void	connect (Engines::Salome_file_ptr source_Salome_file)
	CORBA method. More...
virtual void	connectDistributedFile (const char *file_name, Engines::Salome_file_ptr source_Salome_file)
	CORBA method. More...
virtual void	setDistributedSourceFile (const char *file_name, const char *source_file_name)
	CORBA method. More...
virtual void	recvFiles ()
	CORBA method. More...
virtual void	recvFiles_node ()
virtual void	setContainer (Engines::Container_ptr container)
virtual bool	getParallelDistributedFile (std::string file_name)
virtual void	setLocalFile (const char *comp_file_name)
	CORBA method. More...
virtual void	setDistributedFile (const char *comp_file_name)
	CORBA method. More...
virtual void	removeFile (const char *file_name)
	CORBA method. More...
virtual void	removeFiles ()
	CORBA method. More...
virtual Engines::files *	getFilesInfos ()
	CORBA method. More...
virtual Engines::file *	getFileInfos (const char *file_name)
	CORBA method. More...
virtual Engines::SfState *	getSalome_fileState ()
	CORBA method. More...
virtual CORBA::Long	open (const char *file_name)
	CORBA method: try to open the file given. More...
virtual void	close (CORBA::Long fileId)
	CORBA method: close the file associated to the fileId given at open. More...
virtual Engines::fileBlock *	getBlock (CORBA::Long fileId)
CORBA::Long	openW (const char *fileName)
	open the given file in write mode (for copy) More...
void	putBlock (CORBA::Long fileId, const Engines::fileBlock &block)
	put a data block for copy into a file More...
virtual PortableServer::POA_ptr	_default_POA ()
	Get default POA for the servant object. More...
virtual void	Register ()
	Increment reference counter. More...
virtual void	UnRegister ()
	Decrement reference counter. More...
virtual void	Destroy ()
	Decrement reference counter. More...

Protected Types
typedef std::map< int, FILE * >	_t_fileAccess
typedef std::map< std::string, Engines::file >	_t_fileManaged
typedef std::map< std::string, Engines::Salome_file_var >	_t_fileDistributedSource

Protected Member Functions
virtual bool	checkLocalFile (std::string file_name)
	local C++ method : This method is used by revFiles to check if a local managed file is ok. More...
virtual bool	getDistributedFile (std::string file_name)
	local C++ method : this method is used by recvFiles to get a distributed file from is distributed source. More...

Protected Attributes
int	_fileId
long	_path_max
_t_fileAccess	_fileAccess
_t_fileManaged	_fileManaged
_t_fileDistributedSource	_fileDistributedSource
Engines::SfState	_state
Engines::Container_ptr	_container
Engines::Salome_file_var	_default_source_Salome_file
int	_fileKey
int	_ctr
PortableServer::POA_var	myPOA
int	myRefCounter

Private Attributes
Engines::Parallel_Salome_file_var	proxy
Engines::PaCO_Parallel_Salome_file *	parallel_file

Member Typedef Documentation

_t_fileAccess

typedef std::map<int, FILE*> Salome_file_i::_t_fileAccess

protectedinherited

_t_fileDistributedSource

typedef std::map<std::string, Engines::Salome_file_var> Salome_file_i::_t_fileDistributedSource

protectedinherited

_t_fileManaged

typedef std::map<std::string, Engines::file> Salome_file_i::_t_fileManaged

protectedinherited

Constructor & Destructor Documentation

Parallel_Salome_file_i()

Parallel_Salome_file_i::Parallel_Salome_file_i	(	CORBA::ORB_ptr	orb,
		const char *	ior,
		int	rank
	)

References KERNEL_PY.batchmode_salome::obj, parallel_file, and proxy.

~Parallel_Salome_file_i()

Parallel_Salome_file_i::~Parallel_Salome_file_i ( )

virtual

Member Function Documentation

_default_POA()

PortableServer::POA_ptr SALOME::GenericObj_i::_default_POA ( )

virtualinherited

Get default POA for the servant object.

This function is implicitly called from "_this()" function. Default POA can be set via the constructor.

Returns

reference to the default POA for the servant

Reimplemented in SALOMEDS_UseCaseIterator_i, SALOMEDS_UseCaseBuilder_i, SALOMEDS_SObject_i, SALOMEDS_SComponentIterator_i, SALOMEDS_GenericAttribute_i, and SALOMEDS_ChildIterator_i.

References SALOME::GenericObj_i::myPOA.

checkLocalFile()

bool Salome_file_i::checkLocalFile ( std::string  file_name )

protectedvirtualinherited

local C++ method : This method is used by revFiles to check if a local managed file is ok.

Parameters

fileName

name of the file

References Salome_file_i::_fileManaged, INFOS, and ORBConfigFile::path.

Referenced by Salome_file_i::recvFiles(), and recvFiles_node().

close()

void Salome_file_i::close ( CORBA::Long  fileId )

virtualinherited

CORBA method: close the file associated to the fileId given at open.

Parameters

fileId

got in return from open method

References Salome_file_i::_fileAccess, INFOS, and MESSAGE.

Referenced by Salome_file_i::load().

connect()

void Parallel_Salome_file_i::connect ( Engines::Salome_file_ptr  source_Salome_file )

virtual

CORBA method.

See also

Engines::Salome_file::connect

Reimplemented from Salome_file_i.

References Salome_file_i::_fileManaged, Salome_file_i::connect(), parallel_file, and proxy.

connectDistributedFile()

void Parallel_Salome_file_i::connectDistributedFile ( const char *  file_name, Engines::Salome_file_ptr  source_Salome_file  )

virtual

CORBA method.

See also

Engines::Salome_file::connectDistributedFile

Reimplemented from Salome_file_i.

References Salome_file_i::_fileManaged, Salome_file_i::connectDistributedFile(), parallel_file, and proxy.

Destroy()

void SALOME::GenericObj_i::Destroy ( )

virtualinherited

Decrement reference counter.

Deprecated:

Use UnRegister() instead.

References MESSAGE, and SALOME::GenericObj_i::UnRegister().

getBlock()

Engines::fileBlock * Salome_file_i::getBlock ( CORBA::Long  fileId )

virtualinherited

References Salome_file_i::_fileAccess, FILEBLOCK_SIZE, and INFOS.

getDistributedFile()

bool Salome_file_i::getDistributedFile ( std::string  file_name )

protectedvirtualinherited

local C++ method : this method is used by recvFiles to get a distributed file from is distributed source.

If there is no source_file_name for the file, it tries to get the file from the source. In this case, the source distributed file has to managed only one file to be able to the send the file.

Parameters

fileName

name of the file

References Salome_file_i::_fileDistributedSource, Salome_file_i::_fileManaged, ASSERT, INFOS, MESSAGE, and ORBConfigFile::path.

Referenced by Salome_file_i::recvFiles(), and recvFiles_node().

getFileInfos()

Engines::file * Salome_file_i::getFileInfos ( const char *  file_name )

virtualinherited

CORBA method.

See also

Engines::Salome_file::getFileInfos

References Salome_file_i::_fileManaged, SALOME::INTERNAL_ERROR, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

Referenced by main().

getFileNode()

CORBA::Long Parallel_Salome_file_i::getFileNode ( const char *  file_name )

virtual

References Salome_file_i::_fileManaged, SALOME::INTERNAL_ERROR, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

getFilesInfos()

Engines::files * Salome_file_i::getFilesInfos ( )

virtualinherited

CORBA method.

See also

Engines::Salome_file::getFilesInfos

References Salome_file_i::_fileManaged.

Referenced by main().

getParallelDistributedFile()

bool Parallel_Salome_file_i::getParallelDistributedFile ( std::string  file_name )

virtual

References Salome_file_i::_fileDistributedSource, Salome_file_i::_fileManaged, ASSERT, INFOS, MESSAGE, and ORBConfigFile::path.

Referenced by recvFiles_node().

getSalome_fileState()

Engines::SfState * Salome_file_i::getSalome_fileState ( )

virtualinherited

CORBA method.

See also

Engines::Salome_file::getSalome_fileState

References Salome_file_i::_state.

Referenced by main().

load()

void Parallel_Salome_file_i::load ( const char *  hdf5_file )

virtual

CORBA method.

See also

Engines::Salome_file::load

Reimplemented from Salome_file_i.

References SALOME::INTERNAL_ERROR, MESSAGE, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

open()

CORBA::Long Salome_file_i::open ( const char *  file_name )

virtualinherited

CORBA method: try to open the file given.

If the file is readable, return a positive integer else return 0;

Parameters

fileName

file name to be transferred

Returns

fileId = positive integer > 0 if open OK.

References Salome_file_i::_fileAccess, Salome_file_i::_fileId, Salome_file_i::_fileManaged, INFOS, MESSAGE, and ORBConfigFile::path.

Referenced by Salome_file_i::load().

openW()

CORBA::Long fileTransfer_i::openW ( const char *  fileName )

inherited

open the given file in write mode (for copy)

CORBA method: try to open the file. If the file is writable, return a positive integer else return 0;

Parameters

fileName

path to the file to be transferred

Returns

fileId = positive integer > 0 if open OK.

References fileTransfer_i::_ctr, fileTransfer_i::_fileAccess, fileTransfer_i::_fileKey, INFOS, and MESSAGE.

putBlock()

void fileTransfer_i::putBlock ( CORBA::Long  fileId, const Engines::fileBlock &  block  )

inherited

put a data block for copy into a file

CORBA method: put a block of data into the file associated to the fileId given at openW.

Parameters

fileId	got in return from openW method
block	an octet sequence to copy into opened file

References fileTransfer_i::_fileAccess, INFOS, MESSAGE, and SCRUTE.

recvFiles()

void Parallel_Salome_file_i::recvFiles ( )

virtual

CORBA method.

See also

Engines::Salome_file::recvFiles

Reimplemented from Salome_file_i.

References Salome_file_i::_state, SALOME::SALOME_Exception::details, Engines::SfState::files_ok, SALOME::INTERNAL_ERROR, parallel_file, proxy, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

recvFiles_node()

void Parallel_Salome_file_i::recvFiles_node ( )

virtual

References Salome_file_i::_fileDistributedSource, Salome_file_i::_fileManaged, Salome_file_i::checkLocalFile(), Engines::file::file_name, Salome_file_i::getDistributedFile(), getParallelDistributedFile(), SALOME::INTERNAL_ERROR, Engines::file::node, Engines::file::status, SALOME::ExceptionStruct::text, Engines::file::type, and SALOME::ExceptionStruct::type.

Register()

void SALOME::GenericObj_i::Register ( )

virtualinherited

Increment reference counter.

References IS_OBJ_IN_QUESTION, MESSAGE, and SALOME::GenericObj_i::myRefCounter.

removeFile()

void Salome_file_i::removeFile ( const char *  file_name )

virtualinherited

CORBA method.

See also

Engines::Salome_file::removeFile

References MESSAGE.

removeFiles()

void Salome_file_i::removeFiles ( )

virtualinherited

CORBA method.

See also

Engines::Salome_file::removeFiles

References MESSAGE.

save()

void Parallel_Salome_file_i::save ( const char *  hdf5_file )

virtual

CORBA method.

See also

Engines::Salome_file::save

Reimplemented from Salome_file_i.

References SALOME::INTERNAL_ERROR, MESSAGE, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

save_all()

void Parallel_Salome_file_i::save_all ( const char *  hdf5_file )

virtual

CORBA method.

See also

Engines::Salome_file::save_all

Reimplemented from Salome_file_i.

References SALOME::INTERNAL_ERROR, MESSAGE, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

setContainer()

void Parallel_Salome_file_i::setContainer ( Engines::Container_ptr  container )

virtual

Reimplemented from Salome_file_i.

References Salome_file_i::_container, Salome_file_i::_fileManaged, and TestComponentPy::container.

setDistributedFile()

void Salome_file_i::setDistributedFile ( const char *  comp_file_name )

virtualinherited

CORBA method.

See also

Engines::Salome_file::setDistributedFile

References Salome_file_i::_container, Salome_file_i::_default_source_Salome_file, Salome_file_i::_fileDistributedSource, Salome_file_i::_fileManaged, Salome_file_i::_path_max, Salome_file_i::_state, Engines::file::container, Engines::file::file_name, Engines::SfState::files_ok, python_test_driver::index, SALOME::INTERNAL_ERROR, Engines::file::node, Engines::SfState::number_of_files, ORBConfigFile::path, Engines::file::path, Engines::file::source_file_name, salomeContext::status, Engines::file::status, SALOME::ExceptionStruct::text, Engines::file::type, and SALOME::ExceptionStruct::type.

Referenced by main().

setDistributedSourceFile()

void Parallel_Salome_file_i::setDistributedSourceFile ( const char *  file_name, const char *  source_file_name  )

virtual

CORBA method.

See also

Engines::Salome_file::setDistributedSourceFile

Reimplemented from Salome_file_i.

References Salome_file_i::_fileManaged, parallel_file, proxy, and Salome_file_i::setDistributedSourceFile().

setFileNode()

void Parallel_Salome_file_i::setFileNode ( const char *  file_name, CORBA::Long  node  )

virtual

References Salome_file_i::_fileDistributedSource, Salome_file_i::_fileManaged, SALOME::INTERNAL_ERROR, parallel_file, proxy, SALOME::ExceptionStruct::text, and SALOME::ExceptionStruct::type.

setLocalFile()

void Salome_file_i::setLocalFile ( const char *  comp_file_name )

virtualinherited

CORBA method.

See also

Engines::Salome_file::setLocalFile

References Salome_file_i::_container, Salome_file_i::_fileManaged, Salome_file_i::_path_max, Salome_file_i::_state, Engines::file::container, Engines::file::file_name, Engines::SfState::files_ok, python_test_driver::index, SALOME::INTERNAL_ERROR, Engines::file::node, Engines::SfState::number_of_files, ORBConfigFile::path, Engines::file::path, Engines::file::source_file_name, salomeContext::status, Engines::file::status, SALOME::ExceptionStruct::text, Engines::file::type, and SALOME::ExceptionStruct::type.

Referenced by Abstract_Engines_Container_i::createSalome_file(), Engines_Parallel_Container_i::createSalome_file(), and main().

UnRegister()

void SALOME::GenericObj_i::UnRegister ( )

virtualinherited

Decrement reference counter.

As soon as reference counter goes to zero, the object is automatically deactivated.

References IS_OBJ_IN_QUESTION, MESSAGE, SALOME::GenericObj_i::myPOA, and SALOME::GenericObj_i::myRefCounter.

Referenced by SALOME::GenericObj_i::Destroy(), and SALOME_PyNode.Generic::Destroy().

updateFile()

Engines::Container_ptr Parallel_Salome_file_i::updateFile ( const Engines::file &  file )

virtual

References Salome_file_i::_container, Salome_file_i::_fileManaged, Engines::file::container, and Engines::file::file_name.

Field Documentation

_container

Engines::Container_ptr Salome_file_i::_container

protectedinherited

Referenced by SALOME_Container.SALOME_Container_i::create_component_instance(), Salome_file_i::load(), Salome_file_i::Salome_file_i(), Salome_file_i::setContainer(), setContainer(), Salome_file_i::setDistributedFile(), Salome_file_i::setLocalFile(), and updateFile().

_ctr

int fileTransfer_i::_ctr

protectedinherited

Referenced by fileTransfer_i::open(), and fileTransfer_i::openW().

_default_source_Salome_file

Engines::Salome_file_var Salome_file_i::_default_source_Salome_file

protectedinherited

Referenced by Salome_file_i::connect(), Salome_file_i::Salome_file_i(), and Salome_file_i::setDistributedFile().

_fileAccess

_t_fileAccess Salome_file_i::_fileAccess

protectedinherited

Referenced by Salome_file_i::close(), Salome_file_i::getBlock(), and Salome_file_i::open().

_fileDistributedSource

_t_fileDistributedSource Salome_file_i::_fileDistributedSource

protectedinherited

Referenced by Salome_file_i::connect(), Salome_file_i::connectDistributedFile(), Salome_file_i::getDistributedFile(), getParallelDistributedFile(), recvFiles_node(), Salome_file_i::setDistributedFile(), and setFileNode().

_fileId

int Salome_file_i::_fileId

protectedinherited

Referenced by Salome_file_i::open(), and Salome_file_i::Salome_file_i().

_fileKey

int fileTransfer_i::_fileKey

protectedinherited

Referenced by fileTransfer_i::fileTransfer_i(), fileTransfer_i::open(), and fileTransfer_i::openW().

_fileManaged

_t_fileManaged Salome_file_i::_fileManaged

protectedinherited

Referenced by Salome_file_i::checkLocalFile(), Salome_file_i::connect(), connect(), Salome_file_i::connectDistributedFile(), connectDistributedFile(), Salome_file_i::getDistributedFile(), Salome_file_i::getFileInfos(), getFileNode(), Salome_file_i::getFilesInfos(), getParallelDistributedFile(), Salome_file_i::load(), Salome_file_i::open(), Salome_file_i::recvFiles(), recvFiles_node(), Salome_file_i::save(), Salome_file_i::save_all(), Salome_file_i::setContainer(), setContainer(), Salome_file_i::setDistributedFile(), Salome_file_i::setDistributedSourceFile(), setDistributedSourceFile(), setFileNode(), Salome_file_i::setLocalFile(), and updateFile().

_path_max

long Salome_file_i::_path_max

protectedinherited

Referenced by Salome_file_i::load(), Salome_file_i::Salome_file_i(), Salome_file_i::setDistributedFile(), and Salome_file_i::setLocalFile().

_state

Engines::SfState Salome_file_i::_state

protectedinherited

Referenced by Salome_file_i::getSalome_fileState(), Salome_file_i::load(), Salome_file_i::recvFiles(), recvFiles(), Salome_file_i::Salome_file_i(), Salome_file_i::save(), Salome_file_i::save_all(), Salome_file_i::setDistributedFile(), and Salome_file_i::setLocalFile().

myPOA

PortableServer::POA_var SALOME::GenericObj_i::myPOA

protectedinherited

Referenced by SALOME::GenericObj_i::_default_POA(), SALOMEDS_ChildIterator_i::_default_POA(), SALOMEDS_GenericAttribute_i::_default_POA(), SALOMEDS_SComponentIterator_i::_default_POA(), SALOMEDS_SObject_i::_default_POA(), SALOMEDS_UseCaseBuilder_i::_default_POA(), SALOMEDS_UseCaseIterator_i::_default_POA(), SALOME::GenericObj_i::GenericObj_i(), and SALOME::GenericObj_i::UnRegister().

myRefCounter

int SALOME::GenericObj_i::myRefCounter

protectedinherited

Referenced by SALOME::GenericObj_i::Register(), and SALOME::GenericObj_i::UnRegister().

parallel_file

Engines::PaCO_Parallel_Salome_file* Parallel_Salome_file_i::parallel_file

private

Referenced by connect(), connectDistributedFile(), Parallel_Salome_file_i(), recvFiles(), setDistributedSourceFile(), and setFileNode().

proxy

Engines::Parallel_Salome_file_var Parallel_Salome_file_i::proxy

private

Referenced by dsccalcium.PyDSCComponent::beginService(), dsccalcium.PyDSCComponent::checkInputFilesToService(), dsccalcium.PyDSCComponent::checkOutputFilesToService(), connect(), dsccalcium.PyDSCComponent::connect_provides_port(), dsccalcium.PyDSCComponent::connect_uses_port(), connectDistributedFile(), dsccalcium.PyDSCComponent::disconnect_provides_port(), dsccalcium.PyDSCComponent::disconnect_uses_port(), dsccalcium.PyDSCComponent::get_port_properties(), dsccalcium.PyDSCComponent::get_provides_port(), dsccalcium.PyDSCComponent::getInputFileToService(), dsccalcium.PyDSCComponent::getOutputFileToService(), Parallel_Salome_file_i(), recvFiles(), setDistributedSourceFile(), setFileNode(), dsccalcium.PyDSCComponent::setInputFileToService(), and dsccalcium.PyDSCComponent::setOutputFileToService().