PthrWriterBufPool< Writer, PoolSize > Class Template Reference

#include <PthrWriterBufPool.h>

Inheritance diagram for PthrWriterBufPool< Writer, PoolSize >:

Public Member Functions
	PthrWriterBufPool (typename Writer::WriterArgType &arg)
virtual	~PthrWriterBufPool ()
int	writeEvent (void *pevt, int size)
int	stat ()

Detailed Description

template<typename Writer, int PoolSize = 8>
class PthrWriterBufPool< Writer, PoolSize >

Definition at line 11 of file PthrWriterBufPool.h.

Constructor & Destructor Documentation

PthrWriterBufPool()

template<typename Writer , int PoolSize>

PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool

(

typename Writer::WriterArgType &

arg

)

Definition at line 19 of file PthrWriterBufPool.cc.

   : m_inLoop(-1),
     m_outLoop(-1)
{
   if ( PoolSize < 2 ) {
      std::cout << "[PthrWriterBufPool] 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);
   sem_init(&m_semFinalize, 0, 0);
 
   for ( int i = 0; i < PoolSize; ++i ) {
      // buffer in the loop for each event
      m_buf[i] = new AutoEnlargeBuffer(128*1024);
   }
 
   m_writer = new Writer(arg);
 
   // create an individual thread for writing
   pthread_create(&m_tid, NULL, thread_writing, (void*)this);
}

~PthrWriterBufPool()

template<typename Writer , int PoolSize>

PthrWriterBufPool< Writer, PoolSize >::~PthrWriterBufPool ( )

virtual

Definition at line 45 of file PthrWriterBufPool.cc.

{
   // wait for the end of thread_writing
   sem_wait(&m_semFinalize);
 
   for ( int i = 0; i < PoolSize; ++i ) {
      delete m_buf[i];
   }
 
   sem_destroy(&m_semIn);
   sem_destroy(&m_semOut);
   sem_destroy(&m_semFinalize);
 
   delete m_writer;
}

Member Function Documentation

stat()

template<typename Writer , int PoolSize>

int PthrWriterBufPool< Writer, PoolSize >::stat ( )

virtual

Implements IRawWriter.

Definition at line 78 of file PthrWriterBufPool.cc.

{
   return m_writer->stat();
}

writeEvent()

template<typename Writer , int PoolSize>

int PthrWriterBufPool< Writer, PoolSize >::writeEvent ( void * pevt, int size )

virtual

Implements IRawWriter.

Definition at line 62 of file PthrWriterBufPool.cc.

{
   if ( m_writer->stat() != 0 ) return m_writer->stat();
 
   sem_wait(&m_semIn);
 
   int index = (++m_inLoop) % PoolSize;
 
   m_buf[index]->copy( pevt, size );
 
   sem_post(&m_semOut);
 
   return 0;
}

Referenced by EventWriter::execute(), EventWriter::finalize(), and EventWriter::initialize().

---

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

• PthrWriterBufPool.h
• PthrWriterBufPool.cc