cond::IOVEditor Class Reference

#include <IOVEditor.h>

Public Member Functions
unsigned int	append (cond::Time_t sinceTime, const std::string &payloadToken)
void	bulkAppend (std::vector< std::pair< cond::Time_t, std::string > > &values)
	Bulk append of iov chunck. More...
void	bulkAppend (std::vector< cond::IOVElement > &values)
std::string	create (cond::TimeType timetype)
std::string	create (cond::TimeType timetype, cond::Time_t lastTill, const std::string &metadata)
std::string	create (cond::TimeType timetype, cond::Time_t lastTill)
bool	createIOVContainerIfNecessary ()
void	deleteEntries (bool withPayload=false)
void	editMetadata (std::string const &metadata, bool append=false)
	edit metadata More...
unsigned int	freeInsert (cond::Time_t sinceTime, const std::string &payloadToken)
	insert a payload with known since in any position More...
size_t	import (cond::DbSession &sourceSess, const std::string &sourceIovToken)
boost::shared_ptr < IOVImportIterator >	importIterator ()
unsigned int	insert (cond::Time_t tillTime, const std::string &payloadToken)
	Assign a payload with till time. Returns the payload index in the iov sequence. More...
	IOVEditor ()
	IOVEditor (cond::DbSession &dbSess)
	IOVEditor (cond::DbSession &dbSess, const std::string &token)
	IOVEditor (const IOVEditor &rhs)
void	load (const std::string &token)
IOVEditor &	operator= (const IOVEditor &rhs)
cond::IOVProxy	proxy () const
void	reload ()
void	setScope (cond::IOVSequence::ScopeType scope)
	set the scope More...
void	stamp (std::string const &icomment, bool append=false)
TimeType	timetype () const
std::string const &	token () const
unsigned int	truncate (bool withPayload=false)
void	updateClosure (cond::Time_t newtillTime)
	Update the closure of the iov sequence. More...
	~IOVEditor ()
	Destructor. More...

Private Member Functions
void	debugInfo (std::ostream &co) const
void	reportError (std::string message) const
void	reportError (std::string message, cond::Time_t time) const
bool	validTime (cond::Time_t time, cond::TimeType timetype) const
bool	validTime (cond::Time_t time) const

Private Attributes
boost::shared_ptr < cond::IOVProxyData >	m_iov
bool	m_isLoaded

Detailed Description

Definition at line 56 of file IOVEditor.h.

Constructor & Destructor Documentation

IOVEditor::IOVEditor

(

)

Definition at line 168 of file IOVEditor.cc.

                      :
    m_isLoaded(false),
    m_iov(){
  }

IOVEditor::~IOVEditor

(

)

Destructor.

Definition at line 173 of file IOVEditor.cc.

{}

IOVEditor::IOVEditor ( cond::DbSession &  dbSess )

explicit

Definition at line 175 of file IOVEditor.cc.

                                            :
    m_isLoaded(false),
    m_iov( new IOVProxyData( dbSess ) ){
  }

IOVEditor::IOVEditor	(	cond::DbSession &	dbSess,
		const std::string &	token
	)

Definition at line 180 of file IOVEditor.cc.

                                    :
    m_isLoaded(false),
    m_iov( new IOVProxyData( dbSess, token )){
  }

IOVEditor::IOVEditor

(

const IOVEditor &

rhs

)

Definition at line 186 of file IOVEditor.cc.

                                            :
    m_isLoaded( rhs.m_isLoaded ),
    m_iov( rhs.m_iov ){
  }

Member Function Documentation

unsigned int IOVEditor::append	(	cond::Time_t	sinceTime,
		const std::string &	payloadToken
	)

Append a payload with known since time. The previous last payload's till time will be adjusted to the new payload since time. Returns the payload index in the iov sequence

Definition at line 416 of file IOVEditor.cc.

References cond::TimeTypeSpecs::endValue, o2o::iov, m_iov, m_isLoaded, reload(), reportError(), run_regression::ret, AlCaHLTBitMon_QueryRunRegistry::string, cond::timeTypeSpecs, cond::updateIOV(), and validTime().

Referenced by diclist.diclist::add(), Vispa.Views.PropertyView.PropertyView::addProperty(), cond::AlignSplitIOV::execute(), cond::persistency::OraIOVTable::insertOne(), python.seqvaluedict.seqdict::push(), BeautifulSoup.Tag::setString(), and TestFunct::WriteWithIOV().

                                            {
    if( m_iov->token.empty() ) {
      reportError("cond::IOVEditor::appendIOV cannot append to non-existing IOV index");
    }
    
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;

    if(!validTime(sinceTime))
      reportError("cond::IOVEditor::append time not in global range",sinceTime);  
    
    if(  !iov->iovs().empty() ){
      //range check in case 
      cond::Time_t lastValidSince=iov->iovs().back().sinceTime();
      if( sinceTime<= lastValidSince){
    std::ostringstream errStr;
    errStr << "IOVEditor::append Error: trying to append a since time " << lastValidSince
           << " which is not larger than last since";
    reportError(errStr.str(), sinceTime);
      }
    }

    // does it make sense? (in case of mixed till and since insertions...)
    if (iov->lastTill()<=sinceTime) iov->updateLastTill( timeTypeSpecs[iov->timeType()].endValue );
    std::string payloadClassName = m_iov->dbSession.classNameForItem( payloadToken );   
    unsigned int ret = iov->add(sinceTime,payloadToken, payloadClassName );
    updateIOV( m_iov->dbSession, iov, m_iov->token );
    return ret;
  }

void IOVEditor::bulkAppend

(

std::vector< std::pair< cond::Time_t, std::string > > &

values

)

Bulk append of iov chunck.

Definition at line 321 of file IOVEditor.cc.

References firstTime, o2o::iov, m_iov, m_isLoaded, reload(), reportError(), AlCaHLTBitMon_QueryRunRegistry::string, cond::updateIOV(), validTime(), and makeHLTPrescaleTable::values.

Referenced by cond::persistency::OraIOVTable::insertMany().

                                                                           {
    if (values.empty()) return;
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    cond::Time_t firstTime = values.front().first;
    cond::Time_t  lastTime = values.back().first;
    if(!validTime(firstTime))
      reportError("cond::IOVEditor::bulkInsert first time not in global range",firstTime);

    if(!validTime(lastTime))
      reportError("cond::IOVEditor::bulkInsert last time not in global range",lastTime);

    if(lastTime>= iov->lastTill() ||
      ( !iov->iovs().empty() && firstTime<=iov->iovs().back().sinceTime()) 
       )    
     reportError("cond::IOVEditor::bulkInsert IOV not in range",firstTime);

   for(std::vector< std::pair<cond::Time_t,std::string> >::const_iterator it=values.begin(); it!=values.end(); ++it){
     std::string payloadClassName = m_iov->dbSession.classNameForItem( it->second );    
     iov->add(it->first,it->second,payloadClassName );
   }
   updateIOV( m_iov->dbSession, iov, m_iov->token );
  }

void IOVEditor::bulkAppend

(

std::vector< cond::IOVElement > &

values

)

Definition at line 348 of file IOVEditor.cc.

References firstTime, o2o::iov, m_iov, m_isLoaded, reload(), reportError(), AlCaHLTBitMon_QueryRunRegistry::string, cond::updateIOV(), and validTime().

                                                          {
    if (values.empty()) return;
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    cond::Time_t firstTime = values.front().sinceTime();
    cond::Time_t   lastTime = values.back().sinceTime();
    if(!validTime(firstTime))
      reportError("cond::IOVEditor::bulkInsert first time not in global range",firstTime);

    if(!validTime(lastTime))
      reportError("cond::IOVEditor::bulkInsert last time not in global range",lastTime);

   if(lastTime>=iov->lastTill() ||
      ( !iov->iovs().empty() && firstTime<=iov->iovs().back().sinceTime()) 
      )    reportError("cond::IOVEditor::bulkInsert IOV not in range",firstTime);

   for(std::vector< cond::IOVElement >::const_iterator it=values.begin(); it!=values.end(); ++it){
     std::string payloadClassName = m_iov->dbSession.classNameForItem( it->token() );     
     iov->add(it->sinceTime(),it->token(),payloadClassName );
   }

   updateIOV( m_iov->dbSession, iov, m_iov->token );
  }

