EventSelector Class Reference

Definition of class EventSelector. More...

#include <src/EventSelector/EventSelector.h>

Inheritance diagram for EventSelector:

Collaboration diagram for EventSelector:

Public Types
typedef std::vector< EventSelectorDataStream * >	Streams
typedef std::vector< std::string >	StreamSpecs
typedef std::vector< StringProperty >	Properties
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
	IService implementation: Db event selector override. More...
StatusCode	finalize () override
	IService implementation: Service finalization. More...
StatusCode	reinitialize () override
	Service override: Reinitialize service. More...
StatusCode	createContext (Context *&refpCtxt) const override
	Create a new event loop context. More...
StatusCode	next (Context &refCtxt) const override
	Get next iteration item from the event loop context. More...
StatusCode	next (Context &refCtxt, int jump) const override
	Get next iteration item from the event loop context, but skip jump elements. More...
StatusCode	previous (Context &refCtxt) const override
	Get previous iteration item from the event loop context. More...
StatusCode	previous (Context &refCtxt, int jump) const override
	Get previous iteration item from the event loop context, but skip jump elements. More...
StatusCode	rewind (Context &refCtxt) const override
	Rewind the dataset. More...
StatusCode	createAddress (const Context &refCtxt, IOpaqueAddress *&refpAddr) const override
	Create new Opaque address corresponding to the current record. More...
StatusCode	releaseContext (Context *&refCtxt) const override
	Release existing event iteration context. More...
StatusCode	resetCriteria (const std::string &cr, Context &c) const override
	Will set a new criteria for the selection of the next list of events and will change the state of the context in a way to point to the new list. More...
StatusCode	last (Context &c) const override
	Access last item in the iteration. More...
StatusCode	firstOfNextStream (bool shutDown, EvtSelectorContext &it) const
	Retrieve first entry of the next data stream. More...
StatusCode	lastOfPreviousStream (bool shutDown, EvtSelectorContext &it) const
	Retrieve last entry of the previous data stream. More...
	EventSelector (const std::string &name, ISvcLocator *svcloc)
	Standard Constructor. More...
	~EventSelector () override=default
	Standard Destructor. 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...

Public Attributes
long int	m_streamID

Protected Member Functions
virtual void	printEvtInfo (const EvtSelectorContext *iter) const
	Progress report. More...

Protected Attributes
SmartIF< IIncidentSvc >	m_incidentSvc = nullptr
	Reference to the indicent service. More...
SmartIF< IToolSvc >	m_toolSvc = nullptr
IDataStreamTool *	m_streamtool = nullptr
bool	m_reconfigure = false
	Reconfigure occurred. More...
StreamSpecs	m_streamSpecs
	Input stream specifiers (for job options) More...
StreamSpecs	m_streamSpecsLast
	Input stream specifiers (last used) More...
Streams	m_streams
	Input streams. More...
int	m_streamCount = 0
	Input stream counter (0..oo, monotonely increasing) More...
int	m_firstEvent = 0
	First event to be processed. More...
int	m_evtMax = INT_MAX
	Maximum number of events to be processed. More...
int	m_evtPrintFrequency = 10
	Printout frequency. More...
std::string	m_streamManager ="DataStreamTool"

Detailed Description

Definition of class EventSelector.

Basic event selector service. The event selector service itself is able to connect other services to attached streams.

History: +------—+-------------------------------------------—+---------—+ | Date | Comment | Who | +------—+-------------------------------------------—+---------—+ | 3/10/00 | Initial version | M.Frank | +------—+-------------------------------------------—+---------—+ | 4/09/09 | Added firing incident on opening/ending file | R. Lambert | +------—+-------------------------------------------—+---------—+

Author

Markus Frank

R. Lambert

Version

1.0

Definition at line 53 of file EventSelector.h.

Member Typedef Documentation

typedef std::vector<StringProperty> EventSelector::Properties

Definition at line 57 of file EventSelector.h.

typedef std::vector<EventSelectorDataStream*> EventSelector::Streams

Definition at line 55 of file EventSelector.h.

typedef std::vector<std::string> EventSelector::StreamSpecs

Definition at line 56 of file EventSelector.h.

Constructor & Destructor Documentation

