cond::persistency::SessionImpl Class Reference

#include <SessionImpl.h>

Public Types
enum	FailureOnOpeningPolicy { THROW, DO_NOT_THROW, CREATE }

Public Member Functions
void	close ()
void	commitTransaction ()
IGTSchema &	gtSchema ()
IIOVSchema &	iovSchema ()
bool	isActive () const
bool	isTransactionActive (bool deep=true) const
void	openDb ()
void	openGTDb (FailureOnOpeningPolicy policy=THROW)
void	openIovDb (FailureOnOpeningPolicy policy=THROW)
void	openRunInfoDb ()
void	rollbackTransaction ()
IRunInfoSchema &	runInfoSchema ()
	SessionImpl ()
	SessionImpl (std::shared_ptr< coral::ISessionProxy > &session, const std::string &connectionString)
void	startTransaction (bool readOnly=true)
	~SessionImpl ()

Public Attributes
std::string	connectionString
std::shared_ptr< coral::ISessionProxy >	coralSession
std::unique_ptr< IGTSchema >	gtSchemaHandle
std::unique_ptr< IIOVSchema >	iovSchemaHandle
std::unique_ptr< IRunInfoSchema >	runInfoSchemaHandle
std::unique_ptr< ITransaction >	transaction

Private Attributes
std::unique_lock< std::recursive_mutex >	transactionLock
std::recursive_mutex	transactionMutex

Detailed Description

Definition at line 40 of file SessionImpl.h.

Member Enumeration Documentation

FailureOnOpeningPolicy

enum cond::persistency::SessionImpl::FailureOnOpeningPolicy

Enumerator
THROW
DO_NOT_THROW
CREATE

Definition at line 42 of file SessionImpl.h.

{ THROW, DO_NOT_THROW, CREATE } FailureOnOpeningPolicy;

Constructor & Destructor Documentation

SessionImpl() [1/2]

cond::persistency::SessionImpl::SessionImpl

(

)

Definition at line 31 of file SessionImpl.cc.

: coralSession() {}

SessionImpl() [2/2]

cond::persistency::SessionImpl::SessionImpl	(	std::shared_ptr< coral::ISessionProxy > &	session,
		const std::string &	connectionString
	)

Definition at line 33 of file SessionImpl.cc.

        : coralSession(session), connectionString(connectionStr) {}

~SessionImpl()

cond::persistency::SessionImpl::~SessionImpl

(

)

Definition at line 36 of file SessionImpl.cc.

{ close(); }

References close().

Member Function Documentation

close()

void cond::persistency::SessionImpl::close

(

void

)

Definition at line 38 of file SessionImpl.cc.

                            {
      if (coralSession.get()) {
        if (coralSession->transaction().isActive()) {
          coralSession->transaction().rollback();
        }
        coralSession.reset();
      }
      transaction.reset();
    }

References coralSession, and transaction.

Referenced by esMonitoring.AsyncLineReaderMixin::handle_close(), esMonitoring.FDJsonServer::handle_close(), and ~SessionImpl().

commitTransaction()

void cond::persistency::SessionImpl::commitTransaction

(

)

Definition at line 66 of file SessionImpl.cc.

                                        {
      std::unique_lock<std::recursive_mutex> lock;
      lock.swap(transactionLock);
      if (transaction) {
        transaction->clients--;
        if (!transaction->clients) {
          transaction->commit();
          transaction.reset();
          iovSchemaHandle.reset();
          gtSchemaHandle.reset();
          runInfoSchemaHandle.reset();
        }
      }
    }

References gtSchemaHandle, iovSchemaHandle, CommonMethods::lock(), runInfoSchemaHandle, transaction, and transactionLock.

Referenced by cond::persistency::Transaction::commit().

gtSchema()

IGTSchema & cond::persistency::SessionImpl::gtSchema

(

)

Definition at line 172 of file SessionImpl.cc.

{ return *gtSchemaHandle; }

References gtSchemaHandle.

iovSchema()

IIOVSchema & cond::persistency::SessionImpl::iovSchema

