IOVSvc Class Reference

#include <IOVSvc.h>

Inheritance diagram for IOVSvc:

Collaboration diagram for IOVSvc:

Public Member Functions
	IOVSvc (const std::string &name, ISvcLocator *svc)
virtual	~IOVSvc ()
virtual StatusCode	initialize () override
virtual StatusCode	reinitialize () override
virtual StatusCode	finalize () override
virtual StatusCode	createIOVTool (const std::string &storeName) override
virtual std::vector< std::string >	getStoreNames () const override
virtual StatusCode	regFcn (SG::DataProxy *dp, const CallBackID &c, const IOVSvcCallBackFcn &fcn, bool trigger=false) override
	register callback functions
virtual StatusCode	regFcn (const CallBackID &c1, const CallBackID &c2, const IOVSvcCallBackFcn &fcn2, bool trigger) override
virtual StatusCode	regFcn (const std::string &toolName, const CallBackID &c2, const IOVSvcCallBackFcn &fcn2, bool trigger) override
virtual StatusCode	setRange (const CLID &clid, const std::string &key, IOVRange &) override
	Update Range from dB.
virtual StatusCode	setRange (const CLID &clid, const std::string &key, IOVRange &io, const std::string &storeName) override
virtual StatusCode	getRange (const CLID &clid, const std::string &key, IOVRange &io) const override
virtual StatusCode	regProxy (SG::DataProxy *proxy, const std::string &key, const std::string &storeName) override
	Subscribe method for DataProxy. key StoreGate key.
virtual StatusCode	replaceProxy (SG::DataProxy *pOld, SG::DataProxy *pNew, const std::string &storeName) override
	replace a registered DataProxy with a new version
virtual StatusCode	regProxy (const CLID &clid, const std::string &key, const std::string &storeName) override
	Another way to subscribe.
virtual StatusCode	deregProxy (SG::DataProxy *proxy) override
	Deregister a DataProxy with the service.
virtual StatusCode	deregProxy (const CLID &clid, const std::string &key) override
	Deregister a DataProxy with the service.
virtual StatusCode	getRangeFromDB (const CLID &clid, const std::string &key, IOVRange &range, std::string &tag, std::unique_ptr< IOpaqueAddress > &ioa, const EventIDBase &now) const override
	Get IOVRange from db for current event.
virtual StatusCode	getRangeFromDB (const CLID &clid, const std::string &key, const IOVTime &time, IOVRange &range, std::string &tag, std::unique_ptr< IOpaqueAddress > &ioa) const override
	Get IOVRange from db for a particular event.
virtual StatusCode	setRangeInDB (const CLID &clid, const std::string &key, const IOVRange &range, const std::string &tag) override
	Set a particular IOVRange in db (and memory)
virtual StatusCode	dropObjectFromDB (const CLID &clid, const std::string &key, const std::string &storeName) override
	Drop the associated object from the db and trigger reload.
virtual StatusCode	preLoadTAD (const SG::TransientAddress *, const std::string &storeName) override
	supply a list of TADs whose proxies will be preloaded
virtual StatusCode	preLoadDataTAD (const SG::TransientAddress *, const std::string &storeName) override
	supply a list of TADs whose data will be preloaded
virtual StatusCode	getTriggeredTools (const std::string &key, std::set< std::string > &tools, const std::string &storeName) override
	return list of tools (or functions) that have been triggered by key will return FAILURE if no tools found, or no key found
virtual void	resetAllProxies () override
virtual void	ignoreProxy (const CLID &clid, const std::string &key, const std::string &storeName) override
	ignore proxy
virtual StatusCode	createCondObj (CondContBase *, const DataObjID &, const EventIDBase &) override

Private Types
typedef std::map< std::string, IIOVSvcTool * >	toolMap

Private Member Functions
StatusCode	createIOVTool (const std::string &storeName, IIOVSvcTool *&tool)
IIOVSvcTool *	getTool (const std::string &storeName, bool createIF=true)
IIOVSvcTool *	getTool (const CLID &clid, const std::string &key) const
IIOVSvcTool *	getTool (SG::DataProxy *proxy) const
IIOVSvcTool *	getTool (const CallBackID &c1) const
IIOVSvcTool *	getTool (const IAlgTool *ia) const
std::string	fullProxyName (const SG::DataProxy *proxy) const
std::string	fullProxyName (const CLID &clid, const std::string &key) const

