Changeset 1496 in Sophya for trunk/ArchTOIPipe/ProcWSophya

Timestamp:

May 16, 2001, 4:26:28 PM (24 years ago)

Author:

ansari

Message:

2eme version de genwproc + programme de test rz+cmv 16/5/2001

Location:

trunk/ArchTOIPipe/ProcWSophya

Files:

• genwproc.cc (modified) (15 diffs)
• genwproc.h (modified) (5 diffs)

trunk/ArchTOIPipe/ProcWSophya/genwproc.cc

@@ -6 +6 @@
 #include "ctimer.h"
 
+
+// #define DEBUGGENW 1 
+
 // -------------------------------------------------------------
 //   Class GenWindowTOIProcessor : generic processor with window
@@ -19 +22 @@
   if(wsz%2==0) wsz++;
   if(wstep<1) wstep=1;
-  if(wsztot<wsz) wsztot = 2*wsz;
+  if(wsztot<wsz) wsztot = 2*wsz;  // CMV prise de decision wsztot / wstep
 
   NbInput = nbinput;
@@ -27 +30 @@
   WSizeTot = wsztot;
 
-  SNdeb = SNend = StartSample = CurSnInd = -1;
+  SNdeb = SNend = StartSample = CurWtIndex = -1;
   TotNsCount = 0;
 
-  TVector<r_8> vr8;
-  TVector<int_8> vi8;
+  SetDefaultValue();
+
+  TVector<r_8> vr8(1);     // CMV+RZ supprimer taille(1) apres correction de 
+  TVector<int_8> vi8(1);   // constructeur copie de TArray (taille nulle)
   
   int k;
@@ -44 +49 @@
     WOutFlg.push_back(false);
     WPutOutFlg.push_back(false);
+    WPutOutOwnVector.push_back(false);
     OutSample.push_back(0);
   }
@@ -71 +77 @@
     throw RangeCheckError("GenWindowTOIProcessor::GetWData : toi out of range !");
   if(!WInFlg[numtoi])
-    throw RangeCheckError("GenWindowTOIProcessor::GetWData : toi not connected!");
-  return WDataIn[numtoi];
+    throw ParmError("GenWindowTOIProcessor::GetWData : toi not connected!");
+  return (WDataIn[numtoi])(Range(StartWtIndex(),0,WSize));
 }
 
@@ -80 +86 @@
     throw RangeCheckError("GenWindowTOIProcessor::GetWFlag : toi out of range !");
   if(!WInFlg[numtoi])
-    throw RangeCheckError("GenWindowTOIProcessor::GetWFlag : toi not connected!");
-  return WFlagIn[numtoi];
+    throw ParmError("GenWindowTOIProcessor::GetWFlag : toi not connected!");
+  return (WFlagIn[numtoi])(Range(StartWtIndex(),0,WSize));
+}
+
+r_8 * GenWindowTOIProcessor::GetWDataPointer(int numtoi)
+{
+  if(numtoi<0 || numtoi>=NbInput)
+    throw RangeCheckError("GenWindowTOIProcessor::GetWDataPointer : toi out of range !");
+  if(!WInFlg[numtoi])
+    throw ParmError("GenWindowTOIProcessor::GetWDataPointer : toi not connected!");
+  return (WDataIn[numtoi].Data()+StartWtIndex());
+
+}
+ 
+int_8 * GenWindowTOIProcessor::GetWFlagPointer(int numtoi)
+{
+  if(numtoi<0 || numtoi>=NbInput)
+    throw RangeCheckError("GenWindowTOIProcessor::GetWFlagPointer : toi out of range !");
+  if(!WInFlg[numtoi])
+    throw ParmError("GenWindowTOIProcessor::GetWFlagPointer : toi not connected!");
+  return (WFlagIn[numtoi].Data()+StartWtIndex());
+}
+
+void GenWindowTOIProcessor::GetData(int numtoi, int_8 numsample, r_8 & data, int_8 & flag)
+{
+  if(numtoi<0 || numtoi>=NbInput)
+    throw RangeCheckError("GenWindowTOIProcessor::GetData : toi out of range !");
+  if(!WInFlg[numtoi])
+    throw ParmError("GenWindowTOIProcessor::GetData : toi not connected!");
+  int_8 k = numsample-GetStartSample();
+  if ((k<0) || (k >= GetWSize()))
+    throw RangeCheckError("GenWindowTOIProcessor::GetData : numsample out of window!");
+  k += StartWtIndex();
+  data = (WDataIn[numtoi])(k);
+  flag = (WFlagIn[numtoi])(k);
 }
 
