Changeset 3938 in Sophya for trunk/AddOn/TAcq/specmfib.cc


Ignore:
Timestamp:
Jan 13, 2011, 11:42:21 AM (15 years ago)
Author:
ansari
Message:

modification provisoire pour lecture fichiers visibilites 2010, Reza 13/01/2011

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/AddOn/TAcq/specmfib.cc

    r3905 r3938  
    5050    if (rc) return rc;
    5151    par.Print(cout);
    52     if ((par.action_!="cube3d")&&(par.action_!="mspec")) {
    53       cout << " !!! specmfib.cc  BAD action = " << par.action_ << " possible values: mspec,cube3d" << endl;
     52    if ((par.action_!="cube3d")&&(par.action_!="mspec")&&(par.action_!="bproc")) {
     53      cout << " !!! specmfib.cc  BAD action = " << par.action_ << " possible values: mspec,cube3d,bproc" << endl;
    5454      return 5;
    5555    }   
     
    7474    procms.SetVarianceLimits(par.vmin_, par.vmax_);
    7575    if (par.gainfile_.length()>0) procms.ReadGainFitsFile(par.gainfile_);
     76    procms.SetPrintLevel(par.prtlevel_,par.prtmodulo_);
     77    // Il faut appeler procms.DefineDataTable() si on veut remplir le DataTable
    7678
    7779    BRFFTCalculator procfft(mmgr, par.fgsinglechannel_);
     
    8385    FitsCubeWriter wrt(mmgr, par.outpath_, par.nbloc_);
    8486
     87    BRBaseProcessor* bproc_p=NULL;
     88    if (par.action_=="bproc") {
     89       bproc_p = new BRBaseProcessor(mmgr);
     90       bproc_p->SetPrintLevel(par.prtlevel_,par.prtmodulo_);
     91       if (!par.fgdatafft_)  bproc_p->SetMemZAction(MemZA_ProcB);
     92    }
     93
    8594    cout << " specmfib: Starting threads (reader meanSpecCalculator ...) ... " << endl;
    8695    reader.start();
     
    8897    else {  // Calcul spectre moyenne
    8998      if (!par.fgdatafft_)  procfft.start();
    90       procms.start();
     99      if (par.action_=="bproc")  bproc_p->start();
     100      else procms.start();
    91101    }
    92102    usleep(200000);
     
    95105    else {
    96106      if (!par.fgdatafft_)  procfft.join();
    97       procms.join();
     107      if (par.action_=="bproc")  bproc_p->join();
     108      else procms.join();
    98109    }
    99110    mmgr.Print(cout);
     111    if (bproc_p) delete bproc_p;
    100112    cout << resu ;
    101113  }
Note: See TracChangeset for help on using the changeset viewer.