DoubleCollectionMerger< T1, T2, T3, T4 > Class Template Reference

#include <DoubleCollectionMerger.h>

Inheritance diagram for DoubleCollectionMerger< T1, T2, T3, T4 >:

Public Member Functions
	DoubleCollectionMerger (const edm::ParameterSet &)
	~DoubleCollectionMerger () override
Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default
	EDProducer (const EDProducer &)=delete
bool	hasAbilityToProduceInBeginLumis () const final
bool	hasAbilityToProduceInBeginProcessBlocks () const final
bool	hasAbilityToProduceInBeginRuns () const final
bool	hasAbilityToProduceInEndLumis () const final
bool	hasAbilityToProduceInEndProcessBlocks () const final
bool	hasAbilityToProduceInEndRuns () const final
const EDProducer &	operator= (const EDProducer &)=delete

Private Types
typedef T2	BaseHit1
typedef T4	BaseHit2
typedef T1	MergeCollection1
typedef T3	MergeCollection2

Private Member Functions
void	fill_output_obj (std::unique_ptr< MergeCollection1 > &output1, std::vector< edm::Handle< MergeCollection1 >> &inputCollections1)
void	fill_output_obj (std::unique_ptr< MergeCollection2 > &output2, std::vector< edm::Handle< MergeCollection2 >> &inputCollections2)
template<>
void	fill_output_obj (std::unique_ptr< MergeCollection1 > &output, std::vector< edm::Handle< MergeCollection1 >> &inputCollections)
template<>
void	fill_output_obj (std::unique_ptr< MergeCollection2 > &output, std::vector< edm::Handle< MergeCollection2 >> &inputCollections)
template<>
void	fill_output_obj (std::unique_ptr< MergeCollection1 > &output, std::vector< edm::Handle< MergeCollection1 >> &inputCollections)
template<>
void	fill_output_obj (std::unique_ptr< MergeCollection2 > &output, std::vector< edm::Handle< MergeCollection2 >> &inputCollections)
void	fill_output_obj_digiflag (std::unique_ptr< MergeCollection1 > &output, std::vector< edm::Handle< MergeCollection1 >> &inputCollections)
void	fill_output_obj_digiflag (std::unique_ptr< MergeCollection2 > &output, std::vector< edm::Handle< MergeCollection2 >> &inputCollections)
void	fill_output_obj_hcaldigi (std::unique_ptr< MergeCollection1 > &output, std::vector< edm::Handle< MergeCollection1 >> &inputCollections)
void	fill_output_obj_hcaldigi (std::unique_ptr< MergeCollection2 > &output, std::vector< edm::Handle< MergeCollection2 >> &inputCollections)
void	produce (edm::Event &, const edm::EventSetup &) override

Private Attributes
std::map< std::string, std::vector< edm::EDGetTokenT< MergeCollection1 > > >	inputs1_
std::map< std::string, std::vector< edm::EDGetTokenT< MergeCollection2 > > >	inputs2_

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer<>
using	CacheTypes = CacheContexts< T... >
using	GlobalCache = typename CacheTypes::GlobalCache
using	HasAbility = AbilityChecker< T... >
using	InputProcessBlockCache = typename CacheTypes::InputProcessBlockCache
using	LuminosityBlockCache = typename CacheTypes::LuminosityBlockCache
using	LuminosityBlockContext = LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >
using	LuminosityBlockSummaryCache = typename CacheTypes::LuminosityBlockSummaryCache
using	RunCache = typename CacheTypes::RunCache
using	RunContext = RunContextT< RunCache, GlobalCache >
using	RunSummaryCache = typename CacheTypes::RunSummaryCache

Detailed Description

template<typename T1, typename T2, typename T3, typename T4>
class DoubleCollectionMerger< T1, T2, T3, T4 >

Author

Per Ahrens

Clean Up from Christian Winter & Sebastian Brommer, KIT

Definition at line 24 of file DoubleCollectionMerger.h.

Member Typedef Documentation

BaseHit1

template<typename T1 , typename T2 , typename T3 , typename T4 >

typedef T2 DoubleCollectionMerger< T1, T2, T3, T4 >::BaseHit1

private

Definition at line 33 of file DoubleCollectionMerger.h.

