]>
Commit | Line | Data |
---|---|---|
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_TObjArray | |
20 | #include <TObjArray.h> | |
21 | #endif | |
22 | ||
23 | #ifndef ROOT_TSysEvtHandler | |
24 | #include <TSysEvtHandler.h> | |
25 | #endif | |
26 | ||
27 | // Forward class declarations | |
28 | class AliRawEvent; | |
29 | class AliRawEventHeaderBase; | |
30 | class AliRawEquipmentHeader; | |
31 | class AliRawData; | |
32 | class AliRawDB; | |
33 | class AliRunDB; | |
34 | class AliTagDB; | |
35 | class AliStats; | |
36 | class AliESD; | |
37 | ||
38 | class AliMDC : public TObject { | |
39 | ||
40 | public: | |
41 | enum EWriteMode { kLOCAL, kRFIO, kROOTD, kCASTOR, kDEVNULL }; | |
42 | enum EFilterMode { kFilterOff, kFilterTransparent, kFilterOn }; | |
43 | enum EErrorCode { kErrStartEndRun = -1, | |
44 | kErrHeader = -2, | |
45 | kErrHeaderSize = -3, | |
46 | kErrSubHeader = -4, | |
47 | kErrDataSize = -5, | |
48 | kErrEquipmentHeader = -6, | |
49 | kErrEquipment = -7, | |
50 | kErrFileSize = -8, | |
51 | kFilterReject = -9, | |
52 | kErrWriting = -10 }; | |
53 | ||
54 | AliMDC(Int_t compress, Bool_t deleteFiles, | |
55 | EFilterMode filterMode = kFilterTransparent, | |
56 | const char* localRunDB = NULL, Bool_t rdbmsRunDB = kFALSE, | |
57 | const char* alienHostRunDB = NULL, const char* alienDirRunDB = NULL, | |
58 | Double_t maxSizeTagDB = -1, const char* fileNameTagDB = NULL); | |
59 | virtual ~AliMDC(); | |
60 | ||
61 | Int_t Open(EWriteMode mode, const char* fileName); | |
62 | Int_t ProcessEvent(void* event, Bool_t isIovecArray = kFALSE); | |
63 | Int_t GetTotalSize(); | |
64 | Int_t Close(); | |
65 | ||
66 | Int_t Run(const char* inputFile, Bool_t loop, | |
67 | EWriteMode mode, Double_t maxFileSize, | |
68 | const char* fs1 = NULL, const char* fs2 = NULL); | |
69 | void Stop(); | |
70 | ||
71 | private: | |
72 | class AliMDCInterruptHandler : public TSignalHandler { | |
73 | public: | |
74 | AliMDCInterruptHandler(AliMDC *mdc) : TSignalHandler(kSigUser1, kFALSE), fMDC(mdc) { } | |
75 | Bool_t Notify() { | |
76 | Info("Notify", "received a SIGUSR1 signal"); | |
77 | fMDC->Stop(); | |
78 | return kTRUE; | |
79 | } | |
80 | private: | |
81 | AliMDC *fMDC; // alimdc to signal | |
82 | ||
83 | AliMDCInterruptHandler(const AliMDCInterruptHandler& handler); | |
84 | AliMDCInterruptHandler& operator=(const AliMDCInterruptHandler& handler); | |
85 | }; | |
86 | ||
87 | AliRawEvent *fEvent; // produced AliRawEvent | |
88 | AliESD *fESD; // pointer to HLT ESD object | |
89 | AliStats *fStats; // statistics | |
90 | AliRawDB *fRawDB; // raw data DB | |
91 | AliRunDB *fRunDB; // run DB | |
92 | AliTagDB *fTagDB; // tag DB | |
93 | Int_t fCompress; // compression factor used for raw output DB | |
94 | Bool_t fDeleteFiles; // flag for deletion of files | |
95 | EFilterMode fFilterMode; // high level filter mode | |
96 | TObjArray fFilters; // filter algorithms | |
97 | Bool_t fStop; // stop execution (triggered by SIGUSR1) | |
98 | Bool_t fIsTagDBCreated; // is tag db already created | |
99 | Double_t fMaxSizeTagDB;// max size of the tag DB | |
100 | const char* fFileNameTagDB;// tag DB file name | |
101 | ||
102 | // Filter names | |
103 | enum {kNFilters = 1}; | |
104 | static const char* const fgkFilterName[kNFilters]; | |
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(Int_t fd, void *buffer, Int_t length); | |
111 | Int_t ReadEquipmentHeader(AliRawEquipmentHeader &header, | |
112 | Bool_t isSwapped, char*& data); | |
113 | Int_t ReadRawData(AliRawData &raw, Int_t size, char*& data); | |
114 | ||
115 | ClassDef(AliMDC,0) // MDC processor | |
116 | }; | |
117 | ||
118 | #endif |