Process.h

Go to the documentation of this file.

 
#ifndef LDMXSW_FRAMEWORK_PROCESS_H_
#define LDMXSW_FRAMEWORK_PROCESS_H_
 
// LDMX
#include "Framework/Conditions.h"
#include "Framework/Configure/Parameters.h"
#include "Framework/Performance/Tracker.h"
#include "Framework/RunHeader.h"
#include "Framework/StorageControl.h"
 
// STL
#include <memory>
#include <vector>
 
class TFile;
class TDirectory;
 
namespace framework {
 
class EventProcessor;
class EventFile;
class Event;
 
class Process {
 public:
  Process(const framework::config::Parameters& configuration);
 
  ~Process();
 
  const std::string& getPassName() const { return pass_name_; }
 
  int getRunNumber() const;
 
  const ldmx::EventHeader* getEventHeader() const { return event_header_; }
 
  const ldmx::RunHeader* getRunHeader() const { return run_header_; }
 
  Conditions& getConditions() { return conditions_; }
 
  int getLogFrequency() const { return log_frequency_; }
 
  void run();
 
  void requestFinish() { event_limit_ = 0; }
 
  TDirectory* makeHistoDirectory(const std::string& dirName);
 
  TDirectory* openHistoFile();
 
  StorageControl& getStorageController() { return storage_controller_; }
 
  void setEventHeader(ldmx::EventHeader* h) { event_header_ = h; }
 
 private:
  bool process(int n, int n_tries, Event& event) const;
 
  void newRun(ldmx::RunHeader& header, EventFile* out);
 
  void onFileOpen(EventFile& file) const;
 
  void onFileClose(EventFile& file) const;
 
 private:
  framework::config::Parameters config_;
 
  std::string pass_name_;
 
  int event_limit_;
 
  int min_events_;
 
  int total_events_;
 
  int log_frequency_;
 
  int max_tries_;
 
  bool skip_corrupted_input_files_;
 
  bool allow_incomplete_input_files_;
 
  StorageControl storage_controller_;
 
  std::vector<EventProcessor*> sequence_;
 
  Conditions conditions_;
 
  std::vector<std::string> input_files_;
 
  std::vector<std::string> output_files_;
 
  int compression_setting_;
 
  std::vector<std::string> drop_keep_rules_;
 
  int run_for_generation_{1};
 
  std::string histo_filename_;
 
  const ldmx::EventHeader* event_header_{0};
 
  ldmx::RunHeader* run_header_{0};
 
  TFile* histo_t_file_{0};
 
  performance::Tracker* performance_{0};
 
  enableLogging("Process");
};
 
typedef std::unique_ptr<Process> ProcessHandle;
}  // namespace framework
 
#endif