APPLICATIONS/geb2hdt.cxx

// @(#)fROOT/APPLICATIONS:$Name:  $:$Id: geb2hdt.cxx,v 1.24 2007/09/07 14:05:24 Diego_Faso Exp $
// Revision Author: Diego Faso <mailto:faso@to.infn.it>, 2006/07/25
// Author of the first version (macro): Piergiorgio Cerello <mailto:cerello@to.infn.it>, year 2001

// The structure of the Run processing process has been 
// completely changed from fROOT-8 to fROOT-9 (June/December 2006). D. Faso

// the HDT tree is define in this executable only
// TFndRun class handles the event/run processing
// TFndGeb2hdtMan handles monitoring program processing
// TFndGeb2hdtGui handles GUI for TFndGeb2hdtMan
//
// The inter-communication between TFndGeb2hdtMan and TFndGeb2hdtGui
// is realized by means of RQ_OBJECT signals

#include "TRint.h"
#include "TFndGeb2hdtGUI.h"
#include "TFndGeb2hdtMan.h"

TRint *theApp = 0;

TFndGeometry *fingeo;

TFndGeb2hdtMan *geb_run = 0;
TThread *ProdThread = 0;
TThread *GUIThread = 0;

static TCondition *CondProdReady;
static TCondition *CondGuiReady;

TFndGeb2hdtGUI *gebgui = 0;

static Bool_t USING_GEB2HDT_GUI;

//________________________
void *HandleGUI(void *ptr){

  gebgui = new TFndGeb2hdtGUI((TFndGeb2hdtMan *)ptr);
  CondProdReady->Wait();
  gebgui->BuildGUI();
  cout << "GUI built" << endl;
  CondGuiReady->Signal();
  cout << ".................signal emitted" << endl;
  TThread::Join(TThread::GetThread("geb2hdt_prod_thread")->GetId());
  gSystem->Sleep(500);
  delete gebgui;
  return 0;

}

//________________________
void *HandleProducer(void *ptr){
  
  TFndGeb2hdtMan *geb_run = (TFndGeb2hdtMan *)(ptr);
  Int_t TimeLimit = -1; // seconds ("-1" means "unlimited")
  geb_run->SetTimeLimit(TimeLimit);

  geb_run->InitRun(); // debug flags taken from RunConfig.C
  
  if(USING_GEB2HDT_GUI){
    CondProdReady->Signal();
    CondGuiReady->Wait();
  }
  
  cout << "starting event loop......." << endl;
  geb_run->EventLoop();
  geb_run->FinishRun(); // post-processing operations
  
  if(geb_run->GetOnlFlag()) geb_run->HandleConsumerActions(1);  // allow consumer(s)  
  delete geb_run;   
  gROOT->Info("geb2hdt.C (Producer)","All processes completed");

  delete fingeo;
  gApplication->Terminate();
  return 0;
}

//___________________________________________________
//___________________________________________________
//___________________________________________________
//void geb2hdt(TString msqlhost="$MSQL_DB_HOST", TString fpth="$RDT", TString fnam="ONLM00000", Int_t nevts = 100,Int_t gebip=0) {
void geb2hdt(const TString &msqlhost, const TString &fpth, const TString &run_type, const Int_t &run_num,const Int_t &nevts,Int_t gebip) {
  // Online monitor main-macro management:
  //            - GUI support (start/stop/pause/reset) (check if the USE_GEB2HDT_GUI symbol is defined)
  //            - producer->consumer(s) communication support (shared hidden text file)
  //
  // Montecarlo and analysis not supported
  
  CondProdReady = new TCondition(0);
  CondGuiReady = new TCondition(0);
 
  fingeo = new TFndGeometry();
  fingeo->LoadGeometry("$FROOTSYS/geom/fin_spec_geom_2006.root");

  if(!gebip) gebip = FROOT::Ip2Int(gSystem->Getenv("FND_GEBIP"));
  geb_run = new TFndGeb2hdtMan(msqlhost,fpth,run_type,run_num,nevts,gebip);
  ProdThread = new TThread("geb2hdt_prod_thread",HandleProducer,(void *)geb_run);
  
  geb_run->ReadConfFile(); // --- needed for getting GUI-mode and debug flags
  USING_GEB2HDT_GUI = geb_run->UsingGUI();
  gROOT->Info("geb2hdt","USING_GEB2HDT_GUI = %d",USING_GEB2HDT_GUI);

  ProdThread->Run();
  
  if(USING_GEB2HDT_GUI){
    GUIThread = new TThread("gui_thread",HandleGUI,(void *)geb_run);
    GUIThread->Run();
  }
}

// -----------------------------------------
void PrintUsage(){
  cout << endl << " -----------------------------------" << endl;
  cout << " --- geb2hdt usage:" << endl;
  cout << " - argument 1: database-host." << endl;
  cout << " - argument 2: path to raw-data." << endl;
  cout << " - argument 3: requested run type." << endl;
  cout << " - argument 4: requested run number." << endl;
  cout << " - argument 5: requested number of events." << endl;
  cout << " - argument 6: requested Geb-IP (may use defaults)." << endl << endl;
  cout << " EXAMPLE: geb2hdt $MSQL_DB_HOST $RDT FINU 4372 10000000" << endl; 
  cout << " -----------------------------------" << endl;
}

//_____________________________
int main(int argc, char **argv)
{
  
  cout << "geb2hdt executable started: number of arguments: " << argc << endl;

  if(argc < 2){
    PrintUsage();
    return 0;
  }
  
  TString str1 = "$MSQL_DB_HOST";
  if(argc > 1) str1 = TString(argv[1]);

  TString str2 = "$RDT";
  if(argc > 2) str2 = TString(argv[2]);

  TString str3 = "ONLM";
  if(argc > 3) str3 = TString(argv[3]);

  Int_t arg_4 = 0;
  if(argc > 4) arg_4 = atoi(argv[4]);

  Int_t nevts = std::numeric_limits<Int_t>::max();
  if(argc > 5) nevts = atoi(argv[5]);

  Int_t gebip = 0;
  if(argc > 6) gebip = atoi(argv[6]);
  
  cout << "str1: \"" << str1
       << "\"; str2: \"" << str2 
       << "\"; str3: \"" << str3
       << "\"; arg_4: \"" << arg_4
       << "\"," << nevts << "; " << gebip << endl;
  
  argc = 0;
  for(Int_t ar=0;ar<argc;ar++)argv[ar] = '\0';

  for(Int_t ar=0;ar<argc;ar++) cout << "arg[" << ar << "]: \"" << argv[ar] << "\"." << endl;
  cout << endl;
  
  cout << " -------------> \"" << *(argv+2) << "\"" << endl;
  theApp = new TRint("geb2hdt run application", &argc,argv,NULL,0,1);

  theApp->ProcessFile("$FROOTSYS/mcr_called/frootlogon.C");
  theApp->SetPrompt("# froot > ");
  
  geb2hdt(str1,str2,str3,arg_4,nevts,gebip);

  theApp->Run();
  theApp->Terminate(0);
  delete theApp;
  return 0;
}

// Old workaround to skip directory arguments
// TRint takes the first 2 arguments as work-directory:
// then "msqlhost" and "fpth" will be skipped
//  TRint *theApp = new TRint("geb2hdt run",&argc-2,argv+2,NULL,0,1);

---