EventSelector::EventSelector	(	const std::string &	name,
		ISvcLocator *	svcloc
	)

Standard Constructor.

Definition at line 21 of file EventSelector.cpp.

  : base_class( name, svcloc)
{
  declareProperty( "Input",      m_streamSpecs);
  declareProperty( "FirstEvent", m_firstEvent);
  declareProperty( "EvtMax",     m_evtMax);
  declareProperty( "PrintFreq",  m_evtPrintFrequency);
  declareProperty( "StreamManager",  m_streamManager);
}

EventSelector::~EventSelector ( )

overridedefault

Standard Destructor.

Member Function Documentation

StatusCode EventSelector::createAddress ( const Context &  refCtxt, IOpaqueAddress *&  refpAddr  ) const

override

Create new Opaque address corresponding to the current record.

Parameters

refCtxt	[IN/OUT] Reference to the context
refpAddr	[OUT] Reference to address pointer

Returns

StatusCode indicating success or failure

Definition at line 317 of file EventSelector.cpp.

{
  const EvtSelectorContext *cpIt  = dynamic_cast<const EvtSelectorContext*>(&refCtxt);
  EvtSelectorContext *pIt  = const_cast<EvtSelectorContext*>(cpIt);
  refpAddr = nullptr;
  if ( pIt )    {
    const EventSelectorDataStream* s = m_streamtool->getStream(pIt->ID());
    Context* it = pIt->context();
    IEvtSelector* sel = s->selector();
    if ( it && sel )    {
      IOpaqueAddress* pAddr = nullptr;
      StatusCode sc = sel->createAddress(*it, pAddr);
      if ( sc.isSuccess() )  refpAddr = pAddr;
      pIt->set(it, pAddr);
      return sc;
    }
  }
  return StatusCode::FAILURE;
}

StatusCode EventSelector::createContext ( Context *&  refpCtxt ) const

override

Create a new event loop context.

Parameters

refpCtxt

[IN/OUT] Reference to pointer to store the context

Returns

StatusCode indicating success or failure

Definition at line 176 of file EventSelector.cpp.

{
  // Max event is zero. Return begin = end
  refpCtxt = nullptr;
  if ( m_firstEvent < 0 ) {
    MsgStream log(msgSvc(), name());
    log << MSG::ERROR  << "First Event = " << m_firstEvent << " not valid" << endmsg;
    log << MSG::ERROR  << "It should be > 0 " << endmsg;
    return StatusCode::FAILURE;    // if failure => iterators = end();
  }
  EvtSelectorContext* ctxt = new EvtSelectorContext(this);
  ctxt->set(0, -1, 0, 0);
  firstOfNextStream(true, *ctxt).ignore();
  refpCtxt = ctxt;
  long nskip = m_firstEvent;
  while( --nskip > 0 )    {
    StatusCode sc = next(*refpCtxt);
    if ( sc.isFailure() ) {
      MsgStream log(msgSvc(), name());
      log << MSG::ERROR << " createContext() failed to start with event number "
          << m_firstEvent << endmsg;
      releaseContext(refpCtxt);
      refpCtxt = nullptr;
      return StatusCode::FAILURE;
    }
  }
  return StatusCode::SUCCESS;
}

StatusCode EventSelector::finalize ( )

override

IService implementation: Service finalization.

Definition at line 434 of file EventSelector.cpp.

                                      {

  if (msgLevel(MSG::DEBUG)) {
    MsgStream log(msgSvc(), name());
    log << MSG::DEBUG << "finalize()" << endmsg;
  }

  m_incidentSvc = nullptr;

  if (m_streamtool) {
    if (m_toolSvc) {
      m_toolSvc->releaseTool(m_streamtool).ignore();
    } else {
      // It should not be possible to get here
      m_streamtool->release();
    }
    m_streamtool = nullptr;
  }
  m_toolSvc.reset();

  return Service::finalize();
}

StatusCode EventSelector::firstOfNextStream	(	bool	shutDown,
		EvtSelectorContext &	it
	)		const

Retrieve first entry of the next data stream.

