28 class RawDataConnectionEntry;
40 typedef const std::string&
CSTR;
50 typedef std::map<std::string, std::string>
FidMap;
53 "name of the file catalog service" };
56 "if unaccessible files should be quarantines in job" };
59 this,
"DisablePFNWarning",
false,
60 "if set to True, we will not report when a file is opened by its physical name" };
77 using extends::extends;
92 Connection*
connection(
const std::string& dsn )
const override;
96 StatusCode read( Connection* ioDesc,
void*
const data,
size_t len )
override;
98 StatusCode write( Connection* con,
const void* data,
int len )
override;
100 long long int seek( Connection* ioDesc,
long long int where,
int origin )
override;
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
MsgStream & msg() const
shortcut for the method msgStream(MSG::INFO)
ABC describing basic data connection.
ConnectionMap m_connectionMap
Map with I/O descriptors.
StatusCode connectRead(bool keep_open, Connection *ioDesc) override
Open data stream in read mode.
FidMap m_fidMap
Map of FID to PFN.
Gaudi::Property< bool > m_quarantine
StatusCode write(Connection *con, const void *data, int len) override
Write raw byte buffer to output stream.
long long int seek(Connection *ioDesc, long long int where, int origin) override
Seek on the file described by ioDesc. Arguments as in seek()
StatusCode finalize() override
IService implementation: finalize the service.
StatusCode read(Connection *ioDesc, void *const data, size_t len) override
Read raw byte buffer from input stream.
SmartIF< IFileCatalog > m_catalog
Reference to file catalog.
StatusCode disconnect(Connection *ioDesc) override
Release data stream.
Gaudi::Property< std::string > m_catalogSvcName
StatusCode establishConnection(Connection *con)
StatusCode connectWrite(Connection *con, IoType mode=Connection::CREATE, CSTR doctype="UNKNOWN") override
Open data stream in write mode.
Gaudi::Property< bool > m_useGFAL
Connection * connection(const std::string &dsn) const override
Retrieve known connection.
StatusCode reconnect(Entry *e)
std::map< std::string, Entry * > ConnectionMap
Gaudi::Property< bool > m_disablePFNWarning
Gaudi::Property< int > m_ageLimit
StatusCode initialize() override
IService implementation: initialize the service.
Connections connections(const IInterface *owner) const override
Get connection by owner instance (0=ALL)
SmartIF< IIncidentSvc > m_incSvc
std::map< std::string, std::string > FidMap
StatusCode connectDataIO(int typ, IoType rw, CSTR fn, CSTR technology, bool keep, Connection *con)
Implementation of property with value of concrete type.
The interface implemented by the IncidentSvc service.
Definition of the basic interface.
Small smart pointer class with automatic reference counting for IInterface.
This class is used for returning status codes from appropriate routines.
Base class used to extend a class implementing other interfaces.
This file provides a Grammar for the type Gaudi::Accumulators::Axis It allows to use that type from p...
IDataConnection * connection
Entry(CSTR tech, bool k, IoType iot, IDataConnection *con)