In This Package:

DaqBlockHeaderCnv.cc

Go to the documentation of this file.

/*
 *  DaqBlockHeaderCnv.cc
 *  PerDaqBlock
 *
 *  Created by Simon Patton on 3/2/11.
 *  Copyright 2011 DayaBay Collaboration. All rights reserved.
 *
 */

#include "DaqReadoutFormat/ByteBuffer.h"
#include "Event/DaqBlockHeader.h"
#include "PerBaseEvent/HeaderObjectCnv.h"
#include "PerDaqBlock/PerDaqBlock.h"
#include "PerDaqBlock/PerDaqBlockHeader.h"
#include <cstring>

#include "DaqBlockHeaderCnv.h"

using DayaBay::DaqBlock;
using DayaBay::DaqBlockHeader;
using DayaBay::HeaderObject;
using DybDaq::ByteBuffer;

DaqBlockHeaderCnv::DaqBlockHeaderCnv(ISvcLocator* svc) :
    RootIOTypedCnv<PerDaqBlockHeader,DaqBlockHeader>("PerDaqBlockHeader",
                                                     classID(),
                                                     svc) {
}


DaqBlockHeaderCnv::~DaqBlockHeaderCnv() {
}

StatusCode DaqBlockHeaderCnv::PerToTran(const PerDaqBlockHeader& perobj,
                                        DaqBlockHeader& tranobj) {
    MsgStream log(msgSvc(), "ReadoutHeaderCnv::PerToTran");
    StatusCode sc = HeaderObjectCnv::toTran(perobj,tranobj);
    if (sc.isFailure()) {
        return sc;
    }

    tranobj.setDeltaEvents(perobj.deltaEvents);
    if(0 == perobj.daqBlock) {
        tranobj.setDaqBlock(0);
        return StatusCode::SUCCESS;
    }

    DaqBlock* daqBlock = const_cast<DaqBlock*>(tranobj.daqBlock());
    if (0 == daqBlock) {
        daqBlock = new DaqBlock();
        tranobj.setDaqBlock(daqBlock);
    }
    DaqBlock::RawData* rawBytes = daqBlock->bytes();
    std::vector<unsigned int>& daqBytes = perobj.daqBlock->rawData;
    if (0 == rawBytes) {
        rawBytes = new DaqBlock::RawData(daqBytes.size());
        daqBlock->setBytes(rawBytes);
    } else {
        rawBytes->resize(daqBytes.size());
    }
    memcpy(&((*(daqBlock->bytes()))[0]),
           &(daqBytes[0]),
           daqBytes.size() * ByteBuffer::BYTES_IN_INT);
    return StatusCode::SUCCESS;
}                                       

StatusCode DaqBlockHeaderCnv::TranToPer(const DaqBlockHeader& tranobj,
                                        PerDaqBlockHeader& perobj) {
    MsgStream log(msgSvc(), "DaqBlockHeaderCnv::TranToPer");
    StatusCode sc = HeaderObjectCnv::toPer(tranobj,
                                           perobj);
    if (sc.isFailure()) {
        return sc;
    }

    perobj.deltaEvents = tranobj.deltaEvents();
    const DaqBlock* daqBlock = tranobj.daqBlock();
    if ( 0 == daqBlock) {
        delete perobj.daqBlock;
        perobj.daqBlock = 0;
        return StatusCode::SUCCESS;
    }
    perobj.daqBlock = new PerDaqBlock(daqBlock->size());
    std::vector<unsigned int>& daqBytes = perobj.daqBlock->rawData;
    memcpy(&(daqBytes[0]),
           &((*(daqBlock->bytes()))[0]),
           daqBlock->size() * ByteBuffer::BYTES_IN_INT);
    return StatusCode::SUCCESS;
}

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

    log << MSG::DEBUG
        << "Saving links to " << rh->inputHeaders().size() 
        << " input 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 DaqBlockHeader part...
    return sc;
}

StatusCode DaqBlockHeaderCnv::fillObjRefs(IOpaqueAddress*, DataObject* dobj) {
    MsgStream log(msgSvc(), "DaqBlockHeaderCnv::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::DEBUG
        << "Restored links to " << hobj->inputHeaders().size() 
        << " input headers" << endreq;

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

---