STEER/TFndGeb2hdtMan.h

// @(#)fROOT/STEER:$Name:  $:$Id: TFndGeb2hdtMan.h,v 1.24 2007/09/06 16:21:56 Diego_Faso Exp $
// Author: Diego Faso <mailto:faso@to.infn.it>, 2006/06/05

#ifndef FROOT_TFndGeb2hdtMan
#define FROOT_TFndGeb2hdtMan

#ifndef ROOT_Gtypes
#include "Gtypes.h"
#endif

// --- root
//#include <fstream>
#include "TDatime.h"
#include "TROOT.h"
#include "TSystem.h"
#include "TGClient.h"
#include "TThread.h"
#include "TApplication.h"
#include "TTree.h"

#include <RQ_OBJECT.h>

// --- froot
#include "TFndRun.h"
#include "TFndGtsMon.h"
#include "TFndTofMon.h"
#include "TFndStbMon.h"
#include "TFndSilMon.h"
#include "TFndLmdMon.h"

class TFndGeb2hdtMan: public TObject {
  RQ_OBJECT("TFndGeb2hdtMan")
  
 protected:

  TFndRun *fRun;
  Int_t fDebug; // Taken from RunConfig
  Int_t fDebugRaw; // Taken from RunConfig

  Bool_t fUsingGUI; // true [default] if GUI (TFndGeb2hdtGUI) must be used
   
  TString fMsqlHost;
  TString fDataPath;
  TString fFileName;
  Int_t   fNevents;
  Int_t   fGebIp;
  
  Int_t fStartTime;
  Int_t fStopTime;
  
  Int_t fOnlFlg;
  TString fConsumControlFile; // path+name of the shared text file for producer->consumer(s) control
  
  Float_t fkSCALE;
  Int_t fTimeLimit;     // -1 (default) means "unlimited"
  Bool_t fTimedOut;     // TRUE if timed out
  Int_t fUpdateEvGap;   // Number of events for shared memories update
  Bool_t fUpdatingProd; // true while updating producers  

  Int_t fCurEv; // current event (inside the loop)
  Int_t fLastUpdEv; // event corresponding to the last update
  Int_t fRate;  // producer rate (produced events/s)
  Int_t fExitVal; // stop condition (0:don't stop ; 1: end of run; 2: time-out)
  Bool_t fManStop;
  Bool_t fPaused;

  TFile *fHdtRootFile; // root-file (in $FND_HDR) with the hits tree

  TThread *fMonSaveThread;
 
  Bool_t fConfFileRead; // check on RunConfig.C reading

  TTree *fHdtTree; // tree with HDT events
  Bool_t fMustSaveHdt; // used by geb2hdt

private:
  Int_t PrintInfo(Int_t &rate1,Int_t &rate2); // also checks if producer must be updated
  void StartMonitors();
  void FlushHdtTree(); // used in online-mode only

 public:
  TFndGeb2hdtMan();
/*   TFndGeb2hdtMan(TString msqlhost,TString fpth,TString fnam,Int_t nevts,Int_t gebip); */
  TFndGeb2hdtMan(const TString &msqlhost,const TString &fpth,const TString &run_type,const Int_t &run_num,const Int_t &nevts,Int_t gebip=0);
  ~TFndGeb2hdtMan();
  
  Bool_t UsingGUI() { return fUsingGUI; }
  void ReadConfFile();  

  void UpdateProducers(); // Update producer shared files in a new thread

  Int_t GetOnlFlag() { return fOnlFlg; }

  Int_t GetCurrentEvent() { return fCurEv; }
  Int_t GetUpdateEvGap()  { return fUpdateEvGap; }
  Int_t GetRate() { return fRate; }

  void InitRun();
  void EventLoop();
  void FinishRun();

  void CreateHdtFile(); // create new hdt.root file (in $FND_HDT) depending on current run name/number
  void WriteHdtFile();

  void SetUpdateEvGap(Int_t ev)      { fUpdateEvGap = ev; }
  void SetTimeLimit(Int_t TimeLimit) { fTimeLimit = TimeLimit;}

  void ResetGts();
  void ResetTof();
  void ResetSil();
  void ResetLmd();
  void ResetStb();

  // --- producer->consumer(s) communication (support for NFS file sharing)
  Int_t TouchMapFiles();
  void HandleConsumerActions(Bool_t allow);
  
  void PauseProducer();
  void StopProducer();
  static void KillYourself();

  void RealTimeInfo(Int_t Info_id,TString method,TString info);
  void SendRealTimeInfo(Int_t Info_id); // required by the related GUI (if used)

  static void *SavingThread(void *arg); // Update producer outputs within a dedicate thread
  void StartSavingThread();
  void StopSavingThread();

  
  ClassDef(TFndGeb2hdtMan,1)
};
    
#endif // FROOT_TFndGeb2hdtMan

---