#include <SiStripSpyEventMatcher.h>

Classes
class	CountersWrapper

class	EventKey

struct	MatchingOutput

class	SpyDataCollections

Public Types
typedef edm::EventID	EventID

typedef std::set< EventID >	SpyEventList

Public Member Functions
void	getCollections (const edm::EventPrincipal &event, const uint32_t eventId, const uint8_t apvAddress, const SiStripFedCabling &cabling, MatchingOutput &matchingOutput)

void	getMatchedCollections (const uint32_t eventId, const uint8_t apvAddress, const SpyEventList *matchingEvents, const SiStripFedCabling &cabling, SpyDataCollections &collectionsToCreate)

void	initialize ()

const SpyEventList *	matchesForEvent (const uint32_t eventId, const uint8_t apvAddress) const

	SpyEventMatcher (const edm::ParameterSet &config)

virtual	~SpyEventMatcher ()

Private Types
typedef std::vector< uint32_t >	Counters

typedef std::shared_ptr< CountersWrapper >	CountersPtr

typedef edm::VectorInputSource	Source

Private Member Functions
void	addNextEventToMap (const edm::EventPrincipal &nextSpyEvent)

std::unique_ptr< Source >	constructSource (const edm::ParameterSet &sourceConfig)

void	operator() (const edm::EventPrincipal &event)

Static Private Member Functions
static void	findMatchingFeds (const uint32_t eventId, const uint8_t apvAddress, CountersPtr totalEventCounters, CountersPtr l1aCounters, CountersPtr apvAddresses, std::set< uint16_t > &matchingFeds)

static CountersPtr	getCounters (const edm::EventPrincipal &event, const edm::InputTag &tag, const bool mapKeyIsByFedID=true)

template<class T >
static const T *	getProduct (const edm::EventPrincipal &event, const edm::InputTag &tag)

static void	mergeMatchingData (const std::set< uint16_t > &matchingFeds, const FEDRawDataCollection &inputRawData, CountersPtr inputTotalEventCounters, CountersPtr inputL1ACounters, CountersPtr inputAPVAddresses, const edm::DetSetVector< SiStripRawDigi > inputScopeDigis, const edm::DetSetVector< SiStripRawDigi > inputPayloadDigis, const edm::DetSetVector< SiStripRawDigi > inputReorderedDigis, const edm::DetSetVector< SiStripRawDigi > inputVirginRawDigis, FEDRawDataCollection &outputRawData, std::vector< uint32_t > &outputTotalEventCounters, std::vector< uint32_t > &outputL1ACounters, std::vector< uint32_t > &outputAPVAddresses, std::vector< edm::DetSet< SiStripRawDigi > > outputScopeDigisVector, std::vector< edm::DetSet< SiStripRawDigi > > outputPayloadDigisVector, std::vector< edm::DetSet< SiStripRawDigi > > outputReorderedDigisVector, std::vector< edm::DetSet< SiStripRawDigi > > outputVirginRawDigisVector, const SiStripFedCabling &cabling)

Private Attributes
edm::InputTag	apvAddressesTag_

uint32_t	counterDiffMax_

std::map< EventKey, SpyEventList >	eventMatches_

std::unique_ptr< edm::EventPrincipal >	eventPrincipal_

edm::InputTag	l1aCountersTag_

edm::InputTag	payloadDigisTag_

std::unique_ptr< edm::ProcessConfiguration >	processConfiguration_

std::shared_ptr< edm::ProductRegistry >	productRegistry_

edm::InputTag	rawDataTag_

edm::InputTag	reorderedDigisTag_

edm::InputTag	scopeDigisTag_

const std::unique_ptr< edm::VectorInputSource >	source_

edm::InputTag	totalEventCountersTag_

edm::InputTag	virginRawDigisTag_

Static Private Attributes
static const char *	mlLabel_ = "SpyEventMatcher"

Detailed Description

Definition at line 33 of file SiStripSpyEventMatcher.h.

Member Typedef Documentation

◆ Counters

typedef std::vector<uint32_t> sistrip::SpyEventMatcher::Counters

private

Definition at line 103 of file SiStripSpyEventMatcher.h.

◆ CountersPtr

typedef std::shared_ptr<CountersWrapper> sistrip::SpyEventMatcher::CountersPtr

private

Definition at line 121 of file SiStripSpyEventMatcher.h.

◆ EventID

typedef edm::EventID sistrip::SpyEventMatcher::EventID

Definition at line 69 of file SiStripSpyEventMatcher.h.

