In This Package:

RunDataCnv.cc

Go to the documentation of this file.

#include "RunDataCnv.h"
#include "PerBaseEvent/HeaderObjectCnv.h"

using namespace DayaBay;
using namespace std;

RunHeaderCnv::RunHeaderCnv(ISvcLocator* svc)
  : RootIOTypedCnv<PerRunHeader,RunHeader>("PerRunHeader",
                                           classID(),svc)
{
}


RunHeaderCnv::~RunHeaderCnv()
{
}

StatusCode RunHeaderCnv::PerToTran(const PerRunHeader& perobj,
                                   DayaBay::RunHeader& tranobj)
{
  MsgStream log(msgSvc(), "RunHeaderCnv::PerToTran");

  log << MSG::DEBUG << "Converting persistent to transient object" << endreq;

  StatusCode sc = HeaderObjectCnv::toTran(perobj,tranobj);
  if (sc.isFailure()) return sc;
  
  vector<PerRunData*> in_vec = perobj.runDataList;
  vector<PerRunData*>::iterator it;
  
  for(it = in_vec.begin(); it != in_vec.end(); ++it)
  {
    RunData* runData = convert(**it);
    tranobj.runDataList().push_back(runData);
  }
  return StatusCode::SUCCESS;
}                                       

StatusCode RunHeaderCnv::TranToPer(
                                   const DayaBay::RunHeader& tranobj,
                                   PerRunHeader& perobj)
{
  MsgStream log(msgSvc(), "RunHeaderCnv::TranToPer");

  log << MSG::DEBUG << "Converting transient to persistent object" << endreq;

  perobj.clear();
  StatusCode sc = HeaderObjectCnv::toPer(tranobj,perobj);
  if (sc.isFailure()) return sc;
  
  vector<RunData*> in_vec = tranobj.runDataList();
  vector<RunData*>::iterator it;

  for(it=in_vec.begin();it!=in_vec.end();++it){
    perobj.runDataList.push_back( convert(**it) );
  }
  return StatusCode::SUCCESS;
  
}

StatusCode RunHeaderCnv::fillRepRefs(IOpaqueAddress*, DataObject* dobj)
{
    MsgStream log(msgSvc(), "RunHeaderCnv::fillRepRefs");
    RunHeader* rh = dynamic_cast<RunHeader*>(dobj);

    log << MSG::INFO
        << "Got " << rh->inputHeaders().size() << " headers" << endreq;


    StatusCode sc = HeaderObjectCnv::fillPer(m_rioSvc,*rh,*m_perOutObj);
    if (sc.isFailure()) {
        log << MSG::ERROR << "Failed to fill HeaderObject part" << endreq;
        return sc;
    }

    // ... fill RunHeader part...
    return sc;
}

StatusCode RunHeaderCnv::fillObjRefs(IOpaqueAddress*, DataObject* dobj)
{
    MsgStream log(msgSvc(), "RunHeaderCnv::fillObjRefs");
    HeaderObject* hobj = dynamic_cast<HeaderObject*>(dobj);
    StatusCode sc = HeaderObjectCnv::fillTran(m_rioSvc,*m_perInObj,*hobj);
    if (sc.isFailure()) {
        log << MSG::ERROR << "Failed to fill HeaderObject part" << endreq;
        return sc;
    }

    log << MSG::INFO
        << "Got " << hobj->inputHeaders().size() << " headers" << endreq;

    // ... fill RunHeader part...
    return sc;
}

PerRunData* RunHeaderCnv::convert(const DayaBay::RunData& runData){
  std::vector<PerCalibSource> calibSources;
  int nSources = runData.calibSources().size();
  for(int srcIdx=0; srcIdx<nSources; srcIdx++){
    const CalibSource& source = (runData.calibSources())[srcIdx];
    PerCalibSource perSource(source.id(), source.ledFrequency(),
                             source.adZPosition());
    calibSources.push_back(perSource);
  }
  return (new PerRunData(runData.runNumber(), runData.runType(),
                         runData.detectors(), runData.startTime(), 
                         runData.endTime(), calibSources));
}

RunData* RunHeaderCnv::convert(const PerRunData& perRunData)
{
  RunData* runData = new RunData();
  runData->setRunNumber(perRunData.runNumber);
  runData->setRunType(perRunData.runType);
  runData->setDetectors(perRunData.detectors);
  runData->setStartTime(perRunData.startTime);
  runData->setEndTime(perRunData.endTime);
  int nSources = perRunData.calibSources.size();
  DayaBay::RunData::CalibSources calibSources;
  for(int srcIdx=0; srcIdx<nSources; srcIdx++){
    const PerCalibSource& perSource = perRunData.calibSources[srcIdx];
    CalibSource source;
    source.setId(perSource.id);
    source.setLedFrequency(perSource.ledFrequency);
    source.setAdZPosition(perSource.adZPosition);
    calibSources.push_back(source);
  }
  runData->setCalibSources(calibSources);
  return runData;
}

---