RootEvtSelector Class Reference

RootEvtSelector performs the function of controlling the ApplicationMgr loop. More...

#include <RootEvtSelector.h>

Inheritance diagram for RootEvtSelector:

Public Member Functions
	RootEvtSelector (const std::string &name, ISvcLocator *svcloc)
	~RootEvtSelector ()
virtual StatusCode	initialize ()
virtual StatusCode	createContext (Context *&it) const
StatusCode	next () const
virtual StatusCode	next (Context &it) const
virtual StatusCode	next (Context &it, int jump) const
virtual StatusCode	previous (Context &it) const
virtual StatusCode	previous (Context &it, int jump) const
virtual StatusCode	last (Context &it) const
virtual StatusCode	rewind (Context &it) const
virtual StatusCode	createAddress (const Context &it, IOpaqueAddress *&iop) const
virtual StatusCode	releaseContext (Context *&it) const
virtual StatusCode	resetCriteria (const std::string &criteria, Context &context) const
virtual StatusCode	setCriteria (const std::string &criteria)
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
int	getRecId () const

Detailed Description

RootEvtSelector performs the function of controlling the ApplicationMgr loop.

Adapted to RootCnvSvc from GlastSvc/EventSelector. The input property can now be set either to NONE or to ROOT. If it is NONE, the loop will run until it hits EvtMax. A new class variable was added :m_evtMax which is a local copy of the AppMgrs property.

Header

/bes/bes/BossCvs/Event/RootCnvSvc/RootCnvSvc/RootEvtSelector.h,v 1.11 2008/01/09 00:05:48 codeman Exp

Definition at line 27 of file RootEvtSelector.h.

Constructor & Destructor Documentation

RootEvtSelector()

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

Definition at line 23 of file RootEvtSelector.cxx.

  : Service( name, svcloc),
    p_beginContext(0),
    p_endContext(0) {
    m_recId = new int;
    (*m_recId) = -1;
    declareProperty( "Input", m_jobInput="ROOT");
    getMaxEvent();
}

~RootEvtSelector()

RootEvtSelector::~RootEvtSelector

(

)

Definition at line 32 of file RootEvtSelector.cxx.

                                  {
  delete m_recId;
}

Member Function Documentation

createAddress()

StatusCode RootEvtSelector::createAddress ( const Context &  it, IOpaqueAddress *&  iop  ) const

virtual

Definition at line 167 of file RootEvtSelector.cxx.

                                                  {
  iop = new GenericAddress(ROOT_StorageType, CLID_Event, " ", " ", 0);
  return(StatusCode::SUCCESS);
}

createContext()

StatusCode RootEvtSelector::createContext ( Context *&  it ) const

virtual

Definition at line 106 of file RootEvtSelector.cxx.

{
  it = p_beginContext;
  return(StatusCode::SUCCESS);
}

getRecId()

int RootEvtSelector::getRecId ( ) const

inline

Definition at line 59 of file RootEvtSelector.h.

{  return (*m_recId); }

Referenced by RootCnvSvc::createAddress(), RootEventBaseCnv::createObj(), and RootCnvSvc::updateServiceState().

initialize()

StatusCode RootEvtSelector::initialize ( )

virtual

Definition at line 37 of file RootEvtSelector.cxx.

                                           {
  MsgStream log(msgSvc(), name());
  StatusCode sc = Service::initialize();
  log << MSG::DEBUG << "RootEvtSelector::initialize" << endreq;    if( sc.isSuccess() ) {
    setProperties();
  } else {
    log << MSG::ERROR << "Unable to initialize service " << endreq;
  }
    
  if(m_jobInput.value() != " "){
    sc = setCriteria(m_jobInput);
    if(sc.isFailure()){
      log << MSG::ERROR << "Unable to get input value" << endreq;
      return sc;
    }
  }
    
  // Retrieve conversion service handling event iteration
  sc = serviceLocator()->service("EventCnvSvc", m_addrCreator);
  if( !sc.isSuccess() ) {
    log << MSG::ERROR << 
      "Unable to localize interface IID_IAddressCreator from service:" 
    << "RootEventSelector" 
    << endreq;
    return sc;
  }
  // Get DataSvc
  IDataManagerSvc* eds = 0;
  sc = serviceLocator()->service("EventDataSvc", eds, true);
  if( !sc.isSuccess() ) {
    log << MSG::ERROR 
    << "Unable to localize interface IID_IDataManagerSvc "
    << "from RootEventSelector"
    << endreq;
    return sc;
  }
    
  m_rootCLID = eds->rootCLID();
 
  // provide access to the Root Interface
  m_rootInterface=RootInterface::Instance(log);
  if (!m_rootInterface)      log << MSG::ERROR << "Unable to start Root service within RootCnvSvc" << endreq;
 
  // create root event context
  p_beginContext = new RootEventContext(this); 
 
  return sc;
}

last()

StatusCode RootEvtSelector::last ( Context &  it ) const

virtual

