Changeset 2755 in Sophya for trunk/SophyaPI/PIext/nobjmgr.cc

Timestamp:

May 23, 2005, 6:33:02 PM (20 years ago)

Author:

ansari

Message:

1/ Correction bug trace des lignes ds PINTuple
2/ Ajout methode IsThreadable() (declaration conformite thread separe pour certaines commandes) ds baseexecut.h .cc (plot2d plot3d ...) , ds pawexecut.cc (n/plot ...) et ds cxxexecutor.h .cc (c++exec c++execfrf ...)
3/ Ajout de ZMutex (et ZSync) pour la gestion des commandes threadable - ds les
executeurs et ds servnobjm.h .cc
4/ bug d'execution en thread identifie et corrige ds nobjmgr.h .cc (ajout des
methodes GetObj_P() GetObjAdapter_P() et ReadObj_P()
5/ Ajout de l'appel a ZSync::NOp() pour eviter les warnings 'unused variable zs ...'

Reza 23 Mai 2005

File:

• trunk/SophyaPI/PIext/nobjmgr.cc (modified) (52 diffs)

trunk/SophyaPI/PIext/nobjmgr.cc

@@ -95 +95 @@
 static DVList* myVars = NULL;  // Pour stocker les variables
 
-static string* TmpDir;  // Repertoire pour les compilations / link dynamique
+static string* TmpDir = NULL;  // Repertoire pour les compilations / link dynamique
 
 // Pour gestion multithread 
-static ZMutex* myMutex;
+static ZMutex* myMutex = NULL;
 // ..................................................................
 
@@ -122 +122 @@
   myObjs = new NObjList;  
   myVars = new DVList;
+  myMutex = new ZMutex;
   currDir = new string("home");
   string dirn = "home";
@@ -144 +145 @@
   if ( (l>0) && ((*TmpDir)[l-1] != '/') )  (*TmpDir) += '/';
   servnobjm = new Services2NObjMgr(*TmpDir);
-  myMutex = new ZMutex;
   }
 fgOInit++;
@@ -230 +230 @@
     return(false);
   }
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
 #ifdef SANS_EVOLPLANCK
   bool fg = true;
@@ -248 +248 @@
     return(false);
   }
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
 #ifdef SANS_EVOLPLANCK
   DVList::ValList::const_iterator it;
@@ -266 +266 @@
     return(false);
   }
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
 #ifdef SANS_EVOLPLANCK
   return(false);
@@ -281 +281 @@
     return("");
   }
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
   //  cout << " DEBUG::GetVar " << *myVars << endl;
   return(myVars->GetS(key));
@@ -290 +290 @@
 {
   //  cout << " DEBUG::GetVarList " << *myVars << endl;
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
   return(*myVars);
 }
@@ -297 +297 @@
 bool NamedObjMgr::CreateDir(string & dirname)
 {
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
   return CreateDir_P(dirname);
 }
@@ -337 +337 @@
   return(false); 
   }
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 NObjDirList::iterator it = myDirs->find(dirname);
 if (it == myDirs->end()) {
@@ -369 +369 @@
 void NamedObjMgr::LockDir(string & dirname)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 if ( !CheckDirName(dirname) ) return;
 NObjDirList::iterator it = myDirs->find(dirname);
@@ -381 +381 @@
 void NamedObjMgr::UnlockDir(string & dirname)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 if ( !CheckDirName(dirname) ) return;
 NObjDirList::iterator it = myDirs->find(dirname);
@@ -393 +393 @@
 void NamedObjMgr::SetKeepOldDirAtt(string & dirname, bool keepold)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 if ( !CheckDirName(dirname) ) return;
 NObjDirList::iterator it = myDirs->find(dirname);
@@ -409 +409 @@
 bool NamedObjMgr::SetCurrentDir(string & dirname)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 if ( !CheckDirName(dirname) ) {
   cout << "NamedObjMgr::SetCurrentDir( " << dirname << ") Error - Invalid name !" << endl;
@@ -427 +427 @@
 void NamedObjMgr::GetCurrentDir(string & dirname)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 dirname = *currDir;
 }
@@ -434 +434 @@
 void NamedObjMgr::ListDirs(string & patt)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 NObjDirList::iterator it;
 string cn;
@@ -454 +454 @@
 void NamedObjMgr::GetDirList(string & patt, vector<string>& lstd)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 NObjDirList::iterator it;
 string cn;
@@ -467 +467 @@
 void NamedObjMgr::CleanDir(string & dirname)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 CleanDir_P(dirname);
 }
