RawFileReader Class Reference

#include <RawFileReader.h>

Inheritance diagram for RawFileReader:

List of all members.

Public Types
typedef const VFileNames_t	ReaderArgType
Public Member Functions
	RawFileReader (const std::string &fname)
	RawFileReader (const VFileNames_t &fnames)
	RawFileReader (const std::string &fname, const std::string &idxfname)
	RawFileReader (const VFileNames_t &fnames, const VFileNames_t &idxfnames)
virtual	~RawFileReader ()
const uint32_t *	nextEvent ()
const uint32_t *	currentEvent () const
const uint32_t *	nextEvent (int nIgnore)
const uint32_t *	findEventById (uint32_t evtId)
const uint32_t *	roughlyNextEvent (int nIgnore, int evtByte=0)
uint32_t	runNo ()
std::string	currentFile ()
uint32_t	tellg ()
uint32_t	stat ()
Static Public Member Functions
static std::vector< int >	getEventNumber (const VFileNames_t &idxfnames)
Private Member Functions
const uint32_t *	notSafeNextEvent ()
void	read_one_event ()
RawFileReader &	nextFile (RawFileException &e)
	RawFileReader ()
Private Attributes
uint32_t	m_bufferSize
uint32_t *	m_buffer
raw_ifstream *	m_rfs
EvtIdxHandler *	m_idxHandler
DataSeparatorRecord	m_dataSeparatorRecord

---

Detailed Description

Definition at line 16 of file RawFileReader.h.

---

Member Typedef Documentation

typedef const VFileNames_t RawFileReader::ReaderArgType

Definition at line 20 of file RawFileReader.h.

---

Constructor & Destructor Documentation

RawFileReader::RawFileReader

(

const std::string &

fname

)

Definition at line 38 of file RawFileReader.cxx.

References raw_ifstream::instance(), m_rfs, and RawFileTools::wildcard_correct().

   : m_bufferSize(DefaultEventBufferSize),
     m_buffer( new uint32_t[DefaultEventBufferSize] ),
     m_idxHandler(0)
{
   const VFileNames_t newfnames = RawFileTools::wildcard_correct(fname);

   m_rfs =  raw_ifstream::instance(newfnames);
}

RawFileReader::RawFileReader

(

const VFileNames_t &

fnames

)

Definition at line 48 of file RawFileReader.cxx.

References raw_ifstream::instance(), m_rfs, and RawFileTools::wildcard_correct().

   : m_bufferSize(DefaultEventBufferSize),
     m_buffer( new uint32_t[DefaultEventBufferSize] ),
     m_idxHandler(0)
{
   const VFileNames_t newfnames = RawFileTools::wildcard_correct(fnames);

   m_rfs =  raw_ifstream::instance(newfnames);
}

RawFileReader::RawFileReader	(	const std::string &	fname,
		const std::string &	idxfname
	)

Definition at line 58 of file RawFileReader.cxx.

References EvtIdxHandler::instance(), raw_ifstream::instance(), m_idxHandler, m_rfs, and RawFileTools::wildcard_correct().

   : m_bufferSize(DefaultEventBufferSize),
     m_buffer( new uint32_t[DefaultEventBufferSize] )
{
   const VFileNames_t newfnames    = RawFileTools::wildcard_correct(fname);
   const VFileNames_t newidxfnames = RawFileTools::wildcard_correct(idxfname);

   if ( newidxfnames.size() != newfnames.size() ) {
      std::cerr << "[RawFile] Num(IdxFiles) != Num(DataFiles)" << std::endl;
      exit(1);
   }

   m_rfs =  raw_ifstream::instance(newfnames);
   m_idxHandler = EvtIdxHandler::instance(newidxfnames);
}

RawFileReader::RawFileReader	(	const VFileNames_t &	fnames,
		const VFileNames_t &	idxfnames
	)

Definition at line 74 of file RawFileReader.cxx.

