CMS 3D CMS Logo

List of all members | Classes | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | Static Private Attributes
NanoAODOutputModule Class Reference
Inheritance diagram for NanoAODOutputModule:
edm::one::OutputModule<> edm::one::OutputModuleBase edm::EDConsumerBase

Classes

class  CommonEventBranches
 
class  CommonLumiBranches
 
class  CommonRunBranches
 

Public Member Functions

 NanoAODOutputModule (edm::ParameterSet const &pset)
 
 ~NanoAODOutputModule () override
 
- Public Member Functions inherited from edm::one::OutputModule<>
 OutputModule (edm::ParameterSet const &iPSet)
 
bool wantsGlobalLuminosityBlocks () const final
 
bool wantsGlobalRuns () const final
 
- Public Member Functions inherited from edm::one::OutputModuleBase
BranchIDLists const * branchIDLists ()
 
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
SerialTaskQueueglobalRunsQueue ()
 
std::array< bool, NumBranchTypes > const & hasNewlyDroppedBranch () const
 
SelectedProductsForBranchType const & keptProducts () const
 
int maxEvents () const
 
const ModuleDescriptionmoduleDescription () const
 
OutputModuleBaseoperator= (OutputModuleBase const &)=delete
 
 OutputModuleBase (ParameterSet const &pset)
 
 OutputModuleBase (OutputModuleBase const &)=delete
 
std::string const & processName () const
 
int remainingEvents () const
 
bool selected (BranchDescription const &desc) const
 
void selectProducts (ProductRegistry const &preg, ThinnedAssociationsHelper const &)
 
SharedResourcesAcquirersharedResourcesAcquirer ()
 
SubProcessParentageHelper const * subProcessParentageHelper () const
 
ThinnedAssociationsHelper const * thinnedAssociationsHelper () const
 
bool wantAllEvents () const
 
bool wantsStreamLuminosityBlocks () const
 
bool wantsStreamRuns () const
 
 ~OutputModuleBase () override
 
- Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfoconsumesInfo () const
 
void convertCurrentProcessAlias (std::string const &processName)
 Convert "@currentProcess" in InputTag process names to the actual current process name. More...
 
 EDConsumerBase ()
 
 EDConsumerBase (EDConsumerBase const &)=delete
 
 EDConsumerBase (EDConsumerBase &&)=default
 
ProductResolverIndexAndSkipBit indexFrom (EDGetToken, BranchType, TypeID const &) const
 
void itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
 
void itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
 
std::vector< ProductResolverIndexAndSkipBit > const & itemsToGetFrom (BranchType iType) const
 
void labelsForToken (EDGetToken iToken, Labels &oLabels) const
 
void modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const
 
EDConsumerBase const & operator= (EDConsumerBase const &)=delete
 
EDConsumerBaseoperator= (EDConsumerBase &&)=default
 
bool registeredToConsume (ProductResolverIndex, bool, BranchType) const
 
bool registeredToConsumeMany (TypeID const &, BranchType) const
 
ProductResolverIndexAndSkipBit uncheckedIndexFrom (EDGetToken) const
 
void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
 
virtual ~EDConsumerBase () noexcept(false)
 

Static Public Member Functions

static void fillDescriptions (edm::ConfigurationDescriptions &descriptions)
 
- Static Public Member Functions inherited from edm::one::OutputModuleBase
static const std::string & baseType ()
 
static void fillDescription (ParameterSetDescription &desc)
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &)
 

Private Member Functions

bool isFileOpen () const override
 
void openFile (edm::FileBlock const &) override
 
void reallyCloseFile () override
 
void write (edm::EventForOutput const &e) override
 
void writeLuminosityBlock (edm::LuminosityBlockForOutput const &) override
 
void writeRun (edm::RunForOutput const &) override
 

Private Attributes

int m_autoFlush
 
class NanoAODOutputModule::CommonEventBranches m_commonBranches
 
class NanoAODOutputModule::CommonLumiBranches m_commonLumiBranches
 
class NanoAODOutputModule::CommonRunBranches m_commonRunBranches
 
std::string m_compressionAlgorithm
 
int m_compressionLevel
 
int m_eventsSinceFlush {0}
 
bool m_fakeName
 
std::unique_ptr< TFile > m_file
 
std::string m_fileName
 
edm::JobReport::Token m_jrToken
 
