Changeset 2755 in Sophya for trunk

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

Location:

trunk/SophyaPI/PIext

Files:

• basexecut.cc (modified) (2 diffs)
• basexecut.h (modified) (1 diff)
• cxxexecutor.cc (modified) (7 diffs)
• cxxexecutor.h (modified) (2 diffs)
• nobjmgr.cc (modified) (52 diffs)
• nobjmgr.h (modified) (1 diff)
• pawexecut.cc (modified) (3 diffs)
• pawexecut.h (modified) (1 diff)
• piacmd.cc (modified) (2 diffs)
• pintuple.cc (modified) (3 diffs)
• pistdimgapp.cc (modified) (11 diffs)
• servnobjm.cc (modified) (6 diffs)
• servnobjm.h (modified) (2 diffs)

trunk/SophyaPI/PIext/basexecut.cc

@@ -53 +53 @@
 /* Macro pour tester si flag normalized coordinate est present */
 #define _CkBoolNC_(_jk_) ((tokens.size()>_jk_) && (tokens[_jk_] == "true")) ? true : false;
- 
+
+
 /* --Methode-- */
 int PIABaseExecutor::Execute(string& kw, vector<string>& tokens, string& toks)
@@ -1125 +1126 @@
 
 return(0);
+}
+
+/* --Methode-- */
+bool PIABaseExecutor::IsThreadable(string const & keyw)
+{
+  if ( (keyw == "fillvec") || (keyw == "fillmtx") || 
+       (keyw == "fillnt") || (keyw == "ntloop") )  return true;
+  else if (keyw.substr(0,4) == "func")  return true;
+  else {
+    string skw = keyw.substr(0,5);
+    if ( (skw == "plot2") || (skw == "plot3") || (skw == "projh") )  return true; 
+  } 
+  return false; 
 }
 

trunk/SophyaPI/PIext/basexecut.h

@@ -14 +14 @@
   virtual       ~PIABaseExecutor();
   virtual int   Execute(string& keyw, vector<string>& args, string& toks);
+  virtual bool  IsThreadable(string const & keyw);
 
 protected :

trunk/SophyaPI/PIext/cxxexecutor.cc

@@ -155 +155 @@
     return(1);
   }
+  // Pour synchronisation d'execution simultanee
+  ZSync zs(mutx_cxxe, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
+
   rc = ExecuteCXX(toks); if(rc) return(1);
 
@@ -162 +165 @@
     return(1);
   }
+  // Pour synchronisation d'execution simultanee
+  ZSync zs(mutx_cxxe, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
+
   rc = FillUserCode(tokens[0]); if(rc) return(1);
   if(tokens.size()>1) rc = FillUserFctFrF(tokens[1]);
@@ -181 +187 @@
     return(1);
   }
+  // Pour synchronisation d'execution simultanee
+  ZSync zs(mutx_cxxe, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
+
   rc = FillUserCode(toks,2);        if(rc) return(1);
   rc = FillUserFctFrS();            if(rc) return(1);
@@ -190 +199 @@
     return(1);
   }
+  // Pour synchronisation d'execution simultanee
+  ZSync zs(mutx_cxxe, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
+
   rc = FillUserCode(tokens[2]); if(rc) return(1);
   if(tokens.size()>3) rc = FillUserFctFrF(tokens[3]);
@@ -197 +209 @@
 
 } else if(kw == "c++compile") {
+  // Pour synchronisation d'execution simultanee
+  ZSync zs(mutx_cxxe, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
+
   if(tokens.size()>=1) rc = Compile(tokens[0]);
   else                 rc = Compile();
@@ -202 +217 @@
 
 } else if(kw == "c++link") {
+  // Pour synchronisation d'execution simultanee
+  ZSync zs(mutx_cxxe, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
+
   if(tokens.size()>=2)      rc = Link(tokens[0],tokens[1]);
   else if(tokens.size()>=1) rc = Link(tokens[0]);
@@ -262 +280 @@
 
 return(0);
+}
+
+/* --Methode-- */
+bool  CxxExecutor::IsThreadable(string const & kw)
+{
+if ( (kw == "c++exec") || (kw == "c++execfrf") || 
+     (kw == "c++create") || (kw == "c++createfrf") ||
+     (kw == "c++compile") || (kw == "c++link") )   return true;
+else return false;
 }
 

trunk/SophyaPI/PIext/cxxexecutor.h

@@ -24 +24 @@
 
   virtual int Execute(string& keyw,vector<string>& args, string& toks);
+  virtual bool  IsThreadable(string const & keyw);
 
   inline void SetPrtLevel(uint_2 lp=2) {mPrtLevel = lp;}
@@ -96 +97 @@
   uint_2 mPrtLevel;
   bool   mFgPutVar;  // if true , declare ObjMgr variables as $varname, default=false
+
+  // Mutex de controle de thread pour dynamic-link 
+  ZMutex mutx_cxxe;
+
 };
 

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();
 

trunk/SophyaPI/PIext/nobjmgr.h

@@ -116 +116 @@
   virtual bool          RenameObj_P(string & nom, string& nomnew);
   virtual bool          DelObj_P(string & nom, bool fgd=true);
+  virtual AnyDataObj*   GetObj_P(string & nom);
+  virtual NObjMgrAdapter*       GetObjAdapter_P(string & nom);
+  virtual void          ReadObj_P(PInPersist& s, int num=-1);
   virtual void          SaveObj_P(string & nom, POutPersist& s, bool keeppath=false);
 

trunk/SophyaPI/PIext/pawexecut.cc

@@ -319 +319 @@
 } else return(1); 
 }