BaseHit2

template<typename T1 , typename T2 , typename T3 , typename T4 >

typedef T4 DoubleCollectionMerger< T1, T2, T3, T4 >::BaseHit2

private

Definition at line 35 of file DoubleCollectionMerger.h.

MergeCollection1

template<typename T1 , typename T2 , typename T3 , typename T4 >

typedef T1 DoubleCollectionMerger< T1, T2, T3, T4 >::MergeCollection1

private

Definition at line 32 of file DoubleCollectionMerger.h.

MergeCollection2

template<typename T1 , typename T2 , typename T3 , typename T4 >

typedef T3 DoubleCollectionMerger< T1, T2, T3, T4 >::MergeCollection2

private

Definition at line 34 of file DoubleCollectionMerger.h.

Constructor & Destructor Documentation

DoubleCollectionMerger()

template<typename T1 , typename T2 , typename T3 , typename T4 >

DoubleCollectionMerger< T1, T2, T3, T4 >::DoubleCollectionMerger ( const edm::ParameterSet &  iConfig )

explicit

Definition at line 20 of file DoubleCollectionMerger.cc.

References edm::ParameterSet::getParameter().

                                                                                             {
  std::vector<edm::InputTag> inCollections = iConfig.getParameter<std::vector<edm::InputTag>>("mergCollections");
  for (auto const &inCollection : inCollections) {
    inputs1_[inCollection.instance()].push_back(consumes<MergeCollection1>(inCollection));
    inputs2_[inCollection.instance()].push_back(consumes<MergeCollection2>(inCollection));
  }
  for (const auto &toproduce : inputs1_) {
    produces<MergeCollection1>(toproduce.first);
  }
  for (const auto &toproduce : inputs2_) {
    produces<MergeCollection2>(toproduce.first);
  }
}

~DoubleCollectionMerger()

template<typename T1 , typename T2 , typename T3 , typename T4 >

DoubleCollectionMerger< T1, T2, T3, T4 >::~DoubleCollectionMerger ( )

override

Definition at line 35 of file DoubleCollectionMerger.cc.

                                                                {
  // nothing to be done yet...
}

Member Function Documentation

fill_output_obj() [1/6]

template<typename T1 , typename T2 , typename T3 , typename T4 >

void DoubleCollectionMerger< T1, T2, T3, T4 >::fill_output_obj ( std::unique_ptr< MergeCollection1 > &  output1, std::vector< edm::Handle< MergeCollection1 >> &  inputCollections1  )

private

Definition at line 65 of file DoubleCollectionMerger.cc.

References cms::cuda::assert().

                                                                                                       {
  assert(0);
}

fill_output_obj() [2/6]

template<typename T1 , typename T2 , typename T3 , typename T4 >

void DoubleCollectionMerger< T1, T2, T3, T4 >::fill_output_obj ( std::unique_ptr< MergeCollection2 > &  output2, std::vector< edm::Handle< MergeCollection2 >> &  inputCollections2  )

private

Definition at line 71 of file DoubleCollectionMerger.cc.

References cms::cuda::assert().

                                                                                                       {
  assert(0);
}

fill_output_obj() [3/6]

template<>

void DoubleCollectionMerger< edm::SortedCollection< EESrFlag >, EESrFlag, edm::SortedCollection< EBSrFlag >, EBSrFlag >::fill_output_obj ( std::unique_ptr< MergeCollection1 > &  output, std::vector< edm::Handle< MergeCollection1 >> &  inputCollections  )

private

Definition at line 178 of file DoubleCollectionMerger.cc.

                                                                              {
  fill_output_obj_digiflag(output, inputCollections);
}

fill_output_obj() [4/6]

template<>

void DoubleCollectionMerger< edm::SortedCollection< EESrFlag >, EESrFlag, edm::SortedCollection< EBSrFlag >, EBSrFlag >::fill_output_obj ( std::unique_ptr< MergeCollection2 > &  output, std::vector< edm::Handle< MergeCollection2 >> &  inputCollections  )

private

Definition at line 185 of file DoubleCollectionMerger.cc.

                                                                              {
  fill_output_obj_digiflag(output, inputCollections);
}

