In This Package:

DataSeparatorRecord.cc

Go to the documentation of this file.

/*
 *  DataSeparatorRecord.cc
 *  RawDataBundle
 *
 *  Created by Simon Patton on 7/18/10.
 *  Copyright 2010 DayaBay Collaboration. All rights reserved.
 *
 */
#include "FileReadoutFormat/DataSeparatorRecord.h"

#include "DaqReadoutFormat/ByteBuffer.h"
#include "EventReadoutFormat/EventHeader.h"
#include "EventReadoutFormat/EventReadout.h"
#include "FileReadoutFormat/FileTraits.h"

using DybDaq::ByteBuffer;
using DybDaq::DataSeparatorRecord;
using DybDaq::DaqBuffer;
using DybDaq::EventReadout;
using DybDaq::FileTraits;

DataSeparatorRecord::DataSeparatorRecord(const EventReadout& block,
                                         unsigned int blockNumber,
                                         const FileTraits& traits) :
FileBuffer(new char[traits.recordSize(FileTraits::kDataSeparatorRecord) * kBytesInInt],
           traits,
           FileTraits::kDataSeparatorRecord),
m_block(&block),
m_owner(false) {
    setBlockNumber(blockNumber);
    setBlockLength(block.header().totalSize() * kBytesInInt);
}

DataSeparatorRecord::DataSeparatorRecord(const ByteBuffer& byteBuffer,
                                         const FileTraits& traits) :
FileBuffer(byteBuffer,
           traits),
m_block(0),
m_owner(true) {
}

DataSeparatorRecord::~DataSeparatorRecord() {
    if (m_owner && (0 != m_block)) {
        delete m_block;
    }
}

bool DataSeparatorRecord::isMarked(unsigned int marker) const {
    return FileTraits::kDataSeparatorRecord == marker;
}

const EventReadout& DataSeparatorRecord::block() const {
    return *m_block;
}

const EventReadout* DataSeparatorRecord::extractBlock() const {
    m_owner = false;
    return m_block;
}

unsigned int DataSeparatorRecord::blockNumber() const {
    return readUnsignedInt(FileTraits::kBlockNumber);
}

unsigned int DataSeparatorRecord::blockLength() const {
    return readUnsignedInt(FileTraits::kBlockLength);
}

unsigned int DataSeparatorRecord::formatComponent() const {
    return FileTraits::kDataSeparatorRecord;
}

void DataSeparatorRecord::setBlock(const EventReadout* block) {
    if (m_owner && (0 != m_block)) {
        delete m_block;
    }
    m_owner = true;
    m_block = block;
}

unsigned int DataSeparatorRecord::gather(OutputBufferList& outputBuffers) const {
    unsigned int result = bufferSize() * kBytesInInt;
    outputBuffers.push_back(OutputBuffer(buffer(),
                                         result));

    result += m_block->gather(outputBuffers);
    return result;
}

void DataSeparatorRecord::setBlockNumber(unsigned int blockNumber) {
    writeField(blockNumber,
               FileTraits::kBlockNumber);
}

void DataSeparatorRecord::setBlockLength(unsigned int blockLength) {
    writeField(blockLength,
               FileTraits::kBlockLength);
}

---