#include <JobReport.h>

Public Member Functions
void	addGeneratorInfo (std::string const &name, std::string const &value)

void	associateInputLumiSection (unsigned int runNumber, unsigned int lumiSection)

void	associateInputRun (unsigned int runNumber)

void	associateLumiSection (unsigned int runNumber, unsigned int lumiSection)

void	associateRun (unsigned int runNumber)

void	flushFiles (void)

InputFile &	getInputFileForToken (Token t)

OutputFile &	getOutputFileForToken (Token t)

void	insertInputForOutputs (Token t)

	JobReportImpl (std::ostream *iOst)

void	openInputFiles (std::vector< Token > &tokens)

void	openOutputFiles (std::vector< Token > &tokens)

void	removeInputFileRecord_ (Token t)

void	removeOutputFileRecord_ (Token t)

void	writeGeneratorInfo (void)

void	writeInputFile (InputFile const &f)

void	writeOutputFile (OutputFile const &f)

Public Attributes
std::set< std::string > *	fastClonedBranches_

std::map< std::string, std::string >	generatorInfo_

std::vector< InputFile >	inputFiles_

std::ostream *	ost_

std::vector< OutputFile >	outputFiles_

std::map< std::string, long long >	readBranches_

Detailed Description

Definition at line 125 of file JobReport.h.

Constructor & Destructor Documentation

edm::JobReport::JobReportImpl::JobReportImpl ( std::ostream * iOst )

inline

Definition at line 223 of file JobReport.h.

223 : ost_(iOst) {}

edm::JobReport::JobReportImpl::ost_

std::ostream * ost_

Definition: JobReport.h:230

Member Function Documentation

void edm::JobReport::JobReportImpl::addGeneratorInfo	(	std::string const &	name,
		std::string const &	value
	)

Definition at line 306 of file JobReport.cc.

References mergeVDriftHistosByStation::name, and relativeConstraints::value.

                                                                           {
 
     generatorInfo_[name] = value;
   }

void edm::JobReport::JobReportImpl::associateInputLumiSection	(	unsigned int	runNumber,
		unsigned int	lumiSection
	)

Definition at line 396 of file JobReport.cc.

References edm::JobReport::RunReport::runNumber, convertSQLiteXML::runNumber, edm::JobReport::InputFile::runReports, and interactiveExample::theFile.

                                                                                                       {
     std::vector<Token> openFiles;
     openInputFiles(openFiles);
     for(std::vector<Token>::iterator iToken = openFiles.begin(), iTokenEnd = openFiles.end(); iToken != iTokenEnd; ++iToken) {
       //
       // Loop over all open input files
       //
       JobReport::InputFile& theFile = inputFiles_[*iToken];
 
       //
       // check run is known to file
       // if not, add a run report for that run
       if(theFile.runReports.count(runNumber) == 0) {
         JobReport::RunReport newReport = JobReport::RunReport();
         newReport.runNumber = runNumber;
         theFile.runReports.insert(std::make_pair(runNumber, newReport));
       }
 
       //
       // Get the run report for this run, now that it either was created
       // or already existed
       std::map<JobReport::RunNumber, JobReport::RunReport>::iterator finder;
       finder = theFile.runReports.find(runNumber);
 
       //
       // add the lumi section to the report, the lumi list is a Set
       // so duplicates dont matter
       (finder->second).lumiSections.insert(lumiSect);
     }
   }

void edm::JobReport::JobReportImpl::associateInputRun ( unsigned int runNumber )

Definition at line 347 of file JobReport.cc.

References edm::JobReport::RunReport::runNumber, convertSQLiteXML::runNumber, edm::JobReport::InputFile::runReports, and interactiveExample::theFile.

                                                                        {
     std::vector<Token> openFiles;
     openInputFiles(openFiles);
     for(std::vector<Token>::iterator iToken = openFiles.begin(), iTokenEnd = openFiles.end(); iToken != iTokenEnd; ++iToken) {
       JobReport::InputFile& theFile = inputFiles_[*iToken];
 
       //
       // check run is known to file
       // if not, add a run report for that run
       if(theFile.runReports.count(runNumber) == 0) {
         JobReport::RunReport newReport = JobReport::RunReport();
         newReport.runNumber = runNumber;
         theFile.runReports.insert(std::make_pair(runNumber, newReport));
       }
 
     }
   }

void edm::JobReport::JobReportImpl::associateLumiSection	(	unsigned int	runNumber,
		unsigned int	lumiSection
	)

Definition at line 365 of file JobReport.cc.

