| # Gaudi Framework, version v20r2
Generated: 18 Jul 2008

- Main Page
- Namespaces
- Classes
- Files
- Directories
- Related Pages

- Search for |

- Alphabetical List
- Class List
- Class Hierarchy
- Class Members

# EventSelector Class Reference

`#include <EventSelector.h>`

Inheritance diagram for EventSelector:

[legend]
Collaboration diagram for EventSelector:

[legend]
List of all members.

## 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 | +---------+----------------------------------------------+---------+

Author:
  Markus Frank

Version:
  1.0

Definition at line 50 of file EventSelector.h.

## Public Types
typedef std::vector< EventSelectorDataStream * > | Streams
typedef std::vector< std::string > | StreamSpecs
typedef std::vector< StringProperty > | Properties
## Public Member Functions
virtual StatusCode | initialize ()
| IService implementation: Db event selector override.
virtual StatusCode | finalize ()
| IService implementation: Service finalization.
virtual StatusCode | reinitialize ()
| Service override: Reinitialize service.
virtual StatusCode | queryInterface (const InterfaceID &riid, void **ppvInterface)
| Service override: queryInterface.
virtual StatusCode | createContext (Context *&refpCtxt) const
  | Parameters:
  | refpCtxt | [IN/OUT] Reference to pointer to store the context
virtual StatusCode | next (Context &refCtxt) const
  | Parameters:
  | refCtxt | [IN/OUT] Reference to the context
virtual StatusCode | next (Context &refCtxt, int jump) const
  | Parameters:
  | refCtxt | [IN/OUT] Reference to the context
virtual StatusCode | previous (Context &refCtxt) const
  | Parameters:
  | refCtxt | [IN/OUT] Reference to the context
virtual StatusCode | previous (Context &refCtxt, int jump) const
  | Parameters:
  | refCtxt | [IN/OUT] Reference to the context
virtual StatusCode | rewind (Context &refCtxt) const
  | Parameters:
  | refCtxt | [IN/OUT] Reference to the context
virtual StatusCode | createAddress (const Context &refCtxt, IOpaqueAddress *&refpAddr) const
  | Parameters:
  | refCtxt | [IN/OUT] Reference to the context
virtual StatusCode | releaseContext (Context *&refCtxt) const
  | Parameters:
  | refCtxt | [IN/OUT] Reference to the context
virtual StatusCode | resetCriteria (const std::string &cr, Context &c) const
| 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.
virtual StatusCode | last (Context &c) const
| Access last item in the iteration.
StatusCode | firstOfNextStream (bool shutDown, EvtSelectorContext &it) const
| Retrieve first entry of the next data stream.
StatusCode | lastOfPreviousStream (bool shutDown, EvtSelectorContext &it) const
| Retrieve last entry of the previous data stream.
| EventSelector (const std::string &name, ISvcLocator *svcloc)
| Standard Constructor.
virtual | ~EventSelector ()
| Standard Destructor.
## Public Attributes
long int | m_streamID
## Protected Member Functions
virtual void | printEvtInfo (const EvtSelectorContext *iter) const
| Progress report.
## Protected Attributes
IIncidentSvc * | m_incidentSvc
| Reference to the indicent service.
IToolSvc * | m_toolSvc
IDataStreamTool * | m_streamtool
bool | m_reconfigure
| Reconfigure occurred.
StreamSpecs | m_streamSpecs
| Input stream specifiers (for job options).
StreamSpecs | m_streamSpecsLast
| Input stream specifiers (last used).
Streams | m_streams
| Input streams.
int | m_streamCount
| Input stream counter (0..oo, monotonely increasing).
int | m_firstEvent
| First event to be processed.
int | m_evtMax
| Maximum number of events to be processed.
int | m_evtPrintFrequency
| Printout frequency.
std::string | m_streamManager

## Member Typedef Documentation

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

Definition at line 52 of file EventSelector.h.

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

Definition at line 53 of file EventSelector.h.

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

Definition at line 54 of file EventSelector.h.

## Constructor & Destructor Documentation

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

Standard Constructor.

Definition at line 26 of file EventSelector.cpp.

