cond::persistency::IOVEditor Class Reference

#include <IOVEditor.h>

Public Member Functions
std::string	description () const
cond::Time_t	endOfValidity () const
bool	flush ()
bool	flush (const boost::posix_time::ptime &operationTime)
void	insert (cond::Time_t since, const cond::Hash &payloadHash, bool checkType=false)
void	insert (cond::Time_t since, const cond::Hash &payloadHash, const boost::posix_time::ptime &insertionTime, bool checkType=false)
	IOVEditor ()
	IOVEditor (const std::shared_ptr< SessionImpl > &session)
	IOVEditor (const std::shared_ptr< SessionImpl > &session, const std::string &tag, cond::TimeType timeType, const std::string &payloadType, cond::SynchronizationType synchronizationType, const boost::posix_time::ptime &creationTime=boost::posix_time::microsec_clock::universal_time())
	IOVEditor (const IOVEditor &rhs)
cond::Time_t	lastValidatedTime () const
void	load (const std::string &tag)
IOVEditor &	operator= (const IOVEditor &rhs)
std::string	payloadType () const
void	setDescription (const std::string &description)
void	setEndOfValidity (cond::Time_t validity)
void	setLastValidatedTime (cond::Time_t time)
void	setValidationMode ()
cond::SynchronizationType	synchronizationType () const
std::string	tag () const
cond::TimeType	timeType () const

Private Member Functions
void	checkTransaction (const std::string &ctx)

Private Attributes
std::shared_ptr< IOVEditorData >	m_data
std::shared_ptr< SessionImpl >	m_session

Detailed Description

Definition at line 28 of file IOVEditor.h.

Constructor & Destructor Documentation

IOVEditor::IOVEditor

(

)

Definition at line 35 of file IOVEditor.cc.

                        :
      m_data(),
      m_session(){
    }

IOVEditor::IOVEditor ( const std::shared_ptr< SessionImpl > &  session )

explicit

Definition at line 40 of file IOVEditor.cc.

                                                                   :
      m_data( new IOVEditorData ),
      m_session( session ){
    }

IOVEditor::IOVEditor	(	const std::shared_ptr< SessionImpl > &	session,
		const std::string &	tag,
		cond::TimeType	timeType,
		const std::string &	payloadType,
		cond::SynchronizationType	synchronizationType,
		const boost::posix_time::ptime &	creationTime = boost::posix_time::microsec_clock::universal_time()
	)

Definition at line 45 of file IOVEditor.cc.

References m_data, synchronizationType(), tag(), and timeType().

                                                        :
      m_data( new IOVEditorData ),
      m_session( session ){
      m_data->tag = tag;
      m_data->timeType = timeType;
      m_data->payloadType = payloadObjectType;
      m_data->synchronizationType = synchronizationType;
      m_data->creationTime = creationTime;
      m_data->change = true;
    }

IOVEditor::IOVEditor

(

const IOVEditor &

rhs

)

Definition at line 61 of file IOVEditor.cc.

                                              :
      m_data( rhs.m_data ),
      m_session( rhs.m_session ){
    }

Member Function Documentation

void IOVEditor::checkTransaction ( const std::string &  ctx )

private

Definition at line 203 of file IOVEditor.cc.

References m_session, and cond::persistency::throwException().

Referenced by flush(), and load().

                                                          {
      if( !m_session.get() ) throwException("The session is not active.",ctx );
      if( !m_session->isTransactionActive( false ) ) throwException("The transaction is not active.",ctx );
    }

std::string IOVEditor::description

(

)

const

Definition at line 112 of file IOVEditor.cc.

References m_data.

Referenced by setDescription().

                                           {
      return m_data.get() ? m_data->description :  "";
    }

cond::Time_t IOVEditor::endOfValidity

(

)

const

Definition at line 101 of file IOVEditor.cc.

References m_data, and cond::time::MIN_VAL().

                                              {
      return m_data.get() ? m_data->endOfValidity : cond::time::MIN_VAL;
    }

bool IOVEditor::flush

(

)

Definition at line 199 of file IOVEditor.cc.

Referenced by cond::service::PoolDBOutputService::appendSinceTime(), cond::service::PoolDBOutputService::closeIOV(), cond::persistency::copyIov(), cond::persistency::copyTag(), cond::service::PoolDBOutputService::createNewIOV(), cond::persistency::importIovs(), and cond::persistency::migrateTag().

                         {
      return flush( boost::posix_time::microsec_clock::universal_time() );
    }