(

)

Definition at line 170 of file SessionImpl.cc.

{ return *iovSchemaHandle; }

References iovSchemaHandle.

isActive()

bool cond::persistency::SessionImpl::isActive

(

)

const

Definition at line 48 of file SessionImpl.cc.

{ return coralSession.get(); }

References coralSession.

isTransactionActive()

bool cond::persistency::SessionImpl::isTransactionActive

(

bool

deep = true

)

const

Definition at line 93 of file SessionImpl.cc.

                                                         {
      if (!transaction)
        return false;
      if (!deep)
        return true;
      return transaction->isActive();
    }

References transaction.

Referenced by cond::persistency::Transaction::isActive().

openDb()

void cond::persistency::SessionImpl::openDb

(

)

Definition at line 149 of file SessionImpl.cc.

                             {
      if (!transaction.get())
        throwException("The transaction is not active.", "SessionImpl::openIovDb");
      if (!transaction->iovDbOpen) {
        transaction->iovDbExists = iovSchemaHandle->exists();
        transaction->iovDbOpen = true;
      }
      if (!transaction->gtDbOpen) {
        transaction->gtDbExists = gtSchemaHandle->exists();
        transaction->gtDbOpen = true;
      }
      if (!transaction->iovDbExists) {
        iovSchemaHandle->create();
        transaction->iovDbExists = true;
        if (!transaction->gtDbExists) {
          gtSchemaHandle->create();
          transaction->gtDbExists = true;
        }
      }
    }

References gtSchemaHandle, iovSchemaHandle, cond::persistency::throwException(), and transaction.

openGTDb()

void cond::persistency::SessionImpl::openGTDb

(

SessionImpl::FailureOnOpeningPolicy

policy = THROW

)

Definition at line 119 of file SessionImpl.cc.

                                                                       {
      if (!transaction.get())
        throwException("The transaction is not active.", "SessionImpl::openGTDb");
      if (!transaction->gtDbOpen) {
        transaction->gtDbExists = gtSchemaHandle->exists();
        transaction->gtDbOpen = true;
      }
      if (!transaction->gtDbExists) {
        if (policy == CREATE) {
          gtSchemaHandle->create();
          transaction->gtDbExists = true;
        } else {
          if (policy == THROW)
            throwException("GT Database does not exist.", "SessionImpl::openGTDb");
        }
      }
    }

References CREATE, gtSchemaHandle, THROW, cond::persistency::throwException(), and transaction.

openIovDb()

void cond::persistency::SessionImpl::openIovDb

(

SessionImpl::FailureOnOpeningPolicy

policy = THROW

)

Definition at line 101 of file SessionImpl.cc.

                                                                        {
      if (!transaction.get())
        throwException("The transaction is not active.", "SessionImpl::openIovDb");
      if (!transaction->iovDbOpen) {
        transaction->iovDbExists = iovSchemaHandle->exists();
        transaction->iovDbOpen = true;
      }
      if (!transaction->iovDbExists) {
        if (policy == CREATE) {
          iovSchemaHandle->create();
          transaction->iovDbExists = true;
        } else {
          if (policy == THROW)
            throwException("IOV Database does not exist.", "SessionImpl::openIovDb");
        }
      }
    }

References CREATE, iovSchemaHandle, THROW, cond::persistency::throwException(), and transaction.

openRunInfoDb()

void cond::persistency::SessionImpl::openRunInfoDb

(

)

Definition at line 137 of file SessionImpl.cc.

                                    {
      if (!transaction.get())
        throwException("The transaction is not active.", "SessionImpl::openRunInfoDb");
      if (!transaction->runInfoDbOpen) {
        transaction->runInfoDbExists = runInfoSchemaHandle->exists();
        transaction->runInfoDbOpen = true;
      }
      if (!transaction->runInfoDbExists) {
        throwException("RunInfo Database does not exist.", "SessionImpl::openRunInfoDb");
      }
    }

References runInfoSchemaHandle, cond::persistency::throwException(), and transaction.

rollbackTransaction()

