ROBufferSvc.cc

Go to the documentation of this file.

#include "ROBufferSvc/ROBufferSvc.h"

#include <algorithm>

#include "GaudiKernel/IDataManagerSvc.h"

#include "Event/ReadoutPmtCrate.h"
#include "Event/ReadoutRpcCrate.h"

ROBufferSvc::ROBufferSvc(const string& name, ISvcLocator* pSvcLocator) 
            :Service(name, pSvcLocator), m_log(msgSvc(), "ROBufferSvc")
{
  m_log<< MSG::INFO<< "Construct:ROBufferSvc()!"<< endreq;
}

StatusCode ROBufferSvc::initialize()
{
  StatusCode sc= this->Service::initialize();
  if(sc.isFailure()) 
  { 
    m_log<< MSG::ERROR<< "Error when initializing Service."<< endreq;
    return sc;
  }
   
  m_log<< MSG::INFO<< "ROBufferSvc ininalize()"<< endreq; 

  return StatusCode::SUCCESS;
}

StatusCode ROBufferSvc::queryInterface(const InterfaceID& riid, void** ppint)
{
  if(IID_IROBufferSvc.versionMatch(riid)) 
  {
    m_log<< MSG::DEBUG<< "queryInterface("<< riid
         << ")-->(IROBufferSvc*)"<< (void*)this<< endreq;
    *ppint = (IROBufferSvc*)this;
  }
  else 
  {
    return Service::queryInterface(riid, ppint);
  }
  addRef();
  return StatusCode::SUCCESS;
}

StatusCode ROBufferSvc::setROHeaders(SimReadoutHeader* sroh) 
{
  m_log<< MSG::INFO<< "Set ReadoutHeaders from SimReadoutHeader!"<< endreq;
  m_log<< MSG::INFO<< "The deque<MixHeader> m_mhBuffer size: "<< m_mhBuffer.size()<< endreq;

  //Deal with the SimReadoutHeader
  vector<SimReadout*> sros = sroh->readouts();
  m_log<< MSG::INFO<< "Size of vector<SimReadout*>: "<< sros.size()<< endreq;

  vector<SimReadout*>::iterator simit;
  for(simit = sros.begin(); simit != sros.end(); simit++)
  {
    SimReadout* sro = (*simit);
    const Readout* ro = sro->readout();

    Context context = sroh->context();

    Detector det(sro->readout()->detector());
    context.SetSite(det.site());
    context.SetDetId(det.detectorId());

    if(det.detectorId() == DetectorId::kAD1
       || det.detectorId() == DetectorId::kAD2
       || det.detectorId() == DetectorId::kAD3
       || det.detectorId() == DetectorId::kAD4
       || det.detectorId() == DetectorId::kIWS
       || det.detectorId() == DetectorId::kOWS)
    {
      const ReadoutPmtCrate* ropmtc = 0;
      ropmtc = dynamic_cast<const ReadoutPmtCrate*>(ro);
      if(!ropmtc)
      {
        m_log<< MSG::ERROR<< "Failed to get ReadoutPmtCrate!"<< endreq;
        return StatusCode::FAILURE;
      }
      ReadoutPmtCrate* ropc = new ReadoutPmtCrate(*ropmtc);
    
      //Prepare a new ReadoutHeader
      ReadoutHeader* roh = new ReadoutHeader();
      ropc->setHeader(roh);
      roh->setReadout(dynamic_cast<Readout*>(ropc));

      roh->setContext(context);
      roh->setEarliest(sroh->earliest());
      roh->setLatest(sroh->latest());
    
      //Prepare the MBuffer
      MixHeader mh;
      mh.roh = roh;
      m_mhBuffer.push_back(mh);
    }
    else if(det.detectorId() == DetectorId::kRPC)
    {
      const ReadoutRpcCrate *rorpcc = 0;
      rorpcc = dynamic_cast<const ReadoutRpcCrate*>(ro);
      if(!rorpcc)
      {
        m_log<< MSG::ERROR<< "Failed to get ReadoutRpcCrate!"<< endreq;
        return StatusCode::FAILURE;
      }
      ReadoutRpcCrate* rorc = new ReadoutRpcCrate(*rorpcc);

      //Prepare a new ReadoutHeader
      ReadoutHeader* roh = new ReadoutHeader();
      rorc->setHeader(roh);
      roh->setReadout(dynamic_cast<Readout*>(rorc));

      roh->setContext(context);
      roh->setEarliest(sroh->earliest());
      roh->setLatest(sroh->latest());

      //Prepare the MBuffer
      MixHeader mh;
      mh.roh = roh;
      m_mhBuffer.push_back(mh);
    }
    else if(det.detectorId() == DetectorId::kUnknown)
    {
      Readout* nro = new Readout(*ro);

      //Prepare a new ReadoutHeader
      ReadoutHeader* roh = new ReadoutHeader();
      nro->setHeader(roh);
      roh->setReadout(nro);

      roh->setContext(context);
      roh->setEarliest(sroh->earliest());
      roh->setLatest(sroh->latest());
    
      //Prepare the MBuffer
      MixHeader mh;
      mh.roh = roh;
      m_mhBuffer.push_back(mh);
    }
  }

  //Sort the MBuffer
  sort(m_mhBuffer.begin(), m_mhBuffer.end());

  m_log<< MSG::INFO<< "ROBufferSvc MixHeader buffer filled!" << endreq;

  delete sroh;
  return StatusCode::SUCCESS;  
}

ReadoutHeader* ROBufferSvc::getROHeader() 
{
  m_log<< MSG::INFO<< "get one Readout from MixHeader buffer...."<< endreq;

  ReadoutHeader* roh = m_mhBuffer[0].roh;
  m_mhBuffer.pop_front();

  return roh;
}

deque<MixHeader>::size_type ROBufferSvc::getMBufferSize()
{
  m_log<< MSG::INFO<< "The deque<MixHeader> m_mhBuffer size is "
       << m_mhBuffer.size()<< endreq;

  return m_mhBuffer.size();
}

ROBufferSvc::~ROBufferSvc()
{
  m_log<< MSG::INFO<< "MixHeader buffer size: "<< m_mhBuffer.size()<< endreq;
  m_log<< MSG::INFO<< "Destruct:~ROBufferSvc()!"<< endreq;
}