Changeset 2389 in Sophya for trunk/ArchTOIPipe/TestPipes/tstringpipe.cc

Timestamp:

May 21, 2003, 5:55:01 PM (22 years ago)

Author:

cecile

Message:

Cecile ... marche presque !

File:

• trunk/ArchTOIPipe/TestPipes/tstringpipe.cc (modified) (1 diff)

trunk/ArchTOIPipe/TestPipes/tstringpipe.cc

@@ +1 @@
+#include <unistd.h>
+#include "toi.h"
+#include "cgt.h"
+#include "toiprocessor.h"
+#include "toimanager.h"
+#ifdef TOISEQBUFFERED
+#include "toiseqbuff.h"
+#else
+#include "toisegment.h"
+#endif
+
+#include "sambainit.h"
+#include "timing.h"
+#include <stdexcept>
 #include "ring.h"
 #include "ringpipe.h"
 #include "ringprocessor.h"
 
-class RingMaker : public RingProcessor {
+////////////////////////////////////////////////////////////////
+// Le INCLUDE de la classe du processeur (peut etre mis a part)
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+class CreateRing : public RingProcessor {
+public:
+  CreateRing(int nsamples, double theta, double phi, double aperture);
+  virtual ~CreateRing();
+
+  virtual void  init(void);
+  virtual void  run(void);
+
+  void PrintStatus(::ostream & os);
+
+  inline int_8 ProcessedSampleCount() const {return totnscount;}
+protected:
+  Ring r;
+  int_8 nread,nwrite,totnscount;
+};
+
+CreateRing::CreateRing(int nsamples, double theta, double phi, double aperture)
+: r(nsamples,theta,phi,aperture),nread(0), nwrite(0),totnscount(0)
+{
+}
+
+CreateRing::~CreateRing()
+{
+}
+
+void CreateRing::PrintStatus(::ostream & os)
+{
+  os<<"CreateRing::Print -- nread  = "<<nread<<endl
+    <<"                -- nwrite = "<<nwrite<<endl;
+}
+
+void CreateRing::init() {
+//  - 2 ringprocessors qui fabriquent des rings de bruit
+//  - 1 ringprocessor qui les ajoute
+//  - 1 ring processor qui les affiche
+
+
+
+ // Declaration des tuyaux a connecter. L'ordre de declaration compte!
+ cout << "CreateRing::init" << endl;
+ declareRingOutput("sortie_bolo");  // output index 0
+}
+
+void CreateRing::run()
+{
+
+ // Verification des connections en sortie
+ if(!getOutputRing(0) ) {
+   cout<<"CreateRing::run() - Output TOI (boloSum/Mul) not connected! "<<endl;
+   throw ParmError("CreateRing::run() Output TOI (boloSum/Mul) not connected!");
+ }
+
+ //---------------------------------------------------------
+
+ for(int k=0;k<=r.getNSamples();k++) {
+   totnscount++;
+   r.setData(k,0.1*k);
+   nwrite++;
+   putRing(0,k,&r);
+ }
+
+ cout<<"CreateRing::run: end"<<endl;
+}
+
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+
+
+class AddRing : public RingProcessor {
+public:
+  AddRing(void);
+  virtual ~AddRing();
+
+  virtual void  init(void);
+  virtual void  run(void);
+
+  void PrintStatus(::ostream & os);
+
+  inline int_8 ProcessedSampleCount() const {return totnscount;}
+protected:
+  int_8 nread,nwrite,totnscount;
+};
+
+////////////////////////////////////////////////////////////////
+// Le code de la classe du processeur (peut etre mis a part)
+AddRing::AddRing(void)
+: nread(0), nwrite(0),totnscount(0)
+{
+}
+
+AddRing::~AddRing()
+{
+}
+
+void AddRing::PrintStatus(::ostream & os)
+{
+  os<<"AddRing::Print -- nread  = "<<nread<<endl
+    <<"                -- nwrite = "<<nwrite<<endl;
+}
+
+void AddRing::init() {
+//  - 2 ringprocessors qui fabriquent des rings de bruit
+//  - 1 ringprocessor qui les ajoute
+//  - 1 ring processor qui les affiche
+
+
+
+ // Declaration des tuyaux a connecter. L'ordre de declaration compte!
+ cout << "AddRing::init" << endl;
+ declareRingInput("entree_bolo_1");     // input  index 0
+ declareRingInput("entree_bolo_2");     // input  index 1
+ declareRingOutput("sortie_bolo_sum");  // output index 0
+}
+
+void AddRing::run()
+{
+//   // Verification des connections en entree
+ if(!getInputRing(0) || !getInputRing(1) ) {
+   cout<<"AddRing::run() - Input TOI (entree_bolo_1/2/3) not connected! "<<endl;
+   throw ParmError("AddRing::run() Output TOI (entree_bolo_1/2/3) not connected!");
+ }
+
+ // Verification des connections en sortie
+ if(!getOutputRing(0) ) {
+   cout<<"AddRing::run() - Output TOI (boloSum/Mul) not connected! "<<endl;
+   throw ParmError("AddRing::run() Output TOI (boloSum/Mul) not connected!");
+ }
+
+ // On recupere les sample numbers
+ int snb,sne;
+ getRingRange(snb,sne);
+ 
+ cout<<"AddRing::run: sn="<<snb<<" sne="<<sne<<endl;
+ if(snb>sne) {
+   cout<<"AddRing::run() - Bad sample interval"<<snb<<" , "<<sne<<endl;
+   throw ParmError("AddRing::run() - Bad sample interval ");
+ }
+
+ //---------------------------------------------------------
+ Ring const *r1,*r2;
+ 
+
+ for(int k=snb;k<=sne;k++) {
+   totnscount++;
+
+   r1 = getRing(0,k);
+   r2 = getRing(1,k);
+   nread++;
+
+
+   putRing(0,k,r1.getData(k)+r2.getData(k));
+   nwrite++;
+ }
+ cout<<"AddRing::run: end"<<endl;
+}
+
+
+
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+class PrintRing : public RingProcessor {
+public:
+  PrintRing();
+  virtual ~PrintRing();
+
+  virtual void  init(void);
+  virtual void  run(void);
+
+  void PrintStatus(::ostream & os);
+
+  inline int_8 ProcessedSampleCount() const {return totnscount;}
+protected:
+  int_8 nread,nwrite,totnscount;
+};
+
+PrintRing::PrintRing()
+: nread(0), nwrite(0),totnscount(0)
+{
+}
+
+PrintRing::~PrintRing()
+{
+}
+
+void PrintRing::PrintStatus(::ostream & os)
+{
+  os<<"PrintRing::Print -- nread  = "<<nread<<endl
+    <<"                -- nwrite = "<<nwrite<<endl;
+}
+
+void PrintRing::init() {
+//  - 2 ringprocessors qui fabriquent des rings de bruit
+//  - 1 ringprocessor qui les ajoute
+//  - 1 ring processor qui les affiche
+
+
+
+ // Declaration des tuyaux a connecter. L'ordre de declaration compte!
+ cout << "PrintRing::init" << endl;
+ declareRingInput("entree_bolo");  // output index 0
+}
+
+void PrintRing::run()
+{
+
+ // Verification des connections en sortie
+ if(!getInputRing(0) ) {
+   cout<<"PrintRing::run() - Input TOI  not connected! "<<endl;
+   throw ParmError("PrintRing::run() Input TOI  not connected!");
+ }
+
+ //---------------------------------------------------------
+ int min,max;
+ getRingRange(min,max);
+
+ for(int k=min;k<=max;k++) {
+   totnscount++;
+   cout << k << " " << getRing(0,k);
+   nwrite++;
+ }
+ cout<<"PrintRing::run: end"<<endl;
+}
+
+
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////
+void usage(void);
+void usage(void) {
+  cout<<"tstringpipe  ";
+   cout<<" "<<endl;
+ return;
+}
+
+////////////////////////////////////////////////////////////////
+int main(int narg, char** arg) {
+
+TOIManager* mgr = TOIManager::getManager();
+
+//-- Decodage arguments
+
+SophyaInit();
+InitTim();
+
+//--------------------------------------------------------------------
+try {
+//--------------------------------------------------------------------
   
-
-
-};
-
+//  bool fgsegmented = true;
+//  int wsize = 512;
+//    CGT plombier(fgsegmented,wsize);
+//    plombier.SetDebugLevel(99);
+
+ // FITS reader et writer
+ int nsamples=1024;
+ 
+ double theta = 12.;
+ double phi = 0.;
+ double aperture = 85.;
+ CreateRing cr1(nsamples,theta,phi,aperture);
+ CreateRing cr2(nsamples,theta,phi,aperture);
+ AddRing addring();
+ PrintRing p();
+
+ RingPipe *ring1;
+ RingPipe *ring2;
+ RingPipe *ring3;
+ cr1.addRingOutput("sortie_bolo", ring1);
+ cr2.addRingOutput("sortie_bolo", ring2);
+ addring.addRingInput("entree_bolo_1",ring1);
+ addring.addRingInput("entree_bolo_2",ring2);
+ addring.addRingOutput("sortie_bolo_sum",ring3);
+ p.addRingInput("entree_bolo",ring3);
+
+ cr1.start();
+ cr2.start();
+ addring.start();
+ p.start();
+ 
+//   plombier.Connect(cr1,"sortie_bolo",AddRing,"entree_bolo_1");
+//   plombier.Connect(cr2,"sortie_bolo",AddRing,"entree_bolo_2");
+//   plombier.Connect(AddRing,"sortie_bolo_sum",PrintRing,"entree_bolo");
+//   plombier.Start();
+//   plombier.ListTOIs(cout, 1);
+ cout << "Joining ..." << endl;
+
+ mgr->joinAll();
+ PrtTim("End threads");
+
+//--------------------------------------------------------------------
+} catch (PThrowable & exc) {
+ cout<<"\ntsttoi2ring: Catched Exception \n"<<(string)typeid(exc).name() 
+     <<" - Msg= "<<exc.Msg()<<endl;
+} catch (const std::exception & sex) {
+ cout<<"\ntsttoi2ring: Catched std::exception \n" 
+     <<(string)typeid(sex).name()<<endl; 
+} catch (...) {
+ cout<<"\ntsttoi2ring: some other exception was caught ! "<<endl;
+}
+//--------------------------------------------------------------------
+
+exit(0);
+}