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 ()
	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 DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/PthrWriterBufPool.h.

Constructor & Destructor Documentation

PthrWriterBufPool() [1/2]

template<typename Writer , int PoolSize>

PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool

(

typename Writer::WriterArgType &

arg

)

Definition at line 19 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/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() [1/2]

template<typename Writer , int PoolSize>

PthrWriterBufPool< Writer, PoolSize >::~PthrWriterBufPool

virtual

Definition at line 45 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/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;
}

PthrWriterBufPool() [2/2]

template<typename Writer , int PoolSize = 8>

PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool

(

typename Writer::WriterArgType &

arg

)

~PthrWriterBufPool() [2/2]

template<typename Writer , int PoolSize = 8>

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

virtual

Member Function Documentation

stat() [1/2]

template<typename Writer , int PoolSize>

int PthrWriterBufPool< Writer, PoolSize >::stat

virtual

Implements IRawWriter.

Definition at line 78 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/PthrWriterBufPool.cc.

{
   return m_writer->stat();
}

stat() [2/2]

template<typename Writer , int PoolSize = 8>

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

virtual

Implements IRawWriter.

writeEvent() [1/2]

template<typename Writer , int PoolSize>

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

virtual

Implements IRawWriter.

Definition at line 62 of file DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/template/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().

writeEvent() [2/2]

template<typename Writer , int PoolSize = 8>

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

virtual

Implements IRawWriter.

---

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

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