1 #ifndef ALIMONITORPROCESS_H
2 #define ALIMONITORPROCESS_H
3 /* Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
4 * See cxx source for full Copyright notice */
16 #include <TObjArray.h>
30 class AliMonitorProcess : public TObject {
32 AliMonitorProcess(const char* alienHost,
34 const char* selection = "ALL",
35 const char* fileNameGalice = "galice.root");
36 virtual ~AliMonitorProcess();
38 static const char* GetRevision();
44 void ProcessFile(const char* fileName);
46 UInt_t GetRunNumber() const {return fRunNumber;};
47 UInt_t GetEventPeriodNumber() const;
48 UInt_t GetEventOrbitNumber() const;
49 UInt_t GetEventBunchNumber() const;
51 enum EStatus {kStopped, kWaiting, kReading, kRecTPC, kRecITS, kRecV0s,
52 kRecHLT, kFilling, kUpdating, kWriting, kResetting,
53 kConnecting, kBroadcasting};
54 EStatus GetStatus() const
55 {gSystem->ProcessEvents(); return fStatus;};
56 Bool_t WillStop() const {return fStopping;};
57 Bool_t IsStopped() const {return (fStatus == kStopped);};
59 Int_t GetNumberOfEvents() const {return fNEvents;};
60 Int_t GetNumberOfClients() const
61 {return fSockets.GetEntriesFast();};
62 TObjArray* GetListOfClients() {return &fSockets;};
63 Int_t GetNEventsMin() const {return fNEventsMin;};
64 void SetNEventsMin(Int_t nEventsMin) {fNEventsMin = nEventsMin;};
65 void SetWriteHistoList(Bool_t writeHistoList = kTRUE)
66 {fWriteHistoList = writeHistoList;};
68 static Int_t GetPort() {return fgkPort;};
71 AliMonitorProcess(const AliMonitorProcess& process);
72 AliMonitorProcess& operator = (const AliMonitorProcess& process);
74 Bool_t CheckForNewFile();
76 Int_t GetNumberOfEvents(const char* fileName) const;
77 Bool_t ReconstructTPC(AliRawReader* rawReader, AliESD* esd);
78 Bool_t ReconstructITS(AliRawReader* rawReader, AliESD* esd);
79 Bool_t ReconstructV0s(AliESD* esd);
80 void CreateHLT(const char* fileName);
81 void CreateHLTHough(const char* fileName);
82 Bool_t ReconstructHLT(Int_t iEvent);
83 Bool_t ReconstructHLTHough(Int_t iEvent);
88 void CheckForConnections();
89 void BroadcastHistos(TSocket* toSocket = NULL);
90 void SetStatus(EStatus status);
91 Bool_t IsSelected(const char* name) const
92 {return (fSelection.Contains(name) || fSelection.Contains("ALL"));}
94 static const Int_t fgkPort; // port number for client connections
96 TString fSelection; // selection of monitor histograms
97 TGrid* fGrid; // pointer to AliEn
98 TString fAlienDir; // name of alien directory
99 AliRunLoader* fRunLoader; // the current run loader
100 AliTPCParam* fTPCParam; // TPC parameters
101 AliITSgeom* fITSgeom; // ITS parameters
102 TString fLogicalFileName; // logical AliEn file name
103 TString fFileName; // physical file name
104 AliLevel3* fHLT; // the HLT tracker
105 AliHLTHough* fHLTHough; // the HLT hough transformer
107 UInt_t fRunNumber; // current run number
108 UInt_t fSubRunNumber; // current part (=resets per run)
109 UInt_t fEventNumber[2]; // current event number
110 Int_t fNEvents; // total number of monitored events
111 Int_t fNEventsMin; // threshold for writing
112 Bool_t fWriteHistoList; // write event histos or not
114 TFolder* fTopFolder; // folder with histos
115 TObjArray fMonitors; // array of monitor objects
116 TFile* fFile; // file with tree
117 TTree* fTree; // monitor tree
119 TServerSocket* fServerSocket; // socket for client connections
120 TObjArray fSockets; // array of client sockets
121 TSocket* fDisplaySocket; // socket for an event display
123 EStatus fStatus; // current status
124 Bool_t fStopping; // stop of process requested or not
126 class AliMonitorInterruptHandler : public TSignalHandler {
128 AliMonitorInterruptHandler(AliMonitorProcess* process);
129 virtual ~AliMonitorInterruptHandler() {};
130 virtual Bool_t Notify();
132 AliMonitorProcess* fProcess; // process to notify
134 AliMonitorInterruptHandler(const AliMonitorInterruptHandler& handler); // Not implemented
135 AliMonitorInterruptHandler& operator =
136 (const AliMonitorInterruptHandler& handler); // Not implemented
140 AliMonitorInterruptHandler* fInterruptHandler; // interrupt handler
142 ClassDef(AliMonitorProcess, 0) // class for performing the monitoring