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