fill_output_obj() [5/6]

template<>

void DoubleCollectionMerger< HBHEDigiCollection, HBHEDataFrame, HcalCalibDigiCollection, HcalCalibDataFrame >::fill_output_obj ( std::unique_ptr< MergeCollection1 > &  output, std::vector< edm::Handle< MergeCollection1 >> &  inputCollections  )

private

Definition at line 192 of file DoubleCollectionMerger.cc.

                                                                              {
  fill_output_obj_hcaldigi(output, inputCollections);
}

fill_output_obj() [6/6]

template<>

void DoubleCollectionMerger< HBHEDigiCollection, HBHEDataFrame, HcalCalibDigiCollection, HcalCalibDataFrame >::fill_output_obj ( std::unique_ptr< MergeCollection2 > &  output, std::vector< edm::Handle< MergeCollection2 >> &  inputCollections  )

private

Definition at line 199 of file DoubleCollectionMerger.cc.

                                                                              {
  fill_output_obj_hcaldigi(output, inputCollections);
}

fill_output_obj_digiflag() [1/2]

template<typename T1 , typename T2 , typename T3 , typename T4 >

void DoubleCollectionMerger< T1, T2, T3, T4 >::fill_output_obj_digiflag ( std::unique_ptr< MergeCollection1 > &  output, std::vector< edm::Handle< MergeCollection1 >> &  inputCollections  )

private

Definition at line 77 of file DoubleCollectionMerger.cc.

References HLT_2024v14_cff::inputCollection, ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, SiStripPI::max, getGTfromDQMFile::obj, and or.

                                                                                                       {
  std::map<uint32_t, BaseHit1> output_map;

  // First merge the two collections again
  for (auto const &inputCollection : inputCollections) {
    for (typename MergeCollection1::const_iterator obj = inputCollection->begin(); obj != inputCollection->end();
         ++obj) {
      DetId detIdObject(obj->id().rawId());

      std::map<uint32_t, EESrFlag>::iterator it = output_map.find(detIdObject.rawId());
      if (it == output_map.end()) {
        BaseHit1 *akt_flag_obj = &output_map[detIdObject.rawId()];
        const T2 &newSrFlag(*obj);
        *akt_flag_obj = newSrFlag;
      } else {
        // re-determine flag
        BaseHit1 preFlag = it->second;
        BaseHit1 *akt_flag_obj = &output_map[detIdObject.rawId()];
        T2 newSrFlag(*obj);

        newSrFlag.setValue(std::max(obj->value(), preFlag.value()));
        if (preFlag.value() == 3 or obj->value() == 3)
          newSrFlag.setValue(3);
        if (preFlag.value() == 7 or obj->value() == 7)
          newSrFlag.setValue(7);

        *akt_flag_obj = newSrFlag;
      }
    }
  }

  // Now save it into the standard CMSSW format
  for (typename std::map<uint32_t, BaseHit1>::const_iterator outFlags = output_map.begin();
       outFlags != output_map.end();
       ++outFlags) {
    BaseHit1 currFlag = outFlags->second;
    output->push_back(outFlags->second);
  }
  output->sort();  // Do a sort for this collection
}

fill_output_obj_digiflag() [2/2]

template<typename T1 , typename T2 , typename T3 , typename T4 >

void DoubleCollectionMerger< T1, T2, T3, T4 >::fill_output_obj_digiflag ( std::unique_ptr< MergeCollection2 > &  output, std::vector< edm::Handle< MergeCollection2 >> &  inputCollections  )

private

Definition at line 120 of file DoubleCollectionMerger.cc.