◆ Source

typedef edm::VectorInputSource sistrip::SpyEventMatcher::Source

private

Definition at line 124 of file SiStripSpyEventMatcher.h.

◆ SpyEventList

typedef std::set<EventID> sistrip::SpyEventMatcher::SpyEventList

Definition at line 70 of file SiStripSpyEventMatcher.h.

Constructor & Destructor Documentation

◆ SpyEventMatcher()

sistrip::SpyEventMatcher::SpyEventMatcher ( const edm::ParameterSet & config )

Definition at line 47 of file SiStripSpyEventMatcher.cc.

       : rawDataTag_(config.getParameter<edm::InputTag>("RawSpyDataTag")),
         totalEventCountersTag_(config.getParameter<edm::InputTag>("SpyTotalEventCountersTag")),
         l1aCountersTag_(config.getParameter<edm::InputTag>("SpyL1ACountersTag")),
         apvAddressesTag_(config.getParameter<edm::InputTag>("SpyAPVAddressesTag")),
         scopeDigisTag_(config.getParameter<edm::InputTag>("SpyScopeDigisTag")),
         payloadDigisTag_(config.getParameter<edm::InputTag>("SpyPayloadDigisTag")),
         reorderedDigisTag_(config.getParameter<edm::InputTag>("SpyReorderedDigisTag")),
         virginRawDigisTag_(config.getParameter<edm::InputTag>("SpyVirginRawDigisTag")),
         counterDiffMax_(config.getParameter<uint32_t>("CounterDiffMaxAllowed")),
         productRegistry_(new edm::SignallingProductRegistry),
         source_(constructSource(config.getParameter<edm::ParameterSet>("SpySource"))),
         processConfiguration_(
             new edm::ProcessConfiguration(std::string("@MIXING"), edm::getReleaseVersion(), edm::getPassID())),
         eventPrincipal_() {
     // Use the empty parameter set for the parameter set ID of our "@MIXING" process.
     processConfiguration_->setParameterSetID(edm::ParameterSet::emptyParameterSetID());
     productRegistry_->setFrozen();
  
     eventPrincipal_.reset(new edm::EventPrincipal(source_->productRegistry(),
                                                   std::make_shared<edm::BranchIDListHelper>(),
                                                   std::make_shared<edm::ThinnedAssociationsHelper>(),
                                                   *processConfiguration_,
                                                   nullptr));
   }

References edm::ParameterSet::emptyParameterSetID(), eventPrincipal_, processConfiguration_, productRegistry_, and source_.

◆ ~SpyEventMatcher()

sistrip::SpyEventMatcher::~SpyEventMatcher ( )

virtual

Definition at line 45 of file SiStripSpyEventMatcher.cc.

45 {}

Member Function Documentation

◆ addNextEventToMap()

void sistrip::SpyEventMatcher::addNextEventToMap ( const edm::EventPrincipal & nextSpyEvent )

private

Definition at line 104 of file SiStripSpyEventMatcher.cc.

                                                                                {
     edm::EventID spyEventId = nextSpyEvent.id();
  
     CountersPtr totalEventCounters = getCounters(nextSpyEvent, totalEventCountersTag_);
     CountersPtr l1aCounters = getCounters(nextSpyEvent, l1aCountersTag_);
     CountersPtr apvAddresses = getCounters(nextSpyEvent, apvAddressesTag_, false);
     //loop over all FEDs. Maps should have same content and be in order so, avoid searches by iterating (and checking keys match)
     //add all possible event keys to the map
     std::vector<uint32_t>::const_iterator iTotalEventCount = totalEventCounters->begin();
     std::vector<uint32_t>::const_iterator iL1ACount = l1aCounters->begin();
     std::vector<uint32_t>::const_iterator iAPVAddress = apvAddresses->begin();
     //for debug
     std::map<EventKey, uint16_t> fedCounts;
     unsigned int fedid = 0;
     for (; ((iTotalEventCount != totalEventCounters->end()) && (iL1ACount != l1aCounters->end()) &&
             (iAPVAddress != apvAddresses->end()));
          (++iTotalEventCount, ++iL1ACount, ++iAPVAddress, ++fedid)) {
       if (*iAPVAddress == 0) {
         continue;
       }
  
       if (((*iTotalEventCount) > (*iL1ACount)) || ((*iL1ACount) - (*iTotalEventCount) > counterDiffMax_)) {
         LogWarning(mlLabel_) << "Spy event " << spyEventId.event() << " error in counter values for FED " << fedid
                              << ", totCount = " << *iTotalEventCount << ", L1Acount = " << *iL1ACount << std::endl;
  
         continue;
       }
  
       for (uint32_t eventId = (*iTotalEventCount) + 1; eventId <= (*iL1ACount) + 1; ++eventId) {
         EventKey key(eventId, *iAPVAddress);
         eventMatches_[key].insert(spyEventId);
         fedCounts[key]++;
       }
     }
  
     //for debug
     std::ostringstream ss;
     ss << "Spy event " << spyEventId.event() << " matches (eventID,apvAddress,nFEDs): ";
     for (std::map<EventKey, uint16_t>::const_iterator iEventFEDCount = fedCounts.begin();
          iEventFEDCount != fedCounts.end();
          ++iEventFEDCount) {
       ss << "(" << iEventFEDCount->first.eventId() << "," << uint16_t(iEventFEDCount->first.apvAddress()) << ","
          << iEventFEDCount->second << ") ";
     }
     LogDebug(mlLabel_) << ss.str();
   }

