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  {
      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;

    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);

    virtual ~IODataManager()  {}

    virtual StatusCode initialize();

    virtual StatusCode finalize();

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