std::string m_logicalFileName
 
std::unique_ptr< TTree > m_lumiTree
 
std::unique_ptr< TTree > m_metaDataTree
 
std::vector< std::pair< std::string, edm::EDGetToken > > m_nanoMetadata
 
std::unique_ptr< TTree > m_parameterSetsTree
 
edm::ProcessHistoryRegistry m_processHistoryRegistry
 
std::vector< SummaryTableOutputBranchesm_runTables
 
std::unique_ptr< TTree > m_runTree
 
std::vector< TableOutputBranchesm_tables
 
std::unique_ptr< TTree > m_tree
 
std::vector< TriggerOutputBranchesm_triggers
 
bool m_writeProvenance
 

Static Private Attributes

static int m_firstFlush {1000}
 

Additional Inherited Members

- Public Types inherited from edm::one::OutputModuleBase
typedef OutputModuleBase ModuleType
 
- Public Types inherited from edm::EDConsumerBase
typedef ProductLabels Labels
 
- Protected Member Functions inherited from edm::one::OutputModuleBase
void configure (OutputModuleDescription const &desc)
 
ModuleDescription const & description () const
 
void doBeginJob ()
 
bool doBeginLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *)
 
bool doBeginRun (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *)
 
void doEndJob ()
 
bool doEndLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *)
 
bool doEndRun (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *)
 
bool doEvent (EventPrincipal const &ep, EventSetup const &c, ActivityRegistry *, ModuleCallingContext const *)
 
void doPreallocate (PreallocationConfiguration const &)
 
std::map< BranchID::value_type, BranchID::value_type > const & droppedBranchIDToKeptBranchID ()
 
ParameterSetID selectorConfig () const
 
void setEventSelectionInfo (std::map< std::string, std::vector< std::pair< std::string, int > > > const &outputModulePathPositions, bool anyProductProduced)
 
- Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
EDGetToken consumes (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken consumes (TypeToGet const &id, edm::InputTag const &tag)
 
ConsumesCollector consumesCollector ()
 Use a ConsumesCollector to gather consumes information from helper functions. More...
 
template<typename ProductType , BranchType B = InEvent>
void consumesMany ()
 
void consumesMany (const TypeToGet &id)
 
template<BranchType B>
void consumesMany (const TypeToGet &id)
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > mayConsume (edm::InputTag const &tag)
 
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 

Detailed Description

Definition at line 45 of file NanoAODOutputModule.cc.

Constructor & Destructor Documentation

NanoAODOutputModule::NanoAODOutputModule ( edm::ParameterSet const &  pset)

Definition at line 137 of file NanoAODOutputModule.cc.

137  :
140  m_fileName(pset.getUntrackedParameter<std::string>("fileName")),
141  m_logicalFileName(pset.getUntrackedParameter<std::string>("logicalFileName")),
142  m_compressionLevel(pset.getUntrackedParameter<int>("compressionLevel")),
143  m_compressionAlgorithm(pset.getUntrackedParameter<std::string>("compressionAlgorithm")),
144  m_writeProvenance(pset.getUntrackedParameter<bool>("saveProvenance", true)),
145  m_fakeName(pset.getUntrackedParameter<bool>("fakeNameForCrab", false)),
146  m_autoFlush(pset.getUntrackedParameter<int>("autoFlush", -10000000)),
148 {
149 }
OutputModuleBase(ParameterSet const &pset)
edm::ProcessHistoryRegistry m_processHistoryRegistry
std::string m_compressionAlgorithm
NanoAODOutputModule::~NanoAODOutputModule ( )
override

Definition at line 151 of file NanoAODOutputModule.cc.

152 {
153 }

Member Function Documentation

void NanoAODOutputModule::fillDescriptions ( edm::ConfigurationDescriptions descriptions)
static

Definition at line 343 of file NanoAODOutputModule.cc.

References edm::ParameterSetDescription::add(), edm::ConfigurationDescriptions::addDefault(), edm::ParameterSetDescription::addUntracked(), DEFINE_FWK_MODULE, edm::OutputModule::fillDescription(), keep, edm::ParameterSetDescription::setAllowAnything(), and AlCaHLTBitMon_QueryRunRegistry::string.

343  {
345 
346  desc.addUntracked<std::string>("fileName");
347  desc.addUntracked<std::string>("logicalFileName","");
348 
349  desc.addUntracked<int>("compressionLevel", 9)
350  ->setComment("ROOT compression level of output file.");
351  desc.addUntracked<std::string>("compressionAlgorithm", "ZLIB")
352  ->setComment("Algorithm used to compress data in the ROOT output file, allowed values are ZLIB and LZMA");
353  desc.addUntracked<bool>("saveProvenance", true)
354  ->setComment("Save process provenance information, e.g. for edmProvDump");
355  desc.addUntracked<bool>("fakeNameForCrab", false)
356  ->setComment("Change the OutputModule name in the fwk job report to fake PoolOutputModule. This is needed to run on cran (and publish) till crab is fixed");
357  desc.addUntracked<int>("autoFlush", -10000000)
358  ->setComment("Autoflush parameter for ROOT file");
359 
360  //replace with whatever you want to get from the EDM by default
361  const std::vector<std::string> keep = {"drop *", "keep nanoaodFlatTable_*Table_*_*", "keep edmTriggerResults_*_*_*", "keep nanoaodMergeableCounterTable_*Table_*_*", "keep nanoaodUniqueString_nanoMetadata_*_*"};
363 
364  //Used by Workflow management for their own meta data
366  dataSet.setAllowAnything();
367  desc.addUntracked<edm::ParameterSetDescription>("dataset", dataSet)
368  ->setComment("PSet is only used by Data Operations and not by this module.");
369 
371  branchSet.setAllowAnything();
372  desc.add<edm::ParameterSetDescription>("branches", branchSet);
373 
374 
375 
376  descriptions.addDefault(desc);
377 
378 }
ParameterDescriptionBase * addUntracked(U const &iLabel, T const &value)
void setAllowAnything()
allow any parameter label/value pairs
const int keep
void addDefault(ParameterSetDescription const &psetDescription)
static void fillDescription(ParameterSetDescription &desc, std::vector< std::string > const &iDefaultOutputCommands=ProductSelectorRules::defaultSelectionStrings())
ParameterDescriptionBase * add(U const &iLabel, T const &value)
bool NanoAODOutputModule::isFileOpen ( ) const
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 244 of file NanoAODOutputModule.cc.

References m_file.

244  {
245  return nullptr != m_file.get();
246 }
std::unique_ptr< TFile > m_file
void NanoAODOutputModule::openFile ( edm::FileBlock const &  )
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 249 of file NanoAODOutputModule.cc.

References NanoAODOutputModule::CommonEventBranches::branch(), NanoAODOutputModule::CommonLumiBranches::branch(), NanoAODOutputModule::CommonRunBranches::branch(), edm::createGlobalIdentifier(), edm::one::OutputModuleBase::description(), cms::Digest::digest(), Exception, edm::InEvent, edm::InRun, keep, edm::one::OutputModuleBase::keptProducts(), m_commonBranches, m_commonLumiBranches, m_commonRunBranches, m_compressionAlgorithm, m_compressionLevel, m_fakeName, m_file, m_fileName, m_jrToken, m_logicalFileName, m_lumiTree, m_metaDataTree, m_nanoMetadata, m_parameterSetsTree, m_runTables, m_runTree, m_tables, m_tree, m_triggers, m_writeProvenance, edm::poolNames::metaDataTreeName(), edm::poolNames::parameterSetsTreeName(), AlCaHLTBitMon_QueryRunRegistry::string, and cms::MD5Result::toString().

249  {
250  m_file = std::make_unique<TFile>(m_fileName.c_str(),"RECREATE","",m_compressionLevel);
252  cms::Digest branchHash;
253  m_jrToken = jr->outputFileOpened(m_fileName,
255  std::string(),
256  m_fakeName?"PoolOutputModule":"NanoAODOutputModule",
257  description().moduleLabel(),
259  std::string(),
260  branchHash.digest().toString(),
261  std::vector<std::string>()
262  );
263 
264  if (m_compressionAlgorithm == std::string("ZLIB")) {
265  m_file->SetCompressionAlgorithm(ROOT::kZLIB);
266  } else if (m_compressionAlgorithm == std::string("LZMA")) {
267  m_file->SetCompressionAlgorithm(ROOT::kLZMA);
268  } else {
269  throw cms::Exception("Configuration") << "NanoAODOutputModule configured with unknown compression algorithm '" << m_compressionAlgorithm << "'\n"
270  << "Allowed compression algorithms are ZLIB and LZMA\n";
271  }
272  /* Setup file structure here */
273  m_tables.clear();
274  m_triggers.clear();
275  m_runTables.clear();
276  const auto & keeps = keptProducts();
277  for (const auto & keep : keeps[edm::InEvent]) {
278  if(keep.first->className() == "nanoaod::FlatTable" )
279  m_tables.emplace_back(keep.first, keep.second);
280  else if(keep.first->className() == "edm::TriggerResults" )
281  {
282  m_triggers.emplace_back(keep.first, keep.second);
283  }
284  else throw cms::Exception("Configuration", "NanoAODOutputModule cannot handle class " + keep.first->className());
285  }
286 
287  for (const auto & keep : keeps[edm::InRun]) {
288  if(keep.first->className() == "nanoaod::MergeableCounterTable" )
289  m_runTables.push_back(SummaryTableOutputBranches(keep.first, keep.second));
290  else if(keep.first->className() == "nanoaod::UniqueString" && keep.first->moduleLabel() == "nanoMetadata")
291  m_nanoMetadata.emplace_back(keep.first->productInstanceName(), keep.second);
292  else throw cms::Exception("Configuration", "NanoAODOutputModule cannot handle class " + keep.first->className() + " in Run branch");
293  }
294 
295 
296  // create the trees
297  m_tree.reset(new TTree("Events","Events"));
298  m_tree->SetAutoSave(0);
299  m_tree->SetAutoFlush(0);
301 
302  m_lumiTree.reset(new TTree("LuminosityBlocks","LuminosityBlocks"));
303  m_lumiTree->SetAutoSave(0);
305 
306  m_runTree.reset(new TTree("Runs","Runs"));
307  m_runTree->SetAutoSave(0);
309 
310  if (m_writeProvenance) {
311  m_metaDataTree.reset(new TTree(edm::poolNames::metaDataTreeName().c_str(),"Job metadata"));
312  m_metaDataTree->SetAutoSave(0);
313  m_parameterSetsTree.reset(new TTree(edm::poolNames::parameterSetsTreeName().c_str(),"Parameter sets"));
314  m_parameterSetsTree->SetAutoSave(0);
315  }
316 }
std::unique_ptr< TTree > m_runTree
std::unique_ptr< TTree > m_lumiTree
ModuleDescription const & description() const
std::unique_ptr< TTree > m_tree
MD5Result digest() const
Definition: Digest.cc:194
std::vector< std::pair< std::string, edm::EDGetToken > > m_nanoMetadata
std::string const & parameterSetsTreeName()
Definition: BranchType.cc:251
std::unique_ptr< TTree > m_parameterSetsTree
class NanoAODOutputModule::CommonLumiBranches m_commonLumiBranches
std::unique_ptr< TTree > m_metaDataTree
const int keep
std::unique_ptr< TFile > m_file
std::vector< SummaryTableOutputBranches > m_runTables
std::vector< TableOutputBranches > m_tables
std::vector< TriggerOutputBranches > m_triggers
SelectedProductsForBranchType const & keptProducts() const
std::string const & metaDataTreeName()
Definition: BranchType.cc:168
std::string toString() const
Definition: Digest.cc:87
class NanoAODOutputModule::CommonRunBranches m_commonRunBranches
edm::JobReport::Token m_jrToken
class NanoAODOutputModule::CommonEventBranches m_commonBranches
std::string m_compressionAlgorithm
std::string createGlobalIdentifier()
void NanoAODOutputModule::reallyCloseFile ( )
overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 318 of file NanoAODOutputModule.cc.

References edm::fillParameterSetBranch(), edm::fillProcessHistoryBranch(), m_file, m_jrToken, m_lumiTree, m_metaDataTree, m_parameterSetsTree, m_processHistoryRegistry, m_runTree, m_tree, m_writeProvenance, and edm::JobReport::outputFileClosed().

318  {
319  if (m_writeProvenance) {
320  int basketSize = 16384; // fixme configurable?
323  if (m_metaDataTree->GetNbranches() != 0) {
324  m_metaDataTree->SetEntries(-1);
325  }
326  if (m_parameterSetsTree->GetNbranches() != 0) {
327  m_parameterSetsTree->SetEntries(-1);
328  }
329  }
330  m_file->Write();
331  m_file->Close();
332  m_file.reset();
333  m_tree.release(); // apparently root has ownership
334  m_lumiTree.release(); //
335  m_runTree.release(); //
336  m_metaDataTree.release(); //
337  m_parameterSetsTree.release(); //
340 }
std::unique_ptr< TTree > m_runTree
std::unique_ptr< TTree > m_lumiTree
std::unique_ptr< TTree > m_tree
void fillParameterSetBranch(TTree *parameterSetsTree, int basketSize)
void fillProcessHistoryBranch(TTree *metaDataTree, int basketSize, ProcessHistoryRegistry const &processHistoryRegistry)
std::unique_ptr< TTree > m_parameterSetsTree
std::unique_ptr< TTree > m_metaDataTree
std::unique_ptr< TFile > m_file
void outputFileClosed(Token fileToken)
Definition: JobReport.cc:461
edm::JobReport::Token m_jrToken
edm::ProcessHistoryRegistry m_processHistoryRegistry
void NanoAODOutputModule::write ( edm::EventForOutput const &  e)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 156 of file NanoAODOutputModule.cc.

References edm::EventID::event(), PatBasicFWLiteAnalyzer::events, edm::JobReport::eventWrittenToFile(), NanoAODOutputModule::CommonEventBranches::fill(), edm::EventForOutput::id(), m_autoFlush, m_commonBranches, m_eventsSinceFlush, m_firstFlush, m_jrToken, m_processHistoryRegistry, m_tables, m_tree, m_triggers, edm::OccurrenceForOutput::processHistory(), edm::ProcessHistoryRegistry::registerProcessHistory(), edm::EventID::run(), and lumiQTWidget::t.

156  {
157  //Get data from 'e' and write it to the file
159  jr->eventWrittenToFile(m_jrToken, iEvent.id().run(), iEvent.id().event());
160 
161  if (m_autoFlush) {
162  int64_t events = m_tree->GetEntriesFast();
163  if (events == m_firstFlush) {
164  m_tree->FlushBaskets();
165  float maxMemory;
166  if (m_autoFlush > 0) {
167  // Estimate the memory we'll be using at the first full flush by
168  // linearly scaling the number of events.
169  float percentClusterDone = m_firstFlush / static_cast<float>(m_autoFlush);
170  maxMemory = static_cast<float>(m_tree->GetTotBytes()) / percentClusterDone;
171  } else if (m_tree->GetZipBytes() == 0) {
172  maxMemory = 100*1024*1024; // Degenerate case of no information in the tree; arbitrary value
173  } else {
174  // Estimate the memory we'll be using by scaling the current compression ratio.
175  float cxnRatio = m_tree->GetTotBytes() / static_cast<float>(m_tree->GetZipBytes());
176  maxMemory = -m_autoFlush * cxnRatio;
177  float percentBytesDone = -m_tree->GetZipBytes() / static_cast<float>(m_autoFlush);
178  m_autoFlush = m_firstFlush / percentBytesDone;
179  }
180  //std::cout << "OptimizeBaskets: total bytes " << m_tree->GetTotBytes() << std::endl;
181  //std::cout << "OptimizeBaskets: zip bytes " << m_tree->GetZipBytes() << std::endl;
182  //std::cout << "OptimizeBaskets: autoFlush " << m_autoFlush << std::endl;
183  //std::cout << "OptimizeBaskets: maxMemory " << static_cast<uint32_t>(maxMemory) << std::endl;
184  //m_tree->OptimizeBaskets(static_cast<uint32_t>(maxMemory), 1, "d");
185  m_tree->OptimizeBaskets(static_cast<uint32_t>(maxMemory), 1, "");
186  }
188  m_tree->FlushBaskets();
189  m_eventsSinceFlush = 0;
190  }
192  }
193 
195  // fill all tables, starting from main tables and then doing extension tables
196  for (unsigned int extensions = 0; extensions <= 1; ++extensions) {
197  for (auto & t : m_tables) t.fill(iEvent,*m_tree,extensions);
198  }
199  // fill triggers
200  for (auto & t : m_triggers) t.fill(iEvent,*m_tree);
201  m_tree->Fill();
202 
204 }
std::unique_ptr< TTree > m_tree
bool registerProcessHistory(ProcessHistory const &processHistory)
int iEvent
Definition: GenABIO.cc:230
std::vector< TableOutputBranches > m_tables
std::vector< TriggerOutputBranches > m_triggers
void eventWrittenToFile(Token fileToken, RunNumber_t run, EventNumber_t event)
Definition: JobReport.cc:455
edm::JobReport::Token m_jrToken
class NanoAODOutputModule::CommonEventBranches m_commonBranches
edm::ProcessHistoryRegistry m_processHistoryRegistry
void NanoAODOutputModule::writeLuminosityBlock ( edm::LuminosityBlockForOutput const &  iLumi)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 207 of file NanoAODOutputModule.cc.