References Service::declareProperty().

    00027   : Service( name, svcloc)
    00028 {
    00029   m_incidentSvc       = 0;
    00030   m_toolSvc           = 0;
    00031   m_streamCount       = 0;
    00032   m_firstEvent        = 0;
    00033   m_evtPrintFrequency = 10;
    00034   m_evtMax            = INT_MAX;
    00035   declareProperty( "Input",      m_streamSpecs);
    00036   declareProperty( "FirstEvent", m_firstEvent);
    00037   declareProperty( "EvtMax",     m_evtMax);
    00038   declareProperty( "PrintFreq",  m_evtPrintFrequency);
    00039   declareProperty( "StreamManager",  m_streamManager="DataStreamTool");
    00040   m_reconfigure = false;
    00041 }

EventSelector::~EventSelector | ( |  | ) | `[virtual]`

Standard Destructor.

Definition at line 44 of file EventSelector.cpp.

    00045 {
    00046 }

## Member Function Documentation

void EventSelector::printEvtInfo | ( | const EvtSelectorContext * | iter | ) | const`[protected, virtual]`

Progress report.

Definition at line 56 of file EventSelector.cpp.

References MSG::ALWAYS, EvtSelectorContext::context(), count(), endreq(), EvtSelectorContext::ID(), MSG::INFO, m_evtPrintFrequency, Service::messageService(), Service::name(), EvtSelectorContext::numEvent(), and EvtSelectorContext::numStreamEvent().

Referenced by next(), and previous().

    00056                                                                      {
    00057   if ( 0 != iter )  {
    00058     long count = iter->numEvent();
    00059     // Print an message every m_evtPrintFrequency events
    00060     if ( 0 == iter->context() )   {
    00061       MsgStream log(messageService(), name());
    00062       log << MSG::INFO << "End of event input reached." << endreq;
    00063     }
    00064     else if( iter->numStreamEvent() == -1 ) {
    00065       // Intial value for this stream
    00066     }
    00067     else if( m_evtPrintFrequency != -1 && (count % m_evtPrintFrequency == 0))   {
    00068       MsgStream log(messageService(), name());
    00069       log << MSG::ALWAYS << "Reading Event record " << count+1
    00070           << ". Record number within stream " << iter->ID()+1
    00071           << ": " << iter->numStreamEvent()+1 << endreq;
    00072     }
    00073   }
    00074   else  {
    00075     MsgStream log(messageService(), name());
    00076     log << MSG::INFO << "End of event input reached." << endreq;
    00077   }
    00078 }

StatusCode EventSelector::initialize | ( |  | ) | `[virtual]`

IService implementation: Db event selector override.

Reimplemented from Service.

Definition at line 385 of file EventSelector.cpp.

References IDataStreamTool::addStreams(), std::basic_string< _CharT, _Traits, _Alloc >::c_str(), endreq(), MSG::ERROR, StatusCode::FAILURE, MSG::FATAL, Service::initialize(), StatusCode::isFailure(), StatusCode::isSuccess(), apmon_utils::logger(), m_evtMax, m_incidentSvc, m_streamID, m_streamManager, m_streamSpecs, m_streamSpecsLast, m_streamtool, m_toolSvc, Service::messageService(), Service::name(), IToolSvc::retrieveTool(), ISvcLocator::service(), and Service::serviceLocator().

    00385                                         {
    00386   // Initialize base class
    00387   StatusCode status = Service::initialize();
    00388   MsgStream logger(messageService(), name());
    00389   if ( !status.isSuccess() )    {
    00390     logger << MSG::ERROR << "Error initializing base class Service!" << endreq;
    00391     return status;
    00392   }
    00393   // Get the references to the services that are needed by the ApplicationMgr itself
    00394   StatusCode sc = serviceLocator()->service("IncidentSvc", m_incidentSvc, true);
    00395   if( !sc.isSuccess() )  {
    00396     logger << MSG::FATAL << "Error retrieving IncidentSvc." << endreq;
    00397     return sc;
    00398   }
    00399   if ( m_evtMax != INT_MAX )   {
    00400     logger << MSG::ERROR << "EvtMax is an obsolete property of the event selector." << endreq;
    00401     logger << MSG::ERROR << "Please set \"ApplicationMgr.EvtMax = " << m_evtMax
    00402            << ";\" to process the requested number of events." << endreq;
    00403     return StatusCode::FAILURE;
    00404   }
    00405
    00406   m_toolSvc = 0 ;
    00407   sc = serviceLocator()->service( "ToolSvc" , m_toolSvc , true );
    00408   if ( sc.isFailure() )
    00409   { logger << MSG::ERROR << " Could not locate the Tool Service! " << endreq ;
    00410   return StatusCode::FAILURE ;}
    00411
    00412   sc = m_toolSvc->retrieveTool(m_streamManager.c_str(), m_streamtool, this );
    00413
    00414   if( sc.isFailure() ) {
    00415     logger << MSG::ERROR << "Error initializing "
    00416            << m_streamManager << endreq;
    00417     return sc;
    00418   }
    00419
    00420   status = m_streamtool->addStreams(m_streamSpecs);
    00421
    00422   m_streamSpecsLast = m_streamSpecs;
    00423
    00424   m_streamID          = 0;
    00425
    00426   return status;
    00427 }

