RootIoSvc Class Reference

Service that implements the IRunable interface, to control the event loop. Based on RootIoSvc of Glast. More...

Inheritance diagram for RootIoSvc:

Public Member Functions
virtual StatusCode	run ()
	for the IRunnable interfce
virtual StatusCode	initialize ()
	perform initializations for this service.
virtual StatusCode	finalize ()
	perform the finalization, as required for a service.
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvUnknown)
	Query interface.
virtual void	handle (const Incident &inc)
	Handles incidents, implementing IIncidentListener interface.
virtual int	getEvtMax ()
virtual void	setRootEvtMax (unsigned int max)
virtual void	setRootTimeMax (unsigned int max)
virtual void	registerRootTree (TChain *ch)
virtual bool	setIndex (int i)
virtual int	index ()
virtual bool	setRunEventPair (std::pair< int, int > ids)
virtual std::pair< int, int >	runEventPair ()
virtual int	getAutoSaveInterval ()
Public Member Functions inherited from IRootIoSvc
	DeclareInterfaceID (IRootIoSvc, 1, 0)
	DeclareInterfaceID (IRootIoSvc, 1, 0)
	DeclareInterfaceID (IRootIoSvc, 1, 0)

Protected Member Functions
	RootIoSvc (const std::string &name, ISvcLocator *al)
	Standard Constructor.
virtual	~RootIoSvc ()
	destructor

Friends
class	SvcFactory< RootIoSvc >
	Allow SvcFactory to instantiate the service.

Detailed Description

Service that implements the IRunable interface, to control the event loop. Based on RootIoSvc of Glast.

Definition at line 41 of file RootIoSvc.cxx.

Constructor & Destructor Documentation

RootIoSvc()

RootIoSvc::RootIoSvc ( const std::string & name, ISvcLocator * al )

protected

Standard Constructor.

Definition at line 117 of file RootIoSvc.cxx.

                                                              : Service( name, svc ) {
 
  declareProperty( "EvtMax", m_evtMax = 0 );
  declareProperty( "StartTime", m_startTime = 0 );
  declareProperty( "EndTime", m_endTime = 0 );
  declareProperty( "AutoSaveInterval", m_autoSaveInterval = 1000 );
  declareProperty( "StartingIndex", m_index = -1 );
  m_rootEvtMax = 0;
  // m_index = -1;
  m_runEventPair = std::pair<int, int>( -1, -1 );
  m_chainCol.clear();
}

Referenced by SvcFactory< RootIoSvc >.

~RootIoSvc()

RootIoSvc::~RootIoSvc ( )

protectedvirtual

destructor

Standard Destructor.

Definition at line 131 of file RootIoSvc.cxx.

{ m_chainCol.clear(); }

Member Function Documentation

finalize()

StatusCode RootIoSvc::finalize ( )

virtual

perform the finalization, as required for a service.

Definition at line 164 of file RootIoSvc.cxx.

                               {
  StatusCode status = StatusCode::SUCCESS;
  return status;
}

getAutoSaveInterval()

virtual int RootIoSvc::getAutoSaveInterval ( )

inlinevirtual

Implements IRootIoSvc.

Definition at line 78 of file RootIoSvc.cxx.

{ return m_autoSaveInterval; };

getEvtMax()

virtual int RootIoSvc::getEvtMax ( )

inlinevirtual

Implements IRootIoSvc.

Definition at line 64 of file RootIoSvc.cxx.

{ return m_evtMax; };

handle()

void RootIoSvc::handle ( const Incident & inc )

virtual

Handles incidents, implementing IIncidentListener interface.

Definition at line 225 of file RootIoSvc.cxx.

                                            {
  if ( inc.type() == "BeginEvent" ) beginEvent();
  else if ( inc.type() == "EndEvent" ) endEvent();
}

index()

virtual int RootIoSvc::index ( )

inlinevirtual

Implements IRootIoSvc.

Definition at line 73 of file RootIoSvc.cxx.

{ return m_index; };

initialize()

StatusCode RootIoSvc::initialize ( )

virtual

perform initializations for this service.

