Changeset 3178 in Sophya for trunk/SophyaProg

Timestamp:

Feb 6, 2007, 3:05:52 PM (19 years ago)

Author:

ansari

Message:

zthr: test avec synchronisationPb lors de destruction NDataBlock, tentative de contourner , Reza 06/02/2007

File:

• trunk/SophyaProg/Tests/zthr.cc (modified) (7 diffs)

trunk/SophyaProg/Tests/zthr.cc

@@ -96 +96 @@
 // Structure de gestion utilisee par la classe MTVecPool
 typedef struct {
+  TVector<int_8> vv;
   bool busy;
   int stat;
@@ -119 +120 @@
   ~MTVecPool()   { }
   // Renvoie un pointeur de vecteur pour thread tid
-  TVector<int_8>  GetVec(uint_4 tid, uint_4& idx)
+  TVector<int_8>*  GetVec(uint_4 tid, uint_4& idx)
   {
     if (tid >= _nth) ParmError("MTVecPool::getvec() tid > _nth");
@@ -127 +128 @@
       St_VecPool stv;
       idx = _vecs.size();
+      stv.vv = _vmx.Column(idx);
       stv.busy = true;
       stv.stat = 0;
       _vecs.push_back(stv);
       mex.unlock();
-      //DBG cout << "DBG-GetVec(tid= " << tid << ") -> Idx=" << idx << " VecSz=" << _vmx.Column(idx).Size() << endl;
-      return (_vmx.Column(idx));
+      //DBG cout << "DBG-GetVec(tid= " << tid << ") -> Idx=" << idx << " VecSz=" << &(_vecs[idx].vv) << endl;
+      return (&(_vecs[idx].vv));
     }
     else {
@@ -148 +150 @@
           mex.unlock();
           //DBG  cout << "DBG-GetVec(tid= " << tid << ") -> nv=" << hex << rv << dec << endl;
-          return (_vmx.Column(idx));
+          return (&(_vecs[idx].vv));
         }
         else { 
@@ -158 +160 @@
   }
 
-  // Retourne le pointeur de vecteur au gestionnaire, qui le marque comme disponible
+  // Retourne l'index du vecteur au gestionnaire, qui le marque comme disponible
   void RetVec(uint_4 idx)
   {
@@ -182 +184 @@
         nerr++;
       }
-      _vmx.Column(k) -= sum;
-      _vmx.Column(k).MinMax(min, max);
+      _vecs[k].vv -= sum;
+      _vecs[k].vv.MinMax(min, max);
       if ((min!=0) || (max!=0)) {
         cout << " Check()/Pb vec[k=" << k << "] != (sum=" << sum << ")" << endl;
@@ -225 +227 @@
   uint_4 idx;
   for(k=0; k<L; k++) {
-    mtvp->GetVec(tid, idx) += p2;
+    *(mtvp->GetVec(tid, idx)) += p2;
     //DBG cout << "DBG-sync_funzt(tid=" << tid << ", idx=" << idx << endl;
     mtvp->RetVec(idx);