StatusCode EventSelector::finalize | ( |  | ) | `[virtual]`

IService implementation: Service finalization.

Reimplemented from Service.

Definition at line 449 of file EventSelector.cpp.

References MSG::DEBUG, endreq(), Service::finalize(), m_incidentSvc, m_streamtool, m_toolSvc, Service::msgSvc(), Service::name(), and IInterface::release().

    00449                                       {
    00450
    00451   MsgStream log(msgSvc(), name());
    00452
    00453   log << MSG::DEBUG << "finalize()" << endreq;
    00454
    00455   if( m_incidentSvc ) {
    00456     m_incidentSvc->release();
    00457     m_incidentSvc = 0 ;
    00458   }
    00459
    00460   if( m_streamtool ) {
    00461     m_streamtool->release();
    00462     m_streamtool = 0 ;
    00463   }
    00464
    00465   if( m_toolSvc ) {
    00466     m_toolSvc->release();
    00467     m_toolSvc = 0 ;
    00468   }
    00469
    00470   return Service::finalize();
    00471 }

StatusCode EventSelector::reinitialize | ( |  | ) | `[virtual]`

Service override: Reinitialize service.

Reimplemented from Service.

Definition at line 430 of file EventSelector.cpp.

References IDataStreamTool::addStreams(), IDataStreamTool::clear(), endreq(), MSG::ERROR, StatusCode::FAILURE, Service::FSMState(), Gaudi::StateMachine::INITIALIZED, StatusCode::isFailure(), apmon_utils::logger(), m_reconfigure, m_streamSpecs, m_streamSpecsLast, m_streamtool, Service::messageService(), Service::name(), and StatusCode::SUCCESS.

    00430                                        {
    00431   if ( FSMState() != Gaudi::StateMachine::INITIALIZED ) {
    00432     MsgStream logger(messageService(), name());
    00433     logger << MSG::ERROR << "Cannot reinitialize: service not in state initialized" << endreq;
    00434     return StatusCode::FAILURE;
    00435   }
    00436
    00437   if( m_streamSpecsLast != m_streamSpecs ) {
    00438     StatusCode status = m_streamtool->clear();
    00439     if ( status.isFailure() ) return status;
    00440     m_streamSpecsLast = m_streamSpecs;
    00441     m_reconfigure = true;
    00442     return m_streamtool->addStreams(m_streamSpecs);
    00443   }
    00444
    00445   return StatusCode::SUCCESS;
    00446 }

StatusCode EventSelector::queryInterface | ( | const InterfaceID & | riid,
|  | void ** | ppvInterface |
| ) |  |  | `[virtual]`

Service override: queryInterface.

Reimplemented from Service.

Definition at line 375 of file EventSelector.cpp.

References Service::addRef(), IID_IEvtSelector, Service::queryInterface(), and IInterface::SUCCESS.

    00375                                                                                       {
    00376   if ( riid == IID_IEvtSelector )  {
    00377     *ppvInterface = (IEvtSelector*)this;
    00378     addRef();
    00379     return SUCCESS;
    00380   }
    00381   return Service::queryInterface( riid, ppvInterface );
    00382 }

