RAW/AliMDC.h

   1 #ifndef ALIMDC_H
   2 #define ALIMDC_H
   3 // @(#)alimdc:$Name$:$Id$
   4 // Author: Fons Rademakers  26/11/99
   5
   6 /* Copyright(c) 1998-2003, ALICE Experiment at CERN, All rights reserved. *
   7  * See cxx source for full Copyright notice                               */
   8
   9 //////////////////////////////////////////////////////////////////////////
  10 //                                                                      //
  11 // AliMDC                                                               //
  12 //                                                                      //
  13 //////////////////////////////////////////////////////////////////////////
  14
  15 #ifndef ROOT_TObject
  16 #include <TObject.h>
  17 #endif
  18
  19 #ifndef ROOT_TSysEvtHandler
  20 #include <TSysEvtHandler.h>
  21 #endif
  22
  23 // Forward class declarations
  24 class AliRawEventHeader;
  25 class AliRawEquipmentHeader;
  26 class AliRawData;
  27
  28
  29 class AliMDC : public TObject {
  30
  31 public:
  32    enum EWriteMode { kLOCAL, kRFIO, kROOTD, kCASTOR, kDEVNULL };
  33
  34    AliMDC(Int_t fd, Int_t compress, Double_t maxFileSize, Bool_t useFilter,
  35           EWriteMode mode, Bool_t useLoop, Bool_t delFiles);
  36    ~AliMDC() { fgInstance = NULL; }
  37
  38    static AliMDC* Instance() {return fgInstance;}
  39
  40    Int_t  Run();
  41    void   SetStopLoop() { fStopLoop = kTRUE; }
  42    Bool_t StopLoop() const { return fStopLoop; }
  43
  44    void   SetDebugLevel(Int_t level) { fDebugLevel = level; }
  45    Int_t  GetDebugLevel() const { return fDebugLevel; }
  46
  47    static Bool_t DeleteFiles() { return fgDeleteFiles; }
  48
  49    enum {kMDC = 6};  // Which MDC is this...
  50
  51    static const char* const Fifo() {return fgkFifo;}
  52    static const char* const RawDBFS(Int_t i) {return fgkRawDBFS[i];}
  53    static const char* const TagDBFS() {return fgkTagDBFS;}
  54    static const char* const RunDBFS() {return fgkRunDBFS;}
  55    static const char* const RFIOFS() {return fgkRFIOFS;}
  56    static const char* const CastorFS() {return fgkCastorFS;}
  57    static const char* const RootdFS() {return fgkRootdFS;}
  58    static const char* const AlienHost() {return fgkAlienHost;}
  59    static const char* const AlienDir() {return fgkAlienDir;}
  60
  61 private:
  62    class AliMDCInterruptHandler : public TSignalHandler {
  63    public:
  64      AliMDCInterruptHandler(AliMDC *mdc) : TSignalHandler(kSigUser1, kFALSE), fMDC(mdc) { }
  65      Bool_t Notify() {
  66        Info("Notify", "received a SIGUSR1 signal");
  67        fMDC->SetStopLoop();
  68        return kTRUE;
  69      }
  70    private:
  71      AliMDC *fMDC;   // alimdc to signal
  72
  73      AliMDCInterruptHandler(const AliMDCInterruptHandler& handler);
  74      AliMDCInterruptHandler& operator=(const AliMDCInterruptHandler& handler);
  75    };
  76
  77    static AliMDC* fgInstance;  // singleton instance
  78
  79    Int_t      fFd;          // DATE input stream
  80    Int_t      fCompress;    // compression factor used for raw output DB
  81    Int_t      fNumEvents;   // number of events processed
  82    Int_t      fDebugLevel;  // controls debug print-out
  83    Double_t   fMaxFileSize; // maximum size of raw output DB
  84    EWriteMode fWriteMode;   // write mode (local, rfio, rootd, castor, /dev/null)
  85    Bool_t     fUseFifo;     // read from fifo, file otherwise
  86    Bool_t     fUseEb;       // use event builder API instead of fifo
  87    Bool_t     fUseFilter;   // use 3rd level trigger filter
  88    Bool_t     fUseLoop;     // loop on input source (must be file)
  89    Bool_t     fStopLoop;    // break from endless loop (triggered by SIGUSR1)
  90
  91    static Bool_t fgDeleteFiles;  // flag for deletion of files
  92
  93    static const Double_t fgkMaxTagFileSize;  // maximal size of tag DB
  94
  95    // Fixed file system locations for the different DB's
  96    static const char* const fgkFifo;       // fifo
  97    static const char* const fgkRawDBFS[2]; // raw DB
  98    static const char* const fgkTagDBFS;    // tag DB
  99    static const char* const fgkRunDBFS;    // run DB
 100    static const char* const fgkRFIOFS;     // rfio
 101    static const char* const fgkCastorFS;   // castor
 102    static const char* const fgkRootdFS;    // rootd
 103    static const char* const fgkAlienHost;  // alien host name
 104    static const char* const fgkAlienDir;   // alien directory
 105
 106    AliMDC(const AliMDC& mdc);
 107    AliMDC& operator = (const AliMDC& mdc);
 108
 109    Int_t     Read(const char *name) { return TObject::Read(name); }
 110    Int_t     Read(void *buffer, Int_t length);
 111    Int_t     ReadHeader(AliRawEventHeader &header, void *eb = 0);
 112    Int_t     ReadEquipmentHeader(AliRawEquipmentHeader &header,
 113                                  Bool_t isSwapped, void *eb = 0);
 114    Int_t     ReadRawData(AliRawData &raw, Int_t size, void *eb = 0);
 115    Int_t     DumpEvent(Int_t toRead);
 116    Int_t     Filter(AliRawData &raw);
 117
 118    ClassDef(AliMDC,0)  // MDC processor
 119 };
 120
 121 #endif