Definition at line 134 of file RootIoSvc.cxx.

                                 {
  StatusCode status = Service::initialize();
 
  // bind all of the properties for this service
  // setProperties ();
 
  // open the message log
  MsgStream log( msgSvc(), name() );
 
  status = serviceLocator()->queryInterface( IAppMgrUI::interfaceID(), (void**)&m_appMgrUI );
 
  // use the incident service to register begin, end events
  IIncidentSvc* incsvc = 0;
  status               = service( "IncidentSvc", incsvc, true );
 
  if ( status.isFailure() ) return status;
 
  incsvc->addListener( this, "BeginEvent", 100 );
  incsvc->addListener( this, "EndEvent", 0 );
 
  // Tell ROOT to reset signals to their default behavior
  gSystem->ResetSignal( kSigBus );
  gSystem->ResetSignal( kSigSegmentationViolation );
  gSystem->ResetSignal( kSigIllegalInstruction );
  gSystem->ResetSignal( kSigFloatingException );
 
  return StatusCode::SUCCESS;
}

queryInterface()

StatusCode RootIoSvc::queryInterface ( const InterfaceID & riid, void ** ppvUnknown )

virtual

Query interface.

Definition at line 170 of file RootIoSvc.cxx.

                                                                                   {
  if ( IID_IRootIoSvc.versionMatch( riid ) ) { *ppvInterface = (IRootIoSvc*)this; }
  else if ( IRunable::interfaceID().versionMatch( riid ) ) { *ppvInterface = (IRunable*)this; }
  else if ( IIncidentListener::interfaceID().versionMatch( riid ) )
  { *ppvInterface = (IIncidentListener*)this; }
  else { return Service::queryInterface( riid, ppvInterface ); }
 
  addRef();
  return StatusCode::SUCCESS;
}

registerRootTree()

void RootIoSvc::registerRootTree ( TChain * ch )

virtual

Implements IRootIoSvc.

Definition at line 198 of file RootIoSvc.cxx.

{ m_chainCol.push_back( ch ); }

run()

StatusCode RootIoSvc::run ( )

virtual

for the IRunnable interfce

Definition at line 239 of file RootIoSvc.cxx.

                          {
  // Purpose and Method:  Control the event loop
 
  StatusCode status = StatusCode::FAILURE;
  MsgStream  log( msgSvc(), name() );
 
  if ( 0 == m_appMgrUI ) return status;
 
  IProperty* propMgr = 0;
  status             = serviceLocator()->service( "ApplicationMgr", propMgr );
  if ( status.isFailure() )
  {
    log << MSG::ERROR << "Unable to locate PropertyManager Service" << endmsg;
    return status;
  }
 
  IntegerProperty evtMax( "EvtMax", 0 );
  status = propMgr->getProperty( &evtMax );
  if ( status.isFailure() ) return status;
 
  // Determine if the min number of ROOT events is less than the
  // requested number of events in the jobOptions file
  IntegerProperty rootEvtMax( "EvtMax", m_rootEvtMax );
  if ( rootEvtMax < evtMax ) setProperty( rootEvtMax );
  else setProperty( evtMax );
 
  // now find the top alg so we can monitor its error count
  //
  IAlgManager* theAlgMgr;
  status = serviceLocator()->getService( "ApplicationMgr", IAlgManager::interfaceID(),
                                         (IInterface*&)theAlgMgr );
  IAlgorithm*     theIAlg;
  Algorithm*      theAlgorithm = 0;
  IntegerProperty errorProperty( "ErrorCount", 0 );
 
  status = theAlgMgr->getAlgorithm( "Top", theIAlg );
  if ( status.isSuccess() )
  {
    try
    { theAlgorithm = dynamic_cast<Algorithm*>( theIAlg ); } catch ( ... )
    { status = StatusCode::FAILURE; }
  }
  if ( status.isFailure() )
  {
    log << MSG::WARNING << "Could not find algorithm 'Top'; will not monitor errors" << endmsg;
  }
 
  // loop over the events
 
  int    eventNumber = 0;
  double currentTime = m_startTime;
 
  {
    bool noend = true;
    log << MSG::INFO << "Runable interface starting event loop as :";
    if ( m_evtMax > 0 )
    {
      log << " MaxEvt = " << m_evtMax;
      noend = false;
    }
    if ( m_endTime > 0 )
    {
      log << " EndTime= " << m_endTime;
      noend = false;
    }
    log << endmsg;
 
    if ( noend )
    {
      log << MSG::WARNING << "No end condition specified: will not process any events!"
          << endmsg;
    }
  }
  // Not yet using time as a control on the event loop for ROOT
  while ( m_evtMax > 0 && eventNumber < m_evtMax || m_endTime > 0 && currentTime < m_endTime )
  {
 
    status = m_appMgrUI->nextEvent( 1 ); // currently, always success
 
    // the single event may have created a failure. Check the ErrorCount propery of the Top
    // alg.
    if ( theAlgorithm != 0 ) theAlgorithm->getProperty( &errorProperty );
    if ( status.isFailure() || errorProperty.value() > 0 ) { status = StatusCode::FAILURE; }
 
    if ( status.isFailure() ) break;
    // if(flux!=0){
    //    currentTime = flux->gpsTime();
    // }
    eventNumber++;
  }
  if ( status.isFailure() )
  { log << MSG::ERROR << "Terminating RootIoSvc loop due to error" << endmsg; }
  else if ( m_endTime > 0 && currentTime >= m_endTime )
  { log << MSG::INFO << "Loop terminated by time " << endmsg; }
  else { log << MSG::INFO << "Processing loop terminated by event count" << endmsg; }
  return status;
}

