Loading [MathJax]/extensions/tex2jax.js
The Gaudi Framework  v31r0 (aeb156f0)
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Modules Pages
IODataManager.h
Go to the documentation of this file.
1 #ifndef GAUDIUTILS_IODATAMANAGER_H
2 #define GAUDIUTILS_IODATAMANAGER_H
3 
4 // C++ include files
5 #include <map>
6 // Framework include files
7 #include "GaudiKernel/Service.h"
9 
10 class IIncidentSvc;
11 
12 /*
13  * LHCb namespace declaration
14  */
15 namespace Gaudi {
16 
17  // Forward declarations
18  class IFileCatalog;
19  class RawDataConnectionEntry;
20 
29  class IODataManager : public extends<Service, IIODataManager> {
30  protected:
31  typedef const std::string& CSTR;
32  struct Entry final {
34  IoType ioType;
36  bool keepOpen;
37  Entry( CSTR tech, bool k, IoType iot, IDataConnection* con )
38  : type( tech ), ioType( iot ), connection( con ), keepOpen( k ) {}
39  };
42 
43  Gaudi::Property<std::string> m_catalogSvcName{this, "CatalogType", "Gaudi::MultiFileCatalog/FileCatalog",
44  "name of the file catalog service"};
45  Gaudi::Property<bool> m_useGFAL{this, "UseGFAL", true, "flag for auto gfal data access"};
46  Gaudi::Property<bool> m_quarantine{this, "QuarantineFiles", true,
47  "if unaccessible files should be quarantines in job"};
48  Gaudi::Property<int> m_ageLimit{this, "AgeLimit", 2, "age limit"};
50  this, "DisablePFNWarning", false,
51  "if set to True, we will not report when a file is opened by its physical name"};
52 
54  ConnectionMap m_connectionMap;
58  FidMap m_fidMap;
59  StatusCode connectDataIO( int typ, IoType rw, CSTR fn, CSTR technology, bool keep, Connection* con );
61  StatusCode error( CSTR msg, bool rethrow );
62  StatusCode establishConnection( Connection* con );
63 
65 
66  public:
68  using extends::extends;
69 
71  StatusCode initialize() override;
72 
74  StatusCode finalize() override;
75 
77  StatusCode connectRead( bool keep_open, Connection* ioDesc ) override;
79  StatusCode connectWrite( Connection* con, IoType mode = Connection::CREATE, CSTR doctype = "UNKNOWN" ) override;
81  StatusCode disconnect( Connection* ioDesc ) override;
83  Connection* connection( const std::string& dsn ) const override;
85  Connections connections( const IInterface* owner ) const override;
87  StatusCode read( Connection* ioDesc, void* const data, size_t len ) override;
89  StatusCode write( Connection* con, const void* data, int len ) override;
91  long long int seek( Connection* ioDesc, long long int where, int origin ) override;
92  };
93 } // End namespace Gaudi
94 #endif // GAUDIUTILS_IODATAMANAGER_H
StatusCode finalize() override
IService implementation: finalize the service.
Gaudi::Property< int > m_ageLimit
Definition: IODataManager.h:48
Small smart pointer class with automatic reference counting for IInterface.
Definition: IConverter.h:15
MsgStream & msg() const
shortcut for the method msgStream(MSG::INFO)
Implementation of property with value of concrete type.
Definition: Property.h:352
Connections connections(const IInterface *owner) const override
Get connection by owner instance (0=ALL)
StatusCode disconnect(Connection *ioDesc) override
Release data stream.
Gaudi::Property< std::string > m_catalogSvcName
Definition: IODataManager.h:43
SmartIF< IIncidentSvc > m_incSvc
Definition: IODataManager.h:64
Entry(CSTR tech, bool k, IoType iot, IDataConnection *con)
Definition: IODataManager.h:37
StatusCode establishConnection(Connection *con)
StatusCode read(Connection *ioDesc, void *const data, size_t len) override
Read raw byte buffer from input stream.
STL class.
std::map< std::string, std::string > FidMap
Definition: IODataManager.h:41
Gaudi::Property< bool > m_quarantine
Definition: IODataManager.h:46
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
StatusCode initialize() override
IService implementation: initialize the service.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:50
SmartIF< IFileCatalog > m_catalog
Reference to file catalog.
Definition: IODataManager.h:56
Definition of the basic interface.
Definition: IInterface.h:244
StatusCode write(Connection *con, const void *data, int len) override
Write raw byte buffer to output stream.
Definition: IODataManager.h:32
Gaudi::Property< bool > m_useGFAL
Definition: IODataManager.h:45
StatusCode connectWrite(Connection *con, IoType mode=Connection::CREATE, CSTR doctype="UNKNOWN") override
Open data stream in write mode.
std::string type
Definition: IODataManager.h:33
std::map< std::string, Entry * > ConnectionMap
Definition: IODataManager.h:40
ABC describing basic data connection.
Base class used to extend a class implementing other interfaces.
Definition: extends.h:10
ConnectionMap m_connectionMap
Map with I/O descriptors.
Definition: IODataManager.h:54
IDataConnection * connection
Definition: IODataManager.h:35
const std::string & CSTR
Definition: IODataManager.h:31
Gaudi::Property< bool > m_disablePFNWarning
Definition: IODataManager.h:49
StatusCode connectDataIO(int typ, IoType rw, CSTR fn, CSTR technology, bool keep, Connection *con)
StatusCode connectRead(bool keep_open, Connection *ioDesc) override
Open data stream in read mode.
bool keepOpen
Definition: IODataManager.h:36
long long int seek(Connection *ioDesc, long long int where, int origin) override
Seek on the file described by ioDesc. Arguments as in ::seek()
Helper functions to set/get the application return code.
Definition: __init__.py:1
StatusCode reconnect(Entry *e)
The interface implemented by the IncidentSvc service.
Definition: IIncidentSvc.h:23
IoType ioType
Definition: IODataManager.h:34
FidMap m_fidMap
Map of FID to PFN.
Definition: IODataManager.h:58