Private Attributes
toolMap	m_toolMap
BooleanProperty	m_preLoadRanges
BooleanProperty	m_preLoadData
BooleanProperty	m_partialPreLoadData
BooleanProperty	m_preLoadExtensibleFolders
BooleanProperty	m_sortKeys
BooleanProperty	m_forceReset
std::string	m_updateInterval
ServiceHandle< IToolSvc >	p_toolSvc
ServiceHandle< IClassIDSvc >	p_CLIDSvc
ServiceHandle< StoreGateSvc >	p_sgs
ServiceHandle< StoreGateSvc >	p_detStore
ServiceHandle< ICondSvc >	p_condSvc
std::recursive_mutex	m_lock

Detailed Description

Definition at line 53 of file IOVSvc.h.

Member Typedef Documentation

toolMap

typedef std::map< std::string, IIOVSvcTool* > IOVSvc::toolMap

private

Definition at line 170 of file IOVSvc.h.

Constructor & Destructor Documentation

IOVSvc()

IOVSvc::IOVSvc	(	const std::string &	name,
		ISvcLocator *	svc )

Definition at line 66 of file IOVSvc.cxx.

  : base_class( name, svc ), 
    p_toolSvc("ToolSvc",name),
    p_CLIDSvc("ClassIDSvc",name),
    p_sgs("StoreGateSvc",name),
    p_detStore("StoreGateSvc/DetectorStore",name),
    p_condSvc("CondSvc",name)
{
 
  declareProperty("preLoadRanges",m_preLoadRanges=false);
  declareProperty("preLoadData",m_preLoadData=false);
  declareProperty("partialPreLoadData",m_partialPreLoadData=true);
  declareProperty("preLoadExtensibleFolders", m_preLoadExtensibleFolders=true);
  declareProperty("updateInterval", m_updateInterval="Event");
  declareProperty("sortKeys",m_sortKeys=true);
  declareProperty("forceResetAtBeginRun", m_forceReset=false);
 
}

~IOVSvc()

IOVSvc::~IOVSvc ( )

virtual

Definition at line 87 of file IOVSvc.cxx.

                {
 
}

Member Function Documentation

createCondObj()

StatusCode IOVSvc::createCondObj ( CondContBase * ccb, const DataObjID & id, const EventIDBase & now )

overridevirtual

Definition at line 832 of file IOVSvc.cxx.

                                              {
  
  ATH_MSG_DEBUG("createCondObj:  id: " << id << "  t: " << now << "  valid: "
                << ccb->valid(now));
 
  if (ccb->valid(now)) {
    if (msgLvl(MSG::DEBUG)) {
      EventIDRange r;
      ccb->range(now,r);
      ATH_MSG_DEBUG( "  range " << r << " for " << id 
                     << " is still valid at " << now );
    }
    return StatusCode::SUCCESS;
  }
 
  IOVTime t(now.run_number(), now.lumi_block(), (long long)now.time_stamp()*1000000000+now.time_stamp_ns_offset());
  IOVRange range;
  std::string tag;
  // remove storename from key
  std::string sgKey = id.key();
  auto sep = sgKey.find('+');
  if (sep != std::string::npos) {
    sgKey.erase(0,sep+1);
  }
  
  std::unique_ptr<IOpaqueAddress> ioa;
  if (getRangeFromDB(id.clid(), sgKey, t, range, tag, ioa).isFailure()) {
    ATH_MSG_ERROR( "unable to get range from db for time "  << t << " clid "
                   << id.clid() << " " << sgKey );
    return StatusCode::FAILURE;
  }
     
  //In case the conditons-container is a 'mixed' type, we need both run/lb and time-stamps in the range. 
  //Assume infinite IOV in the other dimension 
  EventIDRange eidRange(range);   
  if (ccb->keyType()==CondContBase::KeyType::MIXED) { 
    eidRange=EventIDRange::intersect(IOVInfiniteRange::infiniteMixed(),eidRange);    
  } 
  ATH_MSG_DEBUG( " new range for ID " << id << " : " << range 
                 << " IOA: " << ioa.get());
 
  // If the start of the new range matches the start of the last range, then
  // extend the last range rather than trying to insert a new range.
  // This can happen when a folder is tagged as `extensible' in IOVDbSvc.
  EventIDRange r;
  if (ccb->range (eidRange.start(), r) &&
      eventIDMatch (r.start(), eidRange.start()))
  {
    if (ccb->extendLastRange (eidRange).isSuccess()) {
      return StatusCode::SUCCESS;
    }
  }
 
  if (ccb->proxy() == nullptr) {
    // nb. We don't want to be holding the IOVSvc lock here,
    // as SGImplSvc can call to IOVSvc with the store lock held.
    SG::DataProxy* dp = p_detStore->proxy (id.clid(), sgKey);
    ATH_MSG_DEBUG( " found DataProxy " << dp << " for " << id );
    ccb->setProxy(dp);
  }
 
  // this will talk to the IOVDbSvc, get current run/event from EventInfo 
  // object, load
  SG::DataProxy* dp = ccb->proxy();
  DataObject* dobj(0);
  void* v(0);
 
  if (dp->store()->createObj(dp->loader(), ioa.get(), dobj).isFailure()) {
    ATH_MSG_ERROR(" could not create a new DataObject ");
    return StatusCode::FAILURE;
  } else {
    ATH_MSG_DEBUG(" created new obj at " << dobj );
 
    v = SG::Storable_cast(dobj, id.clid());
  }
 
  // Free the DataBucket that was created along with the object we read.
  if (DataBucketBase* dbb = dynamic_cast<DataBucketBase*> (dobj)) {
    dbb->relinquish();
    delete dobj;
    dobj = 0;
  }
 
  // Some data objects may be reference counted by the address.
  // CondCont will take ownership of the object, but doesn't
  // do refcounting.  We'll have gotten a reference via the Storable_cast
  // above, so it should be ok ... unless CondCont deletes
  // the new object immediately instead of inserting.
  // In that case, when we delete the address, it will
  // follow an invalid pointer.  So be sure to delete
  // the address before the object is added to CondCont.
  ioa.reset();
 
  // DataObject *d2 = static_cast<DataObject*>(v);
  
  ATH_MSG_DEBUG( " SG::Storable_cast to obj: " << v );
 
  StatusCode sc = ccb->typelessInsert (eidRange, v);
  if (!sc.isSuccess()) {
    ATH_MSG_ERROR("unable to insert Object at " << v << " into CondCont " 
                  << ccb->id() << " for range " << eidRange );
    return StatusCode::FAILURE;
  }
  else if (CondContBase::Category::isOverlap (sc)) {
    // Disable this for now... IOVDbSvc can sometimes produce overlapping
    // ranges.
    //ATH_MSG_ERROR ("IOV range overlap.");
    //return StatusCode::FAILURE;
  }
 
  return sc;
 
}

