mcr_called/geb2hdt.C

// @(#) 05/06/2006 - Diego Faso
// Author: Piergiorgio Cerello <mailto:cerello@to.infn.it>, Diego Faso <mailto:faso@to.infn.it>

#define USE_GEB2HDT_GUI

#ifdef USE_GEB2HDT_GUI
#include "TFndGeb2hdtGUI.h"
#endif
#include "TFndGeb2hdtMan.h"

#ifdef USE_GEB2HDT_GUI
static TCondition *CondProdReady;
static TCondition *CondGuiReady;
#endif

//________________________
#ifdef USE_GEB2HDT_GUI
void *HandleGUI(void *ptr){

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

}
#endif

//________________________
void *HandleProducer(void *ptr){
  
  TFndGeb2hdtMan *geb_run = (TFndGeb2hdtMan *)(ptr);
  Int_t TimeLimit = -1; // seconds ("-1" means "unlimited")
  Int_t UpdateEvGap = 100; // update interval (number of events)
  
  geb_run->SetUpdateEvGap(UpdateEvGap);
  geb_run->SetTimeLimit(TimeLimit);
  
  geb_run->InitRun();
  
  if(geb_run->GetOnlFlag()){
    geb_run->HandleConsumerActions(0); // inhibit consumer(s) actions
    // ---
    Printf("... removing old shared memories...");
    gSystem->Exec("rm -f $FND_SHR/*.map");
    Printf("...done.");
    geb_run->TouchMapFiles();
    geb_run->HandleConsumerActions(1); // allow consumer(s) actions
  }
  
#ifdef USE_GEB2HDT_GUI
  CondProdReady->Signal();
  CondGuiReady->Wait();
#endif
  Printf("starting event loop.......");
  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");
  TFndGeb2hdtMan::KillYourself(); // must call the static method.
  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(TString msqlhost="$MSQL_DB_HOST", TString fpth="$RDT", TString fnam="FINU02181", Int_t nevts = 1000,Int_t gebip=0) {
  // 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

#ifdef USE_GEB2HDT_GUI
  CondProdReady = new TCondition(0);
  CondGuiReady = new TCondition(0);
#endif

  if(!gebip) gebip = FROOT::Ip2Int(gSystem->Getenv("FND_GEBIP"));
  TFndGeb2hdtMan *geb_run = new TFndGeb2hdtMan(msqlhost,fpth,fnam,nevts,gebip);
  TThread *ProdThread = new TThread("geb2hdt_prod_thread",HandleProducer,(void *)geb_run);
  ProdThread->Run();

#ifdef USE_GEB2HDT_GUI
  TThread *GUIThread = new TThread("gui_thread",HandleGUI,(void *)geb_run);
  GUIThread->Run();
#endif
}

---