SimpleRawReader.cxx

Go to the documentation of this file.

#include "RawFile/SimpleRawReader.h"
#include "RawFile/RawFileUtil.h"
#include "IRawFile/RawFileExceptions.h"
 
#define  DefaultEventBufferSize  1024*32
 
static DataSeparatorRecord   _dataSeparatorRecord;
 
SimpleRawReader::SimpleRawReader(const std::string& fname)
    : m_bufferSize(DefaultEventBufferSize),
      m_buffer( new uint32_t[DefaultEventBufferSize] )
{
    m_rfs = new raw_ifstream(std::vector<std::string>(1, fname));
}
 
SimpleRawReader::~SimpleRawReader()
{
    delete[] m_buffer;
    m_rfs->close();
    delete m_rfs;
}
 
const uint32_t* SimpleRawReader::nextEvent()
{
    (*m_rfs) >> _dataSeparatorRecord;
 
    uint32_t size = _dataSeparatorRecord.getRecord().data_block_size;
    if ( size > m_bufferSize*4 ) {
        while ( size > m_bufferSize*4 ) {
            m_bufferSize *= 2;
        }
        delete[] m_buffer;
        m_buffer = new uint32_t[m_bufferSize];
    }
 
    m_rfs->read((char*)m_buffer, size);
    if ( ! m_rfs->good() ) {
        //std::cerr << "[RawFile] Failed to read FullEventFragment to buffer" << std::endl;
        throw BadInputStream("event_data_block");
    }
 
    return m_buffer;
}