createIOVTool() [1/2]

StatusCode IOVSvc::createIOVTool ( const std::string & storeName )

overridevirtual

Definition at line 658 of file IOVSvc.cxx.

{
  IIOVSvcTool* ist = nullptr;
  return createIOVTool (storeName, ist);
}

createIOVTool() [2/2]

StatusCode IOVSvc::createIOVTool ( const std::string & storeName, IIOVSvcTool *& tool )

private

Definition at line 620 of file IOVSvc.cxx.

                                                                     {
 
  std::string store(storeName);
  std::string toolName("IOVSvcTool");
  if (storeName == "default") store = defaultStore;
 
  // Append the store name if not default
  if (store != defaultStore) {
    toolName += '_';
    toolName += store;
  }
 
  ATH_MSG_DEBUG( "Creating " << toolName << " associated with store \"" << store
                 << "\""  );
 
  toolMap::iterator itr = m_toolMap.find( store );
  if ( itr == m_toolMap.end() ) {
    ist = nullptr;
    if (p_toolSvc->retrieveTool( "IOVSvcTool/" + toolName, ist, this ).isFailure()) {
      ATH_MSG_ERROR( "Unable to create IOVSvcTool associated with store \"" 
                     << store << "\""  );
      return StatusCode::FAILURE;
    } else {
      m_toolMap[ store ] = ist;
      ist->setStoreName( store );
      return StatusCode::SUCCESS;
    }
  } else {
    ATH_MSG_INFO( "an IOVSvcTool already exists associated with store \"" 
                  << store << "\""  );
    ist = itr->second;
    return StatusCode::SUCCESS;
  }
 
}

deregProxy() [1/2]

StatusCode IOVSvc::deregProxy ( const CLID & clid, const std::string & key )

overridevirtual

Deregister a DataProxy with the service.

Definition at line 226 of file IOVSvc.cxx.

                                                           {
 
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
  IIOVSvcTool *ist = getTool( clid, key );
  if (ist == 0) {
    ATH_MSG_ERROR( "deregProxy: no IOVSvcTool found for proxy " 
                   << fullProxyName(clid,key) );
    return StatusCode::FAILURE; 
  }
 
  return ist->deregProxy( clid, key );
 
}

deregProxy() [2/2]

StatusCode IOVSvc::deregProxy ( SG::DataProxy * proxy )

overridevirtual

Deregister a DataProxy with the service.

Definition at line 205 of file IOVSvc.cxx.

                                     {
 
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
  IIOVSvcTool *ist = getTool( proxy );
  if (ist == 0) {
    ATH_MSG_ERROR( "deregProxy: no IOVSvcTool found for proxy "
          << fullProxyName( proxy ) );
    return (StatusCode::FAILURE);
  }
 
  return ist->deregProxy( proxy );
 
}