void cond::persistency::SessionImpl::rollbackTransaction

(

)

Definition at line 81 of file SessionImpl.cc.

                                          {
      std::unique_lock<std::recursive_mutex> lock;
      lock.swap(transactionLock);
      if (transaction) {
        transaction->rollback();
        transaction.reset();
        iovSchemaHandle.reset();
        gtSchemaHandle.reset();
        runInfoSchemaHandle.reset();
      }
    }

References gtSchemaHandle, iovSchemaHandle, CommonMethods::lock(), runInfoSchemaHandle, transaction, and transactionLock.

Referenced by cond::persistency::Transaction::rollback().

runInfoSchema()

IRunInfoSchema & cond::persistency::SessionImpl::runInfoSchema

(

)

Definition at line 174 of file SessionImpl.cc.

{ return *runInfoSchemaHandle; }

References runInfoSchemaHandle.

startTransaction()

void cond::persistency::SessionImpl::startTransaction

(

bool

readOnly = true

)

Definition at line 50 of file SessionImpl.cc.

                                                    {
      std::unique_lock<std::recursive_mutex> lock(transactionMutex);
      if (!transaction.get()) {
        coralSession->transaction().start(readOnly);
        iovSchemaHandle = std::make_unique<IOVSchema>(coralSession->nominalSchema());
        gtSchemaHandle = std::make_unique<GTSchema>(coralSession->nominalSchema());
        runInfoSchemaHandle = std::make_unique<RunInfoSchema>(coralSession->nominalSchema());
        transaction = std::make_unique<CondDBTransaction>(coralSession);
      } else {
        if (!readOnly)
          throwException("An update transaction is already active.", "SessionImpl::startTransaction");
      }
      transaction->clients++;
      transactionLock.swap(lock);
    }

References coralSession, gtSchemaHandle, iovSchemaHandle, CommonMethods::lock(), runInfoSchemaHandle, cond::persistency::throwException(), transaction, transactionLock, and transactionMutex.

Referenced by cond::persistency::Transaction::start().

Member Data Documentation

connectionString

std::string cond::persistency::SessionImpl::connectionString

Definition at line 69 of file SessionImpl.h.

coralSession

std::shared_ptr<coral::ISessionProxy> cond::persistency::SessionImpl::coralSession

Definition at line 67 of file SessionImpl.h.

Referenced by close(), isActive(), and startTransaction().

gtSchemaHandle

std::unique_ptr<IGTSchema> cond::persistency::SessionImpl::gtSchemaHandle

Definition at line 72 of file SessionImpl.h.

Referenced by commitTransaction(), gtSchema(), openDb(), openGTDb(), rollbackTransaction(), and startTransaction().

iovSchemaHandle

std::unique_ptr<IIOVSchema> cond::persistency::SessionImpl::iovSchemaHandle

Definition at line 71 of file SessionImpl.h.

Referenced by commitTransaction(), iovSchema(), openDb(), openIovDb(), rollbackTransaction(), and startTransaction().

runInfoSchemaHandle

std::unique_ptr<IRunInfoSchema> cond::persistency::SessionImpl::runInfoSchemaHandle

Definition at line 73 of file SessionImpl.h.

Referenced by commitTransaction(), openRunInfoDb(), rollbackTransaction(), runInfoSchema(), and startTransaction().

transaction

std::unique_ptr<ITransaction> cond::persistency::SessionImpl::transaction

Definition at line 70 of file SessionImpl.h.

Referenced by close(), commitTransaction(), isTransactionActive(), openDb(), openGTDb(), openIovDb(), openRunInfoDb(), rollbackTransaction(), and startTransaction().

transactionLock

std::unique_lock<std::recursive_mutex> cond::persistency::SessionImpl::transactionLock

private

Definition at line 77 of file SessionImpl.h.

Referenced by commitTransaction(), rollbackTransaction(), and startTransaction().

transactionMutex

std::recursive_mutex cond::persistency::SessionImpl::transactionMutex

private

Definition at line 76 of file SessionImpl.h.

Referenced by startTransaction().