JDL bug fix

[u/mrichter/AliRoot.git] / ANALYSIS / AliAnalysisDataContainer.h

diff --git a/ANALYSIS/AliAnalysisDataContainer.h b/ANALYSIS/AliAnalysisDataContainer.h
index 3d3f235a4dbc74859ea0cd3cd3439200734fb5c3..91be24ce2fe08ce2a90fbe3f5908a4e5695f6100 100644 (file)
--- a/ANALYSIS/AliAnalysisDataContainer.h
+++ b/ANALYSIS/AliAnalysisDataContainer.h
@@ -23,12 +23,18 @@
 #include "TString.h"
 #endif
 
+#ifndef ROOT_TStopwatch
+#include "TStopwatch.h"
+#endif
+
 class TClass;
+class TFile;
 class TObjArray;
 class TCollection;
 class AliAnalysisTask;
 class AliAnalysisDataWrapper;
-class AliESD;
+
+using std::ostream;
 
 class AliAnalysisDataContainer : public TNamed {
 
@@ -39,7 +45,9 @@ enum ENotifyMessage {
    kFileChange
 };   
 enum EAnalysisContainerFlags {
-   kPostEventLoop = BIT(14)
+   kPostEventLoop = BIT(14),
+   kSpecialOutput = BIT(15),
+   kRegisterDataset = BIT(16)
 };     
    AliAnalysisDataContainer();
    AliAnalysisDataContainer(const AliAnalysisDataContainer &cont);
@@ -51,6 +59,8 @@ enum EAnalysisContainerFlags {
    // Getters
    TObject                  *GetData() const      {return fData;}
    const char               *GetFileName() const  {return fFileName.Data();}
+   const char               *GetFolderName() const {return fFolderName.Data();}
+   TFile                    *GetFile() const      {return fFile;}
    TClass                   *GetType() const;
    AliAnalysisTask          *GetProducer() const  {return fProducer;}
    TObjArray                *GetConsumers() const {return fConsumers;}
@@ -60,7 +70,10 @@ enum EAnalysisContainerFlags {
    virtual Bool_t            SetData(TObject *data, Option_t *option="");
    void                      SetDataOwned(Bool_t flag) {fOwnedData = flag;}
    void                      SetPostEventLoop(Bool_t flag=kTRUE) {TObject::SetBit(kPostEventLoop,flag);}
-   void                      SetFileName(const char *filename) {fFileName = filename;}
+   void                      SetSpecialOutput(Bool_t flag=kTRUE) {TObject::SetBit(kSpecialOutput,flag);}
+   void                      SetRegisterDataset(Bool_t flag=kTRUE) {TObject::SetBit(kRegisterDataset,flag);}
+   void                      SetFileName(const char *filename);
+   void                      SetFile(TFile *f) {fFile = f;}
    void                      SetProducer(AliAnalysisTask *prod, Int_t islot);
    void                      AddConsumer(AliAnalysisTask *cons, Int_t islot);
    void                      DeleteData();
@@ -70,6 +83,8 @@ enum EAnalysisContainerFlags {
    // Container status checking
    Bool_t                    IsDataReady() const  {return fDataReady;}
    Bool_t                    IsPostEventLoop() const {return TObject::TestBit(kPostEventLoop);}
+   Bool_t                    IsSpecialOutput() const {return TObject::TestBit(kSpecialOutput);}
+   Bool_t                    IsRegisterDataset() const {return TObject::TestBit(kRegisterDataset);}
    Bool_t                    IsOwnedData() const  {return fOwnedData;}
    Bool_t                    ClientsExecuted() const;
    Bool_t                    HasConsumers() const {return (fConsumers != 0);}
@@ -88,12 +103,14 @@ protected:
    Bool_t                    fDataReady;  // Flag that data is ready
    Bool_t                    fOwnedData;  // Flag data ownership
    TString                   fFileName;   // File storing the data
+   TString                   fFolderName; // Folder name in the output file
+   TFile                    *fFile;       //! Opened file
    TObject                  *fData;       // Contained data
    TClass                   *fType;       //! Type of contained data
    AliAnalysisTask          *fProducer;   // Analysis task to which the slot belongs
    TObjArray                *fConsumers;  // List of consumers of the data
    
-   ClassDef(AliAnalysisDataContainer,1)  // Class describing a data container for analysis
+   ClassDef(AliAnalysisDataContainer,2)  // Class describing a data container for analysis
 };
 
 //==============================================================================
@@ -129,4 +146,61 @@ protected:
    ClassDef(AliAnalysisDataWrapper, 1) // Data wrapper class for exchange via the net
 };
 
+//==============================================================================
+//   AliAnalysisFileDescriptor - A simple wrapper for data related to accessing
+//      an analysis input file.
+//==============================================================================
+class AliAnalysisFileDescriptor : public TObject {
+
+public:
+   AliAnalysisFileDescriptor();
+   AliAnalysisFileDescriptor(const TFile *file);
+   AliAnalysisFileDescriptor(const AliAnalysisFileDescriptor &other);
+   virtual ~AliAnalysisFileDescriptor();
+
+   // Assignment
+   AliAnalysisFileDescriptor &operator=(const AliAnalysisFileDescriptor &other);
+   
+   void         Done();
+   
+   const char  *GetGUID() const  {return fGUID;}
+   Int_t        GetImage() const {return fImage;}
+   const char  *GetLfn() const   {return fLfn;}
+   Int_t        GetNreplicas() const {return fNreplicas;}
+   Long64_t     GetOpenAt() const {return fOpenedAt;}
+   Double_t     GetOpenTime() const {return fOpenTime;}
+   const char  *GetPfn() const   {return fPfn;}
+   Long64_t     GetReadBytes() const {return fReadBytes;}
+   Long64_t     GetSize() const   {return fSize;}
+   const char  *GetSE() const     {return fSE;}
+   Double_t     GetThroughput() const {return fThroughput;}
+   Double_t     GetProcessingTime() const {return fProcessingTime;}
+   const char  *GetUrl() const    {return fUrl;}
+   Bool_t       IsArchive() const {return fIsArchive;}
+   virtual void Print(Option_t *option="") const;
+   virtual void SavePrimitive(std::ostream &out, Option_t *option = "");
+   void         SetOpenTime(Double_t time) {fOpenTime = time;}
+   
+
+protected:   
+   TString      fLfn;       // logical file name
+   TString      fGUID;      // GUID
+   TString      fUrl;       // url for the opened copy
+   TString      fPfn;       // physical file name
+   TString      fSE;        // Storage element
+   Bool_t       fIsArchive; // Archive flag
+   Int_t        fImage;     // Image number
+   Int_t        fNreplicas; // Number of replicas
+   Long64_t     fStartBytes;// Total number of read bytes at start
+   Long64_t     fReadBytes; // Number of bytes read
+   Long64_t     fSize;      // Size of the file in bytes
+   Long64_t     fOpenedAt;  // Absolute value for time when opened
+   Double_t     fOpenTime;  // Time elapsed to open file
+   Double_t     fProcessingTime; // Processing
+   Double_t     fThroughput; // Throughput
+   TStopwatch   fTimer;     //! Processing time
+   
+   ClassDef(AliAnalysisFileDescriptor,1)  // Class describing a a file processed in the analysis
+};
+
 #endif