+
+/* methode */
+bool PAWExecutor::IsThreadable(string const & keyw)
+{
+  if ( (keyw == "n/plot")  || (keyw == "n/pl") || 
+       (keyw == "n/proj") )  return true;
+  else return false;
+}
+
 
 /* methode */
@@ -435 +444 @@
 }
 
+
 /* methode */
 void PAWExecutor::n_proj(vector<string>& tokens)
@@ -630 +640 @@
 }
 
+
 /* methode */
 #define __LENLINE_N_READ__ 8192

trunk/SophyaPI/PIext/pawexecut.h

@@ -19 +19 @@
   virtual     ~PAWExecutor();
   virtual int Execute(string& keyw, vector<string>& args, string& toks);
+  virtual bool  IsThreadable(string const & keyw);
+
 protected:
   void  reset(vector<string>& tokens);

trunk/SophyaPI/PIext/piacmd.cc

@@ -366 +366 @@
   Commander::SetCurrentPrompt(pr);
   if (mImgApp) { 
-    ZSync(mImgApp->getMutex());
+    ZSync zs(mImgApp->getMutex()); zs.NOp(); 
     mImgApp->GetConsole()->SetPrompt(pr);
   }
@@ -378 +378 @@
   char va = (att == 0) ? 0 : PIVA_Magenta;
   if (mImgApp) { 
-    ZSync(mImgApp->getMutex());
+    ZSync(mImgApp->getMutex()); zs.NOp(); 
     mImgApp->GetConsole()->AddStr(msg, va);
   }

trunk/SophyaPI/PIext/pintuple.cc

@@ -198 +198 @@
 npolyg = 0;
 NptDraw = 0;