std::string IOVEditor::create

(

cond::TimeType

timetype

)

Definition at line 260 of file IOVEditor.cc.

References cond::insertIOV(), m_iov, and m_isLoaded.

Referenced by cond::ExportIOVUtilities::execute(), cond::AlignSplitIOV::execute(), cond::persistency::OraTagTable::insert(), and TestFunct::WriteWithIOV().

                                                     {
    m_iov->data.reset( new cond::IOVSequence(timetype) );
    m_iov->token = insertIOV( m_iov->dbSession, m_iov->data );
    m_isLoaded=true;
    return m_iov->token;
  }

std::string IOVEditor::create	(	cond::TimeType	timetype,
		cond::Time_t	lastTill,
		const std::string &	metadata
	)

Definition at line 267 of file IOVEditor.cc.

References cond::insertIOV(), m_iov, and m_isLoaded.

                                              {
    m_iov->data.reset( new cond::IOVSequence((int)timetype,lastTill, metadata) );
    m_iov->token = insertIOV( m_iov->dbSession, m_iov->data );
    m_isLoaded=true;
    return m_iov->token;
  }

std::string IOVEditor::create	(	cond::TimeType	timetype,
		cond::Time_t	lastTill
	)

Definition at line 277 of file IOVEditor.cc.

References cond::insertIOV(), m_iov, m_isLoaded, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                        {
    m_iov->data.reset( new cond::IOVSequence((int)timetype,lastTill, std::string(" ")) );
    m_iov->token = insertIOV( m_iov->dbSession, m_iov->data );
    m_isLoaded=true;
    return m_iov->token;
  }

bool IOVEditor::createIOVContainerIfNecessary

(

)

Definition at line 249 of file IOVEditor.cc.

References cond::IOVSchemaUtility::createIOVContainer(), cond::IOVSchemaUtility::existsIOVContainer(), m_iov, and run_regression::ret.

Referenced by cond::ExportIOVUtilities::execute().

                                               {
    bool ret = false;
    cond::IOVSchemaUtility schemaUtil( m_iov->dbSession );
    if( !schemaUtil.existsIOVContainer() ){
      schemaUtil.createIOVContainer();
      ret = true;
    }
    return ret;
  }

void IOVEditor::debugInfo ( std::ostream &  co ) const

private

Definition at line 208 of file IOVEditor.cc.

References o2o::iov, m_iov, cond::TimeTypeSpecs::name, and cond::timeTypeSpecs.

Referenced by reportError().

                                                 {
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    co << "IOVEditor: ";
    co << "db " << m_iov->dbSession.connectionString();
    if(m_iov->token.empty()) {
      co << " no token"; return;
    }
    if (!m_iov->data.get() )  {
      co << " no iov for token " << m_iov->token;
      return;
    }
    co << " iov token " << m_iov->token;
    co << "\nStamp: " <<  iov->comment()
       << "; time " <<  iov->timestamp()
       << "; revision " <<  iov->revision();
    co <<". TimeType " << cond::timeTypeSpecs[ iov->timeType()].name;
    if(  iov->iovs().empty() ) 
      co << ". empty";
    else
      co << ". size " <<  iov->iovs().size() 
     << "; last since " << iov->iovs().back().sinceTime();
  }

void IOVEditor::deleteEntries

(

bool

withPayload = false

)

Definition at line 504 of file IOVEditor.cc.

