StepSequencer Class Reference

#include <StepSequencer.h>

List of all members.

Public Member Functions
	StepSequencer (const std::string &name, ISvcLocator *pSvcLocator)
	~StepSequencer ()
virtual bool	isEnabled () const
StatusCode	initialize ()
StatusCode	execute ()
StatusCode	finalize ()
void	reset ()
StatusCode	initSequencer (HltProcessor::Sequence *)
bool	execSequencer (const std::string &seqID)
std::vector< Algorithm * >	searchAlgForEachTE_o (HltProcessor::Sequence *)
bool	doesExistAlready (std::string)
Algorithm *	existingAlg (std::string)
Private Attributes
Algorithm *	matchAlg
std::vector< Algorithm * >	vMatchAlg
std::map< std::string, std::vector< Algorithm * > >	m_AlgMap
bool	m_isEnabled

---

Detailed Description

Definition at line 14 of file StepSequencer.h.

---

Constructor & Destructor Documentation

StepSequencer::StepSequencer	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Definition at line 32 of file StepSequencer.cxx.

References m_isEnabled.

                                                                           : 
  Algorithm(name, pSvcLocator) {
  m_isEnabled = false;
}

StepSequencer::~StepSequencer

(

)

Definition at line 38 of file StepSequencer.cxx.

                              {
  /*
  std::vector<Algorithm*>* subAlgms = subAlgorithms();
  std::vector<Algorithm *>::iterator it;
  for (it = subAlgms->begin(); it != subAlgms->end(); it++) {
    std::cout << *it << (*it)->name() << std::endl;
    (*it)->release();
  }
  */
}

---

Member Function Documentation

bool StepSequencer::doesExistAlready

(

std::string

)

Definition at line 139 of file StepSequencer.cxx.

References Bes_Common::WARNING.

Referenced by initSequencer().

{  
  MsgStream log( messageService(), name() );
  bool doesExist=false;
  std::vector<Algorithm*>* subAlgms = subAlgorithms();
  
  if(subAlgms->size()==0) {
    doesExist=false;
    return doesExist;     
  }
  else {
    std::vector<Algorithm*>::iterator it = subAlgms->begin();
    for ( ; it != subAlgms->end(); it++) {
         if(aName==(*it)->name()) {
              log << MSG::WARNING << aName <<" sub-algorithm already created" << endreq;
              doesExist=true;
              break;
         }
    }
  }     
  return doesExist; 
}

bool StepSequencer::execSequencer

(

const std::string &

seqID

)

Definition at line 164 of file StepSequencer.cxx.

References Bes_Common::DEBUG, calibUtil::ERROR, and m_AlgMap.

Referenced by StepHandler::execute().

{
  MsgStream log( messageService(), name() );
  const std::vector<Algorithm*>& algVec = m_AlgMap[seqID];
  /*log << MSG::DEBUG << " Execute Sequencer on a step with "
      << algVec.size() << " algorithms." << endreq;*/

  log << MSG::DEBUG << "=============================" << endreq;

  std::vector<Algorithm*>::const_iterator it = algVec.begin();
  for(; it != algVec.end(); it++) {
    StatusCode sc = (*it)->execute();
    if (sc.isFailure()) {
      log << MSG::ERROR << (*it)->name() << " execute failed" << endreq;
      return false;
    }
  }

  return true;
}

StatusCode StepSequencer::execute

(

)

[inline]

Definition at line 23 of file StepSequencer.h.

{ return StatusCode::SUCCESS; }

Algorithm * StepSequencer::existingAlg

(

std::string

)

Definition at line 123 of file StepSequencer.cxx.

References boss::Algorithm.

Referenced by initSequencer().

{
 MsgStream log( messageService(), name() );
 Algorithm* exAlg;
 std::vector<Algorithm*>* subAlgms = subAlgorithms();
 std::vector<Algorithm*>::iterator it = subAlgms->begin();
 for ( ; it != subAlgms->end(); it++) {
   if(subAlgName==(*it)->name()) {
       log << subAlgName<<" already created, return pointer to it "<< endreq;
       return *it;
   }
 }
 return exAlg;
}

StatusCode StepSequencer::finalize

(

)

[inline]

Definition at line 24 of file StepSequencer.h.

{ return StatusCode::SUCCESS; }

StatusCode StepSequencer::initialize

(

)

[inline]

Definition at line 22 of file StepSequencer.h.

{ return StatusCode::SUCCESS; }

StatusCode StepSequencer::initSequencer

(

HltProcessor::Sequence *

)

Definition at line 69 of file StepSequencer.cxx.

References HltProcessor::Sequence::algoNum(), boss::Algorithm, HltProcessor::Sequence::algoVector(), Bes_Common::DEBUG, doesExistAlready(), existingAlg(), Bes_Common::FATAL, findAlgTypeName(), findParamSet(), HltProcessor::Sequence::getSeqID(), Bes_Common::INFO, m_AlgMap, and deljobs::string.

