PthrWriterBufPool< Writer, PoolSize > Class Template Reference

#include <PthrWriterBufPool.h>

Inheritance diagram for PthrWriterBufPool< Writer, PoolSize >:

List of all members.

Public Member Functions
	PthrWriterBufPool (typename Writer::WriterArgType &arg)
virtual	~PthrWriterBufPool ()
int	writeEvent (void *pevt, int size)
int	stat ()
Private Member Functions
	PthrWriterBufPool ()
Static Private Member Functions
static void *	thread_writing (void *arg)
Private Attributes
int	m_inLoop
int	m_outLoop
AutoEnlargeBuffer *	m_buf [PoolSize]
Writer *	m_writer
pthread_t	m_tid
sem_t	m_semIn
sem_t	m_semOut
sem_t	m_semFinalize

---

Detailed Description

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

Definition at line 11 of file PthrWriterBufPool.h.

---

Constructor & Destructor Documentation

template<typename Writer, int PoolSize>

PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool

(

typename Writer::WriterArgType &

arg

)

Definition at line 19 of file PthrWriterBufPool.cc.

References genRecEmupikp::i, PthrWriterBufPool< Writer, PoolSize >::m_buf, PthrWriterBufPool< Writer, PoolSize >::m_semFinalize, PthrWriterBufPool< Writer, PoolSize >::m_semIn, PthrWriterBufPool< Writer, PoolSize >::m_semOut, PthrWriterBufPool< Writer, PoolSize >::m_tid, PthrWriterBufPool< Writer, PoolSize >::m_writer, and PthrWriterBufPool< Writer, PoolSize >::thread_writing().

   : 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);
}

template<typename Writer, int PoolSize>

PthrWriterBufPool< Writer, PoolSize >::~PthrWriterBufPool

(

)

[virtual]

Definition at line 45 of file PthrWriterBufPool.cc.

References genRecEmupikp::i, PthrWriterBufPool< Writer, PoolSize >::m_buf, PthrWriterBufPool< Writer, PoolSize >::m_semFinalize, PthrWriterBufPool< Writer, PoolSize >::m_semIn, PthrWriterBufPool< Writer, PoolSize >::m_semOut, and PthrWriterBufPool< Writer, PoolSize >::m_writer.

{
   // 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;
}

template<typename Writer, int PoolSize = 8>

PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool

(

)

[private]

---

Member Function Documentation

template<typename Writer, int PoolSize>

int PthrWriterBufPool< Writer, PoolSize >::stat

(

)

[virtual]

Implements IRawWriter.

Definition at line 78 of file PthrWriterBufPool.cc.

References PthrWriterBufPool< Writer, PoolSize >::m_writer.

Referenced by WriterRpc< Writer >::~WriterRpc().

{
   return m_writer->stat();
}

template<typename Writer, int PoolSize>

void * PthrWriterBufPool< Writer, PoolSize >::thread_writing

(

void *

arg

)

[static, private]

Definition at line 84 of file PthrWriterBufPool.cc.

References AutoEnlargeBuffer::data(), PthrWriterBufPool< Writer, PoolSize >::m_buf, PthrWriterBufPool< Writer, PoolSize >::m_outLoop, PthrWriterBufPool< Writer, PoolSize >::m_semFinalize, PthrWriterBufPool< Writer, PoolSize >::m_semIn, PthrWriterBufPool< Writer, PoolSize >::m_semOut, PthrWriterBufPool< Writer, PoolSize >::m_writer, RawExMessage::print(), and AutoEnlargeBuffer::size().

Referenced by PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool().

{
   PthrWriterBufPool<Writer, PoolSize>* pthis = (PthrWriterBufPool<Writer, PoolSize>*)arg;

   uint32_t        index;
   AutoEnlargeBuffer* pbuf;


   while ( true ) {
      // the ahead event buffer is ready for update now
      sem_post(&(pthis->m_semIn));
      // waiting for an event that ready to use
      sem_wait(&(pthis->m_semOut));

      index = (++(pthis->m_outLoop)) % PoolSize;

      pbuf = pthis->m_buf[index];

      try {
         pthis->m_writer->writeEvent( pbuf->data(), pbuf->size() );
      }
      catch (ReachEndOfFileList& e) {
         //std::cout << "[PthrWriterBufPool] Finalized Successfully!" << std::endl;
         break;
      }
      catch (RawExMessage& e) {
         e.print();
         break;
      }
      catch ( ... ) {
         std::cout << "[PthrWriterBufPool] Catch unexpected exception !" << std::endl;
         exit(1);
      }
   }


   pthis->m_writer->close();

   sem_post(&(pthis->m_semFinalize));

   pthread_exit(NULL);
}

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.

