PthrReaderBufPool< Reader, PoolSize > Class Template Reference

#include <PthrReaderBufPool.h>

Inheritance diagram for PthrReaderBufPool< Reader, PoolSize >:

Public Member Functions
	PthrReaderBufPool (typename Reader::ReaderArgType &arg)
virtual	~PthrReaderBufPool ()
const uint32_t *	nextEvent ()
const uint32_t *	currentEvent () const
uint32_t	runNo ()
std::string	currentFile ()
uint32_t	stat ()
	PthrReaderBufPool (typename Reader::ReaderArgType &arg)
virtual	~PthrReaderBufPool ()
const uint32_t *	nextEvent ()
const uint32_t *	currentEvent () const
uint32_t	runNo ()
std::string	currentFile ()
uint32_t	stat ()
Public Member Functions inherited from IRawReader
virtual	~IRawReader ()
virtual const uint32_t *	nextEvent ()=0
virtual const uint32_t *	currentEvent () const =0
virtual uint32_t	runNo ()=0
virtual std::string	currentFile ()=0
virtual uint32_t	stat ()=0
virtual	~IRawReader ()
virtual const uint32_t *	nextEvent ()=0
virtual const uint32_t *	currentEvent () const =0
virtual uint32_t	runNo ()=0
virtual std::string	currentFile ()=0
virtual uint32_t	stat ()=0

Detailed Description

template<typename Reader, int PoolSize = 8>
class PthrReaderBufPool< Reader, PoolSize >

Definition at line 13 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/PthrReaderBufPool.h.

Constructor & Destructor Documentation

PthrReaderBufPool() [1/2]

template<typename Reader , int PoolSize>

PthrReaderBufPool< Reader, PoolSize >::PthrReaderBufPool

(

typename Reader::ReaderArgType &

arg

)

Definition at line 19 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrReaderBufPool.cc.

   : m_inLoop(-1),
     m_outLoop(-1),
     m_RawFileException(0)
{
   if ( PoolSize < 2 ) {
      std::cout << "[PthrReaderBufPool] The PoolSize of buffer must > 1" << std::endl;
      exit(1);
   }
 
   // use(PoolSize-1) to protect the current event buffer
   sem_init(&m_semIn,  0, (PoolSize-1));
   sem_init(&m_semOut, 0, 0);
   pthread_mutex_init(&m_lock, NULL);
 
   sem_init(&m_semSyn, 0, 0);
 
   for ( int i = 0; i < PoolSize; ++i ) {
      // buffer in the loop for each event
      m_buf[i] = new AutoEnlargeBuffer(128*1024);
   }
 
   m_reader = new Reader(arg);
 
   // create an individual thread to fill to buffer
   pthread_create(&m_tid, NULL, thread_filling, (void*)this);
}

~PthrReaderBufPool() [1/2]

template<typename Reader , int PoolSize>

PthrReaderBufPool< Reader, PoolSize >::~PthrReaderBufPool

virtual

Definition at line 48 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrReaderBufPool.cc.

{
   for ( int i = 0; i < PoolSize; ++i ) {
      delete m_buf[i];
   }
 
   delete m_RawFileException;
 
   sem_destroy(&m_semIn);
   sem_destroy(&m_semOut);
 
   delete m_reader;
}

PthrReaderBufPool() [2/2]

template<typename Reader , int PoolSize = 8>

PthrReaderBufPool< Reader, PoolSize >::PthrReaderBufPool

(

typename Reader::ReaderArgType &

arg

)

~PthrReaderBufPool() [2/2]

template<typename Reader , int PoolSize = 8>

virtual PthrReaderBufPool< Reader, PoolSize >::~PthrReaderBufPool ( )

virtual

Member Function Documentation

currentEvent() [1/2]

template<typename Reader , int PoolSize>

const uint32_t * PthrReaderBufPool< Reader, PoolSize >::currentEvent

inlinevirtual

Implements IRawReader.

Definition at line 92 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrReaderBufPool.cc.

{
   //can't be called before any nextEvent() call
   const uint32_t* pevt = (uint32_t*)m_buf[ m_outLoop%PoolSize ]->data();
   return pevt;
}

currentEvent() [2/2]

template<typename Reader , int PoolSize = 8>

const uint32_t * PthrReaderBufPool< Reader, PoolSize >::currentEvent ( ) const

inlinevirtual

Implements IRawReader.

currentFile() [1/2]

template<typename Reader , int PoolSize>

std::string PthrReaderBufPool< Reader, PoolSize >::currentFile

inlinevirtual

Implements IRawReader.

Definition at line 106 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrReaderBufPool.cc.

{
   return m_reader->currentFile();
}

Referenced by main().

currentFile() [2/2]

template<typename Reader , int PoolSize = 8>

std::string PthrReaderBufPool< Reader, PoolSize >::currentFile ( )

inlinevirtual

Implements IRawReader.

nextEvent() [1/2]

template<typename Reader , int PoolSize>

const uint32_t * PthrReaderBufPool< Reader, PoolSize >::nextEvent

inlinevirtual

Implements IRawReader.

Definition at line 63 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrReaderBufPool.cc.

{
   if ( m_outLoop < 0 ) sem_post(&m_semSyn);
 
   // the ahead event buffer is ready for update now
   sem_post(&m_semIn);
   // waiting for a ready to use event
   sem_wait(&m_semOut);
 
   pthread_mutex_lock(&m_lock);
   int inLoop = m_inLoop;
   pthread_mutex_unlock(&m_lock);
 
   if ( m_RawFileException != 0 && m_outLoop >= inLoop ) {
      if ( dynamic_cast<RawExMessage*>(m_RawFileException) ) {
     throw RawExMessage(*(RawExMessage*)m_RawFileException);
      }
      if ( dynamic_cast<ReachEndOfFileList*>(m_RawFileException) ) {
     throw ReachEndOfFileList(*(ReachEndOfFileList*)m_RawFileException);
      }
   }
 
   ++m_outLoop;
 
   const uint32_t* pevt = (uint32_t*)m_buf[ m_outLoop%PoolSize ]->data();
   return pevt;
}

Referenced by main().

nextEvent() [2/2]

template<typename Reader , int PoolSize = 8>

const uint32_t * PthrReaderBufPool< Reader, PoolSize >::nextEvent ( )

inlinevirtual

Implements IRawReader.

runNo() [1/2]

template<typename Reader , int PoolSize>

uint32_t PthrReaderBufPool< Reader, PoolSize >::runNo

inlinevirtual

Implements IRawReader.

Definition at line 100 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrReaderBufPool.cc.

{
   return m_reader->runNo();
}

runNo() [2/2]

template<typename Reader , int PoolSize = 8>

uint32_t PthrReaderBufPool< Reader, PoolSize >::runNo ( )

inlinevirtual

Implements IRawReader.

stat() [1/2]

template<typename Reader , int PoolSize>

uint32_t PthrReaderBufPool< Reader, PoolSize >::stat

inlinevirtual

Implements IRawReader.

Definition at line 112 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrReaderBufPool.cc.

{
   return m_reader->stat();
}

stat() [2/2]

template<typename Reader , int PoolSize = 8>

uint32_t PthrReaderBufPool< Reader, PoolSize >::stat ( )

inlinevirtual

Implements IRawReader.

---

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

• DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/PthrReaderBufPool.h
• InstallArea/include/DistBossUtil/DistBossUtil/PthrReaderBufPool.h
• DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrReaderBufPool.cc
• InstallArea/include/DistBossUtil/DistBossUtil/template/PthrReaderBufPool.cc