mcr/debug/DebugRawRead.C

#include "Riostream.h"
#include "TSystem.h"
#include "TApplication.h"
#include "TROOT.h"
#include "TInterpreter.h"
#include "TThread.h"
#include "TString.h"

#include "TFndRun.h"


//void DebugRawRead(Char_t *msql_host = "$MSQL_DB_HOST",Char_t *data_path = "$RDT",Char_t *fFileName = "COSM05398",Int_t nevents=10000){

//void DebugRawRead(const TString &msql_host="$MSQL_DB_HOST",const TString &data_path="$RDT",const TString &run_type="ONLM",const Int_t &cur_run = -1,Int_t nevents=10000){

void DebugRawRead(const TString &msql_host="$MSQL_DB_HOST",const TString &data_path="$RDT",const TString &run_type="FINU",const Int_t &cur_run = 4106,Int_t nevents=10000){

  //void DebugRawRead(const TString &msql_host="$MSQL_DB_HOST",const TString &data_path="$RDT",const TString &run_type="COSM",const Int_t &cur_run = 5398,Int_t nevents=10000){

#ifdef __CINT__
  cout << "This script can only be executed via ACliC:" << endl;
  gApplication->Terminate();
  return;
#endif

  // fFileName = "ONLM00000";
  // fFileName = "COSM04898"; // break due to DAQ-write failure
  // fFileName = "COSM05013"; // Tofino Night (Ped-subtr:OFF; Zero-suppr:OFF)
  // fFileName = "COSM04899"; // should not break
  // fFileName = "PEDE01161"; // all TOF TDCs active

  // digits: STB = 4, LMD = 3, SIL = 2, TOF = 1, GTS = 0
  //Int_t debug_raw = 0x00000; // (NONE)
  //Int_t debug_raw = 0x00003; // (GTS)
  //Int_t debug_raw = 0x00030; // (TOF)
  //  Int_t debug_raw = 0x00100; // (SIL)
  Int_t debug_raw = 0x03000; // (LMD)
  //  Int_t debug_raw = 0x30000; // (STB)
  //Int_t debug_raw = 0x33333; // (ALL)
  
  TFndRun *fRun = new TFndRun();
  fRun->ReadConfigFile();
  fRun->SetDBHost(msql_host);
  fRun->SetDataPath(data_path);
  fRun->SetMaxNumberOfEvents(nevents);

  fRun->SetDebugRawEv(debug_raw);

  // --- run initialization
  cout << "***********************************************" << fRun->GetDebug() << endl;
  Int_t in_val = fRun->InitNewRun(run_type,cur_run);
  if (in_val == -3) FROOT::TerminateFroot(0,TString("wrong argument received as \"run-type\" (\""+run_type)+"\").");
  if (in_val) gROOT->Warning("DebugRawRead","in_val = %d",in_val);
  cout << "***********************************************" << endl;

  // ---
  //   TFndRun *fRun = new TFndRun(msql_host,data_path,fFileName,nevents,fGebIp);
  //   fRun->SetDebugLevel(debug_froot);
  //   fRun->SetDebugRawEv(debug_raw);
  //  fRun->ConnectToDB(msql_host); 
  Int_t fOnlFlg = fRun->Onlflg();
  Printf("New run initialized: online flag is: %d",fOnlFlg);

  cerr << endl << endl << endl;
  cerr << "Starting the froot \"event read\" debugger" << endl;
  cerr << "RunType: " << fndrun->GetRunType() << endl;
  cerr << "RunNumber: " << fndrun->GetRunNumber() << endl;
  cerr << " (Note: Event numbering starts from \'1\')" << endl;
  cerr << " - Insert the number of events to be processed or just type \"q\" to exit" << endl;
  cerr << "   (Note: a carriage-return is required)" << endl;
  
  TString inp;
  Int_t step = 0; // number of events to be processed in the following step
  Int_t cur_evt_limit = -1;  
  Int_t exit_val = 0;  

  while(fRun->GetNofProcessedEvents() > -1){
    gSystem->Sleep(100);
    if(fRun->GetNofProcessedEvents() >= cur_evt_limit){
      if(fRun->GetNofProcessedEvents()>0){
        cerr << endl;
        cerr << endl;
        cerr << endl;
        gROOT->Info("DebugRawRead"," --- --- Last processed event was \"%d\" --- ---",fRun->GetNofProcessedEvents());
      }
      gROOT->Info("DebugRawRead"," --- --- Insert the number of events to be processed now --- ---");
      cin >> inp;
      if(!inp.CompareTo("q")) break;
      step = inp.Atoi();
      if(!step){
        gROOT->Info("DebugRawRead","Warning: \"%d\" is not a valid entry.",step);
        continue;
      }
      gROOT->Info("DebugRawRead"," ****************** Next step: %d number of events ******************",step);
      cur_evt_limit=fRun->GetNofProcessedEvents() + step;
    }
    
    if(debug_raw){
      gROOT->Info("DebugRawRead"," ****************** Now processing event %d",fRun->GetNofProcessedEvents()+1);
      Printf(" ****************** Now processing event %d",fRun->GetNofProcessedEvents()+1);
    }
    else if(fRun->GetNofProcessedEvents() % 50 == 0) gROOT->Info("DebugRawRead"," ****************** Now processing event %d",fRun->GetNofProcessedEvents());
    
    exit_val = fRun->GetNextEvent(kTRUE);
    
    if(exit_val!= 0){
      fRun->ClearEvent();
      break;
    }
    fRun->ClearEvent(); 
  }
  fRun->FinishRun(kTRUE);
  
  Printf("deleting current fndrun...");
  delete fRun;
  Printf("...done. Now exiting...bye bye ;)");
  gROOT->ProcessLine(".q");
}

---