#include <SALOMESDS_DataScopeServer.hxx>

Inheritance diagram for SALOMESDS::DataScopeServerTransaction:

[legend]

Public Member Functions
	DataScopeServerTransaction (const SALOME_CPythonHelper pyHelper, CORBA::ORB_ptr orb, SALOME::DataScopeKiller_var killer, const std::string &scopeName, SALOME_NamingService_Container_Abstract ns)

	DataScopeServerTransaction (const DataScopeServerTransaction &other)

	~DataScopeServerTransaction ()

void	createRdOnlyVarInternal (const std::string &varName, const SALOME::ByteVec &constValue)

void	createRdExtVarInternal (const std::string &varName, const SALOME::ByteVec &constValue)

void	createRdExtVarFreeStyleInternal (const std::string &varName, const SALOME::ByteVec &constValue, std::string &&compareFuncContent, SALOME::AutoPyRef &&compareFunc)

void	createRdExtInitVarInternal (const std::string &varName, const SALOME::ByteVec &constValue)

void	createRdWrVarInternal (const std::string &varName, const SALOME::ByteVec &constValue)

PortableServer::POA_var	getPOA4KeyWaiter () const

void	addWaitKey (KeyWaiter *kw)

void	pingKey (PyObject *keyObj)

void	notifyKey (const std::string &varName, PyObject keyObj, PyObject valueObj)

SALOME::ByteVec *	waitForMonoThrRev (SALOME::KeyWaiter_ptr kw)

SALOME::ByteVec *	waitForAndKill (SALOME::KeyWaiter_ptr kw)

char *	getAccessOfVar (const char *varName)

void	fetchAndGetAccessOfVar (const char *varName, CORBA::String_out access, SALOME::ByteVec_out data)
	This method is here to retrieve atomically accessStr and picklization. More...

SALOME::Transaction_ptr	createRdOnlyVarTransac (const char *varName, const SALOME::ByteVec &constValue)

SALOME::Transaction_ptr	createRdExtVarTransac (const char *varName, const SALOME::ByteVec &constValue)

SALOME::Transaction_ptr	createRdExtVarFreeStyleTransac (const char varName, const SALOME::ByteVec &constValue, const char compareFuncContent)

SALOME::Transaction_ptr	createRdExtInitVarTransac (const char *varName, const SALOME::ByteVec &constValue)

SALOME::Transaction_ptr	createRdWrVarTransac (const char *varName, const SALOME::ByteVec &constValue)

SALOME::Transaction_ptr	addKeyValueInVarHard (const char *varName, const SALOME::ByteVec &key, const SALOME::ByteVec &value)

SALOME::Transaction_ptr	addKeyValueInVarErrorIfAlreadyExisting (const char *varName, const SALOME::ByteVec &key, const SALOME::ByteVec &value)

SALOME::TransactionMultiKeyAddSession_ptr	addMultiKeyValueSession (const char *varName)

SALOME::Transaction_ptr	removeKeyInVarErrorIfNotAlreadyExisting (const char *varName, const SALOME::ByteVec &key)

SALOME::TransactionRdWrAccess_ptr	createWorkingVarTransac (const char *varName, const SALOME::ByteVec &constValue)

SALOME::Transaction_ptr	killVarTransac (const char *varName)

SALOME::KeyWaiter_ptr	waitForKeyInVar (const char *varName, const SALOME::ByteVec &keyVal)

SALOME::KeyWaiter_ptr	waitForKeyInVarAndKillIt (const char *varName, const SALOME::ByteVec &keyVal, SALOME::Transaction_out transac)

void	atomicApply (const SALOME::ListOfTransaction &transactions)

SALOME::RequestSwitcher_ptr	getRequestSwitcher ()

void	ping ()
	Called remotely -> to protect against throw. More...

char *	getScopeName ()
	Called remotely -> to protect against throw. More...

SALOME::StringVec *	listVars ()
	Called remotely -> to protect against throw. More...

CORBA::Boolean	existVar (const char *varName)

SALOME::BasicDataServer_ptr	retrieveVarInternal (const char *varName)

void	deleteVar (const char *varName)

CORBA::Boolean	shutdownIfNotHostedByDSM (SALOME::DataScopeKiller_out killer)

SALOME::ByteVec *	fetchSerializedContent (const char *varName)

SALOME::SeqOfByteVec *	getAllKeysOfVarWithTypeDict (const char *varName)

SALOME::ByteVec *	getValueOfVarWithTypeDict (const char *varName, const SALOME::ByteVec &constKey)

void	takeANap (CORBA::Double napDurationInSec)

