#include <raw_ifstream.h>

Inheritance diagram for raw_ifstream:

Public Member Functions
std::string	currentFile () const

void	next_file ()

uint32_t	runNo ()

	raw_ifstream (const std::vector< std::string > &fnames)

virtual	~raw_ifstream ()

Static Public Member Functions
static raw_ifstream *	instance (const std::vector< std::string > &fnames)

static void	release ()

static void	lock ()

static void	unlock ()

Detailed Description

Definition at line 13 of file raw_ifstream.h.

Constructor & Destructor Documentation

◆ raw_ifstream()

raw_ifstream::raw_ifstream ( const std::vector< std::string > & fnames )

Definition at line 42 of file raw_ifstream.cxx.

   : m_isOpen(false), m_fnames(fnames)
{
   if ( m_fnames.empty() ) {
      throw RawExMessage("[RawFile] Empty input file list!");
   }
 
   m_curFile = m_fnames.begin();
   init_fstream();
}

Referenced by raw_ifstream().

◆ ~raw_ifstream()

raw_ifstream::~raw_ifstream ( )

virtual

Definition at line 53 of file raw_ifstream.cxx.

54{

55}

Member Function Documentation

◆ currentFile()

std::string raw_ifstream::currentFile ( ) const

inline

Definition at line 29 of file raw_ifstream.h.

29{ return *m_curFile; }

Referenced by RawFileReader::currentFile(), GenRdmTrgIdxAlg::execute(), and GenRdmTrgIdxAlg::finalize().

◆ instance()

raw_ifstream * raw_ifstream::instance ( const std::vector< std::string > & fnames )

static

Definition at line 11 of file raw_ifstream.cxx.

{
   lock();
 
   if ( _instance == 0 ) {
      _instance = new raw_ifstream(fnames);
   }
 
   ++_nHandler;
 
   unlock();
 
   return _instance;
}

Referenced by RawFileReader::RawFileReader().

◆ lock()

static void raw_ifstream::lock ( )

inlinestatic

Definition at line 20 of file raw_ifstream.h.

                         {
     int lstat = pthread_mutex_lock( &_pthread_lock );
     assert( lstat == 0 );
      };

Referenced by instance(), RawFileReader::nextEvent(), and release().

◆ next_file()

void raw_ifstream::next_file ( )

Definition at line 57 of file raw_ifstream.cxx.

{
   std::cout << "[RawFile] Closing: " << *m_curFile << std::endl;
   close();
   m_isOpen = false;
 
   if ( ++m_curFile == m_fnames.end() ) {
      --m_curFile;
      throw ReachEndOfFileList();
   }
 
   init_fstream();
}

◆ release()

void raw_ifstream::release ( )

static

Definition at line 26 of file raw_ifstream.cxx.

{
   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();
}

Referenced by RawFileReader::~RawFileReader().

◆ runNo()

uint32_t raw_ifstream::runNo ( )

Definition at line 71 of file raw_ifstream.cxx.

{
    return m_runParametersRecord.getRecord().run_number;
}

Referenced by RawFileReader::runNo().

◆ unlock()

static void raw_ifstream::unlock ( )