StatusCode EventSelector::createContext | ( | Context *& | refpCtxt | ) | const`[virtual]`

Parameters:

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

Returns:
  StatusCode indicating success or failure

Definition at line 188 of file EventSelector.cpp.

References endreq(), MSG::ERROR, StatusCode::FAILURE, firstOfNextStream(), StatusCode::ignore(), StatusCode::isFailure(), m_firstEvent, Service::messageService(), Service::name(), next(), releaseContext(), EvtSelectorContext::set(), and StatusCode::SUCCESS.

    00189 {
    00190   // Max event is zero. Return begin = end
    00191   refpCtxt = 0;
    00192   if ( m_firstEvent < 0 ) {
    00193     MsgStream log(messageService(), name());
    00194     log << MSG::ERROR  << "First Event = " << m_firstEvent << " not valid" << endreq;
    00195     log << MSG::ERROR  << "It should be > 0 " << endreq;
    00196     return StatusCode::FAILURE;    // if failure => iterators = end();
    00197   }
    00198   EvtSelectorContext* ctxt = new EvtSelectorContext(this);
    00199   ctxt->set(0, -1, 0, 0);
    00200   firstOfNextStream(true, *ctxt).ignore();
    00201   refpCtxt = ctxt;
    00202   long nskip = m_firstEvent;
    00203   while( --nskip > 0 )    {
    00204     StatusCode sc = next(*refpCtxt);
    00205     if ( sc.isFailure() ) {
    00206       MsgStream log(messageService(), name());
    00207       log << MSG::ERROR << " createContext() failed to start with event number "
    00208           << m_firstEvent << endreq;
    00209       releaseContext(refpCtxt);
    00210       refpCtxt = 0;
    00211       return StatusCode::FAILURE;
    00212     }
    00213   }
    00214   return StatusCode::SUCCESS;
    00215 }

StatusCode EventSelector::next | ( | Context & | refCtxt | ) | const`[virtual]`

Parameters:

  | refCtxt | [IN/OUT] Reference to the context

Returns:
  StatusCode indicating success or failure

Definition at line 218 of file EventSelector.cpp.

Referenced by createContext(), next(), and rewind().

    00218                                                       {
    00219   return next(refCtxt, 1);
    00220 }

StatusCode EventSelector::next | ( | Context & | refCtxt,
|  | int | jump |
| ) |  |  | const`[virtual]`

Parameters:

  | refCtxt | [IN/OUT] Reference to the context

Returns:
  StatusCode indicating success or failure

Definition at line 223 of file EventSelector.cpp.

References EvtSelectorContext::context(), StatusCode::FAILURE, firstOfNextStream(), IDataStreamTool::getStream(), EvtSelectorContext::ID(), EvtSelectorContext::increaseCounters(), StatusCode::isSuccess(), m_reconfigure, m_streamtool, next(), IEvtSelector::next(), printEvtInfo(), Gaudi::Units::s, and EvtSelectorContext::set().

    00223                                                                        {
    00224   EvtSelectorContext *pIt  = dynamic_cast<EvtSelectorContext*>(&refCtxt);
    00225   if ( pIt )    {
    00226     if ( pIt->ID() != -1 ) {
    00227       const EventSelectorDataStream* s = m_streamtool->getStream(pIt->ID());
    00228       Context* it = pIt->context();
    00229       IEvtSelector* sel = s->selector();
    00230       if ( it && sel )    { // First exploit the current stream
    00231         StatusCode sc = sel->next(*it);  // This stream is empty: advance to the next stream
    00232         if ( !sc.isSuccess() )   {
    00233           sc = firstOfNextStream(true, *pIt);
    00234           if (sc.isSuccess() ) sc = next(*pIt);
    00235         }
    00236         else  {
    00237           pIt->increaseCounters(false);
    00238           pIt->set(it, 0);
    00239           printEvtInfo(pIt);
    00240         }
    00241         return sc;
    00242       }
    00243       else if ( m_reconfigure )  {
    00244         StatusCode sc = firstOfNextStream(false, *pIt);
    00245         printEvtInfo(pIt);
    00246         return sc;
    00247       }
    00248     }
    00249     else if ( m_reconfigure )  {
    00250       StatusCode sc = firstOfNextStream(false, *pIt);
    00251       printEvtInfo(pIt);
    00252       return sc;
    00253     }
    00254     pIt->increaseCounters(false);
    00255   }
    00256   printEvtInfo(pIt);
    00257   return StatusCode::FAILURE;
    00258 }