References EvtIdxHandler::instance(), raw_ifstream::instance(), m_idxHandler, m_rfs, and RawFileTools::wildcard_correct().

   : m_bufferSize(DefaultEventBufferSize),
     m_buffer( new uint32_t[DefaultEventBufferSize] )
{
   const VFileNames_t newfnames    = RawFileTools::wildcard_correct(fnames);
   const VFileNames_t newidxfnames = RawFileTools::wildcard_correct(idxfnames);

   if ( newidxfnames.size() != newfnames.size() ) {
      std::cerr << "[RawFile] Num(IdxFiles) != Num(DataFiles)" << std::endl;
      exit(1);
   }

   m_rfs =  raw_ifstream::instance(newfnames);
   m_idxHandler = EvtIdxHandler::instance(newidxfnames);
}

RawFileReader::~RawFileReader

(

)

[virtual]

Definition at line 90 of file RawFileReader.cxx.

References m_buffer, EvtIdxHandler::release(), and raw_ifstream::release().

{
   delete[] m_buffer;
   raw_ifstream::release();
   EvtIdxHandler::release();
}

RawFileReader::RawFileReader

(

)

[private]

---

Member Function Documentation

const uint32_t* RawFileReader::currentEvent

(

)

const [inline, virtual]

Implements IRawReader.

Definition at line 33 of file RawFileReader.h.

References m_buffer.

Referenced by MixerAlg::nextEvent().

{ return m_buffer; }

std::string RawFileReader::currentFile

(

)

[virtual]

Implements IRawReader.

Definition at line 229 of file RawFileReader.cxx.

References raw_ifstream::currentFile(), and m_rfs.

Referenced by findEventById(), main(), nextEvent(), and roughlyNextEvent().

{
   return m_rfs->currentFile();
}

const uint32_t * RawFileReader::findEventById

(

uint32_t

evtId

)

Definition at line 155 of file RawFileReader.cxx.

References EvtCyclic3::c_str(), currentFile(), findEventById(), EvtIdxHandler::findPosById(), m_buffer, m_idxHandler, m_rfs, nextFile(), boss::pos, and read_one_event().

Referenced by findEventById(), and main().

{
   // not thread safe !!!
   // find an event by ID ( only backward !!! )
   try {
      if ( m_idxHandler == 0 ) {
         while ( true ) {
            read_one_event();
            uint32_t curEvtId = m_buffer[ m_buffer[5] + 8 ];
            if ( curEvtId == evtId ) {
               break;
            }
         }
      }
      else {
         uint32_t pos = m_idxHandler->findPosById( evtId );
         if ( pos != 0 ) {
            m_rfs->seekg( pos );
            read_one_event();
         }
         else {
            throw ReachEndOfFile( currentFile().c_str() );
         }
      }
   }
   catch (RawFileException& e) {
      return nextFile(e).findEventById(evtId);
   }

   return m_buffer;
}

std::vector< int > RawFileReader::getEventNumber

(

const VFileNames_t &

idxfnames

)

[static]

Definition at line 11 of file RawFileReader.cxx.

References EvtIdxHandler::IdxFileStartMarker(), and RawFileTools::wildcard_correct().

Referenced by MixerAlg::execute().

{
   uint32_t itmp[2];
   std::vector<int> vNevt;

   const VFileNames_t newfnames = RawFileTools::wildcard_correct(idxfnames);
   VFileNames_t::const_iterator it = newfnames.begin();
   while ( it != newfnames.end() ) {
      if ( access( it->c_str(), F_OK ) < 0 ) {
         std::cerr << "[RawFile] Invalid IDX file: " << *it << std::endl;
         exit(1);
      }

      std::ifstream fs( it->c_str(), std::ios::binary );

      fs.read( (char*)(itmp), sizeof(uint32_t)*2 );
      if ( itmp[0] != EvtIdxHandler::IdxFileStartMarker() ) {
         std::cerr << "[RawFile] Wrong IdxFileStartMarker!" << std::endl;
         exit(1);
      }
      vNevt.push_back(itmp[1]);
      ++it;
   }

   return vNevt;
}