References NanoAODOutputModule::CommonLumiBranches::fill(), edm::LuminosityBlockForOutput::id(), m_commonLumiBranches, m_jrToken, m_lumiTree, m_processHistoryRegistry, edm::OccurrenceForOutput::processHistory(), edm::ProcessHistoryRegistry::registerProcessHistory(), edm::JobReport::reportLumiSection(), edm::LuminosityBlockID::run(), and edm::LuminosityBlockID::value().

207  {
209  jr->reportLumiSection(m_jrToken, iLumi.id().run(), iLumi.id().value());
210 
211  m_commonLumiBranches.fill(iLumi.id());
212  m_lumiTree->Fill();
213 
214  m_processHistoryRegistry.registerProcessHistory(iLumi.processHistory());
215 }
std::unique_ptr< TTree > m_lumiTree
bool registerProcessHistory(ProcessHistory const &processHistory)
void fill(const edm::LuminosityBlockID &id)
class NanoAODOutputModule::CommonLumiBranches m_commonLumiBranches
edm::JobReport::Token m_jrToken
edm::ProcessHistoryRegistry m_processHistoryRegistry
void reportLumiSection(JobReport::Token token, unsigned int run, unsigned int lumiSectId, unsigned long nEvents=0)
Definition: JobReport.cc:487
void NanoAODOutputModule::writeRun ( edm::RunForOutput const &  iRun)
overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 218 of file NanoAODOutputModule.cc.

