Event/RawFile/include/RawFile/raw_ifstream.h

Go to the documentation of this file.

#ifndef BESIII_RAW_IFSTREAM_H
#define BESIII_RAW_IFSTREAM_H
 
#include "RawFile/RawFileUtil.h"
#include <assert.h>
#include <fstream>
#include <pthread.h>
#include <stdint.h>
#include <string>
#include <vector>
 
class raw_ifstream : virtual public std::ifstream {
public:
  static raw_ifstream* instance( const std::vector<std::string>& fnames );
  static void          release();
 
  static void lock() {
    int lstat = pthread_mutex_lock( &_pthread_lock );
    assert( lstat == 0 );
  };
  static void unlock() {
    int lstat = pthread_mutex_unlock( &_pthread_lock );
    assert( lstat == 0 );
  };
 
  std::string currentFile() const { return *m_curFile; }
 
  void next_file();
 
  uint32_t runNo();
 
  raw_ifstream( const std::vector<std::string>& fnames );
  virtual ~raw_ifstream();
 
  FileStartRecord& fileStartRecord() { return m_fileStartRecord; }
  FileNameStrings& fileNameStrings() { return m_fileNameStrings; }
  RunParametersRecord& runParametersRecord() { return m_runParametersRecord; }
 
private:
  void init_fstream();
 
  raw_ifstream(); // stop default
 
private:
  bool m_isOpen;
 
  FileStartRecord     m_fileStartRecord;
  FileNameStrings     m_fileNameStrings;
  RunParametersRecord m_runParametersRecord;
 
  std::vector<std::string>           m_fnames;
  std::vector<std::string>::iterator m_curFile;
 
  static int             _nHandler;
  static raw_ifstream*   _instance;
  static pthread_mutex_t _pthread_lock;
};
 
#endif