raw_ifstream.cxx

Go to the documentation of this file.

#include "RawFile/raw_ifstream.h"
#include "IRawFile/RawFileExceptions.h"
#include <cstdio>
#include <cstdlib>
#include <string>
#include <unistd.h>
using namespace std;
 
// static data members
int             raw_ifstream::_nHandler     = 0;
raw_ifstream*   raw_ifstream::_instance     = 0;
pthread_mutex_t raw_ifstream::_pthread_lock = PTHREAD_MUTEX_INITIALIZER;
 
raw_ifstream* raw_ifstream::instance( const std::vector<std::string>& fnames ) {
  lock();
 
  if ( _instance == 0 ) { _instance = new raw_ifstream( fnames ); }
 
  ++_nHandler;
 
  unlock();
 
  return _instance;
}
 
void raw_ifstream::release() {
  lock();
 
  if ( _nHandler > 0 && --_nHandler == 0 )
  {
    if ( _instance->m_isOpen )
    {
      std::cout << "[RawFile] Closing: " << *( _instance->m_curFile ) << std::endl;
      _instance->close();
    }
    delete _instance;
    _instance = 0;
  }
 
  unlock();
}
 
raw_ifstream::raw_ifstream( const std::vector<std::string>& fnames )
    : m_isOpen( false ), m_fnames( fnames ) {
  if ( m_fnames.empty() ) { throw RawExMessage( "[RawFile] Empty input file list!" ); }
 
  m_curFile = m_fnames.begin();
  init_fstream();
}
 
raw_ifstream::~raw_ifstream() {}
 
void raw_ifstream::next_file() {
  std::cout << "[RawFile] Closing: " << *m_curFile << std::endl;
  close();
  m_isOpen = false;
 
  if ( ++m_curFile == m_fnames.end() )
  {
    --m_curFile;
    throw ReachEndOfFileList();
  }
 
  init_fstream();
}
 
uint32_t raw_ifstream::runNo() { return m_runParametersRecord.getRecord().run_number; }
 
void raw_ifstream::init_fstream() {
  if ( access( m_curFile->c_str(), F_OK ) < 0 )
  {
    std::cerr << "[RawFile] Invalid file: " << *m_curFile << std::endl;
    exit( 1 );
  }
 
  std::cout << "[RawFile] Prepare for reading: " << *m_curFile << std::endl;
 
  open( m_curFile->c_str(), std::ios::binary );
  m_isOpen = true;
 
  try
  {
    ( *this ) >> m_fileStartRecord >> m_fileNameStrings >> m_runParametersRecord;
  } catch ( RawFileException& e )
  {
    e.print();
    exit( 1 );
  }
}