source: Sophya/trunk/AddOn/TAcq/brbaseproc.cc@ 3684

//----------------------------------------------------------------
// Projet BAORadio - (C) LAL/IRFU  2008-2010
// Classes de base pour les threads de traitememt donnees BAORadio 
//----------------------------------------------------------------

#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fstream>
#include "brbaseproc.h"


using namespace SOPHYA;
//---------------------------------------------------------------------
// Classe de traitement - calcul de visibilite pour n fibres 
//---------------------------------------------------------------------

/* --Methode-- */
BRBaseProcessor::BRBaseProcessor(RAcqMemZoneMgr& memgr)
  : memgr_(memgr) 
{
  for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)  {
    vpaq_.push_back(BRPaquet(NULL,memgr_.PaqSize()));
    vpchk_.push_back(BRPaqChecker(true,0)); 
    curfc_.push_back(0);
  }
  totprocnpaq_=0;
}

/* --Methode-- */
void BRBaseProcessor::run()
{
  setRC(1);     
  int rc=0;
  try {
    cout << " BRBaseProcessor::run() - Starting " << " NFibers=" << memgr_.NbFibres() 
         << " NChan=" << 2*memgr_.NbFibres() << endl;   

    size_t paqsz=memgr_.PaqSize();
    vector<Byte*> fbuff;
    for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)  fbuff.push_back(NULL);
    bool fgrun=true;
    while (fgrun) {
      if (stop_) break;
      if (memgr_.GetRunState() == MemZR_Stopped) break;
      int mid = memgr_.FindMemZoneId(MemZA_ProcA);
      Byte* buffg = memgr_.GetMemZone(mid);
      if (buffg == NULL) {
        cout << "BRBaseProcessor::run()/ERROR memgr.GetMemZone(" << mid << ") -> NULL" << endl;
        setRC(7);      fgrun=false;             
        break;  
      }
      for(size_t jp=0; jp<memgr_.NbPaquets(); jp++) {   // boucle sur les paquets d'une zone  
        fgokallfibers_=true;
        for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++) {
          fbuff[fib] = memgr_.GetMemZone(mid,fib);
          if (fbuff[fib] == NULL) { // cela ne devrait pas arriver 
            cout << "BRBaseProcessor::run()/ERROR memgr.GetMemZone(" << mid << "," << fib << ") -> NULL" << endl;
            setRC(9);     fgrun=false;          
            break;
          }
          vpaq_[fib].Set(fbuff[fib]+jp*paqsz);
          vfgok_[fib] = vpchk_[fib].Check(vpaq_[fib],curfc_[fib]);
          if (!vfgok_[fib])  fgokallfibers_=false;
        }
        //--- Traitement 
        int rcp = Process();
        totprocnpaq_++;
        if (rcp != 0)   { fgrun=false; break; }
      }  // Fin de boucle sur les paquets 
      memgr_.FreeMemZone(mid, MemZS_ProcA);
    } // Fin de boucle sur les zones a traiter 
    //------------------------------------
    cout << " --------- END BRBaseProcessor::run() , TotNbProcPaq=" << totprocnpaq_ << endl;
  }
  catch (std::exception& exc) {
    cout << " BRBaseProcessor::run()/catched std::exception " << exc.what() << endl;
    setRC(98);  
    return; 
  }
  catch(...) {
    cout << " BRBaseProcessor::run()/catched unknown ... exception " << endl;
    setRC(99);  
    return; 
  }

}


/* --Methode-- */
int BRBaseProcessor::Process()
{
  // la methode par defaut ne fait rien 
  // if (fgokallfibers_) { faire le traitement }
  return 0;
}