References apvAddressesTag_, counterDiffMax_, edm::EventID::event(), eventMatches_, PixelSLinkDataInputSource_cfi::fedid, getCounters(), edm::EventPrincipal::id(), crabWrapper::key, l1aCountersTag_, LogDebug, mlLabel_, contentValuesCheck::ss, and totalEventCountersTag_.

Referenced by initialize().

◆ constructSource()

std::unique_ptr< SpyEventMatcher::Source > sistrip::SpyEventMatcher::constructSource ( const edm::ParameterSet & sourceConfig )

private

Definition at line 73 of file SiStripSpyEventMatcher.cc.

                                                                                                            {
     const edm::VectorInputSourceFactory* sourceFactory = edm::VectorInputSourceFactory::get();
     edm::VectorInputSourceDescription description(productRegistry_, edm::PreallocationConfiguration());
     return sourceFactory->makeVectorInputSource(sourceConfig, description);
   }

References edmLumisInFiles::description, edm::VectorInputSourceFactory::get(), edm::VectorInputSourceFactory::makeVectorInputSource(), and productRegistry_.

◆ findMatchingFeds()

void sistrip::SpyEventMatcher::findMatchingFeds	(	const uint32_t	eventId,
		const uint8_t	apvAddress,
		SpyEventMatcher::CountersPtr	totalEventCounters,
		SpyEventMatcher::CountersPtr	l1aCounters,
		SpyEventMatcher::CountersPtr	apvAddresses,
		std::set< uint16_t > &	matchingFeds
	)

staticprivate

Definition at line 277 of file SiStripSpyEventMatcher.cc.

                                                                          {
     //loop over all FEDs. Maps should have same content and be in order so, avoid searches by iterating (and checking keys match)
     std::vector<uint32_t>::const_iterator iTotalEventCount = totalEventCounters->begin();
     std::vector<uint32_t>::const_iterator iL1ACount = l1aCounters->begin();
     std::vector<uint32_t>::const_iterator iAPVAddress = apvAddresses->begin();
     for (; ((iTotalEventCount != totalEventCounters->end()) && (iL1ACount != l1aCounters->end()) &&
             (iAPVAddress != apvAddresses->end()));
          (++iTotalEventCount, ++iL1ACount, ++iAPVAddress)) {
       if (*iAPVAddress == 0) {
         continue;
       }
       if ((eventId > *iTotalEventCount) && (eventId <= (*iL1ACount) + 1) && (*iAPVAddress == apvAddress)) {
         matchingFeds.insert(matchingFeds.end(), iTotalEventCount - totalEventCounters->begin());
       }
     }
   }

Referenced by getCollections().

◆ getCollections()

void sistrip::SpyEventMatcher::getCollections	(	const edm::EventPrincipal &	event,
		const uint32_t	eventId,
		const uint8_t	apvAddress,
		const SiStripFedCabling &	cabling,
		MatchingOutput &	matchingOutput
	)

