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

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.

Additional Inherited Members
Static Public Member Functions inherited from IRootIoSvc
static const InterfaceID &	interfaceID ()
	Retrieve interface ID.

Detailed Description

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

Definition at line 44 of file RootIoSvc.cxx.

Constructor & Destructor Documentation

RootIoSvc()

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

protected

Standard Constructor.

Definition at line 127 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();
}

~RootIoSvc()

RootIoSvc::~RootIoSvc ( )

protectedvirtual

destructor

Standard Destructor.

Definition at line 144 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 183 of file RootIoSvc.cxx.

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

getAutoSaveInterval()

virtual int RootIoSvc::getAutoSaveInterval ( )

inlinevirtual

Implements IRootIoSvc.

Definition at line 85 of file RootIoSvc.cxx.

{ return m_autoSaveInterval; };

getEvtMax()

virtual int RootIoSvc::getEvtMax ( )

inlinevirtual

Implements IRootIoSvc.

Definition at line 71 of file RootIoSvc.cxx.

{ return m_evtMax; };

handle()

void RootIoSvc::handle ( const Incident & inc )

virtual

Handles incidents, implementing IIncidentListener interface.

Definition at line 250 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 80 of file RootIoSvc.cxx.

{ return m_index; };

initialize()

StatusCode RootIoSvc::initialize ( )

virtual

perform initializations for this service.

Definition at line 151 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 190 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 SUCCESS;
}

registerRootTree()

void RootIoSvc::registerRootTree ( TChain * ch )

virtual

Implements IRootIoSvc.

Definition at line 222 of file RootIoSvc.cxx.

                                           {
    m_chainCol.push_back(ch);
}

run()

StatusCode RootIoSvc::run ( )

virtual

for the IRunnable interfce

Definition at line 267 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" << endreq;
        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" << endreq;
    }
    
    
    // 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 << endreq;
    
    if(noend) { 
        log << MSG::WARNING << "No end condition specified: will not process any events!" << endreq; 
    }
    }
    // 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" << endreq;
        
    }else if( m_endTime>0 && currentTime >= m_endTime ) {
        log << MSG::INFO << "Loop terminated by time " << endreq;
    }else {
        log << MSG::INFO << "Processing loop terminated by event count" << endreq;
    }
    return status;
}

runEventPair()

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

inlinevirtual

Implements IRootIoSvc.

Definition at line 83 of file RootIoSvc.cxx.

{ return m_runEventPair; };

setIndex()

bool RootIoSvc::setIndex ( int i )

virtual

Implements IRootIoSvc.

Definition at line 226 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 206 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 217 of file RootIoSvc.cxx.

                                               {
    // Not yet used
    return;
}

setRunEventPair()

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

virtual

Implements IRootIoSvc.

Definition at line 238 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 98 of file RootIoSvc.cxx.

---

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

• RootIoSvc.cxx