RPCLinkSynchroStat Class Reference

#include <RPCLinkSynchroStat.h>

Classes
struct	LessCountSum
struct	LessLinkName
class	LinkBoard
struct	ShortLinkInfo
class	SynchroCounts

Public Member Functions
void	add (const RPCRawSynchro::ProdItem &counts, std::vector< LinkBoardElectronicIndex > &problems)
void	add (const std::string &lbName, const unsigned int *hits)
std::string	dumpDelays ()
void	init (const RPCReadOutMapping *theCabling, bool addChamberInfo)
	RPCLinkSynchroStat (bool useFirstHitOnly)
virtual	~RPCLinkSynchroStat ()

Protected Types
typedef std::pair< LinkBoard, SynchroCounts >	BoardAndCounts

Protected Attributes
std::vector< BoardAndCounts >	theLinkStatMap
unsigned int	theLinkStatNavi [MAXDCCINDEX+1][MAXRBCINDEX+1][MAXLINKINDEX+1][MAXLBINDEX+1]
bool	theUseFirstHitOnly

Static Protected Attributes
static const unsigned int	DCCINDEXSHIFT = 790
static const unsigned int	MAXDCCINDEX = 2
static const unsigned int	MAXLBINDEX = 2
static const unsigned int	MAXLINKINDEX = 17
static const unsigned int	MAXRBCINDEX = 35

Friends
class	RPCLinkSynchroHistoMaker

Detailed Description

Definition at line 11 of file RPCLinkSynchroStat.h.

Member Typedef Documentation

BoardAndCounts

typedef std::pair<LinkBoard, SynchroCounts> RPCLinkSynchroStat::BoardAndCounts

protected

Definition at line 68 of file RPCLinkSynchroStat.h.

Constructor & Destructor Documentation

RPCLinkSynchroStat()

RPCLinkSynchroStat::RPCLinkSynchroStat

(

bool

useFirstHitOnly

)

Definition at line 116 of file RPCLinkSynchroStat.cc.

                                                           : theUseFirstHitOnly(useFirstFitOnly) {
  for (unsigned int i1 = 0; i1 <= MAXDCCINDEX; ++i1) {
    for (unsigned int i2 = 0; i2 <= MAXRBCINDEX; i2++) {
      for (unsigned int i3 = 0; i3 <= MAXLINKINDEX; ++i3) {
        for (unsigned int i4 = 0; i4 <= MAXLBINDEX; ++i4) {
          theLinkStatNavi[i1][i2][i3][i4] = 0;
        }
      }
    }
  }
  theLinkStatMap.push_back(std::make_pair(LinkBoard("Dummy"), SynchroCounts()));
}

References testProducerWithPsetDescEmpty_cfi::i1, testProducerWithPsetDescEmpty_cfi::i2, testProducerWithPsetDescEmpty_cfi::i3, MAXDCCINDEX, MAXLBINDEX, MAXLINKINDEX, MAXRBCINDEX, theLinkStatMap, and theLinkStatNavi.

~RPCLinkSynchroStat()

virtual RPCLinkSynchroStat::~RPCLinkSynchroStat ( )

inlinevirtual

Definition at line 15 of file RPCLinkSynchroStat.h.

{}

Member Function Documentation

add() [1/2]

void RPCLinkSynchroStat::add	(	const RPCRawSynchro::ProdItem &	counts,
		std::vector< LinkBoardElectronicIndex > &	problems
	)

Definition at line 174 of file RPCLinkSynchroStat.cc.

                                                                                                              {
  std::vector<int> hits(theLinkStatMap.size(), 0);
  std::vector<ShortLinkInfo> slis;
  for (auto it = vItem.begin(); it != vItem.end(); ++it) {
    const LinkBoardElectronicIndex& path = it->first;
    unsigned int bxDiff = it->second;
    unsigned int eleCode = (path.dccId - DCCINDEXSHIFT) * 100000 + path.dccInputChannelNum * 1000 +
                           path.tbLinkInputNum * 10 + path.lbNumInLink;
    unsigned int idx =
        theLinkStatNavi[path.dccId - DCCINDEXSHIFT][path.dccInputChannelNum][path.tbLinkInputNum][path.lbNumInLink];
    if (hits[idx] == 0) {
      ShortLinkInfo sli = {idx, std::vector<unsigned int>(1, eleCode), SynchroCounts()};
      slis.push_back(sli);
      hits[idx] = slis.size();
    } else {
      std::vector<unsigned int>& v = slis[hits[idx] - 1].hit_paths;
      std::vector<unsigned int>::iterator iv = lower_bound(v.begin(), v.end(), eleCode);
      if (iv == v.end() || (*iv) != eleCode)
        v.insert(iv, eleCode);
    }
    slis[hits[idx] - 1].counts.set(bxDiff);  // ensure one count per LB per BX
  }
 
  for (auto ic = slis.begin(); ic != slis.end(); ++ic) {
    if (theUseFirstHitOnly) {
      theLinkStatMap[ic->idx].second.increment(ic->counts.firstHit());  // first hit only
    } else {
      theLinkStatMap[ic->idx].second += ic->counts;
    }
    if (theLinkStatMap[ic->idx].first.paths().size() != ic->hit_paths.size()) {
      const std::vector<LinkBoardElectronicIndex>& paths = theLinkStatMap[ic->idx].first.paths();
      problems.insert(problems.end(), paths.begin(), paths.end());
    }
  }
}

