core::ProcessorBlock Class Reference

A set of Processors. More...

#include <ProcessorBlock.hh>

Public Member Functions
	ProcessorBlock ()
virtual	~ProcessorBlock ()
virtual void	AddProcessor (ProcessorBase *processor, fhicl::ParameterSet *config)
virtual void	ProcessFiles (std::vector< std::string > filenames)
virtual void	DeleteProcessors ()

Protected Attributes
std::vector< std::pair < ProcessorBase *, fhicl::ParameterSet * > >	fProcessors

Detailed Description

A set of Processors.

Definition at line 25 of file ProcessorBlock.hh.

Constructor & Destructor Documentation

core::ProcessorBlock::ProcessorBlock

(

)

Constructor

Definition at line 9 of file ProcessorBlock.cxx.

{}

core::ProcessorBlock::~ProcessorBlock ( )

virtual

Destructor

Definition at line 12 of file ProcessorBlock.cxx.

{}

Member Function Documentation

void core::ProcessorBlock::AddProcessor ( ProcessorBase *  processor, fhicl::ParameterSet *  config  )

virtual

Add a processor to the block.

Note that the ProcessorBlock takes ownership of the Processor.

Parameters

processor	The processor
config	The configuration, if any

Definition at line 15 of file ProcessorBlock.cxx.

                                                             {
  fProcessors.push_back({processor, config});
}

void core::ProcessorBlock::DeleteProcessors ( )

virtual

Delete all processors owned by the block.

Definition at line 76 of file ProcessorBlock.cxx.

                                      {
  for (auto it : fProcessors) {
    delete it.first;
  }
}

void core::ProcessorBlock::ProcessFiles ( std::vector< std::string >  filenames )

virtual

Process a set of files.

Parameters

filenames

A list of art ROOT files to process

Definition at line 21 of file ProcessorBlock.cxx.

                                                                {
  // Setup
  for (auto it : fProcessors) {
    it.first->Setup(it.second);
    it.first->Initialize(it.second);
  }

  // Event loop
  for (gallery::Event ev(filenames); !ev.atEnd(); ev.next()) {
    for (auto it : fProcessors) {
      ProcessorBase* p = it.first;
      p->BuildEventTree(ev);
      p->SetupServices(ev);

      bool accept = p->ProcessEvent(ev, p->fEvent->truth, *p->fReco);

      // Set reco index
      for (size_t i=0; i<p->fReco->size(); i++) {
        p->fReco->at(i).index = i;
      }
      p->fEvent->nreco = p->fReco->size();

      if (accept) {
        p->FillTree();

        // For each reco event, fill the reco output tree
        p->fRecoEvent->experiment = p->fEvent->experiment;
        p->fRecoEvent->metadata = p->fEvent->metadata;

        for (auto const& reco : *p->fReco) {
          p->fRecoEvent->reco = reco;

          // Copy the associated truth interaction, if any
          p->fRecoEvent->truth.resize(0);
          int truthidx = p->fRecoEvent->reco.truth_index;
          if (truthidx >= 0 && truthidx < p->fEvent->truth.size()) {
            p->fRecoEvent->truth.push_back(p->fEvent->truth.at(truthidx));
          }

          p->FillRecoTree();
        }
      }

      p->EventCleanup();
    }
  }

  // Finalize
  for (auto it : fProcessors) {
    it.first->Finalize();
    it.first->Teardown();
  }
}

Member Data Documentation

std::vector<std::pair<ProcessorBase*, fhicl::ParameterSet*> > core::ProcessorBlock::fProcessors

protected

Processors and their configurations.

Definition at line 55 of file ProcessorBlock.hh.

---

The documentation for this class was generated from the following files:

• ProcessorBlock.hh
• ProcessorBlock.cxx