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 {
 
  class DatabaseConnectionPolicy;
 
  // forward declarations
  class DatabaseRegistry;
  class MicroSessionManager;

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

    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 void setDefaultConnectionPolicy( const DatabaseConnectionPolicy& policy ) override final;

    virtual const DatabaseConnectionPolicy& defaultConnectionPolicy() const override final;

    virtual bool disconnectAll() override final;

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

    virtual bool start( ITransaction::Type type = READ ) override final;

    virtual bool commit() override final;

    virtual bool commitAndHold() override final;

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

    virtual ITransaction::Type type() const override final { return m_transactionType; }

    ITransaction::Type 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:
    DatabaseConnectionPolicy*      m_policy;
    IFileCatalog*                  m_catalog;
    DatabaseRegistry*              m_registry;
    ITransaction::Type             m_transactionType;
    std::map< long, std::unique_ptr<MicroSessionManager> >    m_technologies;
 
  };
}
 
#endif