dropObjectFromDB()

StatusCode IOVSvc::dropObjectFromDB ( const CLID & clid, const std::string & key, const std::string & storeName )

overridevirtual

Drop the associated object from the db and trigger reload.

Definition at line 389 of file IOVSvc.cxx.

                                                     {
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
 
  IIOVSvcTool *ist = getTool( clid, key );
  if (ist == nullptr) {
    ATH_MSG_ERROR( "dropObjectFromDB: no IOVSvcTool associated with store "
                   << storeName << " and failed to create one."  );
    return StatusCode::FAILURE;
  }
 
  DataProxy* proxy = p_detStore->proxy(clid, key);
  if (proxy == nullptr) {
    ATH_MSG_DEBUG("Proxy for (clid: " << clid << " key: " << key << ") in store " << storeName
                  << " does not exist. Cannot drop associated object.");
    return StatusCode::SUCCESS;
  }
 
  // Set IOV in the past to trigger reload on next range check
  IOVRange iovr(IOVTime(0, 0), IOVTime(0, 0));
  ATH_CHECK( ist->setRange(clid, key, iovr) );
 
  IIOVDbSvc *iovDB = dynamic_cast<IIOVDbSvc*>(proxy->provider());
  if (iovDB != nullptr) {
    ATH_MSG_DEBUG("Dropping " << key << "via IOVDBSvc");
    ATH_CHECK( iovDB->dropObject(key, /*resetCache=*/true) );
  } else {
    ATH_MSG_ERROR("dropObjectFromDB: Provider for " << key << " is not an IIOVDbSvc.");
    return StatusCode::FAILURE;
  }
 
  return StatusCode::SUCCESS;
}

finalize()

StatusCode IOVSvc::finalize ( )

overridevirtual

Definition at line 118 of file IOVSvc.cxx.

{
  ATH_MSG_DEBUG( "Service finalised successfully" );
  return StatusCode::SUCCESS;
}

fullProxyName() [1/2]

std::string IOVSvc::fullProxyName ( const CLID & clid, const std::string & key ) const

private

Definition at line 776 of file IOVSvc.cxx.

                                                                    {
 
  std::string fullname, tname;
  if (p_CLIDSvc->getTypeNameOfID( clid, tname ).isFailure()) {
    fullname = "[";
    fullname += std::to_string(clid);
    fullname += '/';
    fullname += key;
    fullname += ']';
  } else {
    fullname = "[";
    fullname += tname;
    fullname += ':';
    fullname += std::to_string(clid);
    fullname += '/';
    fullname += key;
    fullname += ']';
  }
 
  return fullname;
}

fullProxyName() [2/2]

std::string IOVSvc::fullProxyName ( const SG::DataProxy * proxy ) const

private

Definition at line 767 of file IOVSvc.cxx.

                                                 {
 
  return fullProxyName(dp->clID(), dp->name());
 
}

getRange()

StatusCode IOVSvc::getRange ( const CLID & clid, const std::string & key, IOVRange & io ) const

overridevirtual

Definition at line 428 of file IOVSvc.cxx.

                                      {
 
 
  IIOVSvcTool *ist = getTool( clid, key );
  if (ist == 0) {
    ATH_MSG_ERROR( "getRange: proxy for " << fullProxyName(clid,key)
                   << " not registered"  );
    return StatusCode::FAILURE;
  } else {
    return ist->getRange( clid, key, iov );
  }
 
}

getRangeFromDB() [1/2]

StatusCode IOVSvc::getRangeFromDB ( const CLID & clid, const std::string & key, const IOVTime & time, IOVRange & range, std::string & tag, std::unique_ptr< IOpaqueAddress > & ioa ) const

overridevirtual

Get IOVRange from db for a particular event.

Definition at line 476 of file IOVSvc.cxx.

                                                                 {
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
 
  IIOVSvcTool *ist = getTool( clid, key );
  if (ist == 0) {
    ATH_MSG_ERROR( "getRangeFromDB: proxy for "
                   << fullProxyName(clid, key) << " not registered"  );
    return StatusCode::FAILURE;
  } else {
    return ist->getRangeFromDB( clid, key, time, range, tag, ioa );
  }
 
}

getRangeFromDB() [2/2]

StatusCode IOVSvc::getRangeFromDB ( const CLID & clid, const std::string & key, IOVRange & range, std::string & tag, std::unique_ptr< IOpaqueAddress > & ioa, const EventIDBase & now ) const

overridevirtual

Get IOVRange from db for current event.

