20 #include <boost/shared_ptr.hpp> 21 #include <boost/filesystem.hpp> 50 class TreeHelperBase {
52 TreeHelperBase(): m_wasFilled(
false), m_firstIndex(0),m_lastIndex(0) {}
53 virtual ~TreeHelperBase(){}
56 if(m_wasFilled) {++m_lastIndex;}
58 bool wasFilled()
const {
return m_wasFilled;}
59 void getRangeAndReset(ULong64_t& iFirstIndex, ULong64_t& iLastIndex) {
60 iFirstIndex = m_firstIndex;
61 iLastIndex = m_lastIndex;
63 m_firstIndex = m_lastIndex +1;
64 m_lastIndex = m_firstIndex;
69 ULong64_t m_firstIndex;
70 ULong64_t m_lastIndex;
74 class TreeHelper :
public TreeHelperBase {
76 TreeHelper(TTree* iTree,
std::string* iFullNameBufferPtr ):
77 m_tree(iTree), m_flagBuffer(0),m_fullNameBufferPtr(iFullNameBufferPtr){
setup();}
80 m_flagBuffer = iElement->
getTag();
82 assert(
nullptr!=m_bufferPtr);
93 m_bufferPtr =
nullptr;
97 uint32_t m_flagBuffer;
102 class IntTreeHelper:
public TreeHelperBase {
104 IntTreeHelper(TTree* iTree,
std::string* iFullNameBufferPtr):
105 m_tree(iTree), m_flagBuffer(0),m_fullNameBufferPtr(iFullNameBufferPtr)
110 m_flagBuffer = iElement->
getTag();
122 uint32_t m_flagBuffer;
127 class FloatTreeHelper:
public TreeHelperBase {
129 FloatTreeHelper(TTree* iTree,
std::string* iFullNameBufferPtr):
130 m_tree(iTree), m_flagBuffer(0),m_fullNameBufferPtr(iFullNameBufferPtr)
134 m_flagBuffer = iElement->
getTag();
146 uint32_t m_flagBuffer;
151 class StringTreeHelper:
public TreeHelperBase {
153 StringTreeHelper(TTree* iTree,
std::string* iFullNameBufferPtr):
154 m_tree(iTree), m_flagBuffer(0),m_fullNameBufferPtr(iFullNameBufferPtr), m_bufferPtr(&m_buffer)
158 m_flagBuffer = iElement->
getTag();
170 uint32_t m_flagBuffer;
179 class ModuleCallingContext;
195 void reallyCloseFile()
override;
198 void finishEndFile();
229 static TreeHelperBase*
235 return new IntTreeHelper(iTree,iFullNameBufferPtr);
237 return new FloatTreeHelper(iTree,iFullNameBufferPtr);
239 return new StringTreeHelper(iTree,iFullNameBufferPtr);
241 return new TreeHelper<TH1F>(iTree,iFullNameBufferPtr);
243 return new TreeHelper<TH1S>(iTree,iFullNameBufferPtr);
245 return new TreeHelper<TH1D>(iTree,iFullNameBufferPtr);
247 return new TreeHelper<TH2F>(iTree,iFullNameBufferPtr);
249 return new TreeHelper<TH2S>(iTree,iFullNameBufferPtr);
251 return new TreeHelper<TH2D>(iTree,iFullNameBufferPtr);
253 return new TreeHelper<TH3F>(iTree,iFullNameBufferPtr);
255 return new TreeHelper<TProfile>(iTree,iFullNameBufferPtr);
257 return new TreeHelper<TProfile2D>(iTree,iFullNameBufferPtr);
272 edm::
one::OutputModule<>(pset),
273 m_fileName(pset.getUntrackedParameter<
std::
string>(
"fileName")),
274 m_logicalFileName(pset.getUntrackedParameter<
std::
string>(
"logicalFileName")),
277 m_presentHistoryIndex(0),
278 m_filterOnRun(pset.getUntrackedParameter<unsigned
int>(
"filterOnRun")),
279 m_enableMultiThread(
false),
280 m_fullNameBufferPtr(&m_fullNameBuffer),
320 return nullptr!=
m_file.get();
337 "DQMRootOutputModule",
342 std::vector<std::string>()
364 tree->SetDirectory(
m_file.get());
403 for(std::vector<MonitorElement*>::iterator it =
items.begin(), itEnd=
items.end();
406 if((*it)->getLumiFlag()) {
407 std::map<unsigned int,unsigned int>::iterator itFound =
m_dqmKindToTypeIndex.find((*it)->kind());
424 bool storedLumiIndex =
false;
425 unsigned int typeIndex = 0;
429 if((*it)->wasFilled()) {
432 storedLumiIndex =
true;
436 if(not storedLumiIndex) {
464 for(std::vector<MonitorElement*>::iterator it =
items.begin(), itEnd=
items.end();
467 if(not (*it)->getLumiFlag()) {
468 std::map<unsigned int,unsigned int>::iterator itFound =
m_dqmKindToTypeIndex.find((*it)->kind());
485 unsigned int typeIndex = 0;
489 if((*it)->wasFilled()) {
516 processHistoryTree->SetDirectory(metaDataDirectory);
518 unsigned int index = 0;
533 assert(
nullptr!=history);
535 for(edm::ProcessHistory::collection_type::const_iterator itPC = history->
begin(), itPCEnd = history->
end();
538 processName = itPC->processName();
539 releaseVersion = itPC->releaseVersion();
540 passID = itPC->passID();
541 parameterSetID = itPC->parameterSetID().compactForm();
542 processHistoryTree->Fill();
548 parameterSetsTree->SetDirectory(metaDataDirectory);
553 assert(
nullptr!=psr);
558 it->second.toString(blob);
559 parameterSetsTree->Fill();
586 ->setComment(
"Only write the run with this run number. 0 means write all runs.");
588 ->setComment(
"UNUSED Only here to allow older configurations written for PoolOutputModule to work.");
589 const std::vector<std::string>
keep = {
"drop *",
"keep DQMToken_*_*_*"};
595 ->setComment(
"PSet is only used by Data Operations and not by this module.");
const_iterator begin() const
void reallyCloseFile() override
Timestamp const & endTime() const
virtual ProcessHistory const & processHistory() const
int64_t getIntValue() const
boost::uint64_t value() const
map_type::const_iterator const_iterator
ModuleDescription const & description() const
bool getMapped(ProcessHistoryID const &key, ProcessHistory &value) const
ParameterDescriptionBase * addUntracked(U const &iLabel, T const &value)
const_iterator end() const
void writeLuminosityBlock(edm::LuminosityBlockForOutput const &) override
void write(edm::EventForOutput const &e) override
void setAllowAnything()
allow any parameter label/value pairs
double getFloatValue() const
TObject * getRootObject() const
#define DEFINE_FWK_MODULE(type)
unsigned int m_presentHistoryIndex
bool registerProcessHistory(ProcessHistory const &processHistory)
static TreeHelperBase * makeHelper(unsigned int iTypeIndex, TTree *iTree, std::string *iFullNameBufferPtr)
edm::ProcessHistoryRegistry m_processHistoryRegistry
def setup(process, global_tag, zero_tesla=False)
void reportRunNumber(JobReport::Token token, unsigned int run)
void find(edm::Handle< EcalRecHitCollection > &hits, DetId thisDet, std::vector< EcalRecHitCollection::const_iterator > &hit, bool debug=false)
~DQMRootOutputModule() override
Timestamp const & beginTime() const
std::string m_fullNameBuffer
const uint32_t getTag() const
std::map< unsigned int, unsigned int > m_dqmKindToTypeIndex
void addDefault(ParameterSetDescription const &psetDescription)
static void fillDescription(ParameterSetDescription &desc, std::vector< std::string > const &iDefaultOutputCommands=ProductSelectorRules::defaultSelectionStrings())
const_iterator begin() const
Token outputFileOpened(std::string const &physicalFileName, std::string const &logicalFileName, std::string const &catalog, std::string const &outputModuleClassName, std::string const &moduleLabel, std::string const &guid, std::string const &dataType, std::string const &branchHash, std::vector< std::string > const &branchNames)
Timestamp const & endTime() const
std::unique_ptr< TFile > m_file
const std::string & getStringValue() const
const std::string getFullname() const
get full name of ME including Pathname
DQMRootOutputModule(edm::ParameterSet const &pset)
std::vector< boost::shared_ptr< TreeHelperBase > > m_treeHelpers
std::string * m_fullNameBufferPtr
static void fillDescriptions(edm::ConfigurationDescriptions &descriptions)
void writeRun(edm::RunForOutput const &) override
std::string toString() const
bool isFileOpen() const override
std::string const & processName() const
unsigned int m_filterOnRun
Timestamp const & beginTime() const
const_iterator end() const
ProcessHistoryID const & processHistoryID() const
void outputFileClosed(Token fileToken)
edm::JobReport::Token m_jrToken
void openFile(edm::FileBlock const &) override
ParameterDescriptionBase * addOptionalUntracked(U const &iLabel, T const &value)
static void fillDescriptions(edm::ConfigurationDescriptions &descriptions)
LuminosityBlockID const & id() const
std::string m_logicalFileName
TimeValue_t value() const
static Registry * instance()
std::vector< MonitorElement * > getAllContents(std::string const &path, uint32_t runNumber=0, uint32_t lumi=0) const
std::string createGlobalIdentifier()
void reportLumiSection(JobReport::Token token, unsigned int run, unsigned int lumiSectId, unsigned long nEvents=0)
std::vector< edm::ProcessHistoryID > m_seenHistories