DataOnDemandSvc Class Reference

The DataOnDemandSvc listens to incidents typically triggered by the data service of the configurable name "IncidentName". More...

#include <src/IncidentSvc/DataOnDemandSvc.h>

Inheritance diagram for DataOnDemandSvc:

Collaboration diagram for DataOnDemandSvc:

Classes
struct	Leaf
struct	Node
	Helper class of the DataOnDemandSvc. More...
struct	Protection
	Helper class of the DataOnDemandSvc. More...

Public Types
typedef std::vector< std::string >	Setup
typedef TClass *	ClassH
typedef GaudiUtils::HashMap< Gaudi::StringKey, Node >	NodeMap
typedef GaudiUtils::HashMap< Gaudi::StringKey, Leaf >	AlgMap
Public Types inherited from extends< BASE, Interfaces >
using	base_class = extends
	Typedef to this class. More...
using	extend_interfaces_base = extend_interfaces< Interfaces...>
	Typedef to the base of this class. More...
using	base_class = extends
	Typedef to this class. More...
using	extend_interfaces_base = extend_interfaces< Interfaces...>
	Typedef to the base of this class. More...
Public Types inherited from extend_interfaces< Interfaces...>
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...

Public Member Functions
StatusCode	initialize () override
	Inherited Service overrides: Service initialization. More...
StatusCode	finalize () override
	Inherited Service overrides: Service finalization. More...
StatusCode	reinitialize () override
	Inherited Service overrides: Service reinitialization. More...
void	handle (const Incident &incident) override
	IIncidentListener interfaces overrides: incident handling. More...
	DataOnDemandSvc (const std::string &name, ISvcLocator *svc)
	Standard initializing service constructor. More...
	~DataOnDemandSvc () override=default
	Standard destructor. More...
void	update_1 (Property &p)
void	update_2 (Property &p)
void	update_3 (Property &p)
void	update_dump (Property &)
	update handler for 'Dump' property More...
Public Member Functions inherited from extends< BASE, Interfaces >
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...
StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...
std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...
	~extends () override=default
	Virtual destructor. More...
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...
StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...
std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...
	~extends () override=default
	Virtual destructor. More...
Public Member Functions inherited from extend_interfaces< Interfaces...>
	~extend_interfaces () override=default
	Virtual destructor. More...
	~extend_interfaces () override=default
	Virtual destructor. More...

Protected Member Functions
StatusCode	configureHandler (Leaf &leaf)
	Configure handler for leaf. More...
StatusCode	execHandler (const std::string &tag, Leaf &leaf)
	Execute leaf handler (algorithm) More...
StatusCode	execHandler (const std::string &tag, Node &node)
	Execute node handler (simple object creation using seal reflection) More...
StatusCode	setupNodeHandlers ()
	Initialize node handlers. More...
StatusCode	setupAlgHandlers ()
	Initialize leaf handlers. More...
