Changeset 1699 in Sophya for trunk/ArchTOIPipe/TestPipes

Timestamp:

Oct 15, 2001, 11:55:09 AM (24 years ago)

Author:

cmv

Message:

intro des toisegmented + constructeur avec char* pour compat cmv 15/10/01

File:

• trunk/ArchTOIPipe/TestPipes/tstdemopipe.cc (modified) (9 diffs)

trunk/ArchTOIPipe/TestPipes/tstdemopipe.cc

@@ -82 +82 @@
 #include "fitstoiwtr.h"
 #include "toimanager.h"
-#include "toiseqbuff.h"
+#include "toisegment.h"
 #include "sophyainit.h"
 
@@ -247 +247 @@
 
  // tuyau bolo10 pour entree processeur
- TOISeqBuffered * bolo10 = new TOISeqBuffered("tuyau_bolo_10",taille);
+ TOISegmented * bolo10 = new TOISegmented("tuyau_bolo_10",taille);
  // connection a la colonne correspondante du lecteur fits
  rfits1.addOutput("boloMuV_10",bolo10);
@@ -257 +257 @@
 
  // tuyau bolo20 pour entree processeur (idem cf au dessus)
- TOISeqBuffered * bolo20 = new TOISeqBuffered("tuyau_bolo_20",taille);
+ TOISegmented * bolo20 = new TOISegmented("tuyau_bolo_20",taille);
  rfits1.addOutput("boloMuV_20",bolo20);
  demo.addInput("entree_bolo_2",bolo20);
@@ -264 +264 @@
 
  // tuyau bolo30 pour entree processeur (idem cf au dessus)
- TOISeqBuffered * bolo30 = new TOISeqBuffered("tuyau_bolo_30",taille);
+ TOISegmented * bolo30 = new TOISegmented("tuyau_bolo_30",taille);
  rfits2.addOutput("boloMuV_30",bolo30);
  demo.addInput("entree_bolo_3",bolo30);
@@ -271 +271 @@
 
  // tuyau bolosum pour sortie processeur
- TOISeqBuffered * bolosum = new TOISeqBuffered("tuyau_bolo_sum",taille);
+ TOISegmented * bolosum = new TOISegmented("tuyau_bolo_sum",taille);
  demo.addOutput("sortie_bolo_sum",bolosum);
  writeflag = true;
@@ -277 +277 @@
 
  // tuyau bolomul pour sortie processeur
- TOISeqBuffered * bolomul = new TOISeqBuffered("tuyau_bolo_mul",taille);
+ TOISegmented * bolomul = new TOISegmented("tuyau_bolo_mul",taille);
  demo.addOutput("sortie_bolo_mul",bolomul);
  writeflag = true;
@@ -289 +289 @@
  cout<<"----- FITSWriterTOI::PrintStatus() : -----"<<endl;
  wfits.PrintStatus(cout);  
- cout<<"----- TOISeqBuffered::PrintStatus() : -----"<<endl;
+ cout<<"----- TOISegmented::PrintStatus() : -----"<<endl;
  bolo10->PrintStatus(cout);  
  bolo20->PrintStatus(cout);  
@@ -306 +306 @@
 
  //  Affichage de l'avancement des TOIProcessors (optionnel)
- ProcSampleCounter<FITSTOIReader> statr(rfits1);
- statr.InfoMessage() = "tstdemopipe/Info rfits1";
- statr.PrintStats();
-
- ProcSampleCounter<FITSTOIWriter> statw(wfits);
- statw.InfoMessage() = "tstdemopipe/Info wfits";
- statw.PrintStats();
-
- ProcSampleCounter<DemoPipe> statp(demo);
- statp.InfoMessage() = "tstdemopipe/Info DemoPipe";
- statp.PrintStats();
+ // ProcSampleCounter<FITSTOIReader> statr(rfits1);
+ // statr.InfoMessage() = "tstdemopipe/Info rfits1";
+ // statr.PrintStats();
+
+ // ProcSampleCounter<FITSTOIWriter> statw(wfits);
+ // statw.InfoMessage() = "tstdemopipe/Info wfits";
+ // statw.PrintStats();
+
+ // ProcSampleCounter<DemoPipe> statp(demo);
+ // statp.InfoMessage() = "tstdemopipe/Info DemoPipe";
+ // statp.PrintStats();
 
  // Gestion de la re-connection des threads
@@ -346 +346 @@
 void crefits(void)
 {
- const int nro = 50000;
+ const int nro = 500000;
  const int sn1 = 100001;
  const int sn2 = 100001+100;