CMS 3D CMS Logo

List of all members | Classes | Public Types | Public Member Functions | Private Attributes
perftools::EdmEventSize Class Reference

#include <EdmEventSize.h>

Classes

struct  BranchRecord
 the information for each branch More...
 
struct  Error
 generic exception More...
 

Public Types

typedef std::vector< BranchRecordBranches
 

Public Member Functions

void dump (std::ostream &co, bool header=true) const
 dump the ascii table on "co" More...
 
 EdmEventSize ()
 Constructor. More...
 
 EdmEventSize (std::string const &fileName, std::string const &treeName="Events")
 Constructor and parse. More...
 
void formatNames ()
 transform Branch names in "formatted" prodcut identifiers More...
 
void parseFile (std::string const &fileName, std::string const &treeName="Events")
 read file, compute branch size, sort by size More...
 
void produceHistos (std::string const &plot, std::string const &file, int top=0) const
 produce histograms and optionally write them in "file" or as "plot" More...
 
void sortAlpha ()
 sort by name More...
 

Private Attributes

Branches m_branches
 
std::string m_fileName
 
int m_nEvents
 

Detailed Description

Measure the size of each product in an edm::event Provides the output as an ascii table or root histograms

Based on the original implementation by Luca Lista

Algorithm: Measure the size of each branch in a tree as the sum of the sizes of all its baskets Estimate the "size in memory" multipling the actual branch size by its compression factor

Author
Vincenzo Innocente

Definition at line 24 of file EdmEventSize.h.

Member Typedef Documentation

◆ Branches

Definition at line 44 of file EdmEventSize.h.

Constructor & Destructor Documentation

◆ EdmEventSize() [1/2]

perftools::EdmEventSize::EdmEventSize ( )

Constructor.

Definition at line 73 of file EdmEventSize.cc.

73 : m_nEvents(0) {}

◆ EdmEventSize() [2/2]

perftools::EdmEventSize::EdmEventSize ( std::string const &  fileName,
std::string const &  treeName = "Events" 
)
explicit

Constructor and parse.

Definition at line 75 of file EdmEventSize.cc.

75  : m_nEvents(0) {
77  }

References MillePedeFileConverter_cfg::fileName, and parseFile().

Member Function Documentation

◆ dump()

void perftools::EdmEventSize::dump ( std::ostream &  co,
bool  header = true 
) const

dump the ascii table on "co"

Definition at line 161 of file EdmEventSize.cc.

161  {
162  if (header) {
163  co << "File " << m_fileName << " Events " << m_nEvents << "\n";
164  co << "Branch Name | Average Uncompressed Size (Bytes/Event) | Average Compressed Size (Bytes/Event) \n";
165  }
166  std::for_each(m_branches.begin(), m_branches.end(), boost::bind(detail::dump, boost::ref(co), _1));
167  }

References cms::cuda::co, perftools::detail::dump(), RecoTauValidation_cfi::header, m_branches, m_fileName, and m_nEvents.

◆ formatNames()

void perftools::EdmEventSize::formatNames ( )

transform Branch names in "formatted" prodcut identifiers

Definition at line 152 of file EdmEventSize.cc.

152 { std::for_each(m_branches.begin(), m_branches.end(), &detail::shorterName); }

References m_branches, and perftools::detail::shorterName().

◆ parseFile()

void perftools::EdmEventSize::parseFile ( std::string const &  fileName,
std::string const &  treeName = "Events" 
)

read file, compute branch size, sort by size

Definition at line 79 of file EdmEventSize.cc.

79  {
81  m_branches.clear();
82 
83  TFile* file = TFile::Open(fileName.c_str());
84  if (file == nullptr || (!(*file).IsOpen()))
85  throw Error("unable to open data file " + fileName, 7002);
86 
87  TObject* o = file->Get(treeName.c_str());
88  if (o == nullptr)
89  throw Error("no object \"" + treeName + "\" found in file: " + fileName, 7003);
90 
91  TTree* events = dynamic_cast<TTree*>(o);
92  if (events == nullptr)
93  throw Error("object \"" + treeName + "\" is not a TTree in file: " + fileName, 7004);
94 
95  m_nEvents = events->GetEntries();
96  if (m_nEvents == 0)
97  throw Error("tree \"" + treeName + "\" in file " + fileName + " contains no Events", 7005);
98 
99  TObjArray* branches = events->GetListOfBranches();
100  if (branches == nullptr)
101  throw Error("tree \"" + treeName + "\" in file " + fileName + " contains no branches", 7006);
102 
103  const size_t n = branches->GetEntries();
104  m_branches.reserve(n);
105  for (size_t i = 0; i < n; ++i) {
106  TBranch* b = dynamic_cast<TBranch*>(branches->At(i));
107  if (b == nullptr)
108  continue;
109  std::string const name(b->GetName());
110  if (name == "EventAux")
111  continue;
112  size_type s = getTotalSize(b);
113  m_branches.push_back(
114  BranchRecord(name, double(s[kCompressed]) / double(m_nEvents), double(s[kUncompressed]) / double(m_nEvents)));
115  }
116  std::sort(m_branches.begin(),
117  m_branches.end(),
118  boost::bind(std::greater<double>(),
119  boost::bind(&BranchRecord::compr_size, _1),
120  boost::bind(&BranchRecord::compr_size, _2)));
121  }