@@ -533 +533 @@
 bool NamedObjMgr::AddObj(AnyDataObj* obj, string & nom, bool crd)
 {
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
   return AddObj_P(obj, nom, crd);
 }
@@ -625 +625 @@
 bool NamedObjMgr::AddObj(AnyDataObj& obj, string & nom, bool crd)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 NObjMgrAdapter* adap = GetServiceObj()->GetAdapter(&obj);
 if (adap == NULL) {
@@ -643 +643 @@
 bool NamedObjMgr::RenameObj(string & nom, string& nomnew)
 {
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
   return RenameObj_P(nom, nomnew);
 }
@@ -710 +710 @@
 bool NamedObjMgr::CopyObj(string & nom, string& nomcp)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 if(nomcp.length()<=0)
   {cout<<"NamedObjMgr::CopyObj() Error, copied obj name "<<nomcp<<" not valid"<<endl;
   return(false);}
-NObjMgrAdapter* obnom = GetObjAdapter(nom);
+NObjMgrAdapter* obnom = GetObjAdapter_P(nom);
 if(obnom==NULL)
   {cout<<"NamedObjMgr::CopyObj() Error -  No "<<nom<<" object !"<<endl;
@@ -727 +727 @@
 bool NamedObjMgr::DelObj(string & nom, bool fgd)
 {
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
   return DelObj_P(nom, fgd);
 }
@@ -778 +778 @@
 bool NamedObjMgr::DelObj_Id(int oid)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 NObjList::iterator it;
 string nom;
@@ -794 +794 @@
 void NamedObjMgr::DelObjects(string & patt, bool fgd)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 string n1,r1;
 ParseObjectName(patt, r1, n1);
@@ -812 +812 @@
 AnyDataObj* NamedObjMgr::GetObj(string & nom)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
+return GetObj_P(nom);
+}
+
+/* --Methode-- */
+AnyDataObj* NamedObjMgr::GetObj_P(string & nom)
+{
 string n1,r1;
 ParseObjectName(nom, r1, n1);
@@ -824 +830 @@
 NObjMgrAdapter* NamedObjMgr::GetObjAdapter(string & nom)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
+return GetObjAdapter_P(nom);
+}
+
+/* --Methode-- */
+NObjMgrAdapter* NamedObjMgr::GetObjAdapter_P(string & nom)
+{
 string n1,r1;
 ParseObjectName(nom, r1, n1);
@@ -836 +848 @@
 void NamedObjMgr::ListObjs(string & patt)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 int k;
 AnyDataObj* obj=NULL;
@@ -865 +877 @@
 void NamedObjMgr::GetObjList(string & patt, vector<string> &lst)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 string n1,r1;
 if (patt.length() < 1)  return;
@@ -901 +913 @@
 void NamedObjMgr::ReadObj(string const & flnm, string & nobj)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 PPersist* ppobj=NULL;
 bool ok = true;
@@ -934 +946 @@
 {
 if(flnm_objname.size()<2) return;
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 int nread=0;
 try {
@@ -963 +975 @@
 void NamedObjMgr::ReadObj(PInPersist& s, int num)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp();
+ReadObj_P(s, num); 
+}
+
+/* --Methode-- */
+void NamedObjMgr::ReadObj_P(PInPersist& s, int num)
+{
 int_4 i; // $CHECK$ int -> int_4 a cause de TagKey
 #ifdef SANS_EVOLPLANCK
@@ -1046 +1064 @@
 void NamedObjMgr::ReadAll(string const & flnm)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 #ifdef SANS_EVOLPLANCK
 bool ok = true;
@@ -1065 +1083 @@
   AddObj_P(obj->DataObj(), nom, false);
   }
-else ReadObj((*ppin), -1);
+else ReadObj_P((*ppin), -1);
 delete ppin;
 #else
@@ -1077 +1095 @@
       cout << " ... Reading " << pis.NbNameTags() << " objects at NameTags " ;
     }
-    ReadObj(pis, -1);
+    ReadObj_P(pis, -1);
     return;
   }
@@ -1101 +1119 @@
 void NamedObjMgr::ReadFits(string const & flnm, string & nobj)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 #ifdef SANS_EVOLPLANCK 
 bool ok = false;
@@ -1161 +1179 @@
 void NamedObjMgr::SaveObj(string & nom, POutPersist& s, bool keeppath)
 {
-  ZSync(*myMutex);
+  ZSync zs(*myMutex); zs.NOp(); 
   SaveObj_P(nom, s, keeppath);
 }
@@ -1175 +1193 @@
 NObjMgrAdapter* obja=NULL;
 string nomf = (keeppath) ? nom : nob;
-obja = GetObjAdapter(nom);
+obja = GetObjAdapter_P(nom);
 if (obja == NULL)  return;
 printf("NamedObjMgr::SaveObj(%s, )  (Type=%s) \n",  
@@ -1186 +1204 @@
 void NamedObjMgr::SaveObjects(string & patt, string const& flnm)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 string n1,r1;
 if (patt.length() < 1)  return;
@@ -1228 +1246 @@
 // dont le nom est le dernier argument (liste[n-1])
 {
- ZSync(*myMutex);
+ ZSync zs(*myMutex); zs.NOp(); 
 
  if(liste.size()<2) {
@@ -1260 +1278 @@
 void NamedObjMgr::SaveAll(string const& flnm)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 bool ok = true;
 
@@ -1293 +1311 @@
 void NamedObjMgr::SaveFits(string& nom, string const & flnm)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 
 NObjMgrAdapter* obja=NULL;
-obja = GetObjAdapter(nom);
+obja = GetObjAdapter_P(nom);
 if (obja == NULL)  return;
 cout << "  SaveFits: Object" << nom << " to FITS file " << flnm << endl; 
@@ -1308 +1326 @@
 void NamedObjMgr::PrintObj(string& nom)
 {
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 NObjMgrAdapter* obja=NULL;
-obja = GetObjAdapter(nom);
+obja = GetObjAdapter_P(nom);
 if (obja == NULL)  return;
 AnyDataObj* ob = obja->GetDataObj();
@@ -1330 +1348 @@
 if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
 
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 
 NObjMgrAdapter* obja=NULL;
-obja = GetObjAdapter(nom);
+obja = GetObjAdapter_P(nom);
 if (obja == NULL) {
   cout << "NamedObjMgr::DisplayObj() Error , No object with name " << nom << endl; 
@@ -1380 +1398 @@
 if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
 
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 
 NObjMgrAdapter* obja=NULL;
-obja = GetObjAdapter(nom);
+obja = GetObjAdapter_P(nom);
 if (obja == NULL) {
   cout << "NamedObjMgr::DisplayImage() Error , No such object " << nom << endl; 
@@ -1420 +1438 @@
 if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
 
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 
 NObjMgrAdapter* obja=NULL;
-obja = GetObjAdapter(nom);
+obja = GetObjAdapter_P(nom);
 if (obja == NULL) {
   cout << "NamedObjMgr::DisplaySurf3D() Error , No such object " << nom << endl; 
@@ -1470 +1488 @@
 if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
 
-ZSync(*myMutex);
-
-AnyDataObj* obj=GetObj(nom);
+ZSync zs(*myMutex); zs.NOp(); 
+
+AnyDataObj* obj=GetObj_P(nom);
 if (obj == NULL) {
   cout << "NamedObjMgr::DisplayNT() Error , No such object " << nom << endl; 
@@ -1536 +1554 @@
 if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
 
-ZSync(*myMutex);
-
-AnyDataObj* obj=GetObj(nom);
+ZSync zs(*myMutex); zs.NOp(); 
+
+AnyDataObj* obj=GetObj_P(nom);
 if(obj == NULL)
   {cout << "NamedObjMgr::DisplayGFD() Error , No such object " << nom << endl; 
@@ -1592 +1610 @@
 if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
 
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 
 #ifdef SANS_EVOLPLANCK
@@ -1601 +1619 @@
 
 AnyDataObj* obj;
-obj = GetObj(nomvx);
+obj = GetObj_P(nomvx);
 if(obj == NULL) {
   cout << "NamedObjMgr::DisplayVector() Error , No such object " << nomvx << endl; 
@@ -1613 +1631 @@
 }
 
-obj = GetObj(nomvy);
+obj = GetObj_P(nomvy);
 if(obj == NULL) {
   cout << "NamedObjMgr::DisplayVector() Error , No such object " << nomvy << endl; 
@@ -1706 +1724 @@
 {
 if (!myImgApp)  return;
-ZSync(*myMutex);
+ZSync zs(*myMutex); zs.NOp(); 
 if ( !_fgimgapp )  myImgApp->LockMutex();