References AutoEnlargeBuffer::copy(), PthrWriterBufPool< Writer, PoolSize >::m_buf, PthrWriterBufPool< Writer, PoolSize >::m_inLoop, PthrWriterBufPool< Writer, PoolSize >::m_semIn, PthrWriterBufPool< Writer, PoolSize >::m_semOut, and PthrWriterBufPool< Writer, PoolSize >::m_writer.

Referenced by WriterRpc< Writer >::clearBak(), EventWriter::execute(), EventWriter::finalize(), EventWriter::initialize(), WriterRpc< Writer >::rpcHandler(), and WriterRpc< Writer >::~WriterRpc().

{
   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;
}

---

Member Data Documentation

template<typename Writer, int PoolSize = 8>

AutoEnlargeBuffer* PthrWriterBufPool< Writer, PoolSize >::m_buf[PoolSize] [private]

Definition at line 33 of file PthrWriterBufPool.h.

Referenced by PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool(), PthrWriterBufPool< Writer, PoolSize >::thread_writing(), PthrWriterBufPool< Writer, PoolSize >::writeEvent(), and PthrWriterBufPool< Writer, PoolSize >::~PthrWriterBufPool().

template<typename Writer, int PoolSize = 8>

int PthrWriterBufPool< Writer, PoolSize >::m_inLoop [private]

Definition at line 31 of file PthrWriterBufPool.h.

Referenced by PthrWriterBufPool< Writer, PoolSize >::writeEvent().

template<typename Writer, int PoolSize = 8>

int PthrWriterBufPool< Writer, PoolSize >::m_outLoop [private]

Definition at line 32 of file PthrWriterBufPool.h.

Referenced by PthrWriterBufPool< Writer, PoolSize >::thread_writing().

template<typename Writer, int PoolSize = 8>

sem_t PthrWriterBufPool< Writer, PoolSize >::m_semFinalize [private]

Definition at line 41 of file PthrWriterBufPool.h.

Referenced by PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool(), PthrWriterBufPool< Writer, PoolSize >::thread_writing(), and PthrWriterBufPool< Writer, PoolSize >::~PthrWriterBufPool().

template<typename Writer, int PoolSize = 8>

sem_t PthrWriterBufPool< Writer, PoolSize >::m_semIn [private]

Definition at line 38 of file PthrWriterBufPool.h.

Referenced by PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool(), PthrWriterBufPool< Writer, PoolSize >::thread_writing(), PthrWriterBufPool< Writer, PoolSize >::writeEvent(), and PthrWriterBufPool< Writer, PoolSize >::~PthrWriterBufPool().

template<typename Writer, int PoolSize = 8>

sem_t PthrWriterBufPool< Writer, PoolSize >::m_semOut [private]

Definition at line 39 of file PthrWriterBufPool.h.

Referenced by PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool(), PthrWriterBufPool< Writer, PoolSize >::thread_writing(), PthrWriterBufPool< Writer, PoolSize >::writeEvent(), and PthrWriterBufPool< Writer, PoolSize >::~PthrWriterBufPool().

template<typename Writer, int PoolSize = 8>

pthread_t PthrWriterBufPool< Writer, PoolSize >::m_tid [private]

Definition at line 37 of file PthrWriterBufPool.h.

Referenced by PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool().

template<typename Writer, int PoolSize = 8>

Writer* PthrWriterBufPool< Writer, PoolSize >::m_writer [private]

Definition at line 35 of file PthrWriterBufPool.h.

Referenced by PthrWriterBufPool< Writer, PoolSize >::PthrWriterBufPool(), PthrWriterBufPool< Writer, PoolSize >::stat(), PthrWriterBufPool< Writer, PoolSize >::thread_writing(), PthrWriterBufPool< Writer, PoolSize >::writeEvent(), and PthrWriterBufPool< Writer, PoolSize >::~PthrWriterBufPool().

---