OutputWorker.cc

Go to the documentation of this file.

#include "art/Framework/Core/OutputWorker.h"

#include "art/Framework/Core/FileBlock.h"
#include "art/Framework/Core/OutputModule.h"
#include "art/Framework/Principal/WorkerParams.h"
#include "fhiclcpp/ParameterSetRegistry.h"

namespace art {
  OutputWorker::OutputWorker(std::unique_ptr<OutputModule>&& mod,
                             ModuleDescription const& md,
                             WorkerParams const& wp)
    : WorkerT<OutputModule>(std::move(mod), md, wp), ci_()
  {
    ci_->outputModuleInitiated(
      label(),
      fhicl::ParameterSetRegistry::get(description().parameterSetID()));
  }

  OutputWorker::~OutputWorker() {}

  std::string const&
  OutputWorker::lastClosedFileName() const
  {
    return module().lastClosedFileName();
  }

  void
  OutputWorker::closeFile()
  {
    module().doCloseFile();
    ci_->outputFileClosed(description().moduleLabel(),
                          module().lastClosedFileName());
  }

  void
  OutputWorker::incrementInputFileNumber()
  {
    return module().incrementInputFileNumber();
  }

  bool
  OutputWorker::requestsToCloseFile() const
  {
    return module().requestsToCloseFile();
  }

  void
  OutputWorker::openFile(FileBlock const& fb)
  {
    module().doOpenFile(fb);
    ci_->outputFileOpened(description().moduleLabel());
  }

  void
  OutputWorker::writeRun(RunPrincipal& rp)
  {
    module().doWriteRun(rp);
  }

  void
  OutputWorker::writeSubRun(SubRunPrincipal& srp)
  {
    module().doWriteSubRun(srp);
  }

  void
  OutputWorker::writeEvent(EventPrincipal& srp)
  {
    module().doWriteEvent(srp);
  }

  void
  OutputWorker::setRunAuxiliaryRangeSetID(RangeSet const& rs)
  {
    module().doSetRunAuxiliaryRangeSetID(rs);
  }

  void
  OutputWorker::setSubRunAuxiliaryRangeSetID(RangeSet const& rs)
  {
    module().doSetSubRunAuxiliaryRangeSetID(rs);
  }

  bool
  OutputWorker::fileIsOpen() const
  {
    return module().fileIsOpen();
  }

  void
  OutputWorker::setFileStatus(OutputFileStatus const ofs)
  {
    return module().setFileStatus(ofs);
  }

  bool
  OutputWorker::wantAllEvents() const
  {
    return module().wantAllEvents();
  }

  bool
  OutputWorker::limitReached() const
  {
    return module().limitReached();
  }

  void
  OutputWorker::configure(OutputModuleDescription const& desc)
  {
    module().configure(desc);
  }

  void
  OutputWorker::selectProducts(ProductList const& productList)
  {
    module().selectProducts(productList);
  }

  Granularity
  OutputWorker::fileGranularity() const
  {
    return module().fileGranularity();
  }
}