Definition at line 446 of file IOVSvc.cxx.

                                                     {
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
 
  IIOVSvcTool *ist = getTool( clid, key );
  if (ist == 0) {
    ATH_MSG_ERROR( "getRangeFromDB: proxy for " 
                   << fullProxyName(clid,key) << " not registered"  );
    return StatusCode::FAILURE;
  } else {
    
    uint32_t event = now.lumi_block();
    uint32_t run   = now.run_number();
    IOVTime curTime;
    curTime.setRunEvent(run,event);
    // get ns timestamp from event
    curTime.setTimestamp(1000000000L*static_cast<uint64_t>(now.time_stamp()) + now.time_stamp_ns_offset());
 
 
    return ist->getRangeFromDB( clid, key, range, tag, ioa, curTime );
  }
 
}

getStoreNames()

std::vector< std::string > IOVSvc::getStoreNames ( ) const

overridevirtual

Definition at line 801 of file IOVSvc.cxx.

                            {
 
  std::vector<std::string> stores;
 
  toolMap::const_iterator itr = m_toolMap.begin();
  for( ; itr!=m_toolMap.end(); ++itr) {
    stores.push_back( itr->first );
  }
 
  return stores;
 
}

getTool() [1/5]

IIOVSvcTool * IOVSvc::getTool ( const CallBackID & c1 ) const

private

Definition at line 732 of file IOVSvc.cxx.

                                            {
 
  IIOVSvcTool *ist(0);
  toolMap::const_iterator itr = m_toolMap.begin();
  for (; itr != m_toolMap.end(); ++itr) {
    if (itr->second->holdsCallback( c1 )) {
      ist = itr->second;
      return ist;
    }
  }
 
  return ist;
 
}

getTool() [2/5]

IIOVSvcTool * IOVSvc::getTool ( const CLID & clid, const std::string & key ) const

private

Definition at line 714 of file IOVSvc.cxx.

                                                              {
 
  IIOVSvcTool *ist(0);
  toolMap::const_iterator itr = m_toolMap.begin();
  for (; itr != m_toolMap.end(); ++itr) {
    if (itr->second->holdsProxy( clid, key )) {
      ist = itr->second;
      return ist;
    }
  }
 
  return ist;
 
}

getTool() [3/5]

IIOVSvcTool * IOVSvc::getTool ( const IAlgTool * ia ) const

private

Definition at line 749 of file IOVSvc.cxx.

                                          {
 
  IIOVSvcTool *ist(0);
  toolMap::const_iterator itr = m_toolMap.begin();
  for (; itr != m_toolMap.end(); ++itr) {
    if (itr->second->holdsAlgTool( ia )) {
      ist = itr->second;
      return ist;
    }
  }
 
  return ist;
 
}

getTool() [4/5]

IIOVSvcTool * IOVSvc::getTool ( const std::string & storeName, bool createIF = true )

private

Definition at line 668 of file IOVSvc.cxx.

                                                           {
 
  std::string store(storeName);
  if (storeName == "default") {
    store = defaultStore;
  }
 
  toolMap::const_iterator itr = m_toolMap.find( store );
  IIOVSvcTool *ist(0);
  if ( itr == m_toolMap.end() ) {
    ATH_MSG_INFO( "No IOVSvcTool associated with store \"" << store
                  << "\""  );
 
    if (createIF) {
      createIOVTool(store, ist).ignore();
    }
 
  } else {
    ist = itr->second;
  }
 
  return ist;
}

getTool() [5/5]

IIOVSvcTool * IOVSvc::getTool ( SG::DataProxy * proxy ) const

private

Definition at line 695 of file IOVSvc.cxx.

                                        {
 
 
  IIOVSvcTool *ist(0);
  toolMap::const_iterator itr = m_toolMap.begin();
  for (; itr != m_toolMap.end(); ++itr) {
    if (itr->second->holdsProxy( proxy )) {
      ist = itr->second;
      return ist;
    }
  }
 
  return ist;
 
}

getTriggeredTools()

StatusCode IOVSvc::getTriggeredTools ( const std::string & key, std::set< std::string > & tools, const std::string & storeName )

overridevirtual

return list of tools (or functions) that have been triggered by key will return FAILURE if no tools found, or no key found

Definition at line 584 of file IOVSvc.cxx.

                                                      {
 
  IIOVSvcTool *ist = getTool( storeName, false );
  if (ist == 0) {
    ATH_MSG_ERROR( "getTriggeredTools: no store \"" << storeName
                   << "\" associated with any IOVSvcTool" );
    return StatusCode::FAILURE;
  } else {
    return ist->getTriggeredTools(key, tools);
  }
 
}

ignoreProxy()

void IOVSvc::ignoreProxy ( const CLID & clid, const std::string & key, const std::string & storeName )

overridevirtual

ignore proxy