StatusCode	setup ()
	Setup routine (called by (re-) initialize. More...
void	i_setNodeHandler (const std::string &name, const std::string &type)
	Internal method to initialize a node handler. More...
StatusCode	i_setAlgHandler (const std::string &name, const Gaudi::Utils::TypeNameString &alg)
	Internal method to initialize an algorithm handler. More...
StatusCode	update ()
	update the handlers More...
MsgStream &	stream () const
	get the message stream More...
void	dump (const MSG::Level level, const bool mode=true) const
	dump the content of DataOnDemand service More...

Private Types
typedef std::map< std::string, std::string >	Map

Private Attributes
SmartIF< IIncidentSvc >	m_incSvc = nullptr
	Incident service. More...
SmartIF< IAlgManager >	m_algMgr = nullptr
	Algorithm manager. More...
SmartIF< IDataProviderSvc >	m_dataSvc = nullptr
	Data provider reference. More...
SmartIF< IToolSvc >	m_toolSvc
	Data provider reference. More...
std::string	m_trapType = "DataFault"
	Trap name. More...
std::string	m_dataSvcName = "EventDataSvc"
	Data service name. More...
bool	m_partialPath = true
	Flag to allow for the creation of partial leaves. More...
bool	m_dump = false
	flag to force the printout More...
bool	m_init = false
	flag to warm up the configuration More...
bool	m_allowInitFailure = false
	flag to allow DataOnDemand initialization to succeed even if the (pre)initialization of the algorithms fails (m_init). More...
Setup	m_algMapping
	Mapping to algorithms. More...
Setup	m_nodeMapping
	Mapping to nodes. More...
AlgMap	m_algs
	Map of algorithms to handle incidents. More...
NodeMap	m_nodes
	Map of "empty" objects to be placed as intermediate nodes. More...
Map	m_algMap
	the major configuration property { 'data' : 'algorithm' } More...
Map	m_nodeMap
	the major configuration property { 'data' : 'type' } More...
bool	m_updateRequired = true
std::string	m_prefix = "/Event/"
std::unique_ptr< MsgStream >	m_log
ChronoEntity	m_total
ulonglong	m_statAlg = 0
ulonglong	m_statNode = 0
ulonglong	m_stat = 0
ChronoEntity	m_timer_nodes
ChronoEntity	m_timer_algs
ChronoEntity	m_timer_all
bool	m_locked_nodes = false
bool	m_locked_algs = false
bool	m_locked_all = false
std::vector< std::string >	m_nodeMapTools
std::vector< IDODNodeMapper * >	m_nodeMappers
std::vector< std::string >	m_algMapTools
std::vector< IDODAlgMapper * >	m_algMappers

Detailed Description

The DataOnDemandSvc listens to incidents typically triggered by the data service of the configurable name "IncidentName".

In the job options handlers can be declared, which allow to configure this service. Such handlers are either:

• Node handlers, if objects other than the default object type have to be instantiated. DataOnDemandSvc.Nodes = { "DATA='/Event/Rec' TYPE='DataObject'", "DATA='/Event/Rec/Muon' TYPE='DataObject'" };
• Leaf handlers (Algorithms), which get instantiated and executed on demand. DataOnDemandSvc.Algorithms = { "DATA='/Event/Rec/Muon/Digits' TYPE='MuonDigitAlg/MyMuonDigits'" }; If the algorithm name is omitted the class name will be the instance name.

The handlers only get called if the exact path matches. In the event already the partial path to any handler is missing a leaf handler may be triggered, which includes the partial paths ( DataOnDemandSvc.UsePreceedingPath = true )

2006-10-15: New options (using map-like semantics:)

 DataOnDemandSvc.AlgMap  +=
{ "Phys/StdLoosePions/Particles" : "PreLoadParticles/StdLoosePions" ,
  "Phys/StdLoosePions/Vertioces" : "PreLoadParticles/StdLoosePions" } ;

 DataOnDemandSvc.NodeMap +=
{ "Phys" : "DataObject" ,
  "MC"   : "DataObject" } ;

New treatment of preceding paths. for each registered leaf or node the all parent nodes are added into the node-map with default directory type 'DataObject'

The major properties are equipped with handlers (more or less mandatory for interactive work in python)

From now the default prefix ( "/Event/" ) could be omitted from any data-item. It will be added automatically.

Author

M.Frank

Version

1.0

Definition at line 90 of file DataOnDemandSvc.h.

Member Typedef Documentation

typedef GaudiUtils::HashMap<Gaudi::StringKey, Leaf> DataOnDemandSvc::AlgMap

Definition at line 163 of file DataOnDemandSvc.h.

typedef TClass* DataOnDemandSvc::ClassH

Definition at line 96 of file DataOnDemandSvc.h.

typedef std::map<std::string,std::string> DataOnDemandSvc::Map

private

Definition at line 274 of file DataOnDemandSvc.h.

typedef GaudiUtils::HashMap<Gaudi::StringKey, Node> DataOnDemandSvc::NodeMap

Definition at line 162 of file DataOnDemandSvc.h.

typedef std::vector<std::string> DataOnDemandSvc::Setup

Definition at line 95 of file DataOnDemandSvc.h.

Constructor & Destructor Documentation

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

Standard initializing service constructor.

Parameters

name	[IN] Service instance name
svc	[IN] Pointer to service locator

Returns

Reference to DataOnDemandSvc object.

Definition at line 41 of file DataOnDemandSvc.cpp.

  : base_class( name, svc )
{
  // ==========================================================================
  declareProperty
    ( "IncidentName"       ,
      m_trapType           ,
      "The type of handled Incident" ) ;
  //
  declareProperty ( "DataSvc"            , m_dataSvcName ) ;
  //
  declareProperty ( "UsePreceedingPath"  , m_partialPath ) ;
  declareProperty
    ( "Dump"        ,
      m_dump        ,
      "Dump the configuration and stastics" )  ->
    declareUpdateHandler ( &DataOnDemandSvc::update_dump , this ) ;
  //
  declareProperty
    ( "PreInitialize" ,
      m_init          ,
      "Flag to (pre)initialize all algorithms" ) ;
  declareProperty
    ( "AllowPreInitializeFailure" ,
      m_allowInitFailure          ,
      "Allow (pre)initialization of algorithms to fail without stopping the application" ) ;
  //
  declareProperty ( "Algorithms"         , m_algMapping  )  ->
    declareUpdateHandler ( &DataOnDemandSvc::update_2 , this ) ;
  declareProperty ( "Nodes"              , m_nodeMapping ) ->
    declareUpdateHandler ( &DataOnDemandSvc::update_3 , this ) ;
  //
  declareProperty ( "AlgMap"  , m_algMap  ) ->
    declareUpdateHandler ( &DataOnDemandSvc::update_1 , this ) ;
  declareProperty ( "NodeMap" , m_nodeMap ) ->
    declareUpdateHandler ( &DataOnDemandSvc::update_1 , this ) ;

  declareProperty ( "Prefix"             , m_prefix      ) ;

  declareProperty("NodeMappingTools", m_nodeMapTools,
                  "List of tools of type IDODNodeMapper");
  declareProperty("AlgMappingTools", m_algMapTools,
                  "List of tools of type IDODAlgMapper");
  // ==========================================================================
}

DataOnDemandSvc::~DataOnDemandSvc ( )

overridedefault

Standard destructor.

Member Function Documentation

StatusCode DataOnDemandSvc::configureHandler ( Leaf &  leaf )

protected

Configure handler for leaf.

Parameters

leaf	[IN] Reference to leaf handler

Returns

StatusCode indicating success or failure

Definition at line 528 of file DataOnDemandSvc.cpp.

{
  if ( l.algorithm ) { return StatusCode::SUCCESS ; }
  if ( ! m_algMgr  ) { return StatusCode::FAILURE ; }
  l.algorithm = m_algMgr->algorithm(l.name, false);
  if ( l.algorithm ) { return StatusCode::SUCCESS ; }
  // create it!
  StatusCode sc = m_algMgr->createAlgorithm ( l.type , l.name , l.algorithm , true ) ;
  if ( sc.isFailure() )
  {
    stream()
      << MSG::ERROR
      << "Failed to create algorithm "
      << l.type << "('" << l.name<< "')" << endmsg;
    l.algorithm = nullptr ;
    return sc ;                                                    // RETURN
  }
  if ( l.algorithm->isInitialized() ) { return StatusCode:: SUCCESS ;}
  // initialize it!
  sc = l.algorithm -> sysInitialize () ;
  if ( sc.isFailure() )
  {
    stream()
      << MSG::ERROR
      << "Failed to initialize algorithm "
      << l.type << "('" << l.name<< "')" << endmsg;
    l.algorithm = nullptr ;
    return sc ;                                                    // RETURN
  }
  if ( Gaudi::StateMachine::RUNNING == l.algorithm->FSMState() )
  { return StatusCode::SUCCESS ; }
  // run it!
  sc = l.algorithm->sysStart() ;
  if ( sc.isFailure() )
  {
    stream()
      << MSG::ERROR
      << "Failed to 'run'      algorithm "
      << l.type << "('" << l.name<< "')" << endmsg;
    l.algorithm = nullptr ;
    return sc ;                                                    // RETURN
  }
  return StatusCode::SUCCESS  ;
}

void DataOnDemandSvc::dump ( const MSG::Level  level, const bool  mode = true  ) const

protected

dump the content of DataOnDemand service

Parameters

level	the printout level
mode	the printout mode

Definition at line 805 of file DataOnDemandSvc.cpp.

{
  if ( m_algs.empty()  &&  m_nodes.empty() ) { return ; }

  typedef std::pair<std::string,std::string> Pair ;
  std::map<std::string,Pair>  _m ;
  for ( auto& alg : m_algs )
  {
    auto check = _m.find(alg.first) ;
    if ( _m.end() != check )
    {
      stream()
        << MSG::WARNING
        << " The data item is activated for '"
        << check->first << "' as '" << check->second.first << "'" << endmsg ;
    }
    const Leaf& l = alg.second ;
    std::string nam = ( l.name == l.type ? l.type  : (l.type+"/"+l.name) ) ;
    //
    if ( !mode && 0 == l.num ) { continue ; }
    //
    std::string val ;
    if ( mode ) { val = ( ! l.algorithm ) ? "F" : "T" ; }
    else { val = std::to_string( l.num ) ; }
    //
    _m[ no_prefix ( alg.first , m_prefix ) ] = { nam , val } ;
  }
  // nodes:
  for ( const auto& node : m_nodes )
  {
    auto check = _m.find(node.first) ;
    if ( _m.end() != check )
    {
      stream()
        << MSG::WARNING
        << " The data item is already activated for '"
        << check->first << "' as '" << check->second.first << "'" << endmsg ;
    }
    const Node& n = node.second ;
    std::string nam = "'" + n.name + "'"  ;
    //
    std::string val ;

    if ( !mode && 0 == n.num ) { continue ; }

    if ( mode ) { val = ( 0 == n.clazz ) ? "F" : "T" ; }
    else { val = std::to_string( n.num ) ; }
    //
    _m[ no_prefix ( node.first , m_prefix ) ] = { nam , val } ;
  }
  //
  if ( _m.empty() ) { return ; }

  // find the correct formats
  size_t n1 = 0 ;
  size_t n2 = 0 ;
  size_t n3 = 0 ;
  for  ( const auto& i : _m )
  {
    n1 = std::max ( n1 , i.first.size()         ) ;
    n2 = std::max ( n2 , i.second.first.size()  ) ;
    n3 = std::max ( n3 , i.second.second.size() ) ;
  }
  if ( 10 > n1 ) { n1 = 10 ; }
  if ( 10 > n2 ) { n2 = 10 ; }
  if ( 60 < n1 ) { n1 = 60 ; }
  if ( 60 < n2 ) { n2 = 60 ; }
  //

  const std::string _f = " | %%1$-%1%.%1%s | %%2$-%2%.%2%s | %%3$%3%.%3%s |" ;
  boost::format _ff ( _f ) ;
  _ff % n1 % n2 % n3 ;

  const std::string _format  = _ff.str() ;

  MsgStream& msg = stream() << level ;

  if ( mode ) { msg << "Data-On-Demand Actions enabled for:"       ; }
  else        { msg << "Data-On-Demand Actions has been used for:" ; }

  boost::format fmt1( _format)  ;
  fmt1 % "Address" % "Creator" % ( mode ? "S" : "#" ) ;
  //
  const std::string header = fmt1.str() ;
  std::string line = std::string( header.size() , '-' ) ;
  line[0] = ' ' ;

  msg << '\n' << line
      << '\n' << header
      << '\n' << line ;

  // make the actual printout:
  for ( const auto& item : _m )
  {
    boost::format fmt( _format)  ;
    msg << '\n' <<
      ( fmt % item.first % item.second.first % item.second.second ) ;
  }

  msg << '\n' << line << endmsg ;

}

StatusCode DataOnDemandSvc::execHandler ( const std::string &  tag, Leaf &  leaf  )

protected

Execute leaf handler (algorithm)

Parameters

tag	[IN] Path to requested leaf
leaf	[IN] Reference to leaf handler

Returns

StatusCode indicating success or failure

Definition at line 764 of file DataOnDemandSvc.cpp.

{
  Gaudi::Utils::LockedChrono timer ( m_timer_algs ,  m_locked_algs ) ;
  //
  if ( l.executing ) { return StatusCode::FAILURE ; }             // RETURN
  //
  if ( ! l.algorithm )
  {
    StatusCode sc = configureHandler ( l ) ;
    if ( sc.isFailure() )
    {
      stream()
        << MSG::ERROR
        << "Failed to configure handler for: "
        << l.name << "[" << l.type << "] " << tag << endmsg;
      return sc ;                                                 // RETURN
    }
  }
  //
  Chrono atimer ( m_total ) ;
  //
  Protection p(l.executing);
  StatusCode sc = l.algorithm->sysExecute();
  if ( sc.isFailure() )
  {
    stream() << MSG::ERROR
             << "Failed to execute the algorithm:"
             << l.algorithm->name() << " for location:" << tag << endmsg;
    return sc ;                                                       // RETURN
  }
  ++l.num ;
  //
  return StatusCode::SUCCESS ;
}

StatusCode DataOnDemandSvc::execHandler ( const std::string &  tag, Node &  node  )

protected

Execute node handler (simple object creation using seal reflection)

Parameters

tag	[IN] Path to requested leaf
node	[IN] Reference to node handler

Returns

StatusCode indicating success or failure

Definition at line 708 of file DataOnDemandSvc.cpp.

{

  Gaudi::Utils::LockedChrono timer ( m_timer_nodes ,  m_locked_nodes ) ;

  if ( n.executing ) { return StatusCode::FAILURE ; }            // RETURN

  Protection p(n.executing);

  std::unique_ptr<DataObject> object;

  if ( n.dataObject )  { object.reset( new DataObject() ) ; }
  else
  {
    // try to recover the handler
    if ( !n.clazz  ) { n.clazz = TClass::GetClass(n.name.c_str()) ; }
    if ( !n.clazz  )
    {
      stream()
        << MSG::ERROR
        << "Failed to get dictionary for class '"
        << n.name
        << "' for location:" << tag << endmsg;
      return StatusCode::FAILURE ;                               // RETURN
    }

    object.reset(  reinterpret_cast<DataObject*>(n.clazz->New()) );

    if ( !object )
    {
      stream()
        << MSG::ERROR
        << "Failed to create an object of type:"
        << n.clazz->GetName() << " for location:" << tag
        << endmsg;
      return StatusCode::FAILURE  ;                               // RETURN
    }
  }
  //
  StatusCode sc = m_dataSvc->registerObject(tag, object.release() );
  if ( sc.isFailure() )
  {
    stream()
      << MSG::ERROR << "Failed to register an object of type:"
      << n.name << " at location:" << tag
      << endmsg;
    return sc ;                                                  // RETURN
  }
  ++n.num ;
  //
  return StatusCode::SUCCESS ;
}

StatusCode DataOnDemandSvc::finalize ( )

override

Inherited Service overrides: Service finalization.

Definition at line 316 of file DataOnDemandSvc.cpp.

{
  //
  stream ()
    << MSG::INFO
    << "Handled \"" << m_trapType << "\" incidents: "
    << m_statAlg  << "/" << m_statNode << "/" << m_stat << "(Alg/Node/Total)."
    << endmsg ;
  if ( m_dump || MSG::DEBUG >= outputLevel() )
  {
    stream ()
      << MSG::INFO
      << m_total.outputUserTime
      ( "Algorithm timing: Mean(+-rms)/Min/Max:%3%(+-%4%)/%6%/%7%[ms] " , System::milliSec )
      << m_total.outputUserTime ( "Total:%2%[s]" , System::Sec ) << endmsg ;
    stream ()
      << MSG::INFO
      << m_timer_nodes.outputUserTime
      ( "Nodes     timing: Mean(+-rms)/Min/Max:%3%(+-%4%)/%6%/%7%[ms] " , System::milliSec )
      << m_timer_nodes.outputUserTime ( "Total:%2%[s]" , System::Sec ) << endmsg ;
    stream ()
      << MSG::INFO
      << m_timer_algs .outputUserTime
      ( "Algs      timing: Mean(+-rms)/Min/Max:%3%(+-%4%)/%6%/%7%[ms] " , System::milliSec )
      << m_timer_algs .outputUserTime ( "Total:%2%[s]" , System::Sec ) << endmsg ;
    stream ()
      << MSG::INFO
      << m_timer_all  .outputUserTime
      ( "All       timing: Mean(+-rms)/Min/Max:%3%(+-%4%)/%6%/%7%[ms] " , System::milliSec )
      << m_timer_all  .outputUserTime ( "Total:%2%[s]" , System::Sec ) << endmsg ;
  }
  // dump it!
  if      ( m_dump )                      { dump ( MSG::INFO  , false ) ; }
  else if ( MSG::DEBUG >= outputLevel() ) { dump ( MSG::DEBUG , false ) ; }
  //
  if ( m_incSvc )
  {
    m_incSvc->removeListener(this, m_trapType);
    m_incSvc.reset();
  }
  m_algMgr.reset();
  m_dataSvc.reset();
  if (m_toolSvc) { // we may not have retrieved the ToolSvc
    // Do not call releaseTool if the ToolSvc was already finalized.
    if (SmartIF<IStateful>(m_toolSvc)->FSMState() > Gaudi::StateMachine::CONFIGURED) {
      for(const auto& i : m_nodeMappers ) m_toolSvc->releaseTool(i).ignore();
      for(const auto& i : m_algMappers ) m_toolSvc->releaseTool(i).ignore();
    } else {
      warning() << "ToolSvc already finalized: cannot release tools. Check options." << endmsg;
    }
    m_nodeMappers.clear();
    m_algMappers.clear();
    m_toolSvc.reset();
  }
  return Service::finalize();
}

void DataOnDemandSvc::handle ( const Incident &  incident )

override

IIncidentListener interfaces overrides: incident handling.

Definition at line 636 of file DataOnDemandSvc.cpp.

{

  Gaudi::Utils::LockedChrono timer ( m_timer_all , m_locked_all ) ;

  ++m_stat ;
  // proper incident type?
  if ( incident.type() != m_trapType ) { return ; }             // RETURN
  const DataIncident* inc = dynamic_cast<const DataIncident*>(&incident);
  if ( ! inc                         ) { return ; }             // RETURN
  // update if needed!
  if ( m_updateRequired ) { update() ; }

  if ( MSG::VERBOSE >= outputLevel() )
  {
    verbose()
      << "Incident: [" << incident.type   () << "] "
      << " = "         << incident.source ()
      << " Location:"  << inc->tag()         << endmsg;
  }
  // ==========================================================================
  Gaudi::StringKey tag ( inc->tag() ) ;
  // ==========================================================================
  auto icl = m_nodes.find ( tag ) ;
  if ( icl != m_nodes.end() )
  {
    StatusCode sc = execHandler ( tag , icl->second ) ;
    if ( sc.isSuccess() ) { ++m_statNode ; }
    return ;                                                        // RETURN
  }
  // ==========================================================================
  auto ialg = m_algs.find ( tag ) ;
  if ( ialg != m_algs.end() )
  {
    StatusCode sc = execHandler ( tag , ialg->second ) ;
    if ( sc.isSuccess() ) { ++m_statAlg ; }
    return ;                                                        // RETURN
  }
  // ==========================================================================
  // Fall back on the tools
  if (m_toolSvc) {
    if (MSG::VERBOSE >= outputLevel())
      verbose() << "Try to find mapping with mapping tools" << endmsg;
    Finder finder(no_prefix(inc->tag(), m_prefix), m_nodeMappers, m_algMappers);
    //  - try the node mappers
    std::string node = finder.node();
    if (isGood(node)) {
      // if one is found update the internal node mapping and try again.
      if (MSG::VERBOSE >= outputLevel())
        verbose() << "Found Node handler: " << node << endmsg;
      i_setNodeHandler(inc->tag(), node);
      handle(incident);
      --m_stat; // avoid double counting because of recursion
      return;
    }
    //  - try alg mappings
    Gaudi::Utils::TypeNameString alg = finder.alg();
    if (isGood(alg)) {
      // we got an algorithm, update alg map and try to handle again
      if (MSG::VERBOSE >= outputLevel())
        verbose() << "Found Algorithm handler: " << alg << endmsg;
      i_setAlgHandler(inc->tag(), alg).ignore();
      handle(incident);
      --m_stat; // avoid double counting because of recursion
      return;
    }
  }
}

StatusCode DataOnDemandSvc::i_setAlgHandler ( const std::string &  name, const Gaudi::Utils::TypeNameString &  alg  )

protected

Internal method to initialize an algorithm handler.

Definition at line 217 of file DataOnDemandSvc.cpp.

                                                                                                     {
  Leaf leaf(alg.type(), alg.name());
  if (m_init)
  {
    StatusCode sc = configureHandler(leaf);
    if (sc.isFailure()) {
      if (m_allowInitFailure) {
        // re-store the content of the leaf object to try again to initialize
        // the algorithm later (on demand)
        leaf = Leaf(alg.type(), alg.name());
      }
      else
        return sc;
    }
  }
  m_algs[name] = leaf;
  return StatusCode::SUCCESS;
}

void DataOnDemandSvc::i_setNodeHandler ( const std::string &  name, const std::string &  type  )

protected

Internal method to initialize a node handler.

Definition at line 207 of file DataOnDemandSvc.cpp.

                                                                                  {
  ClassH cl = TClass::GetClass(type.c_str()) ;
  if (!cl) {
    warning()
        << "Failed to access dictionary class for "
        << name << " of type:" << type << endmsg;
  }
  m_nodes[name] = Node(cl, false, type);
}

StatusCode DataOnDemandSvc::initialize ( )

override

Inherited Service overrides: Service initialization.

Definition at line 298 of file DataOnDemandSvc.cpp.

{
  // initialize the Service Base class
  StatusCode sc = Service::initialize();
  if ( sc.isFailure() )  { return sc; }
  sc = setup();
  if ( sc.isFailure() )  { return sc; }
  //
  if      ( m_dump )                      { dump ( MSG::INFO  ) ; }
  else if ( MSG::DEBUG >= outputLevel() ) { dump ( MSG::DEBUG ) ; }
  //
  if ( m_init ) { return update () ; }
  //
  return StatusCode::SUCCESS ;
}

StatusCode DataOnDemandSvc::reinitialize ( )

override

Inherited Service overrides: Service reinitialization.

re-initialization of the service

Definition at line 375 of file DataOnDemandSvc.cpp.

{
  // reinitialize the Service Base class
  if ( m_incSvc )
  {
    m_incSvc -> removeListener ( this , m_trapType );
    m_incSvc.reset();
  }
  m_algMgr.reset();
  m_dataSvc.reset();
  for(const auto& i : m_nodeMappers ) m_toolSvc->releaseTool(i).ignore();
  m_nodeMappers.clear();
  for(const auto& i : m_algMappers ) m_toolSvc->releaseTool(i).ignore();
  m_algMappers.clear();
  m_toolSvc.reset();
  m_log.reset();
  //
  StatusCode sc = Service::reinitialize();
  if ( sc.isFailure() )  { return sc; }
  //
  sc = setup() ;
  if ( sc.isFailure() )  { return sc; }
  //
  if ( m_dump ) { dump ( MSG::INFO ) ; }
  else if ( MSG::DEBUG >= outputLevel() ) { dump ( MSG::DEBUG  ) ; }
  //
  return StatusCode::SUCCESS ;
}

StatusCode DataOnDemandSvc::setup ( )

protected

Setup routine (called by (re-) initialize.

Definition at line 406 of file DataOnDemandSvc.cpp.

{
  if ( !(m_algMgr = serviceLocator()) ) // assignment meant
  {
    error() << "Failed to retrieve the IAlgManager interface." << endmsg;
    return StatusCode::FAILURE;
  }

  if ( !(m_incSvc = serviceLocator()->service("IncidentSvc")) ) // assignment meant
  {
    error() << "Failed to retrieve Incident service." << endmsg;
    return StatusCode::FAILURE;
  }
  m_incSvc->addListener(this, m_trapType);

  if ( !(m_dataSvc = serviceLocator()->service(m_dataSvcName)) ) // assignment meant
  {
    error()
      << "Failed to retrieve the data provider interface of "
      << m_dataSvcName << endmsg;
    return StatusCode::FAILURE;
  }

  // No need to get the ToolSvc if we are not using tools
  if (!(m_nodeMapTools.empty() && m_algMapTools.empty())) {
    if ( !(m_toolSvc = serviceLocator()->service("ToolSvc")) ) // assignment meant
    {
      error() << "Failed to retrieve ToolSvc" << endmsg;
      return StatusCode::FAILURE;
    }

    // load the node mapping tools
    IDODNodeMapper *nodetool = nullptr;
    for(const auto& i : m_nodeMapTools) {
      const StatusCode sc = m_toolSvc->retrieveTool(i, nodetool);
      if (sc.isFailure()) return sc;
      m_nodeMappers.push_back(nodetool);
    }
    IDODAlgMapper *algtool = nullptr;
    for(const auto& i : m_algMapTools) {
      const StatusCode sc = m_toolSvc->retrieveTool(i, algtool);
      if (sc.isFailure()) return sc;
      m_algMappers.push_back(algtool);
    }
  }
  return update();
}

StatusCode DataOnDemandSvc::setupAlgHandlers ( )

protected

Initialize leaf handlers.

Definition at line 493 of file DataOnDemandSvc.cpp.

{
  std::string typ, tag;

  for (auto alg: m_algMapping)
  {
    using Parser = Gaudi::Utils::AttribStringParser;
    for (auto attrib: Parser(alg)) {
      switch( ::toupper(attrib.tag[0]) ) {
      case 'D':
        tag = std::move(attrib.value);
        break;
      case 'T':
        typ = std::move(attrib.value);
        break;
      }
    }
    Gaudi::Utils::TypeNameString item(typ);
    if ( m_algMap  .end () != m_algMap  .find ( tag ) ||
         m_nodeMap .end () != m_nodeMap .find ( tag ) )
    {
      stream()
        << MSG::WARNING
        << "The obsolete property 'Algorithms' redefines the action for '"
        + tag + "' to be '" +item.type() +"/"+item.name()+"'"
        << endmsg ;
    }
    m_algMap[tag] = item.type() + "/" + item.name() ;
  }
  m_updateRequired = true ;
  return StatusCode::SUCCESS;
}

StatusCode DataOnDemandSvc::setupNodeHandlers ( )

protected

Initialize node handlers.

Definition at line 456 of file DataOnDemandSvc.cpp.

{
  std::string nam, typ, tag;
  StatusCode sc = StatusCode::SUCCESS;
  // Setup for node leafs, where simply a constructor is called...
  for (auto node: m_nodeMapping)
  {
    using Parser = Gaudi::Utils::AttribStringParser;
    for (auto attrib: Parser(node)) {
      switch( ::toupper(attrib.tag[0]) ) {
      case 'D':
        tag = std::move(attrib.value);
        break;
      case 'T':
        nam = std::move(attrib.value);
        break;
      }
    }
    if ( m_algMap  .end () != m_algMap  .find ( tag ) ||
         m_nodeMap .end () != m_nodeMap .find ( tag ) )
    {
      stream()
        << MSG::WARNING
        << "The obsolete property 'Nodes' redefines the action for '"
        + tag + "' to be '" +nam+"'"
        << endmsg ;
    }
    m_nodeMap[tag] = nam ;
  }
  //
  m_updateRequired = true ;
  //
  return sc;
}

MsgStream& DataOnDemandSvc::stream ( ) const

inlineprotected

get the message stream

Definition at line 231 of file DataOnDemandSvc.h.

  {
    if ( !m_log ) m_log.reset( new MsgStream( msgSvc() , name() ) ); 
    return *m_log;
  }

StatusCode DataOnDemandSvc::update ( )

protected

update the handlers

convert obsolete "Nodes" into new "NodeMap"

convert obsolete "Algorithms" into new "AlgMap"

add the default prefix

add the default prefix

get all directories

setup algorithms

setup nodes

Definition at line 239 of file DataOnDemandSvc.cpp.

{
  if ( !m_updateRequired ) { return StatusCode::SUCCESS  ; }

  StatusCode sc = setupNodeHandlers() ; // convert "Nodes"      new "NodeMap"
  if ( sc.isFailure() )
  {
    stream() << MSG::ERROR << "Failed to setup old \"Nodes\""      << endmsg ;
    return sc ;
  }
  sc = setupAlgHandlers()   ; // convert "Algorithms" into "AlgMap"
  if ( sc.isFailure() )
  {
    stream() << MSG::ERROR << "Failed to setup old \"Algorithms\"" << endmsg ;
    return sc ;
  }
  add_prefix ( m_algMap  , m_prefix ) ;
  add_prefix ( m_nodeMap , m_prefix ) ;
  std::set<std::string> dirs ;
  if ( m_partialPath ){ get_dirs ( m_algMap  , dirs ) ; }
  if ( m_partialPath ){ get_dirs ( m_nodeMap , dirs ) ; }
  //
  auto _e = dirs.find("/Event") ;
  if ( dirs.end() != _e ) { dirs.erase( _e ) ; }
  // add all directories as nodes
  for ( const auto& dir : dirs )
  {
    if ( m_algMap  .end () == m_algMap  .find ( dir ) &&
         m_nodeMap .end () == m_nodeMap .find ( dir ) )
            m_nodeMap [dir] = "DataObject" ;
  }
  //
  m_algs  .clear  () ;
  m_nodes .clear  () ;
  //
  for ( const auto& alg : m_algMap )
  {
    if (i_setAlgHandler(alg.first, alg.second).isFailure())
      return StatusCode::FAILURE;
  }
  for ( const auto& node : m_nodeMap )
  {
    i_setNodeHandler(node.first, node.second);
  }
  m_updateRequired = false ;
  //
  return StatusCode::SUCCESS ;
}

void DataOnDemandSvc::update_1

(

Property &

p

)

Definition at line 89 of file DataOnDemandSvc.cpp.

{
  stream() << MSG::VERBOSE << " I am update handler for property " << p << endmsg ;
  // force update
  m_updateRequired = true ;
}

void DataOnDemandSvc::update_2

(

Property &

p

)

Definition at line 110 of file DataOnDemandSvc.cpp.

{
  stream() << MSG::WARNING
           << "The property 'Algorithms' is obsolete, switch to map-like 'AlgMap'  "
           << " = { 'data' : 'algorithm' } "
           << endmsg ;
  // force update
  m_updateRequired = true ;
}

void DataOnDemandSvc::update_3

(

Property &

p

)

Definition at line 98 of file DataOnDemandSvc.cpp.

{
  stream() << MSG::WARNING
           << "The property 'Nodes'      is obsolete, switch to map-like 'NodeMap' "
           << " = { 'data' : 'type'      } "
           << endmsg ;
  // force update
  m_updateRequired = true ;
}

void DataOnDemandSvc::update_dump

(

Property &

)

update handler for 'Dump' property

Definition at line 122 of file DataOnDemandSvc.cpp.

{
  // no action if not yet initialized
  if ( FSMState() < Gaudi::StateMachine::INITIALIZED ) { return ; }
  // dump the configuration:
  if ( m_dump ) { dump ( MSG::ALWAYS ) ; }
}

Member Data Documentation

Map DataOnDemandSvc::m_algMap

private

the major configuration property { 'data' : 'algorithm' }

Definition at line 276 of file DataOnDemandSvc.h.

std::vector<IDODAlgMapper *> DataOnDemandSvc::m_algMappers

private

Definition at line 298 of file DataOnDemandSvc.h.

Setup DataOnDemandSvc::m_algMapping

private

Mapping to algorithms.

Definition at line 266 of file DataOnDemandSvc.h.

std::vector<std::string> DataOnDemandSvc::m_algMapTools

private

Definition at line 297 of file DataOnDemandSvc.h.

SmartIF<IAlgManager> DataOnDemandSvc::m_algMgr = nullptr

private

Algorithm manager.

Definition at line 247 of file DataOnDemandSvc.h.

AlgMap DataOnDemandSvc::m_algs

private

Map of algorithms to handle incidents.

Definition at line 270 of file DataOnDemandSvc.h.

bool DataOnDemandSvc::m_allowInitFailure = false

private

flag to allow DataOnDemand initialization to succeed even if the (pre)initialization of the algorithms fails (m_init).

Definition at line 264 of file DataOnDemandSvc.h.

SmartIF<IDataProviderSvc> DataOnDemandSvc::m_dataSvc = nullptr

private

Data provider reference.

Definition at line 249 of file DataOnDemandSvc.h.

std::string DataOnDemandSvc::m_dataSvcName = "EventDataSvc"

private

Data service name.

Definition at line 255 of file DataOnDemandSvc.h.

bool DataOnDemandSvc::m_dump = false

private

flag to force the printout

Definition at line 259 of file DataOnDemandSvc.h.

SmartIF<IIncidentSvc> DataOnDemandSvc::m_incSvc = nullptr

private

Incident service.

Definition at line 245 of file DataOnDemandSvc.h.

bool DataOnDemandSvc::m_init = false

private

flag to warm up the configuration

Definition at line 261 of file DataOnDemandSvc.h.

bool DataOnDemandSvc::m_locked_algs = false

private

Definition at line 292 of file DataOnDemandSvc.h.

bool DataOnDemandSvc::m_locked_all = false

private

Definition at line 293 of file DataOnDemandSvc.h.

bool DataOnDemandSvc::m_locked_nodes = false

private

Definition at line 291 of file DataOnDemandSvc.h.

std::unique_ptr<MsgStream> DataOnDemandSvc::m_log

mutableprivate

Definition at line 281 of file DataOnDemandSvc.h.

Map DataOnDemandSvc::m_nodeMap

private

the major configuration property { 'data' : 'type' }

Definition at line 278 of file DataOnDemandSvc.h.

std::vector<IDODNodeMapper *> DataOnDemandSvc::m_nodeMappers

private

Definition at line 296 of file DataOnDemandSvc.h.

Setup DataOnDemandSvc::m_nodeMapping

private

Mapping to nodes.

Definition at line 268 of file DataOnDemandSvc.h.

std::vector<std::string> DataOnDemandSvc::m_nodeMapTools

private

Definition at line 295 of file DataOnDemandSvc.h.

NodeMap DataOnDemandSvc::m_nodes

private

Map of "empty" objects to be placed as intermediate nodes.

Definition at line 272 of file DataOnDemandSvc.h.

bool DataOnDemandSvc::m_partialPath = true

private

Flag to allow for the creation of partial leaves.

Definition at line 257 of file DataOnDemandSvc.h.

std::string DataOnDemandSvc::m_prefix = "/Event/"

private

Definition at line 280 of file DataOnDemandSvc.h.

ulonglong DataOnDemandSvc::m_stat = 0

private

Definition at line 286 of file DataOnDemandSvc.h.

ulonglong DataOnDemandSvc::m_statAlg = 0

private

Definition at line 284 of file DataOnDemandSvc.h.

ulonglong DataOnDemandSvc::m_statNode = 0

private

Definition at line 285 of file DataOnDemandSvc.h.

ChronoEntity DataOnDemandSvc::m_timer_algs

private

Definition at line 289 of file DataOnDemandSvc.h.

ChronoEntity DataOnDemandSvc::m_timer_all

private

Definition at line 290 of file DataOnDemandSvc.h.

ChronoEntity DataOnDemandSvc::m_timer_nodes

private

Definition at line 288 of file DataOnDemandSvc.h.

SmartIF<IToolSvc> DataOnDemandSvc::m_toolSvc

private

Data provider reference.

Definition at line 251 of file DataOnDemandSvc.h.

ChronoEntity DataOnDemandSvc::m_total

private

Definition at line 283 of file DataOnDemandSvc.h.

std::string DataOnDemandSvc::m_trapType = "DataFault"

private

Trap name.

Definition at line 253 of file DataOnDemandSvc.h.

bool DataOnDemandSvc::m_updateRequired = true

private

Definition at line 279 of file DataOnDemandSvc.h.

---

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

• GaudiCoreSvc/src/IncidentSvc/DataOnDemandSvc.h
• GaudiCoreSvc/src/IncidentSvc/DataOnDemandSvc.cpp