References edm::JobReport::RunReport::runNumber, convertSQLiteXML::runNumber, edm::JobReport::OutputFile::runReports, and interactiveExample::theFile.

                                                                                                  {
     std::vector<Token> openFiles;
     openOutputFiles(openFiles);
     for(std::vector<Token>::iterator iToken = openFiles.begin(), iTokenEnd = openFiles.end(); iToken != iTokenEnd; ++iToken) {
       //
       // Loop over all open output files
       //
       JobReport::OutputFile& theFile = outputFiles_[*iToken];
 
       //
       // check run is known to file
       // if not, add a run report for that run
       if(theFile.runReports.count(runNumber) == 0) {
         JobReport::RunReport newReport = JobReport::RunReport();
         newReport.runNumber = runNumber;
         theFile.runReports.insert(std::make_pair(runNumber, newReport));
       }
 
       //
       // Get the run report for this run, now that it either was created
       // or already existed
       std::map<JobReport::RunNumber, JobReport::RunReport>::iterator finder;
       finder = theFile.runReports.find(runNumber);
 
       //
       // add the lumi section to the report, the lumi list is a Set
       // so duplicates dont matter
       (finder->second).lumiSections.insert(lumiSect);
     }
   }

void edm::JobReport::JobReportImpl::associateRun ( unsigned int runNumber )

Definition at line 327 of file JobReport.cc.

References edm::JobReport::RunReport::runNumber, convertSQLiteXML::runNumber, edm::JobReport::OutputFile::runReports, and interactiveExample::theFile.

                                                                   {
     std::vector<Token> openFiles;
     openOutputFiles(openFiles);
     for(std::vector<Token>::iterator iToken = openFiles.begin(), iTokenEnd = openFiles.end(); iToken != iTokenEnd; ++iToken) {
       JobReport::OutputFile& theFile = outputFiles_[*iToken];
 
       //
       // check run is known to file
       // if not, add a run report for that run
       if(theFile.runReports.count(runNumber) == 0) {
         JobReport::RunReport newReport = JobReport::RunReport();
         newReport.runNumber = runNumber;
         theFile.runReports.insert(
                  std::make_pair(runNumber, newReport)
                 );
       }
 
     }
   }

void edm::JobReport::JobReportImpl::flushFiles ( void )

Definition at line 291 of file JobReport.cc.

                                                 {
       for(std::vector<JobReport::InputFile>::iterator ipos = inputFiles_.begin(), iposEnd = inputFiles_.end();
           ipos != iposEnd; ++ipos) {
         if(!(ipos->fileHasBeenClosed)) {
           writeInputFile(*ipos);
         }
       }
       for(std::vector<JobReport::OutputFile>::iterator opos = outputFiles_.begin(), oposEnd = outputFiles_.end();
           opos != oposEnd; ++opos) {
         if(!(opos->fileHasBeenClosed)) {
           writeOutputFile(*opos);
         }
       }
     }

JobReport::InputFile & edm::JobReport::JobReportImpl::getInputFileForToken ( JobReport::Token t )

Definition at line 143 of file JobReport.cc.

References edm::hlt::Exception, inputFiles_, edm::errors::LogicError, and lumiQTWidget::t.

                                                                                      {
         if(t >= inputFiles_.size()) {
             throw edm::Exception(edm::errors::LogicError)
               << "Access reported for input file with token "
               << t
               << " but no matching input file is found\n";
         }
 
         if(inputFiles_[t].fileHasBeenClosed) {
             throw edm::Exception(edm::errors::LogicError)
               << "Access reported for input file with token "
               << t
               << " after this file has been closed.\n"
               << "File record follows:\n"
               << inputFiles_[t]
               << '\n';
         }
 
       return inputFiles_[t];
     }

JobReport::OutputFile & edm::JobReport::JobReportImpl::getOutputFileForToken ( JobReport::Token t )

Definition at line 164 of file JobReport.cc.

References edm::hlt::Exception, edm::errors::LogicError, and lumiQTWidget::t.

                                                                                        {
         if(t >= outputFiles_.size()) {
             throw edm::Exception(edm::errors::LogicError)
               << "Access reported for output file with token "
               << t
               << " but no matching output file is found\n";
         }
         if(outputFiles_[t].fileHasBeenClosed) {
             throw edm::Exception(edm::errors::LogicError)
               << "Access reported for output file with token "
               << t
               << " after this file has been closed.\n"
               << "File record follows:\n"
               << outputFiles_[t]
               << '\n';
         }
       return outputFiles_[t];
     }

void edm::JobReport::JobReportImpl::insertInputForOutputs ( JobReport::Token t )

Definition at line 189 of file JobReport.cc.

References GetRecoTauVFromDQM_MC_cff::outFile.

                                                                        {
         typedef std::vector<JobReport::OutputFile>::iterator iterator;
         for(iterator outFile = outputFiles_.begin(), outFileEnd = outputFiles_.end(); outFile != outFileEnd; ++outFile) {
           outFile->contributingInputs.push_back(t);
         }
     }

void edm::JobReport::JobReportImpl::openInputFiles ( std::vector< Token > & tokens )

Definition at line 201 of file JobReport.cc.

References i.

                                                                                  {
         result.reserve(inputFiles_.size());
         for(unsigned int i = 0; i < inputFiles_.size(); ++i) {
           if(inputFiles_[i].fileHasBeenClosed == false) {
             result.push_back(i);
           }
         }
     }

void edm::JobReport::JobReportImpl::openOutputFiles ( std::vector< Token > & tokens )

Definition at line 215 of file JobReport.cc.

References i.

                                                                                   {
         result.reserve(outputFiles_.size());
         for(unsigned int i = 0; i < outputFiles_.size(); ++i) {
           if(outputFiles_[i].fileHasBeenClosed == false) {
             result.push_back(i);
           }
         }
     }

void edm::JobReport::JobReportImpl::removeInputFileRecord_ ( Token t )

void edm::JobReport::JobReportImpl::removeOutputFileRecord_ ( Token t )

void edm::JobReport::JobReportImpl::writeGeneratorInfo ( void )

Definition at line 312 of file JobReport.cc.

References lumiQueryAPI::msg, and pos.

                                                       {
     if(ost_) {
       *ost_ << "\n<GeneratorInfo>\n";
       for(std::map<std::string, std::string>::iterator pos = generatorInfo_.begin(),
           posEnd = generatorInfo_.end();
           pos != posEnd;  ++pos) {
         std::ostringstream msg;
         msg << "\n<Data Name=\"" << pos->first
           << "\" Value=\"" << pos->second << "\"/>";
         *ost_ << msg.str();
       }
       *ost_ << "</GeneratorInfo>\n";
     }
   }

void edm::JobReport::JobReportImpl::writeInputFile ( JobReport::InputFile const & f )

Definition at line 229 of file JobReport.cc.

References f.

                                                                            {
       if(ost_) {
         *ost_ << f ;
         *ost_ << "\n<Runs>";
         typedef std::map<JobReport::RunNumber, JobReport::RunReport>::const_iterator const_iterator;
         for(const_iterator iRun = f.runReports.begin(), iRunEnd = f.runReports.end(); iRun != iRunEnd; ++iRun) {
           *ost_ << iRun->second;
         }
         *ost_ << "\n</Runs>\n";
         *ost_ << "</InputFile>\n";
         *ost_ << std::flush;
       }
         //LogInfo("FwkJob") << f;
     }

void edm::JobReport::JobReportImpl::writeOutputFile ( JobReport::OutputFile const & f )

Definition at line 258 of file JobReport.cc.

References f, edm::findOrDefault(), edm::JobReport::InputFile::logicalFileName, and edm::JobReport::InputFile::physicalFileName.

                                                                              {
       if(ost_) {
         *ost_ << "\n<File>";
         *ost_ << f;
 
         *ost_ << "\n<Runs>";
         typedef std::map<JobReport::RunNumber, JobReport::RunReport>::const_iterator const_iterator;
         for(const_iterator iRun = f.runReports.begin(), iRunEnd = f.runReports.end(); iRun != iRunEnd; ++iRun) {
           *ost_ << iRun->second;
         }
         *ost_ << "\n</Runs>\n";
 
         *ost_ << "\n<Inputs>";
         for(std::vector<JobReport::Token>::const_iterator
           iInput = f.contributingInputs.begin(),
           iInputEnd = f.contributingInputs.end();
           iInput != iInputEnd; ++iInput) {
             JobReport::InputFile inpFile = inputFiles_[*iInput];
             *ost_ << "\n<Input>";
             *ost_ << "\n  <LFN>" << TiXmlText(inpFile.logicalFileName) << "</LFN>";
             *ost_ << "\n  <PFN>" << TiXmlText(inpFile.physicalFileName) << "</PFN>";
             *ost_ << "\n  <FastCopying>" << findOrDefault(f.fastCopyingInputs, inpFile.physicalFileName) << "</FastCopying>";
             *ost_ << "\n</Input>";
         }
         *ost_ << "\n</Inputs>";
         *ost_ << "\n</File>\n";
       }
     }

Member Data Documentation

std::set<std::string>* edm::JobReport::JobReportImpl::fastClonedBranches_

Definition at line 229 of file JobReport.h.

std::map<std::string, std::string> edm::JobReport::JobReportImpl::generatorInfo_

Definition at line 227 of file JobReport.h.

std::vector<InputFile> edm::JobReport::JobReportImpl::inputFiles_

Definition at line 225 of file JobReport.h.

Referenced by getInputFileForToken().

std::ostream* edm::JobReport::JobReportImpl::ost_

Definition at line 230 of file JobReport.h.

std::vector<OutputFile> edm::JobReport::JobReportImpl::outputFiles_

Definition at line 226 of file JobReport.h.

std::map<std::string, long long> edm::JobReport::JobReportImpl::readBranches_

Definition at line 228 of file JobReport.h.

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation