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)
bool	flush (const std::string &logText)
bool	flush (const std::string &logText, bool forceInsertion)
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	setSynchronizationType (cond::SynchronizationType synchronizationType)
void	setValidationMode ()
cond::SynchronizationType	synchronizationType () const
std::string	tag () const
cond::TimeType	timeType () const

Private Member Functions
void	checkTransaction (const std::string &ctx)
bool	flush (const std::string &logText, const boost::posix_time::ptime &operationTime, bool forceInsertion)

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 38 of file IOVEditor.cc.

                        :
      m_data(),
      m_session(){
    }

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

explicit

Definition at line 43 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 48 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 64 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 263 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 124 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 112 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 255 of file IOVEditor.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by SiStripDetVOffHandler::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), cond::service::PoolDBOutputService::appendSinceTime(), cond::service::PoolDBOutputService::closeIOV(), cond::persistency::copyIov(), cond::service::PoolDBOutputService::createNewIOV(), flush(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), and cond::persistency::importIovs().

                         {
      return flush( std::string("-"), boost::posix_time::microsec_clock::universal_time(), false );
    }

bool IOVEditor::flush

(

const boost::posix_time::ptime &

operationTime

)

Definition at line 251 of file IOVEditor.cc.

References flush(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                    {
      return flush( std::string("-"), operationTime, false );
    }

bool IOVEditor::flush

(

const std::string &

logText

)

Definition at line 247 of file IOVEditor.cc.

References flush().

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

bool IOVEditor::flush	(	const std::string &	logText,
		bool	forceInsertion
	)

Definition at line 259 of file IOVEditor.cc.

References flush().

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

bool IOVEditor::flush ( const std::string &  logText, const boost::posix_time::ptime &  operationTime, bool  forceInsertion  )

private

Definition at line 168 of file IOVEditor.cc.

References writedatasetfile::action, EnergyCorrector::c, checkTransaction(), h, mps_fire::i, cond::persistency::iovSorter(), checklumidiff::l, plotBeamSpotDB::last, m_data, m_session, mps_check::msg, jetUpdater_cfi::sort, AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, cond::SYNCH_VALIDATION, cond::synchronizationTypeNames(), and cond::persistency::throwException().

                                                                                                                   {
      bool ret = false;
      checkTransaction( "IOVEditor::flush" );
      std::string lt = logText;
      if( lt.empty() ) lt = "-";
      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 ){
      // set the creation time ( only available in the migration from v1...)
      if( m_data->creationTime.is_not_a_date_time() )  m_data->creationTime = operationTime;
      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 );
          if( m_session->iovSchema().tagLogTable().exists() )
        m_session->iovSchema().tagLogTable().insert(  m_data->tag,  m_data->creationTime, cond::getUserName(),cond::getHostName(), cond::getCommand(),
                              std::string("New tag created."),lt );
      m_data->exists = true;
      ret = true;
    } else {
      m_session->iovSchema().tagTable().update( m_data->tag, m_data->synchronizationType, m_data->endOfValidity, m_data->description, 
                            m_data->lastValidatedTime, operationTime );   
          if( m_session->iovSchema().tagLogTable().exists() ){
        std::string action("Tag header updated. Changes involve: ");
            size_t i = 0;
        for( auto c: m_data->changes){
          action += c;
          if( i==(m_data->changes.size()-1) ) action += ".";
          else action += ", ";
              i++;
        } 
        m_session->iovSchema().tagLogTable().insert(  m_data->tag,  operationTime, cond::getUserName(),cond::getHostName(), cond::getCommand(), 
                              action,lt );
      }
      ret = true;
    }
    m_data->change = false;
      }
      if( !m_data->iovBuffer.empty() ) {
    std::sort(m_data->iovBuffer.begin(),m_data->iovBuffer.end(),iovSorter);
    cond::Time_t l = std::get<0>(m_data->iovBuffer.front());
        //We do not allow for IOV updates (i.e. insertion in the past or overriding) on tags whose syncrosization is not "ANY" or "VALIDATION".
        //This policy is stricter than the one deployed in the Condition Upload service,
        //which allows insertions in the past or overriding for IOVs larger than the first condition safe run for HLT ("HLT"/"EXPRESS" synchronizations) and Tier0 ("PROMPT"/"PCL").
        //This is intended: in the C++ API we have not got a way to determine the first condition safe runs.
        if( !forceInsertion && m_data->synchronizationType != cond::SYNCH_ANY && m_data->synchronizationType != cond::SYNCH_VALIDATION ){
      // retrieve the last since
      cond::Time_t last = 0;
      cond::Hash h;
      boost::posix_time::ptime no_time;
      m_session->iovSchema().iovTable().getLastIov( m_data->tag, no_time, 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");
      }
    }
    // set the insertion time ( only for the migration from v1 will be available... )
        for( auto& iov : m_data->iovBuffer ){
      boost::posix_time::ptime& insertionTime = std::get<2>(iov);
      if( insertionTime.is_not_a_date_time() ) insertionTime = operationTime;
    }
    // insert the new iovs
    m_session->iovSchema().iovTable().insertMany( m_data->tag, m_data->iovBuffer );
    std::stringstream msg;
        msg << m_data->iovBuffer.size() << " iov(s) inserted.";
    if( m_session->iovSchema().tagLogTable().exists() ){
      m_session->iovSchema().tagLogTable().insert(  m_data->tag,  operationTime, cond::getUserName(), cond::getHostName(), cond::getCommand(), 
                            msg.str(),lt );
    }
    m_data->iovBuffer.clear();
        m_data->changes.clear();
    ret = true;
      }
      return ret;
    }

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

