X-Git-Url: http://git.uio.no/git/?a=blobdiff_plain;ds=sidebyside;f=ANALYSIS%2FAliAnalysisTask.h;h=c478cf3fd92779f28ef19fb71d5634561f9202f1;hb=dc850ba8d659f1fe891612c11c0d39acbb3408a4;hp=db94cbcc184de5321f097cc8380468b1692ac474;hpb=8508e09fc7a41be69c481fee6792f75ea50d6173;p=u%2Fmrichter%2FAliRoot.git diff --git a/ANALYSIS/AliAnalysisTask.h b/ANALYSIS/AliAnalysisTask.h index db94cbcc184..c478cf3fd92 100644 --- a/ANALYSIS/AliAnalysisTask.h +++ b/ANALYSIS/AliAnalysisTask.h @@ -43,6 +43,7 @@ class AliAnalysisTask : public TTask { TObject *fPublishedData; //! published data TObjArray *fInputs; // Array of input slots TObjArray *fOutputs; // Array of output slots + TString fBranchNames; // List of input branches that need to be loaded for this task // Define the input/output slots (called by user in the ctor of the derived class) //=== CALL IN THE CONSTRUCTOR OF DERIVED CLASS TO DEFINE INPUTS/OUTPUTS === @@ -88,9 +89,13 @@ public: virtual void LocalInit(); // === OVERLOAD THIS IF YOU NEED TO TREAT INPUT FILE/TREE CHANGE virtual Bool_t Notify(); + // === OVERLOAD THIS IF YOU NEED TO TREAT BIN CHANGE IN EVENT MIXING + virtual Bool_t NotifyBinChange(); //===================================================================== - // Optional cleanup method to be called only in PROOF in SlaveTerminate phase - virtual void Cleanup(); + // Optional method that will be called in SlaveTerminate phase for each task + // Warning: in PROOF mode this is called before merging so their cleanup is + // not allowed - do output cleanup in class destructor. + virtual void FinishTaskOutput(); // Conect inputs/outputs to data containers (by AliAnalysisModule) Bool_t ConnectInput(Int_t islot, AliAnalysisDataContainer *cont); Bool_t ConnectOutput(Int_t islot, AliAnalysisDataContainer *cont); @@ -101,6 +106,7 @@ public: // Check if there are illegal circular dependencies Bool_t CheckCircularDeps(); // Getters + void GetBranches(const char *type, TString &result) const; Int_t GetNinputs() const {return fNinputs;} Int_t GetNoutputs() const {return fNoutputs;} TObject *GetPublishedData() const {return fPublishedData;} @@ -118,8 +124,10 @@ public: Bool_t IsReady() const {return fReady;} Bool_t IsUsed() const {return TObject::TestBit(kTaskUsed);} Bool_t IsZombie() const {return TObject::TestBit(kTaskZombie);} + Bool_t HasBranches() const {return !fBranchNames.IsNull();} void PrintTask(Option_t *option="all", Int_t indent=0) const; void PrintContainers(Option_t *option="all", Int_t indent=0) const; + void SetBranches(const char *names) {fBranchNames = names;} void SetChecked(Bool_t flag=kTRUE) {TObject::SetBit(kTaskChecked,flag);} void SetPostEventLoop(Bool_t flag=kTRUE); void SetUsed(Bool_t flag=kTRUE); @@ -134,6 +142,6 @@ public: virtual void Terminate(Option_t *option=""); //===================================================================== - ClassDef(AliAnalysisTask,1) // Class describing an analysis task + ClassDef(AliAnalysisTask,2) // Class describing an analysis task }; #endif