References NanoAODOutputModule::CommonRunBranches::fill(), edm::OccurrenceForOutput::getByToken(), edm::RunForOutput::id(), m_commonRunBranches, m_file, m_jrToken, m_nanoMetadata, m_processHistoryRegistry, m_runTables, m_runTree, AlCaHLTBitMon_ParallelJobs::p, edm::OccurrenceForOutput::processHistory(), edm::ProcessHistoryRegistry::registerProcessHistory(), edm::JobReport::reportRunNumber(), edm::RunID::run(), nanoaod::UniqueString::str(), and lumiQTWidget::t.

218  {
220  jr->reportRunNumber(m_jrToken, iRun.id().run());
221 
222  m_commonRunBranches.fill(iRun.id());
223 
224  for (auto & t : m_runTables) t.fill(iRun,*m_runTree);
225 
227  for (const auto & p : m_nanoMetadata) {
228  iRun.getByToken(p.second, hstring);
229  TObjString *tos = dynamic_cast<TObjString *>(m_file->Get(p.first.c_str()));
230  if (tos) {
231  if (hstring->str() != tos->GetString()) throw cms::Exception("LogicError", "Inconsistent nanoMetadata " + p.first + " (" + hstring->str() +")");
232  } else {
233  auto ostr = std::make_unique<TObjString>(hstring->str().c_str());
234  m_file->WriteTObject(ostr.release(), p.first.c_str());
235  }
236  }
237 
238  m_runTree->Fill();
239 
240  m_processHistoryRegistry.registerProcessHistory(iRun.processHistory());
241 }
std::unique_ptr< TTree > m_runTree
bool registerProcessHistory(ProcessHistory const &processHistory)
void reportRunNumber(JobReport::Token token, unsigned int run)
Definition: JobReport.cc:497
std::vector< std::pair< std::string, edm::EDGetToken > > m_nanoMetadata
std::unique_ptr< TFile > m_file
std::vector< SummaryTableOutputBranches > m_runTables
class NanoAODOutputModule::CommonRunBranches m_commonRunBranches
edm::JobReport::Token m_jrToken
const std::string & str() const
Definition: UniqueString.h:12
edm::ProcessHistoryRegistry m_processHistoryRegistry

