#include <IFCatalogInterface_service.h>

Inheritance diagram for ifdh_ns::IFCatalogInterface:

Public Member Functions
	IFCatalogInterface (const fhicl::ParameterSet &, art::ActivityRegistry &)

	~IFCatalogInterface ()

Public Member Functions inherited from art::CatalogInterface
virtual	~CatalogInterface () noexcept=default

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
virtual void	doConfigure (std::vector< std::string > const &item)

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

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

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

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

virtual void	doOutputFileClosed (std::string const &module_label, std::string const &fileFQname)

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

virtual bool	doIsSearchable ()

virtual void	doRewind ()

Private Attributes
art::ServiceHandle< IFDH >	_ifdh_handle

std::string	_process_id

std::string	_proj_uri

std::string	_project_name

std::string	_sam_station

std::string	_last_file_uri

std::vector< std::string >	_output_files

std::vector< bool >	_output_ignore

Detailed Description

Definition at line 15 of file IFCatalogInterface_service.h.

Constructor & Destructor Documentation

ifdh_ns::IFCatalogInterface::IFCatalogInterface	(	const fhicl::ParameterSet &	cfg,
		art::ActivityRegistry &
	)

Definition at line 13 of file IFCatalogInterface_service.cc.

                                                                                          :
     _process_id(""), 
     _proj_uri(""),
     _project_name(""), 
     _sam_station(""), 
     _last_file_uri("")
 { 
     std::vector<std::string> cfgkeys = cfg.get_names();
     std::string s;
 
     mf::LogVerbatim("test") << "IFCatalogInterface constructor, got keys:";
     for (std::vector<std::string>::iterator p = cfgkeys.begin(); p != cfgkeys.end(
   ); p++ ) {
          mf::LogVerbatim("test")<< *p << ", ";
     }
 
     if ( cfg.get_if_present("webURI", s) ) {
         mf::LogVerbatim("test") << "IFCatalogInterface: setting _proj_uri to:" << s << "\n";
         _proj_uri = s;
     }
 }

ifdh_ns::IFCatalogInterface::~IFCatalogInterface ( )

Definition at line 35 of file IFCatalogInterface_service.cc.

                                         {
     std::string process_status("completed");
     mf::LogVerbatim("test") << "IFCatalogInterface destructor:";
     if( _last_file_uri.length() ) {
         mf::LogVerbatim("test") << "IFCatalogInterface: updating file status in destructor";
         doUpdateStatus(_last_file_uri, art::FileDisposition::SKIPPED);
         process_status = "bad";
     }
     if( _proj_uri.length() &&  _process_id.length() ) {
        _ifdh_handle->setStatus(_proj_uri, _process_id, process_status);
     }
 }

Member Function Documentation

void ifdh_ns::IFCatalogInterface::doConfigure ( std::vector< std::string > const & item )

privatevirtual

Implements art::CatalogInterface.

Definition at line 49 of file IFCatalogInterface_service.cc.

                                                                  {
     if (item.size() ) {
         _process_id = item[0]; 
        mf::LogVerbatim("test") << "IFCatalogInterface doConfigure, got id:" << item[0];
     }
 }

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

privatevirtual

Implements art::CatalogInterface.

Definition at line 136 of file IFCatalogInterface_service.cc.

                                                                 {
     ;
 }

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

privatevirtual

Implements art::CatalogInterface.

Definition at line 58 of file IFCatalogInterface_service.cc.

                                                                                         {
     mf::LogVerbatim("test") << "IFCatalogInterface entering doGetNextFile\n";
     if ( _last_file_uri.length() ) {
         mf::LogVerbatim("test") << "Updating status in doGetNextFile\n";
         // XXX should this be  art::FileDisposition::SKIPPED ???
         // shouldn't we have updated the status already?
         doUpdateStatus(_last_file_uri, art::FileDisposition::CONSUMED);
     }
     if ( _proj_uri.length())  {
         uri = _ifdh_handle->getNextFile(_proj_uri,_process_id);
         _last_file_uri = uri;
         if (uri.length()) {
             mf::LogVerbatim("test") << "doGetNextFile success\n";
             return art::FileDeliveryStatus::SUCCESS;
         } else {
             mf::LogVerbatim("test") << "doGetNextFile no_more_files\n";
             return art::FileDeliveryStatus::NO_MORE_FILES;
         }
     }
     return art::FileDeliveryStatus::BAD_REQUEST;
 }

bool ifdh_ns::IFCatalogInterface::doIsSearchable ( )

privatevirtual

Implements art::CatalogInterface.

Definition at line 143 of file IFCatalogInterface_service.cc.

                                    {
    return 0;
 }

void ifdh_ns::IFCatalogInterface::doOutputFileClosed	(	std::string const &	module_label,
		std::string const &	fileFQname
	)

privatevirtual

Implements art::CatalogInterface.

Definition at line 129 of file IFCatalogInterface_service.cc.

                                                         {
      mf::LogVerbatim("test")  << "IFCatalogInteface doOutputFileClosed: " << module_label << ", " << fileFQname << "\n";
     return;
 }

void ifdh_ns::IFCatalogInterface::doOutputFileOpened ( std::string const & module_label )

privatevirtual

Implements art::CatalogInterface.

Definition at line 102 of file IFCatalogInterface_service.cc.

                                                          {
    return;
 }

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

privatevirtual

Implements art::CatalogInterface.

Definition at line 107 of file IFCatalogInterface_service.cc.

                                                                {
     std::string s;
     bool ignore = false;
     std::vector<std::string> cfgkeys = pset.get_names();
     mf::LogVerbatim("test") << "IFCatalogInterface doOutputModuleInitiated, got keys:";
     for (std::vector<std::string>::iterator p = cfgkeys.begin(); p != cfgkeys.end(
   ); p++ ) {
          mf::LogVerbatim("test")<< *p << ", ";
     }
    
     if ( pset.get_if_present("fileName", s) ) {
        _output_files.push_back(s);
     }
     if ( pset.get_if_present("sam_ignore", ignore) ) {
       ;
     }
     _output_ignore.push_back(ignore);
 }

void ifdh_ns::IFCatalogInterface::doRewind ( )

privatevirtual

Implements art::CatalogInterface.

Definition at line 148 of file IFCatalogInterface_service.cc.

                              {
    // throw NotImplemented;
    ;
 }

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

privatevirtual

Implements art::CatalogInterface.

Definition at line 81 of file IFCatalogInterface_service.cc.

                                                                                    {
     static const char *statusmap[] = {
         "transferred",
         "consumed",
         "skipped",
         "consumed",  /* INCOMPLETE */
     };
 
     mf::LogVerbatim("test") << "IFCatalogInterface doUpdateStatus " << uri << " status: " << int(status) << "\n";
 
     if( _proj_uri.length()) {
         _ifdh_handle->updateFileStatus(_proj_uri,_process_id,uri,statusmap[int(status)]);
         if (status != art::FileDisposition::TRANSFERRED) {
            int res = unlink(_ifdh_handle->localPath(_last_file_uri).c_str());
            mf::LogVerbatim("test")  << "unlink of file returns:" << res  << "\n";
            _last_file_uri = "";
         }
     }
 }