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

void	getEntryFromTag () 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.17 2022/01/24 04:07:17 maqm Exp

Definition at line 29 of file RootEvtSelector.h.

Constructor & Destructor Documentation

◆ RootEvtSelector()

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

Definition at line 39 of file RootEvtSelector.cxx.

  : base_class( 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 48 of file RootEvtSelector.cxx.

                                  {
  delete m_recId;
}

Member Function Documentation

◆ createAddress()

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

virtual

Definition at line 208 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 147 of file RootEvtSelector.cxx.

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

◆ getEntryFromTag()

void RootEvtSelector::getEntryFromTag ( ) const

Definition at line 214 of file RootEvtSelector.cxx.

                                            {
  bool flag=true;;
  MsgStream log(messageService(), name());
  static std::string tempFile = "";
  log << MSG::DEBUG <<"current file: "<<m_rootInterface->getCurrentFileName()<<endreq;
  std::ifstream fin;
  static std::string tagFile;
  static int i=-1;
  static std::vector<int> ventry;
  int num1 = m_rootInterface->getCurrentFileNum();
  int num2 = m_rootInterface->getTotalFileNum();
 
  
  if(tempFile != m_rootInterface->getCurrentFileName())
  {
    tempFile = m_rootInterface->getCurrentFileName();
    log << MSG::DEBUG<<"temp file: "<<tempFile<<endreq;
    i=-1;
    ventry.clear();
    log << MSG::DEBUG<<"num1: "<<num1<<" num2: "<<num2<<endreq;
    tagFile = (m_rootInterface->getTagInputFile())[num1];
    log << MSG::DEBUG <<"tag file: "<<tagFile<<endreq;
    m_tagFilterSvc->getVEntry(tagFile, ventry);
  }  //end of read a tag file
 
  i++;
  log << MSG::DEBUG<<"ventry i: "<<i<<endreq;
  log << MSG::DEBUG<<"ventry size: "<<ventry.size()<<endreq;
  if(i<ventry.size())
  {
    (*m_recId)=ventry[i];
    log << MSG::DEBUG<<"ventry[i]: "<<ventry[i]<<endreq;
  }
  else
    (*m_recId)= -1;
 
  log << MSG::DEBUG<<"(*m_recId): "<<(*m_recId)<<endreq;
 
  int vs = ventry.size();
 
  if( (i>(vs-1)) && (num1<(num2-1)))
  {  
    bool endAll = m_rootInterface->checkEndOfTree();
    getEntryFromTag();
  }
  if( (i>(vs-1)) && (num1==(num2-1)))
    (*m_recId)= -1;
}

Referenced by getEntryFromTag(), and next().

◆ getRecId()

int RootEvtSelector::getRecId ( ) const

inline

Definition at line 60 of file RootEvtSelector.h.

60{ return (*m_recId); }

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

◆ initialize()

StatusCode RootEvtSelector::initialize ( )

virtual

Definition at line 53 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);
  log << MSG::INFO << "currentFile in RootEvtSelector::initialize "<<m_rootInterface->getCurrentFileName()<<endreq;
  if (!m_rootInterface)      log << MSG::ERROR << "Unable to start Root service within RootCnvSvc" << endreq;
 
  // create root event context
  p_beginContext = new RootEventContext(this); 
 
 
  ITagFilterSvc *tmpSvc;
 
  ISvcLocator* svcLocator = Gaudi::svcLocator();
  StatusCode status = svcLocator->service("TagFilterSvc",tmpSvc);
  if (status.isSuccess()) {
    log << MSG::INFO << "get the TagFilterSvc" << endreq;
    m_tagFilterSvc=dynamic_cast<TagFilterSvc *>(tmpSvc);
  }else {
    log << MSG::WARNING << "could not get the TagFilterSvc. Ignore it." << endreq;
  }
 
  m_rootInterface->setTagInputFile(m_tagFilterSvc->getTagFiles());
 
  vector<string> dstFiles = m_tagFilterSvc->getDstFiles();
  int size = dstFiles.size();
  std::string treeName="Event";
 
  for(int i=0;i<size;i++)
  {
    std::cout<<"RootEvtSelector, dstFile: "<<dstFiles[i]<<std::endl;
    m_rootInterface->addInput(treeName, dstFiles[i].c_str());
  }
  return sc;
}

◆ last()

StatusCode RootEvtSelector::last ( Context & it ) const

virtual

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

                                        {  
    MsgStream log(msgSvc(), name());
    if(m_criteriaType == ROOT)
    {
      log<<MSG::INFO<<"m_criteriaType == ROOT"<<endreq; 
      if(m_rootInterface->getSelectFromTag()!=0)
      {
        getEntryFromTag();
        if((*m_recId)<0)
           return StatusCode::FAILURE;
      }
 
      else
      {
        (*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
    }// end if(m_criteriaType == ROOT) 
    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 319 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 204 of file RootEvtSelector.cxx.

                                                            {
   return(StatusCode::SUCCESS);
}

◆ resetCriteria()

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

virtual

Definition at line 192 of file RootEvtSelector.cxx.

                                                                                          {
   return(StatusCode::SUCCESS);
}

◆ rewind()

StatusCode RootEvtSelector::rewind ( Context & it ) const

virtual

Definition at line 197 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 127 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:

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ RootEvtSelector()

◆ ~RootEvtSelector()

Member Function Documentation

◆ createAddress()

◆ createContext()

◆ getEntryFromTag()

◆ getRecId()

◆ initialize()

◆ last()

◆ next() [1/3]

◆ next() [2/3]

◆ next() [3/3]

◆ previous() [1/2]

◆ previous() [2/2]

◆ queryInterface()

◆ releaseContext()

◆ resetCriteria()

◆ rewind()

◆ setCriteria()