Inheritance diagram for art::TrivialFileDelivery:

Classes
struct	Config

Public Types
using	Parameters = ServiceTable< Config >

Public Member Functions
	TrivialFileDelivery (Parameters const &config)

void	doConfigure (std::vector< std::string > const &items) override

int	doGetNextFileURI (std::string &uri, double &waitTime) override

void	doUpdateStatus (std::string const &uri, FileDisposition status) override

void	doOutputFileOpened (std::string const &module_label) override

void	doOutputModuleInitiated (std::string const &module_label, fhicl::ParameterSet const &pset) override

void	doOutputFileClosed (std::string const &module_label, std::string const &file) override

void	doEventSelected (std::string const &module_label, EventID const &event_id, HLTGlobalStatus const &acceptance_info) override

bool	doIsSearchable () override

void	doRewind () override

void	configure (std::vector< std::string > const &items)

int	getNextFileURI (std::string &uri, double &waitTime)

void	updateStatus (std::string const &uri, FileDisposition status)

void	outputFileClosed (std::string const &module_label, std::string const &fileFQname)

void	outputFileOpened (std::string const &module_label)

void	outputModuleInitiated (std::string const &module_label, fhicl::ParameterSet const &pset)

void	eventSelected (std::string const &module_label, EventID const &event_id, HLTGlobalStatus const &acceptance_info)

bool	isSearchable ()

void	rewind ()

Private Member Functions
std::string	prependFileDesignation (std::string const &name) const

Private Attributes
std::recursive_mutex	mutex_ {}

std::vector< std::string >	fileList_ {}

std::vector< std::string >::const_iterator	nextFile_ {fileList_.cbegin()}

std::vector< std::string >::const_iterator	endOfFiles_ {fileList_.cend()}

Detailed Description

Definition at line 36 of file TrivialFileDelivery_service.cc.

Member Typedef Documentation

using art::TrivialFileDelivery::Parameters = ServiceTable<Config>

Definition at line 39 of file TrivialFileDelivery_service.cc.

Constructor & Destructor Documentation

art::TrivialFileDelivery::TrivialFileDelivery ( TrivialFileDelivery::Parameters const & config )

Definition at line 68 of file TrivialFileDelivery_service.cc.

70 {}

Member Function Documentation

void art::CatalogInterface::configure ( std::vector< std::string > const & items )

inlineinherited

Definition at line 65 of file CatalogInterface.h.

References art::CatalogInterface::doConfigure().

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     doConfigure(items);
   }

void art::TrivialFileDelivery::doConfigure ( std::vector< std::string > const & items )

overridevirtual

Implements art::CatalogInterface.

Definition at line 73 of file TrivialFileDelivery_service.cc.

   {
     std::lock_guard sentry{mutex_};
     fileList_ = items;
     nextFile_ = fileList_.begin();
     endOfFiles_ = fileList_.end();
   }

void art::TrivialFileDelivery::doEventSelected	(	std::string const &	module_label,
		EventID const &	event_id,
		HLTGlobalStatus const &	acceptance_info
	)

overridevirtual

Implements art::CatalogInterface.

Definition at line 128 of file TrivialFileDelivery_service.cc.

131 {}

int art::TrivialFileDelivery::doGetNextFileURI	(	std::string &	uri,
		double &	waitTime
	)

overridevirtual

Implements art::CatalogInterface.

Definition at line 82 of file TrivialFileDelivery_service.cc.

References art::detail::FDS::NO_MORE_FILES, and SUCCESS.

   {
     std::lock_guard sentry{mutex_};
     FileDeliveryStatus stat;
     if (nextFile_ == endOfFiles_) {
       stat = FileDeliveryStatus::NO_MORE_FILES;
       return stat;
     }
     // Look for protocol.
     auto pos = nextFile_->find("://");
     if (pos == string::npos) {
       // Bare filename.
       throwIfFileNotExist(nextFile_->c_str());
       uri = prependFileDesignation(*nextFile_);
     } else if (nextFile_->substr(0, pos) == "file") {
       // file://
       throwIfFileNotExist(nextFile_->c_str() + pos + 3);
       uri = *nextFile_;
     } else {
       // Unknown URI.
       uri = *nextFile_;
     }
     waitTime = 0.0;
     stat = FileDeliveryStatus::SUCCESS;
     ++nextFile_;
     return stat;
   }

bool art::TrivialFileDelivery::doIsSearchable ( )

overridevirtual

Implements art::CatalogInterface.

Definition at line 134 of file TrivialFileDelivery_service.cc.

   {
     return true;
   }

void art::TrivialFileDelivery::doOutputFileClosed	(	std::string const &	module_label,
		std::string const &	file
	)

overridevirtual

Implements art::CatalogInterface.

Definition at line 124 of file TrivialFileDelivery_service.cc.

125 {}

void art::TrivialFileDelivery::doOutputFileOpened ( std::string const & module_label )

overridevirtual

Implements art::CatalogInterface.

Definition at line 115 of file TrivialFileDelivery_service.cc.

116 {}

void art::TrivialFileDelivery::doOutputModuleInitiated	(	std::string const &	module_label,
		fhicl::ParameterSet const &	pset
	)

overridevirtual

Implements art::CatalogInterface.

Definition at line 119 of file TrivialFileDelivery_service.cc.

121 {}

void art::TrivialFileDelivery::doRewind ( )

overridevirtual

Implements art::CatalogInterface.

Definition at line 140 of file TrivialFileDelivery_service.cc.

   {
     std::lock_guard sentry{mutex_};
     nextFile_ = fileList_.begin();
   }

void art::TrivialFileDelivery::doUpdateStatus	(	std::string const &	uri,
		FileDisposition	status
	)

overridevirtual

Implements art::CatalogInterface.

Definition at line 111 of file TrivialFileDelivery_service.cc.

112 {}

void art::CatalogInterface::eventSelected	(	std::string const &	module_label,
		EventID const &	event_id,
		HLTGlobalStatus const &	acceptance_info
	)

inlineinherited

Definition at line 109 of file CatalogInterface.h.

References art::CatalogInterface::doEventSelected().

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     doEventSelected(module_label, event_id, acceptance_info);
   }

int art::CatalogInterface::getNextFileURI	(	std::string &	uri,
		double &	waitTime
	)

inlineinherited

Definition at line 72 of file CatalogInterface.h.

References art::CatalogInterface::doGetNextFileURI().

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     return doGetNextFileURI(uri, waitTime);
   }

bool art::CatalogInterface::isSearchable ( )

inlineinherited

Definition at line 118 of file CatalogInterface.h.

References art::CatalogInterface::doIsSearchable().

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     return doIsSearchable();
   }

void art::CatalogInterface::outputFileClosed	(	std::string const &	module_label,
		std::string const &	fileFQname
	)

inlineinherited

Definition at line 86 of file CatalogInterface.h.

References art::CatalogInterface::doOutputFileClosed().

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     doOutputFileClosed(module_label, fileFQname);
   }

void art::CatalogInterface::outputFileOpened ( std::string const & module_label )

inlineinherited

Definition at line 94 of file CatalogInterface.h.

References art::CatalogInterface::doOutputFileOpened().

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     doOutputFileOpened(module_label);
   }

void art::CatalogInterface::outputModuleInitiated	(	std::string const &	module_label,
		fhicl::ParameterSet const &	pset
	)

inlineinherited

Definition at line 101 of file CatalogInterface.h.

References art::CatalogInterface::doOutputModuleInitiated().

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     doOutputModuleInitiated(module_label, pset);
   }

string art::TrivialFileDelivery::prependFileDesignation ( std::string const & name ) const

private

Definition at line 147 of file TrivialFileDelivery_service.cc.

References DECLARE_ART_SERVICE_INTERFACE_IMPL, DEFINE_ART_SERVICE_INTERFACE_IMPL, and art::SHARED.

   {
     std::lock_guard sentry{mutex_};
     string ret{"file://"};
     ret += name;
     return ret;
   }

void art::CatalogInterface::rewind ( )

inlineinherited

Definition at line 125 of file CatalogInterface.h.

References DECLARE_ART_SERVICE_INTERFACE, art::CatalogInterface::doRewind(), and art::SHARED.

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     doRewind();
   }

void art::CatalogInterface::updateStatus	(	std::string const &	uri,
		FileDisposition	status
	)

inlineinherited

Definition at line 79 of file CatalogInterface.h.

References art::CatalogInterface::doUpdateStatus().

   {
     HEP_CONCURRENCY_ASSERT_ONLY_ONE_THREAD();
     doUpdateStatus(uri, status);
   }

Member Data Documentation

std::vector<std::string>::const_iterator art::TrivialFileDelivery::endOfFiles_ {fileList_.cend()}

private

Definition at line 65 of file TrivialFileDelivery_service.cc.

std::vector<std::string> art::TrivialFileDelivery::fileList_ {}

private

Definition at line 63 of file TrivialFileDelivery_service.cc.

std::recursive_mutex art::TrivialFileDelivery::mutex_ {}

mutableprivate

Definition at line 62 of file TrivialFileDelivery_service.cc.

std::vector<std::string>::const_iterator art::TrivialFileDelivery::nextFile_ {fileList_.cbegin()}

private

Definition at line 64 of file TrivialFileDelivery_service.cc.

The documentation for this class was generated from the following file:

art/Framework/Services/Optional/TrivialFileDelivery_service.cc

Classes

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation