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;
 
  namespace PersistencySvc {
 
    // 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