Inheritance diagram for NanoAODOutputModule:

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<>
SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

	OutputModule (edm::ParameterSet const &iPSet)

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

Public Member Functions inherited from edm::one::OutputModuleBase
BranchIDLists const *	branchIDLists ()

std::array< bool, NumBranchTypes > const &	hasNewlyDroppedBranch () const

SelectedProductsForBranchType const &	keptProducts () const

int	maxEvents () const

const ModuleDescription &	moduleDescription () const

OutputModuleBase &	operator= (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 &)

SharedResourcesAcquirer &	sharedResourcesAcquirer ()

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< ConsumesInfo >	consumesInfo () 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

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

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

EDConsumerBase &	operator= (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)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

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}

std::vector< EventStringOutputBranches >	m_evstrings

bool	m_fakeName

std::unique_ptr< TFile >	m_file

std::string	m_fileName

edm::JobReport::Token	m_jrToken

std::string	m_logicalFileName

std::vector< SummaryTableOutputBranches >	m_lumiTables

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< SummaryTableOutputBranches >	m_runTables

std::unique_ptr< TTree >	m_runTree

std::vector< TableOutputBranches >	m_tables

std::unique_ptr< TTree >	m_tree

std::vector< TriggerOutputBranches >	m_triggers

bool	m_triggers_areSorted = false

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, EventSetupImpl const &c, ModuleCallingContext const *)

bool	doBeginRun (RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *)

void	doEndJob ()

bool	doEndLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *)

bool	doEndRun (RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *)