StatusCode EventSelector::previous | ( | Context & | refCtxt | ) | const`[virtual]`

Parameters:

  | refCtxt | [IN/OUT] Reference to the context

Parameters:

  | jump | [IN] Number of events to be skipped

Returns:
  StatusCode indicating success or failure

Definition at line 261 of file EventSelector.cpp.

    00261                                                           {
    00262   return previous(refCtxt, 1);
    00263 }

StatusCode EventSelector::previous | ( | Context & | refCtxt,
|  | int | jump |
| ) |  |  | const`[virtual]`

Parameters:

  | refCtxt | [IN/OUT] Reference to the context

Parameters:

  | jump | [IN] Number of events to be skipped

Returns:
  StatusCode indicating success or failure

Definition at line 266 of file EventSelector.cpp.

References EvtSelectorContext::context(), StatusCode::FAILURE, IDataStreamTool::getStream(), EvtSelectorContext::ID(), EvtSelectorContext::increaseCounters(), StatusCode::isSuccess(), lastOfPreviousStream(), m_streamtool, IEvtSelector::previous(), printEvtInfo(), Gaudi::Units::s, EvtSelectorContext::set(), and StatusCode::SUCCESS.

    00266                                                               {
    00267   EvtSelectorContext *pIt  = dynamic_cast<EvtSelectorContext*>(&it);
    00268   if ( pIt && jump > 0 )    {
    00269     StatusCode sc = StatusCode::SUCCESS;
    00270     for ( int i = 0; i < jump && sc.isSuccess(); ++i ) {
    00271       const EventSelectorDataStream* s = m_streamtool->getStream(pIt->ID());
    00272       Context* it = pIt->context();
    00273       IEvtSelector* sel = s->selector();
    00274       if ( it && sel )    { // First exploit the current stream
    00275                             // This stream is empty: advance to the next stream
    00276         sc = sel->previous(*it);  // This stream is empty: advance to the next stream
    00277         if ( !sc.isSuccess() )   {
    00278           sc = lastOfPreviousStream(true, *pIt);
    00279         }
    00280         else  {
    00281           pIt->increaseCounters(false);
    00282           pIt->set(it, 0);
    00283         }
    00284         printEvtInfo(pIt);
    00285         if ( !sc.isSuccess() ) {
    00286           return sc;
    00287         }
    00288       }
    00289       pIt->increaseCounters(false);
    00290     }
    00291     return sc;
    00292   }
    00293   printEvtInfo(pIt);
    00294   return StatusCode::FAILURE;
    00295 }

StatusCode EventSelector::rewind | ( | Context & | refCtxt | ) | const`[virtual]`

Parameters:

  | refCtxt | [IN/OUT] Reference to the context

Returns:
  StatusCode indicating success or failure

Definition at line 306 of file EventSelector.cpp.

References endreq(), MSG::ERROR, StatusCode::FAILURE, firstOfNextStream(), StatusCode::isFailure(), m_firstEvent, Service::messageService(), Service::name(), next(), EvtSelectorContext::set(), and StatusCode::SUCCESS.

    00306                                                         {
    00307   EvtSelectorContext *ctxt  = dynamic_cast<EvtSelectorContext*>(&refCtxt);
    00308   if ( ctxt )    {
    00309     ctxt->set(0, -1, 0, 0);
    00310     firstOfNextStream(true, *ctxt);
    00311     long nskip = m_firstEvent;
    00312     while( --nskip > 0 )    {
    00313       StatusCode sc = next(*ctxt);
    00314       if ( sc.isFailure() ) {
    00315         MsgStream log(messageService(), name());
    00316         log << MSG::ERROR << "rewind() failed to start with event number "
    00317             << m_firstEvent << endreq;
    00318         return StatusCode::FAILURE;
    00319       }
    00320     }
    00321     return StatusCode::SUCCESS;
    00322   }
    00323   return StatusCode::FAILURE;
    00324 }

