#include <SALOMESDS_DataScopeServer.hxx>
Public Member Functions | |
DataScopeServerTransaction (CORBA::ORB_ptr orb, SALOME::DataScopeKiller_var killer, const std::string &scopeName) | |
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 | 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 | 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) |
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) |
BasicDataServer * | retrieveVarInternal2 (const std::string &varName) |
void | initializePython (int argc, char *argv[]) |
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 |
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 | |
PyObject * | _globals |
PyObject * | _locals |
PyObject * | _pickler |
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 Member Functions | |
PyObject * | getPyCmpFunc () |
Returns borrowed reference. More... | |
Private Attributes | |
PortableServer::POA_var | _poa_for_key_waiter |
std::list< KeyWaiter * > | _waiting_keys |
DataScopeServerTransaction::DataScopeServerTransaction | ( | CORBA::ORB_ptr | orb, |
SALOME::DataScopeKiller_var | killer, | ||
const std::string & | scopeName | ||
) |
References SALOMESDS::DataScopeServerBase::_orb, and _poa_for_key_waiter.
DataScopeServerTransaction::DataScopeServerTransaction | ( | const DataScopeServerTransaction & | other | ) |
DataScopeServerTransaction::~DataScopeServerTransaction | ( | ) |
|
inherited |
References SALOMESDS::POAHolder::getPOA().
Referenced by addKeyValueInVarErrorIfAlreadyExisting(), addKeyValueInVarHard(), addMultiKeyValueSession(), createRdExtInitVarInternal(), createRdExtInitVarTransac(), SALOMESDS::DataScopeServer::createRdExtVar(), createRdExtVarInternal(), createRdExtVarTransac(), SALOMESDS::DataScopeServer::createRdOnlyVar(), createRdOnlyVarInternal(), createRdOnlyVarTransac(), SALOMESDS::DataScopeServer::createRdWrVar(), createRdWrVarInternal(), createRdWrVarTransac(), createWorkingVarTransac(), SALOMESDS::DataServerManager::DataServerManager(), killVarTransac(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExt(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdOnlyToRdWr(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdWrToRdOnly(), removeKeyInVarErrorIfNotAlreadyExisting(), waitForKeyInVar(), and waitForKeyInVarAndKillIt().
SALOME::Transaction_ptr DataScopeServerTransaction::addKeyValueInVarErrorIfAlreadyExisting | ( | const char * | varName, |
const SALOME::ByteVec & | key, | ||
const SALOME::ByteVec & | value | ||
) |
SALOME::Transaction_ptr DataScopeServerTransaction::addKeyValueInVarHard | ( | const char * | varName, |
const SALOME::ByteVec & | key, | ||
const SALOME::ByteVec & | value | ||
) |
SALOME::TransactionMultiKeyAddSession_ptr DataScopeServerTransaction::addMultiKeyValueSession | ( | const char * | varName | ) |
void DataScopeServerTransaction::addWaitKey | ( | KeyWaiter * | kw | ) |
References _waiting_keys.
Referenced by SALOMESDS::KeyWaiter::KeyWaiter().
void DataScopeServerTransaction::atomicApply | ( | const SALOME::ListOfTransaction & | transactions | ) |
References SALOMESDS::DataScopeServerBase::_poa.
|
staticinherited |
|
inherited |
References SALOMESDS::DataScopeServerBase::getAllVarNames().
Referenced by SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), getAccessOfVar(), and killVarTransac().
|
inherited |
References SALOMESDS::DataScopeServerBase::getAllVarNames().
Referenced by createRdExtInitVarInternal(), createRdExtInitVarTransac(), SALOMESDS::DataScopeServer::createRdExtVar(), createRdExtVarInternal(), createRdExtVarTransac(), SALOMESDS::DataScopeServer::createRdOnlyVar(), createRdOnlyVarInternal(), createRdOnlyVarTransac(), SALOMESDS::DataScopeServer::createRdWrVar(), createRdWrVarInternal(), createRdWrVarTransac(), and createWorkingVarTransac().
|
inherited |
References SALOMESDS::DataScopeServerBase::checkExistingVar(), SALOMESDS::PickelizedPyObjServer::isDict(), and SALOMESDS::DataScopeServerBase::retrieveVarInternal2().
Referenced by addKeyValueInVarErrorIfAlreadyExisting(), SALOMESDS::TransactionMultiKeyAddSession::addKeyValueInVarErrorIfAlreadyExistingNow(), addKeyValueInVarHard(), addMultiKeyValueSession(), SALOMESDS::TransactionDictModify::checkVarExistingAndDict(), removeKeyInVarErrorIfNotAlreadyExisting(), waitForKeyInVar(), and waitForKeyInVarAndKillIt().
void DataScopeServerTransaction::createRdExtInitVarInternal | ( | const std::string & | varName, |
const SALOME::ByteVec & | constValue | ||
) |
SALOME::Transaction_ptr DataScopeServerTransaction::createRdExtInitVarTransac | ( | const char * | varName, |
const SALOME::ByteVec & | constValue | ||
) |
void DataScopeServerTransaction::createRdExtVarInternal | ( | const std::string & | varName, |
const SALOME::ByteVec & | constValue | ||
) |
SALOME::Transaction_ptr DataScopeServerTransaction::createRdExtVarTransac | ( | const char * | varName, |
const SALOME::ByteVec & | constValue | ||
) |
void DataScopeServerTransaction::createRdOnlyVarInternal | ( | const std::string & | varName, |
const SALOME::ByteVec & | constValue | ||
) |
SALOME::Transaction_ptr DataScopeServerTransaction::createRdOnlyVarTransac | ( | const char * | varName, |
const SALOME::ByteVec & | constValue | ||
) |
void DataScopeServerTransaction::createRdWrVarInternal | ( | const std::string & | varName, |
const SALOME::ByteVec & | constValue | ||
) |
SALOME::Transaction_ptr DataScopeServerTransaction::createRdWrVarTransac | ( | const char * | varName, |
const SALOME::ByteVec & | constValue | ||
) |
SALOME::TransactionRdWrAccess_ptr DataScopeServerTransaction::createWorkingVarTransac | ( | const char * | varName, |
const SALOME::ByteVec & | constValue | ||
) |
|
inherited |
|
inherited |
|
inherited |
References SALOMESDS::DataScopeServerBase::_vars.
Referenced by SALOMESDS::TransactionVarCreate::rollBack().
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(), and getAccessOfVar().
|
inherited |
References SALOMESDS::PickelizedPyObjServer::fetchSerializedContent(), and SALOMESDS::DataScopeServerBase::retrieveVarInternal2().
Referenced by fetchAndGetAccessOfVar().
|
inherited |
|
inherited |
References SALOMESDS::DataScopeServerBase::_vars.
Referenced by SALOMESDS::DataScopeServerBase::checkExistingVar(), SALOMESDS::DataScopeServerBase::checkNotAlreadyExistingVar(), SALOMESDS::DataScopeServerBase::deleteVar(), SALOMESDS::DataScopeServerBase::retrieveVarInternal3(), and SALOMESDS::DataScopeServerBase::retrieveVarInternal4().
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
virtualinherited |
PortableServer::POA_var SALOMESDS::DataScopeServerTransaction::getPOA4KeyWaiter | ( | ) | const |
Referenced by SALOMESDS::KeyWaiter::getPOA().
|
private |
Returns borrowed reference.
References SALOMESDS::DataScopeServerBase::_globals.
Referenced by notifyKey(), and pingKey().
|
inherited |
Called remotely -> to protect against throw.
References SALOMESDS::DataScopeServerBase::_name.
Referenced by SALOMESDS::BasicDataServer::getScopeName().
|
inherited |
|
inherited |
SALOME::Transaction_ptr DataScopeServerTransaction::killVarTransac | ( | const char * | varName | ) |
|
inherited |
Called remotely -> to protect against throw.
References SALOMESDS::DataScopeServerBase::_vars, and SALOMESDS::BasicDataServer::getVarNameCpp().
|
inherited |
References SALOMESDS::POAHolder::activate(), SALOMESDS::PickelizedPyObjRdExtInitServer::decrNbClients(), SALOMESDS::RefCountServ::decrRef(), SALOMESDS::PickelizedPyObjServer::getPyObj(), and SALOMESDS::DataScopeServerBase::retrieveVarInternal4().
Referenced by SALOMESDS::TransactionMultiKeyAddSession::perform().
|
inherited |
References SALOMESDS::POAHolder::activate(), SALOMESDS::RefCountServ::decrRef(), SALOMESDS::PickelizedPyObjServer::getPyObj(), SALOMESDS::PickelizedPyObjRdExtInitServer::incrNbClients(), and SALOMESDS::DataScopeServerBase::retrieveVarInternal4().
Referenced by SALOMESDS::TransactionMultiKeyAddSession::TransactionMultiKeyAddSession().
|
inherited |
|
inherited |
void DataScopeServerTransaction::notifyKey | ( | const std::string & | varName, |
PyObject * | keyObj, | ||
PyObject * | valueObj | ||
) |
References _waiting_keys, and getPyCmpFunc().
Referenced by SALOMESDS::TransactionAddKeyValue::notify().
|
inherited |
Called remotely -> to protect against throw.
void DataScopeServerTransaction::pingKey | ( | PyObject * | keyObj | ) |
References _waiting_keys, and getPyCmpFunc().
Referenced by SALOMESDS::TransactionAddKeyValue::prepareRollBackInCaseOfFailure().
|
inherited |
|
inherited |
SALOME::Transaction_ptr DataScopeServerTransaction::removeKeyInVarErrorIfNotAlreadyExisting | ( | const char * | varName, |
const SALOME::ByteVec & | key | ||
) |
|
inherited |
References SALOMESDS::DataScopeServerBase::retrieveVarInternal3().
Referenced by SALOMESDS::TransactionMorphRdWrIntoRdOnly::getVar().
|
inherited |
References SALOMESDS::DataScopeServerBase::retrieveVarInternal3().
Referenced by SALOMESDS::DataScopeServerBase::checkVarExistingAndDict(), SALOMESDS::DataScopeServerBase::fetchSerializedContent(), getAccessOfVar(), SALOMESDS::DataScopeServerBase::getAllKeysOfVarWithTypeDict(), and SALOMESDS::TransactionMorphRdWrIntoRdOnly::prepareRollBackInCaseOfFailure().
|
protectedinherited |
|
protectedinherited |
References SALOMESDS::DataScopeServerBase::_vars, and SALOMESDS::DataScopeServerBase::getAllVarNames().
Referenced by SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExt(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit(), SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdOnlyToRdWr(), and SALOMESDS::DataScopeServerBase::moveStatusOfVarFromRdWrToRdOnly().
|
inherited |
References SALOMESDS::DataScopeServerBase::_poa.
Referenced by SALOMESDS::DataServerManager::DataServerManager().
|
inherited |
References SALOMESDS::DataScopeServerBase::_killer, SALOMESDS::DataScopeServerBase::_name, SALOMESDS::DataScopeServerBase::_orb, SALOMESDS::DataScopeServerBase::_poa, SALOMESDS::DataServerManager::CreateAbsNameInNSFromScopeName(), SALOME_NamingService::Destroy_Name(), SALOMESDS::POAHolder::enforcedRelease(), SALOMESDS::DataServerManager::NAME_IN_NS, and SALOME_NamingService::Resolve().
SALOME::ByteVec * DataScopeServerTransaction::waitForAndKill | ( | SALOME::KeyWaiter_ptr | kw | ) |
SALOME::KeyWaiter_ptr DataScopeServerTransaction::waitForKeyInVar | ( | const char * | varName, |
const SALOME::ByteVec & | keyVal | ||
) |
SALOME::KeyWaiter_ptr DataScopeServerTransaction::waitForKeyInVarAndKillIt | ( | const char * | varName, |
const SALOME::ByteVec & | keyVal, | ||
SALOME::Transaction_out | transac | ||
) |
SALOME::ByteVec * DataScopeServerTransaction::waitForMonoThrRev | ( | SALOME::KeyWaiter_ptr | kw | ) |
|
protectedinherited |
Referenced by getPyCmpFunc(), and SALOMESDS::DataScopeServerBase::initializePython().
|
protectedinherited |
Referenced by SALOMESDS::DataScopeServerBase::shutdownIfNotHostedByDSM().
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
protectedinherited |
|
private |
Referenced by DataScopeServerTransaction(), waitForAndKill(), and waitForMonoThrRev().
|
protectedinherited |
Referenced by createRdExtInitVarInternal(), SALOMESDS::DataScopeServer::createRdExtVar(), createRdExtVarInternal(), SALOMESDS::DataScopeServer::createRdOnlyVar(), createRdOnlyVarInternal(), SALOMESDS::DataScopeServer::createRdWrVar(), createRdWrVarInternal(), createWorkingVarTransac(), SALOMESDS::DataScopeServerBase::deleteVar(), SALOMESDS::DataScopeServerBase::existVar(), SALOMESDS::DataScopeServerBase::getAllVarNames(), SALOMESDS::DataScopeServerBase::listVars(), SALOMESDS::DataScopeServerBase::retrieveVarInternal3(), SALOMESDS::DataScopeServerBase::retrieveVarInternal4(), and SALOMESDS::DataScopeServerBase::~DataScopeServerBase().
|
private |
Referenced by addWaitKey(), notifyKey(), and pingKey().
|
staticprotectedinherited |
Referenced by SALOMESDS::DataScopeServerBase::BuildTmpVarNameFrom().