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

//----------------------------------------------------------------
// 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), vpaq_(memgr.NbFibres()), vpchk_(memgr.NbFibres()), vfgok_(memgr.NbFibres()), 
    curfc_(memgr.NbFibres())
{
  stop_ = false;
  for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)  {
    vpaq_[fib]=BRPaquet(NULL,memgr_.PaqSize());
    vpchk_[fib]=BRPaqChecker(true,0); 
    vfgok_[fib]=true;
    curfc_[fib]=0;
  }
  fcfirst_=ttfirst_=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;
    /*
    for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)  vpchk_[fib].Print();
    cout << " ------------------------------------ " << 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;
  /*    Exemple de code test 
  if ( totprocnpaq_ % 1000 == 0 ) {
    cout << " BRVisibilityCalculator::Process() " << totprocnpaq_ << " FrameCnt=" ;
    for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)   
      cout << curfc_[fib] << "," ;
    cout << endl;
    cout << " TimeTag : " ;
    for(size_t fib=0; fib<(size_t)memgr_.NbFibres(); fib++)   
      cout << vpaq_[fib].TimeTag()/125000000 << "," ;
      cout << "   seconds" << endl;
  }

   */
}