Definition at line 65 of file EventSelector.cpp.

                                                                              {
  StatusCode status = StatusCode::SUCCESS;
  IDataStreamTool::size_type iter_id = (m_reconfigure) ? 0 : iter.ID()+1;
  if ( m_reconfigure ) const_cast<EventSelector*>(this)->m_reconfigure = false;
  if ( shutDown )   {
    if ( iter.ID() >= 0 && iter.ID() < (long)m_streamtool->size() )   {
      const EventSelectorDataStream* s = m_streamtool->getStream(iter.ID());
      if ( s->isInitialized() )    {
        EventSelector* thisPtr = const_cast<EventSelector*>(this);
        if ( s->selector() && iter.context() )  {
          Context* ctxt = iter.context();
          s->selector()->releaseContext(ctxt).ignore();
          iter.set(0,0);
        }
        status = thisPtr->m_streamtool->finalizeStream(const_cast<EventSelectorDataStream*>(s));
        iter.set(0,0);
      }
    }
  }

  const EventSelectorDataStream* s ;
  status = m_streamtool->getNextStream( s , iter_id );

  if ( status.isSuccess() )   {

    if (s) {
    if ( !s->isInitialized() )    {
      EventSelector* thisPtr = const_cast<EventSelector*>(this);
      status = thisPtr->m_streamtool->initializeStream(const_cast<EventSelectorDataStream*>(s));
    }

    if ( status.isSuccess() ) {
      const IEvtSelector* sel = s->selector();
      if ( sel )    {
        Context* ctxt = nullptr;
        status = sel->createContext(ctxt);
        if ( status.isSuccess() )   {
          status = sel->resetCriteria(s->criteria(), *ctxt);
          if ( status.isSuccess() )   {
            MsgStream log(msgSvc(), name());
            iter.set(this, iter_id, ctxt, 0);
            log << MSG::INFO << *s << endmsg;
            m_incidentSvc->fireIncident(Incident(s->dbName(),IncidentType::BeginInputFile));
            return StatusCode::SUCCESS;
          }
        }
      }
    }
      m_incidentSvc->fireIncident(Incident(s->dbName(),IncidentType::FailInputFile));
    }
  }

  iter.set(this, -1, 0, 0);
  status.setChecked();
  //m_incidentSvc->fireIncident(Incident(s->dbName(),IncidentType::FailInputFile));
  return StatusCode::FAILURE;
}

StatusCode EventSelector::initialize ( )

override

IService implementation: Db event selector override.

Definition at line 358 of file EventSelector.cpp.

                                        {
  // Initialize base class
  StatusCode status = Service::initialize();
  MsgStream logger(msgSvc(), name());
  if ( !status.isSuccess() )    {
    logger << MSG::ERROR << "Error initializing base class Service!" << endmsg;
    return status;
  }
  // Get the references to the services that are needed by the ApplicationMgr itself
  m_incidentSvc = serviceLocator()->service("IncidentSvc");
  if( !m_incidentSvc )  {
    logger << MSG::FATAL << "Error retrieving IncidentSvc." << endmsg;
    return StatusCode::FAILURE;
  }
  if ( m_evtMax != INT_MAX )   {
    logger << MSG::ERROR << "EvtMax is an obsolete property of the event selector." << endmsg;
    logger << MSG::ERROR << "Please set \"ApplicationMgr.EvtMax = " << m_evtMax
           << ";\" to process the requested number of events." << endmsg;
    return StatusCode::FAILURE;
  }

  m_toolSvc = serviceLocator()->service("ToolSvc");
  if ( !m_toolSvc ) {
    logger << MSG::ERROR << " Could not locate the Tool Service! " << endmsg;
    return StatusCode::FAILURE;
  }
  // make sure we finalize _prior_ to ToolSvc... we are about to get a
  // a pointer to a tool which gets finalized and released by the ToolSvc
  // during ToolSvc::finalize, and we don't want dangling pointers...
  SmartIF<ISvcManager> mgr(serviceLocator());
  auto prio = mgr->getPriority("ToolSvc");
  mgr->setPriority(name(),prio+1).ignore();

  status = m_toolSvc->retrieveTool(m_streamManager.c_str(), m_streamtool, this);

  if( status.isFailure() ) {
    logger << MSG::ERROR << "Error initializing "
           << m_streamManager << endmsg;
    return status;
  }

  status = m_streamtool->clear();
  if( status.isFailure() ) {
    // Message already printed by the tool
    return status;
  }

  status = m_streamtool->addStreams(m_streamSpecs);

  m_streamSpecsLast = m_streamSpecs;

  m_streamID          = 0;

  return status;
}