+
+// Mai 2005: Correction bug trace des lignes avec le pts en dehors de la zone (Reza)
+// flags pour la gestion des points/lignes a tracer
+bool fgokcurpt = true;  // Point courant dans la zone a tracer
+bool fgoklastpt = true;   // Le dernier point etait dans la zone a tracer
 for (long i=0; i<(long)mNT->NbLines(); i++) {
-  xl = xp;  yl = yp;
+  xl = xp;  yl = yp; fgoklastpt = fgokcurpt;
+
   xp = mNT->GetCell(i, xK);
   yp = mNT->GetCell(i, yK);
-  if ( (xp < xmin2) || (xp > xmax2) || (yp < ymin2) || (yp > ymax2) )  continue;
-  nok++;
-  if ( (xp < xmin) || (xp > xmax) || (yp < ymin) || (yp > ymax) )  continue;
-
-  NptDraw++;
+
+  // Comptage du nombre de pts dans la zone graphique du widget
+  if ( !((xp < xmin2) || (xp > xmax2) || (yp < ymin2) || (yp > ymax2)) )  nok++;
+  // Gestion des limites a tracer
+  fgokcurpt = true;
+  if ( (xp < xmin) || (xp > xmax) || (yp < ymin) || (yp > ymax) ) fgokcurpt = false;
+  else NptDraw++;
+
 // Taille - couleur de marker en fonction du poids
-  if (wK >= 0) wp = mNT->GetCell(i, wK);
-  if (mrkSzScale && (wK >= 0)) {  // Changement de taille
+  if ( fgokcurpt &&(wK >= 0) ) wp = mNT->GetCell(i, wK);
+  if ( fgokcurpt && mrkSzScale && (wK >= 0) ) {  // Changement de taille
     sz = (int)((wp-wMin)/dw);
     if (sz < 0) sz = 0;
@@ -218 +227 @@
   }
 // Couleur du marker en fonction du poids
-  if( colorScale && (wK >= 0) && cmap ) {
+  if( fgokcurpt && colorScale && (wK >= 0) && cmap ) {
     int cid = (int)((wp-wMin)/dwc);
     if (cid < 0) cid = 0;
@@ -227 +236 @@
   // Trace d'une ligne reliant les points
   if( connectPts ) {
-    if((npolyg==0) && (i>0)) {xpolyg[0]=xl; ypolyg[0]=yl; npolyg=1;}
-    if(npolyg<NMXMULTP_LOCAL)
+    // On initialise le polygone avec le dernier point, si ce dernier ok
+    if((npolyg==0) && (i>0) && fgokcurpt) {xpolyg[0]=xl; ypolyg[0]=yl; npolyg=1;}
+    // On ajoute le point courant au polygone - sauf si celui-ci est vide
+    if((npolyg<NMXMULTP_LOCAL) && (npolyg>0))
       {xpolyg[npolyg]=xp; ypolyg[npolyg]=yp; npolyg++;}
-    if(npolyg==NMXMULTP_LOCAL)
+    // On trace le polygone s'il est plein - ou le point courant en dehors
+    // (point courant en dehors -> discontinuite de la ligne 
+    if( !fgokcurpt || (npolyg==NMXMULTP_LOCAL) )
       {g->DrawPolygon(xpolyg,ypolyg,npolyg,false); npolyg=0;}
   }
 
+  // Plus rien a faire si point en dehors -- on s'en va 
+  if (!fgokcurpt)  continue;
+
   // Trace des erreurs selon X et Y
-  if ( xebK >= 0 ) {
+  if (xebK >= 0) {
     xer = mNT->GetCell(i, xebK);
     if(xer>0.) g->DrawLine(xp-xer, yp, xp+xer, yp);
   }
-  if ( yebK >= 0 ) {
+  if (yebK >= 0) {
     yer = mNT->GetCell(i, yebK);
     if(yer>0.) g->DrawLine(xp, yp-yer, xp, yp+yer);

trunk/SophyaPI/PIext/pistdimgapp.cc

@@ -1035 +1035 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1062 +1062 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1090 +1090 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1116 +1116 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1156 +1156 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1183 +1183 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1209 +1209 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1233 +1233 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1259 +1259 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1286 +1286 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();
@@ -1312 +1312 @@
 {
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+ZSync zs(thr_glsyn, 2);  zs.NOp(); 
 
 PIDrawer *eld=CurrentElDrawer();

trunk/SophyaPI/PIext/servnobjm.cc

@@ -107 +107 @@
 if (!mImgapp)  return; 
 
+// Pour synchronisation d'execution simultanee
+ZSync zs(mutx_dynlink, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
+
 cmd = "rm -f " + fname;
 rc = system(cmd.c_str());
@@ -141 +144 @@
 
 if (!mImgapp)  return; 
+// Pour synchronisation d'execution simultanee
+ZSync zs(mutx_dynlink, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
 
 cmd = "rm " + fname;
@@ -170 +175 @@
                                        double xmin, double xmax, int np, string dopt)
 {
+// Pour synchronisation d'execution simultanee
+ZSync zs(mutx_dynlink, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
 DlFunctionOfX f = (DlFunctionOfX) LinkFunctionFromFile(fname, func);
 if (!f) return; 
@@ -181 +188 @@
                                          double xmin, double xmax, double ymin, double ymax, int npx, int npy, string dopt)
 {
+// Pour synchronisation d'execution simultanee
+ZSync zs(mutx_dynlink, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
 DlFunctionOfXY f = (DlFunctionOfXY) LinkFunctionFromFile(fname, func);
 if (!f)  return;
@@ -884 +893 @@
   }
 
+// Pour synchronisation d'execution simultanee
+ZSync zs(mutx_dynlink, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
+
 NTLoopExprFunc f = (NTLoopExprFunc)LinkFunctionFromFile(fname, funcname);
 if (!f) { 
@@ -1177 +1189 @@
 if (objnt == NULL)  return;
 string  vardec = objnt->VarList_C("_zz6qi_");
+
+// Pour synchronisation d'execution simultanee
+ZSync zs(mutx_dynlink, 2);  zs.NOp(); // 2 -> broadcast lors de la destruction
 
 PlotExprFunc f = LinkExprFunc(vardec, expx, expy, expz, expt, expcut);

trunk/SophyaPI/PIext/servnobjm.h

@@ -17 +17 @@
 #include "dlftypes.h"
 #include "anydataobj.h"
+
+#include "zthread.h"
 
 #ifdef SANS_EVOLPLANCK
@@ -135 +137 @@
   PDynLinkMgr * dynlink;  // shared-lib lib.so
   string TmpDir;          // Pour fichiers temporaires
+  // Mutex de controle de thread pour dynamic-link 
+  ZMutex mutx_dynlink;
 
   PIStdImgApp* mImgapp;
   NamedObjMgr* mOmg;
+
   
 };