/* $Id$ */
#include <TObject.h>
+#include <TSystem.h>
#include <TString.h>
-#include <TFolder.h>
-#include <TFile.h>
-#include <TTree.h>
#include <TObjArray.h>
-#include <TServerSocket.h>
-#include <TTimer.h>
-#include <TGrid.h>
-#include "AliRunLoader.h"
-#include "AliRawReader.h"
-#include "AliTPCParam.h"
-#include "AliITSgeom.h"
+
+class AliRawReader;
+class AliTPCParam;
+class AliITSgeom;
+class AliRunLoader;
+class TFile;
+class TGrid;
+class TTimer;
+class TServerSocket;
+class TFolder;
+class TTree;
#ifdef ALI_HLT
-#include "AliLevel3.h"
+class AliLevel3;
+class AliL3Hough;
#endif
class AliMonitorProcess : public TObject {
public:
- AliMonitorProcess(const char* alienDir,
+ AliMonitorProcess(const char* alienHost,
+ const char* alienDir,
const char* fileNameGalice = "galice.root");
+ AliMonitorProcess(const AliMonitorProcess& process);
+ AliMonitorProcess& operator = (const AliMonitorProcess& process);
virtual ~AliMonitorProcess();
static const char* GetRevision();
void ProcessFile(const char* fileName);
- UInt_t GetRunNumber() {return fRunNumber;};
- UInt_t GetEventPeriodNumber();
- UInt_t GetEventOrbitNumber();
- UInt_t GetEventBunchNumber();
+ UInt_t GetRunNumber() const {return fRunNumber;};
+ UInt_t GetEventPeriodNumber() const;
+ UInt_t GetEventOrbitNumber() const;
+ UInt_t GetEventBunchNumber() const;
enum EStatus {kStopped, kWaiting, kReading, kRecTPC, kRecITS, kRecV0s,
kRecHLT, kFilling, kUpdating, kWriting, kResetting,
kConnecting, kBroadcasting};
- EStatus GetStatus() {return fStatus;};
- Bool_t WillStop() {return fStopping;};
- Bool_t IsStopped() {return (fStatus == kStopped);};
-
- Int_t GetNumberOfEvents() {return fNEvents;};
- Int_t GetNumberOfClients() {return fSockets.GetEntriesFast();};
+ EStatus GetStatus() const
+ {gSystem->ProcessEvents(); return fStatus;};
+ Bool_t WillStop() const {return fStopping;};
+ Bool_t IsStopped() const {return (fStatus == kStopped);};
+
+ Int_t GetNumberOfEvents() const {return fNEvents;};
+ Int_t GetNumberOfClients() const
+ {return fSockets.GetEntriesFast();};
TObjArray* GetListOfClients() {return &fSockets;};
- Int_t GetNEventsMin() {return fNEventsMin;};
+ Int_t GetNEventsMin() const {return fNEventsMin;};
void SetNEventsMin(Int_t nEventsMin) {fNEventsMin = nEventsMin;};
void SetWriteHistoList(Bool_t writeHistoList = kTRUE)
{fWriteHistoList = writeHistoList;};
-
- static const Int_t kgPort;
+ static Int_t GetPort() {return fgkPort;};
+
private:
Bool_t CheckForNewFile();
Bool_t ProcessFile();
- Int_t GetNumberOfEvents(const char* fileName);
+ Int_t GetNumberOfEvents(const char* fileName) const;
Bool_t ReconstructTPC(AliRawReader* rawReader);
Bool_t ReconstructITS(AliRawReader* rawReader);
Bool_t ReconstructV0s();
#ifdef ALI_HLT
void CreateHLT(const char* fileName);
+ void CreateHLTHough(const char* fileName);
#endif
Bool_t ReconstructHLT(Int_t iEvent);
+ Bool_t ReconstructHLTHough(Int_t iEvent);
Bool_t WriteHistos();
void StartNewRun();
void CheckForConnections();
- void BroadcastHistos();
-
- TGrid* fGrid;
- AliRunLoader* fRunLoader;
- AliTPCParam* fTPCParam;
- AliITSgeom* fITSgeom;
- TString fLogicalFileName;
- TString fFileName;
+ void BroadcastHistos(TSocket* toSocket = NULL);
+ void SetStatus(EStatus status);
+
+ static const Int_t fgkPort; // port number for client connections
+
+ TGrid* fGrid; // pointer to AliEn
+ TString fAlienDir; // name of alien directory
+ AliRunLoader* fRunLoader; // the current run loader
+ AliTPCParam* fTPCParam; // TPC parameters
+ AliITSgeom* fITSgeom; // ITS parameters
+ TString fLogicalFileName; // logical AliEn file name
+ TString fFileName; // physical file name
#ifdef ALI_HLT
- AliLevel3* fHLT;
+ AliLevel3* fHLT; // the HLT tracker
+ AliL3Hough* fHLTHough; // the HLT hough transformer
#endif
- UInt_t fRunNumber;
- UInt_t fSubRunNumber;
- UInt_t fEventNumber[2];
- Int_t fNEvents;
- Int_t fNEventsMin;
- Bool_t fWriteHistoList;
-
- TFolder* fTopFolder;
- TObjArray fMonitors;
- TFile* fFile;
- TTree* fTree;
-
- TServerSocket* fServerSocket;
- TObjArray fSockets;
- TSocket* fDisplaySocket;
-
- EStatus fStatus;
- Bool_t fStopping;
+ UInt_t fRunNumber; // current run number
+ UInt_t fSubRunNumber; // current part (=resets per run)
+ UInt_t fEventNumber[2]; // current event number
+ Int_t fNEvents; // total number of monitored events
+ Int_t fNEventsMin; // threshold for writing
+ Bool_t fWriteHistoList; // write event histos or not
+
+ TFolder* fTopFolder; // folder with histos
+ TObjArray fMonitors; // array of monitor objects
+ TFile* fFile; // file with tree
+ TTree* fTree; // monitor tree
+
+ TServerSocket* fServerSocket; // socket for client connections
+ TObjArray fSockets; // array of client sockets
+ TSocket* fDisplaySocket; // socket for an event display
+
+ EStatus fStatus; // current status
+ Bool_t fStopping; // stop of process requested or not
+
+ class AliMonitorInterruptHandler : public TSignalHandler {
+ public:
+ AliMonitorInterruptHandler(AliMonitorProcess* process);
+ AliMonitorInterruptHandler(const AliMonitorInterruptHandler& handler);
+ AliMonitorInterruptHandler& operator =
+ (const AliMonitorInterruptHandler& handler);
+ virtual Bool_t Notify();
+ private:
+ AliMonitorProcess* fProcess; // process to notify
+ };
+
+ AliMonitorInterruptHandler* fInterruptHandler; // interrupt handler
ClassDef(AliMonitorProcess, 0) // class for performing the monitoring
};
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff