edm::InputFile Class Reference

#include <InputFile.h>

Public Member Functions
void	Close ()
void	eventReadFromFile () const
TObject *	Get (char const *name)
TFileCacheRead *	GetCacheRead () const
	InputFile (char const *fileName, char const *msg, InputType inputType)
	InputFile (InputFile const &)=delete
void	inputFileOpened (std::string const &logicalFileName, std::string const &inputType, std::string const &moduleName, std::string const &label, std::string const &fid, std::vector< std::string > const &branchNames)
void	logFileAction (char const *msg, char const *fileName) const
InputFile &	operator= (InputFile const &)=delete
void	reportInputLumiSection (unsigned int run, unsigned int lumi) const
void	reportInputRunNumber (unsigned int run) const
void	SetCacheRead (TFileCacheRead *tfcr)
	~InputFile ()

Static Public Member Functions
static void	reportFallbackAttempt (std::string const &pfn, std::string const &logicalFileName, std::string const &errorMessage)
static void	reportReadBranch (InputType inputType, std::string const &branchname)
static void	reportReadBranches ()
static void	reportSkippedFile (std::string const &fileName, std::string const &logicalFileName)

Private Attributes
edm::propagate_const< std::unique_ptr< TFile > >	file_
std::string	fileName_
InputType	inputType_
JobReport::Token	reportToken_

Detailed Description

Definition at line 21 of file InputFile.h.

Constructor & Destructor Documentation

InputFile() [1/2]

InputFile::InputFile ( char const *  fileName, char const *  msg, InputType  inputType  )

explicit

Definition at line 18 of file InputFile.cc.

References MillePedeFileConverter_cfg::e, Exception, file_, MillePedeFileConverter_cfg::fileName, edm::errors::FileOpenError, edm::threadLocalException::getException(), logFileAction(), mps_check::msg, and edm::threadLocalException::setException().

      : file_(), fileName_(fileName), reportToken_(0), inputType_(inputType) {
    logFileAction(msg, fileName);
    {
      // ROOT's context management implicitly assumes that a file is opened and
      // closed on the same thread.  To avoid the problem, we declare a local
      // TContext object; when it goes out of scope, its destructor unregisters
      // the context, guaranteeing the context is unregistered in the same thread
      // it was registered in.  Fixes issue #15524.
      TDirectory::TContext contextEraser;

      file_ = std::unique_ptr<TFile>(TFile::Open(fileName));  // propagate_const<T> has no reset() function
    }
    std::exception_ptr e = edm::threadLocalException::getException();
    if (e != std::exception_ptr()) {
      edm::threadLocalException::setException(std::exception_ptr());
      std::rethrow_exception(e);
    }
    if (!file_) {
      throw edm::Exception(errors::FileOpenError) << "TFile::Open failed.";
    }
    if (file_->IsZombie()) {
      throw edm::Exception(errors::FileOpenError) << "TFile::Open returned zombie.";
    }

    logFileAction("  Successfully opened file ", fileName);
  }

~InputFile()

InputFile::~InputFile

(

)

Definition at line 46 of file InputFile.cc.

References Close().

{ Close(); }

InputFile() [2/2]

edm::InputFile::InputFile ( InputFile const &  )

delete

Member Function Documentation

Close()

void InputFile::Close

(

)

Definition at line 86 of file InputFile.cc.

References cppFunctionSkipper::exception, file_, fileName_, inputType_, logFileAction(), and reportToken_.

Referenced by ~InputFile().

                        {
    if (file_->IsOpen()) {
      file_->Close();
      try {
        logFileAction("  Closed file ", fileName_.c_str());
        Service<JobReport> reportSvc;
        reportSvc->inputFileClosed(inputType_, reportToken_);
      } catch (std::exception const&) {
        // If Close() called in a destructor after an exception throw, the services may no longer be active.
        // Therefore, we catch any reasonable new exception.
      }
    }
  }

eventReadFromFile()

void InputFile::eventReadFromFile

(

)

const

Definition at line 59 of file InputFile.cc.

References inputType_, and reportToken_.

                                          {
    Service<JobReport> reportSvc;
    reportSvc->eventReadFromFile(inputType_, reportToken_);
  }

Get()

TObject* edm::InputFile::Get ( char const *  name )

inline

Definition at line 48 of file InputFile.h.

References file_, and Skims_PA_cff::name.

{ return file_->Get(name); }

GetCacheRead()

TFileCacheRead* edm::InputFile::GetCacheRead ( ) const

inline

Definition at line 49 of file InputFile.h.

References file_.

{ return file_->GetCacheRead(); }

inputFileOpened()

void InputFile::inputFileOpened	(	std::string const &	logicalFileName,
		std::string const &	inputType,
		std::string const &	moduleName,
		std::string const &	label,
		std::string const &	fid,
		std::vector< std::string > const &	branchNames
	)

Definition at line 48 of file InputFile.cc.

References haddnano::branchNames, fileName_, label, edm::moduleName(), reportToken_, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                           {
    Service<JobReport> reportSvc;
    reportToken_ = reportSvc->inputFileOpened(
        fileName_, logicalFileName, std::string(), inputType, moduleName, label, fid, branchNames);
  }

logFileAction()

void InputFile::logFileAction	(	char const *	msg,
		char const *	fileName
	)		const

Definition at line 100 of file InputFile.cc.

References MillePedeFileConverter_cfg::fileName, edm::FlushMessageLog(), and mps_check::msg.

Referenced by Close(), and InputFile().

                                                                           {
    LogAbsolute("fileAction") << std::setprecision(0) << TimeOfDay() << msg << fileName;
    FlushMessageLog();
  }

operator=()

InputFile& edm::InputFile::operator= ( InputFile const &  )

delete

reportFallbackAttempt()

void InputFile::reportFallbackAttempt ( std::string const &  pfn, std::string const &  logicalFileName, std::string const &  errorMessage  )

static

Definition at line 79 of file InputFile.cc.

                                                                       {
    Service<JobReport> reportSvc;
    reportSvc->reportFallbackAttempt(pfn, logicalFileName, errorMessage);
  }

reportInputLumiSection()

void InputFile::reportInputLumiSection	(	unsigned int	run,
		unsigned int	lumi
	)		const

Definition at line 69 of file InputFile.cc.

References writedatasetfile::run.

                                                                                  {
    Service<JobReport> reportSvc;
    reportSvc->reportInputLumiSection(run, lumi);
  }

reportInputRunNumber()

void InputFile::reportInputRunNumber

(

unsigned int

run

)

const

Definition at line 64 of file InputFile.cc.

References writedatasetfile::run.

                                                             {
    Service<JobReport> reportSvc;
    reportSvc->reportInputRunNumber(run);
  }

reportReadBranch()

void InputFile::reportReadBranch ( InputType  inputType, std::string const &  branchname  )

static

Definition at line 110 of file InputFile.cc.

References electrons_cff::branchName.

Referenced by edm::RootDelayedReader::getProduct_().

                                                                                   {
    Service<JobReport> reportSvc;
    reportSvc->reportReadBranch(inputType, branchName);
  }

reportReadBranches()

void InputFile::reportReadBranches ( )

static

Definition at line 105 of file InputFile.cc.

Referenced by edm::EmbeddedRootSource::endJob(), and edm::PoolSource::endJob().

                                     {
    Service<JobReport> reportSvc;
    reportSvc->reportReadBranches();
  }

reportSkippedFile()

void InputFile::reportSkippedFile ( std::string const &  fileName, std::string const &  logicalFileName  )

static

Definition at line 74 of file InputFile.cc.

References MillePedeFileConverter_cfg::fileName.

Referenced by edm::RootInputFileSequence::initTheFile().

                                                                                               {
    Service<JobReport> reportSvc;
    reportSvc->reportSkippedFile(fileName, logicalFileName);
  }

SetCacheRead()

void edm::InputFile::SetCacheRead ( TFileCacheRead *  tfcr )

inline

Definition at line 50 of file InputFile.h.

References file_.

{ file_->SetCacheRead(tfcr, nullptr, TFile::kDoNotDisconnect); }

Member Data Documentation

file_

edm::propagate_const<std::unique_ptr<TFile> > edm::InputFile::file_

private

Definition at line 54 of file InputFile.h.

Referenced by Close(), Get(), GetCacheRead(), InputFile(), and SetCacheRead().

fileName_

std::string edm::InputFile::fileName_

private

Definition at line 55 of file InputFile.h.

Referenced by Close(), and inputFileOpened().

inputType_

InputType edm::InputFile::inputType_

private

Definition at line 57 of file InputFile.h.

Referenced by Close(), and eventReadFromFile().

reportToken_

JobReport::Token edm::InputFile::reportToken_

private

Definition at line 56 of file InputFile.h.

Referenced by Close(), eventReadFromFile(), and inputFileOpened().