IODataManager.h

Go to the documentation of this file.

#ifndef GAUDIUTILS_IODATAMANAGER_H
#define GAUDIUTILS_IODATAMANAGER_H

// C++ include files
#include <map>
// Framework include files
#include "GaudiKernel/Service.h"
#include "GaudiUtils/IIODataManager.h"

class IIncidentSvc;

/*
 *  LHCb namespace declaration
 */
namespace Gaudi  {

  // Forward declarations
  class IFileCatalog;
  class RawDataConnectionEntry;

  class IODataManager : public extends1<Service, IIODataManager> {
  protected:
    typedef const std::string& CSTR;
    struct Entry final {
      std::string      type;
      IoType           ioType;
      IDataConnection* connection;
      bool             keepOpen;
      Entry(CSTR tech,bool k, IoType iot,IDataConnection* con)
      : type(tech), ioType(iot), connection(con), keepOpen(k) {
      }
    };
    typedef std::map<std::string,Entry*>       ConnectionMap;
    typedef std::map<std::string, std::string> FidMap;

    std::string          m_catalogSvcName;
    int                  m_ageLimit;
    bool                 m_useGFAL;
    bool                 m_quarantine;
    bool                 m_disablePFNWarning;

    ConnectionMap        m_connectionMap;
    SmartIF<IFileCatalog> m_catalog;
    FidMap               m_fidMap;
    StatusCode connectDataIO(int typ, IoType rw, CSTR fn, CSTR technology, bool keep,Connection* con);
    StatusCode reconnect(Entry* e);
    StatusCode error(CSTR msg, bool rethrow);
    StatusCode establishConnection(Connection* con);

    SmartIF<IIncidentSvc> m_incSvc; 

  public:

    IODataManager(CSTR nam, ISvcLocator* loc);

    ~IODataManager() override = default;

    StatusCode initialize() override;

    StatusCode finalize() override;

    StatusCode connectRead(bool keep_open, Connection* ioDesc) override;
    StatusCode connectWrite(Connection* con,IoType mode=Connection::CREATE,CSTR doctype="UNKNOWN") override;
    StatusCode disconnect(Connection* ioDesc) override;
    Connection* connection(const std::string& dsn) const override;
    Connections connections(const IInterface* owner) const override;
    StatusCode read(Connection* ioDesc, void* const data, size_t len) override;
    StatusCode write(Connection* con, const void* data, int len) override;
    long long int seek(Connection* ioDesc, long long int where, int origin) override;
  };
}         // End namespace Gaudi
#endif    // GAUDIUTILS_IODATAMANAGER_H