ana_processor.hh

Go to the documentation of this file.

#ifndef ANA_PROCESSOR_HH
#define ANA_PROCESSOR_HH

#include <TFile.h>
#include <vector>
#include "ana_base.hh"
#include "storage_manager.hh"

class ana_processor : public decoder_base{

public:

  enum PROCESS_FLAG{
    INIT,       
    READY,      
    PROCESSING, 
    FINISHED    
  };

  ana_processor();

  ~ana_processor(){};


  virtual void set_verbosity(MSG::Level level);

  void add_input_file(std::string name){_storage->add_in_filename(name);};

  void set_output_file(std::string name){_storage->set_out_filename(name);};
  
  void set_ana_output_file(std::string name){_ofile_name=name;};

  void set_io_mode(storage_manager::MODE mode){_storage->set_io_mode(mode);};
  
  void set_data_to_read(DATA_STRUCT::DATA_TYPE type,bool read=true)
  {_storage->set_data_to_read(type,read);};

  void set_data_to_write(DATA_STRUCT::DATA_TYPE type,bool write=true)
  {_storage->set_data_to_write(type,write);};
  
  bool get_ana_status(ana_base* ptr) const;
  
  bool run(UInt_t start_index=0, UInt_t nevents=0);

  bool process_event(UInt_t index=0);

  size_t add_process(ana_base* ana){_analyzers.push_back(ana); return _analyzers.size()-1;};

  ana_base* get_process(size_t loc){return (_analyzers.size() > loc) ? _analyzers[loc] : 0;};

  PROCESS_FLAG get_process_status() {return _process;};

private:

  void reset();

  bool initialize();
  
  bool finalize();

  std::vector<ana_base*>   _analyzers;  
  std::map<ana_base*,bool> _ana_status; 

  PROCESS_FLAG _process;       
  UInt_t _nevents;           
  UInt_t _index;             
  std::string _ofile_name;     
  TFile*   _fout;              
  storage_manager* _storage;   

};
#endif
 // end of doxygen group 

---