RawDataMining.cxx

Go to the documentation of this file.

#include "RawFile/RawDataMining.h"
#include "IRawFile/RawFileExceptions.h"
 
RawDataMining::RawDataMining( const std::string& filename )
  : m_fname(filename)
{
  m_ifstream = new raw_ifstream( std::vector<std::string>{ filename } );
  m_cache = new RawDataCache(512*1024);
 
  auto p = m_ifstream->tellg();
  m_ifstream->seekg( -sizeof( FileEndRecord ), std::ios::end );
  *m_ifstream >> m_fileEndRecord;
  m_ifstream->seekg( p );
}
 
RawDataMining::~RawDataMining() { delete m_ifstream; }
 
uint32_t* RawDataMining::nextEvent()
{
  try {
    *m_ifstream >> m_dataSeparatorRecord;
  }
  catch ( ReachEndOfFile& e ) {
    //makeEndRecord(m_dataSeparatorRecord, *m_ifstream, m_fileEndRecord);
    m_eof = true;
    return nullptr;
  }
  catch ( ... ) {
    std::cerr << "Error: invalid data in file " << m_fname << std::endl;
    return nullptr;
  }
 
  uint32_t size = m_dataSeparatorRecord.getRecord().data_block_size;
  if ( size > m_cache->capacity() ) {
      uint32_t _capacity = m_cache->capacity();
      do {
          _capacity *= 2;
      } while ( size > _capacity );
      m_cache->reserve<char>(_capacity);
  }
 
  uint32_t* dptr = m_cache->data<uint32_t>();
 
  m_ifstream->read(reinterpret_cast<char*>(dptr), size);
 
  if ( dptr[0] != 0xaa1234aa ) {
      std::cerr << "Error: wrong event marker" << std::endl;
      dptr = nullptr;
  }
 
  return dptr;
}
 
void RawDataMining::dump() {
  m_ifstream->fileStartRecord().dump();
  m_ifstream->fileNameStrings().dump();
  m_ifstream->runParametersRecord().dump();
  //m_dataSeparatorRecord.dump();
  m_fileEndRecord.dump();
}