BasicDataServer *	retrieveVarInternal2 (const std::string &varName)

void	registerToSalomePiDict () const

void	setPOA (PortableServer::POA_var poa)

void	registerInNS (SALOME::DataScopeServerBase_ptr ptr)

PyObject *	getGlobals () const

PyObject *	getLocals () const

PyObject *	getPickler () const

PortableServer::POA_var	getPOA () const

CORBA::ORB_var	getORB ()

std::string	getScopeNameCpp () const

std::vector< std::string >	getAllVarNames () const

bool	isExistingVar (const std::string &varName) const

void	checkNotAlreadyExistingVar (const std::string &varName) const

void	checkExistingVar (const std::string &varName) const

PickelizedPyObjServer *	checkVarExistingAndDict (const std::string &varName)

void	moveStatusOfVarFromRdWrToRdOnly (const std::string &varName)

void	moveStatusOfVarFromRdOnlyToRdWr (const std::string &varName)

void	moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit (const std::string &varName)

void	moveStatusOfVarFromRdExtOrRdExtInitToRdExt (const std::string &varName)

CORBA::Object_var	activate ()

void	enforcedRelease ()

Static Public Member Functions
static std::string	BuildTmpVarNameFrom (const std::string &varName)

Protected Member Functions
std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator	retrieveVarInternal3 (const std::string &varName) const

std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator	retrieveVarInternal4 (const std::string &varName)

Protected Attributes
SALOME_NamingService_Container_Abstract *	_ns = nullptr

const SALOME_CPythonHelper *	_pyHelper = nullptr

PortableServer::POA_var	_poa

CORBA::ORB_var	_orb

std::string	_name

std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >	_vars

SALOME::DataScopeKiller_var	_killer

Static Protected Attributes
static std::size_t	COUNTER =0

Private Attributes
PortableServer::POA_var	_poa_for_key_waiter

std::list< KeyWaiter * >	_waiting_keys

AutoServantPtr< RequestSwitcher >	_rs

Constructor & Destructor Documentation

◆ DataScopeServerTransaction() [1/2]

DataScopeServerTransaction::DataScopeServerTransaction	(	const SALOME_CPythonHelper *	pyHelper,
		CORBA::ORB_ptr	orb,
		SALOME::DataScopeKiller_var	killer,
		const std::string &	scopeName,
		SALOME_NamingService_Container_Abstract *	ns
	)

References SALOMESDS::DataScopeServerBase::_orb, _poa_for_key_waiter, KERNEL_PY.batchmode_salome::obj, and SALOME_ContainerPy::poa.

◆ DataScopeServerTransaction() [2/2]

DataScopeServerTransaction::DataScopeServerTransaction ( const DataScopeServerTransaction & other )

◆ ~DataScopeServerTransaction()

DataScopeServerTransaction::~DataScopeServerTransaction ( )

Member Function Documentation

◆ activate()

CORBA::Object_var SALOMESDS::POAHolder::activate ( )

inherited

< TODO: unused variables

References SALOMESDS::POAHolder::getPOA(), SALOME_ContainerPy::poa, and TestKernelHelpers::ret.