Referenced by StepHandler::beginRun().

                                                           {
  MsgStream log( messageService(), name() );

  std::string SubAlg_type, SubAlg_name, SubAlg_param, SubAlg_NameParam,AlgNameFromConfig ;
  Algorithm* pAlg;
  Algorithm* bAlg;
  
  //read in algorithms in sequence and initialize them
  log<< MSG::DEBUG << "Sequence " << sequence->getSeqID()
     <<" has " << sequence->algoNum() << " algorithms " << endreq;

  std::vector<Algorithm*> helpAlgVec;
  std::vector<std::string>::iterator algI = sequence->algoVector().begin();

  for ( ; algI != sequence->algoVector().end(); algI++){
      std::string alg_def = *algI;
      log << MSG::DEBUG << "algorithm    : " << alg_def << endreq;     
      findAlgTypeName(alg_def,SubAlg_type,SubAlg_NameParam);
      findParamSet(SubAlg_NameParam,AlgNameFromConfig,SubAlg_param);
      SubAlg_name=AlgNameFromConfig+"_"+SubAlg_param;
      
      //check if the name exists, don't create again the subalgorithm, just added to the AlgoTePairs vector
      bool subAlgExist = doesExistAlready(SubAlg_name);
      if(!subAlgExist) {   
         StatusCode sc = createSubAlgorithm(SubAlg_type, SubAlg_name, pAlg);
         if(sc.isFailure() ) {
              log << MSG::FATAL << alg_def <<" sub-algorithm create failed!" << endreq;
              return sc;
         }
         log << MSG::DEBUG << "created " << SubAlg_type << "/" << SubAlg_name << endreq;
         bAlg = dynamic_cast<Algorithm*>(pAlg);
         bAlg->initialize();
         bAlg->beginRun();
         StringProperty paramSet("ParamSetFile", SubAlg_param);
         bAlg->setProperty(paramSet);

         helpAlgVec.push_back(bAlg);
      } else {
         pAlg = existingAlg(SubAlg_name);
         bAlg = dynamic_cast<Algorithm*>(pAlg);
         //bAlg->set_isReRunable();
         StringProperty paramSet("ParamSetFile",SubAlg_param);
         bAlg->setProperty(paramSet);
         helpAlgVec.push_back(bAlg);
      }
  }
  m_AlgMap[sequence->getSeqID()] = helpAlgVec;
  
  log << MSG::INFO << "Initialization of "<< name() << " completed successfully" << endreq;
  return StatusCode::SUCCESS;
}

virtual bool StepSequencer::isEnabled

(

)

const [inline, virtual]

Definition at line 21 of file StepSequencer.h.

References m_isEnabled.

{return m_isEnabled;};

void StepSequencer::reset

(

)

Definition at line 50 of file StepSequencer.cxx.

References Bes_Common::DEBUG, genRecEmupikp::i, and m_AlgMap.

Referenced by StepHandler::execute().

{
  MsgStream log( messageService(), name() );
  std::map<std::string, std::vector<Algorithm*> >::iterator it = m_AlgMap.begin();
  log << MSG::DEBUG << "the size of algorithm map is " << m_AlgMap.size() << endreq;
  for ( ; it != m_AlgMap.end(); it++) {
    log << MSG::DEBUG << "reset() of " << it->first << endreq;
    const std::vector<Algorithm*>& algs = it->second;
    int n = algs.size();
    for (int i = 0; i < n; i++) {
      if (IEFAlgorithm* ialg = dynamic_cast<IEFAlgorithm*>(algs[i])) {
        //std::cout << " @reset(): " << algs[i]->name() << "  p: " << ialg << std::endl;
        ialg->reset();
      }
    }
  }
}

std::vector< Algorithm * > StepSequencer::searchAlgForEachTE_o

(

HltProcessor::Sequence *

)

Definition at line 185 of file StepSequencer.cxx.

References HltProcessor::Sequence::algoVector(), findAlgTypeName(), findParamSet(), deljobs::string, and vMatchAlg.

{

  MsgStream log( messageService(), name() );
  std::string SubAlg_type, SubAlg_name, SubAlg_param, SubAlg_NameParam,AlgNameFromConfig;

  /* std::string n=name();
  std::string::size_type p_end, p_begin;
  p_end=n.size();
  p_begin=p_end-3;
  std::string instance=n.substr( p_begin, p_end);*/

  vMatchAlg.clear();
     std::vector<std::string>::iterator It = seq->algoVector().begin();
     for ( ; It < seq->algoVector().end(); It++) {
       std::string alg_defin = *It;
       findAlgTypeName(alg_defin,SubAlg_type,SubAlg_NameParam);
       findParamSet(SubAlg_NameParam,AlgNameFromConfig,SubAlg_param);
       SubAlg_name=AlgNameFromConfig+"_"+SubAlg_param;

       /*std::vector<std::pair<Algorithm*,HltElement* > >::iterator I;
       for(I=AlgoTEPairs.begin();I!=AlgoTEPairs.end();++I) {       

          if( SubAlg_name==(I->first)->name() && (I->second)->label()==seq->outputLabel() ) {
            matchAlg=I->first;
            vMatchAlg.push_back(matchAlg);
          } 
       }*/
      }   
  return vMatchAlg;
}

---

Member Data Documentation

std::map<std::string, std::vector<Algorithm* > > StepSequencer::m_AlgMap [private]

Definition at line 40 of file StepSequencer.h.

Referenced by execSequencer(), initSequencer(), and reset().

bool StepSequencer::m_isEnabled [private]

Definition at line 42 of file StepSequencer.h.

Referenced by isEnabled(), and StepSequencer().

Algorithm* StepSequencer::matchAlg [private]

Definition at line 37 of file StepSequencer.h.

std::vector<Algorithm* > StepSequencer::vMatchAlg [private]

Definition at line 38 of file StepSequencer.h.

Referenced by searchAlgForEachTE_o().

---