const uint32_t * RawFileReader::nextEvent

(

int

nIgnore

)

Definition at line 120 of file RawFileReader.cxx.

References EvtCyclic3::c_str(), currentFile(), m_buffer, m_dataSeparatorRecord, m_idxHandler, m_rfs, EvtIdxHandler::nEvtLeft(), nextEvent(), nextFile(), EvtIdxHandler::nextPos(), read_one_event(), and delete_small_size::size.

{
   // not thread safe !!!
   int nnIgnore = nIgnore;

   try {
      if ( m_idxHandler != 0 ) {
         int nleft = m_idxHandler->nEvtLeft(nnIgnore);
         if ( nleft > 0 ) {
            m_rfs->seekg( m_idxHandler->nextPos( nnIgnore ) );
            nnIgnore = 0;
         }
         else {
            nnIgnore = -nleft;
            throw ReachEndOfFile( currentFile().c_str() );
         }
      }
      else {
         while ( nnIgnore > 0 ) {
            (*m_rfs) >> m_dataSeparatorRecord;
            uint32_t size = m_dataSeparatorRecord.getRecord().data_block_size;
            m_rfs->seekg( size + m_rfs->tellg() );
            --nnIgnore;
         }
      }

      read_one_event();
   }
   catch (RawFileException& e) {
      nextFile(e).nextEvent(nnIgnore);
   }

   return m_buffer;
}

const uint32_t * RawFileReader::nextEvent

(

)

[virtual]

Implements IRawReader.

Definition at line 97 of file RawFileReader.cxx.

References raw_ifstream::lock(), m_buffer, notSafeNextEvent(), RawFileException::print(), and raw_ifstream::unlock().

Referenced by main(), MixerAlg::nextEvent(), nextEvent(), and RawEventReader::readEvent().

{
   // thread safe
   raw_ifstream::lock();

   try {
      notSafeNextEvent();
   }
   catch ( ReachEndOfFileList& e) {
      raw_ifstream::unlock();
      throw e;
   }
   catch ( RawFileException& e) {
      raw_ifstream::unlock();
      e.print();
      throw e;
   }

   raw_ifstream::unlock();

   return m_buffer;
}

RawFileReader & RawFileReader::nextFile

(

RawFileException &

e

)

[private]

Definition at line 282 of file RawFileReader.cxx.

References m_idxHandler, m_rfs, EvtIdxHandler::next_file(), raw_ifstream::next_file(), and RawFileException::print().

Referenced by findEventById(), nextEvent(), notSafeNextEvent(), and roughlyNextEvent().

{
   e.print();

   m_rfs->clear();
   m_rfs->next_file();

   if ( m_idxHandler != 0 ) {
      m_idxHandler->next_file();
   }

   return *this;
}

const uint32_t * RawFileReader::notSafeNextEvent

(

)

[private]

Definition at line 250 of file RawFileReader.cxx.

References m_buffer, nextFile(), notSafeNextEvent(), and read_one_event().

Referenced by nextEvent(), and notSafeNextEvent().

{
   try {
      read_one_event();
   }
   catch (RawFileException& e) {
      nextFile(e).notSafeNextEvent();
   }

   return m_buffer;
}

void RawFileReader::read_one_event

(

)

[private]

Definition at line 262 of file RawFileReader.cxx.

References m_buffer, m_bufferSize, m_dataSeparatorRecord, m_rfs, and delete_small_size::size.

Referenced by findEventById(), nextEvent(), notSafeNextEvent(), and roughlyNextEvent().

{
   (*m_rfs) >> m_dataSeparatorRecord;

   uint32_t size = m_dataSeparatorRecord.getRecord().data_block_size;
   if ( size > m_bufferSize*4 ) {
      while ( size > m_bufferSize*4 ) {
         m_bufferSize *= 2;
      }
      delete[] m_buffer;
      m_buffer = new uint32_t[m_bufferSize];
   }

   m_rfs->read((char*)m_buffer, size);
   if ( ! m_rfs->good() ) {
      //std::cerr << "[RawFile] Failed to read FullEventFragment to buffer" << std::endl;
      throw BadInputStream("event_data_block");
   }
}

