In This Package:

CbltReadout.cc

Go to the documentation of this file.

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

#include "CbltReadoutFormat/CbltBody.h"
#include "CbltReadoutFormat/CbltFoot.h"
#include "CbltReadoutFormat/CbltHead.h"
#include "CbltReadoutFormat/CbltTraits.h"
#include "DaqReadoutFormat/ByteBuffer.h"

using DybDaq::ByteBuffer;
using DybDaq::CbltBody;
using DybDaq::CbltBuffer;
using DybDaq::CbltFoot;
using DybDaq::CbltHead;
using DybDaq::CbltReadout;
using DybDaq::CbltTraits;
using DybDaq::DaqBuffer;
using DybDaq::DaqTraits;

// Used to fudge CBLT data
#include "LtbReadoutFormat/LtbHead.h"
#include "LtbReadoutFormat/LtbReadout.h"

using DybDaq::LtbHead;
using DybDaq::LtbReadout;

CbltReadout::CbltReadout(const unsigned int moduleAddress,
                         const unsigned int moduleType,
                         const RomData* romData,
                         const CbltTraits& traits) :
DaqContainer(),
m_head(new CbltHead(moduleAddress,
                    moduleType,
                    traits)),
m_body(new CbltBody(romData,
                    moduleType,
                    *this)),
m_foot(0) {
    const LtbReadout* ltbReadout;
    if (0 != (ltbReadout = dynamic_cast<const LtbReadout*>(romData))) {
        // TODO: DAQ_ERROR, Fix LTB trigger number!
        const LtbHead& ltbHead = ltbReadout->head();
        if (ltbHead.ltbTraits().majorVersion() > 3) {
            // Set undocumented values
        const unsigned int triggerNumber = ltbHead.localTriggerNumber();
        *((unsigned int*)m_head->buffer()) = *((const unsigned int*)m_head->buffer())
            + ((triggerNumber % 256) * 256)
            + (triggerNumber % 256);
        }
    }
    CbltFoot& footToUse = foot();
    footToUse.setDataLength(footToUse.dataLength() + (m_body->bufferSize() * kBytesInInt));
}

CbltReadout::CbltReadout(const ByteBuffer& byteBuffer,
                         const unsigned int bufferSize) :
DaqContainer(byteBuffer,
             bufferSize),
m_head(0),
m_body(0),
m_foot(0) {
    byteBuffer.position(byteBuffer.position() + (bufferSize * kBytesInInt));
}

CbltReadout::~CbltReadout() {
    if (0 != m_foot) {
        delete m_foot;
    }
    if (0 != m_body) {
        delete m_body;
    }
    if (0 != m_head) {
        delete m_head;
    }
}

const DaqTraits& CbltReadout::daqTraits() const {
    return head().cbltTraits();
}

const CbltHead& CbltReadout::head() const {
    if (0 == m_head && hasByteBuffer()) {
        const ByteBuffer& buffer = byteBuffer();
        const unsigned int originalPosition = buffer.position();
        buffer.position(begin());
        m_head = new CbltHead(buffer);
        buffer.position(originalPosition);
    }
    return *m_head;
}

const CbltBody& CbltReadout::body() const {
    if (0 == m_body) {
        if (hasByteBuffer()) {
            const CbltTraits& traits = cbltTraits();
            const ByteBuffer& buffer = byteBuffer();
            
            const unsigned int originalPosition = buffer.position();
            buffer.position(begin() + (traits.headSize() * kBytesInInt));
            m_body = new CbltBody(buffer,
                                  head().moduleType(),
                                  containerSize() - (traits.headSize() + traits.footSize()),
                                  head().cbltTraits());
            buffer.position(originalPosition);
        }
    }
    return *m_body;
}

const CbltFoot& CbltReadout::foot() const {
    if (0 == m_foot && hasByteBuffer()) {
        const CbltTraits& traits = cbltTraits();
        const ByteBuffer& buffer = byteBuffer();
        
        const unsigned int originalPosition = buffer.position();
        buffer.position(begin() + ((containerSize() - traits.footSize()) * kBytesInInt));
        m_foot = new CbltFoot(buffer,
                              head().cbltTraits());
        buffer.position(originalPosition);
        
    }
    return *m_foot;
}

unsigned int CbltReadout::romSize() const {
    return bufferSize();
}

unsigned int CbltReadout::gatherRom(DaqBuffer::OutputBufferList& outputBuffers) const {
    return gather(outputBuffers);
}

unsigned int CbltReadout::inspectRom(DaqBuffer::Bytes& inspectors) const {
    return inspect(inspectors);
}

unsigned int CbltReadout::bufferSize() const {
    unsigned int result = head().bufferSize();
    result += body().bufferSize();
    result += foot().bufferSize();
    return result;
}

unsigned int CbltReadout::gatherComponents(DaqBuffer::OutputBufferList& outputBuffers) const {
    unsigned int result = head().gather(outputBuffers);
    result += body().gather(outputBuffers);
    
    result += foot().gather(outputBuffers);
    return result;
}

unsigned int CbltReadout::inspectComponents(DaqBuffer::Bytes& inspectors) const {
    unsigned int result = head().inspect(inspectors);
    result += body().inspect(inspectors);
    
    result += foot().inspect(inspectors);
    return result;
}

void CbltReadout::expanded(const unsigned int size) {
    CbltFoot& footToUse = foot();
    footToUse.setDataLength(footToUse.dataLength() + (size * kBytesInInt));
    notifyExpandable(size);
}

bool CbltReadout::setRomExpandable(DaqExpandable& expandable) {
    return setExpandable(expandable);
}

const CbltTraits& CbltReadout::cbltTraits() const {
    return dynamic_cast<const CbltTraits&>(daqTraits());
}

CbltFoot& CbltReadout::foot() {
    if (0 == m_foot) {
        m_foot = new CbltFoot(head());
    }
    return *m_foot;
}

---