StatusCode EventSelector::last ( Context &  c ) const

override

Access last item in the iteration.

Parameters

c	Reference to the Context object.

Returns

StatusCode indicating success or failure

Definition at line 287 of file EventSelector.cpp.

                                                     {
  EvtSelectorContext *pIt  = dynamic_cast<EvtSelectorContext*>(&refCtxt);
  if ( pIt )    {
  }
  return StatusCode::FAILURE;
}

StatusCode EventSelector::lastOfPreviousStream	(	bool	shutDown,
		EvtSelectorContext &	it
	)		const

Retrieve last entry of the previous data stream.

Definition at line 125 of file EventSelector.cpp.

                                                                                 {
  StatusCode status = StatusCode::SUCCESS;
  if ( shutDown )   {
    if ( iter.ID() >= 0 && iter.ID() < (long)m_streamtool->size() )   {
      const EventSelectorDataStream* s = m_streamtool->getStream(iter.ID());
      if ( s->isInitialized() )    {
        EventSelector* thisPtr = const_cast<EventSelector*>(this);
        if ( s->selector() && iter.context() )  {
          Context* ctxt = iter.context();
          s->selector()->releaseContext(ctxt);
          iter.set(0,0);
        }
        status = thisPtr->m_streamtool->finalizeStream(const_cast<EventSelectorDataStream*>(s));
        iter.set(0,0);
      }
    }
  }

  IDataStreamTool::size_type iter_id = iter.ID()-1;
  const EventSelectorDataStream* s = nullptr;
  status = m_streamtool->getPreviousStream( s , iter_id );

  if ( status.isSuccess() )   {

    if ( !s->isInitialized() )    {
      EventSelector* thisPtr = const_cast<EventSelector*>(this);
      status = thisPtr->m_streamtool->initializeStream(const_cast<EventSelectorDataStream*>(s));
    }
    if ( status.isSuccess() )   {
      const IEvtSelector* sel = s->selector();
      if ( sel )  {
        Context* ctxt = nullptr;
        status = sel->createContext(ctxt);
        if ( status.isSuccess() )   {
          status = sel->resetCriteria(s->criteria(), *ctxt);
          if ( status.isSuccess() )   {
            MsgStream log(msgSvc(), name());
            iter.set(this, iter_id, ctxt, 0);
            log << MSG::INFO << *s << endmsg;
            return StatusCode::SUCCESS;
          }
        }
      }
    }
  }

  iter.set(this, -1, 0, 0);
  return StatusCode::FAILURE;
}

StatusCode EventSelector::next ( Context &  refCtxt ) const

override

Get next iteration item from the event loop context.

Parameters

refCtxt

[IN/OUT] Reference to the context

Returns

StatusCode indicating success or failure

Definition at line 206 of file EventSelector.cpp.

                                                      {
  return next(refCtxt, 1);
}

StatusCode EventSelector::next ( Context &  refCtxt, int  jump  ) const

override

Get next iteration item from the event loop context, but skip jump elements.

Parameters

refCtxt

[IN/OUT] Reference to the context

Returns

StatusCode indicating success or failure

Definition at line 211 of file EventSelector.cpp.

                                                              {
  EvtSelectorContext *pIt  = dynamic_cast<EvtSelectorContext*>(&refCtxt);
  if ( pIt )    {
    if ( pIt->ID() != -1 ) {
      const EventSelectorDataStream* s = m_streamtool->getStream(pIt->ID());
      Context* it = pIt->context();
      IEvtSelector* sel = s->selector();
      if ( it && sel )    { // First exploit the current stream
        StatusCode sc = sel->next(*it);  // This stream is empty: advance to the next stream
        if ( !sc.isSuccess() )   {
          m_incidentSvc->fireIncident(Incident(s->dbName(),IncidentType::EndInputFile));
          sc = firstOfNextStream(true, *pIt);
          if (sc.isSuccess() ) sc = next(*pIt);
        }
        else  {
          pIt->increaseCounters(false);
          pIt->set(it, 0);
          printEvtInfo(pIt);
        }
        return sc;
      }
      else if ( m_reconfigure )  {
        StatusCode sc = firstOfNextStream(false, *pIt);
        printEvtInfo(pIt);
        return sc;
      }
    }
    else if ( m_reconfigure )  {
      StatusCode sc = firstOfNextStream(false, *pIt);
      printEvtInfo(pIt);
      return sc;
    }
    pIt->increaseCounters(false);
  }
  printEvtInfo(pIt);
  return StatusCode::FAILURE;
}

