#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

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

protectedinherited

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

protectedinherited

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

protectedinherited

Constructor & Destructor Documentation

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

References parallel_file, and proxy.

Parallel_Salome_file_i::~Parallel_Salome_file_i ( )

virtual

Member Function Documentation

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

References SALOME::GenericObj_i::myPOA.

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, and INFOS.

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

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

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.

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.

void SALOME::GenericObj_i::Destroy ( )

virtualinherited

Decrement reference counter.

Deprecated:: Use UnRegister() instead.

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

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

virtualinherited

References Salome_file_i::_fileAccess, FILEBLOCK_SIZE, and INFOS.

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, and MESSAGE.

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

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

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.

Engines::files * Salome_file_i::getFilesInfos ( )

virtualinherited

CORBA method.

See Also: Engines::Salome_file::getFilesInfos

References Salome_file_i::_fileManaged.

Referenced by main().

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

virtual

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

Referenced by recvFiles_node().

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

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.

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 transfered

Returns: fileId = positive integer > 0 if open OK.

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

Referenced by Salome_file_i::load().

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 transfered

Returns: fileId = positive integer > 0 if open OK.

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

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.

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.

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, SALOME::ExceptionStruct::type, and Engines::file::type.

void SALOME::GenericObj_i::Register ( )

virtualinherited

Increment reference counter.

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

void Salome_file_i::removeFile ( const char * file_name )

virtualinherited

CORBA method.

See Also: Engines::Salome_file::removeFile

References MESSAGE.

void Salome_file_i::removeFiles ( )

virtualinherited

CORBA method.

See Also: Engines::Salome_file::removeFiles

References MESSAGE.

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.

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.

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

virtual

Reimplemented from Salome_file_i.

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

void Salome_file_i::setDistributedFile ( const char * comp_file_name )

virtualinherited

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

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.

void Salome_file_i::setLocalFile ( const char * comp_file_name )

virtualinherited

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, MYDEBUG, SALOME::GenericObj_i::myPOA, and SALOME::GenericObj_i::myRefCounter.

Referenced by SALOME::GenericObj_i::Destroy().

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

Engines::Container_ptr Salome_file_i::_container

protectedinherited

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

int fileTransfer_i::_ctr

protectedinherited

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

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

_t_fileAccess Salome_file_i::_fileAccess

protectedinherited

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

_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().

int Salome_file_i::_fileId

protectedinherited

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

int fileTransfer_i::_fileKey

protectedinherited

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

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

Engines::SfState Salome_file_i::_state

protectedinherited

Referenced by Salome_file_i::getSalome_fileState(), Salome_file_i::load(), recvFiles(), Salome_file_i::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().

PortableServer::POA_var SALOME::GenericObj_i::myPOA

protectedinherited

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

int SALOME::GenericObj_i::myRefCounter

protectedinherited

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

Engines::PaCO_Parallel_Salome_file* Parallel_Salome_file_i::parallel_file

private

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

Engines::Parallel_Salome_file_var Parallel_Salome_file_i::proxy

private

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

Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Private Attributes

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Field Documentation