Changeset 2192 in Sophya for trunk/ArchTOIPipe/TestPipes/toimerge.cc

Timestamp:

Sep 13, 2002, 4:51:53 PM (23 years ago)

Author:

cmv

Message:

intermediaire cmv echanch EA 13/9/02

File:

• trunk/ArchTOIPipe/TestPipes/toimerge.cc (modified) (6 diffs)

trunk/ArchTOIPipe/TestPipes/toimerge.cc

@@ -8 +8 @@
 #include "toi.h"
 #include "toimanager.h"
-#include "cgt.h"
 #include "fitstoirdr.h"
 #include "fitstoiwtr.h"
@@ -99 +98 @@
  // Set Pipe
  TOIManager* mgr = TOIManager::getManager();
- if(gsetstart) mgr->setRequestedSample(sdeb,sfin);
+ //if(gsetstart) mgr->setRequestedSample(sdeb,sfin);
+ if(fgsegmented) mgr->selectTOISegmented(width);
+   else          mgr->selectTOISeqBuffered(width);
 
  // Create FITS writer
@@ -105 +106 @@
  string cmd = "rm -f "; cmd += namefitsout; system(cmd.c_str());
  FITSTOIWriter wfits(namefitsout);
+ //if(gsetstart) wfits.setRequestedSample(sdeb,sfin);
 
  // Create FITS reader table
@@ -111 +113 @@
  for(int i=0;i<ntoi;i++) rfits[i]=NULL;
 
- // Create FITS reader and connect with CGT
- cout<<"> Connecting Processors through plombier ... "<<endl;
- CGT plombier(fgsegmented,width);
- //plombier.SetDebugLevel(lp);
+ // Create FITS reader and connect
+ cout<<"> Connecting Processors ... "<<endl;
  for(int i=0;i<ntoi;i++) {
    int nread = TOI_Merge[i].FileNameIn.size();
@@ -127 +127 @@
        else   rfits[i]->addFile(fname);
    }
-   plombier.Connect(*(rfits[i]),colin,wfits,colout,"",width,withflag);
+   mgr->connect(*(rfits[i]),colin,wfits,colout,"",width,withflag);
  }
 
  // Start Pipe
- cout<<"> Plombier status before start"<<endl;
- cout<<plombier;
  PrtTim("starting processors");
- plombier.Start();
+ mgr->startAll();
 
  // ------------------- Impression continu de stat ------------------------ 
@@ -146 +144 @@
 
  // End Pipe
- mgr->joinAll();
+ mgr->waitForAll();
  PrtTim("End threads");