ReaderRpc.h

Go to the documentation of this file.

#ifndef DISTBOSS_READER_RPC_H
#define DISTBOSS_READER_RPC_H
 
#include "DistBossUtil/PthrReaderBufPool.h"
#include "DistBossServer/RpcInterface.h"
#include "dis.hxx"
#include <string>
#include <map>
#include <vector>
#include <semaphore.h>
 
template<class Reader>
class ReaderRpc : virtual public DimRpc, virtual public RpcInterface
{
   public :
 
      ReaderRpc(const std::string& svrName, const std::vector<std::string>& fnames, int evtMax);
      virtual ~ReaderRpc();
 
      int wait_to_end();
 
 
   private :
 
      void rpcHandler();
 
      ReaderRpc();  //stop default
 
 
   private :
 
      int  m_evtDone;
      int  m_evtMax;
 
      int  m_stopFlag;
 
      int  m_inCode;
      int  m_outCode;
      const uint32_t* m_pEvt;
 
      PthrReaderBufPool<Reader>* m_freader;
 
      sem_t  m_sem;
 
      std::string m_svrName;
 
      std::map<int, AutoEnlargeBuffer*> m_evtBak;
};
 
#include "DistBossServer/template/ReaderRpc.cc"
 
#endif