Definition at line 142 of file RootEvtSelector.cxx.

                                                             {
  if (it.identifier() == p_endContext->identifier()) {
    MsgStream log(messageService(), name());
    log << MSG::DEBUG << "last(): Last event in InputStream." <<endreq;
    return(StatusCode::SUCCESS);
  }
  return (StatusCode::FAILURE);
}

next() [1/3]

StatusCode RootEvtSelector::next

(

)

const

Definition at line 174 of file RootEvtSelector.cxx.

                              {  
    MsgStream log(msgSvc(), name());
 
    if(m_criteriaType == ROOT)
    {
      log<<MSG::INFO<<"m_criteriaType == ROOT"<<endreq; 
      (*m_recId)++;        
 
      //if((*m_recId)>m_evtMax){ // if get the max event number?
      //  return StatusCode::FAILURE;
      //}else{  //didn't get the max event number
        static int entry = 0;
 
        bool endOfFile = m_rootInterface->getEOF();
        entry++;
        bool maxEntry = (entry >m_rootInterface->getEntries() &&  m_rootInterface->getEntries()>=0); 
        if(maxEntry) entry =1;
        log<<MSG::INFO<<"entry = "<<entry<<"    "<<maxEntry<<"   "<<endOfFile<<endreq;
        if(endOfFile || maxEntry){   //the using file is get max event or get the end of file
          bool endAll = m_rootInterface->checkEndOfTree();
 
          if(endAll){ //if all is finished ?
            return StatusCode::FAILURE;
          }
        }
      //}  // to make it run if not set event number from jobOption
    } 
    else if( m_criteriaType == NONE)
    {     
      log << MSG::DEBUG << "Reading Event " << (*m_recId) << endreq;
      //If we go over the count set equal to the end
      if((*m_recId) > m_evtMax) {
        return StatusCode::FAILURE;
      }
    }else {
      //We are going to blow up if this situation happens
      log << MSG::FATAL << "Cannot iterate a dead iterator" << endreq;
      return StatusCode::FAILURE;
    } 
    log << MSG::DEBUG << "Reading Event " <<  (*m_recId) << endreq;
    log << MSG::DEBUG << "Max Event " <<  m_evtMax << endreq; 
   return StatusCode::SUCCESS;
}

next() [2/3]

virtual StatusCode RootEvtSelector::next ( Context &  it ) const

virtual

next() [3/3]

virtual StatusCode RootEvtSelector::next ( Context &  it, int  jump  ) const

virtual

previous() [1/2]

virtual StatusCode RootEvtSelector::previous ( Context &  it ) const

virtual

previous() [2/2]

virtual StatusCode RootEvtSelector::previous ( Context &  it, int  jump  ) const

virtual

queryInterface()

StatusCode RootEvtSelector::queryInterface ( const InterfaceID &  riid, void **  ppvInterface  )

virtual

Definition at line 218 of file RootEvtSelector.cxx.

                                                                                       {
  if ( riid == IID_IRootEvtSelector )  {
    *ppvInterface = (RootEvtSelector*)this;
  }
  else if ( riid == IEvtSelector::interfaceID() )  {
    *ppvInterface = (IEvtSelector*)this;
  }
  else if ( riid == IProperty::interfaceID() )  {
    *ppvInterface = (IProperty*)this;
  }
  else   {
    return Service::queryInterface( riid, ppvInterface );
  }
  addRef();
  return SUCCESS;
}

releaseContext()

StatusCode RootEvtSelector::releaseContext ( Context *&  it ) const

virtual

Definition at line 163 of file RootEvtSelector.cxx.

                                                            {
   return(StatusCode::SUCCESS);
}

resetCriteria()

StatusCode RootEvtSelector::resetCriteria ( const std::string &  criteria, Context &  context  ) const

virtual

Definition at line 151 of file RootEvtSelector.cxx.

                                                                                          {
   return(StatusCode::SUCCESS);
}

rewind()

StatusCode RootEvtSelector::rewind ( Context &  it ) const

virtual

Definition at line 156 of file RootEvtSelector.cxx.

                                                               {
   MsgStream log(messageService(), name());
   log << MSG::ERROR << "RootEvtSelector::rewind() not implemented" << endreq;
   return(StatusCode::FAILURE);
}

setCriteria()

StatusCode RootEvtSelector::setCriteria ( const std::string &  criteria )

virtual

Definition at line 86 of file RootEvtSelector.cxx.

                                                                   {
  // Purpose and Method:  set the input criteria
  MsgStream log(msgSvc(), name());
  m_criteria = criteria;
  
  if( criteria == "ROOT" ) {
    log << MSG::INFO << "RootEvtSelector input has been set to ROOT" << endreq;
    m_criteriaType = ROOT;
  }else if( criteria == "NONE"){
    m_criteriaType = NONE;
    log << MSG::INFO << "RootEvtSelector input has been set to NONE" << endreq;
  }
  else {
    log << MSG::ERROR << "Invalid Event Selection Criteria: " << criteria << endreq;
    return StatusCode::FAILURE;
  }
  return StatusCode::SUCCESS;
}

Referenced by initialize().

---

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

• RootEvtSelector.h
• RootEvtSelector.cxx