/home/bes3soft/bes3soft/Boss/7.0.2/dist/7.0.2/DistBoss/DistBossUtil/DistBossUtil-00-00-04/DistBossUtil/PthrReaderBufPool.h

Go to the documentation of this file.

#ifndef PTHR_READER_BUF_POOL_H
#define PTHR_READER_BUF_POOL_H

#include "DistBossUtil/AutoEnlargeBuffer.h"
#include "IRawFile/RawFileExceptions.h"
#include "IRawFile/IRawReader.h"
#include <semaphore.h>
#include <pthread.h>
#include <vector>
#include <string>

template <typename Reader, int PoolSize = 8>
class PthrReaderBufPool : public IRawReader
{
   public :

      PthrReaderBufPool(typename Reader::ReaderArgType& arg);
      virtual ~PthrReaderBufPool();

      inline const uint32_t*  nextEvent();
      inline const uint32_t*  currentEvent() const;
      inline uint32_t         runNo();
      inline std::string      currentFile();
      inline uint32_t         stat();


   private :

      static void*  thread_filling(void* arg);

      PthrReaderBufPool();  //stop default


   private :

      int                 m_inLoop;
      int                 m_outLoop;
      AutoEnlargeBuffer*  m_buf[PoolSize];

      Reader*             m_reader;

      pthread_t           m_tid;
      sem_t               m_semIn;
      sem_t               m_semOut;
      pthread_mutex_t     m_lock;

      sem_t               m_semSyn;

      // copy of possible exceptions
      RawFileException*   m_RawFileException;
};

#include "DistBossUtil/template/PthrReaderBufPool.cc"

#endif

---