StatusCode EventSelector::createAddress | ( | const Context & | refCtxt,
|  | IOpaqueAddress *& | refpAddr |
| ) |  |  | const`[virtual]`

Parameters:

  | refCtxt | [IN/OUT] Reference to the context

Parameters:

  | refpAddr | [OUT] Reference to address pointer

Returns:
  StatusCode indicating success or failure

Definition at line 328 of file EventSelector.cpp.

References IEvtSelector::createAddress(), StatusCode::FAILURE, IDataStreamTool::getStream(), StatusCode::isSuccess(), m_streamtool, and Gaudi::Units::s.

    00330 {
    00331   const EvtSelectorContext *cpIt  = dynamic_cast<const EvtSelectorContext*>(&refCtxt);
    00332   EvtSelectorContext *pIt  = const_cast<EvtSelectorContext*>(cpIt);
    00333   refpAddr = 0;
    00334   if ( pIt )    {
    00335     const EventSelectorDataStream* s = m_streamtool->getStream(pIt->ID());
    00336     Context* it = pIt->context();
    00337     IEvtSelector* sel = s->selector();
    00338     if ( it && sel )    {
    00339       IOpaqueAddress* pAddr = 0;
    00340       StatusCode sc = sel->createAddress(*it, pAddr);
    00341       if ( sc.isSuccess() )  {
    00342         refpAddr = pAddr;
    00343       }
    00344       pIt->set(it, pAddr);
    00345       return sc;
    00346     }
    00347   }
    00348   return StatusCode::FAILURE;
    00349 }

StatusCode EventSelector::releaseContext | ( | Context *& | refCtxt | ) | const`[virtual]`

Parameters:

  | refCtxt | [IN/OUT] Reference to the context

Returns:
  StatusCode indicating success or failure

Definition at line 352 of file EventSelector.cpp.

References IDataStreamTool::getStream(), StatusCode::isSuccess(), m_streamtool, IEvtSelector::releaseContext(), Gaudi::Units::s, IDataStreamTool::size(), and StatusCode::SUCCESS.

Referenced by createContext().

    00352                                                                  {
    00353   const EvtSelectorContext *cpIt = dynamic_cast<const EvtSelectorContext*>(refCtxt);
    00354   EvtSelectorContext       *pIt  = const_cast<EvtSelectorContext*>(cpIt);
    00355   if ( pIt && pIt->ID() >= 0 && pIt->ID() < (long)m_streamtool->size() ) {
    00356     const EventSelectorDataStream* s = m_streamtool->getStream(pIt->ID());
    00357     Context* it = pIt->context();
    00358     IEvtSelector* sel = s->selector();
    00359     if ( it && sel )    {
    00360       StatusCode sc = sel->releaseContext(it);
    00361       if ( sc.isSuccess() )  {
    00362         refCtxt = 0;
    00363         delete pIt;
    00364         return sc;
    00365       }
    00366     }
    00367   }
    00368   if ( pIt )   {
    00369     delete pIt;
    00370   }
    00371   return StatusCode::SUCCESS;
    00372 }

StatusCode EventSelector::resetCriteria | ( | const std::string & | cr,
|  | Context & | c |
| ) |  |  | const`[virtual]`

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 49 of file EventSelector.cpp.

References StatusCode::FAILURE.

    00051 {
    00052   return StatusCode::FAILURE;
    00053 }

StatusCode EventSelector::last | ( | Context & | c | ) | const`[virtual]`

Access last item in the iteration.

Parameters:

  | c | Reference to the Context object.

Returns:
  StatusCode indicating success or failure

Definition at line 298 of file EventSelector.cpp.

References StatusCode::FAILURE.

    00298                                                      {
    00299   EvtSelectorContext *pIt  = dynamic_cast<EvtSelectorContext*>(&refCtxt);
    00300   if ( pIt )    {
    00301   }
    00302   return StatusCode::FAILURE;
    00303 }

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