References DCCINDEXSHIFT, hfClusterShapes_cfi::hits, heavyIonCSV_trainingSettings::idx, if(), gpuVertexFinder::iv, pfDeepBoostedJetPreprocessParams_cfi::lower_bound, castor_dqm_sourceclient_file_cfg::path, Skims_PA_cff::paths, edmOneToOneComparison::problems, theLinkStatMap, theLinkStatNavi, theUseFirstHitOnly, and findQualityFiles::v.

Referenced by RPCMonitorLinkSynchro::analyze(), counter.Counter::register(), SequenceTypes.Task::remove(), and SequenceTypes.Task::replace().

add() [2/2]

void RPCLinkSynchroStat::add	(	const std::string &	lbName,
		const unsigned int *	hits
	)

Definition at line 18 of file RPCLinkSynchroStat.cc.

                                                                              {
  LinkBoard lb(lbName);
  SynchroCounts counts(hits);
  for (auto it = theLinkStatMap.begin(); it != theLinkStatMap.end(); ++it)
    if (it->first == lb)
      it->second += counts;
}

References dqmiodumpmetadata::counts, hfClusterShapes_cfi::hits, and theLinkStatMap.

Referenced by counter.Counter::register(), SequenceTypes.Task::remove(), and SequenceTypes.Task::replace().

dumpDelays()

std::string RPCLinkSynchroStat::dumpDelays

(

)

Definition at line 210 of file RPCLinkSynchroStat.cc.

                                         {
  std::ostringstream str;
  std::vector<BoardAndCounts> sortedStat = theLinkStatMap;
  stable_sort(sortedStat.begin(), sortedStat.end(), LessCountSum());
  for (unsigned int idx = 0; idx < sortedStat.size(); ++idx) {
    const LinkBoard& board = sortedStat[idx].first;
    const SynchroCounts& counts = sortedStat[idx].second;
 
    // DUMP LINKNAME
    str << std::setw(20) << board.name();
 
    // DUMP COUNTS
    str << " " << counts.print();
 
    //PATHS
    str << " paths: ";
    const std::vector<LinkBoardElectronicIndex>& paths = board.paths();
    for (auto ip = paths.begin(); ip != paths.end(); ++ip)
      str << "{" << ip->dccId << "," << std::setw(2) << ip->dccInputChannelNum << "," << std::setw(2)
          << ip->tbLinkInputNum << "," << ip->lbNumInLink << "}";
 
    // DUMP CHAMBERS
    std::map<std::string, std::vector<std::string> > chMap;
    const std::vector<LinkBoard::ChamberAndPartition>& chamberAndPartitions = board.chamberAndPartitions();
    for (auto it = chamberAndPartitions.begin(); it != chamberAndPartitions.end(); ++it) {
      std::vector<std::string>& partitions = chMap[it->first];
      if (find(partitions.begin(), partitions.end(), it->second) == partitions.end())
        partitions.push_back(it->second);
    }
    str << " chambers: ";
    for (auto im = chMap.begin(); im != chMap.end(); ++im) {
      str << im->first << "(";
      for (std::vector<std::string>::const_iterator ip = im->second.begin(); ip != im->second.end(); ++ip) {
        str << *ip;
        if ((ip + 1) != (im->second.end()))
          str << ",";
        else
          str << ")";
      }
    }
 
    str << std::endl;
  }
  LogTrace("RPCLinkSynchroStat") << "RPCLinkSynchroStat::dumpDelays,  SIZE OF LINKS IS: " << theLinkStatMap.size()
                                 << std::endl;
  return str.str();
}

References RPCLinkSynchroStat::LinkBoard::chamberAndPartitions(), dqmiodumpmetadata::counts, spr::find(), heavyIonCSV_trainingSettings::idx, LogTrace, RPCLinkSynchroStat::LinkBoard::name(), Skims_PA_cff::paths, RPCLinkSynchroStat::LinkBoard::paths(), str, and theLinkStatMap.

init()

void RPCLinkSynchroStat::init	(	const RPCReadOutMapping *	theCabling,
		bool	addChamberInfo
	)

