FeeReadout.cc

Go to the documentation of this file.

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

#include "DaqReadoutFormat/ByteBuffer.h"
#include "FeeReadoutFormat/FeeFoot.h"
#include "FeeReadoutFormat/FeeHead.h"
#include "FeeReadoutFormat/FeeHit.h"
#include "FeeReadoutFormat/FeeTraits.h"

using DybDaq::DaqBuffer;
using DybDaq::DaqContainer;
using DybDaq::DaqTraits;
using DybDaq::FeeFoot;
using DybDaq::FeeHead;
using DybDaq::FeeHit;
using DybDaq::FeeReadout;

FeeReadout::FeeReadout(const unsigned int triggerNumber,
                       const unsigned int triggerType,
                       const bool checked,
                       const bool error,
                       const FeeTraits& traits) :
DaqContainer(),
m_head(new FeeHead(triggerNumber,
                   triggerType,
                   checked,
                   error,
                   traits)),
m_hits(0),
m_foot(0) {
}

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

FeeReadout::~FeeReadout() {
    if (0 != m_foot) {
        delete m_foot;
    }
        if (0 != m_hits) {
                FeeHitPtrList::const_iterator hit;
                for (hit = m_hits->begin();
                         hit != m_hits->end();
                         ++hit) {
                        delete const_cast<FeeHit*>(*hit);
                }
                delete m_hits;
        }
    if (0 != m_head) {
        delete m_head;
    }
}

const DaqTraits& FeeReadout::daqTraits() const {
    return head().feeTraits();
}

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

const FeeReadout::FeeHitPtrList& FeeReadout::feeHits() const {
    if (0 == m_hits) {
        m_hits = new FeeHitPtrList();
        if (hasByteBuffer()) {
            const FeeTraits& traits = head().feeTraits();
            const ByteBuffer& buffer = byteBuffer();
            
            const unsigned int originalPosition = buffer.position();
            buffer.position(begin() + (traits.headSize() * kBytesInInt));
            const unsigned int finished = (containerSize() - (traits.headSize() + traits.footSize())) / traits.hitSize();
            for (unsigned int count = 0;
                 count != finished;
                 ++count) {
                FeeHit* hit = new FeeHit(buffer,
                                         traits);
                m_hits->push_back(hit);
            }
            buffer.position(originalPosition);
        }
    }
    return *m_hits;
}

const FeeFoot& FeeReadout::foot() const {
    if (0 == m_foot) {
        if (hasByteBuffer()) {
            const FeeTraits& traits = head().feeTraits();
            const ByteBuffer& buffer = byteBuffer();
            
            const unsigned int originalPosition = buffer.position();
            buffer.position(begin() + ((containerSize() - traits.footSize()) * kBytesInInt));
            m_foot = new FeeFoot(buffer,
                                 head().feeTraits());
            buffer.position(originalPosition);
        } else {
            m_foot = new FeeFoot(head());
        }
    }
    return *m_foot;
}

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

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

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

unsigned int FeeReadout::gatherComponents(OutputBufferList& outputBuffers) const {
    unsigned int result = head().gather(outputBuffers);
    const FeeHitPtrList& hits = feeHits();
    FeeHitPtrList::const_iterator hit;
    for (hit = hits.begin();
         hit != hits.end();
         ++hit) {
        result += (*hit)->gather(outputBuffers);
    }
    
    result += foot().gather(outputBuffers);
    return result;
}

unsigned int FeeReadout::inspectComponents(DaqBuffer::Bytes& inspectors) const {
    unsigned int result = head().inspect(inspectors);
    const FeeHitPtrList& hits = feeHits();
    FeeHitPtrList::const_iterator hit;
    for (hit = hits.begin();
         hit != hits.end();
         ++hit) {
        result += (*hit)->inspect(inspectors);
    }
    
    result += foot().inspect(inspectors);
    return result;
}

unsigned int FeeReadout::bufferSize() const {
    unsigned int result = head().bufferSize();
    const FeeHitPtrList& hits = feeHits();
    FeeHitPtrList::const_iterator hit;
    for (hit = hits.begin();
         hit != hits.end();
         ++hit) {
        result += (*hit)->bufferSize();
    }
    result += foot().bufferSize();
    return result;
}

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

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

const FeeHit& FeeReadout::addHit(const unsigned int channel,
                                    const unsigned int peakCycle,
                                    const bool highRangeAdc,
                                    const unsigned int pedestal,
                                    const unsigned int charge,
                                    const unsigned int hitNumber,
                                    const unsigned int time) {
    const FeeTraits& traits = head().feeTraits();
    FeeHit* result = new FeeHit(channel,
                                peakCycle,
                                highRangeAdc,
                                pedestal,
                                charge,
                                hitNumber,
                                time,
                                traits);
    return add(result);
}

const FeeHit& FeeReadout::add(const FeeHit* hit) {
    if (0 == m_hits) {
        m_hits = new FeeHitPtrList();
    }
    m_hits->push_back(hit);
    expanded(hit->bufferSize());
    return *hit;
}

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