@@ -91 +130 @@
     throw RangeCheckError("GenWindowTOIProcessor::PutWFlag : toi out of range !");
   if(!WOutFlg[numtoi])
-    throw RangeCheckError("GenWindowTOIProcessor::PutWFlag : toi not connected!");
+    throw ParmError("GenWindowTOIProcessor::PutWFlag : toi not connected!");
   if(data.Size()!=flag.Size())
     throw ParmError("GenWindowTOIProcessor::PutWFlag : data.Size()!=flag.Size()!");
+  if(data.Size() == 0)
+    throw ParmError("GenWindowTOIProcessor::PutWFlag : data.Size()==0 !");
   WDataOut[numtoi].Share(data);
   WFlagOut[numtoi].Share(flag);
   OutSample[numtoi] = numsample;
   WPutOutFlg[numtoi] = true;
+  WPutOutOwnVector[numtoi] = false;
 }
 
@@ -106 +148 @@
     throw RangeCheckError("GenWindowTOIProcessor::PutWFlag : toi out of range !");
   if(!WOutFlg[numtoi])
-    throw RangeCheckError("GenWindowTOIProcessor::PutWFlag : toi not connected!");
-  WDataOut[numtoi].Realloc(1,BaseArray::SameVectorType,true);
-    (WDataOut[numtoi])(0) = data;
-  WFlagOut[numtoi].Realloc(1,BaseArray::SameVectorType,true);
-    (WFlagOut[numtoi])(0) = flag;
+    throw ParmError("GenWindowTOIProcessor::PutWFlag : toi not connected!");
+  if (!WPutOutOwnVector[numtoi]) {
+    WDataOut[numtoi].Realloc(1,BaseArray::SameVectorType,true);
+    WFlagOut[numtoi].Realloc(1,BaseArray::SameVectorType,true);
+    WPutOutOwnVector[numtoi] = true;
+  }
+  (WDataOut[numtoi])(0) = data;
+  (WFlagOut[numtoi])(0) = flag;
   OutSample[numtoi] = numsample;
   WPutOutFlg[numtoi] = true;
@@ -116 +161 @@
 
 ////////////////////////////////////////////////////////////////
-void GenWindowTOIProcessor::UserInit()
+void GenWindowTOIProcessor::UserInit(int_8 kstart)
 {
   cout<<"GenWindowTOIProcessor::UserInit() Default implementation does nothing"<<endl;
 }
 
-void GenWindowTOIProcessor::UserProc()
+void GenWindowTOIProcessor::UserProc(int_8 ks)
 {
   cout<<"GenWindowTOIProcessor:UserProc() Default implementation does nothing"<<endl;
 }
 