Definition at line 171 of file SiStripSpyEventMatcher.cc.

                                                            {
     //read the input collections from the event
     const FEDRawDataCollection* inputRawDataPtr = getProduct<FEDRawDataCollection>(event, rawDataTag_);
     if (!inputRawDataPtr) {
       throw cms::Exception(mlLabel_) << "Failed to get raw spy data with tag " << rawDataTag_ << " from spy event";
     }
     const FEDRawDataCollection& inputRawData = *inputRawDataPtr;
     CountersPtr inputTotalEventCounters = getCounters(event, totalEventCountersTag_);
     CountersPtr inputL1ACounters = getCounters(event, l1aCountersTag_);
     CountersPtr inputAPVAddresses = getCounters(event, apvAddressesTag_, false);
     const edm::DetSetVector<SiStripRawDigi>* inputScopeDigis =
         getProduct<edm::DetSetVector<SiStripRawDigi> >(event, scopeDigisTag_);
     const edm::DetSetVector<SiStripRawDigi>* inputPayloadDigis =
         getProduct<edm::DetSetVector<SiStripRawDigi> >(event, payloadDigisTag_);
     const edm::DetSetVector<SiStripRawDigi>* inputReorderedDigis =
         getProduct<edm::DetSetVector<SiStripRawDigi> >(event, reorderedDigisTag_);
     const edm::DetSetVector<SiStripRawDigi>* inputVirginRawDigis =
         getProduct<edm::DetSetVector<SiStripRawDigi> >(event, virginRawDigisTag_);
     //construct the output vectors if the digis were found and they do not exist
     if (inputScopeDigis && !mo.outputScopeDigisVector_.get())
       mo.outputScopeDigisVector_.reset(new std::vector<edm::DetSet<SiStripRawDigi> >);
     if (inputPayloadDigis && !mo.outputPayloadDigisVector_.get())
       mo.outputPayloadDigisVector_.reset(new std::vector<edm::DetSet<SiStripRawDigi> >);
     if (inputReorderedDigis && !mo.outputReorderedDigisVector_.get())
       mo.outputReorderedDigisVector_.reset(new std::vector<edm::DetSet<SiStripRawDigi> >);
     if (inputVirginRawDigis && !mo.outputVirginRawDigisVector_.get())
       mo.outputVirginRawDigisVector_.reset(new std::vector<edm::DetSet<SiStripRawDigi> >);
     //find matching FEDs
     std::set<uint16_t> matchingFeds;
     findMatchingFeds(eventId, apvAddress, inputTotalEventCounters, inputL1ACounters, inputAPVAddresses, matchingFeds);
     LogInfo(mlLabel_) << "Spy event " << event.id() << " has " << matchingFeds.size() << " matching FEDs";
     std::ostringstream ss;
     ss << "Matching FEDs for event " << event.id() << ": ";
     for (std::set<uint16_t>::const_iterator iFedId = matchingFeds.begin(); iFedId != matchingFeds.end(); ++iFedId) {
       ss << *iFedId << " ";
     }
     LogDebug(mlLabel_) << ss.str();
     //check there are no duplicates
     std::vector<uint16_t> duplicateFeds(std::min(mo.alreadyMergedFeds_.size(), matchingFeds.size()));
     std::vector<uint16_t>::iterator duplicatesBegin = duplicateFeds.begin();
     std::vector<uint16_t>::iterator duplicatesEnd = std::set_intersection(mo.alreadyMergedFeds_.begin(),
                                                                           mo.alreadyMergedFeds_.end(),
                                                                           matchingFeds.begin(),
                                                                           matchingFeds.end(),
                                                                           duplicatesBegin);
     if ((duplicatesEnd - duplicatesBegin) != 0) {
       std::ostringstream ss;
       ss << "Found a match for FEDs ";
       for (std::vector<uint16_t>::const_iterator iDup = duplicatesBegin; iDup != duplicatesEnd; ++iDup) {
         ss << *iDup << " ";
       }
       ss << ". Output SetSetVectors will be unusable!";
       LogError(mlLabel_) << ss.str();
     }
     //merge the matching data
     mergeMatchingData(matchingFeds,
                       inputRawData,
                       inputTotalEventCounters,
                       inputL1ACounters,
                       inputAPVAddresses,
                       inputScopeDigis,
                       inputPayloadDigis,
                       inputReorderedDigis,
                       inputVirginRawDigis,
                       mo.outputRawData_,
                       mo.outputTotalEventCounters_,
                       mo.outputL1ACounters_,
                       mo.outputAPVAddresses_,
                       mo.outputScopeDigisVector_.get(),
                       mo.outputPayloadDigisVector_.get(),
                       mo.outputReorderedDigisVector_.get(),
                       mo.outputVirginRawDigisVector_.get(),
                       cabling);
     mo.alreadyMergedFeds_.insert(matchingFeds.begin(), matchingFeds.end());
   }

Referenced by getMatchedCollections().

