Changeset 2755 in Sophya for trunk/SophyaPI/PIext/cxxexecutor.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/cxxexecutor.cc (modified) (7 diffs)

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;
 }