bool IOVEditor::flush

(

const boost::posix_time::ptime &

operationTime

)

Definition at line 154 of file IOVEditor.cc.

References checkTransaction(), h, cond::persistency::iovSorter(), prof2calltree::l, prof2calltree::last, m_data, m_session, visualization-live-secondInstance_cfg::msg, run_regression::ret, python.multivaluedict::sort(), cond::SYNCH_ANY, cond::SYNCH_VALIDATION, cond::synchronizationTypeNames(), and cond::persistency::throwException().

                                                                    {
      bool ret = false;
      checkTransaction( "IOVEditor::flush" );
      if( m_data->change ){
    if( m_data->description.empty() ) throwException( "A non-empty description string is mandatory.","IOVEditor::flush" );
    if( m_data->validationMode ) m_session->iovSchema().tagTable().setValidationMode();
    if( !m_data->exists ){
      m_session->iovSchema().tagTable().insert( m_data->tag, m_data->timeType, m_data->payloadType, 
                            m_data->synchronizationType, m_data->endOfValidity, 
                            m_data->description, m_data->lastValidatedTime, m_data->creationTime );
      m_data->exists = true;
      ret = true;
    } else {
      m_session->iovSchema().tagTable().update( m_data->tag, m_data->endOfValidity, m_data->description, 
                            m_data->lastValidatedTime, operationTime );   
      ret = true;
    }
    m_data->change = false;
      }
      if( m_data->iovBuffer.size() ) {

    std::sort(m_data->iovBuffer.begin(),m_data->iovBuffer.end(),iovSorter);
    cond::Time_t l = std::get<0>(m_data->iovBuffer.front());
    if( m_data->synchronizationType != cond::SYNCH_ANY && m_data->synchronizationType != cond::SYNCH_VALIDATION ){
      // retrieve the last since
      cond::Time_t last = 0;
      cond::Hash h;
      m_session->iovSchema().iovTable().getLastIov( m_data->tag, last, h );
      // check if the min iov is greater then the last since
      if( l <= last ){
        std::stringstream msg;
        msg << "Can't insert iov since "<<l<<" on the tag "<< m_data->tag<<": last since is "<<last<<
          " and synchronization is \""<<cond::synchronizationTypeNames(  m_data->synchronizationType )<<"\"";
        throwException( msg.str(),"IOVEditor::flush");
      }
    }
    
    // insert the new iovs
    m_session->iovSchema().iovTable().insertMany( m_data->tag, m_data->iovBuffer );
    m_data->iovBuffer.clear();
    ret = true;
      }
      return ret;
    }

void IOVEditor::insert	(	cond::Time_t	since,
		const cond::Hash &	payloadHash,
		bool	checkType = false
	)

Definition at line 138 of file IOVEditor.cc.

References fileCollector::now.

Referenced by BeautifulSoup.PageElement::_invert(), cond::service::PoolDBOutputService::appendSinceTime(), cond::persistency::copyIov(), cond::persistency::copyTag(), cond::service::PoolDBOutputService::createNewIOV(), cond::persistency::importIovs(), and cond::persistency::migrateTag().

                                                                                         {
      boost::posix_time::ptime now = boost::posix_time::microsec_clock::universal_time();
      insert( since, payloadHash, now, checkType ); 
    }

void IOVEditor::insert	(	cond::Time_t	since,
		const cond::Hash &	payloadHash,
		const boost::posix_time::ptime &	insertionTime,
		bool	checkType = false
	)

Definition at line 143 of file IOVEditor.cc.

References m_data.

Referenced by BeautifulSoup.PageElement::_invert().

                                                                                                                          {
      if( m_data.get() ){
    // here the type check could be added
    m_data->iovBuffer.push_back( std::tie( since, payloadHash, insertionTime ) );
      }
    }

cond::Time_t IOVEditor::lastValidatedTime

(

)

const

Definition at line 123 of file IOVEditor.cc.

References m_data, and cond::time::MIN_VAL().

                                                  {
      return m_data.get() ? m_data->lastValidatedTime : cond::time::MIN_VAL;
    }

void IOVEditor::load

(

const std::string &

tag

)

Definition at line 72 of file IOVEditor.cc.

References checkTransaction(), m_data, m_session, tag(), and cond::throwException().