References o2o::iov, m_iov, m_isLoaded, reload(), reportError(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                          {
    if( m_iov->token.empty() ) reportError("cond::IOVEditor::deleteEntries cannot delete to non-existing IOV sequence");
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    if(withPayload){
      std::string tokenStr;
      IOVSequence::const_iterator payloadIt;
      IOVSequence::const_iterator payloadItEnd=iov->piovs().end();
      for(payloadIt=iov->piovs().begin();payloadIt!=payloadItEnd;++payloadIt){
        tokenStr=payloadIt->token();
        m_iov->dbSession.deleteObject( tokenStr );
      }
    }
    m_iov->dbSession.deleteObject( m_iov->token );
    iov->piovs().clear();
  }

void IOVEditor::editMetadata	(	std::string const &	metadata,
		bool	append = false
	)

edit metadata

Definition at line 385 of file IOVEditor.cc.

References o2o::iov, m_iov, m_isLoaded, reload(), and cond::updateIOV().

                             {
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    iov->updateMetadata( metadata, append);
    updateIOV( m_iov->dbSession, iov, m_iov->token );
  }

unsigned int IOVEditor::freeInsert	(	cond::Time_t	sinceTime,
		const std::string &	payloadToken
	)

insert a payload with known since in any position

Definition at line 451 of file IOVEditor.cc.

References cond::TimeTypeSpecs::endValue, o2o::iov, m_iov, m_isLoaded, reload(), reportError(), run_regression::ret, AlCaHLTBitMon_QueryRunRegistry::string, cond::timeTypeSpecs, cond::updateIOV(), and validTime().

Referenced by cond::persistency::OraIOVTable::insertOne().

                                           {
    if( m_iov->token.empty() ) {
      reportError("cond::IOVEditor::freeInsert cannot append to non-existing IOV index");
    }
    
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    
    //   if( m_iov->data->iov.empty() ) reportError("cond::IOVEditor::freeInsert cannot insert  to empty IOV index");
    

   if(!validTime(sinceTime))
     reportError("cond::IOVEditor::freeInsert time not in global range",sinceTime);

   
   // we do not support multiple iov with identical since...
   if (m_iov->data->exist(sinceTime))
     reportError("cond::IOVEditor::freeInsert sinceTime already existing",sinceTime);



     // does it make sense? (in case of mixed till and since insertions...)
   if (iov->lastTill()<sinceTime) iov->updateLastTill( timeTypeSpecs[iov->timeType()].endValue );
   std::string payloadClassName = m_iov->dbSession.classNameForItem( payloadToken );   
   unsigned int ret = iov->add(sinceTime,payloadToken, payloadClassName );
   updateIOV( m_iov->dbSession, iov, m_iov->token );
   return ret;
  }

size_t IOVEditor::import	(	cond::DbSession &	sourceSess,
		const std::string &	sourceIovToken
	)

Definition at line 523 of file IOVEditor.cc.

References importIterator().

                                                 {
    boost::shared_ptr<IOVImportIterator> importer = importIterator();
    importer->setUp( sourceSess, sourceIovToken );
    return importer->importAll();
  }

boost::shared_ptr< IOVImportIterator > IOVEditor::importIterator

(

)

Definition at line 531 of file IOVEditor.cc.

References m_iov, m_isLoaded, and reload().

Referenced by cond::ExportIOVUtilities::execute(), and import().

                           {
    if( !m_isLoaded ){
      reload();
    }
    return boost::shared_ptr<IOVImportIterator>( new IOVImportIterator( m_iov ));                        
  }

unsigned int IOVEditor::insert	(	cond::Time_t	tillTime,
		const std::string &	payloadToken
	)

Assign a payload with till time. Returns the payload index in the iov sequence.

Definition at line 297 of file IOVEditor.cc.

References o2o::iov, m_iov, m_isLoaded, reload(), reportError(), run_regression::ret, AlCaHLTBitMon_QueryRunRegistry::string, cond::updateIOV(), and validTime().

Referenced by BeautifulSoup.PageElement::_invert().

                                            {
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    if( iov->iovs().empty() ) 
      reportError("cond::IOVEditor::insert cannot inser into empty IOV sequence",tillTime);
    
    if(!validTime(tillTime))
      reportError("cond::IOVEditor::insert time not in global range",tillTime);
    
    if(tillTime<=iov->lastTill() )
      reportError("cond::IOVEditor::insert IOV not in range",tillTime);
    
    cond::Time_t newSince=iov->lastTill()+1;
    std::string payloadClassName = m_iov->dbSession.classNameForItem( payloadToken );
    unsigned int ret = iov->add(newSince, payloadToken, payloadClassName);
    iov->updateLastTill(tillTime);
    updateIOV( m_iov->dbSession, iov, m_iov->token );
    return ret;
  }

void IOVEditor::load

(

const std::string &

token

)

Definition at line 202 of file IOVEditor.cc.

References m_iov, m_isLoaded, and token().

Referenced by cond::ExportIOVUtilities::execute(), MatrixToProcess.MatrixToProcess::getProcess(), MatrixToProcess.MatrixToProcess::listAll(), cond::persistency::IOVCache::load(), and cond::persistency::OraTagTable::update().

                                              {
    m_iov->token = token;
    m_iov->refresh();
    m_isLoaded = true;
  }

IOVEditor & IOVEditor::operator=

(

const IOVEditor &

rhs

)

Definition at line 191 of file IOVEditor.cc.

References m_iov, and m_isLoaded.

                                                       {
    m_isLoaded = rhs.m_isLoaded;
    m_iov = rhs.m_iov;
    return *this;
  }

IOVProxy IOVEditor::proxy

(

)

const

Definition at line 546 of file IOVEditor.cc.

References m_iov.

Referenced by cond::ExportIOVUtilities::execute(), cond::persistency::IOVCache::iovSequence(), and cond::persistency::IOVCache::session().

                                 {
    return IOVProxy( m_iov );
  }

void IOVEditor::reload

(

)

Definition at line 197 of file IOVEditor.cc.

References m_iov, and m_isLoaded.

Referenced by append(), bulkAppend(), deleteEntries(), editMetadata(), cond::ExportIOVUtilities::execute(), freeInsert(), importIterator(), insert(), setScope(), stamp(), truncate(), and updateClosure().

                        {
    m_iov->refresh();
    m_isLoaded = true;
  }

void IOVEditor::reportError ( std::string  message ) const

private

Definition at line 231 of file IOVEditor.cc.

References debugInfo(), Exception, python.rootplot.argparse::message, and dbtoconf::out.

Referenced by append(), bulkAppend(), deleteEntries(), freeInsert(), insert(), truncate(), and updateClosure().

                                                     {
    std::ostringstream out;
    out << "Error in ";
    debugInfo(out);
    out  << "\n" << message;
    throw cond::Exception(out.str());
  }

void IOVEditor::reportError ( std::string  message, cond::Time_t  time  ) const

private

Definition at line 239 of file IOVEditor.cc.

References debugInfo(), Exception, dbtoconf::out, and cond::rpcobgas::time.

                                                      {
    std::ostringstream out;
    out << "Error in ";
    debugInfo(out);
    out << "\n" <<  message << " for time:  " << time;
    throw cond::Exception(out.str());
  }

void IOVEditor::setScope

(

cond::IOVSequence::ScopeType

scope

)

set the scope

Definition at line 395 of file IOVEditor.cc.

References o2o::iov, m_iov, m_isLoaded, reload(), and cond::updateIOV().

Referenced by cond::ExportIOVUtilities::execute().

                                                          {
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    iov->setScope( scope );
    updateIOV( m_iov->dbSession, iov, m_iov->token );
  }

void IOVEditor::stamp	(	std::string const &	icomment,
		bool	append = false
	)

Definition at line 375 of file IOVEditor.cc.

References o2o::iov, m_iov, m_isLoaded, reload(), and cond::updateIOV().

Referenced by cond::AlignSplitIOV::execute(), cond::persistency::OraTagTable::insert(), and cond::persistency::OraTagTable::update().

                                 {
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    iov->stamp(icomment, append);
    updateIOV( m_iov->dbSession, iov, m_iov->token );
  }

TimeType IOVEditor::timetype

(

)

const

Definition at line 538 of file IOVEditor.cc.

References m_iov.

Referenced by cond::ExportIOVUtilities::execute(), cond::persistency::OraIOVTable::insertMany(), cond::persistency::OraIOVTable::insertOne(), and validTime().

                                     {
    return m_iov->data->timeType();
  }

std::string const & IOVEditor::token

(

)

const

Definition at line 542 of file IOVEditor.cc.

References m_iov.

Referenced by cond::AlignSplitIOV::execute(), cond::persistency::IOVCache::load(), load(), and TestFunct::WriteWithIOV().

                                           {
    return m_iov->token;
  }

unsigned int IOVEditor::truncate

(

bool

withPayload = false

)

Definition at line 485 of file IOVEditor.cc.

References o2o::iov, m_iov, m_isLoaded, reload(), reportError(), run_regression::ret, AlCaHLTBitMon_QueryRunRegistry::string, and cond::updateIOV().

Referenced by Vispa.Gui.VispaWidget.TextField::calculateDimensions().

                                                   {
    if( m_iov->token.empty() ) reportError("cond::IOVEditor::truncate cannot delete to non-existing IOV sequence");
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    if (iov->piovs().empty()) return 0;
    if(withPayload){
      std::string tokenStr = iov->piovs().back().token();
      m_iov->dbSession.deleteObject( tokenStr );
    }
    unsigned int ret = iov->truncate();
    updateIOV( m_iov->dbSession, iov, m_iov->token );
    return ret;
    
  }

void IOVEditor::updateClosure

(

cond::Time_t

newtillTime

)

Update the closure of the iov sequence.

Definition at line 405 of file IOVEditor.cc.

References o2o::iov, m_iov, m_isLoaded, reload(), reportError(), and cond::updateIOV().

Referenced by cond::persistency::OraTagTable::update().

                                                  {
    if( m_iov->token.empty() ) reportError("cond::IOVEditor::updateClosure cannot change non-existing IOV index");
    if( !m_isLoaded ){
      reload();
    }
    boost::shared_ptr<IOVSequence>& iov = m_iov->data;
    iov->updateLastTill(newtillTime);
    updateIOV( m_iov->dbSession, iov, m_iov->token );
  }

bool IOVEditor::validTime ( cond::Time_t  time, cond::TimeType  timetype  ) const

private

Definition at line 284 of file IOVEditor.cc.

References cond::TimeTypeSpecs::beginValue, cond::TimeTypeSpecs::endValue, timetype(), and cond::timeTypeSpecs.

Referenced by append(), bulkAppend(), freeInsert(), insert(), and validTime().

                                                          {
    return time>=timeTypeSpecs[timetype].beginValue && time<=timeTypeSpecs[timetype].endValue;   
    
  }

bool IOVEditor::validTime ( cond::Time_t  time ) const

private

Definition at line 290 of file IOVEditor.cc.

References m_iov, and validTime().

                                                 {
    return validTime(time,m_iov->data->timeType());
  }

Member Data Documentation

boost::shared_ptr<cond::IOVProxyData> cond::IOVEditor::m_iov

private

Definition at line 147 of file IOVEditor.h.

Referenced by append(), bulkAppend(), create(), createIOVContainerIfNecessary(), debugInfo(), deleteEntries(), editMetadata(), freeInsert(), importIterator(), insert(), load(), operator=(), proxy(), reload(), setScope(), stamp(), timetype(), token(), truncate(), updateClosure(), and validTime().

bool cond::IOVEditor::m_isLoaded

private

Definition at line 146 of file IOVEditor.h.

Referenced by append(), bulkAppend(), create(), deleteEntries(), editMetadata(), freeInsert(), importIterator(), insert(), load(), operator=(), reload(), setScope(), stamp(), truncate(), and updateClosure().