◆ getCounters()

SpyEventMatcher::CountersPtr sistrip::SpyEventMatcher::getCounters	(	const edm::EventPrincipal &	event,
		const edm::InputTag &	tag,
		const bool	mapKeyIsByFedID = `true`
	)

staticprivate

Definition at line 391 of file SiStripSpyEventMatcher.cc.

                                                                                         {
     const std::vector<uint32_t>* vectorFromEvent = getProduct<std::vector<uint32_t> >(event, tag);
     if (vectorFromEvent) {
       //vector is from event so, will be deleted when the event is destroyed (and not before)
       return std::make_shared<CountersWrapper>(vectorFromEvent);
     } else {
       const std::map<uint32_t, uint32_t>* mapFromEvent = getProduct<std::map<uint32_t, uint32_t> >(event, tag);
       if (mapFromEvent) {
         std::vector<uint32_t>* newVector = new std::vector<uint32_t>(FED_ID_MAX + 1, 0);
         if (mapKeyIsByFedID) {
           for (std::map<uint32_t, uint32_t>::const_iterator iIdValue = mapFromEvent->begin();
                iIdValue != mapFromEvent->end();
                ++iIdValue) {
             newVector->at(iIdValue->first) = iIdValue->second;
           }
         } else {
           SpyUtilities::fillFEDMajorities(*mapFromEvent, *newVector);
         }
         //  std::cout << " -- Map " << tag << std::endl;
         //  for (uint32_t lIt= 0;
         //       lIt < newVector->size();
         //       lIt++) {
         //    std::cout << lIt << " " << newVector->at(lIt) << std::endl;
         //  }
         //vector was allocated here so, will need to be deleted when finished with
         CountersPtr newCountersPtr(new CountersWrapper(newVector, true));
         return newCountersPtr;
       } else {
         throw cms::Exception(mlLabel_) << "Unable to get product " << tag << " from spy event";
       }
     }
   }

References event(), Exception, sistrip::FED_ID_MAX, sistrip::SpyUtilities::fillFEDMajorities(), mlLabel_, and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by addNextEventToMap(), and getCollections().

◆ getMatchedCollections()

void sistrip::SpyEventMatcher::getMatchedCollections	(	const uint32_t	eventId,
		const uint8_t	apvAddress,
		const SpyEventList *	matchingEvents,
		const SiStripFedCabling &	cabling,
		SpyDataCollections &	collectionsToCreate
	)

Definition at line 251 of file SiStripSpyEventMatcher.cc.

                                                                                        {
     if (!matchingEvents)
       return;
     size_t fileNameHash = 0U;
     FEDRawDataCollection outputRawData;
     MatchingOutput mo(outputRawData);
     source_->loopSpecified(
         *eventPrincipal_,
         fileNameHash,
         matchingEvents->begin(),
         matchingEvents->end(),
         [&](auto const& iE, auto const&) { this->getCollections(iE, eventId, apvAddress, cabling, mo); });
     collectionsToCreate = SpyDataCollections(mo.outputRawData_,
                                              mo.outputTotalEventCounters_,
                                              mo.outputL1ACounters_,
                                              mo.outputAPVAddresses_,
                                              mo.outputScopeDigisVector_.get(),
                                              mo.outputPayloadDigisVector_.get(),
                                              mo.outputReorderedDigisVector_.get(),
                                              mo.outputVirginRawDigisVector_.get());
   }

◆ getProduct()

template<class T >

const T * sistrip::SpyEventMatcher::getProduct	(	const edm::EventPrincipal &	event,
		const edm::InputTag &	tag
	)

staticprivate

Definition at line 178 of file SiStripSpyEventMatcher.h.

                                                                                              {
     LogDebug(mlLabel_) << "Retrieving product " << tag;
     // Note: The third argument to getProductByTag can be a nullptr
     // as long as unscheduled execution of an EDProducer cannot occur
     // as a result of this function call (and with the current implementation
     // of SpyEventMatcher unscheduled execution never happens).
     const std::shared_ptr<const edm::Wrapper<T> > productWrapper = edm::getProductByTag<T>(event, tag, nullptr);
     if (productWrapper) {
       return productWrapper->product();
     } else {
       return nullptr;
     }
   }

References LogDebug, mlLabel_, and GlobalPosition_Frontier_DevDB_cff::tag.

◆ initialize()

void sistrip::SpyEventMatcher::initialize ( )

