UserSession.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef POOLSVC_USERSESSION_H
#define POOLSVC_USERSESSION_H
 
#include "AthenaBaseComps/AthMessaging.h"
#include "PoolSvc/ISession.h"
#include "StorageSvc/DbPrint.h"
 
#include <map>
 
namespace pool {
 
  // forward declarations
  class DatabaseRegistry;
  class MicroSessionManager;

 
  class UserSession : public ISession, public APRMessaging
  {
  public:
    explicit UserSession( Gaudi::IFileCatalog& fileCatalog, int ageLimit );

    virtual ~UserSession();
 
    UserSession (const UserSession&) = delete;
    UserSession& operator= (const UserSession&) = delete;
 

    virtual void* readObject( const Token& token, void* object = 0 ) override;
 

    virtual Token* registerForWrite( const Placement& place, const void* object, const RootType& type ) override;
 
 
    // Signatures needed for the PersistencySvc
    DatabaseRegistry& registry();

    virtual bool disconnectAll() override final;

    virtual bool start( Io::IoFlag type = Io::READ ) override final;

    virtual bool commit() override final;

    virtual bool commitAndHold() override final;

    virtual Io::IoFlag type() const override final { return m_transactionType; }

    virtual std::unique_ptr<IDatabase>
    databaseHandle( const std::string& dbName, DatabaseSpecification::NameType dbNameType ) override final;

    virtual Gaudi::IFileCatalog& fileCatalog();

    virtual IStorageSvc& getStorageSvc( long technology ) override final;

    MicroSessionManager& microSessionManager( long technology ) override final;
 
  private:
    Gaudi::IFileCatalog*           m_catalog;
    int                            m_ageLimit;
    DatabaseRegistry*              m_registry;
    Io::IoFlag                     m_transactionType;
    std::map< long, std::unique_ptr<MicroSessionManager> >    m_technologies;
  };
}
 
#endif