Member Data Documentation

int NanoAODOutputModule::m_autoFlush
private

Definition at line 67 of file NanoAODOutputModule.cc.

Referenced by write().

class NanoAODOutputModule::CommonEventBranches NanoAODOutputModule::m_commonBranches
private

Referenced by openFile(), and write().

class NanoAODOutputModule::CommonLumiBranches NanoAODOutputModule::m_commonLumiBranches
private

Referenced by openFile(), and writeLuminosityBlock().

class NanoAODOutputModule::CommonRunBranches NanoAODOutputModule::m_commonRunBranches
private

Referenced by openFile(), and writeRun().

std::string NanoAODOutputModule::m_compressionAlgorithm
private

Definition at line 64 of file NanoAODOutputModule.cc.

Referenced by openFile().

int NanoAODOutputModule::m_compressionLevel
private

Definition at line 62 of file NanoAODOutputModule.cc.

Referenced by openFile().

int NanoAODOutputModule::m_eventsSinceFlush {0}
private

Definition at line 63 of file NanoAODOutputModule.cc.

Referenced by write().

bool NanoAODOutputModule::m_fakeName
private

Definition at line 66 of file NanoAODOutputModule.cc.

Referenced by openFile().

std::unique_ptr<TFile> NanoAODOutputModule::m_file
private