Definition at line 79 of file SiStripSpyEventMatcher.cc.

                                    {
     size_t fileNameHash = 0U;
     //add spy events to the map until there are none left
     source_->loopOverEvents(
         *eventPrincipal_,
         fileNameHash,
         std::numeric_limits<size_t>::max(),
         [this](auto const& iE, auto const&) {
           this->addNextEventToMap(iE);
           return true;
         },
         nullptr,
         nullptr,
         false);
     //debug
     std::ostringstream ss;
     ss << "Events with possible matches (eventID,apvAddress): ";
     for (std::map<EventKey, SpyEventList>::const_iterator iSpyEvent = eventMatches_.begin();
          iSpyEvent != eventMatches_.end();
          ++iSpyEvent) {
       ss << "(" << iSpyEvent->first.eventId() << "," << uint16_t(iSpyEvent->first.apvAddress()) << ") ";
     }
     LogDebug(mlLabel_) << ss.str();
   }

References addNextEventToMap(), eventMatches_, eventPrincipal_, LogDebug, SiStripPI::max, mlLabel_, source_, contentValuesCheck::ss, and mitigatedMETSequence_cff::U.

◆ matchesForEvent()

const SpyEventMatcher::SpyEventList * sistrip::SpyEventMatcher::matchesForEvent	(	const uint32_t	eventId,
		const uint8_t	apvAddress
	)		const

Definition at line 151 of file SiStripSpyEventMatcher.cc.

                                                                                                         {
     EventKey eventKey(eventId, apvAddress);
     std::map<EventKey, SpyEventList>::const_iterator iMatch = eventMatches_.find(eventKey);
     if (iMatch == eventMatches_.end()) {
       LogDebug(mlLabel_) << "No match found for event " << eventId << " with APV address " << uint16_t(apvAddress);
       return nullptr;
     } else {
       std::ostringstream ss;
       ss << "Found matches to event " << eventId << " with address " << uint16_t(apvAddress) << " in spy events ";
       for (SpyEventList::const_iterator iMatchingSpyEvent = iMatch->second.begin();
            iMatchingSpyEvent != iMatch->second.end();
            ++iMatchingSpyEvent) {
         ss << iMatchingSpyEvent->event() << " ";
       }
       LogInfo(mlLabel_) << ss.str();
       return &(iMatch->second);
     }
   }

References eventMatches_, LogDebug, mlLabel_, and contentValuesCheck::ss.

◆ mergeMatchingData()

void sistrip::SpyEventMatcher::mergeMatchingData	(	const std::set< uint16_t > &	matchingFeds,
		const FEDRawDataCollection &	inputRawData,
		SpyEventMatcher::CountersPtr	inputTotalEventCounters,
		SpyEventMatcher::CountersPtr	inputL1ACounters,
		SpyEventMatcher::CountersPtr	inputAPVAddresses,
		const edm::DetSetVector< SiStripRawDigi > *	inputScopeDigis,
		const edm::DetSetVector< SiStripRawDigi > *	inputPayloadDigis,
		const edm::DetSetVector< SiStripRawDigi > *	inputReorderedDigis,
		const edm::DetSetVector< SiStripRawDigi > *	inputVirginRawDigis,
		FEDRawDataCollection &	outputRawData,
		std::vector< uint32_t > &	outputTotalEventCounters,
		std::vector< uint32_t > &	outputL1ACounters,
		std::vector< uint32_t > &	outputAPVAddresses,
		std::vector< edm::DetSet< SiStripRawDigi > > *	outputScopeDigisVector,
		std::vector< edm::DetSet< SiStripRawDigi > > *	outputPayloadDigisVector,
		std::vector< edm::DetSet< SiStripRawDigi > > *	outputReorderedDigisVector,
		std::vector< edm::DetSet< SiStripRawDigi > > *	outputVirginRawDigisVector,
		const SiStripFedCabling &	cabling
	)

staticprivate