References b, perftools::EdmEventSize::BranchRecord::compr_size, patZpeak::events, FrontierConditions_GlobalTag_cff::file, MillePedeFileConverter_cfg::fileName, mps_fire::i, m_branches, m_fileName, m_nEvents, dqmiodumpmetadata::n, Skims_PA_cff::name, EcalTangentSkim_cfg::o, alignCSCRings::s, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by EdmEventSize().

◆ produceHistos()

void perftools::EdmEventSize::produceHistos ( std::string const &  plot,
std::string const &  file,
int  top = 0 
) const

produce histograms and optionally write them in "file" or as "plot"

Definition at line 231 of file EdmEventSize.cc.

231  {
232  if (top == 0)
233  top = m_branches.size();
234  detail::Hist h(top);
235  std::for_each(m_branches.begin(), m_branches.end(), boost::bind(&detail::Hist::fill, boost::ref(h), _1));
236  h.finalize();
237  if (!plot.empty()) {
238  gROOT->SetStyle("Plain");
239  gStyle->SetOptStat(kFALSE);
240  gStyle->SetOptLogy();
241  TCanvas c;
242  h.uncompressed.Draw();
243  h.compressed.Draw("same");
244  c.SaveAs(plot.c_str());
245  }
246  if (!file.empty()) {
247  TFile f(file.c_str(), "RECREATE");
248  h.compressed.Write();
249  h.uncompressed.Write();
250  f.Close();
251  }
252  }

References HltBtagPostValidation_cff::c, f, FrontierConditions_GlobalTag_cff::file, perftools::detail::Hist::fill(), h, m_branches, and plotFactory::plot.

◆ sortAlpha()

void perftools::EdmEventSize::sortAlpha ( )

sort by name

Definition at line 123 of file EdmEventSize.cc.

123  {
124  std::sort(
125  m_branches.begin(),
126  m_branches.end(),
127  boost::bind(
128  std::less<std::string>(), boost::bind(&BranchRecord::name, _1), boost::bind(&BranchRecord::name, _2)));
129  }

References m_branches, and perftools::EdmEventSize::BranchRecord::name.

Member Data Documentation

◆ m_branches

Branches perftools::EdmEventSize::m_branches
private

Definition at line 69 of file EdmEventSize.h.

Referenced by dump(), formatNames(), parseFile(), produceHistos(), and sortAlpha().

◆ m_fileName

std::string perftools::EdmEventSize::m_fileName
private

Definition at line 67 of file EdmEventSize.h.

Referenced by dump(), and parseFile().

◆ m_nEvents

int perftools::EdmEventSize::m_nEvents
private

Definition at line 68 of file EdmEventSize.h.

Referenced by dump(), and parseFile().

perftools::detail::dump
void dump(std::ostream &co, EdmEventSize::BranchRecord const &br)
Definition: EdmEventSize.cc:156
mps_fire.i
i
Definition: mps_fire.py:355
dqmiodumpmetadata.n
n
Definition: dqmiodumpmetadata.py:28
f
double f[11][100]
Definition: MuScleFitUtils.cc:78
h
FWCore Framework interface EventSetupRecordImplementation h
Helper function to determine trigger accepts.
Definition: L1TUtmAlgorithmRcd.h:4
perftools::EdmEventSize::BranchRecord::compr_size
double compr_size
Definition: EdmEventSize.h:40
MillePedeFileConverter_cfg.fileName
fileName
Definition: MillePedeFileConverter_cfg.py:32
cms::cuda::co
T *__restrict__ co
Definition: prefixScan.h:46
patZpeak.events
events
Definition: patZpeak.py:20
plotFactory.plot
plot
Definition: plotFactory.py:109
EcalTangentSkim_cfg.o
o
Definition: EcalTangentSkim_cfg.py:36
perftools::detail::shorterName
void shorterName(EdmEventSize::BranchRecord &br)
Definition: EdmEventSize.cc:133
alignCSCRings.s
s
Definition: alignCSCRings.py:92
perftools::EdmEventSize::parseFile
void parseFile(std::string const &fileName, std::string const &treeName="Events")
read file, compute branch size, sort by size
Definition: EdmEventSize.cc:79
trigger::size_type
uint16_t size_type
Definition: TriggerTypeDefs.h:18
perftools::EdmEventSize::BranchRecord::name
std::string name
Definition: EdmEventSize.h:39
h
perftools::EdmEventSize::m_nEvents
int m_nEvents
Definition: EdmEventSize.h:68
b
double b
Definition: hdecay.h:118
AlCaHLTBitMon_QueryRunRegistry.string
string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
leef::Error
edm::ErrorSummaryEntry Error
Definition: LogErrorEventFilter.cc:29
FrontierConditions_GlobalTag_cff.file
file
Definition: FrontierConditions_GlobalTag_cff.py:13
HltBtagPostValidation_cff.c
c
Definition: HltBtagPostValidation_cff.py:31
perftools::EdmEventSize::m_branches
Branches m_branches
Definition: EdmEventSize.h:69
perftools::detail::Hist::fill
void fill(EdmEventSize::BranchRecord const &br)
Definition: EdmEventSize.cc:180
Skims_PA_cff.name
name
Definition: Skims_PA_cff.py:17
perftools::EdmEventSize::m_fileName
std::string m_fileName
Definition: EdmEventSize.h:67
RecoTauValidation_cfi.header
header
Definition: RecoTauValidation_cfi.py:292