Referenced by SALOMESDS::DataServerManager::DataServerManager(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExt(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdOnlyToRdWr(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdWrToRdOnly(), and waitForKeyInVarAndKillIt().

◆ addKeyValueInVarErrorIfAlreadyExisting()

SALOME::Transaction_ptr DataScopeServerTransaction::addKeyValueInVarErrorIfAlreadyExisting	(	const char *	varName,
		const SALOME::ByteVec &	key,
		const SALOME::ByteVec &	value
	)

References SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ addKeyValueInVarHard()

SALOME::Transaction_ptr DataScopeServerTransaction::addKeyValueInVarHard	(	const char *	varName,
		const SALOME::ByteVec &	key,
		const SALOME::ByteVec &	value
	)

References SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ addMultiKeyValueSession()

SALOME::TransactionMultiKeyAddSession_ptr DataScopeServerTransaction::addMultiKeyValueSession ( const char * varName )

References SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ addWaitKey()

void DataScopeServerTransaction::addWaitKey ( KeyWaiter * kw )

References _waiting_keys.

Referenced by SALOMESDS::KeyWaiter::KeyWaiter().

◆ atomicApply()

void DataScopeServerTransaction::atomicApply ( const SALOME::ListOfTransaction & transactions )

< TODO: size_t to CORBA::ULong

References SALOMESDS::DataScopeServerBase::_poa.

◆ BuildTmpVarNameFrom()

std::string DataScopeServerBase::BuildTmpVarNameFrom ( const std::string & varName )

staticinherited

References SALOMESDS::DataScopeServerBase::COUNTER, and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::PickelizedPyObjRdExtServer::invokePythonMethodOn(), and SALOMESDS::PickelizedPyObjRdWrServer::invokePythonMethodOn().

◆ checkExistingVar()

void DataScopeServerBase::checkExistingVar ( const std::string & varName ) const

inherited

References SALOMESDS::DataScopeServerBase::getAllVarNames(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), getAccessOfVar(), and killVarTransac().

◆ checkNotAlreadyExistingVar()

void DataScopeServerBase::checkNotAlreadyExistingVar ( const std::string & varName ) const

inherited

References SALOMESDS::DataScopeServerBase::isExistingVar(), and TestSalomeSDSHelper0::varName.

Referenced by createRdExtInitVarInternal(), createRdExtInitVarTransac(), SALOMESDS::DataScopeServer::createRdExtVar(), createRdExtVarInternal(), createRdExtVarTransac(), SALOMESDS::DataScopeServer::createRdOnlyVar(), createRdOnlyVarInternal(), createRdOnlyVarTransac(), SALOMESDS::DataScopeServer::createRdWrVar(), createRdWrVarInternal(), createRdWrVarTransac(), and createWorkingVarTransac().

◆ checkVarExistingAndDict()

PickelizedPyObjServer * DataScopeServerBase::checkVarExistingAndDict ( const std::string & varName )

inherited

References SALOMESDS::DataScopeServerBase::checkExistingVar(), TestKernelHelpers::ret, SALOMESDS::DataScopeServerBase::retrieveVarInternal2(), and TestSalomeSDSHelper0::varName.

Referenced by addKeyValueInVarErrorIfAlreadyExisting(), SALOMESDS::TransactionMultiKeyAddSession::addKeyValueInVarErrorIfAlreadyExistingNow(), addKeyValueInVarHard(), addMultiKeyValueSession(), SALOMESDS::TransactionDictModify::checkVarExistingAndDict(), removeKeyInVarErrorIfNotAlreadyExisting(), waitForKeyInVar(), and waitForKeyInVarAndKillIt().

◆ createRdExtInitVarInternal()

void DataScopeServerTransaction::createRdExtInitVarInternal	(	const std::string &	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::_vars, SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), TestKernelHelpers::ret, TestSalomeSDS1::tmp, and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionRdExtInitVarCreate::perform().

◆ createRdExtInitVarTransac()

SALOME::Transaction_ptr DataScopeServerTransaction::createRdExtInitVarTransac	(	const char *	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ createRdExtVarFreeStyleInternal()

void DataScopeServerTransaction::createRdExtVarFreeStyleInternal	(	const std::string &	varName,
		const SALOME::ByteVec &	constValue,
		std::string &&	compareFuncContent,
		SALOME::AutoPyRef &&	compareFunc
	)

References SALOMESDS::DataScopeServerBase::_vars, SALOMESDS::Sha1Keeper::checkSame(), SALOMESDS::Transaction::FromByteSeqToVB(), SALOMESDS::PickelizedPyObjServer::getPyObj(), SALOMESDS::PickelizedPyObjServer::GetPyObjFromPickled(), SALOMESDS::DataScopeServerBase::isExistingVar(), SALOME::AutoPyRef::isNull(), TestKernelHelpers::ret, SALOMESDS::DataScopeServerBase::retrieveVarInternal2(), TestSalomeSDS1::tmp, and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionRdExtVarFreeStyleCreate::perform().

◆ createRdExtVarFreeStyleTransac()

SALOME::Transaction_ptr DataScopeServerTransaction::createRdExtVarFreeStyleTransac	(	const char *	varName,
		const SALOME::ByteVec &	constValue,
		const char *	compareFuncContent
	)

References KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ createRdExtVarInternal()

void DataScopeServerTransaction::createRdExtVarInternal	(	const std::string &	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::_vars, SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), TestKernelHelpers::ret, TestSalomeSDS1::tmp, and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionRdExtVarCreate::perform().

◆ createRdExtVarTransac()

SALOME::Transaction_ptr DataScopeServerTransaction::createRdExtVarTransac	(	const char *	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ createRdOnlyVarInternal()

void DataScopeServerTransaction::createRdOnlyVarInternal	(	const std::string &	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::_vars, SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), TestKernelHelpers::ret, TestSalomeSDS1::tmp, and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionRdOnlyVarCreate::perform().

◆ createRdOnlyVarTransac()

SALOME::Transaction_ptr DataScopeServerTransaction::createRdOnlyVarTransac	(	const char *	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ createRdWrVarInternal()

void DataScopeServerTransaction::createRdWrVarInternal	(	const std::string &	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::_vars, SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), TestKernelHelpers::ret, TestSalomeSDS1::tmp, and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionRdWrVarCreate::perform().

◆ createRdWrVarTransac()

SALOME::Transaction_ptr DataScopeServerTransaction::createRdWrVarTransac	(	const char *	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ createWorkingVarTransac()

SALOME::TransactionRdWrAccess_ptr DataScopeServerTransaction::createWorkingVarTransac	(	const char *	varName,
		const SALOME::ByteVec &	constValue
	)

References SALOMESDS::DataScopeServerBase::_vars, SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, TestSalomeSDS1::tmp, and TestSalomeSDSHelper0::varName.

◆ deleteVar()

void DataScopeServerBase::deleteVar ( const char * varName )

inherited

References SALOMESDS::DataScopeServerBase::_vars, pythonpath_reduction::copy(), SALOMESDS::DataScopeServerBase::getAllVarNames(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionKillVar::perform(), and SALOMESDS::TransactionVarCreate::rollBack().

◆ enforcedRelease()

void SALOMESDS::POAHolder::enforcedRelease ( )

inherited

References SALOMESDS::POAHolder::getPOA(), and SALOME_ContainerPy::poa.

Referenced by SALOMESDS::RefCountServ::decrRef(), SALOMESDS::BasicDataServer::Destroy(), SALOMESDS::DataScopeServerBase::shutdownIfNotHostedByDSM(), waitForAndKill(), and waitForMonoThrRev().

◆ existVar()

CORBA::Boolean DataScopeServerBase::existVar ( const char * varName )

inherited

References SALOMESDS::DataScopeServerBase::_vars, and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionVarCreate::rollBack().

◆ fetchAndGetAccessOfVar()

void DataScopeServerTransaction::fetchAndGetAccessOfVar	(	const char *	varName,
		CORBA::String_out	access,
		SALOME::ByteVec_out	data
	)

This method is here to retrieve atomically accessStr and picklization.

References SALOMESDS::DataScopeServerBase::fetchSerializedContent(), getAccessOfVar(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::RequestSwitcher::fetchAndGetAccessOfVar().

◆ fetchSerializedContent()

SALOME::ByteVec * DataScopeServerBase::fetchSerializedContent ( const char * varName )

inherited

References SALOMESDS::PickelizedPyObjServer::fetchSerializedContent(), SALOMESDS::DataScopeServerBase::retrieveVarInternal2(), and TestSalomeSDSHelper0::varName.

Referenced by fetchAndGetAccessOfVar(), and SALOMESDS::RequestSwitcher::fetchSerializedContent().

◆ getAccessOfVar()

char * DataScopeServerTransaction::getAccessOfVar ( const char * varName )

References SALOMESDS::DataScopeServerBase::checkExistingVar(), SALOMESDS::PickelizedPyObjServer::getAccessStr(), TestKernelHelpers::ret, SALOMESDS::DataScopeServerBase::retrieveVarInternal2(), and TestSalomeSDSHelper0::varName.

Referenced by fetchAndGetAccessOfVar().

◆ getAllKeysOfVarWithTypeDict()

SALOME::SeqOfByteVec * DataScopeServerBase::getAllKeysOfVarWithTypeDict ( const char * varName )

inherited

< TODO: convert Py_ssize_t in CORBA::ULong

References SALOMESDS::PickelizedPyObjServer::FromCppToByteSeq(), SALOMESDS::PickelizedPyObjServer::getPyObj(), SALOMESDS::PickelizedPyObjServer::isDict(), SALOMESDS::PickelizedPyObjServer::pickelize(), TestKernelHelpers::ret, SALOMESDS::DataScopeServerBase::retrieveVarInternal2(), and TestSalomeSDSHelper0::varName.

◆ getAllVarNames()

std::vector< std::string > DataScopeServerBase::getAllVarNames ( ) const

inherited

References SALOMESDS::DataScopeServerBase::_vars, and TestKernelHelpers::ret.

Referenced by SALOMESDS::DataScopeServerBase::checkExistingVar(), SALOMESDS::DataScopeServerBase::deleteVar(), SALOMESDS::DataScopeServerBase::isExistingVar(), SALOMESDS::DataScopeServerBase::retrieveVarInternal3(), and SALOMESDS::DataScopeServerBase::retrieveVarInternal4().

◆ getGlobals()

PyObject* SALOMESDS::DataScopeServerBase::getGlobals ( ) const

inherited

Referenced by SALOMESDS::TransactionRdExtVarFreeStyleCreate::TransactionRdExtVarFreeStyleCreate().

◆ getLocals()

PyObject* SALOMESDS::DataScopeServerBase::getLocals ( ) const

inherited

◆ getORB()

CORBA::ORB_var SALOMESDS::DataScopeServerBase::getORB ( )

inherited

◆ getPickler()

PyObject* SALOMESDS::DataScopeServerBase::getPickler ( ) const

inherited

Referenced by SALOMESDS::PickelizedPyObjServer::GetPyObjFromPickled(), and SALOMESDS::PickelizedPyObjServer::Pickelize().

◆ getPOA()

PortableServer::POA_var SALOMESDS::DataScopeServerBase::getPOA ( ) const

virtualinherited

Implements SALOMESDS::POAHolder.

References _poa.

Referenced by SALOMESDS::BasicDataServer::getMyDataScopeServer(), SALOMESDS::BasicDataServer::getPOA(), SALOMESDS::PickelizedPyObjRdExtServer::invokePythonMethodOn(), and SALOMESDS::PickelizedPyObjRdWrServer::invokePythonMethodOn().

◆ getPOA4KeyWaiter()

PortableServer::POA_var SALOMESDS::DataScopeServerTransaction::getPOA4KeyWaiter ( ) const

Referenced by SALOMESDS::KeyWaiter::getPOA().

◆ getRequestSwitcher()

SALOME::RequestSwitcher_ptr DataScopeServerTransaction::getRequestSwitcher ( )

References SALOMESDS::DataScopeServerBase::_orb, _rs, and KERNEL_PY.batchmode_salome::obj.

◆ getScopeName()

char * DataScopeServerBase::getScopeName ( )

inherited

Called remotely -> to protect against throw.

References SALOMESDS::DataScopeServerBase::_name.

Referenced by SALOMESDS::BasicDataServer::getScopeName().

◆ getScopeNameCpp()

std::string SALOMESDS::DataScopeServerBase::getScopeNameCpp ( ) const

inherited

◆ getValueOfVarWithTypeDict()

SALOME::ByteVec * DataScopeServerBase::getValueOfVarWithTypeDict	(	const char *	varName,
		const SALOME::ByteVec &	constKey
	)

inherited

References SALOMESDS::PickelizedPyObjServer::FromByteSeqToCpp(), SALOMESDS::PickelizedPyObjServer::FromCppToByteSeq(), SALOME::AutoPyRef::get(), SALOMESDS::PickelizedPyObjServer::getPyObj(), SALOMESDS::PickelizedPyObjServer::GetPyObjFromPickled(), SALOMESDS::PickelizedPyObjServer::isDict(), SALOMESDS::PickelizedPyObjServer::Pickelize(), TestKernelHelpers::ret, SALOMESDS::DataScopeServerBase::retrieveVarInternal2(), and TestSalomeSDSHelper0::varName.

◆ isExistingVar()

bool DataScopeServerBase::isExistingVar ( const std::string & varName ) const

inherited

References SALOMESDS::DataScopeServerBase::getAllVarNames(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), and createRdExtVarFreeStyleInternal().

◆ killVarTransac()

SALOME::Transaction_ptr DataScopeServerTransaction::killVarTransac ( const char * varName )

References SALOMESDS::DataScopeServerBase::checkExistingVar(), TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ listVars()

SALOME::StringVec * DataScopeServerBase::listVars ( )

inherited

Called remotely -> to protect against throw.

< TODO: size_t to CORBA::ULong

References SALOMESDS::DataScopeServerBase::_vars, pythfilter::name, KERNEL_PY.batchmode_salome::obj, and TestKernelHelpers::ret.

Referenced by SALOMESDS::RequestSwitcher::listVars().

◆ moveStatusOfVarFromRdExtOrRdExtInitToRdExt()

void DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExt ( const std::string & varName )

inherited

References SALOMESDS::POAHolder::activate(), SALOMESDS::PickelizedPyObjRdExtInitServer::buildStdInstanceFrom(), SALOMESDS::PickelizedPyObjRdExtInitServer::decrNbClients(), SALOMESDS::RefCountServ::decrRef(), KERNEL_PY.batchmode_salome::obj, SALOMESDS::DataScopeServerBase::retrieveVarInternal4(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionMultiKeyAddSession::perform().

◆ moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit()

void DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit ( const std::string & varName )

inherited

References SALOMESDS::POAHolder::activate(), SALOMESDS::PickelizedPyObjRdExtServer::buildInitInstanceFrom(), SALOMESDS::RefCountServ::decrRef(), SALOMESDS::PickelizedPyObjRdExtInitServer::incrNbClients(), KERNEL_PY.batchmode_salome::obj, SALOMESDS::DataScopeServerBase::retrieveVarInternal4(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionMultiKeyAddSession::TransactionMultiKeyAddSession().

◆ moveStatusOfVarFromRdOnlyToRdWr()

void DataScopeServerBase::moveStatusOfVarFromRdOnlyToRdWr ( const std::string & varName )

inherited

References SALOMESDS::POAHolder::activate(), SALOMESDS::RefCountServ::decrRef(), SALOMESDS::PickelizedPyObjServer::getPyObj(), KERNEL_PY.batchmode_salome::obj, SALOMESDS::DataScopeServerBase::retrieveVarInternal4(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionMorphRdWrIntoRdOnly::rollBack().

◆ moveStatusOfVarFromRdWrToRdOnly()

void DataScopeServerBase::moveStatusOfVarFromRdWrToRdOnly ( const std::string & varName )

inherited

References SALOMESDS::POAHolder::activate(), SALOMESDS::RefCountServ::decrRef(), SALOMESDS::PickelizedPyObjServer::getPyObj(), KERNEL_PY.batchmode_salome::obj, SALOMESDS::DataScopeServerBase::retrieveVarInternal4(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionMorphRdWrIntoRdOnly::perform().

◆ notifyKey()

void DataScopeServerTransaction::notifyKey	(	const std::string &	varName,
		PyObject *	keyObj,
		PyObject *	valueObj
	)

References _waiting_keys, pythfilter::args, test::res, TestSalomeSDSHelper0::varName, and TestSalomeSDSHelper0::waitKey().

Referenced by SALOMESDS::TransactionAddKeyValue::notify().

◆ ping()

void DataScopeServerBase::ping ( )

inherited

Called remotely -> to protect against throw.

◆ pingKey()

void DataScopeServerTransaction::pingKey ( PyObject * keyObj )

References _waiting_keys, pythfilter::args, test::res, and TestSalomeSDSHelper0::waitKey().

Referenced by SALOMESDS::TransactionAddKeyValue::prepareRollBackInCaseOfFailure().

◆ registerInNS()

void DataScopeServerBase::registerInNS ( SALOME::DataScopeServerBase_ptr ptr )

inherited

References SALOMESDS::DataScopeServerBase::_name, SALOMESDS::DataScopeServerBase::_ns, SALOMESDS::DataServerManager::CreateAbsNameInNSFromScopeName(), and SALOME_NamingService_Container_Abstract::Register().

Referenced by SALOMESDS::DataServerManager::DataServerManager().

◆ registerToSalomePiDict()

void DataScopeServerBase::registerToSalomePiDict ( ) const

inherited

References SALOMESDS::DataScopeServerBase::_pyHelper, and SALOME_CPythonHelper::registerToSalomePiDict().

◆ removeKeyInVarErrorIfNotAlreadyExisting()

SALOME::Transaction_ptr DataScopeServerTransaction::removeKeyInVarErrorIfNotAlreadyExisting	(	const char *	varName,
		const SALOME::ByteVec &	key
	)

References SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ retrieveVarInternal()

SALOME::BasicDataServer_ptr DataScopeServerBase::retrieveVarInternal ( const char * varName )

inherited

References SALOMESDS::DataScopeServerBase::retrieveVarInternal3(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::TransactionMorphRdWrIntoRdOnly::getVar().

◆ retrieveVarInternal2()

BasicDataServer * DataScopeServerBase::retrieveVarInternal2 ( const std::string & varName )

inherited

References SALOMESDS::DataScopeServerBase::retrieveVarInternal3(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), createRdExtVarFreeStyleInternal(), SALOMESDS::DataScopeServerBase::fetchSerializedContent(), getAccessOfVar(), SALOMESDS::DataScopeServerBase::getAllKeysOfVarWithTypeDict(), SALOMESDS::DataScopeServerBase::getValueOfVarWithTypeDict(), and SALOMESDS::TransactionMorphRdWrIntoRdOnly::prepareRollBackInCaseOfFailure().

◆ retrieveVarInternal3()

std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator DataScopeServerBase::retrieveVarInternal3 ( const std::string & varName ) const

protectedinherited

References SALOMESDS::DataScopeServerBase::_vars, pythonpath_reduction::copy(), SALOMESDS::DataScopeServerBase::getAllVarNames(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::DataScopeServerBase::retrieveVarInternal(), and SALOMESDS::DataScopeServerBase::retrieveVarInternal2().

◆ retrieveVarInternal4()

std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator DataScopeServerBase::retrieveVarInternal4 ( const std::string & varName )

protectedinherited

References SALOMESDS::DataScopeServerBase::_vars, pythonpath_reduction::copy(), SALOMESDS::DataScopeServerBase::getAllVarNames(), and TestSalomeSDSHelper0::varName.

Referenced by SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExt(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdOnlyToRdWr(), and SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdWrToRdOnly().

◆ setPOA()

void DataScopeServerBase::setPOA ( PortableServer::POA_var poa )

inherited

References SALOMESDS::DataScopeServerBase::_poa, and SALOME_ContainerPy::poa.

Referenced by SALOMESDS::DataServerManager::DataServerManager().

◆ shutdownIfNotHostedByDSM()

CORBA::Boolean DataScopeServerBase::shutdownIfNotHostedByDSM ( SALOME::DataScopeKiller_out killer )

inherited

References SALOMESDS::DataScopeServerBase::_killer, SALOMESDS::DataScopeServerBase::_name, SALOMESDS::DataScopeServerBase::_ns, SALOMESDS::DataScopeServerBase::_poa, SALOMESDS::DataServerManager::CreateAbsNameInNSFromScopeName(), SALOME_NamingService_Container_Abstract::Destroy_Name(), salome::dsm, SALOMESDS::POAHolder::enforcedRelease(), SALOMESDS::DataServerManager::NAME_IN_NS, KERNEL_PY.batchmode_salome::obj, SALOME_NamingService_Container_Abstract::Resolve(), and TestKernelHelpers::ret.

◆ takeANap()

void DataScopeServerBase::takeANap ( CORBA::Double napDurationInSec )

inherited

References TestKernelHelpers::ret.

◆ waitForAndKill()

SALOME::ByteVec * DataScopeServerTransaction::waitForAndKill ( SALOME::KeyWaiter_ptr kw )

References _poa_for_key_waiter, SALOMESDS::POAHolder::enforcedRelease(), TestKernelHelpers::ret, and SALOMESDS::KeyWaiter::waitForAndKill().

◆ waitForKeyInVar()

SALOME::KeyWaiter_ptr DataScopeServerTransaction::waitForKeyInVar	(	const char *	varName,
		const SALOME::ByteVec &	keyVal
	)

References SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), KERNEL_PY.batchmode_salome::obj, TestKernelHelpers::ret, and TestSalomeSDSHelper0::varName.

◆ waitForKeyInVarAndKillIt()

SALOME::KeyWaiter_ptr DataScopeServerTransaction::waitForKeyInVarAndKillIt	(	const char *	varName,
		const SALOME::ByteVec &	keyVal,
		SALOME::Transaction_out	transac
	)

References SALOMESDS::POAHolder::activate(), SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), KERNEL_PY.batchmode_salome::obj, and TestSalomeSDSHelper0::varName.

◆ waitForMonoThrRev()

SALOME::ByteVec * DataScopeServerTransaction::waitForMonoThrRev ( SALOME::KeyWaiter_ptr kw )

References _poa_for_key_waiter, SALOMESDS::POAHolder::enforcedRelease(), TestKernelHelpers::ret, and SALOMESDS::KeyWaiter::waitForMonoThr().

Field Documentation

◆ _killer

SALOME::DataScopeKiller_var SALOMESDS::DataScopeServerBase::_killer

protectedinherited

Referenced by SALOMESDS::DataScopeServerBase::shutdownIfNotHostedByDSM().

◆ _name

std::string SALOMESDS::DataScopeServerBase::_name

protectedinherited

Referenced by SALOMESDS::DataScopeServerBase::getScopeName(), SALOMESDS::DataScopeServerBase::registerInNS(), and SALOMESDS::DataScopeServerBase::shutdownIfNotHostedByDSM().

◆ _ns

SALOME_NamingService_Container_Abstract* SALOMESDS::DataScopeServerBase::_ns = nullptr

protectedinherited

Referenced by SALOMESDS::DataScopeServerBase::registerInNS(), SALOMESDS::DataScopeServerBase::shutdownIfNotHostedByDSM(), and SALOMESDS::DataScopeServerBase::~DataScopeServerBase().

◆ _orb

CORBA::ORB_var SALOMESDS::DataScopeServerBase::_orb

protectedinherited

Referenced by SALOME_Container.SALOME_Container_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_i::create_component_instance(), SALOME_Container.SALOME_Container_i::create_pynode(), SALOME_Container.SALOME_Container_i::create_pyscriptnode(), DataScopeServerTransaction(), getRequestSwitcher(), SALOME_Embedded_NamingService_ClientPy.SALOME_Embedded_NamingService_ClientPy::Register(), SALOME_Embedded_NamingService_ClientPy.SALOME_Embedded_NamingService_ClientPy::Resolve(), and SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::Shutdown().

◆ _poa

PortableServer::POA_var SALOMESDS::DataScopeServerBase::_poa

protectedinherited

Referenced by SALOME_Container.SALOME_Container_i::__init__(), SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::__init__(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::__init__(), atomicApply(), SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::create_component_instance(), SALOME_Container.SALOME_Container_i::create_component_instance(), SALOME_Container.SALOME_Container_i::create_pynode(), SALOME_Container.SALOME_Container_i::create_pyscriptnode(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::destroy(), SALOMESDS::DataScopeServerBase::setPOA(), and SALOMESDS::DataScopeServerBase::shutdownIfNotHostedByDSM().

◆ _poa_for_key_waiter

PortableServer::POA_var SALOMESDS::DataScopeServerTransaction::_poa_for_key_waiter

private

Referenced by DataScopeServerTransaction(), waitForAndKill(), and waitForMonoThrRev().

◆ _pyHelper

const SALOME_CPythonHelper* SALOMESDS::DataScopeServerBase::_pyHelper = nullptr

protectedinherited

Referenced by SALOMESDS::DataScopeServerBase::registerToSalomePiDict().

◆ _rs

AutoServantPtr<RequestSwitcher> SALOMESDS::DataScopeServerTransaction::_rs

private

Referenced by getRequestSwitcher().

◆ _vars

std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > > SALOMESDS::DataScopeServerBase::_vars

protectedinherited

◆ _waiting_keys

std::list< KeyWaiter * > SALOMESDS::DataScopeServerTransaction::_waiting_keys

private

Referenced by addWaitKey(), notifyKey(), and pingKey().

◆ COUNTER

std::size_t DataScopeServerBase::COUNTER =0

staticprotectedinherited

Referenced by SALOMESDS::DataScopeServerBase::BuildTmpVarNameFrom().

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Static Protected Attributes

Private Attributes

Constructor & Destructor Documentation

◆ DataScopeServerTransaction() [1/2]

◆ DataScopeServerTransaction() [2/2]

◆ ~DataScopeServerTransaction()

Member Function Documentation

◆ activate()

◆ addKeyValueInVarErrorIfAlreadyExisting()

◆ addKeyValueInVarHard()

◆ addMultiKeyValueSession()

◆ addWaitKey()

◆ atomicApply()

◆ BuildTmpVarNameFrom()

◆ checkExistingVar()

◆ checkNotAlreadyExistingVar()

◆ checkVarExistingAndDict()

◆ createRdExtInitVarInternal()

◆ createRdExtInitVarTransac()

◆ createRdExtVarFreeStyleInternal()

◆ createRdExtVarFreeStyleTransac()

◆ createRdExtVarInternal()

◆ createRdExtVarTransac()

◆ createRdOnlyVarInternal()

◆ createRdOnlyVarTransac()

◆ createRdWrVarInternal()

◆ createRdWrVarTransac()

◆ createWorkingVarTransac()

◆ deleteVar()

◆ enforcedRelease()

◆ existVar()

◆ fetchAndGetAccessOfVar()

◆ fetchSerializedContent()

◆ getAccessOfVar()

◆ getAllKeysOfVarWithTypeDict()

◆ getAllVarNames()

◆ getGlobals()

◆ getLocals()

◆ getORB()

◆ getPickler()

◆ getPOA()

◆ getPOA4KeyWaiter()

◆ getRequestSwitcher()

◆ getScopeName()

◆ getScopeNameCpp()

◆ getValueOfVarWithTypeDict()

◆ isExistingVar()

◆ killVarTransac()

◆ listVars()

◆ moveStatusOfVarFromRdExtOrRdExtInitToRdExt()

◆ moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit()

◆ moveStatusOfVarFromRdOnlyToRdWr()

◆ moveStatusOfVarFromRdWrToRdOnly()

◆ notifyKey()

◆ ping()

◆ pingKey()

◆ registerInNS()

◆ registerToSalomePiDict()

◆ removeKeyInVarErrorIfNotAlreadyExisting()

◆ retrieveVarInternal()

◆ retrieveVarInternal2()

◆ retrieveVarInternal3()

◆ retrieveVarInternal4()

◆ setPOA()

◆ shutdownIfNotHostedByDSM()

◆ takeANap()

◆ waitForAndKill()

◆ waitForKeyInVar()

◆ waitForKeyInVarAndKillIt()

◆ waitForMonoThrRev()

Field Documentation

◆ _killer

◆ _name

◆ _ns

◆ _orb

◆ _poa