StatusCode EventSelector::previous ( Context &  refCtxt ) const

override

Get previous iteration item from the event loop context.

Parameters

refCtxt	[IN/OUT] Reference to the context
jump	[IN] Number of events to be skipped

Returns

StatusCode indicating success or failure

Definition at line 250 of file EventSelector.cpp.

                                                          {
  return previous(refCtxt, 1);
}

StatusCode EventSelector::previous ( Context &  refCtxt, int  jump  ) const

override

Get previous iteration item from the event loop context, but skip jump elements.

Parameters

refCtxt	[IN/OUT] Reference to the context
jump	[IN] Number of events to be skipped

Returns

StatusCode indicating success or failure

Definition at line 255 of file EventSelector.cpp.

                                                                    {
  EvtSelectorContext *pIt  = dynamic_cast<EvtSelectorContext*>(&refCtxt);
  if ( pIt && jump > 0 )    {
    StatusCode sc = StatusCode::SUCCESS;
    for ( int i = 0; i < jump && sc.isSuccess(); ++i ) {
      const EventSelectorDataStream* s = m_streamtool->getStream(pIt->ID());
      Context* it = pIt->context();
      IEvtSelector* sel = s->selector();
      if ( it && sel )    { // First exploit the current stream
                            // This stream is empty: advance to the next stream
        sc = sel->previous(*it);  // This stream is empty: advance to the next stream
        if ( !sc.isSuccess() )   {
          sc = lastOfPreviousStream(true, *pIt);
        }
        else  {
          pIt->increaseCounters(false);
          pIt->set(it, 0);
        }
        printEvtInfo(pIt);
        if ( !sc.isSuccess() ) {
          return sc;
        }
      }
      pIt->increaseCounters(false);
    }
    return sc;
  }
  printEvtInfo(pIt);
  return StatusCode::FAILURE;
}

void EventSelector::printEvtInfo ( const EvtSelectorContext *  iter ) const

protectedvirtual

Progress report.

Definition at line 39 of file EventSelector.cpp.

                                                                     {
  if ( iter )  {
    long count = iter->numEvent();
    // Print an message every m_evtPrintFrequency events
    if ( 0 == iter->context() )   {
      MsgStream log(msgSvc(), name());
      log << MSG::INFO << "End of event input reached." << endmsg;
    }
    else if( iter->numStreamEvent() == -1 ) {
      // Intial value for this stream
    }
    else if( m_evtPrintFrequency != -1 && (count % m_evtPrintFrequency == 0))   {
      MsgStream log(msgSvc(), name());
      log << MSG::ALWAYS << "Reading Event record " << count+1
          << ". Record number within stream " << iter->ID()+1
          << ": " << iter->numStreamEvent()+1 << endmsg;
    }
  }
  else  {
    MsgStream log(msgSvc(), name());
    log << MSG::INFO << "End of event input reached." << endmsg;
  }
}

StatusCode EventSelector::reinitialize ( )

override

Service override: Reinitialize service.

Definition at line 415 of file EventSelector.cpp.

                                       {
  if ( FSMState() != Gaudi::StateMachine::INITIALIZED ) {
    MsgStream logger(msgSvc(), name());
    logger << MSG::ERROR << "Cannot reinitialize: service not in state initialized" << endmsg;
    return StatusCode::FAILURE;
  }

  if( m_streamSpecsLast != m_streamSpecs ) {
    StatusCode status = m_streamtool->clear();
    if ( status.isFailure() ) return status;
    m_streamSpecsLast = m_streamSpecs;
    m_reconfigure = true;
    return m_streamtool->addStreams(m_streamSpecs);
  }

  return StatusCode::SUCCESS;
}

StatusCode EventSelector::releaseContext ( Context *&  refCtxt ) const

override

