JobInfoCnv.cc

Go to the documentation of this file.

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

using namespace DayaBay;
using namespace std;

JobHeaderCnv::JobHeaderCnv(ISvcLocator* svc)
  : RootIOTypedCnv<PerJobHeader,JobHeader>("PerJobHeader",
                                           classID(),svc)
{
}


JobHeaderCnv::~JobHeaderCnv()
{
}

StatusCode JobHeaderCnv::PerToTran(const PerJobHeader& perobj,
                                   DayaBay::JobHeader& tranobj)
{
  MsgStream log(msgSvc(), "JobHeaderCnv::PerToTran");

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

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

StatusCode JobHeaderCnv::TranToPer(
                                   const DayaBay::JobHeader& tranobj,
                                   PerJobHeader& perobj)
{
  MsgStream log(msgSvc(), "JobHeaderCnv::TranToPer");

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

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

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

StatusCode JobHeaderCnv::fillRepRefs(IOpaqueAddress*, DataObject* dobj)
{
    MsgStream log(msgSvc(), "JobHeaderCnv::fillRepRefs");
    JobHeader* rh = dynamic_cast<JobHeader*>(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 JobHeader part...
    return sc;
}

StatusCode JobHeaderCnv::fillObjRefs(IOpaqueAddress*, DataObject* dobj)
{
    MsgStream log(msgSvc(), "JobHeaderCnv::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 JobHeader part...
    return sc;
}

PerJobInfo* JobHeaderCnv::convert(const DayaBay::JobInfo& jobInfo){
  return (new PerJobInfo(jobInfo.jobId(),jobInfo.parameters()));
}

JobInfo* JobHeaderCnv::convert(const PerJobInfo& perJobInfo)
{
  JobInfo* jobInfo = new JobInfo();
  jobInfo->setJobId(perJobInfo.jobId);
  jobInfo->setParameters(perJobInfo.parameters);
  return jobInfo;
}