fix coding violation
[u/mrichter/AliRoot.git] / EVE / EveHLT / AliEveEventBuffer.h
1 // $Id$
2
3 /* This file is property of and copyright by the ALICE HLT Project        * 
4  * ALICE Experiment at CERN, All rights reserved.                         *
5  * See cxx source for full Copyright notice     
6  */
7
8 /** @file   AliEveEventBuffer.h
9     @author Svein Lindal
10     @date
11     @brief  Event buffer for HOMER
12 */
13
14
15 #ifndef ALIEVEEVENTBUFFER_H
16 #define ALIEVEEVENTBUFFER_H
17
18
19
20 #include "TObject.h"
21 #include "TMutex.h"
22
23 class TObjArray;
24 class TTimer;
25 class TThread;
26 class TTimer;
27
28
29 class AliEveEventBuffer : public TObject{
30
31 public:
32   
33   /** default constructor */
34   AliEveEventBuffer();
35
36   /** destructor */
37   virtual ~AliEveEventBuffer();
38
39   void SetBufferSize(Int_t bs) { fBufferSize = bs;}
40     
41   TObject * NextEvent();
42   TObject * Back();
43   TObject * Fwd();
44   
45   void StartBufferMonitor();
46   void StopBufferMonitor();
47   //Needed for Homer buffer
48   virtual void ConnectToSource() = 0;
49   //Check if more events are needed in buffer
50   void MonitorBuffer();
51
52   static void * BufferThread(void * buffer);
53   virtual void WriteToFile(Int_t runnumber) = 0; 
54
55   void CreateBufferThread();
56
57   ULong64_t GetEventId() const { return fEventId[fBIndex[kCurrent]]; }
58   void SetEventId(ULong64_t eventId) { fEventId[fBIndex[kCurrent]] = eventId;}
59
60   Int_t LockMutex() { return fMutex->TryLock();}
61   Int_t UnLockMutex() { return fMutex->UnLock();}
62
63
64 protected:
65   
66   enum fBufferIndex {
67     kCurrent,
68     kLast, 
69     kTop,
70     kSize
71   };
72
73   
74   Int_t fBufferSize;//Size of event buffer
75   Int_t fPreBuffer;//How many events should be prefetched
76   TObjArray * fEventBuffer;   //TClonesArray containing the stored events
77   TObject * fCurrentEvent;   //Pointer to current event
78   Int_t fBIndex[kSize];   //Event buffer indexes
79
80   
81   
82   //Add event to buffer
83   virtual void AddToBuffer(TObject * event);
84   virtual TObject * GetEventFromSource() = 0;
85   virtual ULong64_t GetEventIdFromSource() { return 0;}
86
87
88   void FetchEvent();
89   
90
91   //Calculate buffer index stuff
92   Int_t CalculateDifference(Int_t top, Int_t low) const;
93   Int_t CalculatePrevious(Int_t current) const;
94   Int_t CalculateNext(Int_t current) const;
95
96   
97   void SetBufferMonStarted(Bool_t started) {fBufferMonStarted = started;}
98   Bool_t GetBufferMonStarted () const { return fBufferMonStarted;}
99
100 private:
101
102   /** copy constructor prohibited */
103   AliEveEventBuffer(const AliEveEventBuffer&);
104
105   /** assignment operator prohibited */
106   AliEveEventBuffer& operator=(const AliEveEventBuffer&);
107
108   
109
110   TObject *  GetNextUnSeen();
111
112   void PrintIndeces();
113   void PrintBuffer();
114
115   TTimer * fTimer;//Timer to loop over buffer monitor
116
117   //Current event id
118   ULong64_t * fEventId;//Event id
119   
120   Bool_t fBufferMonStarted;//Has buffer monitor loop started?
121
122   TThread * fThread; //Thread pointer
123   TMutex * fMutex;//Mutex
124
125   ClassDef(AliEveEventBuffer, 0); // Manage connections to HLT data-sources.
126 };
127
128 #endif