Definition at line 152 of file IOVEditor.cc.

References cmsPerfSuiteHarvest::now.

Referenced by SiStripDetVOffHandler::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), BeautifulSoup.PageElement::append(), cond::service::PoolDBOutputService::appendSinceTime(), cond::persistency::copyIov(), cond::service::PoolDBOutputService::createNewIOV(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), and cond::persistency::importIovs().

                                                                                         {
      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 157 of file IOVEditor.cc.

References m_data.

Referenced by BeautifulSoup.PageElement::append().

                                                                                                                          {
      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 136 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 75 of file IOVEditor.cc.

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

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

                                              {
      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 69 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 96 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 128 of file IOVEditor.cc.

References description(), and m_data.

Referenced by SiStripDetVOffHandler::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), cond::persistency::copyIov(), cond::service::PoolDBOutputService::createNewIOV(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), and cond::persistency::importIovs().

                                                                {
      if( m_data.get() ) {
    m_data->description = description;
    m_data->change = true;
    m_data->changes.insert("Description");
      }
    }

void IOVEditor::setEndOfValidity

(

cond::Time_t

validity

)

Definition at line 116 of file IOVEditor.cc.

References m_data, and protons_cff::time.

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

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

void IOVEditor::setLastValidatedTime

(

cond::Time_t

time

)

Definition at line 140 of file IOVEditor.cc.

References m_data, and protons_cff::time.

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

void IOVEditor::setSynchronizationType

(

cond::SynchronizationType

synchronizationType

)

Definition at line 104 of file IOVEditor.cc.

References m_data, and synchronizationType().

                                                                                       {
      if( m_data.get() ) {
    m_data->synchronizationType = synchronizationType;
    m_data->change = true;
        m_data->changes.insert("SynchronizationType");
      }      
    }

void IOVEditor::setValidationMode

(

)

Definition at line 148 of file IOVEditor.cc.

References m_data.

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

cond::SynchronizationType IOVEditor::synchronizationType

(

)

const

Definition at line 100 of file IOVEditor.cc.

References m_data, and cond::SYNCH_ANY.

Referenced by IOVEditor(), and setSynchronizationType().

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

std::string IOVEditor::tag

(

)

const

Definition at line 87 of file IOVEditor.cc.

References m_data.

Referenced by IOVEditor(), and load().

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

cond::TimeType IOVEditor::timeType

(

)

const

Definition at line 92 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 89 of file IOVEditor.h.

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

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

private

Definition at line 90 of file IOVEditor.h.

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