Definition at line 247 of file IOVSvc.cxx.

                                                  {
 
 
  IIOVSvcTool *ist = getTool( storeName );
  if (ist == 0) {
    ATH_MSG_ERROR( "ignoreProxy: no IOVSvcTool found for store " 
                   << storeName << " and failed to create one" );
    return;
  }
 
  return ist->ignoreProxy( clid, key );
}

initialize()

StatusCode IOVSvc::initialize ( )

overridevirtual

Definition at line 93 of file IOVSvc.cxx.

                              {
 
  msg().setLevel( m_outputLevel.value() );
  ATH_MSG_DEBUG( "Initializing IOVSvc" );
 
  if (!p_sgs.isValid()) {
    ATH_MSG_ERROR("could not get the Event Store");
    return StatusCode::FAILURE;
  }
 
  if (!p_detStore.isValid()) {
    ATH_MSG_ERROR("could not get the Detector Store");
    return StatusCode::FAILURE;
  }
 
  if (!p_condSvc.isValid()) {
    ATH_MSG_ERROR("could not get the ConditionSvc");
    return StatusCode::FAILURE;
  }
 
  return StatusCode::SUCCESS;
}

preLoadDataTAD()

StatusCode IOVSvc::preLoadDataTAD ( const SG::TransientAddress * tad, const std::string & storeName )

overridevirtual

supply a list of TADs whose data will be preloaded

add to a set of TADs that who's data will be preLoaded

Definition at line 311 of file IOVSvc.cxx.

                                                     {
 
  IIOVSvcTool *ist = getTool( storeName );
  if (ist == 0) {
    ATH_MSG_ERROR( "preLoadDataTAD: no IOVSvcTool associated with store \""
                   << storeName << "\" and failed to create one."  );
    return StatusCode::FAILURE;
  } else {
    return ist->preLoadDataTAD( tad );
  }
 
}

preLoadTAD()

StatusCode IOVSvc::preLoadTAD ( const SG::TransientAddress * tad, const std::string & storeName )

overridevirtual

supply a list of TADs whose proxies will be preloaded

add to a set of TADs that will be registered at start of first event

Definition at line 290 of file IOVSvc.cxx.

                                                 {
 
 
  IIOVSvcTool *ist = getTool( storeName );
  if (ist == 0) {
    ATH_MSG_ERROR( "preLoadTAD: no IOVSvcTool associated with store \""
                   << storeName << "\" and failed to create one."  );
    return StatusCode::FAILURE;
  } else {
    return ist->preLoadTAD( tad );
  }
 
}

regFcn() [1/3]

StatusCode IOVSvc::regFcn ( const CallBackID & c1, const CallBackID & c2, const IOVSvcCallBackFcn & fcn2, bool trigger )

overridevirtual

Definition at line 533 of file IOVSvc.cxx.

                             {
 
 
  if (c1 == c2) {
    ATH_MSG_ERROR( "Cannot register 2nd callback function and assocaited"
                   << " object with itself"  );
    return StatusCode::FAILURE;
  }
 
 
  IIOVSvcTool *ist = getTool( c1 );
  if (ist == 0) {
    ATH_MSG_ERROR( "CallBack function \"" << c2.name()
                   << "\" cannot be registered since function \"" << c1.name()
                   << "\" has not been registered first"  );
    return StatusCode::FAILURE;
  } else {
    return ist->regFcn(c1, c2, fcn2, trigger);
  }
 
}

regFcn() [2/3]

StatusCode IOVSvc::regFcn ( const std::string & toolName, const CallBackID & c2, const IOVSvcCallBackFcn & fcn2, bool trigger )

overridevirtual

Definition at line 560 of file IOVSvc.cxx.

                             {
 
  IAlgTool *ia;
  if ( p_toolSvc->retrieveTool(toolName, ia, 0, false).isFailure() ) {
    ATH_MSG_ERROR( "AlgTool " << toolName << " has not yet been created"
                   << " and thus cannot be registered" );
    return StatusCode::FAILURE;
  }
 
  IIOVSvcTool *ist = getTool( ia );
  if (ist == 0) {
    ATH_MSG_ERROR( "No callback registered with AlgTool " << toolName );
    return StatusCode::FAILURE;
  } else {
    return ist->regFcn(ia, c2, fcn2, trigger);
  }
 
}

regFcn() [3/3]

StatusCode IOVSvc::regFcn ( SG::DataProxy * dp, const CallBackID & c, const IOVSvcCallBackFcn & fcn, bool trigger = false )

overridevirtual

register callback functions