Retrieve first entry of the next data stream.

Definition at line 82 of file EventSelector.cpp.

References EvtSelectorContext::context(), endreq(), StatusCode::FAILURE, IDataStreamTool::getNextStream(), IDataStreamTool::getStream(), EvtSelectorContext::ID(), MSG::INFO, StatusCode::isSuccess(), m_reconfigure, m_streamtool, Service::messageService(), Service::name(), Gaudi::Units::s, EvtSelectorContext::set(), StatusCode::setChecked(), IDataStreamTool::size(), and StatusCode::SUCCESS.

Referenced by createContext(), next(), and rewind().

    00082                                                                               {
    00083   StatusCode status = StatusCode::SUCCESS;
    00084   IDataStreamTool::size_type iter_id = (m_reconfigure) ? 0 : iter.ID()+1;
    00085   if ( m_reconfigure ) const_cast<EventSelector*>(this)->m_reconfigure = false;
    00086   if ( shutDown )   {
    00087     if ( iter.ID() >= 0 && iter.ID() < (long)m_streamtool->size() )   {
    00088       const EventSelectorDataStream* s = m_streamtool->getStream(iter.ID());
    00089       if ( s->isInitialized() )    {
    00090         EventSelector* thisPtr = const_cast<EventSelector*>(this);
    00091         if ( s->selector() && iter.context() )  {
    00092           Context* ctxt = iter.context();
    00093           s->selector()->releaseContext(ctxt).ignore();
    00094           iter.set(0,0);
    00095         }
    00096         status = thisPtr->m_streamtool->finalizeStream(const_cast<EventSelectorDataStream*>(s));
    00097         iter.set(0,0);
    00098       }
    00099     }
    00100   }
    00101
    00102   const EventSelectorDataStream* s ;
    00103   status = m_streamtool->getNextStream( s , iter_id );
    00104
    00105   if ( status.isSuccess() )   {
    00106
    00107     if ( !s->isInitialized() )    {
    00108       EventSelector* thisPtr = const_cast<EventSelector*>(this);
    00109       status = thisPtr->m_streamtool->initializeStream(const_cast<EventSelectorDataStream*>(s));
    00110     }
    00111
    00112     if ( status.isSuccess() ) {
    00113       const IEvtSelector* sel = s->selector();
    00114       if ( sel )    {
    00115         Context* ctxt = 0;
    00116         status = sel->createContext(ctxt);
    00117         if ( status.isSuccess() )   {
    00118           status = sel->resetCriteria(s->criteria(), *ctxt);
    00119           if ( status.isSuccess() )   {
    00120             MsgStream log(messageService(), name());
    00121             iter.set(this, iter_id, ctxt, 0);
    00122             log << MSG::INFO << *s << endreq;
    00123             return StatusCode::SUCCESS;
    00124           }
    00125         }
    00126       }
    00127     }
    00128   }
    00129
    00130   iter.set(this, -1, 0, 0);
    00131   status.setChecked();
    00132   return StatusCode::FAILURE;
    00133 }

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

Retrieve last entry of the previous data stream.

Definition at line 137 of file EventSelector.cpp.

References EvtSelectorContext::context(), endreq(), StatusCode::FAILURE, IDataStreamTool::getPreviousStream(), IDataStreamTool::getStream(), EvtSelectorContext::ID(), MSG::INFO, StatusCode::isSuccess(), m_streamtool, Service::messageService(), Service::name(), Gaudi::Units::s, EvtSelectorContext::set(), IDataStreamTool::size(), and StatusCode::SUCCESS.