runEventPair()

virtual std::pair< int, int > RootIoSvc::runEventPair ( )

inlinevirtual

Implements IRootIoSvc.

Definition at line 76 of file RootIoSvc.cxx.

{ return m_runEventPair; };

setIndex()

bool RootIoSvc::setIndex ( int i )

virtual

Implements IRootIoSvc.

Definition at line 200 of file RootIoSvc.cxx.

                                {
  if ( i < 0 ) return false;
  std::vector<TChain*>::iterator it;
  for ( it = m_chainCol.begin(); it != m_chainCol.end(); it++ )
  {
    if ( i >= ( *it )->GetEntries() ) return false;
  }
  m_index        = i;
  m_runEventPair = std::pair<int, int>( -1, -1 );
  return true;
}

setRootEvtMax()

void RootIoSvc::setRootEvtMax ( unsigned int max )

virtual

Implements IRootIoSvc.

Definition at line 181 of file RootIoSvc.cxx.

                                                {
  // Purpose and Method:  Allow users of the RootIoSvc to specify the number
  //  of events found in their ROOT files
  if ( m_rootEvtMax == 0 )
  {
    m_rootEvtMax = max;
    return;
  }
 
  if ( m_rootEvtMax > max ) m_rootEvtMax = max;
}

setRootTimeMax()

void RootIoSvc::setRootTimeMax ( unsigned int max )

virtual

Implements IRootIoSvc.

Definition at line 193 of file RootIoSvc.cxx.

                                                 {
  // Not yet used
  return;
}

setRunEventPair()

bool RootIoSvc::setRunEventPair ( std::pair< int, int > ids )

virtual

Implements IRootIoSvc.

Definition at line 212 of file RootIoSvc.cxx.

                                                       {
  std::vector<TChain*>::iterator it;
  for ( it = m_chainCol.begin(); it != m_chainCol.end(); it++ )
  {
    int readInd = ( *it )->GetEntryNumberWithIndex( ids.first, ids.second );
    if ( ( readInd < 0 ) || ( readInd >= ( *it )->GetEntries() ) ) return false;
  }
  m_runEventPair = ids;
  m_index        = -1;
  return true;
}

Friends And Related Symbol Documentation

SvcFactory< RootIoSvc >

friend class SvcFactory< RootIoSvc >

friend

Allow SvcFactory to instantiate the service.

Definition at line 89 of file RootIoSvc.cxx.

---

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

• RootIoSvc.cxx