Definition at line 70 of file NanoAODOutputModule.cc.

Referenced by isFileOpen(), openFile(), reallyCloseFile(), and writeRun().

std::string NanoAODOutputModule::m_fileName
private

Definition at line 60 of file NanoAODOutputModule.cc.

Referenced by openFile().

int NanoAODOutputModule::m_firstFlush {1000}
staticprivate

Definition at line 73 of file NanoAODOutputModule.cc.

Referenced by write().

edm::JobReport::Token NanoAODOutputModule::m_jrToken
private
std::string NanoAODOutputModule::m_logicalFileName
private

Definition at line 61 of file NanoAODOutputModule.cc.

Referenced by openFile().

std::unique_ptr<TTree> NanoAODOutputModule::m_lumiTree
private

Definition at line 71 of file NanoAODOutputModule.cc.

Referenced by openFile(), reallyCloseFile(), and writeLuminosityBlock().

std::unique_ptr<TTree> NanoAODOutputModule::m_metaDataTree
private

Definition at line 71 of file NanoAODOutputModule.cc.

Referenced by openFile(), and reallyCloseFile().

std::vector<std::pair<std::string,edm::EDGetToken> > NanoAODOutputModule::m_nanoMetadata
private

Definition at line 121 of file NanoAODOutputModule.cc.

Referenced by openFile(), and writeRun().

std::unique_ptr<TTree> NanoAODOutputModule::m_parameterSetsTree
private

Definition at line 71 of file NanoAODOutputModule.cc.

Referenced by openFile(), and reallyCloseFile().

edm::ProcessHistoryRegistry NanoAODOutputModule::m_processHistoryRegistry
private

Definition at line 68 of file NanoAODOutputModule.cc.

Referenced by reallyCloseFile(), write(), writeLuminosityBlock(), and writeRun().

std::vector<SummaryTableOutputBranches> NanoAODOutputModule::m_runTables
private

Definition at line 119 of file NanoAODOutputModule.cc.

Referenced by openFile(), and writeRun().

std::unique_ptr<TTree> NanoAODOutputModule::m_runTree
private

Definition at line 71 of file NanoAODOutputModule.cc.

Referenced by openFile(), reallyCloseFile(), and writeRun().

std::vector<TableOutputBranches> NanoAODOutputModule::m_tables
private

Definition at line 116 of file NanoAODOutputModule.cc.

Referenced by openFile(), and write().

std::unique_ptr<TTree> NanoAODOutputModule::m_tree
private

Definition at line 71 of file NanoAODOutputModule.cc.

Referenced by openFile(), reallyCloseFile(), and write().

std::vector<TriggerOutputBranches> NanoAODOutputModule::m_triggers
private

Definition at line 117 of file NanoAODOutputModule.cc.

Referenced by openFile(), and write().

bool NanoAODOutputModule::m_writeProvenance
private

Definition at line 65 of file NanoAODOutputModule.cc.

Referenced by openFile(), and reallyCloseFile().