Release existing event iteration context.

Parameters

refCtxt

[IN/OUT] Reference to the context

Returns

StatusCode indicating success or failure

Definition at line 339 of file EventSelector.cpp.

                                                                 {
  const EvtSelectorContext *cpIt = dynamic_cast<const EvtSelectorContext*>(refCtxt);
  std::unique_ptr<EvtSelectorContext> pIt{ const_cast<EvtSelectorContext*>(cpIt) };
  if ( pIt && pIt->ID() >= 0 && pIt->ID() < (long)m_streamtool->size() ) {
    const EventSelectorDataStream* s = m_streamtool->getStream(pIt->ID());
    Context* it = pIt->context();
    IEvtSelector* sel = s->selector();
    if ( it && sel )    {
      StatusCode sc = sel->releaseContext(it);
      if ( sc.isSuccess() )  {
        refCtxt = nullptr;
        return sc;
      }
    }
  }
  return StatusCode::SUCCESS;
}

StatusCode EventSelector::resetCriteria ( const std::string &  cr, Context &  c  ) const

override

Will set a new criteria for the selection of the next list of events and will change the state of the context in a way to point to the new list.

Parameters

cr	The new criteria string.
c	Reference pointer to the Context object.

Returns

StatusCode indicating success or failure

Definition at line 32 of file EventSelector.cpp.

{
  return StatusCode::FAILURE;
}

StatusCode EventSelector::rewind ( Context &  refCtxt ) const

override

Rewind the dataset.

Parameters

refCtxt

[IN/OUT] Reference to the context

Returns

StatusCode indicating success or failure

Definition at line 295 of file EventSelector.cpp.

                                                        {
  EvtSelectorContext *ctxt  = dynamic_cast<EvtSelectorContext*>(&refCtxt);
  if ( ctxt )    {
    ctxt->set(0, -1, 0, 0);
    firstOfNextStream(true, *ctxt);
    long nskip = m_firstEvent;
    while( --nskip > 0 )    {
      StatusCode sc = next(*ctxt);
      if ( sc.isFailure() ) {
        MsgStream log(msgSvc(), name());
        log << MSG::ERROR << "rewind() failed to start with event number "
            << m_firstEvent << endmsg;
        return StatusCode::FAILURE;
      }
    }
    return StatusCode::SUCCESS;
  }
  return StatusCode::FAILURE;
}

Member Data Documentation

int EventSelector::m_evtMax = INT_MAX

protected

Maximum number of events to be processed.

Definition at line 82 of file EventSelector.h.

int EventSelector::m_evtPrintFrequency = 10

protected

Printout frequency.

Definition at line 84 of file EventSelector.h.

int EventSelector::m_firstEvent = 0

protected

First event to be processed.

Definition at line 80 of file EventSelector.h.

SmartIF<IIncidentSvc> EventSelector::m_incidentSvc = nullptr

protected

Reference to the indicent service.

Definition at line 63 of file EventSelector.h.

bool EventSelector::m_reconfigure = false

protected

Reconfigure occurred.

Definition at line 70 of file EventSelector.h.

int EventSelector::m_streamCount = 0

protected

Input stream counter (0..oo, monotonely increasing)

Definition at line 78 of file EventSelector.h.

long int EventSelector::m_streamID

Definition at line 59 of file EventSelector.h.

std::string EventSelector::m_streamManager ="DataStreamTool"

protected

Definition at line 86 of file EventSelector.h.

Streams EventSelector::m_streams

protected

Input streams.

Definition at line 76 of file EventSelector.h.

StreamSpecs EventSelector::m_streamSpecs

protected

Input stream specifiers (for job options)

Definition at line 72 of file EventSelector.h.

StreamSpecs EventSelector::m_streamSpecsLast

protected

Input stream specifiers (last used)

Definition at line 74 of file EventSelector.h.

IDataStreamTool* EventSelector::m_streamtool = nullptr

protected

Definition at line 67 of file EventSelector.h.

SmartIF<IToolSvc> EventSelector::m_toolSvc = nullptr

protected

Definition at line 65 of file EventSelector.h.

---

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

• GaudiCoreSvc/src/EventSelector/EventSelector.h
• GaudiCoreSvc/src/EventSelector/EventSelector.cpp