SimpleRawReader.cxx

Go to the documentation of this file.

#include "RawFile/SimpleRawReader.h"
#include "IRawFile/RawFileExceptions.h"
#include "RawFile/RawFileUtil.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;
}