Definition at line 299 of file SiStripSpyEventMatcher.cc.

                                                                             {
     //reserve space in vectors
     if (inputScopeDigis) {
       outputScopeDigisVector->reserve(outputScopeDigisVector->size() +
                                       matchingFeds.size() *
                                           FEDCH_PER_FED);  //maximum number of channels on matching FEDs
     }
     if (inputPayloadDigis) {
       outputPayloadDigisVector->reserve(outputPayloadDigisVector->size() + matchingFeds.size() * FEDCH_PER_FED);
     }
     if (inputReorderedDigis) {
       outputReorderedDigisVector->reserve(outputReorderedDigisVector->size() + matchingFeds.size() * FEDCH_PER_FED);
     }
     if (inputVirginRawDigis) {
       outputVirginRawDigisVector->reserve(outputVirginRawDigisVector->size() +
                                           matchingFeds.size() * FEDCH_PER_FED /
                                               2);  //maximum number of dets on matching FEDs
     }
     //copy the data into output collections
     std::set<uint32_t> usedDetIds;
     for (std::set<uint16_t>::const_iterator iFedId = matchingFeds.begin(); iFedId != matchingFeds.end(); ++iFedId) {
       const uint32_t fedId = *iFedId;
       LogDebug(mlLabel_) << "Copying data for FED " << fedId;
       if (inputRawData.FEDData(fedId).size() && inputRawData.FEDData(fedId).data()) {
         outputRawData.FEDData(fedId) = inputRawData.FEDData(fedId);
       }
       outputTotalEventCounters[fedId] = (*inputTotalEventCounters)[fedId];
       outputL1ACounters[fedId] = (*inputL1ACounters)[fedId];
       outputAPVAddresses[fedId] = (*inputAPVAddresses)[fedId];
       for (uint8_t chan = 0; chan < FEDCH_PER_FED; ++chan) {
         uint32_t fedIndex = ((fedId & sistrip::invalid_) << 16) | (chan & sistrip::invalid_);
         ;
         if (inputScopeDigis) {
           edm::DetSetVector<SiStripRawDigi>::const_iterator iScopeDigis = inputScopeDigis->find(fedIndex);
           if (iScopeDigis != inputScopeDigis->end()) {
             outputScopeDigisVector->push_back(*iScopeDigis);
           }
         }
         if (inputPayloadDigis) {
           edm::DetSetVector<SiStripRawDigi>::const_iterator iPayloadDigis = inputPayloadDigis->find(fedIndex);
           if (iPayloadDigis != inputPayloadDigis->end()) {
             outputPayloadDigisVector->push_back(*iPayloadDigis);
           }
         }
         if (inputReorderedDigis) {
           edm::DetSetVector<SiStripRawDigi>::const_iterator iReorderedDigis = inputReorderedDigis->find(fedIndex);
           if (iReorderedDigis != inputReorderedDigis->end()) {
             outputReorderedDigisVector->push_back(*iReorderedDigis);
           }
         }
       }
       if (inputVirginRawDigis) {
         std::set<uint32_t> fedDetIds;
         auto conns = cabling.fedConnections(fedId);
         for (auto iConn = conns.begin(); iConn != conns.end(); ++iConn) {
           if (!iConn->isConnected())
             continue;
           const uint32_t detId = iConn->detId();
           if (usedDetIds.find(detId) != usedDetIds.end()) {
             LogError(mlLabel_) << "Duplicate DetID found " << detId << " skipping data for this Det from FED " << fedId;
             continue;
           }
           fedDetIds.insert(iConn->detId());
         }
         usedDetIds.insert(fedDetIds.begin(), fedDetIds.end());
         for (std::set<uint32_t>::const_iterator iDetId = fedDetIds.begin(); iDetId != fedDetIds.end(); ++iDetId) {
           edm::DetSetVector<SiStripRawDigi>::const_iterator iVirginRawDigis = inputVirginRawDigis->find(*iDetId);
           if (iVirginRawDigis != inputVirginRawDigis->end()) {
             outputVirginRawDigisVector->push_back(*iVirginRawDigis);
           }
         }
       }
     }
   }

References officialStyle::chan, FEDRawData::data(), edm::DetSetVector< T >::end(), sistrip::FEDCH_PER_FED, SiStripFedCabling::fedConnections(), FEDRawDataCollection::FEDData(), l1tstage2_dqm_sourceclient-live_cfg::fedId, edm::DetSetVector< T >::find(), sistrip::invalid_, LogDebug, mlLabel_, and FEDRawData::size().

Referenced by getCollections().

◆ operator()()

void sistrip::SpyEventMatcher::operator() ( const edm::EventPrincipal & event )

private

Member Data Documentation

◆ apvAddressesTag_

edm::InputTag sistrip::SpyEventMatcher::apvAddressesTag_

private

Definition at line 164 of file SiStripSpyEventMatcher.h.

Referenced by addNextEventToMap(), and getCollections().

◆ counterDiffMax_

uint32_t sistrip::SpyEventMatcher::counterDiffMax_

private

Definition at line 169 of file SiStripSpyEventMatcher.h.

