#include "MixOp.h"

Inheritance diagram for art::MixOp< PROD, OPROD >:

Public Member Functions
template<typename FUNC >
	MixOp (InputTag const &inputTag, std::string const &outputInstanceLabel, FUNC mixFunc, bool outputProduct, bool compactMissingProducts, BranchType bt)

InputTag const &	inputTag () const override

TypeID const &	inputType () const override

std::string const &	outputInstanceLabel () const override

void	mixAndPut (Event &e, PtrRemapper const &remap) const override

void	initializeBranchInfo (RootBranchInfoList const &rbiList) override

ProductID	incomingProductID () const override

ProductID	outgoingProductID () const override

void	readFromFile (EntryNumberSequence const &seq, cet::exempt_ptr< BranchIDLists const > branchIDLists) override

BranchType	branchType () const override

Protected Member Functions
void	configureStreamers (cet::exempt_ptr< BranchIDLists const > branchIDLists)

Private Types
using	SpecProdList = std::vector< std::shared_ptr< Wrapper< PROD >>>

Private Attributes
InputTag const	inputTag_

TypeID const	inputType_

std::string const	outputInstanceLabel_

MixFunc< PROD, OPROD > const	mixFunc_

SpecProdList	inProducts_ {}

std::string const	processName_

std::string const	moduleLabel_

RootBranchInfo	branchInfo_ {}

bool const	outputProduct_

bool const	compactMissingProducts_

BranchType const	branchType_

Detailed Description

template<typename PROD, typename OPROD>
class art::MixOp< PROD, OPROD >

Definition at line 28 of file MixOp.h.

Member Typedef Documentation

template<typename PROD , typename OPROD >

using art::MixOp< PROD, OPROD >::SpecProdList = std::vector<std::shared_ptr<Wrapper<PROD>>>

private

Definition at line 63 of file MixOp.h.

Constructor & Destructor Documentation

template<typename PROD , typename OPROD >

template<typename FUNC >

art::MixOp< PROD, OPROD >::MixOp	(	InputTag const &	inputTag,
		std::string const &	outputInstanceLabel,
		FUNC	mixFunc,
		bool	outputProduct,
		bool	compactMissingProducts,
		BranchType	bt
	)

Definition at line 80 of file MixOp.h.

References art::MixOp< PROD, OPROD >::branchType_, art::MixOp< PROD, OPROD >::compactMissingProducts_, art::MixOp< PROD, OPROD >::inputType_, art::MixOp< PROD, OPROD >::mixFunc_, art::MixOp< PROD, OPROD >::moduleLabel_, art::MixOp< PROD, OPROD >::outputInstanceLabel(), art::MixOp< PROD, OPROD >::outputInstanceLabel_, art::MixOp< PROD, OPROD >::outputProduct_, and art::MixOp< PROD, OPROD >::processName_.

   : inputTag_{inputTag}
   , inputType_{typeid(PROD)}
   , outputInstanceLabel_(outputInstanceLabel)
   , mixFunc_{mixFunc}
   , processName_{ServiceHandle<TriggerNamesService const>{}->getProcessName()}
   , moduleLabel_{ServiceHandle<CurrentModule const>{}->label()}
   , outputProduct_{outputProduct}
   , compactMissingProducts_{compactMissingProducts}
   , branchType_{bt}
 {}

Member Function Documentation

template<typename PROD , typename OPROD >

art::BranchType art::MixOp< PROD, OPROD >::branchType ( ) const

inlineoverridevirtual

Implements art::MixOpBase.

Definition at line 232 of file MixOp.h.

References art::MixOp< PROD, OPROD >::branchType_.

 {
   return branchType_;
 }

void art::MixOpBase::configureStreamers ( cet::exempt_ptr< BranchIDLists const > branchIDLists )

protectedinherited

Definition at line 9 of file MixOpBase.cc.

Referenced by art::MixOp< PROD, OPROD >::readFromFile().

 {
   // Make sure the schema evolution is ready for ProductID
   configureProductIDStreamer(branchIDLists);
   // Make sure we don't have a ProductGetter set.
   configureRefCoreStreamer();
 }

template<typename PROD , typename OPROD >

art::ProductID art::MixOp< PROD, OPROD >::incomingProductID ( ) const

overridevirtual

Implements art::MixOpBase.

Definition at line 171 of file MixOp.h.

References art::MixOp< PROD, OPROD >::branchInfo_, and art::RootBranchInfo::branchName().

 {
   return ProductID{branchInfo_.branchName()};
 }

template<typename PROD , typename OPROD >

void art::MixOp< PROD, OPROD >::initializeBranchInfo ( RootBranchInfoList const & rbiList )

overridevirtual

Implements art::MixOpBase.

Definition at line 155 of file MixOp.h.

References art::MixOp< PROD, OPROD >::branchInfo_, art::detail::checkForMissingDictionaries(), art::RootBranchInfoList::findBranchInfo(), art::TypeID::friendlyClassName(), art::MixOp< PROD, OPROD >::inputTag_, art::MixOp< PROD, OPROD >::inputType_, and art::errors::ProductNotFound.

 {
   if (!branchInfo_List.findBranchInfo(inputType_, inputTag_, branchInfo_)) {
     throw Exception(errors::ProductNotFound)
       << "Unable to find requested product " << inputTag_ << " of type "
       << inputType_.friendlyClassName() << " in secondary input stream.\n";
   }
   // Check dictionaries for input product, not output product: let
   // output modules take care of that.
   std::vector<TypeID> const types{TypeID{typeid(PROD)}};
   detail::checkForMissingDictionaries(types);
 }