Definition at line 514 of file IOVSvc.cxx.

                             {
 
  IIOVSvcTool *ist = getTool( dp );
  if (ist == 0) {
    ATH_MSG_ERROR( "regFcn: no IOVSvcTool found containing DataProxy "
                   << fullProxyName( dp )
                   << "-> Need to bind DataHandle first"  );
    return StatusCode::FAILURE;
  } else {
    return ist->regFcn( dp, c, fcn, trigger );
  }
 
}

regProxy() [1/2]

StatusCode IOVSvc::regProxy ( const CLID & clid, const std::string & key, const std::string & storeName )

overridevirtual

Another way to subscribe.

Register a DataProxy with the service.

Definition at line 167 of file IOVSvc.cxx.

                                               {
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
  IIOVSvcTool *ist = getTool( storeName );
  if (ist == 0) {
    ATH_MSG_ERROR( "regProxy: no IOVSvcTool associated with store \"" 
                   << storeName << "\" and failed to create one."  );
    return (StatusCode::FAILURE);
  }
 
  IIOVSvcTool *ist2 = getTool( clid, key );
  if (ist2 != 0) {
    if (ist2 != ist) {
      ATH_MSG_ERROR( "regProxy: when registering proxy for "
                     << fullProxyName(clid,key)
                     << " with store " << storeName
                     << ", it is already registered with store \"" 
                     << ist2->getStoreName() << "\""  );
      return StatusCode::FAILURE;
    } else {
      ATH_MSG_DEBUG( "regProxy: proxy for " << fullProxyName(clid,key)
                     << " already registered with store \"" << storeName << "\""
                     );
      return StatusCode::SUCCESS;
    }
  }
 
  return ist->regProxy( clid, key );
 
}

regProxy() [2/2]

StatusCode IOVSvc::regProxy ( SG::DataProxy * proxy, const std::string & key, const std::string & storeName )

overridevirtual

Subscribe method for DataProxy. key StoreGate key.

Register a DataProxy with the service.

Definition at line 130 of file IOVSvc.cxx.

                                               {
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
  IIOVSvcTool *ist = getTool( storeName );
  if (ist == 0) {
    ATH_MSG_ERROR( "regProxy: no IOVSvcTool associated with store \"" 
                   << storeName << "\" and failed to create one"  );
    return (StatusCode::FAILURE);
  }
 
  IIOVSvcTool *ist2 = getTool( proxy );
  if (ist2 != 0) {
    if (ist2 != ist) {
      ATH_MSG_ERROR( "regProxy: when registering proxy for " 
                     << fullProxyName(proxy) << " with store \"" << storeName
                     << "\", it is already registered with store \"" 
                     << ist2->getStoreName() << "\""  );
      return StatusCode::FAILURE;
    } else {
      ATH_MSG_DEBUG( "regProxy: proxy for " << fullProxyName(proxy)
                     << " already registered with store \"" << storeName << "\""
                     );
      return StatusCode::SUCCESS;
    }
  }
 
  return ist->regProxy( proxy, key );
 
}

reinitialize()

StatusCode IOVSvc::reinitialize ( )

overridevirtual

Definition at line 603 of file IOVSvc.cxx.

{
  // Set flag to reset all proxies 
  StatusCode sc;
  toolMap::iterator itr = m_toolMap.begin();
  for ( ; itr!=m_toolMap.end(); ++itr) {
    sc &= itr->second->reinitialize();
  }
  return sc;
 
}

replaceProxy()

StatusCode IOVSvc::replaceProxy ( SG::DataProxy * pOld, SG::DataProxy * pNew, const std::string & storeName )

overridevirtual

replace a registered DataProxy with a new version

Replace a registered DataProxy with a new version.

Definition at line 268 of file IOVSvc.cxx.

                                                   {
 
  StatusCode sc(StatusCode::FAILURE);
  IIOVSvcTool *ist = getTool( storeName );
  if (0 != ist) {
    sc = ist->replaceProxy(pOld, pNew);
  } else {
    ATH_MSG_ERROR( "regProxy: no IOVSvcTool associated with store \"" 
                   << storeName << "\" and failed to create one."  );
  } 
  return sc;
}

resetAllProxies()

void IOVSvc::resetAllProxies ( )

overridevirtual

Definition at line 817 of file IOVSvc.cxx.

                        {
 
  toolMap::iterator itr = m_toolMap.begin();
  for (; itr!= m_toolMap.end(); ++itr) {
    IIOVSvcTool* ist = itr->second;
    ATH_MSG_DEBUG( "resetting all proxies for store \""
                   << ist->getStoreName() << "\""  );
    ist->resetAllProxies();
  }
 
}

setRange() [1/2]

StatusCode IOVSvc::setRange ( const CLID & clid, const std::string & key, IOVRange & iovr )

overridevirtual

Update Range from dB.