References HLT_2024v14_cff::inputCollection, ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, SiStripPI::max, getGTfromDQMFile::obj, and or.

                                                                                                       {
  std::map<uint32_t, BaseHit2> output_map;

  // First merge the two collections again
  for (auto const &inputCollection : inputCollections) {
    for (typename MergeCollection2::const_iterator obj = inputCollection->begin(); obj != inputCollection->end();
         ++obj) {
      DetId detIdObject(obj->id().rawId());

      std::map<uint32_t, EBSrFlag>::iterator it = output_map.find(detIdObject.rawId());
      if (it == output_map.end()) {
        BaseHit2 *akt_flag_obj = &output_map[detIdObject.rawId()];
        const T4 &newSrFlag(*obj);
        *akt_flag_obj = newSrFlag;
      } else {
        // re-determine flag
        BaseHit2 preFlag = it->second;
        BaseHit2 *akt_flag_obj = &output_map[detIdObject.rawId()];
        T4 newSrFlag(*obj);

        newSrFlag.setValue(std::max(obj->value(), preFlag.value()));
        if (preFlag.value() == 3 or obj->value() == 3)
          newSrFlag.setValue(3);
        if (preFlag.value() == 7 or obj->value() == 7)
          newSrFlag.setValue(7);

        *akt_flag_obj = newSrFlag;
      }
    }
  }

  // Now save it into the standard CMSSW format
  for (typename std::map<uint32_t, BaseHit2>::const_iterator outFlags = output_map.begin();
       outFlags != output_map.end();
       ++outFlags) {
    BaseHit2 currFlag = outFlags->second;
    output->push_back(outFlags->second);
  }
  output->sort();  // Do a sort for this collection
}

fill_output_obj_hcaldigi() [1/2]

template<typename T1 , typename T2 , typename T3 , typename T4 >

void DoubleCollectionMerger< T1, T2, T3, T4 >::fill_output_obj_hcaldigi ( std::unique_ptr< MergeCollection1 > &  output, std::vector< edm::Handle< MergeCollection1 >> &  inputCollections  )

private

Definition at line 163 of file DoubleCollectionMerger.cc.

                                                                                                       {
  // TODO: implement proper merging, only skeleton for the time-being
  return;
}

fill_output_obj_hcaldigi() [2/2]

template<typename T1 , typename T2 , typename T3 , typename T4 >

void DoubleCollectionMerger< T1, T2, T3, T4 >::fill_output_obj_hcaldigi ( std::unique_ptr< MergeCollection2 > &  output, std::vector< edm::Handle< MergeCollection2 >> &  inputCollections  )

private

Definition at line 170 of file DoubleCollectionMerger.cc.

                                                                                                       {
  // TODO: implement proper merging, only skeleton for the time-being
  return;
}

produce()

template<typename T1 , typename T2 , typename T3 , typename T4 >

void DoubleCollectionMerger< T1, T2, T3, T4 >::produce ( edm::Event &  iEvent, const edm::EventSetup &  iSetup  )

overrideprivate

Definition at line 40 of file DoubleCollectionMerger.cc.

References iEvent, eostools::move(), and convertSQLitetoXML_cfg::output.

                                                                                                  {
  for (auto input_ : inputs1_) {
    std::unique_ptr<MergeCollection1> output(new MergeCollection1());
    std::vector<edm::Handle<MergeCollection1>> inputCollections;
    inputCollections.resize(input_.second.size());
    for (unsigned id = 0; id < input_.second.size(); id++) {
      iEvent.getByToken(input_.second[id], inputCollections[id]);
    }
    fill_output_obj(output, inputCollections);
    iEvent.put(std::move(output), input_.first);
  }

  for (auto input_ : inputs2_) {
    std::unique_ptr<MergeCollection2> output(new MergeCollection2());
    std::vector<edm::Handle<MergeCollection2>> inputCollections;
    inputCollections.resize(input_.second.size());
    for (unsigned id = 0; id < input_.second.size(); id++) {
      iEvent.getByToken(input_.second[id], inputCollections[id]);
    }
    fill_output_obj(output, inputCollections);
    iEvent.put(std::move(output), input_.first);
  }
}

Member Data Documentation

inputs1_

template<typename T1 , typename T2 , typename T3 , typename T4 >

std::map<std::string, std::vector<edm::EDGetTokenT<MergeCollection1> > > DoubleCollectionMerger< T1, T2, T3, T4 >::inputs1_

private

Definition at line 36 of file DoubleCollectionMerger.h.

inputs2_

template<typename T1 , typename T2 , typename T3 , typename T4 >

std::map<std::string, std::vector<edm::EDGetTokenT<MergeCollection2> > > DoubleCollectionMerger< T1, T2, T3, T4 >::inputs2_

private

Definition at line 37 of file DoubleCollectionMerger.h.