Referenced by cond::persistency::Session::editIov(), MatrixToProcess.MatrixToProcess::getProcess(), and MatrixToProcess.MatrixToProcess::listAll().

                                              {
      checkTransaction( "IOVEditor::load" );
      // loads the current header data in memory
      if( !m_session->iovSchema().tagTable().select( tag, m_data->timeType, m_data->payloadType, m_data->synchronizationType, 
                             m_data->endOfValidity, m_data->description, m_data->lastValidatedTime ) ){
    cond::throwException( "Tag \""+tag+"\" has not been found in the database.","IOVEditor::load");
      }
      m_data->tag = tag;
      m_data->exists = true;
      m_data->change = false;
    }

IOVEditor & IOVEditor::operator=

(

const IOVEditor &

rhs

)

Definition at line 66 of file IOVEditor.cc.

References m_data, and m_session.

                                                         {
      m_data = rhs.m_data;
      m_session = rhs.m_session;
      return *this;
    }

std::string IOVEditor::payloadType

(

)

const

Definition at line 93 of file IOVEditor.cc.

References m_data.

Referenced by cond::service::PoolDBOutputService::appendSinceTime(), cond::persistency::copyIov(), cond::service::PoolDBOutputService::createNewIOV(), and cond::persistency::importIovs().

                                           {
      return m_data.get() ? m_data->payloadType :  "";
    }

void IOVEditor::setDescription

(

const std::string &

description

)

Definition at line 116 of file IOVEditor.cc.

References description(), and m_data.

Referenced by cond::persistency::copyIov(), cond::persistency::copyTag(), cond::service::PoolDBOutputService::createNewIOV(), cond::persistency::importIovs(), and cond::persistency::migrateTag().

                                                                {
      if( m_data.get() ) {
    m_data->description = description;
    m_data->change = true;
      }
    }

void IOVEditor::setEndOfValidity

(

cond::Time_t

validity

)

Definition at line 105 of file IOVEditor.cc.

References m_data, and cond::rpcobgas::time.

Referenced by cond::service::PoolDBOutputService::closeIOV().

                                                     {
      if( m_data.get() ) {
    m_data->endOfValidity = time;
    m_data->change = true;
      }
    }

void IOVEditor::setLastValidatedTime

(

cond::Time_t

time

)

Definition at line 127 of file IOVEditor.cc.

References m_data, and cond::rpcobgas::time.

                                                        {
      if( m_data.get() ) {
    m_data->lastValidatedTime = time;
    m_data->change = true;
      }
    }

void IOVEditor::setValidationMode

(

)

Definition at line 134 of file IOVEditor.cc.

References m_data.

Referenced by cond::persistency::copyTag().

                                     {
      if( m_data.get() ) m_data->validationMode = true;
    }

cond::SynchronizationType IOVEditor::synchronizationType

(

)

const

Definition at line 97 of file IOVEditor.cc.

References m_data, and cond::SYNCH_ANY.

Referenced by IOVEditor().

                                                                 {
      return m_data.get()? m_data->synchronizationType : cond::SYNCH_ANY ; 
    }

std::string IOVEditor::tag

(

)

const

Definition at line 84 of file IOVEditor.cc.

References m_data.

Referenced by IOVEditor(), load(), and Inspector.Inspector::SetTag().

                                   {
      return m_data.get()? m_data->tag : "" ;
    }

cond::TimeType IOVEditor::timeType

(

)

const

Definition at line 89 of file IOVEditor.cc.

References cond::invalid, and m_data.

Referenced by cond::persistency::copyIov(), cond::persistency::importIovs(), and IOVEditor().

                                           {
      return m_data.get() ? m_data->timeType : cond::invalid;
    }

Member Data Documentation

std::shared_ptr<IOVEditorData> cond::persistency::IOVEditor::m_data

private

Definition at line 84 of file IOVEditor.h.

Referenced by description(), endOfValidity(), flush(), insert(), IOVEditor(), lastValidatedTime(), load(), operator=(), payloadType(), setDescription(), setEndOfValidity(), setLastValidatedTime(), setValidationMode(), synchronizationType(), tag(), and timeType().

std::shared_ptr<SessionImpl> cond::persistency::IOVEditor::m_session

private

Definition at line 85 of file IOVEditor.h.

Referenced by checkTransaction(), flush(), load(), and operator=().