EventAna.h

/*
 * EventAna.h
 *
 *  Created on: 05-08-2013
 *      Author: Daniel Wielanek
 *      E-mail: daniel.wielanek@gmail.com
 *      Warsaw University of Technology, Faculty of Physics
 */
 
#ifndef HALEVENTANA_H_
#define HALEVENTANA_H_
 
#include "Cut.h"
#include "CutMonitor.h"
#include "Std.h"
#include "Task.h"
 
#include <Rtypes.h>
#include <RtypesCore.h>
#include <TString.h>
 
 
class TDatabasePDG;
 
namespace Hal {
  class Event;
  class CutsAndMonitors;
  class DataFormatManager;
  class MemoryMapManager;
 
  // s#define _HAL_CLEAR_BUFFER_ // realy need to clear bufferes?
  class EventAnaChain;
  class EventAna : public Task {
    friend EventAnaChain;
 
  protected:
    Int_t fFormatOption;
    enum eBitFormat { kCompression = 0, kSource = 1, kDirectAcesss = 2, kReader = 3, kChecking = 4 };
    UInt_t fProcessedEvents;
    Int_t fMixSize;
    Int_t fEventCollectionsNo;
    Int_t fCurrentEventCollectionID;
    const ECutUpdate fTiers;
    TDatabasePDG* fPDG;
    CutContainer* fCutContainer;
    MemoryMapManager* fMemoryMap;
    Event* fCurrentEvent;
    TString fComment;
    Int_t fInit;
    TString GetInputFileName() const { return fInFileName; };
    void SetInputFileName(TString name) { fInFileName = name; };
    virtual void InitMemoryMap();
 
 
  private:
    Bool_t fInChain;
    std::vector<TString> fTagList;
    Int_t fTaskID;
    TString fInFileName;
    DataFormatManager* fDataFormatManager;  //->
#ifdef _HAL_CLEAR_BUFFER_
    Bool_t fIsLastTask;
#endif
 
  protected:
    Bool_t IsInChain() const { return fInChain; };
    void MarkAsInChain() { fInChain = kTRUE; };
    void AddToAnaMetadata(Package* main_pack, TObject* obj) const;
    Task::EInitFlag InitCutContainer();
    virtual Task::EInitFlag CheckFormat();
    inline Int_t GetTaskID() const { return fTaskID; };
    virtual void LinkCollections();
    virtual void ProcessEvent() {};
    virtual void InitNewCutContainer();
    virtual void CheckCutContainerCollections();
    virtual Package* Report() const;
#ifdef _HAL_CLEAR_BUFFER_
    void ClearMemory();
#endif
    virtual Task::EInitFlag Init();
    EventAna(ECutUpdate tiers);
 
  public:
    enum class EFormatOption {
      kCompress,
      kNoCompress,
      kKeepSource,
      kNoKeepSource,
      kDirectAccess,
      kNoDirectAccess,
      kReaderAccess,
      kNoReaderAcces,
      kDisableChecking,
      kStandardAcess 
    };
    EventAna() : EventAna(ECutUpdate::kEvent) {};
    EventAna(const EventAna& ana);
    EventAna& operator=(const EventAna& other);
    virtual void AddTags(TString tag);
    virtual void AddCut(const Cut& cut, Option_t* opt = "");
    virtual void AddCutMonitor(const CutMonitor& mon, Option_t* opt = "");
    virtual void AddCutsAndMonitors(const CutsAndMonitors& monCuts);
    virtual void Exec(Option_t* opt);
    virtual void SetOption(Option_t* opt);
    void SetFormatOption(EFormatOption option);
    virtual void SetComment(TString comment);
    virtual void SetFormat(Event* format, EFormatDepth depth = EFormatDepth::kAll);
    virtual void FinishTask();
    virtual ~EventAna();
    ClassDef(EventAna, 1)
  };
}  // namespace Hal
#endif /* HALEVENTANA_H_ */