IIODataManager.h

Go to the documentation of this file.

#ifndef GAUDIUTILS_IIODATAMANAGER_H
#define GAUDIUTILS_IIODATAMANAGER_H
// $Id:

// Framework include files
#include "GaudiKernel/IInterface.h"

// C++ include files
#include <string>
#include <vector>

/*
 *  LHCb namespace declaration
 */
namespace Gaudi  {

  class GAUDI_API IDataConnection  {
  protected:
    std::string              m_name;
    std::string              m_fid;
    std::string              m_pfn;
    int                      m_age;
    const IInterface*        m_owner;
  public:
    enum IoType   { READ=1<<1,UPDATE=1<<2,CREATE=1<<3,RECREATE=(1<<4)+(1<<3) };
    enum IoStatus { BAD_DATA_CONNECTION=4 };
  public:
    IDataConnection(const IInterface* own, const std::string& nam)
    : m_name(nam), m_age(0), m_owner(own) {}
    virtual ~IDataConnection() {}
    const std::string& name() const       {     return m_name;       }
    void setFID(const std::string& fid)   {     m_fid = fid;         }
    const std::string& fid() const        {     return m_fid;        }
    const std::string& pfn() const        {     return m_pfn;        }
    void setPFN(const std::string& fn)    {     m_pfn = fn;          }
    void ageFile()                        {     ++m_age;             }
    void resetAge()                       {     m_age = 0;           }
    int age() const                       {     return m_age;        }
    const IInterface* owner() const       {     return m_owner;      }
    virtual StatusCode connectRead() = 0;
    virtual StatusCode connectWrite(IoType type) = 0;
    virtual StatusCode disconnect() = 0;
    virtual bool isConnected() const = 0;
    virtual StatusCode read(void* const data, size_t len) = 0;
    virtual StatusCode write(const void* data, int len) = 0;
    virtual long long int seek(long long int where, int origin) = 0;
  };

  class GAUDI_API IIODataManager : virtual public IInterface {
  public:
    DeclareInterfaceID(IIODataManager,2,0);

    typedef IDataConnection           Connection;
    typedef std::vector<Connection*>  Connections;
    typedef Connection::IoType        IoType;
    enum FileType { UNKNOWN=1, PFN, LFN, FID };

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