raw_ofstream Class Reference

#include <raw_ofstream.h>

List of all members.

Public Member Functions
void	close ()
void	close ()
int	write_event (const char *pbuf, int size)
int	write_event (const char *pbuf, int size)
Static Public Member Functions
raw_ofstream *	instance (const std::string &fname)
raw_ofstream *	instance (const std::string &fname)
void	lock ()
void	lock ()
void	release ()
void	release ()
void	unlock ()
void	unlock ()
Private Member Functions
void	init_fstream ()
void	init_fstream ()
	raw_ofstream ()
	raw_ofstream (const std::string &fname)
	raw_ofstream ()
	raw_ofstream (const std::string &fname)
std::string	real_fname ()
std::string	real_fname ()
virtual	~raw_ofstream ()
virtual	~raw_ofstream ()
Private Attributes
DataSeparatorRecord	m_dataSeparatorRecord
FileEndRecord	m_fileEndRecord
FileNameStrings	m_fileNameStrings
FileStartRecord	m_fileStartRecord
std::string	m_fname
int	m_nevt
int	m_nfile
RunParametersRecord	m_runParametersRecord
Static Private Attributes
raw_ofstream *	_instance
raw_ofstream *	_instance = 0
int	_nHandler = 0
pthread_mutex_t	_pthread_lock = PTHREAD_MUTEX_INITIALIZER

---

Constructor & Destructor Documentation

raw_ofstream::raw_ofstream (  const std::string &  fname  )  [private]

: m_nevt(0), m_nfile(0), m_fname(fname) { init_fstream(); }

raw_ofstream::~raw_ofstream (   )  [private, virtual]

{ this->close(); }

raw_ofstream::raw_ofstream (   )  [private]

raw_ofstream::raw_ofstream (  const std::string &  fname  )  [private]

virtual raw_ofstream::~raw_ofstream (   )  [private, virtual]

raw_ofstream::raw_ofstream (   )  [private]

---

Member Function Documentation

void raw_ofstream::close (   )

void raw_ofstream::close (   )

{ if ( is_open() ) { m_fileEndRecord.setEventsInFile(m_nevt); m_nevt = 0; (*this) << m_fileEndRecord; std::ofstream::close(); std::cout << "[RawFile] Finished writing file: " << real_fname() << std::endl; } }

void raw_ofstream::init_fstream (   )  [private]

void raw_ofstream::init_fstream (   )  [private]

{ ++m_nfile; std::string fname = real_fname(); if ( access( fname.c_str(), F_OK ) == 0 ) { std::cerr << "[RawFile] Attempt to create an exist file: " << fname << std::endl; exit(1); } std::cout << "[RawFile] Creating a new file: " << real_fname() << std::endl; open( fname.c_str(), std::ios::binary ); (*this) << m_fileStartRecord << m_fileNameStrings << m_runParametersRecord; }

raw_ofstream* raw_ofstream::instance (  const std::string &  fname  )  [static]

raw_ofstream * raw_ofstream::instance (  const std::string &  fname  )  [static]

{ lock(); if ( _instance == 0 ) { _instance = new raw_ofstream(fname); } ++_nHandler; unlock(); return _instance; }

void raw_ofstream::lock (   )  [inline, static]

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

void raw_ofstream::lock (   )  [inline, static]

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

std::string raw_ofstream::real_fname (   )  [private]

std::string raw_ofstream::real_fname (   )  [private]

{ std::string fname = m_fname; if ( m_nfile > 1 ) { fname += ".part" + RawFileTools::itoa( m_nfile ); } return fname; }

void raw_ofstream::release (   )  [static]

void raw_ofstream::release (   )  [static]

{ lock(); if ( _nHandler > 0 && --_nHandler == 0 ) { delete _instance; _instance = 0; } unlock(); }

void raw_ofstream::unlock (   )  [inline, static]

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

void raw_ofstream::unlock (   )  [inline, static]

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

int raw_ofstream::write_event (  const char *  pbuf, int  size )

int raw_ofstream::write_event (  const char *  pbuf, int  size )

{ uint32_t fsize = tellp(); if ( fsize >= MAX_RAWFILE_SiZE ) { this->close(); init_fstream(); } m_dataSeparatorRecord.setDataBlockNumber(++m_nevt); m_dataSeparatorRecord.setDataBlockSize(size); (*this) << m_dataSeparatorRecord; std::ofstream::write(pbuf, size); return m_nfile; }

---

Member Data Documentation

raw_ofstream* raw_ofstream::_instance [static, private]

raw_ofstream * raw_ofstream::_instance = 0 [static, private]

int raw_ofstream::_nHandler = 0 [static, private]

pthread_mutex_t raw_ofstream::_pthread_lock = PTHREAD_MUTEX_INITIALIZER [static, private]

DataSeparatorRecord raw_ofstream::m_dataSeparatorRecord [private]

FileEndRecord raw_ofstream::m_fileEndRecord [private]

FileNameStrings raw_ofstream::m_fileNameStrings [private]

FileStartRecord raw_ofstream::m_fileStartRecord [private]

std::string raw_ofstream::m_fname [private]

int raw_ofstream::m_nevt [private]

int raw_ofstream::m_nfile [private]

RunParametersRecord raw_ofstream::m_runParametersRecord [private]

---

The documentation for this class was generated from the following files:

• /data0/mdestefa/bes3soft/Boss_6.5.5/dist/6.5.5/Event/RawFile/RawFile-00-00-04/RawFile/raw_ofstream.h
• /data0/mdestefa/bes3soft/Boss_6.5.5/dist/6.5.5/InstallArea/include/RawFile/RawFile/raw_ofstream.h
• /data0/mdestefa/bes3soft/Boss_6.5.5/dist/6.5.5/Event/RawFile/RawFile-00-00-04/src/raw_ofstream.cxx

---