Referenced by previous().

    00137                                                                                  {
    00138   StatusCode status = StatusCode::SUCCESS;
    00139   if ( shutDown )   {
    00140     if ( iter.ID() >= 0 && iter.ID() < (long)m_streamtool->size() )   {
    00141       const EventSelectorDataStream* s = m_streamtool->getStream(iter.ID());
    00142       if ( s->isInitialized() )    {
    00143         EventSelector* thisPtr = const_cast<EventSelector*>(this);
    00144         if ( s->selector() && iter.context() )  {
    00145           Context* ctxt = iter.context();
    00146           s->selector()->releaseContext(ctxt);
    00147           iter.set(0,0);
    00148         }
    00149         status = thisPtr->m_streamtool->finalizeStream(const_cast<EventSelectorDataStream*>(s));
    00150         iter.set(0,0);
    00151       }
    00152     }
    00153   }
    00154
    00155   IDataStreamTool::size_type iter_id = iter.ID()-1;
    00156   const EventSelectorDataStream* s ;
    00157   status = m_streamtool->getPreviousStream( s , iter_id );
    00158
    00159   if ( status.isSuccess() )   {
    00160
    00161     if ( !s->isInitialized() )    {
    00162       EventSelector* thisPtr = const_cast<EventSelector*>(this);
    00163       status = thisPtr->m_streamtool->initializeStream(const_cast<EventSelectorDataStream*>(s));
    00164     }
    00165     if ( status.isSuccess() )   {
    00166       const IEvtSelector* sel = s->selector();
    00167       if ( sel )  {
    00168         Context* ctxt = 0;
    00169         status = sel->createContext(ctxt);
    00170         if ( status.isSuccess() )   {
    00171           status = sel->resetCriteria(s->criteria(), *ctxt);
    00172           if ( status.isSuccess() )   {
    00173             MsgStream log(messageService(), name());
    00174             iter.set(this, iter_id, ctxt, 0);
    00175             log << MSG::INFO << *s << endreq;
    00176             return StatusCode::SUCCESS;
    00177           }
    00178         }
    00179       }
    00180     }
    00181   }
    00182
    00183   iter.set(this, -1, 0, 0);
    00184   return StatusCode::FAILURE;
    00185 }

## Member Data Documentation

long int EventSelector::m_streamID

Definition at line 56 of file EventSelector.h.

Referenced by initialize().

IIncidentSvc* EventSelector::m_incidentSvc`[protected]`

Reference to the indicent service.

Definition at line 60 of file EventSelector.h.

Referenced by finalize(), and initialize().

IToolSvc* EventSelector::m_toolSvc`[protected]`

Definition at line 62 of file EventSelector.h.

Referenced by finalize(), and initialize().

IDataStreamTool* EventSelector::m_streamtool`[protected]`

Definition at line 64 of file EventSelector.h.

Referenced by createAddress(), finalize(), firstOfNextStream(), initialize(), lastOfPreviousStream(), next(), previous(), reinitialize(), and releaseContext().

bool EventSelector::m_reconfigure`[protected]`

Reconfigure occurred.

Definition at line 67 of file EventSelector.h.

Referenced by firstOfNextStream(), next(), and reinitialize().

StreamSpecs EventSelector::m_streamSpecs`[protected]`

Input stream specifiers (for job options).

Definition at line 69 of file EventSelector.h.

Referenced by initialize(), and reinitialize().

StreamSpecs EventSelector::m_streamSpecsLast`[protected]`

Input stream specifiers (last used).

Definition at line 71 of file EventSelector.h.

Referenced by initialize(), and reinitialize().

Streams EventSelector::m_streams`[protected]`

Input streams.

Definition at line 73 of file EventSelector.h.

int EventSelector::m_streamCount`[protected]`

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

Definition at line 75 of file EventSelector.h.

int EventSelector::m_firstEvent`[protected]`

First event to be processed.

Definition at line 77 of file EventSelector.h.

Referenced by createContext(), and rewind().

int EventSelector::m_evtMax`[protected]`

Maximum number of events to be processed.

Definition at line 79 of file EventSelector.h.

Referenced by initialize().

int EventSelector::m_evtPrintFrequency`[protected]`

Printout frequency.

Definition at line 81 of file EventSelector.h.

Referenced by printEvtInfo().

std::string EventSelector::m_streamManager`[protected]`

Definition at line 83 of file EventSelector.h.

Referenced by initialize().

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

- /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v20r2/GaudiSvc/v17r1/src/EventSelector/EventSelector.h
- /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v20r2/GaudiSvc/v17r1/src/EventSelector/EventSelector.cpp