template<typename PROD , typename OPROD >

art::InputTag const & art::MixOp< PROD, OPROD >::inputTag ( ) const

overridevirtual

Implements art::MixOpBase.

Definition at line 99 of file MixOp.h.

References art::MixOp< PROD, OPROD >::inputTag_.

 {
   return inputTag_;
 }

template<typename PROD , typename OPROD >

art::TypeID const & art::MixOp< PROD, OPROD >::inputType ( ) const

overridevirtual

Implements art::MixOpBase.

Definition at line 106 of file MixOp.h.

References art::MixOp< PROD, OPROD >::inputType_.

 {
   return inputType_;
 }

template<typename PROD , typename OPROD >

void art::MixOp< PROD, OPROD >::mixAndPut	(	Event &	e,
		PtrRemapper const &	remap
	)		const

overridevirtual

Implements art::MixOpBase.

Definition at line 120 of file MixOp.h.

References art::MixOp< PROD, OPROD >::compactMissingProducts_, art::errors::DataCorruption, art::MixOp< PROD, OPROD >::inProducts_, art::errors::LogicError, art::MixOp< PROD, OPROD >::mixFunc_, art::MixOp< PROD, OPROD >::outputInstanceLabel_, art::MixOp< PROD, OPROD >::outputProduct_, and art::Event::put().

 {
   auto rProd = std::make_unique<OPROD>();
   std::vector<PROD const*> inConverted;
   inConverted.reserve(inProducts_.size());
   try {
     auto const endIter = cend(inProducts_);
     for (auto i = cbegin(inProducts_); i != endIter; ++i) {
       auto const prod = (*i)->product();
       if (prod || !compactMissingProducts_) {
         inConverted.emplace_back(prod);
       }
     }
   }
   catch (std::bad_cast const&) {
     throw Exception(errors::DataCorruption)
       << "Unable to obtain correctly-typed product from wrapper.\n";
   }
   if (mixFunc_(inConverted, *rProd, remap)) {
     if (!outputProduct_) {
       throw Exception(errors::LogicError)
         << "Returned true (output product to be put in event) from a mix "
            "function\n"
         << "declared with outputProduct=false.\n";
     }
     if (outputInstanceLabel_.empty()) {
       e.put(std::move(rProd));
     } else {
       e.put(std::move(rProd), outputInstanceLabel_);
     }
   } // False means don't want this in the event.
 }

template<typename PROD , typename OPROD >

art::ProductID art::MixOp< PROD, OPROD >::outgoingProductID ( ) const

overridevirtual

Implements art::MixOpBase.

Definition at line 178 of file MixOp.h.

References evd::details::end(), art::InEvent, art::ProductMetaData::instance(), art::errors::LogicError, art::MixOp< PROD, OPROD >::moduleLabel_, art::MixOp< PROD, OPROD >::outputInstanceLabel_, art::MixOp< PROD, OPROD >::outputProduct_, art::MixOp< PROD, OPROD >::processName_, and art::ProductMetaData::productList().

 {
   art::ProductID result;
   if (outputProduct_) {
     TypeID const outputType{typeid(OPROD)};
     BranchKey const key{outputType.friendlyClassName(),
                         moduleLabel_,
                         outputInstanceLabel_,
                         processName_,
                         art::InEvent}; // Outgoing product must be InEvent.
     auto I = ProductMetaData::instance().productList().find(key);
     if (I == ProductMetaData::instance().productList().end()) {
       throw Exception(errors::LogicError)
         << "MixOp unable to find branch id for a product ("
         << outputType.className() << ") that should have been registered!\n";
     }
     result = I->second.productID();
   }
   return result;
 }

template<typename PROD , typename OPROD >

std::string const & art::MixOp< PROD, OPROD >::outputInstanceLabel ( ) const

overridevirtual

Implements art::MixOpBase.

Definition at line 113 of file MixOp.h.

References art::MixOp< PROD, OPROD >::outputInstanceLabel_.

Referenced by art::MixOp< PROD, OPROD >::MixOp().

 {
   return outputInstanceLabel_;
 }

template<typename PROD , typename OPROD >

void art::MixOp< PROD, OPROD >::readFromFile	(	EntryNumberSequence const &	seq,
		cet::exempt_ptr< BranchIDLists const >	branchIDLists
	)

overridevirtual

Implements art::MixOpBase.

Definition at line 201 of file MixOp.h.

References art::RootBranchInfo::branch(), art::MixOp< PROD, OPROD >::branchInfo_, art::MixOpBase::configureStreamers(), e, art::MixOp< PROD, OPROD >::inProducts_, and art::errors::LogicError.

 {
   inProducts_.clear();
   inProducts_.reserve(seq.size());
   if (branchInfo_.branch() == nullptr) {
     throw Exception(errors::LogicError) << "Branch not initialized for read.\n";
   }
   configureStreamers(branchIDLists);
 
   // Assume the sequence is ordered per
   // MixHelper::generateEventSequence.
   auto const b = seq.cbegin(), e = seq.cend();
   for (auto i = b; i != e; ++i) {
     auto fit = std::find(b, i, *i);
     if (fit == i) { // Need new product.
       inProducts_.emplace_back(new Wrapper<PROD>);
       Wrapper<PROD>* wp = inProducts_.back().get();
       branchInfo_.branch()->SetAddress(&wp);
       branchInfo_.branch()->GetEntry(*i);
     } else { // Already have one: find and use.
       auto pit = cbegin(inProducts_);
       std::advance(pit, std::distance(b, fit));
       inProducts_.emplace_back(*pit);
     }
   }
 }