OutputWorker.h
Go to the documentation of this file.
1 #ifndef art_Framework_Core_OutputWorker_h
2 #define art_Framework_Core_OutputWorker_h
3 // vim: set sw=2 expandtab :
4 
5 // The OutputModule as the schedule sees it. The job of
6 // this object is to call the output module.
7 //
8 // According to our current definition, a single output module can only
9 // appear in one worker.
10 
20 
21 #include <memory>
22 
23 namespace art {
24  struct OutputModuleDescription;
25  class RangeSet;
26  class OutputWorker : public WorkerT<OutputModule> {
27  public: // MEMBER FUNCTIONS -- Special Member Functions
28  virtual ~OutputWorker();
29  // This is called directly by the make_worker function created
30  // by the DEFINE_ART_MODULE macro.
31  OutputWorker(std::shared_ptr<OutputModule> mod,
32  ModuleDescription const&,
33  WorkerParams const&);
34 
35  public:
36  std::string const& lastClosedFileName() const;
37  bool closeFile();
38  bool fileIsOpen() const;
40  bool requestsToCloseFile() const;
41  bool wantAllEvents() const;
42  bool openFile(FileBlock const& fb);
43  void writeRun(RunPrincipal& rp);
44  void writeSubRun(SubRunPrincipal& srp);
48  bool limitReached() const;
50  void configure(OutputModuleDescription const& desc);
52  virtual void selectProducts(ProductTables const&);
53 
54  private:
57  };
58 } // namespace art
59 
60 #endif /* art_Framework_Core_OutputWorker_h */
61 
62 // Local Variables:
63 // mode: c++
64 // End:
void setRunAuxiliaryRangeSetID(RangeSet const &)
virtual ~OutputWorker()
std::string const & lastClosedFileName() const
bool limitReached() const
Granularity fileGranularity_
Definition: OutputWorker.h:56
void configure(OutputModuleDescription const &desc)
void setFileStatus(OutputFileStatus)
bool fileIsOpen() const
OutputFileStatus
void setSubRunAuxiliaryRangeSetID(RangeSet const &)
bool openFile(FileBlock const &fb)
bool requestsToCloseFile() const
OutputWorker(std::shared_ptr< OutputModule > mod, ModuleDescription const &, WorkerParams const &)
bool wantAllEvents() const
void writeEvent(EventPrincipal &ep)
Service to store calibration data products (CDP) in the SQLite3 metadatabase of a file...
Definition: FillParentInfo.h:8
void incrementInputFileNumber()
void writeSubRun(SubRunPrincipal &srp)
ServiceHandle< CatalogInterface > ci_
Definition: OutputWorker.h:55
virtual void selectProducts(ProductTables const &)
void writeRun(RunPrincipal &rp)
Granularity fileGranularity() const
enum BeamMode string