In This Package:

CbltBody.cc

Go to the documentation of this file.

/*
 *  CbltBody.cc
 *  CbltReadoutFormat
 *
 *  Created by Simon Patton on 7/22/10.
 *  Copyright 2010 DayaBay Collaboration. All rights reserved.
 *
 */
#include "CbltReadoutFormat/CbltBody.h"

#include "CbltReadoutFormat/CbltTraits.h"
#include "DaqReadoutFormat/ByteBuffer.h"
#include "DaqReadoutFormat/RomData.h"
#include "FadcReadoutFormat/FadcReadout.h"
#include "FeeReadoutFormat/FeeReadout.h"
#include "LtbReadoutFormat/LtbReadout.h"
#include "FecReadoutFormat/FecReadout.h"
#include "RtmReadoutFormat/RtmReadout.h"

using DybDaq::ByteBuffer;
using DybDaq::CbltBody;
using DybDaq::CbltBuffer;
using DybDaq::DaqBuffer;
using DybDaq::FadcReadout;
using DybDaq::FeeReadout;
using DybDaq::LtbReadout;
using DybDaq::FecReadout;
using DybDaq::RtmReadout;
using DybDaq::RomData;

CbltBody::CbltBody(const RomData* data,
                   const unsigned int moduleType,
                   DaqExpandable& expandable) :
DaqContainer(expandable),
m_data(data),
m_moduleType(moduleType) {
    expandedByRomData(data);
}

CbltBody::CbltBody(const ByteBuffer& byteBuffer,
                   const unsigned int moduleType,
                   const unsigned int bufferSize,
                   const CbltTraits& traits) :
DaqContainer(byteBuffer,
             traits,
             bufferSize),
m_data(0),
m_moduleType(moduleType) {
    byteBuffer.position(byteBuffer.position() + (bufferSize * kBytesInInt));
}

CbltBody::~CbltBody() {
    if (0 != m_data) {
        delete m_data;
    }
}

const RomData& CbltBody::data() const {
    if (0 == m_data && hasByteBuffer()) {
        const CbltTraits& traits = dynamic_cast<const CbltTraits&>(daqTraits());
        const ByteBuffer& buffer = byteBuffer();

        const unsigned int originalPosition = buffer.position();
        buffer.position(begin());
        if (m_moduleType == traits.moduleType(CbltTraits::kFadcModule)) {
            m_data = new FadcReadout(buffer,
                                     containerSize());
        } else if (m_moduleType == traits.moduleType(CbltTraits::kFeeModule)) {
            m_data = new FeeReadout(buffer,
                                    containerSize());
        } else if (m_moduleType == traits.moduleType(CbltTraits::kLtbModule)) {
            m_data = new LtbReadout(buffer,
                                    containerSize());
        }
        else if ( m_moduleType == traits.moduleType(CbltTraits::kRpcRomModule)) {
           const unsigned int version = (traits.majorVersion() << 4) | traits.minorVersion();
           m_data = new FecReadout(buffer, containerSize(), version);
        }
        else if ( m_moduleType == traits.moduleType(CbltTraits::kRpcRtmModule)) {
           const unsigned int version = (traits.majorVersion() << 4) | traits.minorVersion();
           m_data = new RtmReadout(buffer, containerSize(), version);
        }
        buffer.position(originalPosition);
    }
    return *m_data;
}

unsigned int CbltBody::bufferSize() const {
    return data().romSize();
}

unsigned int CbltBody::gatherComponents(OutputBufferList& outputBuffers) const {
    return data().gatherRom(outputBuffers);
}

unsigned int CbltBody::inspectComponents(DaqBuffer::Bytes& inspectors) const {
 //   return 0;
    return data().inspectRom(inspectors);
}

void CbltBody::expanded(const unsigned int size) {
    notifyExpandable(size);
}

---