UserSession.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef INCLUDE_PERSISTENCYSVC_USERSESSION_H
#define INCLUDE_PERSISTENCYSVC_USERSESSION_H
 
#include "AthenaBaseComps/AthMessaging.h"
#include "PersistencySvc/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( 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();
    //TechnologyDispatcher& technologyDispatcher();

    virtual bool disconnectAll() override final;

    virtual ITransaction& transaction() override final { return *this; }
    virtual const ITransaction& transaction() const override final { return *this; }

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

    virtual bool commit() override final;

    virtual bool commitAndHold() override final;

    virtual bool isActive() const override final { return m_transactionType != Io::INVALID; }

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

    Io::IoFlag transactionType() const { return transaction().type(); }

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

    virtual IFileCatalog& fileCatalog() override final;

    void setFileCatalog(IFileCatalog& catalog);

    virtual const ITechnologySpecificAttributes&
    technologySpecificAttributes( long technology ) const override final;
 
    virtual  ITechnologySpecificAttributes&
    technologySpecificAttributes( long technology ) override final;

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