/home/bes3soft/bes3soft/Boss/7.0.2/dist/7.0.2/Event/RawFile/RawFile-00-00-10/src/raw_ifstream.cxx

Go to the documentation of this file.

#include "RawFile/raw_ifstream.h"
#include "IRawFile/RawFileExceptions.h"
#include <cstdlib>

//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);
   }
}

---