Referenced by addNextEventToMap().

◆ eventMatches_

std::map<EventKey, SpyEventList> sistrip::SpyEventMatcher::eventMatches_

private

Definition at line 160 of file SiStripSpyEventMatcher.h.

Referenced by addNextEventToMap(), initialize(), and matchesForEvent().

◆ eventPrincipal_

std::unique_ptr<edm::EventPrincipal> sistrip::SpyEventMatcher::eventPrincipal_

private

Definition at line 173 of file SiStripSpyEventMatcher.h.

Referenced by getMatchedCollections(), initialize(), and SpyEventMatcher().

◆ l1aCountersTag_

edm::InputTag sistrip::SpyEventMatcher::l1aCountersTag_

private

Definition at line 163 of file SiStripSpyEventMatcher.h.

Referenced by addNextEventToMap(), and getCollections().

◆ mlLabel_

const char * sistrip::SpyEventMatcher::mlLabel_ = "SpyEventMatcher"

staticprivate

Definition at line 174 of file SiStripSpyEventMatcher.h.

Referenced by addNextEventToMap(), getCollections(), getCounters(), getProduct(), initialize(), matchesForEvent(), and mergeMatchingData().

◆ payloadDigisTag_

edm::InputTag sistrip::SpyEventMatcher::payloadDigisTag_

private

Definition at line 166 of file SiStripSpyEventMatcher.h.

Referenced by getCollections().

◆ processConfiguration_

std::unique_ptr<edm::ProcessConfiguration> sistrip::SpyEventMatcher::processConfiguration_

private

Definition at line 172 of file SiStripSpyEventMatcher.h.

Referenced by SpyEventMatcher().

◆ productRegistry_

std::shared_ptr<edm::ProductRegistry> sistrip::SpyEventMatcher::productRegistry_

private

Definition at line 170 of file SiStripSpyEventMatcher.h.

Referenced by constructSource(), and SpyEventMatcher().

◆ rawDataTag_

edm::InputTag sistrip::SpyEventMatcher::rawDataTag_

private

Definition at line 161 of file SiStripSpyEventMatcher.h.

Referenced by getCollections().

◆ reorderedDigisTag_

edm::InputTag sistrip::SpyEventMatcher::reorderedDigisTag_

private

Definition at line 167 of file SiStripSpyEventMatcher.h.

Referenced by getCollections().

◆ scopeDigisTag_

edm::InputTag sistrip::SpyEventMatcher::scopeDigisTag_

private

Definition at line 165 of file SiStripSpyEventMatcher.h.

Referenced by getCollections().

◆ source_

const std::unique_ptr<edm::VectorInputSource> sistrip::SpyEventMatcher::source_

private

Definition at line 171 of file SiStripSpyEventMatcher.h.

Referenced by Config.Process::dumpConfig(), Config.Process::dumpPython(), getMatchedCollections(), initialize(), Config.Process::splitPython(), and SpyEventMatcher().

◆ totalEventCountersTag_

edm::InputTag sistrip::SpyEventMatcher::totalEventCountersTag_

private

Definition at line 162 of file SiStripSpyEventMatcher.h.

Referenced by addNextEventToMap(), and getCollections().

◆ virginRawDigisTag_

edm::InputTag sistrip::SpyEventMatcher::virginRawDigisTag_

private

Definition at line 168 of file SiStripSpyEventMatcher.h.

Referenced by getCollections().

Classes

Public Types

Public Member Functions

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Member Typedef Documentation

◆ Counters

◆ CountersPtr

◆ EventID

◆ Source

◆ SpyEventList

Constructor & Destructor Documentation

◆ SpyEventMatcher()

◆ ~SpyEventMatcher()

Member Function Documentation

◆ addNextEventToMap()

◆ constructSource()

◆ findMatchingFeds()

◆ getCollections()

◆ getCounters()

◆ getMatchedCollections()

◆ getProduct()

◆ initialize()

◆ matchesForEvent()

◆ mergeMatchingData()

◆ operator()()

Member Data Documentation

◆ apvAddressesTag_

◆ counterDiffMax_

◆ eventMatches_

◆ eventPrincipal_

◆ l1aCountersTag_

◆ mlLabel_

◆ payloadDigisTag_

◆ processConfiguration_

◆ productRegistry_

◆ rawDataTag_

◆ reorderedDigisTag_

◆ scopeDigisTag_

◆ source_

◆ totalEventCountersTag_

◆ virginRawDigisTag_