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/Exception/Exception.h"
#include "Framework/Performance/Tracker.h"
#include "Framework/RunHeader.h"
#include "Framework/StorageControl.h"
 
// STL
#include <csignal>
#include <map>
#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);
 
  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_;
 
  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