MONITOR/MONITORzmq/AliEventsCollectorThread.h

   1 #ifndef __AliEventsCollectorThread__
   2 #define __AliEventsCollectorThread__
   3
   4 #include "AliStorageDatabase.h"
   5 #include "AliStorageClientThread.h"
   6
   7 #include <TThread.h>
   8 #include <TFile.h>
   9
  10 class AliStorageClientThread;
  11
  12 class AliEventsCollectorThread
  13 {
  14 public:
  15     AliEventsCollectorThread(AliStorageClientThread *onlineReconstructionManager);
  16     ~AliEventsCollectorThread();
  17
  18     void Kill();
  19 private:
  20     AliStorageClientThread *fManager;
  21
  22     static void* Dispatch(void *arg)
  23     {
  24         static_cast<AliEventsCollectorThread*>(arg)->CollectorHandle();
  25         return nullptr;
  26     }
  27     void CollectorHandle();
  28     TThread *fCollectorThread;
  29
  30     TFile *fCurrentFile;
  31     AliStorageDatabase *fDatabase;
  32     void CheckCurrentStorageSize();
  33     Long64_t GetSizeOfAllChunks();
  34
  35     bool fFinished;
  36 };
  37
  38
  39 #endif /* defined(__AliEventsCollectorThread__) */