Definition at line 328 of file IOVSvc.cxx.

                                 {
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
 
  IIOVSvcTool *ist = getTool( clid, key );
  if (ist == 0) {
 
    // FIXME - this should be eliminated once the IOVDbSvc is set up to 
    // use store names. There should be no default store for setRange
 
    ATH_MSG_WARNING( "setRange(CLID,key,range) for unregistered proxies "
                     << "is deprecated - you need to specify a store! "
                     << "This will be an ERROR soon!" );
 
    return setRange(clid,key,iovr, defaultStore );
 
  } else {
    return ist->setRange( clid, key, iovr );
  }
 
}

setRange() [2/2]

StatusCode IOVSvc::setRange ( const CLID & clid, const std::string & key, IOVRange & io, const std::string & storeName )

overridevirtual

Definition at line 354 of file IOVSvc.cxx.

                                                             {
 
  std::lock_guard<std::recursive_mutex> lock(m_lock);
 
  IIOVSvcTool *ist = getTool( storeName );
  if (ist == 0) {
    ATH_MSG_ERROR( "setRange: no IOVSvcTool associated with store \""
                   << storeName << "\" and failed to create one."  );
    return StatusCode::FAILURE;
  }
 
  IIOVSvcTool *ist2 = getTool( clid, key );
  if (ist2 == 0) {
    ATH_MSG_INFO( "setRange: proxy for " << fullProxyName(clid,key)
                  << " not registered with store \"" << storeName << "\". Doing it now"
                  );
    if (ist->regProxy(clid, key).isFailure()) {
      return StatusCode::FAILURE;
    }
  } else if (ist2 != ist) {
    ATH_MSG_INFO( "setRange: when registering proxy (clid: " 
                  << clid << " key: " << key << ") with store \"" << storeName
                  << "\" --> already registered with store \"" << ist2->getStoreName()
                  << "\""  );
    return StatusCode::FAILURE;
  }
 
  return ist->setRange( clid, key, iovr );
 
}

setRangeInDB()

StatusCode IOVSvc::setRangeInDB ( const CLID & clid, const std::string & key, const IOVRange & range, const std::string & tag )

overridevirtual

Set a particular IOVRange in db (and memory)

Definition at line 497 of file IOVSvc.cxx.

                                                                  {
  
  IIOVSvcTool *ist = getTool( clid, key );
  if (ist == 0) {
    ATH_MSG_ERROR( "setRangeInDB: proxy for "
                   << fullProxyName(clid,key) << " not registered"  );
    return StatusCode::FAILURE;
  } else {
    return ist->setRangeInDB( clid, key, range, tag );
  }
 
}

Member Data Documentation

m_forceReset

BooleanProperty IOVSvc::m_forceReset

private

Definition at line 175 of file IOVSvc.h.

m_lock

std::recursive_mutex IOVSvc::m_lock

mutableprivate

Definition at line 185 of file IOVSvc.h.

m_partialPreLoadData

BooleanProperty IOVSvc::m_partialPreLoadData

private

Definition at line 174 of file IOVSvc.h.

m_preLoadData

BooleanProperty IOVSvc::m_preLoadData

private

Definition at line 174 of file IOVSvc.h.

m_preLoadExtensibleFolders

BooleanProperty IOVSvc::m_preLoadExtensibleFolders

private

Definition at line 174 of file IOVSvc.h.

m_preLoadRanges

BooleanProperty IOVSvc::m_preLoadRanges

private

Definition at line 174 of file IOVSvc.h.

m_sortKeys

BooleanProperty IOVSvc::m_sortKeys

private

Definition at line 175 of file IOVSvc.h.

m_toolMap

toolMap IOVSvc::m_toolMap

private

Definition at line 171 of file IOVSvc.h.

m_updateInterval

std::string IOVSvc::m_updateInterval

private

Definition at line 176 of file IOVSvc.h.

p_CLIDSvc

ServiceHandle<IClassIDSvc> IOVSvc::p_CLIDSvc

private

Definition at line 179 of file IOVSvc.h.

p_condSvc

ServiceHandle<ICondSvc> IOVSvc::p_condSvc

private

Definition at line 181 of file IOVSvc.h.

p_detStore

ServiceHandle<StoreGateSvc> IOVSvc::p_detStore

private

Definition at line 180 of file IOVSvc.h.

p_sgs

ServiceHandle<StoreGateSvc> IOVSvc::p_sgs

private

Definition at line 180 of file IOVSvc.h.

p_toolSvc

ServiceHandle<IToolSvc> IOVSvc::p_toolSvc

private

Definition at line 178 of file IOVSvc.h.

---

The documentation for this class was generated from the following files:

• IOVSvc.h
• IOVSvc.cxx