bool	doEvent (EventPrincipal const &ep, EventSetupImpl const &c, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate (PreallocationConfiguration const &)

std::map< BranchID::value_type, BranchID::value_type > const &	droppedBranchIDToKeptBranchID ()

virtual void	preallocLumis (unsigned int)

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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

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 47 of file NanoAODOutputModule.cc.

Constructor & Destructor Documentation

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

Definition at line 142 of file NanoAODOutputModule.cc.

                                                                    :
   edm::one::OutputModuleBase::OutputModuleBase(pset),
   edm::one::OutputModule<>(pset),
   m_fileName(pset.getUntrackedParameter<std::string>("fileName")),
   m_logicalFileName(pset.getUntrackedParameter<std::string>("logicalFileName")),
   m_compressionLevel(pset.getUntrackedParameter<int>("compressionLevel")),
   m_compressionAlgorithm(pset.getUntrackedParameter<std::string>("compressionAlgorithm")),
   m_writeProvenance(pset.getUntrackedParameter<bool>("saveProvenance", true)),
   m_fakeName(pset.getUntrackedParameter<bool>("fakeNameForCrab", false)),
   m_autoFlush(pset.getUntrackedParameter<int>("autoFlush", -10000000)),
   m_processHistoryRegistry()
 {
 }

NanoAODOutputModule::~NanoAODOutputModule ( )

override

Definition at line 156 of file NanoAODOutputModule.cc.

157 {

158 }

Member Function Documentation

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

static

Definition at line 375 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.

                                                                                 {
   edm::ParameterSetDescription desc;
 
   desc.addUntracked<std::string>("fileName");
   desc.addUntracked<std::string>("logicalFileName","");
 
   desc.addUntracked<int>("compressionLevel", 9)
         ->setComment("ROOT compression level of output file.");
   desc.addUntracked<std::string>("compressionAlgorithm", "ZLIB")
         ->setComment("Algorithm used to compress data in the ROOT output file, allowed values are ZLIB and LZMA");
   desc.addUntracked<bool>("saveProvenance", true)
         ->setComment("Save process provenance information, e.g. for edmProvDump");
   desc.addUntracked<bool>("fakeNameForCrab", false)
         ->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");
   desc.addUntracked<int>("autoFlush", -10000000)
         ->setComment("Autoflush parameter for ROOT file");
 
   //replace with whatever you want to get from the EDM by default
   const std::vector<std::string> keep = {"drop *", "keep nanoaodFlatTable_*Table_*_*", "keep edmTriggerResults_*_*_*", "keep String_*_genModel_*", "keep nanoaodMergeableCounterTable_*Table_*_*", "keep nanoaodUniqueString_nanoMetadata_*_*"};
   edm::OutputModule::fillDescription(desc, keep);
   
   //Used by Workflow management for their own meta data
   edm::ParameterSetDescription dataSet;
   dataSet.setAllowAnything();
   desc.addUntracked<edm::ParameterSetDescription>("dataset", dataSet)
     ->setComment("PSet is only used by Data Operations and not by this module.");
   
   edm::ParameterSetDescription branchSet;
   branchSet.setAllowAnything();
   desc.add<edm::ParameterSetDescription>("branches", branchSet);
 
 
 
   descriptions.addDefault(desc);
 
 }

bool NanoAODOutputModule::isFileOpen ( ) const

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 263 of file NanoAODOutputModule.cc.

References m_file.

                                       {
   return nullptr != m_file.get();
 }

void NanoAODOutputModule::openFile ( edm::FileBlock const & )

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 268 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::InLumi, edm::InRun, keep, edm::one::OutputModuleBase::keptProducts(), m_commonBranches, m_commonLumiBranches, m_commonRunBranches, m_compressionAlgorithm, m_compressionLevel, m_evstrings, m_fakeName, m_file, m_fileName, m_jrToken, m_logicalFileName, m_lumiTables, m_lumiTree, m_metaDataTree, m_nanoMetadata, m_parameterSetsTree, m_runTables, m_runTree, m_tables, m_tree, m_triggers, m_triggers_areSorted, m_writeProvenance, edm::poolNames::metaDataTreeName(), edm::poolNames::parameterSetsTreeName(), AlCaHLTBitMon_QueryRunRegistry::string, and cms::MD5Result::toString().

                                                  {
   m_file = std::make_unique<TFile>(m_fileName.c_str(),"RECREATE","",m_compressionLevel);
   edm::Service<edm::JobReport> jr;
   cms::Digest branchHash;
   m_jrToken = jr->outputFileOpened(m_fileName,
                                    m_logicalFileName,
                                    std::string(),
                                    m_fakeName?"PoolOutputModule":"NanoAODOutputModule",
                                    description().moduleLabel(),
                                    edm::createGlobalIdentifier(),
                                    std::string(),
                                    branchHash.digest().toString(),
                                    std::vector<std::string>()
                                    );
 
   if (m_compressionAlgorithm == std::string("ZLIB")) {
       m_file->SetCompressionAlgorithm(ROOT::kZLIB);
     } else if (m_compressionAlgorithm == std::string("LZMA")) {
       m_file->SetCompressionAlgorithm(ROOT::kLZMA);
     } else {
       throw cms::Exception("Configuration") << "NanoAODOutputModule configured with unknown compression algorithm '" << m_compressionAlgorithm << "'\n"
                                            << "Allowed compression algorithms are ZLIB and LZMA\n";
     }
   /* Setup file structure here */
   m_tables.clear();
   m_triggers.clear();
   m_triggers_areSorted = false;
   m_evstrings.clear();
   m_runTables.clear();
   m_lumiTables.clear();
   const auto & keeps = keptProducts();
   for (const auto & keep : keeps[edm::InEvent]) {
       if(keep.first->className() == "nanoaod::FlatTable" )
             m_tables.emplace_back(keep.first, keep.second);
       else if(keep.first->className() == "edm::TriggerResults" )
         {
             m_triggers.emplace_back(keep.first, keep.second);
         }
       else if(keep.first->className() == "std::basic_string<char,std::char_traits<char> >" && keep.first->productInstanceName()=="genModel") { // friendlyClassName == "String"
       m_evstrings.emplace_back(keep.first, keep.second, true); // update only at lumiBlock transitions
       }
       else throw cms::Exception("Configuration", "NanoAODOutputModule cannot handle class " + keep.first->className());     
   }
 
   for (const auto & keep : keeps[edm::InRun]) {
       if(keep.first->className() == "nanoaod::MergeableCounterTable" )
             m_runTables.push_back(SummaryTableOutputBranches(keep.first, keep.second));
       else if(keep.first->className() == "nanoaod::UniqueString" && keep.first->moduleLabel() == "nanoMetadata")
             m_nanoMetadata.emplace_back(keep.first->productInstanceName(), keep.second);
       else throw cms::Exception("Configuration", "NanoAODOutputModule cannot handle class " + keep.first->className() + " in Run branch");     
   }
 
   for (const auto& keep : keeps[edm::InLumi]) {
       if (keep.first->className() == "nanoaod::MergeableCounterTable")
              m_lumiTables.push_back(SummaryTableOutputBranches(keep.first, keep.second));
       else if (keep.first->className() == "nanoaod::UniqueString" && keep.first->moduleLabel() == "nanoMetadata")
             m_nanoMetadata.emplace_back(keep.first->productInstanceName(), keep.second);
       else throw cms::Exception("Configuration", "NanoAODOutputModule cannot handle class " + keep.first->className() + " in LuminosityBlock branch");
   }
 
   // create the trees
   m_tree.reset(new TTree("Events","Events"));
   m_tree->SetAutoSave(0);
   m_tree->SetAutoFlush(0);
   m_commonBranches.branch(*m_tree);
 
   m_lumiTree.reset(new TTree("LuminosityBlocks","LuminosityBlocks"));
   m_lumiTree->SetAutoSave(0);
   m_commonLumiBranches.branch(*m_lumiTree);
 
   m_runTree.reset(new TTree("Runs","Runs"));
   m_runTree->SetAutoSave(0);
   m_commonRunBranches.branch(*m_runTree);
   
   if (m_writeProvenance) {
       m_metaDataTree.reset(new TTree(edm::poolNames::metaDataTreeName().c_str(),"Job metadata"));
       m_metaDataTree->SetAutoSave(0);
       m_parameterSetsTree.reset(new TTree(edm::poolNames::parameterSetsTreeName().c_str(),"Parameter sets"));
       m_parameterSetsTree->SetAutoSave(0);
   }
 }

void NanoAODOutputModule::reallyCloseFile ( )

overrideprivatevirtual

Reimplemented from edm::one::OutputModuleBase.

Definition at line 350 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().

                                      {
   if (m_writeProvenance) {
       int basketSize = 16384; // fixme configurable?
       edm::fillParameterSetBranch(m_parameterSetsTree.get(), basketSize);
       edm::fillProcessHistoryBranch(m_metaDataTree.get(), basketSize, m_processHistoryRegistry);
       if (m_metaDataTree->GetNbranches() != 0) {
           m_metaDataTree->SetEntries(-1);
       }
       if (m_parameterSetsTree->GetNbranches() != 0) {
           m_parameterSetsTree->SetEntries(-1);
       }
   }
   m_file->Write();
   m_file->Close();
   m_file.reset();
   m_tree.release();     // apparently root has ownership
   m_lumiTree.release(); // 
   m_runTree.release(); // 
   m_metaDataTree.release(); //
   m_parameterSetsTree.release(); //
   edm::Service<edm::JobReport> jr;
   jr->outputFileClosed(m_jrToken);
 }

void NanoAODOutputModule::write ( edm::EventForOutput const & e )

overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 161 of file NanoAODOutputModule.cc.

References a, b, edm::EventID::event(), PatBasicFWLiteAnalyzer::events, edm::JobReport::eventWrittenToFile(), NanoAODOutputModule::CommonEventBranches::fill(), spr::find(), edm::EventForOutput::id(), m_autoFlush, m_commonBranches, m_eventsSinceFlush, m_evstrings, m_firstFlush, m_jrToken, m_processHistoryRegistry, m_tables, m_tree, m_triggers, m_triggers_areSorted, AlCaHLTBitMon_ParallelJobs::p, edm::OccurrenceForOutput::processHistory(), TriggerOutputBranches::processName(), edm::ProcessHistoryRegistry::registerProcessHistory(), edm::EventID::run(), jetUpdater_cfi::sort, and protons_cff::t.

                                                           {
   //Get data from 'e' and write it to the file
   edm::Service<edm::JobReport> jr;
   jr->eventWrittenToFile(m_jrToken, iEvent.id().run(), iEvent.id().event());
 
   if (m_autoFlush) {
     int64_t events = m_tree->GetEntriesFast();
     if (events == m_firstFlush) {
       m_tree->FlushBaskets();
       float maxMemory;
       if (m_autoFlush > 0) {
         // Estimate the memory we'll be using at the first full flush by
         // linearly scaling the number of events.
         float percentClusterDone = m_firstFlush / static_cast<float>(m_autoFlush);
         maxMemory = static_cast<float>(m_tree->GetTotBytes()) / percentClusterDone;
       } else if (m_tree->GetZipBytes() == 0) {
         maxMemory = 100*1024*1024; // Degenerate case of no information in the tree; arbitrary value
       } else {
         // Estimate the memory we'll be using by scaling the current compression ratio.
         float cxnRatio = m_tree->GetTotBytes() / static_cast<float>(m_tree->GetZipBytes());
         maxMemory = -m_autoFlush * cxnRatio;
         float percentBytesDone = -m_tree->GetZipBytes() / static_cast<float>(m_autoFlush);
         m_autoFlush = m_firstFlush / percentBytesDone;
       }
       //std::cout << "OptimizeBaskets: total bytes " << m_tree->GetTotBytes() << std::endl;
       //std::cout << "OptimizeBaskets: zip bytes " << m_tree->GetZipBytes() << std::endl;
       //std::cout << "OptimizeBaskets: autoFlush " << m_autoFlush << std::endl;
       //std::cout << "OptimizeBaskets: maxMemory " << static_cast<uint32_t>(maxMemory) << std::endl;
       //m_tree->OptimizeBaskets(static_cast<uint32_t>(maxMemory), 1, "d");
       m_tree->OptimizeBaskets(static_cast<uint32_t>(maxMemory), 1, "");
     }
     if (m_eventsSinceFlush == m_autoFlush) {
       m_tree->FlushBaskets();
       m_eventsSinceFlush = 0;
     }
     m_eventsSinceFlush++;
   }
 
   m_commonBranches.fill(iEvent.id());
   // fill all tables, starting from main tables and then doing extension tables
   for (unsigned int extensions = 0; extensions <= 1; ++extensions) {
       for (auto & t : m_tables) t.fill(iEvent,*m_tree,extensions);
   }
   if (!m_triggers_areSorted) {  // sort triggers/flags in inverse processHistory order, to save without any special label the most recent ones
     std::vector<std::string> pnames;
     for (auto& p : iEvent.processHistory())
       pnames.push_back(p.processName());
     std::sort(m_triggers.begin(), m_triggers.end(), [pnames](TriggerOutputBranches& a, TriggerOutputBranches& b) {
       return ((std::find(pnames.begin(), pnames.end(), a.processName()) - pnames.begin()) >
               (std::find(pnames.begin(), pnames.end(), b.processName()) - pnames.begin()));
     });
     m_triggers_areSorted = true;
   }
   // fill triggers
   for (auto & t : m_triggers) t.fill(iEvent,*m_tree);
   // fill event branches
   for (auto & t : m_evstrings) t.fill(iEvent,*m_tree);
   m_tree->Fill();
 
   m_processHistoryRegistry.registerProcessHistory(iEvent.processHistory());
 }

void NanoAODOutputModule::writeLuminosityBlock ( edm::LuminosityBlockForOutput const & iLumi )

overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 224 of file NanoAODOutputModule.cc.

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

                                                                                   {
   edm::Service<edm::JobReport> jr;
   jr->reportLumiSection(m_jrToken, iLumi.id().run(), iLumi.id().value());
 
   m_commonLumiBranches.fill(iLumi.id());
   for (auto & t : m_lumiTables) t.fill(iLumi,*m_lumiTree);
 
   m_lumiTree->Fill();
 
   m_processHistoryRegistry.registerProcessHistory(iLumi.processHistory());
 }

void NanoAODOutputModule::writeRun ( edm::RunForOutput const & iRun )

overrideprivatevirtual

Implements edm::one::OutputModuleBase.

Definition at line 237 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 protons_cff::t.

                                                          {
   edm::Service<edm::JobReport> jr;
   jr->reportRunNumber(m_jrToken, iRun.id().run());
 
   m_commonRunBranches.fill(iRun.id());
 
   for (auto & t : m_runTables) t.fill(iRun,*m_runTree);
 
   edm::Handle<nanoaod::UniqueString> hstring;
   for (const auto & p : m_nanoMetadata) {
     iRun.getByToken(p.second, hstring);
     TObjString *tos = dynamic_cast<TObjString *>(m_file->Get(p.first.c_str()));
     if (tos) {
         if (hstring->str() != tos->GetString()) throw cms::Exception("LogicError", "Inconsistent nanoMetadata " + p.first + " (" + hstring->str() +")");
     } else {
         auto ostr = std::make_unique<TObjString>(hstring->str().c_str());
         m_file->WriteTObject(ostr.release(), p.first.c_str()); 
     }
   }
 
   m_runTree->Fill();
 
   m_processHistoryRegistry.registerProcessHistory(iRun.processHistory());
 }

Member Data Documentation

int NanoAODOutputModule::m_autoFlush

private

Definition at line 69 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 66 of file NanoAODOutputModule.cc.

Referenced by openFile().

int NanoAODOutputModule::m_compressionLevel

private

Definition at line 64 of file NanoAODOutputModule.cc.

Referenced by openFile().

int NanoAODOutputModule::m_eventsSinceFlush {0}

private

Definition at line 65 of file NanoAODOutputModule.cc.

Referenced by write().

std::vector<EventStringOutputBranches> NanoAODOutputModule::m_evstrings

private

Definition at line 121 of file NanoAODOutputModule.cc.

Referenced by openFile(), and write().

bool NanoAODOutputModule::m_fakeName

private

Definition at line 68 of file NanoAODOutputModule.cc.

Referenced by openFile().

std::unique_ptr<TFile> NanoAODOutputModule::m_file

private

Definition at line 72 of file NanoAODOutputModule.cc.

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

std::string NanoAODOutputModule::m_fileName

private

Definition at line 62 of file NanoAODOutputModule.cc.

Referenced by openFile().

int NanoAODOutputModule::m_firstFlush {1000}

staticprivate

Definition at line 75 of file NanoAODOutputModule.cc.

Referenced by write().

edm::JobReport::Token NanoAODOutputModule::m_jrToken

private

Definition at line 71 of file NanoAODOutputModule.cc.

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

std::string NanoAODOutputModule::m_logicalFileName

private

Definition at line 63 of file NanoAODOutputModule.cc.

Referenced by openFile().

std::vector<SummaryTableOutputBranches> NanoAODOutputModule::m_lumiTables

private

Definition at line 124 of file NanoAODOutputModule.cc.

Referenced by openFile(), and writeLuminosityBlock().

std::unique_ptr<TTree> NanoAODOutputModule::m_lumiTree

private

Definition at line 73 of file NanoAODOutputModule.cc.

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

std::unique_ptr<TTree> NanoAODOutputModule::m_metaDataTree

private

Definition at line 73 of file NanoAODOutputModule.cc.

Referenced by openFile(), and reallyCloseFile().

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

private

Definition at line 126 of file NanoAODOutputModule.cc.

Referenced by openFile(), and writeRun().

std::unique_ptr<TTree> NanoAODOutputModule::m_parameterSetsTree

private

Definition at line 73 of file NanoAODOutputModule.cc.

Referenced by openFile(), and reallyCloseFile().

edm::ProcessHistoryRegistry NanoAODOutputModule::m_processHistoryRegistry

private

Definition at line 70 of file NanoAODOutputModule.cc.

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

std::vector<SummaryTableOutputBranches> NanoAODOutputModule::m_runTables

private

Definition at line 123 of file NanoAODOutputModule.cc.

Referenced by openFile(), and writeRun().

std::unique_ptr<TTree> NanoAODOutputModule::m_runTree

private

Definition at line 73 of file NanoAODOutputModule.cc.

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

std::vector<TableOutputBranches> NanoAODOutputModule::m_tables

private

Definition at line 118 of file NanoAODOutputModule.cc.

Referenced by openFile(), and write().

std::unique_ptr<TTree> NanoAODOutputModule::m_tree

private

Definition at line 73 of file NanoAODOutputModule.cc.

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

std::vector<TriggerOutputBranches> NanoAODOutputModule::m_triggers

private

Definition at line 119 of file NanoAODOutputModule.cc.

Referenced by openFile(), and write().

bool NanoAODOutputModule::m_triggers_areSorted = false

private

Definition at line 120 of file NanoAODOutputModule.cc.

Referenced by openFile(), and write().

bool NanoAODOutputModule::m_writeProvenance

private

Definition at line 67 of file NanoAODOutputModule.cc.

Referenced by openFile(), and reallyCloseFile().

Classes

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation