Version: 9.12.0
Public Member Functions | Static Public Member Functions | Protected Member Functions | Protected Attributes | Static Protected Attributes
SALOMESDS::DataScopeServerBase Class Reference

#include <SALOMESDS_DataScopeServer.hxx>

Inheritance diagram for SALOMESDS::DataScopeServerBase:
Inheritance graph
[legend]

Public Member Functions

 DataScopeServerBase (const SALOME_CPythonHelper *pyHelper, CORBA::ORB_ptr orb, SALOME::DataScopeKiller_var killer, const std::string &scopeName, SALOME_NamingService_Container_Abstract *ns)
 
 DataScopeServerBase (const DataScopeServerBase &other)
 
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)
 
 ~DataScopeServerBase ()
 
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
 

Constructor & Destructor Documentation

◆ DataScopeServerBase() [1/2]

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

◆ DataScopeServerBase() [2/2]

DataScopeServerBase::DataScopeServerBase ( const DataScopeServerBase &  other)

◆ ~DataScopeServerBase()

DataScopeServerBase::~DataScopeServerBase ( )

References _ns, _vars, and KERNEL_PY.batchmode_salome::obj.

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(), moveStatusOfVarFromRdExtOrRdExtInitToRdExt(), moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit(), moveStatusOfVarFromRdOnlyToRdWr(), moveStatusOfVarFromRdWrToRdOnly(), and SALOMESDS::DataScopeServerTransaction::waitForKeyInVarAndKillIt().

◆ BuildTmpVarNameFrom()

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

References COUNTER, and TestSalomeSDSHelper0::varName.

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

◆ checkExistingVar()

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

References getAllVarNames(), and TestSalomeSDSHelper0::varName.

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

◆ checkNotAlreadyExistingVar()

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

References isExistingVar(), and TestSalomeSDSHelper0::varName.

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

◆ checkVarExistingAndDict()

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

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

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

◆ deleteVar()

void DataScopeServerBase::deleteVar ( const char *  varName)

References _vars, pythonpath_reduction::copy(), 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(), shutdownIfNotHostedByDSM(), SALOMESDS::DataScopeServerTransaction::waitForAndKill(), and SALOMESDS::DataScopeServerTransaction::waitForMonoThrRev().

◆ existVar()

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

References _vars, and TestSalomeSDSHelper0::varName.

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

◆ fetchSerializedContent()

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

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

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

◆ getAllKeysOfVarWithTypeDict()

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

< TODO: convert Py_ssize_t in CORBA::ULong

< TODO: convert Py_ssize_t in CORBA::ULong

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

◆ getAllVarNames()

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

References _vars, and TestKernelHelpers::ret.

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

◆ getGlobals()

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

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

◆ getLocals()

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

◆ getORB()

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

◆ getPickler()

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

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

◆ getPOA()

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

Implements SALOMESDS::POAHolder.

References _poa.

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

◆ getScopeName()

char * DataScopeServerBase::getScopeName ( )

Called remotely -> to protect against throw.

References _name.

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

◆ getScopeNameCpp()

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

◆ getValueOfVarWithTypeDict()

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

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

◆ isExistingVar()

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

References getAllVarNames(), and TestSalomeSDSHelper0::varName.

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

◆ listVars()

SALOME::StringVec * DataScopeServerBase::listVars ( )

Called remotely -> to protect against throw.

< TODO: size_t to CORBA::ULong

< TODO: size_t to CORBA::ULong

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

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

◆ moveStatusOfVarFromRdExtOrRdExtInitToRdExt()

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

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

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

◆ moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit()

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

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

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

◆ moveStatusOfVarFromRdOnlyToRdWr()

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

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

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

◆ moveStatusOfVarFromRdWrToRdOnly()

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

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

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

◆ ping()

void DataScopeServerBase::ping ( )

Called remotely -> to protect against throw.

◆ registerInNS()

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

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

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

◆ registerToSalomePiDict()

void DataScopeServerBase::registerToSalomePiDict ( ) const

References _pyHelper, and SALOME_CPythonHelper::registerToSalomePiDict().

◆ retrieveVarInternal()

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

References retrieveVarInternal3(), and TestSalomeSDSHelper0::varName.

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

◆ retrieveVarInternal2()

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

References retrieveVarInternal3(), and TestSalomeSDSHelper0::varName.

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

◆ retrieveVarInternal3()

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

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

Referenced by retrieveVarInternal(), and retrieveVarInternal2().

◆ retrieveVarInternal4()

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

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

Referenced by moveStatusOfVarFromRdExtOrRdExtInitToRdExt(), moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit(), moveStatusOfVarFromRdOnlyToRdWr(), and moveStatusOfVarFromRdWrToRdOnly().

◆ setPOA()

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

References _poa, and SALOME_ContainerPy::poa.

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

◆ shutdownIfNotHostedByDSM()

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

References _killer, _name, _ns, _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)

References TestKernelHelpers::ret.

Field Documentation

◆ _killer

SALOME::DataScopeKiller_var SALOMESDS::DataScopeServerBase::_killer
protected

Referenced by shutdownIfNotHostedByDSM().

◆ _name

std::string SALOMESDS::DataScopeServerBase::_name
protected

Referenced by getScopeName(), registerInNS(), and shutdownIfNotHostedByDSM().

◆ _ns

SALOME_NamingService_Container_Abstract* SALOMESDS::DataScopeServerBase::_ns = nullptr
protected

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

◆ _orb

CORBA::ORB_var SALOMESDS::DataScopeServerBase::_orb
protected

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(), SALOMESDS::DataScopeServerTransaction::DataScopeServerTransaction(), SALOMESDS::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
protected

Referenced by SALOME_Container.SALOME_Container_i::__init__(), SALOME_ContainerPy.SALOME_ContainerPy_Gen_i::__init__(), SALOME_ComponentPy.SALOME_ComponentPy_Gen_i::__init__(), SALOMESDS::DataScopeServerTransaction::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(), setPOA(), and shutdownIfNotHostedByDSM().

◆ _pyHelper

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

Referenced by registerToSalomePiDict().

◆ _vars

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

Referenced by SALOMESDS::DataScopeServerTransaction::createRdExtInitVarInternal(), SALOMESDS::DataScopeServer::createRdExtVar(), SALOMESDS::DataScopeServerTransaction::createRdExtVarFreeStyleInternal(), SALOMESDS::DataScopeServerTransaction::createRdExtVarInternal(), SALOMESDS::DataScopeServer::createRdOnlyVar(), SALOMESDS::DataScopeServerTransaction::createRdOnlyVarInternal(), SALOMESDS::DataScopeServer::createRdWrVar(), SALOMESDS::DataScopeServerTransaction::createRdWrVarInternal(), SALOMESDS::DataScopeServerTransaction::createWorkingVarTransac(), deleteVar(), existVar(), getAllVarNames(), listVars(), retrieveVarInternal3(), retrieveVarInternal4(), and ~DataScopeServerBase().

◆ COUNTER

std::size_t DataScopeServerBase::COUNTER =0
staticprotected

Referenced by BuildTmpVarNameFrom().