1 // Copyright (C) 2007-2015 CEA/DEN, EDF R&D, OPEN CASCADE
3 // This library is free software; you can redistribute it and/or
4 // modify it under the terms of the GNU Lesser General Public
5 // License as published by the Free Software Foundation; either
6 // version 2.1 of the License, or (at your option) any later version.
8 // This library is distributed in the hope that it will be useful,
9 // but WITHOUT ANY WARRANTY; without even the implied warranty of
10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 // Lesser General Public License for more details.
13 // You should have received a copy of the GNU Lesser General Public
14 // License along with this library; if not, write to the Free Software
15 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
19 // Author : Anthony GEAY (EDF R&D)
21 #include "SALOMESDS_DataScopeServer.hxx"
22 #include "SALOMESDS_DataServerManager.hxx"
23 #include "SALOMESDS_PickelizedPyObjRdOnlyServer.hxx"
24 #include "SALOMESDS_PickelizedPyObjRdExtServer.hxx"
25 #include "SALOMESDS_PickelizedPyObjRdWrServer.hxx"
26 #include "SALOMESDS_PickelizedPyObjRdExtInitServer.hxx"
27 #include "SALOMESDS_TrustTransaction.hxx"
28 #include "SALOMESDS_KeyWaiter.hxx"
29 #include "SALOMESDS_Transaction.hxx"
30 #include "SALOME_NamingService.hxx"
31 #include "SALOMESDS_Exception.hxx"
37 // agy : awful, to be factorized with ContainerManager.
42 #define getpid _getpid
45 using namespace SALOMESDS;
47 std::size_t DataScopeServerBase::COUNTER=0;
49 void DataScopeKiller::shutdown()
55 DataScopeServerBase::DataScopeServerBase(CORBA::ORB_ptr orb, SALOME::DataScopeKiller_var killer, const std::string& scopeName):_globals(0),_locals(0),_pickler(0),_orb(CORBA::ORB::_duplicate(orb)),_name(scopeName),_killer(killer)
59 DataScopeServerBase::DataScopeServerBase(const DataScopeServerBase& other):omniServant(other),ServantBase(other),_globals(0),_locals(0),_pickler(0),_name(other._name),_vars(other._vars),_killer(other._killer)
63 DataScopeServerBase::~DataScopeServerBase()
65 // _globals is borrowed ref -> do nothing
68 for(std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator it=_vars.begin();it!=_vars.end();it++)
70 BasicDataServer *obj((*it).second);
79 * Called remotely -> to protect against throw
81 void DataScopeServerBase::ping()
86 * Called remotely -> to protect against throw
88 char *DataScopeServerBase::getScopeName()
90 return CORBA::string_dup(_name.c_str());
94 * Called remotely -> to protect against throw
96 SALOME::StringVec *DataScopeServerBase::listVars()
98 SALOME::StringVec *ret(new SALOME::StringVec);
99 std::size_t sz(_vars.size());
101 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator it(_vars.begin());
102 for(std::size_t i=0;i<sz;it++,i++)
104 BasicDataServer *obj((*it).second);
105 std::string name(obj->getVarNameCpp());
106 (*ret)[i]=CORBA::string_dup(name.c_str());
111 CORBA::Boolean DataScopeServerBase::existVar(const char *varName)
113 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator it(_vars.begin());
114 for(;it!=_vars.end();it++)
115 if((*it).second->getVarNameCpp()==varName)
120 SALOME::BasicDataServer_ptr DataScopeServerBase::retrieveVarInternal(const char *varName)
122 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator it0(retrieveVarInternal3(varName));
123 return SALOME::BasicDataServer::_duplicate((*it0).first);
126 BasicDataServer *DataScopeServerBase::retrieveVarInternal2(const std::string& varName)
128 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator it0(retrieveVarInternal3(varName));
129 return (*it0).second;
132 void DataScopeServerBase::deleteVar(const char *varName)
134 std::string varNameCpp(varName);
135 std::vector<std::string> allNames(getAllVarNames());
136 std::vector<std::string>::iterator it(std::find(allNames.begin(),allNames.end(),varNameCpp));
137 if(it==allNames.end())
139 std::ostringstream oss; oss << "DataScopeServerBase::deleteVar : name \"" << varNameCpp << "\" does not exists ! Possibilities are :";
140 std::copy(allNames.begin(),allNames.end(),std::ostream_iterator<std::string>(oss,", "));
141 throw Exception(oss.str());
143 std::size_t pos(std::distance(allNames.begin(),it));
144 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator it0(_vars.begin());
145 for(std::size_t ii=0;ii<pos;ii++,it0++);
146 (*it0).second->decrRef();
150 CORBA::Boolean DataScopeServerBase::shutdownIfNotHostedByDSM(SALOME::DataScopeKiller_out killer)
152 SALOME_NamingService ns(_orb);
153 CORBA::Object_var obj(ns.Resolve(DataServerManager::NAME_IN_NS));
154 SALOME::DataServerManager_var dsm(SALOME::DataServerManager::_narrow(obj));
155 if(CORBA::is_nil(dsm))
156 throw Exception("Unable to reach in the NS the unique DataServerManager instance of the Session !");
157 // destroy ref in the naming service
158 std::string fullScopeName(SALOMESDS::DataServerManager::CreateAbsNameInNSFromScopeName(_name));
159 ns.Destroy_Name(fullScopeName.c_str());
160 // establish if dsm and this shared the same POA. If yes dsm and this are collocated !
161 PortableServer::ServantBase *ret(0);
164 ret=_poa->reference_to_servant(dsm);
166 catch(...) { ret=0; }
171 killer=SALOME::DataScopeKiller::_duplicate(_killer);
178 killer=SALOME::DataScopeKiller::_duplicate(_killer);
183 SALOME::ByteVec *DataScopeServerBase::fetchSerializedContent(const char *varName)
185 BasicDataServer *var(retrieveVarInternal2(varName));
186 PickelizedPyObjServer *varc(dynamic_cast<PickelizedPyObjServer *>(var));
189 std::ostringstream oss; oss << "DataScopeServerBase::fetchSerializedContent : var \"" << varName << "\" exists but it is not serialized !";
190 throw Exception(oss.str());
192 return varc->fetchSerializedContent();
195 SALOME::SeqOfByteVec *DataScopeServerBase::getAllKeysOfVarWithTypeDict(const char *varName)
197 BasicDataServer *var(retrieveVarInternal2(varName));
198 PickelizedPyObjServer *varc(dynamic_cast<PickelizedPyObjServer *>(var));
201 std::ostringstream oss; oss << "DataScopeServerBase::getAllKeysOfVarWithTypeDict : var \"" << varName << "\" exists but it is not serialized !";
202 throw Exception(oss.str());
206 std::ostringstream oss; oss << "DataScopeServerBase::getAllKeysOfVarWithTypeDict : var \"" << varName << "\" exists but it is not a PyDict !";
207 throw Exception(oss.str());
209 PyObject *keys(PyDict_Keys(varc->getPyObj()));
210 if(!PyList_Check(keys))
212 std::ostringstream oss; oss << "DataScopeServerBase::getAllKeysOfVarWithTypeDict : var \"" << varName << "\" has keys but not of type list !";
213 throw Exception(oss.str());
215 Py_ssize_t sz(PyList_Size(keys));
216 SALOME::SeqOfByteVec *ret(new SALOME::SeqOfByteVec);
218 for(Py_ssize_t i=0;i<sz;i++)
220 PyObject *item(PyList_GetItem(keys,i));
222 std::string pickel(varc->pickelize(item));//item consumed
223 PickelizedPyObjServer::FromCppToByteSeq(pickel,(*ret)[i]);
229 void DataScopeServerBase::initializePython(int argc, char *argv[])
232 PyEval_InitThreads();
233 PySys_SetArgv(argc,argv);
234 PyObject *mainmod(PyImport_AddModule("__main__"));
235 _globals=PyModule_GetDict(mainmod);
236 if(PyDict_GetItemString(_globals, "__builtins__") == NULL)
238 PyObject *bimod(PyImport_ImportModule("__builtin__"));
239 if (bimod == NULL || PyDict_SetItemString(_globals, "__builtins__", bimod) != 0)
240 Py_FatalError("can't add __builtins__ to __main__");
243 _locals=PyDict_New();
244 PyObject *tmp(PyList_New(0));
245 _pickler=PyImport_ImportModuleLevel(const_cast<char *>("cPickle"),_globals,_locals,tmp,-1);
248 void DataScopeServerBase::registerToSalomePiDict() const
250 PyObject *mod(PyImport_ImportModule("addToKillList"));//new value
253 PyObject *meth(PyObject_GetAttrString(mod,"addToKillList"));//new value
255 { Py_XDECREF(mod); return ; }
256 PyObject *args(PyTuple_New(2));
257 PyTuple_SetItem(args,0,PyInt_FromLong(getpid()));
258 PyTuple_SetItem(args,1,PyString_FromString("SALOME_DataScopeServerBase"));
259 PyObject *res(PyObject_CallObject(meth,args));
266 void DataScopeServerBase::setPOA(PortableServer::POA_var poa)
271 void DataScopeServerBase::registerInNS(SALOME::DataScopeServerBase_ptr ptr)
273 std::string fullScopeName(SALOMESDS::DataServerManager::CreateAbsNameInNSFromScopeName(_name));
274 SALOME_NamingService ns(_orb);
275 ns.Register(ptr,fullScopeName.c_str());
278 std::string DataScopeServerBase::BuildTmpVarNameFrom(const std::string& varName)
280 std::ostringstream oss;
281 oss << varName << "@" << COUNTER++;
285 std::vector< std::string > DataScopeServerBase::getAllVarNames() const
287 std::size_t sz(_vars.size());
288 std::vector<std::string> ret(sz);
289 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator it(_vars.begin());
290 for(std::size_t i=0;i<sz;it++,i++)
291 ret[i]=(*it).second->getVarNameCpp();
295 void DataScopeServerBase::checkNotAlreadyExistingVar(const std::string& varName) const
297 std::vector<std::string> allNames(getAllVarNames());
298 std::vector<std::string>::iterator it(std::find(allNames.begin(),allNames.end(),varName));
299 if(it!=allNames.end())
301 std::ostringstream oss; oss << "DataScopeServerBase::checkNotAlreadyExistingVar : name \"" << varName << "\" already exists !";
302 throw Exception(oss.str());
306 void DataScopeServerBase::checkExistingVar(const std::string& varName) const
308 std::vector<std::string> allNames(getAllVarNames());
309 std::vector<std::string>::iterator it(std::find(allNames.begin(),allNames.end(),varName));
310 if(it==allNames.end())
312 std::ostringstream oss; oss << "DataScopeServerBase::checkExistingVar : name \"" << varName << "\" does not exist !";
313 throw Exception(oss.str());
317 PickelizedPyObjServer *DataScopeServerBase::checkVarExistingAndDict(const std::string& varName)
319 checkExistingVar(varName);
320 BasicDataServer *var(retrieveVarInternal2(varName.c_str()));
321 PickelizedPyObjServer *ret(dynamic_cast<PickelizedPyObjServer *>(var));
324 std::ostringstream oss; oss << "TransactionAddKeyValueHard::prepareRollBackInCaseOfFailure : var \"" << varName << "\"exists but it is not serialized !";
325 throw Exception(oss.str());
329 std::ostringstream oss; oss << "TransactionAddKeyValueHard::prepareRollBackInCaseOfFailure : var \"" << varName << "\"exists but it is not a Dict !";
330 throw Exception(oss.str());
335 void DataScopeServerBase::moveStatusOfVarFromRdWrToRdOnly(const std::string& varName)
337 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator it(retrieveVarInternal4(varName));
338 std::pair< SALOME::BasicDataServer_var, BasicDataServer * >& p(*it);
339 PickelizedPyObjRdWrServer *varc(dynamic_cast<PickelizedPyObjRdWrServer *>(p.second));
341 throw Exception("DataScopeServerBase::moveStatusOfVarFromRdWrToRdOnly : var is not a RdWr !");
342 PyObject *pyobj(varc->getPyObj()); Py_XINCREF(pyobj);
343 PickelizedPyObjRdOnlyServer *newVar(new PickelizedPyObjRdOnlyServer(this,varName,pyobj));
344 CORBA::Object_var obj(newVar->activate());
345 SALOME::BasicDataServer_var obj2(SALOME::BasicDataServer::_narrow(obj));
346 p.first=obj2; p.second=newVar;
350 void DataScopeServerBase::moveStatusOfVarFromRdOnlyToRdWr(const std::string& varName)
352 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator it(retrieveVarInternal4(varName));
353 std::pair< SALOME::BasicDataServer_var, BasicDataServer * >& p(*it);
354 PickelizedPyObjRdOnlyServer *varc(dynamic_cast<PickelizedPyObjRdOnlyServer *>(p.second));
356 throw Exception("DataScopeServerBase::moveStatusOfVarFromRdOnlyToRdWr : var is not a RdWr !");
357 PyObject *pyobj(varc->getPyObj()); Py_XINCREF(pyobj);
358 PickelizedPyObjRdWrServer *newVar(new PickelizedPyObjRdWrServer(this,varName,pyobj));
359 CORBA::Object_var obj(newVar->activate());
360 SALOME::BasicDataServer_var obj2(SALOME::BasicDataServer::_narrow(obj));
361 p.first=obj2; p.second=newVar;
365 void DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit(const std::string& varName)
367 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator it(retrieveVarInternal4(varName));
368 std::pair< SALOME::BasicDataServer_var, BasicDataServer * >& p(*it);
369 PickelizedPyObjRdExtServer *varc0(dynamic_cast<PickelizedPyObjRdExtServer *>(p.second));
370 PickelizedPyObjRdExtInitServer *varc1(dynamic_cast<PickelizedPyObjRdExtInitServer *>(p.second));
372 throw Exception("DataScopeServerBase::moveStatusOfVarFromRdExtOrRdExtInitToRdExtInit : var is neither RdExt nor RdExtInit !");
375 PyObject *pyobj(varc0->getPyObj()); Py_XINCREF(pyobj);
376 PickelizedPyObjRdExtInitServer *newVar(new PickelizedPyObjRdExtInitServer(this,varName,pyobj));
377 CORBA::Object_var obj(newVar->activate());
378 SALOME::BasicDataServer_var obj2(SALOME::BasicDataServer::_narrow(obj));
379 p.first=obj2; p.second=newVar;
384 void DataScopeServerBase::moveStatusOfVarFromRdExtInitToRdExt(const std::string& varName)
386 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator it(retrieveVarInternal4(varName));
387 std::pair< SALOME::BasicDataServer_var, BasicDataServer * >& p(*it);
388 PickelizedPyObjRdExtInitServer *varc0(dynamic_cast<PickelizedPyObjRdExtInitServer *>(p.second));
389 PickelizedPyObjRdExtServer *varc1(dynamic_cast<PickelizedPyObjRdExtServer *>(p.second));
391 throw Exception("DataScopeServerBase::moveStatusOfVarFromRdExtInitToRdExt : var is not a RdExtInit !");
394 PyObject *pyobj(varc0->getPyObj()); Py_XINCREF(pyobj);
395 PickelizedPyObjRdExtServer *newVar(new PickelizedPyObjRdExtServer(this,varName,pyobj));
396 CORBA::Object_var obj(newVar->activate());
397 SALOME::BasicDataServer_var obj2(SALOME::BasicDataServer::_narrow(obj));
398 p.first=obj2; p.second=newVar;
403 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator DataScopeServerBase::retrieveVarInternal3(const std::string& varName) const
405 std::vector<std::string> allNames(getAllVarNames());
406 std::vector<std::string>::iterator it(std::find(allNames.begin(),allNames.end(),varName));
407 if(it==allNames.end())
409 std::ostringstream oss; oss << "DataScopeServerBase::retrieveVarInternal3 : name \"" << varName << "\" does not exists ! Possibilities are :";
410 std::copy(allNames.begin(),allNames.end(),std::ostream_iterator<std::string>(oss,", "));
411 throw Exception(oss.str());
413 std::size_t pos(std::distance(allNames.begin(),it));
414 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::const_iterator it0(_vars.begin());
415 for(std::size_t i=0;i<pos;i++,it0++);
419 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator DataScopeServerBase::retrieveVarInternal4(const std::string& varName)
421 std::vector<std::string> allNames(getAllVarNames());
422 std::vector<std::string>::iterator it(std::find(allNames.begin(),allNames.end(),varName));
423 if(it==allNames.end())
425 std::ostringstream oss; oss << "DataScopeServerBase::retrieveVarInternal4 : name \"" << varName << "\" does not exists ! Possibilities are :";
426 std::copy(allNames.begin(),allNames.end(),std::ostream_iterator<std::string>(oss,", "));
427 throw Exception(oss.str());
429 std::size_t pos(std::distance(allNames.begin(),it));
430 std::list< std::pair< SALOME::BasicDataServer_var, BasicDataServer * > >::iterator it0(_vars.begin());
431 for(std::size_t i=0;i<pos;i++,it0++);
437 DataScopeServer::DataScopeServer(CORBA::ORB_ptr orb, SALOME::DataScopeKiller_var killer, const std::string& scopeName):DataScopeServerBase(orb,killer,scopeName)
441 DataScopeServer::DataScopeServer(const DataScopeServer& other):omniServant(other),ServantBase(other),DataScopeServerBase(other)
445 SALOME::PickelizedPyObjRdOnlyServer_ptr DataScopeServer::createRdOnlyVar(const char *varName, const SALOME::ByteVec& constValue)
447 std::string varNameCpp(varName);
448 checkNotAlreadyExistingVar(varNameCpp);
449 PickelizedPyObjRdOnlyServer *tmp(new PickelizedPyObjRdOnlyServer(this,varNameCpp,constValue));
450 CORBA::Object_var ret(tmp->activate());
451 std::pair< SALOME::BasicDataServer_var, BasicDataServer * > p(SALOME::BasicDataServer::_narrow(ret),tmp);
453 return SALOME::PickelizedPyObjRdOnlyServer::_narrow(ret);
456 SALOME::PickelizedPyObjRdExtServer_ptr DataScopeServer::createRdExtVar(const char *varName, const SALOME::ByteVec& constValue)
458 std::string varNameCpp(varName);
459 checkNotAlreadyExistingVar(varNameCpp);
460 PickelizedPyObjRdExtServer *tmp(new PickelizedPyObjRdExtServer(this,varNameCpp,constValue));
461 CORBA::Object_var ret(tmp->activate());
462 std::pair< SALOME::BasicDataServer_var, BasicDataServer * > p(SALOME::BasicDataServer::_narrow(ret),tmp);
464 return SALOME::PickelizedPyObjRdExtServer::_narrow(ret);
467 SALOME::PickelizedPyObjRdWrServer_ptr DataScopeServer::createRdWrVar(const char *typeName, const char *varName)
469 std::string varNameCpp(varName),typeNameCpp(typeName);
470 checkNotAlreadyExistingVar(varNameCpp);
471 PickelizedPyObjRdWrServer *tmp(new PickelizedPyObjRdWrServer(this,typeNameCpp,varNameCpp));
472 CORBA::Object_var ret(tmp->activate());
473 std::pair< SALOME::BasicDataServer_var, BasicDataServer * > p(SALOME::BasicDataServer::_narrow(ret),tmp);
475 return SALOME::PickelizedPyObjRdWrServer::_narrow(ret);
478 DataScopeServer::~DataScopeServer()
484 DataScopeServerTransaction::DataScopeServerTransaction(CORBA::ORB_ptr orb, SALOME::DataScopeKiller_var killer, const std::string& scopeName):DataScopeServerBase(orb,killer,scopeName)
486 CORBA::Object_var obj(_orb->resolve_initial_references("RootPOA"));
487 PortableServer::POA_var poa(PortableServer::POA::_narrow(obj));
489 PortableServer::POAManager_var mgr(poa->the_POAManager());
490 CORBA::PolicyList policies;
492 PortableServer::ThreadPolicy_var threadPol(poa->create_thread_policy(PortableServer::ORB_CTRL_MODEL));
493 policies[0]=PortableServer::ThreadPolicy::_duplicate(threadPol);
494 PortableServer::POA_var poa2(poa->create_POA("POAForWaiters",mgr,policies));
495 threadPol->destroy();
497 _poa_for_key_waiter=poa2;
500 DataScopeServerTransaction::DataScopeServerTransaction(const DataScopeServerTransaction& other):omniServant(other),ServantBase(other),DataScopeServerBase(other),_poa_for_key_waiter(other.getPOA4KeyWaiter())
504 char *DataScopeServerTransaction::getAccessOfVar(const char *varName)
506 std::string varNameCpp(varName);
507 checkExistingVar(varNameCpp);
508 BasicDataServer *var(retrieveVarInternal2(varName));
510 throw Exception("DataScopeServerTransaction::getAccessOfVar : variable is NULL !");
511 PickelizedPyObjServer *varc(dynamic_cast<PickelizedPyObjServer *>(var));
513 throw Exception("DataScopeServerTransaction::getAccessOfVar : variable is not of type PickelizedPyObjServer !");
514 std::string ret(varc->getAccessStr());
515 return CORBA::string_dup(ret.c_str());
518 void DataScopeServerTransaction::createRdOnlyVarInternal(const std::string& varName, const SALOME::ByteVec& constValue)
520 checkNotAlreadyExistingVar(varName);
521 PickelizedPyObjRdOnlyServer *tmp(new PickelizedPyObjRdOnlyServer(this,varName,constValue));
522 CORBA::Object_var ret(tmp->activate());
523 std::pair< SALOME::BasicDataServer_var, BasicDataServer * > p(SALOME::BasicDataServer::_narrow(ret),tmp);
527 void DataScopeServerTransaction::createRdExtVarInternal(const std::string& varName, const SALOME::ByteVec& constValue)
529 checkNotAlreadyExistingVar(varName);
530 PickelizedPyObjRdExtServer *tmp(new PickelizedPyObjRdExtServer(this,varName,constValue));
531 CORBA::Object_var ret(tmp->activate());
532 std::pair< SALOME::BasicDataServer_var, BasicDataServer * > p(SALOME::BasicDataServer::_narrow(ret),tmp);
536 void DataScopeServerTransaction::createRdExtInitVarInternal(const std::string& varName, const SALOME::ByteVec& constValue)
538 checkNotAlreadyExistingVar(varName);
539 PickelizedPyObjRdExtInitServer *tmp(new PickelizedPyObjRdExtInitServer(this,varName,constValue));
540 CORBA::Object_var ret(tmp->activate());
541 std::pair< SALOME::BasicDataServer_var, BasicDataServer * > p(SALOME::BasicDataServer::_narrow(ret),tmp);
545 void DataScopeServerTransaction::createRdWrVarInternal(const std::string& varName, const SALOME::ByteVec& constValue)
547 checkNotAlreadyExistingVar(varName);
548 PickelizedPyObjRdWrServer *tmp(new PickelizedPyObjRdWrServer(this,varName,constValue));
549 CORBA::Object_var ret(tmp->activate());
550 std::pair< SALOME::BasicDataServer_var, BasicDataServer * > p(SALOME::BasicDataServer::_narrow(ret),tmp);
554 SALOME::Transaction_ptr DataScopeServerTransaction::createRdOnlyVarTransac(const char *varName, const SALOME::ByteVec& constValue)
556 checkNotAlreadyExistingVar(varName);
557 TransactionRdOnlyVarCreate *ret(new TransactionRdOnlyVarCreate(this,varName,constValue));
558 CORBA::Object_var obj(ret->activate());
559 return SALOME::Transaction::_narrow(obj);
562 SALOME::Transaction_ptr DataScopeServerTransaction::createRdExtVarTransac(const char *varName, const SALOME::ByteVec& constValue)
564 checkNotAlreadyExistingVar(varName);
565 TransactionRdExtVarCreate *ret(new TransactionRdExtVarCreate(this,varName,constValue));
566 CORBA::Object_var obj(ret->activate());
567 return SALOME::Transaction::_narrow(obj);
570 SALOME::Transaction_ptr DataScopeServerTransaction::createRdExtInitVarTransac(const char *varName, const SALOME::ByteVec& constValue)
572 checkNotAlreadyExistingVar(varName);
573 TransactionRdExtInitVarCreate *ret(new TransactionRdExtInitVarCreate(this,varName,constValue));
574 CORBA::Object_var obj(ret->activate());
575 return SALOME::Transaction::_narrow(obj);
578 SALOME::Transaction_ptr DataScopeServerTransaction::createRdWrVarTransac(const char *varName, const SALOME::ByteVec& constValue)
580 checkNotAlreadyExistingVar(varName);
581 TransactionRdWrVarCreate *ret(new TransactionRdWrVarCreate(this,varName,constValue));
582 CORBA::Object_var obj(ret->activate());
583 return SALOME::Transaction::_narrow(obj);
586 void DataScopeServerTransaction::addWaitKey(KeyWaiter *kw)
589 throw Exception("DataScopeServerTransaction::addWaitKey : NULL input object !");
590 _waiting_keys.push_back(kw);
593 void DataScopeServerTransaction::pingKey(PyObject *keyObj)
595 PyObject *cmpObj(getPyCmpFunc());
597 throw Exception("ataScopeServerTransaction::pingKey : Key Object is NULL !");
598 PyObject *args(PyTuple_New(2));
599 PyTuple_SetItem(args,0,keyObj); Py_XINCREF(keyObj);
601 // this part does nothing except to be sure that in notify key all will be OK.
602 for(std::list< KeyWaiter *>::iterator it=_waiting_keys.begin();it!=_waiting_keys.end();it++,ii++)
604 PyObject *waitKey((*it)->getKeyPyObj());
605 PyTuple_SetItem(args,1,waitKey); Py_XINCREF(waitKey);
606 PyObject *res(PyObject_CallObject(cmpObj,args));
609 std::ostringstream oss; oss << "DataScopeServerTransaction::pingKey : for object id #" << ii << " error during cmp(k,wk[i]) !";
610 throw Exception(oss.str());
615 std::ostringstream oss; oss << "DataScopeServerTransaction::pingKey : for object id #" << ii << " error during interpretation of cmp(k,wk[i]) !";
616 throw Exception(oss.str());
622 void DataScopeServerTransaction::notifyKey(const std::string& varName, PyObject *keyObj, PyObject *valueObj)
624 PyObject *cmpObj(getPyCmpFunc());
626 throw Exception("DataScopeServerTransaction::notifyKey : MAIN INTERNAL ERROR ! Key Object is NULL !");
627 PyObject *args(PyTuple_New(2));
628 PyTuple_SetItem(args,0,keyObj); Py_XINCREF(keyObj);
630 std::list< KeyWaiter *> newList,listOfEltToWakeUp;
631 for(std::list< KeyWaiter *>::iterator it=_waiting_keys.begin();it!=_waiting_keys.end();it++,ii++)
633 if((*it)->getVarName()!=varName)
635 newList.push_back(*it);
638 PyObject *waitKey((*it)->getKeyPyObj());
639 PyTuple_SetItem(args,1,waitKey); Py_XINCREF(waitKey);
640 PyObject *res(PyObject_CallObject(cmpObj,args));
643 std::ostringstream oss; oss << "DataScopeServerTransaction::notifyKey : MAIN INTERNAL ERROR ! for object id #" << ii << " error during cmp(k,wk[i]) !";
644 throw Exception(oss.str());
646 long resCpp(PyInt_AsLong(res));
649 std::ostringstream oss; oss << "DataScopeServerTransaction::notifyKey : MAIN INTERNAL ERROR ! for object id #" << ii << " error during interpretation of cmp(k,wk[i]) !";
650 throw Exception(oss.str());
654 listOfEltToWakeUp.push_back(*it);
656 newList.push_back(*it);
658 for(std::list< KeyWaiter *>::iterator it=listOfEltToWakeUp.begin();it!=listOfEltToWakeUp.end();it++)
659 (*it)->valueJustCome(valueObj);
660 for(std::list< KeyWaiter *>::iterator it=listOfEltToWakeUp.begin();it!=listOfEltToWakeUp.end();it++)
662 _waiting_keys=newList;
665 SALOME::Transaction_ptr DataScopeServerTransaction::addKeyValueInVarHard(const char *varName, const SALOME::ByteVec& key, const SALOME::ByteVec& value)
667 checkVarExistingAndDict(varName);
668 TransactionAddKeyValueHard *ret(new TransactionAddKeyValueHard(this,varName,key,value));
669 CORBA::Object_var obj(ret->activate());
670 return SALOME::Transaction::_narrow(obj);
673 SALOME::Transaction_ptr DataScopeServerTransaction::addKeyValueInVarErrorIfAlreadyExisting(const char *varName, const SALOME::ByteVec& key, const SALOME::ByteVec& value)
675 checkVarExistingAndDict(varName);
676 TransactionAddKeyValueErrorIfAlreadyExisting *ret(new TransactionAddKeyValueErrorIfAlreadyExisting(this,varName,key,value));
677 CORBA::Object_var obj(ret->activate());
678 return SALOME::Transaction::_narrow(obj);
681 SALOME::TransactionMultiKeyAddSession_ptr DataScopeServerTransaction::addMultiKeyValueSession(const char *varName)
683 checkVarExistingAndDict(varName);
684 TransactionMultiKeyAddSession *ret(new TransactionMultiKeyAddSession(this,varName));
685 CORBA::Object_var obj(ret->activate());
686 return SALOME::TransactionMultiKeyAddSession::_narrow(obj);
689 SALOME::Transaction_ptr DataScopeServerTransaction::removeKeyInVarErrorIfNotAlreadyExisting(const char *varName, const SALOME::ByteVec& key)
691 checkVarExistingAndDict(varName);
692 TransactionRemoveKeyInVarErrorIfNotAlreadyExisting *ret(new TransactionRemoveKeyInVarErrorIfNotAlreadyExisting(this,varName,key));
693 CORBA::Object_var obj(ret->activate());
694 return SALOME::Transaction::_narrow(obj);
697 SALOME::TransactionRdWrAccess_ptr DataScopeServerTransaction::createWorkingVarTransac(const char *varName, const SALOME::ByteVec& constValue)
699 std::string varNameCpp(varName);
700 checkNotAlreadyExistingVar(varName);
701 PickelizedPyObjRdWrServer *tmp(new PickelizedPyObjRdWrServer(this,varNameCpp,constValue));
702 CORBA::Object_var obj(tmp->activate());
703 std::pair< SALOME::BasicDataServer_var, BasicDataServer * > p(SALOME::BasicDataServer::_narrow(obj),tmp);
706 TransactionMorphRdWrIntoRdOnly *ret(new TransactionMorphRdWrIntoRdOnly(this,varName));
707 CORBA::Object_var obj2(ret->activate());
708 return SALOME::TransactionRdWrAccess::_narrow(obj2);
711 SALOME::KeyWaiter_ptr DataScopeServerTransaction::waitForKeyInVar(const char *varName, const SALOME::ByteVec& keyVal)
713 PickelizedPyObjServer *pickelObj(checkVarExistingAndDict(varName));
714 KeyWaiter *ret(new KeyWaiter(pickelObj,keyVal));
715 CORBA::Object_var obj(ret->activate());//KeyWaiter instance activated inside a multithread POA contrary to all of objects in SALOMESDS in single thread !
716 return SALOME::KeyWaiter::_narrow(obj);
719 SALOME::KeyWaiter_ptr DataScopeServerTransaction::waitForKeyInVarAndKillIt(const char *varName, const SALOME::ByteVec& keyVal, SALOME::Transaction_out transac)
721 PickelizedPyObjServer *pickelObj(checkVarExistingAndDict(varName));
722 KeyWaiter *ret0(new KeyWaiter(pickelObj,keyVal));
723 CORBA::Object_var obj(ret0->activate());//KeyWaiter instance activated inside a multithread POA contrary to all of objects in SALOMESDS in single thread !
725 TransactionRemoveKeyInVarErrorIfNotAlreadyExisting *ret1(new TransactionRemoveKeyInVarErrorIfNotAlreadyExisting(this,varName,keyVal));
726 CORBA::Object_var obj2(ret1->activate());
727 transac=SALOME::Transaction::_narrow(obj2);
729 return SALOME::KeyWaiter::_narrow(obj);
732 SALOME::ByteVec *DataScopeServerTransaction::waitForMonoThrRev(SALOME::KeyWaiter_ptr kw)
734 PortableServer::ServantBase *ret(0);
737 ret=_poa_for_key_waiter->reference_to_servant(kw);
739 catch(...) { ret=0; }
740 KeyWaiter *retc(dynamic_cast<KeyWaiter *>(ret));
742 throw Exception("DataScopeServerTransaction::invokeMonoThr : internal error 1 !");
744 return retc->waitForMonoThr();
747 void DataScopeServerTransaction::atomicApply(const SALOME::ListOfTransaction& transactions)
749 std::size_t sz(transactions.length());
752 std::vector< AutoServantPtr<Transaction> > transactionsCpp(sz);
753 for(std::size_t i=0;i<sz;i++)
755 PortableServer::ServantBase *eltBase(0);
759 eltBase=_poa->reference_to_servant(transactions[i]);
760 elt=dynamic_cast<Transaction *>(eltBase);
764 std::ostringstream oss; oss << "DataScopeServerTransaction::atomicApply : the elt #" << i << " is invalid !";
765 throw Exception(oss.str());
769 std::ostringstream oss; oss << "DataScopeServerTransaction::atomicApply : the elt #" << i << " is null ?";
770 throw Exception(oss.str());
773 transactionsCpp[i]=elt;
775 {// important do not merge loops !
776 std::vector<TrustTransaction> transactions2(sz);
777 bool mustRollback(true);
778 for(std::size_t i=0;i<sz;i++)
779 transactions2[i].setTransaction(transactionsCpp[i],&mustRollback);
780 for(std::size_t i=0;i<sz;i++)
781 transactions2[i].operate();
784 for(std::size_t i=0;i<sz;i++)
785 transactionsCpp[i]->notify();
789 * Returns borrowed reference.
791 PyObject *DataScopeServerTransaction::getPyCmpFunc()
793 PyObject *builtins(PyDict_GetItemString(_globals,"__builtins__"));//borrowed
795 throw Exception("Fail to find reference to builtins !");
796 PyObject *builtins2(PyModule_GetDict(builtins));//borrowed
798 throw Exception("Fail to invoke __dict__ on builtins !");
799 PyObject *cmpObj(PyDict_GetItemString(builtins2,"cmp"));
801 throw Exception("Fail to find cmp in __builtins__ !");
805 DataScopeServerTransaction::~DataScopeServerTransaction()