In This Package:

Alg1.cpp

Go to the documentation of this file.

// $Id: Alg1.cpp,v 1.9 2006/11/30 10:35:26 mato Exp $

// Include files
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/AlgFactory.h"
#include "GaudiKernel/RndmGenerators.h"
#include "Alg1.h"


// Static Factory declaration

DECLARE_ALGORITHM_FACTORY(Alg1);

// Constructor
//------------------------------------------------------------------------------
Alg1::Alg1(const std::string& name, ISvcLocator* ploc)
           : Algorithm(name, ploc) {
//------------------------------------------------------------------------------
  m_initialized = false;
  
  declareProperty("ThisStageName",m_ThisStageName, "Name of this stage");
  declareProperty("LowerStageName",m_LowerStageName, "Name of the lower stage");

}

//------------------------------------------------------------------------------
StatusCode Alg1::initialize() {
//------------------------------------------------------------------------------
  // avoid calling initialize more than once
  if( m_initialized ) return StatusCode::SUCCESS;

  MsgStream log(msgSvc(), name());
  log << MSG::DEBUG << "initializing...." << endreq;
  log << MSG::DEBUG << "Current Stage " <<m_ThisStageName <<endreq;
  log << MSG::DEBUG << "Lower Stage " <<m_LowerStageName <<endreq;

  StatusCode sc;

  // =========
  sc= toolSvc()->retrieveTool("Stage",m_ThisStageName,m_ThisStage);
  if( sc.isFailure() ) {
    log << MSG::ERROR << "Error retrieving the public tool" << endreq;
  }
  // =========
  int diff;
  diff = m_LowerStageName.compare("null");
  if(diff!=0) {
    sc= toolSvc()->retrieveTool("Stage",m_LowerStageName,m_LowerStage);
    if( sc.isFailure() ) {
      log << MSG::ERROR << "Error retrieving the public tool" << endreq;
    }
  } else {
    m_LowerStage=0;
  }

  // Although initialized to 0, however, no special meaning
  m_CurrentTime=0;

  m_FakeDataList.clear();

  m_initialized = true;

  m_Start=true;

  return StatusCode::SUCCESS;
}

//------------------------------------------------------------------------------
StatusCode Alg1::execute() {
//------------------------------------------------------------------------------
  MsgStream  log( msgSvc(), name() );
  log << MSG::DEBUG << "begin of execute()" << endreq;

  FakeDataList::iterator pfakedatalist;

  FFTimeStamp localtime(0,0);

  // Random number (to generate random integer 0,1,2,3)
  Rndm::Numbers flat(randSvc(),Rndm::Flat(0,3.1));

  if(m_LowerStage!=0) {
    log << MSG::DEBUG << "Consumer&Producer" << endreq;
    if(m_Start||m_CurrentTime<=m_ThisStage->currentTime()) {
      
      if(m_Start) {
        // nothing to do
      } else {
        pfakedatalist=m_FakeDataList.begin();
        localtime=pfakedatalist->first;
      }

      while(m_Start||localtime>=m_LowerStage->currentTime()) {
        m_Start=false;
        log << MSG::DEBUG << "In while loop, pulling data from lower Stage ......" << endreq;   
        
        IStageData* pIStageData=0;
        StatusCode sc = m_LowerStage->nextElement(pIStageData);  // pulling out
        if (sc.isFailure()) {
            log << MSG::ERROR
                << "Failed to get next element from lower stage" << endreq;
            return StatusCode::FAILURE;
        }
        
        FakeData* pFakeData=dynamic_cast<FakeData*>(pIStageData);
        if (!pFakeData) {
            log << MSG::ERROR
                << "Recieved unknown type of data from lower stage"
                << endreq;
            return StatusCode::FAILURE;
        }

        //>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>
        // destroy the used one
        FFTimeStamp dt=flat();

        FFTimeStamp tm=pFakeData->time();
        log << MSG::DEBUG << "data pulled out from lower stage has time: "<<tm<<endreq;
        delete pFakeData;
        log << MSG::DEBUG << "data from lower stage is consumed"<<endreq;
        // generate new one
        FakeData* pFD=new FakeData(tm+dt);
        log << MSG::DEBUG << "new data generated at time: "<< pFD->time()<< endreq;
        //<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<

        // push back into a local store
        m_FakeDataList.insert(FakeDataList::value_type(pFD->time(),pFD));

        pfakedatalist=m_FakeDataList.begin();
        localtime=pfakedatalist->first;
      }

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

      if (m_FakeDataList.size()) {
          pfakedatalist=m_FakeDataList.begin();
          log << MSG::DEBUG << "new data pushed out at time " << pfakedatalist->first << endreq;
          
          m_ThisStage->pushElement(pfakedatalist->second);
          m_FakeDataList.erase(pfakedatalist);
      }
      else {
          log << MSG::WARNING 
              << "I have no more data to give" << endreq;
      }

    }
  }

  
  if(m_LowerStage==0) {
    log << MSG::DEBUG << "Producer" << endreq;
    if(m_Start||m_CurrentTime<=m_ThisStage->currentTime()) {
      
      m_Start=false;
      FFTimeStamp dt=flat();
      FakeData* pFD=new FakeData(m_CurrentTime+dt);
      
      m_CurrentTime=pFD->time();
      m_ThisStage->pushElement(pFD);
      log << MSG::DEBUG << "a data is generated: time = "<< pFD->time() <<endreq; 
    }
  }

  log << MSG::DEBUG << "execute() end "<<endreq;
  return StatusCode::SUCCESS;
}


//------------------------------------------------------------------------------
StatusCode Alg1::finalize() {
//------------------------------------------------------------------------------
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << "finalizing...." << endreq;

  m_initialized = false;
  return StatusCode::SUCCESS;
}
//------------------------------------------------------------------------------
StatusCode Alg1::beginRun() {
//------------------------------------------------------------------------------
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << "beginning new run...." << endreq;
  
  m_initialized = true;
  return StatusCode::SUCCESS;
}


//------------------------------------------------------------------------------
StatusCode Alg1::endRun() {
//------------------------------------------------------------------------------
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << "ending new run...." << endreq;
  
  m_initialized = true;
  return StatusCode::SUCCESS;
}

---