Definition at line 129 of file RPCLinkSynchroStat.cc.

                                                                                      {
  if (!theCabling)
    return;
  std::vector<const DccSpec*> dccs = theCabling->dccList();
  for (auto it1 = dccs.begin(); it1 != dccs.end(); ++it1) {
    const std::vector<TriggerBoardSpec>& rmbs = (*it1)->triggerBoards();
    for (auto it2 = rmbs.begin(); it2 != rmbs.end(); ++it2) {
      const std::vector<LinkConnSpec>& links = it2->linkConns();
      for (auto it3 = links.begin(); it3 != links.end(); ++it3) {
        const std::vector<LinkBoardSpec>& lbs = it3->linkBoards();
        for (auto it4 = lbs.begin(); it4 != lbs.end(); ++it4) {
          LinkBoardElectronicIndex ele = {
              (*it1)->id(), it2->dccInputChannelNum(), it3->triggerBoardInputNumber(), it4->linkBoardNumInLink()};
          LinkBoard linkBoard(it4->linkBoardName());
          BoardAndCounts candid = std::make_pair(linkBoard, SynchroCounts());
          std::vector<BoardAndCounts>::iterator candid_place =
              lower_bound(theLinkStatMap.begin(), theLinkStatMap.end(), candid, LessLinkName());
          if (candid_place != theLinkStatMap.end() && candid.first == candid_place->first) {
            candid_place->first.add(ele);
          } else {
            candid_place = theLinkStatMap.insert(candid_place, candid);
            candid_place->first.add(ele);
            if (addChamberInfo) {
              const std::vector<FebConnectorSpec>& febs = it4->febs();
              for (std::vector<FebConnectorSpec>::const_iterator it5 = febs.begin(); it5 != febs.end(); ++it5) {
                std::string chamberName = it5->chamber().chamberLocationName();
                std::string partitionName = it5->feb().localEtaPartitionName();
                LinkBoard::ChamberAndPartition chamberAndPartition = std::make_pair(chamberName, partitionName);
                candid_place->first.add(chamberAndPartition);
              }
            }
          }
        }
      }
    }
  }
  for (unsigned int idx = 0; idx < theLinkStatMap.size(); ++idx) {
    const std::vector<LinkBoardElectronicIndex>& paths = theLinkStatMap[idx].first.paths();
    for (auto it = paths.begin(); it != paths.end(); ++it) {
      theLinkStatNavi[it->dccId - DCCINDEXSHIFT][it->dccInputChannelNum][it->tbLinkInputNum][it->lbNumInLink] = idx;
    }
  }
  //  LogTrace("RPCLinkSynchroStat") <<" SIZE OF LINKS IS: " << theLinkStatMap.size() << endl;
}

References DCCINDEXSHIFT, LinkBoardElectronicIndex::dccInputChannelNum, RPCReadOutMapping::dccList(), heavyIonCSV_trainingSettings::idx, electronStore::links, pfDeepBoostedJetPreprocessParams_cfi::lower_bound, FrameHeaderEvents_cfi::partitionName, Skims_PA_cff::paths, AlCaHLTBitMon_QueryRunRegistry::string, theLinkStatMap, and theLinkStatNavi.

Referenced by RPCMonitorLinkSynchro::dqmBeginRun().

Friends And Related Function Documentation

RPCLinkSynchroHistoMaker

friend class RPCLinkSynchroHistoMaker

friend

Definition at line 91 of file RPCLinkSynchroStat.h.

Member Data Documentation

DCCINDEXSHIFT

const unsigned int RPCLinkSynchroStat::DCCINDEXSHIFT = 790

staticprotected

Definition at line 84 of file RPCLinkSynchroStat.h.

Referenced by add(), and init().

MAXDCCINDEX

const unsigned int RPCLinkSynchroStat::MAXDCCINDEX = 2

staticprotected

Definition at line 83 of file RPCLinkSynchroStat.h.

Referenced by RPCLinkSynchroStat().

MAXLBINDEX

const unsigned int RPCLinkSynchroStat::MAXLBINDEX = 2

staticprotected

Definition at line 87 of file RPCLinkSynchroStat.h.

Referenced by RPCLinkSynchroStat().

MAXLINKINDEX

const unsigned int RPCLinkSynchroStat::MAXLINKINDEX = 17

staticprotected

Definition at line 86 of file RPCLinkSynchroStat.h.

Referenced by RPCLinkSynchroStat().

MAXRBCINDEX

const unsigned int RPCLinkSynchroStat::MAXRBCINDEX = 35

staticprotected

Definition at line 85 of file RPCLinkSynchroStat.h.

Referenced by RPCLinkSynchroStat().

theLinkStatMap

std::vector<BoardAndCounts> RPCLinkSynchroStat::theLinkStatMap

protected

Definition at line 89 of file RPCLinkSynchroStat.h.

Referenced by add(), dumpDelays(), RPCLinkSynchroHistoMaker::fill(), init(), and RPCLinkSynchroStat().

theLinkStatNavi

unsigned int RPCLinkSynchroStat::theLinkStatNavi[MAXDCCINDEX+1][MAXRBCINDEX+1][MAXLINKINDEX+1][MAXLBINDEX+1]

protected

Definition at line 88 of file RPCLinkSynchroStat.h.

Referenced by add(), init(), and RPCLinkSynchroStat().

theUseFirstHitOnly

bool RPCLinkSynchroStat::theUseFirstHitOnly

protected

Definition at line 81 of file RPCLinkSynchroStat.h.

Referenced by add().