-void GenWindowTOIProcessor::UserEnd()
+void GenWindowTOIProcessor::UserEnd(int_8 kend)
 {
   cout<<"GenWindowTOIProcessor::UserEnd() Default implementation does nothing"<<endl;
@@ -152 +197 @@
 {
   //  TOIManager* mgr = TOIManager::getManager();
-  int_8 SNdeb = getMinIn();
-  int_8 SNend = getMaxIn();
+  SNdeb = getMinIn();
+  SNend = getMaxIn();
   if(SNend-SNdeb<WSize)
-    throw RangeCheckError("GenWindowTOIProcessor::run : sne-snb<WSize !");
+    throw ParmError("GenWindowTOIProcessor::run : sne-snb<WSize !");
 
   // Allocation des tailles pour les vecteurs
@@ -169 +214 @@
     throw ParmError("GenWindowTOIProcessor::run() No input TOI connected!");
   }
-  for(kc=0;kc<NbOutput;kc++)
-      WOutFlg[kc] = checkOutputTOIIndex(kc);
+  for(kc=0;kc<NbOutput;kc++) WOutFlg[kc] = checkOutputTOIIndex(kc);
 
   // Lecture des samples et remplissage des vecteurs
@@ -176 +220 @@
   try {
     Timer tm("GenWindowTOIProcessor::run()");
-    int_8 ki = -1;
-
-    for(int_8 ks=SNdeb;ks<=SNend;ks++) {
+    for(int_8 ks=SNdeb;ks<=SNend;ks++) {  // CMV gerer le += step
       Remplissage(ks);
+      if (ks == SNdeb) {
+        UserInit(ks);
+        Ecriture();
+      }
+      if ((ks-SNdeb)%WStep == 0) {
+        UserProc(ks);
+        // Il faut traiter les ecritures en sortie 
+        Ecriture();
+      }
       TotNsCount++;
     }
+    UserEnd(SNend);
+    Ecriture();
     cout << " GenWindowTOIProcessor::run() - End of processing " << endl;
 
   } catch(PException & exc) {
-    cerr<<"GenWindowTOIProcessor: Catched Exception "<<(string)typeid(exc).name()
+    cerr<<"GenWindowTOIProcessor::run Catched Exception "<<(string)typeid(exc).name()
         <<"\n .... Msg= "<<exc.Msg()<<endl;
   }
@@ -196 +249 @@
 //      samples :   sn-ws/2        sn          sn+ws/2
 //      fenetre :   0              ws/2+1      ws-1
-//   ki : index des vecteurs a remplir.
-//        C'est l'index ou on veut remplir la donnee
-//        dans un vecteur (fictif) de taille WSize.
-//        La routine gere le decalage dans le grand buffer WSizeTot.
-//  Si ki depasse la taille maximale permise on decale, sinon on ne fait rien
-// RETURN:
-//   numero du PROCHAIN index a remplir (ki+1 si pas decale !)
-{
-if(ks<SNdeb || ks>SNend)
+{
+#ifdef DEBUGGENW
+ cout << "GenWindowTOIProcessor::Remplissage(" << ks << ") CurWtIndex=" << CurWtIndex << endl;
+#endif 
+
+if(ks<SNdeb || ks>SNend) {
+  cerr << "GenWindowTOIProcessor::remplissage/Erreur : ks(=" << ks << ") <" 
+       << SNdeb << " || ks>" << SNend << endl; 
   throw RangeCheckError("GenWindowTOIProcessor::remplissage : ks<SNdeb || ks>SNend !");
-
+ }
 int_8 wsz2=WSize/2;
 
@@ -212 +264 @@
 
 // Premier remplissage ???? Gestion de la borne inferieure
-if(CurSnInd<0) {
-  CurSnInd = 0;
+if(CurWtIndex<0) {
+#ifdef DEBUGGENW
+  cout << "GenWindowTOIProcessor::Remplissage 1ere fois" << endl; 
+#endif 
+  CurWtIndex = 0;
   for(int_8 k=ks-wsz2; k<=ks+wsz2; k++) { // Lecture TOI
     for(int kc=0; kc<NbInput; kc++) {
       if(!WInFlg[kc]) continue;
       if(k>=SNdeb && k<=SNend) {
-        getData(kc,k,(WDataIn[kc])(CurSnInd), (WFlagIn[kc])(CurSnInd));
+        getData(kc,k,(WDataIn[kc])(CurWtIndex), (WFlagIn[kc])(CurWtIndex));
       } else {
-        (WDataIn[kc])(CurSnInd) = (r_8) 0.;
-        (WFlagIn[kc])(CurSnInd) = (int_8) 0;
+        (WDataIn[kc])(CurWtIndex) = R8DefVal;
+        (WFlagIn[kc])(CurWtIndex) = I8DefVal;
       }
     }
-    CurSnInd++;
+    CurWtIndex++;
   }
   return;
 }
 
+// CMV gere decalage seulement si step < wsize sinon copie.
 // Faut-il decaler ????
-if(CurSnInd == WSizeTot) { // On decale
+if(CurWtIndex == WSizeTot) { // On decale
+#ifdef DEBUGGENW
+  cout << "GenWindowTOIProcessor::Remplissage Decalage " << endl; 
+#endif 
   for(int kc=0; kc<NbInput; kc++) {
     if(!WInFlg[kc]) continue;
@@ -238 +297 @@
       }
   }
-  CurSnInd = WSize-1;
+  CurWtIndex = WSize-1;
 }
 
 // Remplissage de ks+wsz2 (dernier element de la fenetre pour ks central)
 int_8 kse = ks+wsz2;
+#ifdef DEBUGGENW
+  cout << "GenWindowTOIProcessor::Normal fill " << endl; 
+#endif 
 for(int kc=0; kc<NbInput; kc++) {
   if(!WInFlg[kc]) continue;
   if(kse>=SNdeb && kse<=SNend) {
-    getData(kc,kse,(WDataIn[kc])(CurSnInd),(WFlagIn[kc])(CurSnInd));
+    getData(kc,kse,(WDataIn[kc])(CurWtIndex),(WFlagIn[kc])(CurWtIndex));
   } else {
-    (WDataIn[kc])(CurSnInd) = (r_8) 0.;
-    (WFlagIn[kc])(CurSnInd) = (int_8) 0;
-  }
-}
-CurSnInd++;
+    (WDataIn[kc])(CurWtIndex) = R8DefVal;
+    (WFlagIn[kc])(CurWtIndex) = I8DefVal;
+  }
+}
+CurWtIndex++;
 
 return;
 }
+
+void GenWindowTOIProcessor::Ecriture()
+{
+  int_8 maxlenout = 0;
+  int kc;
+  for(kc=0; kc<NbOutput; kc++)
+    if(WOutFlg[kc] && WPutOutFlg[kc] && (WDataOut[kc].Size() > maxlenout) )
+      maxlenout = WDataOut[kc].Size();
+
+  for(int_8 k=0; k<maxlenout; k++) {
+    for(int kc=0; kc<NbOutput; kc++) {
+      if(!WOutFlg[kc]) continue;
+      if(!WPutOutFlg[kc]) continue;
+      if(k>=WDataOut[kc].Size()) continue;
+      putData(kc, k+OutSample[kc], (WDataOut[kc])(k), (WFlagOut[kc])(k));      
+    }
+  }
+  for(kc=0; kc<NbOutput; kc++)  WPutOutFlg[kc] = false;
+}

trunk/ArchTOIPipe/ProcWSophya/genwproc.h

@@ -13 +13 @@
 public:
   GenWindowTOIProcessor(int nbinput,int nboutput,int wsz, int wstep=1, int wsztot=-1);
-  ~GenWindowTOIProcessor();
+  virtual ~GenWindowTOIProcessor();
 
   inline int_8 GetWSize() const { return WSize; }
@@ -21 +21 @@
   inline int_8 GetStartSample()  {return StartSample;}
   inline int_8 GetCenterSample() {return StartSample + WSize/2;}
+  inline int_8 StartSampleNum() { return SNdeb; }
+  inline int_8 EndSampleNum() { return SNend; }
+
+  inline void SetDefaultValue(r_8 r8dval=0., int_8 i8dval=0)
+                      {R8DefVal = r8dval; I8DefVal = i8dval;}
+
   TVector<r_8> GetWData(int numtoi=0);
   TVector<int_8> GetWFlag(int numtoi=0);
+  r_8 * GetWDataPointer(int numtoi=0);
+  int_8 * GetWFlagPointer(int numtoi=0);
+  void GetData(int numtoi, int_8 numsample, r_8 & data, int_8 & flag);
+  inline void GetData(int_8 numsample, r_8 & data, int_8 & flag)
+                      { GetData(0, numsample, data, flag); }
+
   void PutWData(int numtoi,int_8 numsample,TVector<r_8>& data,TVector<int_8>& flag);
   void PutWData(int numtoi,int_8 numsample,r_8 data,int_8 flag);
@@ -32 +44 @@
   virtual void PrintStatus(ostream & os);
 
-  virtual void UserInit();
-  virtual void UserProc();
-  virtual void UserEnd();
+  virtual void UserInit(int_8 kstart);
+  virtual void UserProc(int_8 ks);
+  virtual void UserEnd(int_8 kend);
 
   virtual void  init();  
@@ -41 +53 @@
 protected:
   void Remplissage(int_8 ks);
-  inline int_8 StartSnIndex()
-         {if(CurSnInd<0) return -1; else return CurSnInd-WSize;}
-  inline int_8 CenterSnIndex()
-         {if(CurSnInd<0) return -1; else return CurSnInd-(WSize+1)/2;}
+  void Ecriture();
+  inline int_8 StartWtIndex()
+         {if(CurWtIndex<0) return -1; else return CurWtIndex-WSize;}
+  inline int_8 CenterWtIndex()
+         {if(CurWtIndex<0) return -1; else return CurWtIndex-(WSize+1)/2;}
 
   int NbInput,NbOutput;
   int_8 WSizeTot,WSize,WStep;
   int_8 SNdeb,SNend;
-  int_8 StartSample,CurSnInd;
+  int_8 StartSample,CurWtIndex;
   int_8 TotNsCount;
+  r_8 R8DefVal;
+  int_8 I8DefVal;
   vector< TVector<r_8>   > WDataIn;
   vector< TVector<int_8> > WFlagIn;
@@ -58 +73 @@
   vector< bool > WOutFlg;
   vector< bool > WPutOutFlg;
+  vector< bool > WPutOutOwnVector;
   vector< int_8 > OutSample;
 };