const uint32_t * RawFileReader::roughlyNextEvent	(	int	nIgnore,
		int	evtByte = 0
	)

Definition at line 187 of file RawFileReader.cxx.

References EvtCyclic3::c_str(), currentFile(), deljobs::end, EstimatedEventSize, genRecEmupikp::i, m_buffer, m_rfs, nextFile(), read_one_event(), and roughlyNextEvent().

Referenced by MixerAlg::nextEvent(), and roughlyNextEvent().

{
   // not thread safe !!!
   if ( evtByte == 0 ) evtByte = EstimatedEventSize;

   assert( (evtByte&3) == 0 );

   uint32_t prePos = m_rfs->tellg();
   m_rfs->seekg( prePos + nIgnore*evtByte);

   uint32_t halfEvtWord = evtByte / 8;
   uint32_t halfEvtByte = halfEvtWord * 4;

   while ( m_rfs->read((char*)m_buffer, halfEvtByte).good() ) {
      uint32_t i = 0;
      while ( i < halfEvtWord && m_buffer[i] != 0x1234cccc ) {
         ++i;
      }
      if ( i < halfEvtWord ) {
         uint32_t curPos = m_rfs->tellg();
         m_rfs->seekg( curPos - (halfEvtWord-i)*4 );
         read_one_event();
         return m_buffer;
      }
   }

   // reached the end of current data file! m_rfs->eof()
   m_rfs->clear();
   m_rfs->seekg( -40, std::ios::end );  //sizeof(FileEndRecord) == 40
   uint32_t curPos = m_rfs->tellg();

   int nnIgnore = nIgnore - (curPos - prePos) / evtByte;
   if ( nnIgnore < 0 ) nnIgnore = 0;

   ReachEndOfFile e( currentFile().c_str() );
   return nextFile(e).roughlyNextEvent(nnIgnore, evtByte);
}

uint32_t RawFileReader::runNo

(

)

[virtual]

Implements IRawReader.

Definition at line 224 of file RawFileReader.cxx.

References m_rfs, and raw_ifstream::runNo().

{
    return m_rfs->runNo();
}

uint32_t RawFileReader::stat

(

)

[virtual]

Implements IRawReader.

Definition at line 239 of file RawFileReader.cxx.

References m_rfs.

{
   uint32_t stat = 0;

   if ( m_rfs->eof() )  stat |= 1;
   if ( m_rfs->fail() ) stat |= 2;
   if ( m_rfs->bad() )  stat |= 4;

   return stat;
}

uint32_t RawFileReader::tellg

(

)

Definition at line 234 of file RawFileReader.cxx.

References m_rfs.

Referenced by main().

{
   return m_rfs->tellg();
}

---

Member Data Documentation

uint32_t* RawFileReader::m_buffer [private]

Definition at line 60 of file RawFileReader.h.

Referenced by currentEvent(), findEventById(), nextEvent(), notSafeNextEvent(), read_one_event(), roughlyNextEvent(), and ~RawFileReader().

uint32_t RawFileReader::m_bufferSize [private]

Definition at line 59 of file RawFileReader.h.

Referenced by read_one_event().

DataSeparatorRecord RawFileReader::m_dataSeparatorRecord [private]

Definition at line 65 of file RawFileReader.h.

Referenced by nextEvent(), and read_one_event().

EvtIdxHandler* RawFileReader::m_idxHandler [private]

Definition at line 63 of file RawFileReader.h.

Referenced by findEventById(), nextEvent(), nextFile(), and RawFileReader().

raw_ifstream* RawFileReader::m_rfs [private]

Definition at line 62 of file RawFileReader.h.

Referenced by currentFile(), findEventById(), nextEvent(), nextFile(), RawFileReader(), read_one_event(), roughlyNextEvent(), runNo(), stat(), and tellg().

---